pdb.c File Reference

#include "config.h"
#include "config_unix.h"
#include "config_win32.h"
#include "debug.h"
#include "rtp/rtp.h"
#include "rtp/pbuf.h"
#include "tfrc.h"
#include "pdb.h"

Include dependency graph for pdb.c:

Go to the source code of this file.

Classes
struct	pdb
struct	s_pdb_node

Macros
#define	BTREE_MAGIC   0x10101010
#define	BTREE_NODE_MAGIC   0x01010101
#define	PDB_MAGIC   0x10101010
#define	PDB_NODE_MAGIC   0x01010101

Typedefs
typedef struct s_pdb_node	pdb_node_t

Functions
int	pdb_add (struct pdb *db, uint32_t ssrc)
static struct pdb_e *	pdb_create_item (uint32_t ssrc, volatile int *delay_ms)
static pdb_node_t *	pdb_delete_node (struct pdb *tree, pdb_node_t *z)
void	pdb_destroy (struct pdb **db_p)
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)
static void	pdb_insert_node (struct pdb *tree, pdb_node_t *z)
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)
static pdb_node_t *	pdb_min (pdb_node_t *x)
int	pdb_remove (struct pdb *db, uint32_t ssrc, struct pdb_e **item)
static pdb_node_t *	pdb_search (pdb_node_t *x, uint32_t key)
static pdb_node_t *	pdb_successor (pdb_node_t *x)
static void	pdb_validate (struct pdb *t)

Macro Definition Documentation

BTREE_MAGIC

#define BTREE_MAGIC   0x10101010

Definition at line 95 of file pdb.c.

Referenced by pdb_validate().

BTREE_NODE_MAGIC

#define BTREE_NODE_MAGIC   0x01010101

Definition at line 96 of file pdb.c.

Referenced by pdb_add().

PDB_MAGIC

#define PDB_MAGIC   0x10101010

Definition at line 72 of file pdb.c.

Referenced by pdb_init().

PDB_NODE_MAGIC

#define PDB_NODE_MAGIC   0x01010101

Definition at line 73 of file pdb.c.

Typedef Documentation

pdb_node_t

typedef struct s_pdb_node pdb_node_t

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_create_item()

static struct pdb_e * pdb_create_item ( uint32_t ssrc, volatile int * delay_ms )

static

Definition at line 277 of file pdb.c.

{
        struct pdb_e *p = malloc(sizeof(struct pdb_e));
        if (p != NULL) {
                p->creation_time = get_time_in_ns();
                p->ssrc = ssrc;
                p->sdes_cname = NULL;
                p->sdes_name = NULL;
                p->sdes_email = NULL;
                p->sdes_phone = NULL;
                p->sdes_loc = NULL;
                p->sdes_tool = NULL;
                p->sdes_note = NULL;
                p->decoder_state = NULL;
                p->decoder_state_deleter = NULL;
                p->pt = 255;
                p->playout_buffer = pbuf_init(delay_ms);
                p->tfrc_state = tfrc_init(p->creation_time);
        }
        return p;
}

References pdb_e::creation_time, pdb_e::decoder_state, pdb_e::decoder_state_deleter, get_time_in_ns(), pbuf_init(), pdb_e::playout_buffer, pdb_e::pt, pdb_e::sdes_cname, pdb_e::sdes_email, pdb_e::sdes_loc, pdb_e::sdes_name, pdb_e::sdes_note, pdb_e::sdes_phone, pdb_e::sdes_tool, pdb_e::ssrc, tfrc_init(), and pdb_e::tfrc_state.

Referenced by pdb_add().

Here is the call graph for this function:

pdb_delete_node()

static pdb_node_t * pdb_delete_node ( struct pdb * tree, pdb_node_t * z )

static

Definition at line 204 of file pdb.c.

{
        pdb_node_t *x, *y;
 
        pdb_validate(tree);
        if (z->left == NULL || z->right == NULL) {
                y = z;
        } else {
                y = pdb_successor(z);
        }
 
        if (y->left != NULL) {
                x = y->left;
        } else {
                x = y->right;
        }
 
        if (x != NULL) {
                x->parent = y->parent;
        }
 
        if (y->parent == NULL) {
                tree->root = x;
        } else if (y == y->parent->left) {
                y->parent->left = x;
        } else {
                y->parent->right = x;
        }
 
        z->key = y->key;
        z->data = y->data;
 
        tree->count--;
 
        pdb_validate(tree);
        return y;
}

References pdb::count, s_pdb_node::data, s_pdb_node::key, s_pdb_node::left, s_pdb_node::parent, pdb_successor(), pdb_validate(), s_pdb_node::right, and pdb::root.

Referenced by pdb_remove().

Here is the call graph for this function:

pdb_destroy()

void pdb_destroy

(

struct pdb **

db_p

)

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_insert_node()

static void pdb_insert_node ( struct pdb * tree, pdb_node_t * z )

static

Definition at line 175 of file pdb.c.

{
        pdb_node_t *x, *y;
 
        pdb_validate(tree);
        y = NULL;
        x = tree->root;
        while (x != NULL) {
                y = x;
                assert(z->key != x->key);
                if (z->key < x->key) {
                        x = x->left;
                } else {
                        x = x->right;
                }
        }
 
        z->parent = y;
        if (y == NULL) {
                tree->root = z;
        } else if (z->key < y->key) {
                y->left = z;
        } else {
                y->right = z;
        }
        tree->count++;
        pdb_validate(tree);
}

References pdb::count, s_pdb_node::key, s_pdb_node::left, s_pdb_node::parent, pdb_validate(), s_pdb_node::right, and pdb::root.

Referenced by pdb_add().

Here is the call graph for this function:

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_min()

static pdb_node_t * pdb_min ( pdb_node_t * x )

static

Definition at line 135 of file pdb.c.

{
        if (x == NULL) {
                return NULL;
        }
        while (x->left) {
                x = x->left;
        }
        return x;
}

References s_pdb_node::left.

Referenced by pdb_iter_init(), and pdb_successor().

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:

pdb_search()

static pdb_node_t * pdb_search ( pdb_node_t * x, uint32_t key )

static

Definition at line 163 of file pdb.c.

{
        while (x != NULL && key != x->key) {
                if (key < x->key) {
                        x = x->left;
                } else {
                        x = x->right;
                }
        }
        return x;
}

References key, s_pdb_node::key, s_pdb_node::left, and s_pdb_node::right.

Referenced by pdb_add(), pdb_get(), and pdb_remove().

pdb_successor()

static pdb_node_t * pdb_successor ( pdb_node_t * x )

static

Definition at line 146 of file pdb.c.

{
        pdb_node_t *y;
 
        if (x->right != NULL) {
                return pdb_min(x->right);
        }
 
        y = x->parent;
        while (y != NULL && x == y->right) {
                x = y;
                y = y->parent;
        }
 
        return y;
}

References s_pdb_node::parent, pdb_min(), and s_pdb_node::right.

Referenced by pdb_delete_node(), and pdb_iter_next().

Here is the call graph for this function:

pdb_validate()

static void pdb_validate ( struct pdb * t )

static

Definition at line 119 of file pdb.c.

{
        assert(t->magic == BTREE_MAGIC);
#ifdef DEBUG
        pdb_count = 0;
        if (t->root != NULL) {
                pdb_validate_node(t->root, NULL);
        }
        assert(pdb_count == t->count);
#endif
}

References BTREE_MAGIC, pdb::count, pdb::magic, and pdb::root.

Referenced by pdb_add(), pdb_delete_node(), pdb_destroy(), pdb_get(), pdb_insert_node(), and pdb_remove().