pdb.h File Reference

#include "tv.h"

Include dependency graph for pdb.h:

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

Go to the source code of this file.

Classes
struct	pdb_e

Typedefs
typedef void(*	decoder_state_deleter_t) (void *)
typedef void *	pdb_iter_t

Functions
int	pdb_add (struct pdb *db, uint32_t ssrc)
void	pdb_destroy (struct pdb **db)
void	pdb_destroy_item (struct pdb_e *item)
struct pdb_e *	pdb_get (struct pdb *db, uint32_t ssrc)
struct pdb *	pdb_init (volatile int *delay_ms)
void	pdb_iter_done (pdb_iter_t *it)
struct pdb_e *	pdb_iter_init (struct pdb *db, pdb_iter_t *it)
struct pdb_e *	pdb_iter_next (pdb_iter_t *it)
int	pdb_remove (struct pdb *db, uint32_t ssrc, struct pdb_e **item)

Typedef Documentation

decoder_state_deleter_t

typedef void(* decoder_state_deleter_t) (void *)

Deletes decoder for participant when the participant is deleted

Definition at line 70 of file pdb.h.

pdb_iter_t

typedef void* pdb_iter_t

Definition at line 106 of file pdb.h.

Function Documentation

pdb_add()

int pdb_add	(	struct pdb *	db,
		uint32_t	ssrc )

Definition at line 299 of file pdb.c.

{
        /* Add an item to the participant database, indexed by ssrc. */
        /* Returns 0 on success, 1 if the participant is already in  */
        /* the database, 2 for other failures.                       */
        pdb_node_t *x;
        struct pdb_e *i;
 
        pdb_validate(db);
        x = pdb_search(db->root, ssrc);
        if (x != NULL) {
                debug_msg("Item already exists - ssrc %x\n", ssrc);
                return 1;
        }
 
        i = pdb_create_item(ssrc, db->delay_ms);
        if (i == NULL) {
                debug_msg("Unable to create database entry - ssrc %x\n", ssrc);
                return 2;
        }
 
        x = (pdb_node_t *) malloc(sizeof(pdb_node_t));
        x->key = ssrc;
        x->data = i;
        x->parent = NULL;
        x->left = NULL;
        x->right = NULL;
        x->magic = BTREE_NODE_MAGIC;
        pdb_insert_node(db, x);
        debug_msg("Added participant %x\n", ssrc);
        return 0;
}

References BTREE_NODE_MAGIC, s_pdb_node::data, debug_msg, pdb::delay_ms, s_pdb_node::key, s_pdb_node::left, s_pdb_node::magic, s_pdb_node::parent, pdb_create_item(), pdb_insert_node(), pdb_search(), pdb_validate(), s_pdb_node::right, pdb::root, and pdb_e::ssrc.

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

Here is the call graph for this function:

pdb_destroy()

void pdb_destroy

(

struct pdb **

db

)

Definition at line 256 of file pdb.c.

{
        struct pdb *db = *db_p;
 
        pdb_validate(db);
        if (db->root != NULL) {
                pdb_iter_t it;
                struct pdb_e *cp = pdb_iter_init(db, &it);
                while (cp != NULL) {
                        struct pdb_e *item = NULL;
                        pdb_remove(db, cp->ssrc, &item);
                        cp = pdb_iter_next(&it);
                        pdb_destroy_item(item);
                }
                pdb_iter_done(&it);
        }
 
        free(db);
        *db_p = NULL;
}

References pdb_destroy_item(), pdb_iter_done(), pdb_iter_init(), pdb_iter_next(), pdb_remove(), pdb_validate(), pdb::root, and pdb_e::ssrc.

Referenced by rtp_video_rxtx::~rtp_video_rxtx(), audio_done(), and audio_init().

Here is the call graph for this function:

pdb_destroy_item()

void pdb_destroy_item

(

struct pdb_e *

item

)

Definition at line 370 of file pdb.c.

{
        if (item) {
                free(item->sdes_cname);
                free(item->sdes_name);
                free(item->sdes_email);
                free(item->sdes_phone);
                free(item->sdes_loc);
                free(item->sdes_tool);
                free(item->sdes_note);
                if (item->decoder_state_deleter && item->decoder_state) {
                        item->decoder_state_deleter(item->decoder_state);
                }
                pbuf_destroy(item->playout_buffer);
                tfrc_done(item->tfrc_state);
                free(item);
        }
}

References pbuf_destroy(), and tfrc_done().

Referenced by pdb_destroy(), and rtp_recv_callback().

Here is the call graph for this function:

pdb_get()

struct pdb_e * pdb_get	(	struct pdb *	db,
		uint32_t	ssrc )

Definition at line 332 of file pdb.c.

{
        /* Return a pointer to the item indexed by ssrc, or NULL if   */
        /* the item is not present in the database.                   */
        pdb_node_t *x;
 
        pdb_validate(db);
        x = pdb_search(db->root, ssrc);
        if (x != NULL) {
                return x->data;
        }
        return NULL;
}

References s_pdb_node::data, pdb_search(), pdb_validate(), pdb::root, and pdb_e::ssrc.

Referenced by process_sdes(), and rtp_recv_callback().

Here is the call graph for this function:

pdb_init()

struct pdb * pdb_init

(

volatile int *

delay_ms

)

Parameters

delay_ms

delay to be added to playback. Main reason is to give user a possibility to sync audio and video.

Definition at line 244 of file pdb.c.

{
        struct pdb *db = malloc(sizeof(struct pdb));
        if (db != NULL) {
                db->magic = PDB_MAGIC;
                db->count = 0;
                db->root = NULL;
                db->delay_ms = delay_ms;
        }
        return db;
}

References pdb::count, pdb::delay_ms, pdb::magic, PDB_MAGIC, and pdb::root.

Referenced by rtp_video_rxtx::rtp_video_rxtx(), audio_init(), and vidcap_rtsp_init().

pdb_iter_done()

void pdb_iter_done

(

pdb_iter_t *

it

)

Definition at line 412 of file pdb.c.

{
        *it = NULL;
}

Referenced by audio_receiver_process_message(), audio_receiver_thread(), pdb_destroy(), ultragrid_rtp_video_rxtx::receiver_loop(), ultragrid_rtp_video_rxtx::remove_display_from_decoders(), and vidcap_rtsp_thread().

pdb_iter_init()

struct pdb_e * pdb_iter_init	(	struct pdb *	db,
		pdb_iter_t *	it )

Definition at line 393 of file pdb.c.

{
        if (db->root == NULL) {
                return NULL;    /* The database is empty */
        }
        *it = (pdb_node_t *) pdb_min(db->root);
        return ((pdb_node_t *) *it)->data;
}

References s_pdb_node::data, pdb_min(), and pdb::root.

Referenced by audio_receiver_process_message(), audio_receiver_thread(), pdb_destroy(), ultragrid_rtp_video_rxtx::receiver_loop(), ultragrid_rtp_video_rxtx::receiver_process_messages(), ultragrid_rtp_video_rxtx::remove_display_from_decoders(), and vidcap_rtsp_thread().

Here is the call graph for this function:

pdb_iter_next()

struct pdb_e * pdb_iter_next

(

pdb_iter_t *

it

)

Definition at line 402 of file pdb.c.

{
        assert(*it != NULL);
        *it = (pdb_node_t *)pdb_successor((pdb_node_t *)*it);
        if (*it == NULL) {
                return NULL;
        }
        return ((pdb_node_t *) *it)->data;
}

References s_pdb_node::data, and pdb_successor().

Referenced by audio_receiver_process_message(), audio_receiver_thread(), pdb_destroy(), ultragrid_rtp_video_rxtx::receiver_loop(), ultragrid_rtp_video_rxtx::receiver_process_messages(), ultragrid_rtp_video_rxtx::remove_display_from_decoders(), and vidcap_rtsp_thread().

Here is the call graph for this function:

pdb_remove()

int pdb_remove	(	struct pdb *	db,
		uint32_t	ssrc,
		struct pdb_e **	item )

Definition at line 346 of file pdb.c.

{
        /* Remove the item indexed by ssrc. Return zero on success.   */
        pdb_node_t *x;
 
        pdb_validate(db);
        x = pdb_search(db->root, ssrc);
        if (x == NULL) {
                debug_msg("Item not on tree - ssrc %ul\n", ssrc);
                *item = NULL;
                return 1;
        }
 
        /* Note value that gets freed is not necessarily the the same as node
         * that gets removed from tree since there is an optimization to avoid
         * pointer updates in tree which means sometimes we just copy key and
         * data from one node to another.  
         */
        *item = x->data;
        x = pdb_delete_node(db, x);
        free(x);
        return 0;
}

References s_pdb_node::data, debug_msg, pdb_delete_node(), pdb_search(), pdb_validate(), pdb::root, and pdb_e::ssrc.

Referenced by pdb_destroy(), and rtp_recv_callback().

Here is the call graph for this function: