hust_rtpqueueapi.c

实现基于ip2022的MPEG2 TS的IP组播接收

/* rtpqueueapi.c - copypacket, copypacket2, rtpqinit, rtpqdestroy,
 * rtpqlock , rtpqunlock, rtpqclear, rtpqextracthead, rtpqinsert
 */

#include "hust_rtp.h"
///#include <pthread.h>
///#include <stdlib.h>
///#include <strings.h>

/*------------------------------------------------------------------------
 * copypacket - copy packet portion of rtpln to buffer
 *------------------------------------------------------------------------
 */
int
copypacket(struct rtpln *pln, char *buf, int buflen)
{

	buflen = min(buflen, pln->rln_len);
	memcpy(buf, &pln->rln_rtp, buflen);

	return buflen;
}

/*------------------------------------------------------------------------
 * copypacket2 - copy packet header and data into seperate buffers
 * Any header extension treated as data. Amounts copied returned via out
 * variables.
 *------------------------------------------------------------------------
 */
int
copypacket2(struct rtpln *pln, char *headbuf, int *headbuflen, char *databuf, int *databuflen)
{
	
	*headbuflen = min(*headbuflen, RTP_HEADER_LEN(&pln->rln_rtp));
	memcpy(headbuf, &pln->rln_rtp, *headbuflen);

	*databuflen = min(*databuflen, pln->rln_len - 
			  RTP_HEADER_LEN(&pln->rln_rtp));
	memcpy(databuf, RTP_DATA(&pln->rln_rtp), *databuflen);
	
	return OK;
}

/*------------------------------------------------------------------------
 * rtpqinit - initialize a new queue of RTP packetss
 *------------------------------------------------------------------------
 */
int
rtpqinit(struct rtpqueue *pq)
{
	memset(pq, 0, sizeof(struct rtpqueue));
	///pthread_mutex_init(&pq->rq_mutex, NULL);
	return OK;
}

/*------------------------------------------------------------------------
 * rtpqdestroy - destroy an RTP packet queue, freeing all packets
 *------------------------------------------------------------------------
 */
int
rtpqdestroy(struct rtpqueue *pq)
{
	///if (pthread_mutex_lock(&pq->rq_mutex) != 0)
		///return ERROR;

	_rtpqclear(pq);
	///pthread_mutex_unlock(&pq->rq_mutex);
	//pthread_mutex_destroy(&pq->rq_mutex);
	return OK;
}
////销毁一个rtpqueue，就是用_rtpqclear函数清除queue

/*------------------------------------------------------------------------
 * rtpqlock - lock a stream's queue
 *------------------------------------------------------------------------
 *//*
int
rtpqlock(struct session *psn, ssrc_t ssrc)
{

	struct stream *pstm;

	pstm = rtpgetstream(psn, ssrc);
	if (pstm == NULL)
		return ERROR;

	///if (pthread_mutex_lock(&pstm->stm_queue.rq_mutex) != 0) {
		///rtpreleasestream(psn, pstm);
		///return ERROR;
	///}

	rtpreleasestream(psn, pstm);
	return OK;
}*/
///

/*------------------------------------------------------------------------
 * rtpqunlock - unlock a stream's queue
 *------------------------------------------------------------------------
 *//*
int
rtpqunlock(struct session *psn, ssrc_t ssrc)
{

	struct stream *pstm;

	pstm = rtpgetstream(psn, ssrc);
	if (pstm == NULL)
		return ERROR;

	///pthread_mutex_unlock(&pstm->stm_queue.rq_mutex);
	rtpreleasestream(psn, pstm);
	return OK;
}
*/

/*------------------------------------------------------------------------
 * rtpqclear - free all packets from a stream's RTP queue
 *------------------------------------------------------------------------
 */
int
rtpqclear(struct session *psn, ssrc_t ssrc)
{

	struct stream *pstm;
	int		rv;

	pstm = rtpgetstream(psn, ssrc);
	if (pstm == NULL)
		return ERROR;

	/*if (pthread_mutex_unlock(&pstm->stm_queue.rq_mutex) != 0) {
		rtpreleasestream(psn, pstm);
		return ERROR;
	}*/

	rv = _rtpqclear(&pstm->stm_queue);
	///pthread_mutex_unlock(&pstm->stm_queue.rq_mutex);

	rtpreleasestream(psn, pstm);
	return rv;
}

/*------------------------------------------------------------------------
 * rtpqextracthead - remove and return pointer to first packet in queue
 *------------------------------------------------------------------------
 */
struct rtpln *
rtpqextracthead(struct session *psn, ssrc_t ssrc)
{
	
	struct stream	*pstm;
	struct rtpln	*pln;
      
	pstm = rtpgetstream(psn, ssrc);
	if (pstm == NULL)
		return NULL;
						
	///if (pthread_mutex_lock(&pstm->stm_queue.rq_mutex) != 0) {
	///	rtpreleasestream(psn, pstm);
	///	return NULL;
	///}

	pln = rtpqextract(&pstm->stm_queue, pstm->stm_queue.rq_head);
	///pthread_mutex_unlock(&pstm->stm_queue.rq_mutex);
	rtpreleasestream(psn, pstm);
	return pln;
}

/*------------------------------------------------------------------------
 * rtpqinsert - insert a packet into queue
 *------------------------------------------------------------------------
 */
int
rtpqinsert(struct session *psn, ssrc_t ssrc, struct rtpln *pln)
{

	struct stream *pstm;
	int		rv;

	pstm = rtpgetstream(psn, ssrc);
	if (pstm == NULL)
		return ERROR;

	/*if (pthread_mutex_lock(&pstm->stm_queue.rq_mutex) != 0) {
		rtpreleasestream(psn, pstm);
		return ERROR;
	}*/

	rv = _rtpqinsert(&pstm->stm_queue, pln, NULL);
	///pthread_mutex_unlock(&pstm->stm_queue.rq_mutex);
	rtpreleasestream(psn, pstm);

	return rv;
}