rtcprecvthreadfcn.c

来自「linux环境下用纯c写的RTP协议的通用开发库」· C语言 代码 · 共 52 行

/*-------------------------------------------------------------------------
 * rtcprecvthreadfcn.c - rtcprecvthreadfcn
 *-------------------------------------------------------------------------
 */

#include <rtp.h>
#include <rtcp.h>
#include <pthread.h>
#include <signal.h>
#include <sys/time.h>
#include <util.h>

/*------------------------------------------------------------------------
 * rtcprecvthreadfcn - loop to receive RTCP packets.
 *------------------------------------------------------------------------
 */
void
rtcprecvthreadfcn(struct session *psn)
{

	/*
	 * Initialize by setting signal handler, then signal condition to
	 * indicate that initialization is complete. This code prevents
	 * rtpctl from sending a SIGTERM *before* the handler is installed.
	 */
	pthread_mutex_lock(&psn->sn_rtcpthrmutex);
  
	signal(SIGTERM, nullfcn);
	psn->sn_rtcpthrstat = THR_RUNNING;
	pthread_cond_signal(&psn->sn_cond);
  
	pthread_mutex_unlock(&psn->sn_rtcpthrmutex);
  
	while(TRUE) {

		rtcprecv(psn);

		/*
		 * Check if a SIGTERM has been received.
		 * If so, return.
		 */
		pthread_mutex_lock(&psn->sn_rtcpthrmutex);
		if (psn->sn_rtcpthrstat == THR_TERMINATE) {
			psn->sn_rtcpthrstat = THR_NOTRUNNING;
			pthread_cond_signal(&psn->sn_cond);
			pthread_mutex_unlock(&psn->sn_rtcpthrmutex);
			return;
		}
		pthread_mutex_unlock(&psn->sn_rtcpthrmutex);
	}
}