rtp_callback.h File Reference

#include "rtp/rtp.h"
#include "rtp/rtp_types.h"

Include dependency graph for rtp_callback.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	call_display_frame (void)
int	check_for_frame_completion (struct rtp *)
int	handle_with_buffer (struct rtp *session, rtp_event *e)
void	process_packet_for_display (char *)
void	rtp_recv_callback (struct rtp *session, rtp_event *e)

Function Documentation

call_display_frame()

void call_display_frame

(

void

)

check_for_frame_completion()

int check_for_frame_completion

(

struct rtp *

)

handle_with_buffer()

int handle_with_buffer	(	struct rtp *	session,
		rtp_event *	e )

process_packet_for_display()

void process_packet_for_display

(

char *

)

rtp_recv_callback()

void rtp_recv_callback	(	struct rtp *	session,
		rtp_event *	e )

Definition at line 212 of file rtp_callback.c.

{
        rtcp_app *pckt_app = (rtcp_app *) e->data;
        rtp_packet *pckt_rtp = (rtp_packet *) e->data;
        struct pdb *participants = (struct pdb *)rtp_get_userdata(session);
        struct pdb_e *state = pdb_get(participants, e->ssrc);
 
        switch (e->type) {
        case RX_RTP:
                tfrc_recv_data(state->tfrc_state, get_time_in_ns(), pckt_rtp->seq,
                               pckt_rtp->data_len + 40);
                if (pckt_rtp->data_len > 0) {   /* Only process packets that contain data... */
                        pbuf_insert(state->playout_buffer, pckt_rtp);
                }
                break;
        case RX_TFRC_RX:
                /* compute TCP friendly data rate */
                break;
        case RX_RTCP_START:
                break;
        case RX_RTCP_FINISH:
                break;
        case RX_SR:
                break;
        case RX_RR:
                process_rr(session, e);
                break;
        case RX_RR_EMPTY:
                break;
        case RX_SDES:
                process_sdes(participants, e->ssrc, (rtcp_sdes_item *) e->data);
                break;
        case RX_APP:
                if (strncmp(pckt_app->name, "RTT_", 4) == 0) {
                        assert(pckt_app->length == 3);
                        assert(pckt_app->subtype == 0);
//                      tfrc_recv_rtt(state->tfrc_state, get_time_in_ns(), ntohl(*((int *) pckt_app->data)));
                }
                break;
        case RX_BYE:
                break;
        case SOURCE_DELETED:
                {
                        struct pdb_e *pdb_item = NULL;
                        if(pdb_remove(participants, e->ssrc, &pdb_item) == 0) {
                                pdb_destroy_item(pdb_item);
                        }
                }
                break;
        case SOURCE_CREATED:
                pdb_add(participants, e->ssrc);
                break;
        case RR_TIMEOUT:
                break;
        default:
                debug_msg("Unknown RTP event (type=%d)\n", e->type);
        }
}

References rtp_event::data, debug_msg, get_time_in_ns(), rtcp_app::length, rtcp_app::name, pbuf_insert(), pdb_add(), pdb_destroy_item(), pdb_get(), pdb_remove(), process_rr(), process_sdes(), RR_TIMEOUT, rtp_get_userdata(), rtp_packet, RX_APP, RX_BYE, RX_RR, RX_RR_EMPTY, RX_RTCP_FINISH, RX_RTCP_START, RX_RTP, RX_SDES, RX_SR, RX_TFRC_RX, SOURCE_CREATED, SOURCE_DELETED, rtp_event::ssrc, state, rtcp_app::subtype, tfrc_recv_data(), and rtp_event::type.

Referenced by initialize_audio_network(), rtp_video_rxtx::initialize_network(), and vidcap_rtsp_init().

Here is the call graph for this function: