/* 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 *------------------------------------------------------------------------ */intcopypacket(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. *------------------------------------------------------------------------ */intcopypacket2(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 *------------------------------------------------------------------------ */intrtpqinit(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 *------------------------------------------------------------------------ */intrtpqdestroy(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 *------------------------------------------------------------------------ *//*intrtpqlock(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 *------------------------------------------------------------------------ *//*intrtpqunlock(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 *------------------------------------------------------------------------ */intrtpqclear(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 *------------------------------------------------------------------------ */intrtpqinsert(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;}