Bayonne2 / Common C++ 2 Framework
Public Types | Public Member Functions | Static Public Member Functions | Protected Types | Protected Member Functions | Protected Attributes | Static Protected Attributes | Private Member Functions | Private Attributes | Static Private Attributes
QueueRTCPManager Class Referenceabstract
Generic RTCP control queues.

Adds generic management of RTCP functions to an RTP data queue. More...

#include <cqueue.h>

Inheritance diagram for QueueRTCPManager:
Inheritance graph
[legend]
Collaboration diagram for QueueRTCPManager:
Collaboration graph
[legend]

Public Types

  rtp.h cc++/rtp.h More...
 

Public Member Functions

  Get the most recent sender report received from a synchronization source. More...
 
  Ask for the info in the most recent receiver report about the local source received from the source given as parameter. More...
 
  Set how much time the stack will wait before deleting a synchronization source that has sent an RTCP BYE packet. More...
 
  This method sets the maximum end to end delay allowed. More...
 
 
 
void  setSendersControlFraction (float fraction)
  Specify the fraction of the total control bandwith to be dedicated to senders reports. More...
 
  Manually set the minimum interval for sending RTP compound packets. More...
 
uint32  getSendRTCPPacketCount () const
  Get the total number of RTCP packets sent until now. More...
 
void  setTypeOfService (Tos tos)
  Specify the kind of service the application expects to use. More...
 
void  enableStack ()
  Enable packet queue processing in the stack. More...
 
void  disableStack ()
  Disable packet queue processing in the stack. More...
 
bool  isActive () const
  Get active connection state flag. More...
 
uint32  getCurrentTimestamp () const
  Get the timestamp that should be given for a packet whose payload sampling instant corresponds to the current system time. More...
 
void  setSessionBandwidth (uint32 bw)
  Specify the bandwidth of the current session. More...
 
uint32  getDefaultSessionBandwidth () const
 
uint32  getSessionBandwidth () const
 
void  setTimeclock ()
  Set the packet timeclock for synchronizing timestamps. More...
 
timeout_t  getTimeclock () const
  Get the packet timeclock for synchronizing timestamps. More...
 
 
 
const AppDataUnitgetData (uint32 stamp, const SyncSource *src=NULL)
  Retreive data from a specific timestamped packet if such a packet is currently available in the receive buffer. More...
 
bool  isWaiting (const SyncSource *src=NULL) const
  Determine if packets are waiting in the reception queue. More...
 
uint32  getFirstTimestamp (const SyncSource *src=NULL) const
  Get timestamp of first packet waiting in the queue. More...
 
void  setMinValidPacketSequence (uint8 packets)
  When receiving packets from a new source, it may be convenient to reject a first few packets before we are really sure the source is valid. More...
 
 
uint8  getMinValidPacketSequence () const
  Get the minimun number of consecutive packets that must be received from a source before accepting its data packets. More...
 
void  setMaxPacketMisorder (uint16 packets)
 
uint16  getDefaultMaxPacketMisorder () const
 
uint16  getMaxPacketMisorder () const
 
void  setMaxPacketDropout (uint16 packets)
  It also prevents packets sent after a restart of the source being immediately accepted. More...
 
uint16  getDefaultMaxPacketDropout () const
 
uint16  getMaxPacketDropout () const
 
  Set input queue CryptoContext. More...
 
  Remove input queue CryptoContext. More...
 
  Get an input queue CryptoContext identified by SSRC. More...
 
size_t  getDefaultMaxRecvPacketSize () const
 
size_t  getMaxRecvPacketSize () const
 
void  setMaxRecvPacketSize (size_t maxsize)
 
bool  setPayloadFormat (const PayloadFormat &pf)
  Set the payload format in use, for timing and payload type identification purposes. More...
 
uint32  getLocalSSRC () const
 
uint32  getCurrentRTPClockRate () const
  Get the clock rate in RTP clock units (for instance, 8000 units per second for PCMU, or 90000 units per second for MP2T). More...
 
 
timeval  getInitialTime () const
 
void  setSDESItem (Participant *part, SDESItemType item, const std::string &val)
 
void  setPRIVPrefix (Participant *part, const std::string val)
 
bool  addDestination (const InetHostAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)
 
bool  addDestination (const InetMcastAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)
 
bool  forgetDestination (const InetHostAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)
 
bool  forgetDestination (const InetMcastAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)
 
void  addContributor (uint32 csrc)
  Add csrc as the CSRC identifier of a new contributor. More...
 
bool  removeContributor (uint32 csrc)
  Remove CSRC from the list of contributors. More...
 
bool  isSending () const
  Determine if outgoing packets are waiting to send. More...
 
void  putData (uint32 stamp, const unsigned char *data=NULL, size_t len=0)
  This is used to create a data packet in the send queue. More...
 
void  sendImmediate (uint32 stamp, const unsigned char *data=NULL, size_t len=0)
  This is used to create a data packet and send it immediately. More...
 
void  setPadding (uint8 paddinglen)
  Set padding. More...
 
void  setMark (bool mark)
  Set marker bit for the packet in which the next data provided will be send. More...
 
bool  getMark () const
  Get wheter the mark bit will be set in the next packet. More...
 
size_t  setPartial (uint32 timestamp, unsigned char *data, size_t offset, size_t max)
  Set partial data for an already queued packet. More...
 
 
  Set the default scheduling timeout to use when no data packets are waiting to be sent. More...
 
 
  Set the "expired" timer for expiring packets pending in the send queue which have gone unsent and are already "too late" to be sent now. More...
 
 
uint32  getSendPacketCount () const
  Get the total number of packets sent so far. More...
 
uint32  getSendOctetCount () const
  Get the total number of octets (payload only) sent so far. More...
 
uint16  getSequenceNumber () const
  Get the sequence number of the next outgoing packet. More...
 
  Set ouput queue CryptoContext. More...
 
  Remove output queue CryptoContext. More...
 
  Get an output queue CryptoContext identified by SSRC. More...
 
 
void  setMaxSendSegmentSize (size_t size)
  Set maximum payload segment size before fragmenting sends. More...
 
 

Static Public Member Functions

static size_t  getDefaultMembersSize ()
 

Protected Types

enum   { defaultPathMTU = 1500 }
 

Protected Member Functions

 
 
virtual  ~QueueRTCPManager ()
 
 
void  setControlBandwidth (float fraction)
 
float  getControlBandwidth () const
 
  Build and send RTCP packets following timing rules (including the "timer reconsideration" algorithm). More...
 
  Process incoming RTCP packets pending in the control reception socket. More...
 
bool  checkSSRCInRTCPPkt (SyncSourceLink &sourceLink, bool is_new, InetAddress &na, tpport_t tp)
  Appy collision and loop detection and correction algorithm when receiving RTCP packets. More...
 
 
virtual void  onGotSR (SyncSource &source, SendReport &SR, uint8 blocks)
  Plug-in for processing (acquire information carried in) an incoming RTCP Sender Report. More...
 
virtual void  onGotRR (SyncSource &source, RecvReport &RR, uint8 blocks)
  Plug-in for processing (acquire information carried in) an incoming RTCP Receiver Report. More...
 
bool  onGotSDES (SyncSource &source, RTCPPacket &pkt)
 
virtual bool  onGotSDESChunk (SyncSource &source, SDESChunk &chunk, size_t len)
  Plug-in for handling of SDES chunks. More...
 
virtual void  onGotAPP (SyncSource &, RTCPCompoundHandler::APPPacket &, size_t)
  Plug-in for handling of APP (application specific) RTCP packets. More...
 
timeval  getRTCPCheckInterval ()
 
uint32  getLastSendPacketCount () const
  Get the number of data packets sent at the time the last SR was generated. More...
 
void  setPrevMembersNum (uint32 n)
 
uint32  getPrevMembersCount () const
 
size_t  dispatchBYE (const std::string &reason)
  This method is used to send an RTCP BYE packet. More...
 
size_t  sendControlToDestinations (unsigned char *buffer, size_t len)
 
virtual void  timerTick ()
  A plugin point for timer tick driven events. More...
 
void  renewLocalSSRC ()
 
void  endQueue ()
  This method ends the queue. More...
 
virtual bool  isPendingData (microtimeout_t timeout)=0
  This function is used to check for and schedule against arriving packets based on the derived connection type. More...
 
bool  checkSSRCInIncomingRTPPkt (SyncSourceLink &sourceLink, bool is_new, InetAddress &na, tpport_t tp)
  Apply collision and loop detection and correction algorithm when receiving RTP data packets. More...
 
void  setSourceExpirationPeriod (uint8 intervals)
  Set the number of RTCP intervals that the stack will wait to change the state of a source from stateActive to stateInactive, or to delete the source after being in stateInactive. More...
 
virtual size_t  takeInDataPacket ()
  This function is used by the service thread to process the next incoming packet and place it in the receive list. More...
 
IncomingDataQueue::IncomingRTPPktLinkgetWaiting (uint32 timestamp, const SyncSource *src=NULL)
  This is used to fetch a packet in the receive queue and to expire packets older than the current timestamp. More...
 
bool  recordReception (SyncSourceLink &srcLink, const IncomingRTPPkt &pkt, const timeval recvtime)
  Log reception of a new RTP packet from this source. More...
 
void  recordExtraction (const IncomingRTPPkt &pkt)
  Log extraction of a packet from this source from the scheduled reception queue. More...
 
 
virtual void  onNewSyncSource (const SyncSource &)
  Virtual called when a new synchronization source has joined the session. More...
 
virtual bool  onRTPPacketRecv (IncomingRTPPkt &)
  A virtual function to support parsing of arriving packets to determine if they should be kept in the queue and to dispatch events. More...
 
virtual void  onExpireRecv (IncomingRTPPkt &)
  A hook to filter packets in the receive queue that are being expired. More...
 
virtual bool  onSRTPPacketError (IncomingRTPPkt &pkt, int32 errorCode)
  A hook that gets called if the decoding of an incoming SRTP was erroneous. More...
 
bool  insertRecvPacket (IncomingRTPPktLink *packetLink)
  Insert a just received packet in the queue (both general and source specific queues). More...
 
virtual size_t  recvData (unsigned char *buffer, size_t length, InetHostAddress &host, tpport_t &port)=0
  This function performs the physical I/O for reading a packet from the source. More...
 
virtual size_t  getNextDataPacketSize () const =0
 
void  setLocalSSRC (uint32 ssrc)
 
uint32  getLocalSSRCNetwork () const
 
 
SyncSourceLinkgetLink (const SyncSource &source) const
 
bool  isMine (const SyncSource &source) const
  Get whether a synchronization source is recorded in this membership controller. More...
 
bool  isRegistered (uint32 ssrc)
  Returns whether there is already a synchronizacion source with "ssrc" SSRC identifier. More...
 
SyncSourceLinkgetSourceBySSRC (uint32 ssrc, bool &created)
  Get the description of a source by its ssrc identifier. More...
 
bool  BYESource (uint32 ssrc)
  Mark the source identified by ssrc as having sent a BYE packet. More...
 
bool  removeSource (uint32 ssrc)
  Remove the description of the source identified by ssrc More...
 
 
 
uint32  getMembersCount ()
 
void  setMembersCount (uint32 n)
 
uint32  getSendersCount ()
 
void  setLink (SyncSource &source, void *link)
 
void  setParticipant (SyncSource &source, Participant &p)
 
void  setState (SyncSource &source, SyncSource::State ns)
 
void  setSender (SyncSource &source, bool active)
 
 
 
void  setNetworkAddress (SyncSource &source, InetAddress addr)
 
 
 
 
 
 
void  addConflict (const InetAddress &na, tpport_t dtp, tpport_t ctp)
 
  This is used to write the RTP data packet to one or more destinations. More...
 
  This computes the timeout period for scheduling transmission of the next packet at the "head" of the send buffer. More...
 
size_t  dispatchDataPacket ()
  This function is used by the service thread to process the next outgoing packet pending in the sending queue. More...
 
void  setNextSeqNum (uint32 seqNum)
  For thoses cases in which the application requires a method to set the sequence number for the outgoing stream (such as for implementing the RTSP PLAY command). More...
 
uint32  getCurrentSeqNum (void)
 
void  setInitialTimestamp (uint32 ts)
 
uint32  getInitialTimestamp ()
 
 
virtual void  setControlPeer (const InetAddress &host, tpport_t port)
 
bool  isSingleDestination () const
  Get whether there is only a destination in the list. More...
 
 
void  lockDestinationList () const
 
void  unlockDestinationList () const
 
void  writeLockDestinationList () const
 
bool  addDestinationToList (const InetAddress &ia, tpport_t data, tpport_t control)
  Locks the object before modifying it. More...
 
bool  removeDestinationFromList (const InetAddress &ia, tpport_t dataPort, tpport_t controlPort)
  Locks the object before modifying it. More...
 
void  setPathMTU (uint16 mtu)
 
uint16  getPathMTU ()
 
bool  checkCompoundRTCPHeader (size_t len)
  Perform RTCP compound packet header validity check as specified in draft-ietv-avt-rtp-new. More...
 

Protected Attributes

 
 
 
 
 
uint16  maxPacketDropout
 
 
 
 
std::list< CryptoContext * >  cryptoContexts
 
std::list< CryptoContext * >  cryptoContexts
 
 
 
std::list< TransportAddress * >  destList
 
unsigned char *  rtcpSendBuffer
 
unsigned char *  rtcpRecvBuffer
 

Static Protected Attributes

static const uint8  defaultMinValidPacketSequence
 
static const uint16  defaultMaxPacketMisorder
 
static const uint16  defaultMaxPacketDropout
 
static const size_t  defaultMembersSize
 
static const size_t  defaultMembersHashSize
 
static const uint32  SEQNUMMOD
 

Private Member Functions

 
 
  Posting of RTCP messages. More...
 
  For picking up incoming RTCP packets if they are waiting. More...
 
virtual timeval  computeRTCPInterval ()
  Computes the interval for sending RTCP compound packets, based on the average size of RTCP packets sent and received, and the current estimated number of participants in the session. More...
 
  Choose which should be the type of the next SDES item sent. More...
 
virtual void  onSSRCCollision (const SyncSource &)
  Plug-in for SSRC collision handling. More...
 
virtual bool  end2EndDelayed (IncomingRTPPktLink &p)
  Virtual reimplemented from RTPDataQueue. More...
 
virtual void  onGotRRSRExtension (unsigned char *, size_t)
  Plug-in for processing of SR/RR RTCP packet profile-specific extensions (third part of SR reports or second part of RR reports). More...
 
virtual void  onGotGoodbye (const SyncSource &, const std::string &)
  A plugin point for goodbye message. More...
 
bool  getBYE (RTCPPacket &pkt, size_t &pointer, size_t len)
  Process a BYE packet just received and identified. More...
 
uint8  packReportBlocks (RRBlock *blocks, uint16 &len, uint16 &available)
 
void  packSDES (uint16 &len)
  Builds an SDES RTCP packet. More...
 
void  updateAvgRTCPSize (size_t len)
  This must be called in order to update the average RTCP compound packet size estimation when: More...
 
  Apply reverse reconsideration adjustment to timing parameters when receiving BYE packets and not waiting to send a BYE. More...
 
 
void  expireSSRCs ()
  Purge sources that do not seem active any more. More...
 
void  getOnlyBye ()
  To be executed when whe are leaving the session. More...
 
void  setSDESItem (Participant *part, SDESItemType type, const char *const value, size_t len)
  Set item value from a string without null termination (as it is transported in RTCP packets). More...
 
void  setPRIVPrefix (Participant *part, const char *const value, size_t len)
  Set PRIV item previx value from a string without null termination (as it is transported in RTCP packets). More...
 
virtual uint16  networkHeaderSize ()
  For certain control calculations in RTCP, the size of the underlying network and transport protocols is needed. More...
 
virtual uint16  transportHeaderSize ()
  For certain control calculations in RTCP, the size of the underlying network and transport protocols is needed. More...
 
 
virtual size_t  sendControl (const unsigned char *const buffer, size_t len)=0
 
virtual size_t  recvControl (unsigned char *buffer, size_t len, InetHostAddress &na, tpport_t &tp)=0
 
virtual bool  isPendingControl (microtimeout_t timeout)=0
 

Private Attributes

volatile bool  controlServiceActive
 
float  controlBwFract
 
 
 
uint32  ctrlSendCount
 
uint16  lowerHeadersSize
 
 
struct {
   timeval   rtcpTp
 
   timeval   rtcpTc
 
   timeval   rtcpTn
 
   uint32   rtcpPMembers
 
 
bool  rtcpWeSent
 
uint16  rtcpAvgSize
 
bool  rtcpInitial
 
timeval  rtcpLastCheck
 
timeval  rtcpCheckInterval
 
timeval  rtcpNextCheck
 
 
 
 
 
 

Static Private Attributes

 
static const SDESItemType  lastSchedulable
 
 
static const uint16  TIMEOUT_MULTIPLIER
 
static const double  RECONSIDERATION_COMPENSATION
 

Detailed Description

Adds generic management of RTCP functions to an RTP data queue.

Extends an RTP data i/o queue adding management of RTCP functions:

Provide feedback on the quality of the data distribution.

Convey the CNAME (persistent transport-level identifier) for every RTP source.

Control the sending rate of RTCP packets

Convey minimal control information about the participants

This class implements generic RTCP behaviour (as specified in RFC 1889/draft-ietf-avt-rtp-new) and may be specialized for specific profiles (see AVPQueue) or particular RTCP extensions.

Author
Federico Montesino Pouzols fedem.nosp@m.p@al.nosp@m.tern..nosp@m.org

Definition at line 80 of file cqueue.h.

Member Enumeration Documentation

anonymous enum
protectedinherited
Enumerator
defaultPathMTU 

Definition at line 333 of file rtcppkt.h.

inherited

rtp.h cc++/rtp.h

Type of network service the application uses.

If the application uses enhanced network service, for instance Integrated Services or Differentiated Services, it has not to ensure fair competition with TCP, provided that the requested service is actually being delivered. Whenever the application uses best-effort service or the requested enhanced service is not actually being delivered, it has to ensure fair competition with TCP. By default, best-effot is assumed.

Note
Although not required, RTP packets are always sent on top of UDP segments. No other underlying transport protocol is supported at present.
Todo:
implement fair competition with tcp
Enumerator
tosBestEffort 

Best-effort network service.

tosEnhanced 

Enhanced network service.

Definition at line 101 of file ioqueue.h.

Constructor & Destructor Documentation

QueueRTCPManager::QueueRTCPManager ( uint32  size = RTPDataQueue::defaultMembersHashSize ,
)
protected
QueueRTCPManager::QueueRTCPManager ( uint32  ssrc,
)
protected
virtual QueueRTCPManager::~QueueRTCPManager ( )
protectedvirtual
QueueRTCPManager::QueueRTCPManager ( const QueueRTCPManagero )
private

Member Function Documentation

void ConflictHandler::addConflict ( const InetAddressna,
tpport_t  dtp,
tpport_t  ctp 
)
inherited
void OutgoingDataQueue::addContributor ( uint32  csrc )
inherited

Add csrc as the CSRC identifier of a new contributor.

This method adds the CSRC identifier to a list of contributors that will be inserted in every packet enqueued from now on.

bool OutgoingDataQueue::addDestination ( const InetHostAddressia,
tpport_t  dataPort = DefaultRTPDataPort ,
tpport_t  controlPort = 0 
)
inherited
bool OutgoingDataQueue::addDestination ( const InetMcastAddressia,
tpport_t  dataPort = DefaultRTPDataPort ,
tpport_t  controlPort = 0 
)
inherited
bool DestinationListHandler::addDestinationToList ( const InetAddressia,
tpport_t  data,
tpport_t  control 
)
protectedinherited

Locks the object before modifying it.

void ApplicationHandler::addParticipant ( RTPApplicationapp,
Participantpart 
)
inlineinherited

Definition at line 212 of file iqueue.h.

SyncSourcesIterator IncomingDataQueue::begin ( )
inlineinherited

Definition at line 938 of file iqueue.h.

bool MembershipBookkeeping::BYESource ( uint32  ssrc )
protectedinherited

Mark the source identified by ssrc as having sent a BYE packet.

It is not deleted until a timeout expires, so that in case some packets from this source arrive a bit later the source is not inserted again in the table of known sources.

Returns
true if the source had been previously identified. false if it was not in the table of known sources.
bool RTCPCompoundHandler::checkCompoundRTCPHeader ( size_t  len )
protectedinherited

Perform RTCP compound packet header validity check as specified in draft-ietv-avt-rtp-new.

This method follows appendix A.2. Correct version, payload type, padding bit and length of every RTCP packet in the compound are verified.

Parameters
len length of the RTCP compound packet in the reception buffer
Returns
whether the header is valid.
bool IncomingDataQueue::checkSSRCInIncomingRTPPkt ( SyncSourceLinksourceLink,
bool  is_new,
InetAddressna,
tpport_t  tp 
)
protectedinherited

Apply collision and loop detection and correction algorithm when receiving RTP data packets.

Follows section 8.2 in draft-ietf-avt-rtp-new.

Parameters
sourceLink link to the source object.
is_new whether the source has been just recorded.
na data packet network address.
tp data packet source transport port.
Returns
whether the packet must not be discarded.
bool QueueRTCPManager::checkSSRCInRTCPPkt ( SyncSourceLinksourceLink,
bool  is_new,
InetAddressna,
tpport_t  tp 
)
protected

Appy collision and loop detection and correction algorithm when receiving RTCP packets.

Follows section 8.2 in draft-ietf-avp-rtp-new.

Parameters
sourceLink link to the source object.
is_new whether the source has been just recorded.
na RTCP packet network address.
tp RTCP packet source transport port.
Returns
whether the packet must not be discarded.
virtual timeval QueueRTCPManager::computeRTCPInterval ( )
privatevirtual

Computes the interval for sending RTCP compound packets, based on the average size of RTCP packets sent and received, and the current estimated number of participants in the session.

Note
This currently follows the rules in section 6 of RFC 3550
Todo:
make it more flexible as recommended in the draft. For now, we have setMinRTCPInterval.
Returns
interval for sending RTCP compound packets
void QueueRTCPManager::controlReceptionService ( )
protected

Process incoming RTCP packets pending in the control reception socket.

void QueueRTCPManager::controlTransmissionService ( )
protected

Build and send RTCP packets following timing rules (including the "timer reconsideration" algorithm).

void RTPDataQueue::disableStack ( )
inlineinherited

Disable packet queue processing in the stack.

Definition at line 132 of file ioqueue.h.

size_t QueueRTCPManager::dispatchBYE ( const std::string &  reason )
protectedvirtual

This method is used to send an RTCP BYE packet.

An RTCP BYE packet is sent when one of the the following circumstances occur:

  • when leaving the session
  • when we have detected that another synchronization source in the same session is using the same SSRC identifier as us.

Try to post a BYE message. It will send a BYE packet as long as at least one RTP or RTCP packet has been sent before. If the number of members in the session is more than 50, the algorithm described in section 6.3.7 of RFC 3550 is applied in order to avoid a flood of BYE messages.

Parameters
reason reason to specify in the BYE packet.

Reimplemented from RTPQueueBase.

size_t QueueRTCPManager::dispatchControlPacket ( )
private

Posting of RTCP messages.

Returns
std::size_t number of octets sent
size_t OutgoingDataQueue::dispatchDataPacket ( )
protectedinherited

This function is used by the service thread to process the next outgoing packet pending in the sending queue.

Returns
number of bytes sent. 0 if silent, <0 if error.
void OutgoingDataQueue::dispatchImmediate ( OutgoingRTPPktpacket )
protectedinherited

This is used to write the RTP data packet to one or more destinations.

It is used by both sendImmediate and by dispatchDataPacket.

Parameters
RTP packet to send.
void RTPDataQueue::enableStack ( )
inlineinherited

Enable packet queue processing in the stack.

This method will not any thread of execution.

Definition at line 126 of file ioqueue.h.

SyncSourcesIterator IncomingDataQueue::end ( void  )
inlineinherited

Definition at line 941 of file iqueue.h.

virtual bool QueueRTCPManager::end2EndDelayed ( IncomingRTPPktLinkp )
privatevirtual

Virtual reimplemented from RTPDataQueue.

Reimplemented from IncomingDataQueue.

void RTPDataQueue::endQueue ( )
protectedinherited

This method ends the queue.

void QueueRTCPManager::endQueueRTCPManager ( )
protected
void QueueRTCPManager::expireSSRCs ( )
private

Purge sources that do not seem active any more.

Note
MUST be perform at least every RTCP transmission interval
Todo:
implement it. It may be dangerous and anyway should be optional.
bool OutgoingDataQueue::forgetDestination ( const InetHostAddressia,
tpport_t  dataPort = DefaultRTPDataPort ,
tpport_t  controlPort = 0 
)
inherited
bool OutgoingDataQueue::forgetDestination ( const InetMcastAddressia,
tpport_t  dataPort = DefaultRTPDataPort ,
tpport_t  controlPort = 0 
)
inherited
const RTPApplication& QueueRTCPManager::getApplication ( )
inlineprotected

Definition at line 193 of file cqueue.h.

bool QueueRTCPManager::getBYE ( RTCPPacketpkt,
size_t &  pointer,
size_t  len 
)
private

Process a BYE packet just received and identified.

Parameters
pkt previously identified RTCP BYE packet
pointer octet number in the RTCP reception buffer where the packet is stored
len total length of the compount RTCP packet the BYE packet to process is contained
Bug:
if the bye packet contains several SSRCs, eventSourceLeaving is only called for the last one
float QueueRTCPManager::getControlBandwidth ( ) const
inlineprotected

Definition at line 201 of file cqueue.h.

PayloadType RTPQueueBase::getCurrentPayloadType ( ) const
inlineinherited

Definition at line 201 of file queuebase.h.

uint32 RTPQueueBase::getCurrentRTPClockRate ( ) const
inlineinherited

Get the clock rate in RTP clock units (for instance, 8000 units per second for PCMU, or 90000 units per second for MP2T).

This value depends on what payload format has been selected using setPayloadFormat().

Returns
clock rate in RTP clock units.

Definition at line 198 of file queuebase.h.

uint32 OutgoingDataQueue::getCurrentSeqNum ( void  )
inlineprotectedinherited

Definition at line 525 of file oqueue.h.

uint32 RTPDataQueue::getCurrentTimestamp ( ) const
inherited

Get the timestamp that should be given for a packet whose payload sampling instant corresponds to the current system time.

The timestamp applications should provide for each packet represents the sampling instant of its payload and should not be a reading of the system clock. Nevertheless, the internal operation of the RTP stack relies on the accuracy of the provided timestamp, since several computations assume that there is a certain degree of correspondence between the timestamp and the system clock.

It is recommended that applications use this method in order to periodically adjust the RTP timestamp.

In particular, it is advisable getting the timestamp corresponding to the first sampling instant or any instant after a period of inactivity through a call to this method.

Applications should use the nominal sampling or any other value provided by the coder in order to compute the next timestamps with minimum computational requirement.

For instance, an application using an RTP profile that specifies a fixed sampling rate of 8 Khz with eight bits per sample, continuously transmitting audio blocks 80 octets long, would transmit 100 packets every second. Every packet would carry a timestamp 80 units greater than the previous one. So, the first timestamp would be obtained from this method, whereas the following ones would be computed adding 80 every time. Also the timestamp should be increased for every block whether it is put in the queue or dropped.

The aforementioned increment can be obtained from the RTPDataQueue::getTimestampIncrement() method rather than computing it by hand in the application.

Note
Frame based applications must follow a specific timestamping method, probably specified in a profile.
You should take into account that by default ccRTP assumes that the application begins sampling at the queue creation time. Moreover, the first sampling instant is assigned a "user visible" timestamp of 0, although the RTP stack will then add internally a ramdom offset unknown to the application. That is to say, the application may count samples from 0 in order to get the timestamp for the next packet, provided that the first sampling instant is the same as the queue creation time. Nevertheless, this simpler way of starting will not be as accurate as it would be if the application got at least the first timestamp through getCurrentTimestamp. We provide this option since ccRTP interface is evolving, but we admit that it is ugly, we could remove this option or even replace uint32 timestamps with a restrictively regulated object; suggestions are gladly welcomed
const AppDataUnit* IncomingDataQueue::getData ( uint32  stamp,
const SyncSourcesrc = NULL 
)
inherited

Retreive data from a specific timestamped packet if such a packet is currently available in the receive buffer.

Parameters
stamp Data unit timestamp.
src Optional synchronization source selector.
Returns
data retrieved from the reception buffer.
Return values
null pointer if no packet with such timestamp is available.
microtimeout_t QueueRTCPManager::getDefaultEnd2EndDelay ( ) const
inline

Definition at line 137 of file cqueue.h.

microtimeout_t OutgoingDataQueue::getDefaultExpireTimeout ( ) const
inlineinherited

Definition at line 371 of file oqueue.h.

uint16 IncomingDataQueue::getDefaultMaxPacketDropout ( ) const
inlineinherited

Definition at line 1035 of file iqueue.h.

uint16 IncomingDataQueue::getDefaultMaxPacketMisorder ( ) const
inlineinherited

Definition at line 1018 of file iqueue.h.

size_t IncomingDataQueueBase::getDefaultMaxRecvPacketSize ( ) const
inlineinherited

Definition at line 301 of file queuebase.h.

size_t OutgoingDataQueueBase::getDefaultMaxSendSegmentSize ( )
inlineinherited

Definition at line 262 of file queuebase.h.

size_t MembershipBookkeeping::getDefaultMembersHashSize ( )
inlineinherited

Definition at line 309 of file iqueue.h.

static size_t IncomingDataQueue::getDefaultMembersSize ( )
inlinestaticinherited

Definition at line 1045 of file iqueue.h.

uint8 IncomingDataQueue::getDefaultMinValidPacketSequence ( ) const
inlineinherited

Definition at line 1002 of file iqueue.h.

microtimeout_t OutgoingDataQueue::getDefaultSchedulingTimeout ( ) const
inlineinherited

Definition at line 357 of file oqueue.h.

uint32 RTPDataQueue::getDefaultSessionBandwidth ( ) const
inlineinherited

Definition at line 218 of file ioqueue.h.

microtimeout_t QueueRTCPManager::getEnd2EndDelay ( ) const
inline

Definition at line 141 of file cqueue.h.

microtimeout_t OutgoingDataQueue::getExpireTimeout ( ) const
inlineinherited

Definition at line 385 of file oqueue.h.

SyncSourceLink* MembershipBookkeeping::getFirst ( void  )
inlineprotectedinherited

Definition at line 836 of file iqueue.h.

TransportAddress* DestinationListHandler::getFirstDestination ( ) const
inlineinherited

Definition at line 85 of file oqueue.h.

uint32 IncomingDataQueue::getFirstTimestamp ( const SyncSourcesrc = NULL ) const
inherited

Get timestamp of first packet waiting in the queue.

Parameters
src optional source selector.
Returns
timestamp of first arrival packet.
timeval RTPQueueBase::getInitialTime ( ) const
inlineinherited

Definition at line 204 of file queuebase.h.

uint32 OutgoingDataQueue::getInitialTimestamp ( )
inlineprotectedinherited

Definition at line 537 of file oqueue.h.

CryptoContext* IncomingDataQueue::getInQueueCryptoContext ( uint32  ssrc )
inherited

Get an input queue CryptoContext identified by SSRC.

Parameters
ssrc Request CryptoContext for this incoming SSRC
Returns
Pointer to CryptoContext of the SSRC of NULL if no context available for this SSRC.
SyncSourceLink* MembershipBookkeeping::getLast ( void  )
inlineprotectedinherited

Definition at line 839 of file iqueue.h.

uint32 QueueRTCPManager::getLastSendPacketCount ( ) const
inlineprotected

Get the number of data packets sent at the time the last SR was generated.

Definition at line 304 of file cqueue.h.

SyncSourceLink* MembershipBookkeeping::getLink ( const SyncSourcesource ) const
inlineprotectedinherited

Definition at line 339 of file iqueue.h.

uint32 RTPQueueBase::getLocalSSRC ( ) const
inlineinherited

Definition at line 187 of file queuebase.h.

uint32 RTPQueueBase::getLocalSSRCNetwork ( ) const
inlineprotectedinherited

Definition at line 217 of file queuebase.h.

bool OutgoingDataQueue::getMark ( ) const
inlineinherited

Get wheter the mark bit will be set in the next packet.

Definition at line 340 of file oqueue.h.

uint16 IncomingDataQueue::getMaxPacketDropout ( ) const
inlineinherited

Definition at line 1039 of file iqueue.h.

uint16 IncomingDataQueue::getMaxPacketMisorder ( ) const
inlineinherited

Definition at line 1022 of file iqueue.h.

size_t IncomingDataQueueBase::getMaxRecvPacketSize ( ) const
inlineinherited

Definition at line 305 of file queuebase.h.

size_t OutgoingDataQueueBase::getMaxSendSegmentSize ( )
inlineinherited

Definition at line 276 of file queuebase.h.

uint32 MembershipBookkeeping::getMembersCount ( )
inlineprotectedinherited

Definition at line 843 of file iqueue.h.

uint8 IncomingDataQueue::getMinValidPacketSequence ( ) const
inlineinherited

Get the minimun number of consecutive packets that must be received from a source before accepting its data packets.

Definition at line 1010 of file iqueue.h.

RTCPReceiverInfo* QueueRTCPManager::getMRReceiverInfo ( SyncSourcesrcFrom )

Ask for the info in the most recent receiver report about the local source received from the source given as parameter.

Parameters
srcFrom Source of the receiver info.
Returns
most recent receiver info received from src.
Return values
NULL when no receiver report has been received from the specified source.
RTCPSenderInfo* QueueRTCPManager::getMRSenderInfo ( SyncSourcesrc )

Get the most recent sender report received from a synchronization source.

Parameters
src Synchronization source of the sender info.
Returns
Most recent sender info received from src.
Return values
NULL when no sender report has been received from the specified source.
virtual size_t IncomingDataQueue::getNextDataPacketSize ( ) const
protectedpure virtualinherited

Implemented in RTPDuplex.

void QueueRTCPManager::getOnlyBye ( )
private

To be executed when whe are leaving the session.

CryptoContext* OutgoingDataQueue::getOutQueueCryptoContext ( uint32  ssrc )
inherited

Get an output queue CryptoContext identified by SSRC.

Parameters
ssrc Request CryptoContext for this incoming SSRC
Returns
Pointer to CryptoContext of the SSRC of NULL if no context available for this SSRC.
uint16 RTCPCompoundHandler::getPathMTU ( )
inlineinherited

Definition at line 98 of file rtcppkt.h.

uint32 QueueRTCPManager::getPrevMembersCount ( ) const
inlineprotected

Definition at line 315 of file cqueue.h.

timeval QueueRTCPManager::getRTCPCheckInterval ( )
inlineprotected

Definition at line 296 of file cqueue.h.

microtimeout_t OutgoingDataQueue::getSchedulingTimeout ( )
protectedinherited

This computes the timeout period for scheduling transmission of the next packet at the "head" of the send buffer.

If no packets are waiting, a default timeout is used. This actually forms the "isPending()" timeout of the rtp receiver in the service thread.

Returns
timeout until next packet is scheduled to send.
uint32 MembershipBookkeeping::getSendersCount ( )
inlineprotectedinherited

Definition at line 851 of file iqueue.h.

uint32 OutgoingDataQueue::getSendOctetCount ( ) const
inlineinherited

Get the total number of octets (payload only) sent so far.

Returns
total number of payload octets sent in RTP packets.

Definition at line 403 of file oqueue.h.

uint32 OutgoingDataQueue::getSendPacketCount ( ) const
inlineinherited

Get the total number of packets sent so far.

Returns
total number of packets sent

Definition at line 394 of file oqueue.h.

uint32 QueueRTCPManager::getSendRTCPPacketCount ( ) const
inline

Get the total number of RTCP packets sent until now.

Definition at line 178 of file cqueue.h.

uint16 OutgoingDataQueue::getSequenceNumber ( ) const
inlineinherited

Get the sequence number of the next outgoing packet.

Returns
the 16 bit sequence number.

Definition at line 412 of file oqueue.h.

uint32 RTPDataQueue::getSessionBandwidth ( ) const
inlineinherited

Definition at line 222 of file ioqueue.h.

SyncSourceLink* MembershipBookkeeping::getSourceBySSRC ( uint32  ssrc,
bool &  created 
)
protectedinherited

Get the description of a source by its ssrc identifier.

Parameters
ssrc SSRC identifier, in host order.
created whether a new source has been created.
Returns
Pointer to the SyncSource object identified by ssrc.
timeout_t RTPDataQueue::getTimeclock ( ) const
inlineinherited

Get the packet timeclock for synchronizing timestamps.

Returns
runtime in milliseconds since last set.

Definition at line 238 of file ioqueue.h.

IncomingDataQueue::IncomingRTPPktLink* IncomingDataQueue::getWaiting ( uint32  timestamp,
const SyncSourcesrc = NULL 
)
protectedinherited

This is used to fetch a packet in the receive queue and to expire packets older than the current timestamp.

Returns
packet buffer object for current timestamp if found.
Parameters
timestamp timestamp requested.
src optional source selector
Note
if found, the packet is removed from the reception queue
bool IncomingDataQueue::insertRecvPacket ( IncomingRTPPktLinkpacketLink )
protectedinherited

Insert a just received packet in the queue (both general and source specific queues).

If the packet was already in the queue (same SSRC and sequence number), it is not inserted but deleted.

Parameters
packetLink link to a packet just received and generally validated and processed by onRTPPacketRecv.
Returns
whether the packet was successfully inserted.
Return values
false when the packet is duplicated (there is already a packet from the same source with the same timestamp).
true when the packet is not duplicated.
bool RTPDataQueue::isActive ( void  ) const
inlineinherited

Get active connection state flag.

Returns
true if connection "active".

Definition at line 141 of file ioqueue.h.

bool MembershipBookkeeping::isMine ( const SyncSourcesource ) const
inlineprotectedinherited

Get whether a synchronization source is recorded in this membership controller.

Definition at line 345 of file iqueue.h.

virtual bool QueueRTCPManager::isPendingControl ( microtimeout_t  timeout )
privatepure virtual
virtual bool RTPDataQueue::isPendingData ( microtimeout_t  timeout )
protectedpure virtualinherited

This function is used to check for and schedule against arriving packets based on the derived connection type.

Returns
true if packet waiting for processing.
Parameters
number of microseconds to wait.

Implemented in RTPDuplex.

bool MembershipBookkeeping::isRegistered ( uint32  ssrc )
protectedinherited

Returns whether there is already a synchronizacion source with "ssrc" SSRC identifier.

bool OutgoingDataQueue::isSending ( ) const
inherited

Determine if outgoing packets are waiting to send.

Returns
true if there are packets waiting to be send.
bool DestinationListHandler::isSingleDestination ( ) const
inlineinherited

Get whether there is only a destination in the list.

Definition at line 82 of file oqueue.h.

bool IncomingDataQueue::isWaiting ( const SyncSourcesrc = NULL ) const
inherited

Determine if packets are waiting in the reception queue.

Parameters
src Optional synchronization source selector.
Returns
True if packets are waiting.
void DestinationListHandler::lockDestinationList ( ) const
inlineinherited

Definition at line 88 of file oqueue.h.

virtual uint16 QueueRTCPManager::networkHeaderSize ( )
inlineprivatevirtual

For certain control calculations in RTCP, the size of the underlying network and transport protocols is needed.

This method provides the size of the network level header for the default case of IP (20 octets). In case other protocol with different header size is used, this method should be redefined in a new specialized class.

Returns
size of the headers of the network level. IP (20) by default.

Definition at line 537 of file cqueue.h.

SDESItemType QueueRTCPManager::nextSDESType ( SDESItemType  t )
private
virtual void IncomingDataQueue::onExpireRecv ( IncomingRTPPkt &  )
inlineprotectedvirtualinherited

A hook to filter packets in the receive queue that are being expired.

This hook may be used to do some application specific processing on expired packets before they are deleted.

Parameters
- packet expired from the recv queue.

Definition at line 1217 of file iqueue.h.

virtual void QueueRTCPManager::onGotAPP ( SyncSource &  ,
size_t   
)
inlineprotectedvirtual

Plug-in for handling of APP (application specific) RTCP packets.

Parameters
- Synchronization source of this packet.
- RTCP APP packet struct.
- Length of the app data packet, including ssrc. name and app. specific data.

Definition at line 291 of file cqueue.h.

virtual void QueueRTCPManager::onGotGoodbye ( const SyncSource &  ,
const std::string &   
)
inlineprivatevirtual

A plugin point for goodbye message.

Called when a BYE RTCP packet has been received from a valid synchronization source.

Parameters
- synchronization source from what a BYE RTCP packet has been just received.
- reason string the source has provided.

Definition at line 433 of file cqueue.h.

virtual void QueueRTCPManager::onGotRR ( SyncSourcesource,
RecvReportRR,
uint8  blocks 
)
protectedvirtual

Plug-in for processing (acquire information carried in) an incoming RTCP Receiver Report.

The default implementation in this class only processes the receiver report blocks about the local source.

Parameters
source Synchronization source this report comes from.
RR Receiver report structure
blocks Number of report blocks in the packet
virtual void QueueRTCPManager::onGotRRSRExtension ( unsigned char *  ,
size_t   
)
inlineprivatevirtual

Plug-in for processing of SR/RR RTCP packet profile-specific extensions (third part of SR reports or second part of RR reports).

Parameters
- Content of the profile extension.
- Length of the extension, in octets.

Definition at line 420 of file cqueue.h.

bool QueueRTCPManager::onGotSDES ( SyncSourcesource,
RTCPPacketpkt 
)
protected
Parameters
source Synchronization source of SDES RTCP packet.
pkt SDES RTCP packet received.
virtual bool QueueRTCPManager::onGotSDESChunk ( SyncSourcesource,
SDESChunkchunk,
size_t  len 
)
protectedvirtual

Plug-in for handling of SDES chunks.

Parameters
source Synchronization source of SDES chunk.
chunk SDES chunk structure.
len Length of chunk, in octets.
Returns
whether there was a CNAME.
virtual void QueueRTCPManager::onGotSR ( SyncSourcesource,
SendReportSR,
uint8  blocks 
)
protectedvirtual

Plug-in for processing (acquire information carried in) an incoming RTCP Sender Report.

The default implementation in this class only processes the sender information and the receiver report blocks about the local source.

Parameters
source Synchronization source this report comes from.
SR Sender report structure.
blocks Number of report blocks in the packet.
virtual void IncomingDataQueue::onNewSyncSource ( const SyncSource &  )
inlineprotectedvirtualinherited

Virtual called when a new synchronization source has joined the session.

Parameters
- new synchronization source

Definition at line 1185 of file iqueue.h.

virtual bool IncomingDataQueue::onRTPPacketRecv ( IncomingRTPPkt &  )
inlineprotectedvirtualinherited

A virtual function to support parsing of arriving packets to determine if they should be kept in the queue and to dispatch events.

A generic header validity check (as specified in RFC 1889) is performed on every incoming packet. If the generic check completes succesfully, this method is called before the packet is actually inserted into the reception queue.

May be used to perform additional validity checks or to do some application specific processing.

Parameters
- packet just received.
Returns
true if packet is kept in the incoming packets queue.

Definition at line 1206 of file iqueue.h.

virtual bool IncomingDataQueue::onSRTPPacketError ( IncomingRTPPktpkt,
int32  errorCode 
)
inlineprotectedvirtualinherited

A hook that gets called if the decoding of an incoming SRTP was erroneous.

Parameters
pkt The SRTP packet with error.
errorCode The error code: -1 - SRTP authentication failure, -2 - replay check failed
Returns
True: put the packet in incoming queue for further processing by the applications; false: dismiss packet. The default implementation returns false.

Reimplemented in ZrtpQueue.

Definition at line 1234 of file iqueue.h.

virtual void QueueRTCPManager::onSSRCCollision ( const SyncSource &  )
inlineprivatevirtual

Plug-in for SSRC collision handling.

Parameters
- previously identified source.

Definition at line 402 of file cqueue.h.

QueueRTCPManager& QueueRTCPManager::operator= ( const QueueRTCPManagero )
private
uint8 QueueRTCPManager::packReportBlocks ( RRBlockblocks,
uint16 &  len,
uint16 &  available 
)
private
Returns
number of Report Blocks packed
void QueueRTCPManager::packSDES ( uint16 &  len )
private

Builds an SDES RTCP packet.

Each chunk is built following appendix A.4 in draft-ietf-avt-rtp-new.

Parameters
len provisionary length of the RTCP compound packet
Returns
void IncomingDataQueue::purgeIncomingQueue ( )
protectedinherited
void OutgoingDataQueue::purgeOutgoingQueue ( )
protectedinherited
void OutgoingDataQueue::putData ( uint32  stamp,
const unsigned char *  data = NULL,
size_t  len = 0 
)
inherited

This is used to create a data packet in the send queue.

Sometimes a "NULL" or empty packet will be used instead, and these are known as "silent" packets. "Silent" packets are used simply to "push" the scheduler along more accurately by giving the appearence that a next packet is waiting to be sent and to provide a valid timestamp for that packet.

Parameters
stamp Timestamp for expected send time of packet.
data Value or NULL if special "silent" packet.
len May be 0 to indicate a default by payload type.
void IncomingDataQueue::recordExtraction ( const IncomingRTPPktpkt )
protectedinherited

Log extraction of a packet from this source from the scheduled reception queue.

Parameters
pkt Packet extracted from the queue.
bool IncomingDataQueue::recordReception ( SyncSourceLinksrcLink,
const IncomingRTPPktpkt,
const timeval  recvtime 
)
protectedinherited

Log reception of a new RTP packet from this source.

Usually updates data such as the packet counter, the expected sequence number for the next packet and the time the last packet was received at.

Parameters
srcLink Link structure for the synchronization source of this packet.
pkt Packet just created and to be logged.
recvtime Reception time.
Returns
whether, according to the source state and statistics, the packet is considered valid and must be inserted in the incoming packets queue.
virtual size_t QueueRTCPManager::recvControl ( unsigned char *  buffer,
size_t  len,
InetHostAddressna,
tpport_ttp 
)
privatepure virtual
virtual size_t IncomingDataQueue::recvData ( unsigned char *  buffer,
size_t  length,
InetHostAddresshost,
tpport_tport 
)
protectedpure virtualinherited

This function performs the physical I/O for reading a packet from the source.

It is a virtual that is overriden in the derived class.

Returns
number of bytes read.
Parameters
buffer of read packet.
length of data to read.
host address of source.
port number of source.

Implemented in RTPDuplex.

bool OutgoingDataQueue::removeContributor ( uint32  csrc )
inherited

Remove CSRC from the list of contributors.

bool DestinationListHandler::removeDestinationFromList ( const InetAddressia,
tpport_t  dataPort,
tpport_t  controlPort 
)
protectedinherited

Locks the object before modifying it.

void IncomingDataQueue::removeInQueueCryptoContext ( CryptoContextcc )
inherited

Remove input queue CryptoContext.

The endQueue method (provided by RTPQueue) also deletes all registered CryptoContexts.

Parameters
cc Pointer to initialized CryptoContext to remove. If pointer if NULL then delete the whole queue
void OutgoingDataQueue::removeOutQueueCryptoContext ( CryptoContextcc )
inherited

Remove output queue CryptoContext.

The endQueue method (provided by RTPQueue) also deletes all registered CryptoContexts.

Parameters
cc Pointer to initialized CryptoContext to remove.
void ApplicationHandler::removeParticipant ( RTPApplicationapp,
)
inlineinherited

Definition at line 216 of file iqueue.h.

bool MembershipBookkeeping::removeSource ( uint32  ssrc )
protectedinherited

Remove the description of the source identified by ssrc

Returns
whether the source has been actually removed or it did not exist.
void RTPDataQueue::renewLocalSSRC ( )
inlineprotectedvirtualinherited

Reimplemented from RTPQueueBase.

Definition at line 284 of file ioqueue.h.

void QueueRTCPManager::reverseReconsideration ( )
private

Apply reverse reconsideration adjustment to timing parameters when receiving BYE packets and not waiting to send a BYE.

virtual SDESItemType QueueRTCPManager::scheduleSDESItem ( )
privatevirtual

Choose which should be the type of the next SDES item sent.

This method is called when packing SDES chunks in a new RTCP packet.

Returns
type of the next SDES item to be sent
ConflictingTransportAddress* ConflictHandler::searchControlConflict ( InetAddress  na,
tpport_t  ctp 
)
inherited
Parameters
na Inet network address.
ctp Data transport port.
ConflictingTransportAddress* ConflictHandler::searchDataConflict ( InetAddress  na,
tpport_t  dtp 
)
inherited
Parameters
na Inet network address.
dtp Data transport port.
virtual size_t QueueRTCPManager::sendControl ( const unsigned char *const  buffer,
size_t  len 
)
privatepure virtual
size_t QueueRTCPManager::sendControlToDestinations ( unsigned char *  buffer,
size_t  len 
)
protected
void OutgoingDataQueue::sendImmediate ( uint32  stamp,
const unsigned char *  data = NULL,
size_t  len = 0 
)
inherited

This is used to create a data packet and send it immediately.

Sometimes a "NULL" or empty packet will be used instead, and these are known as "silent" packets. "Silent" packets are used simply to "push" the scheduler along more accurately by giving the appearence that a next packet is waiting to be sent and to provide a valid timestamp for that packet.

Parameters
stamp Timestamp immediate send time of packet.
data Value or NULL if special "silent" packet.
len May be 0 to indicate a default by payload type.
void QueueRTCPManager::setControlBandwidth ( float  fraction )
inlineprotected

Definition at line 197 of file cqueue.h.

virtual void OutgoingDataQueue::setControlPeer ( const InetAddresshost,
tpport_t  port 
)
inlineprotectedvirtualinherited

Reimplemented in RTPDuplex.

Definition at line 543 of file oqueue.h.

void SyncSourceHandler::setControlTransportPort ( SyncSourcesource,
tpport_t  p 
)
inlineinherited

Definition at line 161 of file iqueue.h.

void SyncSourceHandler::setDataTransportPort ( SyncSourcesource,
tpport_t  p 
)
inlineinherited

Definition at line 157 of file iqueue.h.

void QueueRTCPManager::setEnd2EndDelay ( microtimeout_t  t )
inline

This method sets the maximum end to end delay allowed.

If the processing delay plus the trip time for a packet is greater than the end to end delay, the packet is discarded, and the application cannot get it.

This is a way of setting an upper bound to the end to end delay, computed as the elapsed time between the packet timestamping at the sender side, and the picking of the packet at the receiver side.

Parameters
t maximum end to end delay allowed. A value of 0 implies there is no limit and is the default

Definition at line 133 of file cqueue.h.

void OutgoingDataQueue::setExpireTimeout ( microtimeout_t  to )
inlineinherited

Set the "expired" timer for expiring packets pending in the send queue which have gone unsent and are already "too late" to be sent now.

Parameters
to timeout to expire unsent packets in milliseconds.

Definition at line 382 of file oqueue.h.

void OutgoingDataQueue::setInitialTimestamp ( uint32  ts )
inlineprotectedinherited

Definition at line 531 of file oqueue.h.

void IncomingDataQueue::setInQueueCryptoContext ( CryptoContextcc )
inherited

Set input queue CryptoContext.

The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.

Parameters
cc Pointer to initialized CryptoContext.
void QueueRTCPManager::setLeavingDelay ( microtimeout_t  delay )
inline

Set how much time the stack will wait before deleting a synchronization source that has sent an RTCP BYE packet.

Parameters
delay delay in microseconds.
Note
The default delay is 1000000 microseconds

Definition at line 115 of file cqueue.h.

void SyncSourceHandler::setLink ( SyncSourcesource,
void *  link 
)
inlineinherited

Definition at line 141 of file iqueue.h.

void RTPQueueBase::setLocalSSRC ( uint32  ssrc )
inlineprotectedinherited

Definition at line 214 of file queuebase.h.

void OutgoingDataQueue::setMark ( bool  mark )
inlineinherited

Set marker bit for the packet in which the next data provided will be send.

When transmitting audio, should be set for the first packet of a talk spurt. When transmitting video, should be set for the last packet for a video frame.

Parameters
mark Marker bit value for next packet.

Definition at line 334 of file oqueue.h.

void IncomingDataQueue::setMaxPacketDropout ( uint16  packets )
inlineinherited

It also prevents packets sent after a restart of the source being immediately accepted.

Definition at line 1031 of file iqueue.h.

void IncomingDataQueue::setMaxPacketMisorder ( uint16  packets )
inlineinherited

Definition at line 1014 of file iqueue.h.

void IncomingDataQueueBase::setMaxRecvPacketSize ( size_t  maxsize )
inlineinherited
Parameters
maxsize maximum length of received RTP data packets, in octets. Defaults to the value returned by getDefaultMaxRecvPacketSize().
Note
This method sets a filter for incoming packets. Setting higher values does not necessarily imply higher memory usage (this method does not set any buffer size).

Definition at line 319 of file queuebase.h.

void OutgoingDataQueueBase::setMaxSendSegmentSize ( size_t  size )
inlineinherited

Set maximum payload segment size before fragmenting sends.

Parameters
size Maximum payload size.
Returns
Whether segment size was successfully set.

Definition at line 272 of file queuebase.h.

void MembershipBookkeeping::setMembersCount ( uint32  n )
inlineprotectedinherited

Definition at line 847 of file iqueue.h.

void QueueRTCPManager::setMinRTCPInterval ( microtimeout_t  interval )
inline

Manually set the minimum interval for sending RTP compound packets.

Parameters
interval minimum interval between RTCP packets, in microseconds.
See Also
computeRTCPInterval()

Definition at line 171 of file cqueue.h.

void IncomingDataQueue::setMinValidPacketSequence ( uint8  packets )
inlineinherited

When receiving packets from a new source, it may be convenient to reject a first few packets before we are really sure the source is valid.

This method sets how many data packets must be received in sequence before the source is considered valid and the stack starts to accept its packets.

Note
the default (see defaultMinValidPacketSequence()) value for this parameter is 0, so that no packets are rejected (data packets are accepted from the first one).
this validation is performed after the generic header validation and the additional validation done in onRTPPacketRecv().
if any valid RTCP packet is received from this source, it will be immediatly considered valid regardless of the number of sequential data packets received.
Parameters
packets number of sequential packet required

Definition at line 998 of file iqueue.h.

void SyncSourceHandler::setNetworkAddress ( SyncSourcesource,
InetAddress  addr 
)
inlineinherited

Definition at line 165 of file iqueue.h.

void OutgoingDataQueue::setNextSeqNum ( uint32  seqNum )
inlineprotectedinherited

For thoses cases in which the application requires a method to set the sequence number for the outgoing stream (such as for implementing the RTSP PLAY command).

Parameters
seqNum next sequence number to be used for outgoing packets.

Definition at line 521 of file oqueue.h.

void OutgoingDataQueue::setOutQueueCryptoContext ( CryptoContextcc )
inherited

Set ouput queue CryptoContext.

The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.

Parameters
cc Pointer to initialized CryptoContext.
void OutgoingDataQueue::setPadding ( uint8  paddinglen )
inlineinherited

Set padding.

All outgoing packets will be transparently padded to a multiple of paddinglen.

Parameters
paddinglen pad packets to a length multiple of paddinglen.

Definition at line 323 of file oqueue.h.

size_t OutgoingDataQueue::setPartial ( uint32  timestamp,
unsigned char *  data,
size_t  offset,
size_t  max 
)
inherited

Set partial data for an already queued packet.

This is often used for multichannel data.

Parameters
timestamp Timestamp of packet.
data Buffer to copy from.
offset Offset to copy from.
max Maximum data size.
Returns
Number of packet data bytes set.
void SyncSourceHandler::setParticipant ( SyncSourcesource,
Participantp 
)
inlineinherited

Definition at line 145 of file iqueue.h.

void RTCPCompoundHandler::setPathMTU ( uint16  mtu )
inlineinherited

Definition at line 95 of file rtcppkt.h.

bool RTPQueueBase::setPayloadFormat ( const PayloadFormatpf )
inlineinherited

Set the payload format in use, for timing and payload type identification purposes.

Parameters
pf payload format to use from now on.
Returns
whether the payload format has been successfully set.

Definition at line 180 of file queuebase.h.

void QueueRTCPManager::setPrevMembersNum ( uint32  n )
inlineprotected
Parameters
n Number of members.

Definition at line 311 of file cqueue.h.

void ParticipantHandler::setPRIVPrefix ( Participantpart,
const std::string  val 
)
inlineinherited

Definition at line 191 of file iqueue.h.

void QueueRTCPManager::setPRIVPrefix ( Participantpart,
const char *const  value,
size_t  len 
)
private

Set PRIV item previx value from a string without null termination (as it is transported in RTCP packets).

void OutgoingDataQueue::setSchedulingTimeout ( microtimeout_t  to )
inlineinherited

Set the default scheduling timeout to use when no data packets are waiting to be sent.

Parameters
to timeout in milliseconds.

Definition at line 367 of file oqueue.h.

void ParticipantHandler::setSDESItem ( Participantpart,
SDESItemType  item,
const std::string &  val 
)
inlineinherited

Definition at line 186 of file iqueue.h.

void QueueRTCPManager::setSDESItem ( Participantpart,
SDESItemType  type,
const char *const  value,
size_t  len 
)
private

Set item value from a string without null termination (as it is transported in RTCP packets).

void SyncSourceHandler::setSender ( SyncSourcesource,
bool  active 
)
inlineinherited

Definition at line 153 of file iqueue.h.

void QueueRTCPManager::setSendersControlFraction ( float  fraction )
inline

Specify the fraction of the total control bandwith to be dedicated to senders reports.

Parameters
fraction fraction of bandwidth, must be between 0 an 1.

This method sets the fraction of the global control bandwidth that will be dedicated to senders reports. Of course, 1 - fraction will be dedicated to receivers reports.

See Also
setControlBandwidth

Definition at line 158 of file cqueue.h.

void RTPDataQueue::setSessionBandwidth ( uint32  bw )
inlineinherited

Specify the bandwidth of the current session.

Parameters
bw bandwidth of the current session, in bits/s.
See Also
AVPQueue::setControlBandwidth()

Definition at line 214 of file ioqueue.h.

void IncomingDataQueue::setSourceExpirationPeriod ( uint8  intervals )
inlineprotectedinherited

Set the number of RTCP intervals that the stack will wait to change the state of a source from stateActive to stateInactive, or to delete the source after being in stateInactive.

Note that this value should be uniform accross all participants and SHOULD be fixed for a particular profile.

Parameters
intervals number of RTCP report intervals
Note
If RTCP is not being used, the RTCP interval is assumed to be the default: 5 seconds.
The default for this value is, as RECOMMENDED, 5.

Definition at line 1122 of file iqueue.h.

void SyncSourceHandler::setState ( SyncSourcesource,
)
inlineinherited

Definition at line 149 of file iqueue.h.

void RTPDataQueue::setTimeclock ( )
inlineinherited

Set the packet timeclock for synchronizing timestamps.

Definition at line 229 of file ioqueue.h.

void RTPDataQueue::setTypeOfService ( Tos  tos )
inlineinherited

Specify the kind of service the application expects to use.

Parameters
tos type of service the application expects to use
Note
If enhanced service is specified but packet loss is high (the requested service does not appear to actually be delivered) ccRTP defaults to best-effort suitable behaviour: guarantee fair competition with TCP.
Todo:
Implement fair competition with tcp

Definition at line 119 of file ioqueue.h.

void QueueRTCPManager::takeInControlPacket ( )
private

For picking up incoming RTCP packets if they are waiting.

A timeout for the maximum interval since the last RTCP packet had been received is also returned. This is checked every rtcpCheckInterval seconds.

This method decomposes all incoming RTCP compound packets pending in the control socket and processes each RTCP packet.

virtual size_t IncomingDataQueue::takeInDataPacket ( )
protectedvirtualinherited

This function is used by the service thread to process the next incoming packet and place it in the receive list.

Returns
number of payload bytes received. <0 if error.

Reimplemented in ZrtpQueue.

bool QueueRTCPManager::timerReconsideration ( )
private
virtual void RTPDataQueue::timerTick ( )
inlineprotectedvirtualinherited

A plugin point for timer tick driven events.

Definition at line 281 of file ioqueue.h.

virtual uint16 QueueRTCPManager::transportHeaderSize ( )
inlineprivatevirtual

For certain control calculations in RTCP, the size of the underlying network and transport protocols is needed.

This method provides the size of the transport level header for the default case of UDP (8 octets). In case other protocol with different header size is used, this method should be redefined in a new specialized class.

return size of the headers of the transport level. UDP (8) by default

Definition at line 552 of file cqueue.h.

void DestinationListHandler::unlockDestinationList ( ) const
inlineinherited

Definition at line 91 of file oqueue.h.

void QueueRTCPManager::updateAvgRTCPSize ( size_t  len )
private

This must be called in order to update the average RTCP compound packet size estimation when:

a compoung RTCP packet is received (6.3.3).

a compound RTCP packet is transmitted (6.3.6).

Parameters
len length in octets of the compound RTCP packet just received/transmitted.
void ConflictHandler::updateConflict ( ConflictingTransportAddressca )
inlineinherited

Definition at line 276 of file iqueue.h.

void DestinationListHandler::writeLockDestinationList ( ) const
inlineprotectedinherited

Definition at line 95 of file oqueue.h.

Field Documentation

bool OutgoingDataQueue::complete
inherited

Definition at line 618 of file oqueue.h.

float QueueRTCPManager::controlBwFract
private

Definition at line 570 of file cqueue.h.

volatile bool QueueRTCPManager::controlServiceActive
private

Definition at line 569 of file cqueue.h.

std::list<CryptoContext *> OutgoingDataQueue::cryptoContexts
protectedinherited

Definition at line 552 of file oqueue.h.

std::list<CryptoContext *> IncomingDataQueue::cryptoContexts
protectedinherited

Definition at line 1290 of file iqueue.h.

Mutex OutgoingDataQueue::cryptoMutex
mutableprotectedinherited

Definition at line 551 of file oqueue.h.

Mutex IncomingDataQueue::cryptoMutex
mutableprotectedinherited

Definition at line 1289 of file iqueue.h.

uint32 QueueRTCPManager::ctrlSendCount
private

Definition at line 572 of file cqueue.h.

const microtimeout_t QueueRTCPManager::defaultEnd2EndDelay
staticprivate

Definition at line 610 of file cqueue.h.

const uint16 IncomingDataQueue::defaultMaxPacketDropout
staticprotectedinherited

Definition at line 1283 of file iqueue.h.

const uint16 IncomingDataQueue::defaultMaxPacketMisorder
staticprotectedinherited

Definition at line 1282 of file iqueue.h.

const size_t MembershipBookkeeping::defaultMembersHashSize
staticprotectedinherited

Definition at line 854 of file iqueue.h.

const size_t IncomingDataQueue::defaultMembersSize
staticprotectedinherited

Definition at line 1287 of file iqueue.h.

const uint8 IncomingDataQueue::defaultMinValidPacketSequence
staticprotectedinherited

Definition at line 1281 of file iqueue.h.

std::list<TransportAddress*> DestinationListHandler::destList
protectedinherited

Definition at line 71 of file oqueue.h.

microtimeout_t QueueRTCPManager::end2EndDelay
private

Definition at line 613 of file cqueue.h.

ConflictingTransportAddress* ConflictHandler::firstConflict
protectedinherited

Definition at line 288 of file iqueue.h.

const SDESItemType QueueRTCPManager::firstSchedulable
staticprivate

Definition at line 579 of file cqueue.h.

ConflictingTransportAddress * ConflictHandler::lastConflict
protectedinherited

Definition at line 288 of file iqueue.h.

const SDESItemType QueueRTCPManager::lastSchedulable
staticprivate

Definition at line 580 of file cqueue.h.

uint32 QueueRTCPManager::lastSendPacketCount
private

Definition at line 602 of file cqueue.h.

microtimeout_t QueueRTCPManager::leavingDelay
private

Definition at line 609 of file cqueue.h.

uint16 QueueRTCPManager::lowerHeadersSize
private

Definition at line 576 of file cqueue.h.

bool OutgoingDataQueue::marked
inherited

Definition at line 616 of file oqueue.h.

uint16 IncomingDataQueue::maxPacketDropout
protectedinherited

Definition at line 1286 of file iqueue.h.

uint16 IncomingDataQueue::maxPacketMisorder
protectedinherited

Definition at line 1285 of file iqueue.h.

uint8 IncomingDataQueue::minValidPacketSequence
protectedinherited

Definition at line 1284 of file iqueue.h.

SDESItemType QueueRTCPManager::nextScheduledSDESItem
private

Definition at line 578 of file cqueue.h.

uint32 OutgoingDataQueue::octetCount
inherited

Definition at line 604 of file oqueue.h.

timeval OutgoingDataQueue::overflowTime
inherited

Definition at line 623 of file oqueue.h.

uint32 OutgoingDataQueue::packetCount
inherited

Definition at line 602 of file oqueue.h.

uint8 OutgoingDataQueue::paddinglen
inherited

Definition at line 612 of file oqueue.h.

RTPApplication& QueueRTCPManager::queueApplication
private

Definition at line 615 of file cqueue.h.

const double QueueRTCPManager::RECONSIDERATION_COMPENSATION
staticprivate

Definition at line 619 of file cqueue.h.

struct { ... } QueueRTCPManager::reconsInfo
float QueueRTCPManager::recvControlBwFract
private

Definition at line 570 of file cqueue.h.

IncomingRTPPktLink* IncomingDataQueue::recvFirst
protectedinherited

Definition at line 1279 of file iqueue.h.

IncomingRTPPktLink * IncomingDataQueue::recvLast
protectedinherited

Definition at line 1279 of file iqueue.h.

ThreadLock IncomingDataQueue::recvLock
mutableprotectedinherited

Definition at line 1277 of file iqueue.h.

uint16 QueueRTCPManager::rtcpAvgSize
private

Definition at line 591 of file cqueue.h.

timeval QueueRTCPManager::rtcpCheckInterval
private

Definition at line 596 of file cqueue.h.

bool QueueRTCPManager::rtcpInitial
private

Definition at line 592 of file cqueue.h.

timeval QueueRTCPManager::rtcpLastCheck
private

Definition at line 594 of file cqueue.h.

microtimeout_t QueueRTCPManager::rtcpMinInterval
private

Definition at line 607 of file cqueue.h.

timeval QueueRTCPManager::rtcpNextCheck
private

Definition at line 598 of file cqueue.h.

uint32 QueueRTCPManager::rtcpPMembers

Definition at line 588 of file cqueue.h.

unsigned char* RTCPCompoundHandler::rtcpRecvBuffer
protectedinherited

Definition at line 358 of file rtcppkt.h.

unsigned char* RTCPCompoundHandler::rtcpSendBuffer
protectedinherited

Definition at line 355 of file rtcppkt.h.

timeval QueueRTCPManager::rtcpTc

Definition at line 587 of file cqueue.h.

timeval QueueRTCPManager::rtcpTn

Definition at line 587 of file cqueue.h.

timeval QueueRTCPManager::rtcpTp

Definition at line 587 of file cqueue.h.

bool QueueRTCPManager::rtcpWeSent
private

Definition at line 590 of file cqueue.h.

uint16 OutgoingDataQueue::sendCC
inherited

Definition at line 610 of file oqueue.h.

float QueueRTCPManager::sendControlBwFract
private

Definition at line 570 of file cqueue.h.

uint16 OutgoingDataQueue::sendSeq
inherited

Definition at line 606 of file oqueue.h.

uint32 OutgoingDataQueue::sendSources[16]
inherited

Definition at line 608 of file oqueue.h.

const uint32 MembershipBookkeeping::SEQNUMMOD
staticprotectedinherited

Definition at line 855 of file iqueue.h.

uint8 IncomingDataQueue::sourceExpirationPeriod
protectedinherited

Definition at line 1288 of file iqueue.h.

const uint16 QueueRTCPManager::TIMEOUT_MULTIPLIER
staticprivate

Definition at line 618 of file cqueue.h.


The documentation for this class was generated from the following file:

Generated on Dec 21, 2017 for commoncpp2-1.8.1, ccrtp-1.7.2, libzrtpcpp-2.3.4, ccscript3-1.1.7, ccaudio2-1.0.0 and bayonne2-2.3.2 (after installation in /usr/local/) by   doxygen 1.8.6

AltStyle によって変換されたページ (->オリジナル) /