00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020 #ifndef rtpsession_priv_h
00021 #define rtpsession_priv_h
00022
00023 #include "ortp/rtpsession.h"
00024
00025 typedef enum {
00026 RTP_SESSION_RECV_SYNC=1,
00027 RTP_SESSION_FIRST_PACKET_DELIVERED=1<<1,
00028 RTP_SESSION_SCHEDULED=1<<2,
00029 RTP_SESSION_BLOCKING_MODE=1<<3,
00030 RTP_SESSION_RECV_NOT_STARTED=1<<4,
00031 RTP_SESSION_SEND_NOT_STARTED=1<<5,
00032 RTP_SESSION_IN_SCHEDULER=1<<6,
00033 RTP_SESSION_USING_EXT_SOCKETS=1<<7,
00034 RTP_SOCKET_CONNECTED=1<<8,
00035 RTCP_SOCKET_CONNECTED=1<<9,
00036 RTP_SESSION_USING_TRANSPORT=1<<10
00037 }RtpSessionFlags;
00038
00039 #define rtp_session_using_transport(s, stream) (((s)->flags & RTP_SESSION_USING_TRANSPORT) && (s->stream.tr != 0))
00040
00041 void rtp_session_update_payload_type(RtpSession * session, int pt);
00042 void rtp_putq(queue_t *q, mblk_t *mp);
00043 mblk_t * rtp_getq(queue_t *q, uint32_t ts, int *rejected);
00044 int rtp_session_rtp_recv(RtpSession * session, uint32_t ts);
00045 int rtp_session_rtcp_recv(RtpSession * session);
00046 int rtp_session_rtp_send (RtpSession * session, mblk_t * m);
00047 int rtp_session_rtcp_send (RtpSession * session, mblk_t * m);
00048
00049 void rtp_session_rtp_parse(RtpSession *session, mblk_t *mp, uint32_t local_str_ts, struct sockaddr *addr, socklen_t addrlen);
00050 void rtp_session_rtcp_parse(RtpSession *session, mblk_t *mp);
00051
00052 void rtp_session_dispatch_event(RtpSession *session, OrtpEvent *ev);
00053
00054 #endif