ccRTP 2.1.2
|
A peer associated RTP socket pair for physically connected peer hosts. More...
#include <cc++/rtp.h>
Public Types | |
enum | Tos { tosBestEffort, tosEnhanced } |
rtp.h cc++/rtp.h More... | |
Public Member Functions | |
RTPDuplex (const InetAddress &bind, tpport_t local, tpport_t remote) | |
virtual | ~RTPDuplex () |
UDPTransmit::Error | connect (const InetHostAddress &host, tpport_t port=0) |
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... | |
SyncSourcesIterator | begin () |
SyncSourcesIterator | end () |
const AppDataUnit * | getData (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 | getDefaultMinValidPacketSequence () const |
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 |
void | setInQueueCryptoContext (CryptoContext *cc) |
Set input queue CryptoContext. More... | |
void | removeInQueueCryptoContext (CryptoContext *cc) |
Remove input queue CryptoContext. More... | |
CryptoContext * | getInQueueCryptoContext (uint32 ssrc) |
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... | |
PayloadType | getCurrentPayloadType () const |
timeval | getInitialTime () const |
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... | |
microtimeout_t | getDefaultSchedulingTimeout () const |
void | setSchedulingTimeout (microtimeout_t to) |
Set the default scheduling timeout to use when no data packets are waiting to be sent. More... | |
microtimeout_t | getDefaultExpireTimeout () const |
void | setExpireTimeout (microtimeout_t to) |
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... | |
microtimeout_t | getExpireTimeout () const |
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... | |
void | setOutQueueCryptoContext (CryptoContext *cc) |
Set ouput queue CryptoContext. More... | |
void | removeOutQueueCryptoContext (CryptoContext *cc) |
Remove output queue CryptoContext. More... | |
CryptoContext * | getOutQueueCryptoContext (uint32 ssrc) |
Get an output queue CryptoContext identified by SSRC. More... | |
size_t | getDefaultMaxSendSegmentSize () |
void | setMaxSendSegmentSize (size_t size) |
Set maximum payload segment size before fragmenting sends. More... | |
size_t | getMaxSendSegmentSize () |
Static Public Member Functions | |
static size_t | getDefaultMembersSize () |
Protected Member Functions | |
bool | isPendingData (microtimeout_t timeout) |
size_t | sendData (const unsigned char *const buffer, size_t len) |
size_t | recvData (unsigned char *buffer, size_t len, InetHostAddress &na, tpport_t &tp) |
void | setDataPeer (const InetAddress &, tpport_t) |
void | setControlPeer (const InetAddress &, tpport_t) |
size_t | getNextDataPacketSize () const |
SyncSource & | getPeer () |
virtual void | timerTick () |
A plugin point for timer tick driven events. More... | |
void | renewLocalSSRC () |
void | endQueue () |
This method ends the queue. 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::IncomingRTPPktLink * | getWaiting (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... | |
void | purgeIncomingQueue () |
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... | |
virtual bool | end2EndDelayed (IncomingRTPPktLink &) |
bool | insertRecvPacket (IncomingRTPPktLink *packetLink) |
Insert a just received packet in the queue (both general and source specific queues). More... | |
void | setLocalSSRC (uint32 ssrc) |
uint32 | getLocalSSRCNetwork () const |
virtual size_t | dispatchBYE (const std::string &) |
A plugin point for posting of BYE messages. More... | |
size_t | getDefaultMembersHashSize () |
SyncSourceLink * | getLink (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... | |
SyncSourceLink * | getSourceBySSRC (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... | |
SyncSourceLink * | getFirst () |
SyncSourceLink * | getLast () |
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 | setDataTransportPort (SyncSource &source, tpport_t p) |
void | setControlTransportPort (SyncSource &source, tpport_t p) |
void | setNetworkAddress (SyncSource &source, InetAddress addr) |
void | setSDESItem (Participant *part, SDESItemType item, const std::string &val) |
void | setPRIVPrefix (Participant *part, const std::string val) |
void | addParticipant (RTPApplication &app, Participant &part) |
void | removeParticipant (RTPApplication &app, RTPApplication::ParticipantLink *pl) |
ConflictingTransportAddress * | searchDataConflict (InetAddress na, tpport_t dtp) |
ConflictingTransportAddress * | searchControlConflict (InetAddress na, tpport_t ctp) |
void | updateConflict (ConflictingTransportAddress &ca) |
void | addConflict (const InetAddress &na, tpport_t dtp, tpport_t ctp) |
void | dispatchImmediate (OutgoingRTPPkt *packet) |
This is used to write the RTP data packet to one or more destinations. More... | |
microtimeout_t | getSchedulingTimeout () |
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 () |
void | purgeOutgoingQueue () |
bool | isSingleDestination () const |
Get whether there is only a destination in the list. More... | |
TransportAddress * | getFirstDestination () const |
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... | |
Protected Attributes | |
ThreadLock | recvLock |
IncomingRTPPktLink * | recvFirst |
IncomingRTPPktLink * | recvLast |
uint8 | minValidPacketSequence |
uint16 | maxPacketMisorder |
uint16 | maxPacketDropout |
uint8 | sourceExpirationPeriod |
Mutex | cryptoMutex |
Mutex | cryptoMutex |
std::list< CryptoContext * > | cryptoContexts |
std::list< CryptoContext * > | cryptoContexts |
ConflictingTransportAddress * | firstConflict |
ConflictingTransportAddress * | lastConflict |
std::list< TransportAddress * > | destList |
Static Protected Attributes | |
static const uint8 | defaultMinValidPacketSequence = 0 |
static const uint16 | defaultMaxPacketMisorder = 0 |
static const uint16 | defaultMaxPacketDropout = 3000 |
static const size_t | defaultMembersSize |
static const size_t | defaultMembersHashSize = 11 |
static const uint32 | SEQNUMMOD = (1<<16) |
Private Attributes | |
tpport_t | dataBasePort |
A peer associated RTP socket pair for physically connected peer hosts.
This has no RTCP and assumes the receiver is connected to a known transmitter, hence no "foreign" packets will arrive.
|
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.
Enumerator | |
---|---|
tosBestEffort |
Best-effort network service. |
tosEnhanced |
Enhanced network service. |
NAMESPACE_COMMONCPP RTPDuplex::RTPDuplex | ( | const InetAddress & | bind, |
tpport_t | local, | ||
tpport_t | remote | ||
) |
bind | network address this socket is to be bound |
local | transport port this socket is to be bound |
remote | peer transpor port |
Definition at line 47 of file duplex.cpp.
|
virtual |
Definition at line 53 of file duplex.cpp.
|
inherited |
Definition at line 75 of file incqueue.cpp.
|
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.
|
inherited |
Definition at line 219 of file outqueue.cpp.
|
inherited |
Definition at line 233 of file outqueue.cpp.
|
protectedinherited |
Locks the object before modifying it.
Definition at line 74 of file outqueue.cpp.
|
inlineinherited |
|
inlineinherited |
|
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.
Definition at line 282 of file members.cpp.
|
protectedinherited |
Apply collision and loop detection and correction algorithm when receiving RTP data packets.
Follows section 8.2 in draft-ietf-avt-rtp-new.
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. |
Definition at line 299 of file incqueue.cpp.
UDPSocket::Error RTPDuplex::connect | ( | const InetHostAddress & | host, |
tpport_t | port = 0 |
||
) |
host | peer address |
port | peer port. If not specified, the same as the local is used |
Definition at line 60 of file duplex.cpp.
|
inlineinherited |
|
inlineprotectedvirtualinherited |
A plugin point for posting of BYE messages.
- | reason to leave the RTP session. |
Reimplemented in QueueRTCPManager.
Definition at line 228 of file queuebase.h.
|
protectedinherited |
This function is used by the service thread to process the next outgoing packet pending in the sending queue.
Definition at line 549 of file outqueue.cpp.
|
protectedinherited |
This is used to write the RTP data packet to one or more destinations.
It is used by both sendImmediate and by dispatchDataPacket.
RTP | packet to send. |
Definition at line 505 of file outqueue.cpp.
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedvirtualinherited |
Reimplemented in QueueRTCPManager.
|
protectedinherited |
|
inherited |
Definition at line 247 of file outqueue.cpp.
|
inherited |
Definition at line 257 of file outqueue.cpp.
|
inlineinherited |
Definition at line 198 of file queuebase.h.
|
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().
Definition at line 195 of file queuebase.h.
|
inlineprotectedinherited |
|
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.
|
inherited |
Retreive data from a specific timestamped packet if such a packet is currently available in the receive buffer.
stamp | Data unit timestamp. |
src | Optional synchronization source selector. |
null | pointer if no packet with such timestamp is available. |
Definition at line 472 of file incqueue.cpp.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Definition at line 298 of file queuebase.h.
|
inlineinherited |
Definition at line 259 of file queuebase.h.
|
inlineinherited |
|
inlinestaticinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
inlineinherited |
|
inherited |
Get timestamp of first packet waiting in the queue.
src | optional source selector. |
Definition at line 158 of file incqueue.cpp.
|
inlineinherited |
Definition at line 201 of file queuebase.h.
|
inlineprotectedinherited |
|
inherited |
Get an input queue CryptoContext identified by SSRC.
ssrc | Request CryptoContext for this incoming SSRC |
Definition at line 773 of file incqueue.cpp.
|
inlineprotectedinherited |
|
inlineprotectedinherited |
|
inlineinherited |
Definition at line 184 of file queuebase.h.
|
inlineprotectedinherited |
Definition at line 214 of file queuebase.h.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Definition at line 302 of file queuebase.h.
|
inlineinherited |
Definition at line 273 of file queuebase.h.
|
inlineprotectedinherited |
|
inlineinherited |
|
inlineprotectedvirtual |
Implements IncomingDataQueue.
|
inherited |
Get an output queue CryptoContext identified by SSRC.
ssrc | Request CryptoContext for this incoming SSRC |
Definition at line 661 of file outqueue.cpp.
|
protected |
|
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.
Definition at line 303 of file outqueue.cpp.
|
inlineprotectedinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
protectedinherited |
Get the description of a source by its ssrc
identifier.
ssrc | SSRC identifier, in host order. |
created | whether a new source has been created. |
ssrc
. Definition at line 226 of file members.cpp.
|
inlineinherited |
|
protectedinherited |
This is used to fetch a packet in the receive queue and to expire packets older than the current timestamp.
timestamp | timestamp requested. |
src | optional source selector |
Definition at line 496 of file incqueue.cpp.
|
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.
packetLink | link to a packet just received and generally validated and processed by onRTPPacketRecv. |
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. |
Definition at line 369 of file incqueue.cpp.
|
inlineinherited |
|
inlineprotectedinherited |
|
inlineprotectedvirtual |
timeout | how much time to wait for new data |
Implements RTPDataQueue.
|
protectedinherited |
Returns whether there is already a synchronizacion source with "ssrc" SSRC identifier.
Definition at line 205 of file members.cpp.
|
inherited |
Determine if outgoing packets are waiting to send.
Definition at line 294 of file outqueue.cpp.
|
inlineinherited |
|
inherited |
Determine if packets are waiting in the reception queue.
src | Optional synchronization source selector. |
Definition at line 144 of file incqueue.cpp.
|
inlineinherited |
|
inlineprotectedvirtualinherited |
|
inlineprotectedvirtualinherited |
|
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.
- | packet just received. |
|
inlineprotectedvirtualinherited |
A hook that gets called if the decoding of an incoming SRTP was erroneous.
pkt | The SRTP packet with error. |
errorCode | The error code: -1 - SRTP authentication failure, -2 - replay check failed |
Reimplemented in ZrtpQueue.
|
protectedinherited |
Definition at line 105 of file incqueue.cpp.
|
protectedinherited |
Definition at line 203 of file outqueue.cpp.
|
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.
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. |
Definition at line 404 of file outqueue.cpp.
|
protectedinherited |
Log extraction of a packet from this source from the scheduled reception queue.
pkt | Packet extracted from the queue. |
Definition at line 725 of file incqueue.cpp.
|
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.
srcLink | Link structure for the synchronization source of this packet. |
pkt | Packet just created and to be logged. |
recvtime | Reception time. |
Definition at line 632 of file incqueue.cpp.
|
inlineprotectedvirtual |
buffer | where to store the retrieved data |
len | how many octets to read |
na | Source network address. |
tp | Source transport port. |
Implements IncomingDataQueue.
|
inherited |
Remove CSRC from the list of contributors.
|
protectedinherited |
Locks the object before modifying it.
Definition at line 85 of file outqueue.cpp.
|
inherited |
Remove input queue CryptoContext.
The endQueue method (provided by RTPQueue) also deletes all registered CryptoContexts.
cc | Pointer to initialized CryptoContext to remove. If pointer if NULL then delete the whole queue |
Definition at line 748 of file incqueue.cpp.
|
inherited |
Remove output queue CryptoContext.
The endQueue method (provided by RTPQueue) also deletes all registered CryptoContexts.
cc | Pointer to initialized CryptoContext to remove. |
Definition at line 636 of file outqueue.cpp.
|
inlineinherited |
|
protectedinherited |
Remove the description of the source identified by ssrc
Definition at line 295 of file members.cpp.
|
inlineprotectedvirtualinherited |
Reimplemented from RTPQueueBase.
|
inherited |
na | Inet network address. |
ctp | Data transport port. |
Definition at line 64 of file incqueue.cpp.
|
inherited |
na | Inet network address. |
dtp | Data transport port. |
Definition at line 54 of file incqueue.cpp.
|
inlineprotectedvirtual |
buffer | pointer to data to be written |
len | how many octets to write |
Reimplemented from OutgoingDataQueue.
|
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.
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. |
Definition at line 464 of file outqueue.cpp.
|
inlineprotectedvirtual |
- | peer host network address. |
- | peer host RTCP transport port. |
Reimplemented from OutgoingDataQueue.
|
inlineinherited |
|
inlineprotectedvirtual |
- | peer host network address. |
- | peer host RTP data transport port. |
Reimplemented from OutgoingDataQueue.
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
inherited |
Set input queue CryptoContext.
The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.
cc | Pointer to initialized CryptoContext. |
Definition at line 729 of file incqueue.cpp.
|
inlineinherited |
|
inlineprotectedinherited |
Definition at line 211 of file queuebase.h.
|
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.
mark | Marker bit value for next packet. |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
maxsize | maximum length of received RTP data packets, in octets. Defaults to the value returned by getDefaultMaxRecvPacketSize(). |
Definition at line 316 of file queuebase.h.
|
inlineinherited |
Set maximum payload segment size before fragmenting sends.
size | Maximum payload size. |
Definition at line 269 of file queuebase.h.
|
inlineprotectedinherited |
|
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.
packets | number of sequential packet required |
|
inlineinherited |
|
inlineprotectedinherited |
|
inherited |
Set ouput queue CryptoContext.
The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.
cc | Pointer to initialized CryptoContext. |
Definition at line 617 of file outqueue.cpp.
|
inlineinherited |
|
inherited |
Set partial data for an already queued packet.
This is often used for multichannel data.
timestamp | Timestamp of packet. |
data | Buffer to copy from. |
offset | Offset to copy from. |
max | Maximum data size. |
Definition at line 581 of file outqueue.cpp.
|
inlineinherited |
|
inlineinherited |
Set the payload format in use, for timing and payload type identification purposes.
pf | payload format to use from now on. |
Definition at line 177 of file queuebase.h.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Specify the bandwidth of the current session.
bw | bandwidth of the current session, in bits/s. |
|
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.
intervals | number of RTCP report intervals |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Specify the kind of service the application expects to use.
tos | type of service the application expects to use |
|
protectedvirtualinherited |
This function is used by the service thread to process the next incoming packet and place it in the receive list.
Reimplemented in ZrtpQueue.
Definition at line 181 of file incqueue.cpp.
|
inlineprotectedvirtualinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
protectedinherited |
|
protectedinherited |
|
mutableprotectedinherited |
|
mutableprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
mutableprotectedinherited |
|
staticprotectedinherited |
|
protectedinherited |