MNRTPdefs.h

Go to the documentation of this file.

/* Copyright (C) 2000 KOM/Darmstadt University of Technology
 *
 * You are allowed to use all other parts of the code under the following terms:
 *
 * For non-commercial use, code may be used in unmodified form provided
 * that this copyright notice and this permission notice appear in
 * supporting documentation.
 *
 * This software is provided "as is" and without any express or implied
 * warranties, including, without limitation, the implied warranty of
 * fitness for a particular purpose.
 *
 * The code may be subjected to the GNU General Public License, Version 2,
 * and re-distributed under the terms of this license.
 * As a special exception, permission is granted to link this code
 * with the Qt library and distribute executables, as long as you
 * follow the requirements of the GNU GPL in regard to all of the
 * software in the executable aside from Qt.
 *
 * Commercial use other than under the terms of the GNU General Public
 * License is allowed only after express negotiation of conditions
 * with the authors.
 */ 
#ifndef MNRTPDEFS_H
#define MNRTPDEFS_H
#include <assert.h>
#include <sys/time.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <stdio.h>
#include <dlfcn.h>
#include <net/if.h>

#ifdef sun
#include <sys/sockio.h>
#include <arpa/inet.h>
#endif

#include "mnstream.h"
#include "var_type.h"
#include "protected_var_type.h"

#include "MNRTPNetTypes.h"
#include "MNList.h"
#include "MNMutex.h"

class SDESItem
{
    u_int8 _type;              /* type of item (rtcp_sdes_type_t) */
    u_int8 _length;            /* length of item (in octets) */
    char*  data;             
public:
    SDESItem( const rtcp_sdes_item_t* item );
    SDESItem( u_int8 type, u_int8 len, char* d );
    SDESItem( const SDESItem& orig );

    virtual ~SDESItem( );

    SDESItem& operator=( const SDESItem& orig );

    void   reset( const rtcp_sdes_item_t* item );
    void   reset( u_int8 type, u_int8 len, char* d );
    void   flatten( rtcp_sdes_item_t* item );
    u_int8 type() const;
    u_int8 length() const;

    friend ostream& operator<<( ostream& ostr, const SDESItem& item );
};

/***********************************************************************
 * Class: sdes_list_item
 * Desc: This class encapsulates the replacement of LEDA lists with
 *       medianodes simpler implementation.
 ***********************************************************************/

struct sdes_list_item
{
  SDESItem sdes_item;

  int      prio;

  int send;
public:
    sdes_list_item( u_int8 type, u_int8 len, char* d );
    sdes_list_item( const sdes_list_item& orig );

    virtual ~sdes_list_item( );

    sdes_list_item& operator=( const sdes_list_item& orig );
    
    void write_item_to_buffer( u_int8* buffer, size_t len );
};

/**********************************************************************/
class SDESSchedule
    : private MNList<sdes_list_item*>
{
    MNMutex _lock;
public:
    SDESSchedule();

    ~SDESSchedule();

    void* first() {
        return MNList<sdes_list_item*>::first();
    }

    void next( void*& pix ) {
        pix = MNList<sdes_list_item*>::succ(pix);
    }

    sdes_list_item* operator()( void* pix ) {
        return MNList<sdes_list_item*>::inf(pix);
    }

    void append( sdes_list_item* p ) {
        MNList<sdes_list_item*>::push_back ( p );
    }

    void clear() {
        MNList<sdes_list_item*>::clear();
    }

    void del( void* pix ) {
        MNList<sdes_list_item*>::del_item(pix);
    }

    void lock();

    void unlock();

    void decrease_send_counters();

    size_t get_sdes_send_number( size_t& bytecount );

    void set_default_cname();

    void set_sdes( rtcp_sdes_type_t type, char* text, int prio );
};

/*************************************************************/

/* Errors */

enum RTP_RC
{
    RTP_OK                =  0,
    RTP_ERROR             = -1,
    RTP_NO_SESSION        = -2,
    RTP_NO_IP             = -3,
    RTP_IS_IP             = -4,
    RTP_NO_NUMBER         = -5,
    RTP_IS_MC             = -6,
    RTP_NO_MC             = -7,
    RTP_ALREADY_CONNECTED = -8,
    RTP_RUNNING           = -9,
    RTP_PORT_INVALID      = -10,
    RTP_BIND_ERROR        = -11,
    RTP_MC_AND_DIFF_PORT  = -12,
    RTP_SHORT_PACKET      = -13,

    RTCP_ERROR             = -50,
    RTCP_RUNNING           = -51,
    RTCP_ALREADY_CONNECTED = -52,
    RTCP_BUILD_ERROR       = -53,
    RTCP_BLD_LEN_ERR       = -54
};

#define RTCP_SSRC_NULL         0


/**************************************************************/

/* RTP ENUMS and defs */

enum rtp_math
{
    RTP_ABSOLUTE_INC = 0,
    RTP_INC          = 1
};


/* States of Senders received by us 
 * HEARED -> VALID -> ACTIVE <-> INACTIVE
 *   all -> OLD  or INVALID
 */
enum rtp_sr_state
{
  RTP_SR_HEARED     = 80,
  RTP_SR_INVALID    = 81,
  RTP_SR_OLD        = 82,
  RTP_SR_ACTIVE     = 83,         
  RTP_SR_INACTIVE   = 84          /* is also valid */
};

/* After 30 min a source should be timed out and deleted
 * from List (about 360 * 5 sec = 1800 sec = 30 min)
 */
#define RTCP_SOURCE_TIMEOUT 360

/* After 5 reports without having received a RTCP report,
 * a RTP_SR_HEARED source may be deleted
 */
#define RTCP_INACTIVE_TIMEOUT 5

#define RTP_CSRC_MAX       15

#define RTP_BUFFERSIZE         8192
#define RTCP_BUFFERSIZE        4096
#define RTCP_MAX_TU            2048

#define SDES_PRIO_MIN             1
#define SDES_PRIO_MAX            20

/* defs for RTCP stats */
// change (VK) testing for faster SR in the proxy
//#define RTCP_MIN_TIME             5.              /* Minimum scheduled time for a packet */
#define RTCP_MIN_TIME             1              /* Minimum scheduled time for a packet */
#define RTCP_SENDER_BW_FRACTION   0.25            /* sender bandwidth fraction */
#define RTCP_RECV_BW_FRACTION    (1-RTCP_SENDER_BW_FRACTION)
#define RTCP_SIZE_GAIN           (1. / 16.)       /* used for the estimator of the average packet size */
#define UDP_OVER_IP_SIZE          28              /* the UDP IP header */

/* makros oder inlines */

/* DEBUG functions */

#undef DEBUGJ
#ifdef DEBUGJ
/* all on */
#define DEBUG_RTPBASE(a) cerr << __FILE__ << " , " << __LINE__ << ": " << a
#define DEBUG_RTP(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a  
#define DEBUG_RTP_SEND(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
#define DEBUG_RTP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
#define DEBUG_RTCP(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a 
#define DEBUG_LIST(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a 
#define DEBUG_RTCP_SEND(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
#define DEBUG_RTCP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a

/* send and recv on */

/*
#define DEBUG_RTPBASE(a) 
#define DEBUG_RTP(a) 
#define DEBUG_RTP_SEND(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a 
#define DEBUG_RTP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a 
#define DEBUG_RTCP(a) 
#define DEBUG_LIST(a) 
#define DEBUG_RTCP_SEND(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a 
#define DEBUG_RTCP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
*/

/* custom */
/*
#define DEBUG_RTPBASE(a)
#define DEBUG_RTP(a)
#define DEBUG_RTP_SEND(a) 
#define DEBUG_RTP_RECV(a) 
#define DEBUG_RTCP(a)
#define DEBUG_LIST(a)
#define DEBUG_RTCP_SEND(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
#define DEBUG_RTCP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a
*/

#else
/* all off */

#define DEBUG_RTPBASE(a) 
#define DEBUG_RTP(a)  
#define DEBUG_RTP_SEND(a)  
#define DEBUG_RTP_RECV(a) 
#define DEBUG_RTCP(a) 
#define DEBUG_LIST(a) 
#define DEBUG_RTCP_SEND(a) 
// #define DEBUG_RTCP_RECV(a)
#endif

#define DEBUG_RTCP_RECV(a) cerr << __FILE__ << ", " << __LINE__ << ": " << a

#endif /* MNRTPDEFS_H */

---