|
Bayonne2 / Common C++ 2 Framework
|
All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
|
Bayonne2 / Common C++ 2 Framework
|
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... | |
| enum | Tos { tosLowDelay = 0, tosThroughput, tosReliability, tosMinCost, tosInvalid } |
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 () |
| void | connect (const char *service) |
| Error | setTimeToLive (char ttl) |
| Set time to live. More... | |
| ssize_t | transmit (const char *buffer, size_t len) |
| Transmit "send" to use "connected" send rather than sendto. More... | |
| bool | isOutputReady (unsigned long timeout=0l) |
| See if output queue is empty for sending more packets. More... | |
| Error | setRouting (bool enable) |
| Error | setTypeOfService (Tos tos) |
| Error | setBroadcast (bool enable) |
| Error | setLoopback (bool enable) |
| Set the loopback. More... | |
| void | setPeer (const IPV4Host &host, tpport_t port) |
| set the peer address to send message packets to. More... | |
| void | setPeer (const char *service) |
| Associate socket with a named connection. More... | |
| Socket::Error | getInterfaceIndex (const char *ethX, int &InterfaceIndex) |
| get the interface index for a named network device More... | |
| Socket::Error | join (const IPV4Multicast &ia, int InterfaceIndex) |
| join a multicast group on a particular interface More... | |
| ssize_t | receive (void *buf, size_t len, bool reply=false) |
| Receive a message from any host. More... | |
| IPV4Host | getIPV4Peer (tpport_t *port=NULL) const |
| Examine address of sender of next waiting packet. More... | |
| IPV4Host | getPeer (tpport_t *port=NULL) const |
| ssize_t | peek (void *buf, size_t len) |
| Examine contents of next waiting packet. More... | |
| Error | disconnect (void) |
| Disassociate this socket from any host connection. More... | |
| IPV4Host | getSender (tpport_t *port=NULL) const |
| IPV4Host | getIPV4Local (tpport_t *port=NULL) const |
| Get the local address and port number this socket is currently bound to. More... | |
| IPV4Host | getLocal (tpport_t *port=NULL) const |
| IPV4Host | getIPV4NAT (tpport_t *port=NULL) const |
| Perform NAT table lookup for this socket. More... | |
| IPV4Host | getNAT (tpport_t *port) const |
| void | setCompletion (bool immediate) |
| Used to specify blocking mode for the socket. More... | |
| Error | setLinger (bool linger) |
| Enable lingering sockets on close. More... | |
| bool | isConnected (void) const |
| Can test to see if this socket is "connected", and hence whether a "catch" can safely call getPeer(). More... | |
| bool | isActive (void) const |
| Test to see if the socket is at least operating or if it is mearly initialized. More... | |
| bool | operator! () const |
| Operator based testing to see if a socket is currently active. More... | |
| bool | isBroadcast (void) const |
| Return if broadcast has been enabled for the specified socket. More... | |
| bool | isRouted (void) const |
| Return if socket routing is enabled. More... | |
| Error | getErrorNumber (void) const |
| Often used by a "catch" to fetch the last error of a thrown socket. More... | |
| const char * | getErrorString (void) const |
| Often used by a "catch" to fetch the user set error string of a thrown socket, but only if EXTENDED error codes are used. More... | |
| long | getSystemError (void) const |
| const char * | getSystemErrorString (void) const |
Static Public Member Functions | |
| static size_t | getDefaultMembersSize () |
| static bool | check (Family fam) |
| See if a specific protocol family is available in the current runtime environment. More... | |
Protected Types | |
| enum | Family { IPV4 = AF_INET } |
| typedef enum Family | Family |
| enum | Error { errSuccess = 0, errCreateFailed, errCopyFailed, errInput, errInputInterrupt, errResourceFailure, errOutput, errOutputInterrupt, errNotConnected, errConnectRefused, errConnectRejected, errConnectTimeout, errConnectFailed, errConnectInvalid, errConnectBusy, errConnectNoRoute, errBindingFailed, errBroadcastDenied, errRoutingDenied, errKeepaliveDenied, errServiceDenied, errServiceUnavailable, errMulticastDisabled, errTimeout, errNoDelay, errExtended, errLookupFail, errSearchErr, errInvalidValue } |
| typedef enum Error | Error |
| enum | Tos { tosLowDelay = 0, tosThroughput, tosReliability, tosMinCost, tosInvalid } |
| enum | Pending { pendingInput, pendingOutput, pendingError } |
| typedef enum Pending | Pending |
| enum | State { INITIAL, AVAILABLE, BOUND, CONNECTED, CONNECTING, STREAM } |
| typedef enum State | State |
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... | |
| Error | connect (const IPV4Host &host, tpport_t port) |
| Associate this socket with a specified peer host. More... | |
| void | connect (const char *service) |
| bool | isPendingReceive (timeout_t timeout) |
| Check for pending data. More... | |
| void | endReceiver (void) |
| End receiver. More... | |
| SOCKET | getReceiver (void) const |
| Error | setRouting (bool enable) |
| Error | setMulticast (bool enable) |
| Error | join (const IPV4Multicast &ia) |
| Socket::Error | join (const IPV4Multicast &ia, int InterfaceIndex) |
| join a multicast group on a particular interface More... | |
| Error | drop (const IPV4Multicast &ia) |
| ssize_t | receive (void *buf, size_t len) |
| Receive a data packet from the connected peer host. More... | |
| ssize_t | receive (void *buf, size_t len, bool reply=false) |
| Receive a message from any host. More... | |
| bool | isInputReady (timeout_t timeout=TIMEOUT_INF) |
| See if input queue has data packets available. More... | |
| Error | setLoopback (bool enable) |
| Set the loopback. More... | |
| Error | setTimeToLive (char ttl) |
| Set time to live. More... | |
| void | setPeer (const IPV4Host &host, tpport_t port) |
| set the peer address to send message packets to. More... | |
| void | setPeer (const char *service) |
| Associate socket with a named connection. More... | |
| Socket::Error | getInterfaceIndex (const char *ethX, int &InterfaceIndex) |
| get the interface index for a named network device More... | |
| ssize_t | send (const void *buf, size_t len) |
| Send a message packet to a peer host. More... | |
| IPV4Host | getIPV4Peer (tpport_t *port=NULL) const |
| Examine address of sender of next waiting packet. More... | |
| IPV4Host | getPeer (tpport_t *port=NULL) const |
| ssize_t | peek (void *buf, size_t len) |
| Examine contents of next waiting packet. More... | |
| Error | disconnect (void) |
| Disassociate this socket from any host connection. More... | |
| Error | error (Error error, const char *err=NULL, long systemError=0) const |
| This service is used to throw all socket errors which usually occur during the socket constructor. More... | |
| void | error (const char *err) const |
| This service is used to throw application defined socket errors where the application specific error code is a string. More... | |
| void | setError (bool enable) |
| This service is used to turn the error handler on or off for "throwing" exceptions by manipulating the thrown flag. More... | |
| void | endSocket (void) |
| Used as the default destructor for ending a socket. More... | |
| Error | connectError (void) |
| Used as a common handler for connection failure processing. More... | |
| Error | sendLimit (int limit=2048) |
| Set the send limit. More... | |
| Error | receiveLimit (int limit=1) |
| Set thr receive limit. More... | |
| Error | sendTimeout (timeout_t timer) |
| Set the send timeout for sending raw network data. More... | |
| Error | receiveTimeout (timeout_t timer) |
| Receive timeout for receiving raw network data. More... | |
| Error | sendBuffer (unsigned size) |
| Set the protocol stack network kernel send buffer size associated with the socket. More... | |
| Error | receiveBuffer (unsigned size) |
| Set the protocol stack network kernel receive buffer size associated with the socket. More... | |
| Error | bufferSize (unsigned size) |
| Set the total protocol stack network kernel buffer size for both send and receive together. More... | |
| Error | setBroadcast (bool enable) |
| Set the subnet broadcast flag for the socket. More... | |
| Error | setMulticastByFamily (bool enable, Family family=IPV4) |
| Setting multicast binds the multicast interface used for the socket to the interface the socket itself has been implicitly bound to. More... | |
| Error | setLoopbackByFamily (bool enable, Family family=IPV4) |
| Set the multicast loopback flag for the socket. More... | |
| Error | setTimeToLiveByFamily (unsigned char ttl, Family fam=IPV4) |
| Set the multicast time to live for a multicast socket. More... | |
| Error | setNoDelay (bool enable) |
| Enable/disable delaying packets (Nagle algorithm) More... | |
| ssize_t | readLine (char *buf, size_t len, timeout_t timeout=0) |
| Process a logical input line from a socket descriptor directly. More... | |
| virtual ssize_t | readData (void *buf, size_t len, char separator=0, timeout_t t=0) |
| Read in a block of len bytes with specific separator. More... | |
| virtual ssize_t | writeData (const void *buf, size_t len, timeout_t t=0) |
| Write a block of len bytes to socket. More... | |
| virtual IPV4Host | getIPV4Sender (tpport_t *port=NULL) const |
| May be used to examine the origin of data waiting in the socket receive queue. More... | |
| IPV4Host | getSender (tpport_t *port=NULL) const |
| IPV4Host | getIPV4Local (tpport_t *port=NULL) const |
| Get the local address and port number this socket is currently bound to. More... | |
| IPV4Host | getLocal (tpport_t *port=NULL) const |
| IPV4Host | getIPV4NAT (tpport_t *port=NULL) const |
| Perform NAT table lookup for this socket. More... | |
| IPV4Host | getNAT (tpport_t *port) const |
| void | setCompletion (bool immediate) |
| Used to specify blocking mode for the socket. More... | |
| Error | setLinger (bool linger) |
| Enable lingering sockets on close. More... | |
| Error | setTypeOfService (Tos service) |
| Set packet scheduling on platforms which support ip quality of service conventions. More... | |
| bool | isConnected (void) const |
| Can test to see if this socket is "connected", and hence whether a "catch" can safely call getPeer(). More... | |
| bool | isActive (void) const |
| Test to see if the socket is at least operating or if it is mearly initialized. More... | |
| bool | operator! () const |
| Operator based testing to see if a socket is currently active. More... | |
| bool | isBroadcast (void) const |
| Return if broadcast has been enabled for the specified socket. More... | |
| bool | isRouted (void) const |
| Return if socket routing is enabled. More... | |
| Error | getErrorNumber (void) const |
| Often used by a "catch" to fetch the last error of a thrown socket. More... | |
| const char * | getErrorString (void) const |
| Often used by a "catch" to fetch the user set error string of a thrown socket, but only if EXTENDED error codes are used. More... | |
| long | getSystemError (void) const |
| const char * | getSystemErrorString (void) const |
| virtual bool | isPending (Pending pend, timeout_t timeout=TIMEOUT_INF) |
| Get the status of pending operations. More... | |
| Error | connect (const IPV4Host &host, tpport_t port) |
| Associate this socket with a specified peer host. More... | |
| Error | connect (const IPV4Broadcast &subnet, tpport_t port) |
| Associate this socket with a subnet of peer hosts for subnet broadcasting. More... | |
| Error | connect (const IPV4Multicast &mgroup, tpport_t port) |
| Associate this socket with a multicast group. More... | |
| ssize_t | send (const void *buf, size_t len) |
| Transmit "send" to use "connected" send rather than sendto. More... | |
| void | endTransmitter (void) |
| Stop transmitter. More... | |
| SOCKET | getTransmitter (void) |
| Error | setMulticast (bool enable) |
| Error | setTimeToLive (unsigned char ttl) |
| Error | error (Error error, const char *err=NULL, long systemError=0) const |
| This service is used to throw all socket errors which usually occur during the socket constructor. More... | |
| void | error (const char *err) const |
| This service is used to throw application defined socket errors where the application specific error code is a string. More... | |
| void | setError (bool enable) |
| This service is used to turn the error handler on or off for "throwing" exceptions by manipulating the thrown flag. More... | |
| void | endSocket (void) |
| Used as the default destructor for ending a socket. More... | |
| Error | connectError (void) |
| Used as a common handler for connection failure processing. More... | |
| Error | sendLimit (int limit=2048) |
| Set the send limit. More... | |
| Error | receiveLimit (int limit=1) |
| Set thr receive limit. More... | |
| Error | sendTimeout (timeout_t timer) |
| Set the send timeout for sending raw network data. More... | |
| Error | receiveTimeout (timeout_t timer) |
| Receive timeout for receiving raw network data. More... | |
| Error | sendBuffer (unsigned size) |
| Set the protocol stack network kernel send buffer size associated with the socket. More... | |
| Error | receiveBuffer (unsigned size) |
| Set the protocol stack network kernel receive buffer size associated with the socket. More... | |
| Error | bufferSize (unsigned size) |
| Set the total protocol stack network kernel buffer size for both send and receive together. More... | |
| Error | setMulticastByFamily (bool enable, Family family=IPV4) |
| Setting multicast binds the multicast interface used for the socket to the interface the socket itself has been implicitly bound to. More... | |
| Error | setLoopbackByFamily (bool enable, Family family=IPV4) |
| Set the multicast loopback flag for the socket. More... | |
| Error | setTimeToLiveByFamily (unsigned char ttl, Family fam=IPV4) |
| Set the multicast time to live for a multicast socket. More... | |
| Error | setNoDelay (bool enable) |
| Enable/disable delaying packets (Nagle algorithm) More... | |
| ssize_t | readLine (char *buf, size_t len, timeout_t timeout=0) |
| Process a logical input line from a socket descriptor directly. More... | |
Static Protected Member Functions | |
| static bool | check (Family fam) |
| See if a specific protocol family is available in the current runtime environment. 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 |
| union { | |
| struct sockaddr_in ipv4 | |
| } | peer |
| Family | family |
| struct { | |
| bool thrown: 1 | |
| bool broadcast: 1 | |
| bool route: 1 | |
| bool keepalive: 1 | |
| bool loopback: 1 | |
| bool multicast: 1 | |
| bool completion: 1 | |
| bool linger: 1 | |
| unsigned ttl: 8 | |
| } | flags |
| SOCKET volatile | so |
| the actual socket descriptor, in Windows, unlike posix it cannot be used as an file descriptor that way madness lies – jfc More... | |
| State volatile | state |
| union { | |
| struct sockaddr_in ipv4 | |
| } | peer |
| Family | family |
| struct { | |
| bool thrown: 1 | |
| bool broadcast: 1 | |
| bool route: 1 | |
| bool keepalive: 1 | |
| bool loopback: 1 | |
| bool multicast: 1 | |
| bool completion: 1 | |
| bool linger: 1 | |
| unsigned ttl: 8 | |
| } | flags |
| SOCKET volatile | so |
| the actual socket descriptor, in Windows, unlike posix it cannot be used as an file descriptor that way madness lies – jfc More... | |
| State volatile | state |
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 |
| static Mutex | mutex |
| static Mutex | mutex |
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 |
|
inherited |
|
inherited |
|
protectedinherited |
|
inherited |
|
inherited |
|
inherited |
|
protectedinherited |
|
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. |
|
inherited |
|
inherited |
| 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 |
|
virtual |
|
inherited |
|
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 |
|
inherited |
|
protectedinherited |
Locks the object before modifying it.
|
inlineinherited |
|
inlineinherited |
|
protectedinherited |
Set the total protocol stack network kernel buffer size for both send and receive together.
| size | of buffer. |
|
protectedinherited |
Set the total protocol stack network kernel buffer size for both send and receive together.
| size | of buffer. |
|
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.
|
staticinherited |
See if a specific protocol family is available in the current runtime environment.
|
staticinherited |
See if a specific protocol family is available in the current runtime environment.
|
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. |
| UDPTransmit::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 |
|
inherited |
|
inherited |
Associate this socket with a specified peer host.
The port number from the constructor will be used. All UDP packets will be sent to and received from the specified host.
| host | address to connect socket to. |
| port | to connect socket to. |
|
protectedinherited |
Associate this socket with a subnet of peer hosts for subnet broadcasting.
The server must be able to assert broadcast permission for the socket.
| subnet | subnet address to broadcast into. |
| port | transport port to broadcast into. |
|
protectedinherited |
Associate this socket with a multicast group.
| mgroup | address of the multicast group to send to. |
| port | port number |
Associate this socket with a specified peer host.
The port number from the constructor will be used. All UDP packets will be sent received from the specified host.
| host | host network address to connect socket to. |
| port | host transport port to connect socket to. |
|
protectedinherited |
Used as a common handler for connection failure processing.
|
protectedinherited |
Used as a common handler for connection failure processing.
|
inlineinherited |
|
inherited |
Disassociate this socket from any host connection.
No data should be read or written until a connection is established.
|
inherited |
Disassociate this socket from any host connection.
No data should be read or written until a connection is established.
|
inlineprotectedvirtualinherited |
A plugin point for posting of BYE messages.
| - | reason to leave the RTP session. |
Reimplemented in QueueRTCPManager.
Definition at line 231 of file queuebase.h.
|
protectedinherited |
This function is used by the service thread to process the next outgoing packet pending in the sending queue.
|
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. |
|
inlineprotectedinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedvirtualinherited |
Reimplemented in QueueRTCPManager.
|
protectedinherited |
This method ends the queue.
|
inlineprotectedinherited |
|
protectedinherited |
Used as the default destructor for ending a socket.
This will cleanly terminate the socket connection. It is provided for use in derived virtual destructors.
|
protectedinherited |
Used as the default destructor for ending a socket.
This will cleanly terminate the socket connection. It is provided for use in derived virtual destructors.
|
inlineprotectedinherited |
|
protectedinherited |
This service is used to throw all socket errors which usually occur during the socket constructor.
| error | defined socket error id. |
| err | string or message to pass. |
| systemError | the system error# that caused the error |
|
protectedinherited |
This service is used to throw all socket errors which usually occur during the socket constructor.
| error | defined socket error id. |
| err | string or message to pass. |
| systemError | the system error# that caused the error |
|
inlineprotectedinherited |
|
inlineprotectedinherited |
|
inherited |
|
inherited |
|
inlineinherited |
Definition at line 201 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 198 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. |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Definition at line 301 of file queuebase.h.
|
inlineinherited |
Definition at line 262 of file queuebase.h.
|
inlineinherited |
|
inlinestaticinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
inlineinherited |
|
inherited |
Get timestamp of first packet waiting in the queue.
| src | optional source selector. |
|
inlineinherited |
Definition at line 204 of file queuebase.h.
|
inlineprotectedinherited |
|
inherited |
Get an input queue CryptoContext identified by SSRC.
| ssrc | Request CryptoContext for this incoming SSRC |
|
inherited |
get the interface index for a named network device
| ethX | is device name, like "eth0" or "eth1" |
| InterfaceIndex | is the index value returned by os |
|
inherited |
get the interface index for a named network device
| ethX | is device name, like "eth0" or "eth1" |
| InterfaceIndex | is the index value returned by os |
Get the local address and port number this socket is currently bound to.
| port | ptr to port number on local host. |
Get the local address and port number this socket is currently bound to.
| port | ptr to port number on local host. |
Perform NAT table lookup for this socket.
Used to allow an application to know the original ip:port pair the the client "thinks" it is connecting to. Used mostly to transparently impersonate a remote server/service.
On error, 0.0.0.0:0 is returned and one of the following error codes is set: errServiceUnavailable - if nat is not supported on the current platform or if it was not compiled; errLookupFail - if the nat syscall failed for some reason (extended error code); errSearchErr - if the socket does not have nat information (i.e. is not nated).
NAT lookup is supported on NetFilter for ipv4 and ipv6 (Linux), IPFilter for ipv4 (Solaris, *BSD except OpenBSD, HP-UX, etc.) and Packet Filter for ipv4 and ipv6 (OpenBSD). When using IPFilter or Packet Filter, the first NAT lookup must be performed as root (the NAT device is read only for root and is opened once, unless an error occurs). Permissions on the nat device may be changed to solve this.
| port | ptr to NATed port number on local host. |
Perform NAT table lookup for this socket.
Used to allow an application to know the original ip:port pair the the client "thinks" it is connecting to. Used mostly to transparently impersonate a remote server/service.
On error, 0.0.0.0:0 is returned and one of the following error codes is set: errServiceUnavailable - if nat is not supported on the current platform or if it was not compiled; errLookupFail - if the nat syscall failed for some reason (extended error code); errSearchErr - if the socket does not have nat information (i.e. is not nated).
NAT lookup is supported on NetFilter for ipv4 and ipv6 (Linux), IPFilter for ipv4 (Solaris, *BSD except OpenBSD, HP-UX, etc.) and Packet Filter for ipv4 and ipv6 (OpenBSD). When using IPFilter or Packet Filter, the first NAT lookup must be performed as root (the NAT device is read only for root and is opened once, unless an error occurs). Permissions on the nat device may be changed to solve this.
| port | ptr to NATed port number on local host. |
Examine address of sender of next waiting packet.
This also sets "peer" address to the sender so that the next "send" message acts as a "reply". This additional behavior overides the standard socket getSender behavior.
| port | pointer to hold port number. |
Examine address of sender of next waiting packet.
This also sets "peer" address to the sender so that the next "send" message acts as a "reply". This additional behavior overides the standard socket getSender behavior.
| port | pointer to hold port number. |
May be used to examine the origin of data waiting in the socket receive queue.
This can tell a TCP server where pending "connect" requests are coming from, or a UDP socket where it's next packet arrived from.
| port | ptr to port number of sender. |
Reimplemented in DCCPSocket.
|
inlineprotectedinherited |
|
inlineprotectedinherited |
|
inlineinherited |
Definition at line 187 of file queuebase.h.
|
inlineprotectedinherited |
Definition at line 217 of file queuebase.h.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Definition at line 305 of file queuebase.h.
|
inlineinherited |
Definition at line 276 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 |
|
protected |
|
inlineprotectedinherited |
|
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.
|
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.
|
inherited |
|
inherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
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 |
|
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. |
|
inlineinherited |
|
inherited |
Test to see if the socket is at least operating or if it is mearly initialized.
"initialized" sockets may be the result of failed constructors.
|
inherited |
Test to see if the socket is at least operating or if it is mearly initialized.
"initialized" sockets may be the result of failed constructors.
|
inlineinherited |
|
inlineinherited |
|
inherited |
|
inherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
inlineinherited |
|
virtualinherited |
Get the status of pending operations.
This can be used to examine if input or output is waiting, or if an error has occured on the descriptor.
| pend | ready check to perform. |
| timeout | in milliseconds, inf. if not specified. |
Reimplemented in SimpleTCPStream, TCPStream, and UnixStream.
|
inlineprotectedvirtual |
| timeout | how much time to wait for new data |
Implements RTPDataQueue.
|
inlineprotectedinherited |
|
protectedinherited |
Returns whether there is already a synchronizacion source with "ssrc" SSRC identifier.
|
inlineinherited |
|
inlineinherited |
|
inherited |
Determine if outgoing packets are waiting to send.
|
inlineinherited |
|
inherited |
Determine if packets are waiting in the reception queue.
| src | Optional synchronization source selector. |
|
inherited |
join a multicast group on a particular interface
| ia | is the multicast address to use |
| InterfaceIndex | is the index value returned by getInterfaceIndex |
|
inherited |
join a multicast group on a particular interface
| ia | is the multicast address to use |
| InterfaceIndex | is the index value returned by getInterfaceIndex |
|
inlineprotectedinherited |
|
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.
|
inherited |
Operator based testing to see if a socket is currently active.
|
inherited |
Operator based testing to see if a socket is currently active.
|
inlineinherited |
|
inlineinherited |
|
protectedinherited |
|
protectedinherited |
|
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. |
|
protectedvirtualinherited |
Read in a block of len bytes with specific separator.
Can be zero, or any other char. If \n or \r, it's treated just like a readLine(). Otherwise it looks for the separator.
| buf | pointer to byte allocation. |
| len | maximum length to read. |
| separator | separator for a particular ASCII character |
| t | timeout for pending data in milliseconds. |
|
protectedinherited |
Process a logical input line from a socket descriptor directly.
| buf | pointer to string. |
| len | maximum length to read. |
| timeout | for pending data in milliseconds. |
|
protectedinherited |
Process a logical input line from a socket descriptor directly.
| buf | pointer to string. |
| len | maximum length to read. |
| timeout | for pending data in milliseconds. |
|
inherited |
Receive a message from any host.
| buf | pointer to packet buffer to receive. |
| len | of packet buffer to receive. |
| reply | save sender address for reply if true. |
|
inherited |
Receive a message from any host.
| buf | pointer to packet buffer to receive. |
| len | of packet buffer to receive. |
| reply | save sender address for reply if true. |
|
inlineinherited |
|
protectedinherited |
Set the protocol stack network kernel receive buffer size associated with the socket.
| size | of buffer in bytes. |
|
protectedinherited |
Set the protocol stack network kernel receive buffer size associated with the socket.
| size | of buffer in bytes. |
|
protectedinherited |
Set thr receive limit.
|
protectedinherited |
Set thr receive limit.
Receive timeout for receiving raw network data.
| timer | value in milliseconds. |
Receive timeout for receiving raw network data.
| timer | value in milliseconds. |
|
protectedinherited |
Log extraction of a packet from this source from the scheduled reception queue.
| pkt | Packet extracted from the queue. |
|
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. |
|
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.
|
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 |
|
inherited |
Remove output queue CryptoContext.
The endQueue method (provided by RTPQueue) also deletes all registered CryptoContexts.
| cc | Pointer to initialized CryptoContext to remove. |
|
inlineinherited |
|
protectedinherited |
Remove the description of the source identified by ssrc
|
inlineprotectedvirtualinherited |
Reimplemented from RTPQueueBase.
|
inherited |
| na | Inet network address. |
| ctp | Data transport port. |
|
inherited |
| na | Inet network address. |
| dtp | Data transport port. |
|
inherited |
Send a message packet to a peer host.
| buf | pointer to packet buffer to send. |
| len | of packet buffer to send. |
|
inlineprotectedinherited |
|
protectedinherited |
Set the protocol stack network kernel send buffer size associated with the socket.
| size | of buffer in bytes. |
|
protectedinherited |
Set the protocol stack network kernel send buffer size associated with the socket.
| size | of buffer in bytes. |
|
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. |
|
protectedinherited |
Set the send limit.
|
protectedinherited |
Set the send limit.
Set the send timeout for sending raw network data.
| timer | value in millisec. |
Set the send timeout for sending raw network data.
| timer | value in millisec. |
|
protectedinherited |
Set the subnet broadcast flag for the socket.
This enables sending to a subnet and may require special image privileges depending on the operating system.
| enable | when set to true. |
|
inlineinherited |
|
inherited |
Used to specify blocking mode for the socket.
A socket can be made non-blocking by setting setCompletion(false) or set to block on all access with setCompletion(true). I do not believe this form of non-blocking socket I/O is supported in winsock, though it provides an alternate asynchronous set of socket services.
| immediate | mode specify socket I/O call blocking mode. |
|
inherited |
Used to specify blocking mode for the socket.
A socket can be made non-blocking by setting setCompletion(false) or set to block on all access with setCompletion(true). I do not believe this form of non-blocking socket I/O is supported in winsock, though it provides an alternate asynchronous set of socket services.
| immediate | mode specify socket I/O call blocking mode. |
|
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 |
|
inlineprotectedinherited |
|
inlineprotectedinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
inherited |
Set input queue CryptoContext.
The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.
| cc | Pointer to initialized CryptoContext. |
|
inherited |
Enable lingering sockets on close.
| linger | specify linger enable. |
|
inherited |
Enable lingering sockets on close.
| linger | specify linger enable. |
|
inlineinherited |
|
inlineprotectedinherited |
Definition at line 214 of file queuebase.h.
|
inlineinherited |
|
inlineinherited |
Set the multicast loopback flag for the socket.
Loopback enables a socket to hear what it is sending.
| enable | when set to true. |
| family | of protocol. |
Set the multicast loopback flag for the socket.
Loopback enables a socket to hear what it is sending.
| enable | when set to true. |
| family | of protocol. |
|
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 319 of file queuebase.h.
|
inlineinherited |
Set maximum payload segment size before fragmenting sends.
| size | Maximum payload size. |
Definition at line 272 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 |
|
inlineprotectedinherited |
|
inlineprotectedinherited |
Setting multicast binds the multicast interface used for the socket to the interface the socket itself has been implicitly bound to.
It is also used as a check flag to make sure multicast is enabled before multicast operations are used.
| enable | when set to true. |
| family | of protocol. |
Setting multicast binds the multicast interface used for the socket to the interface the socket itself has been implicitly bound to.
It is also used as a check flag to make sure multicast is enabled before multicast operations are used.
| enable | when set to true. |
| family | of protocol. |
|
inlineinherited |
|
inlineprotectedinherited |
|
protectedinherited |
Enable/disable delaying packets (Nagle algorithm)
| enable | disable Nagle algorithm when set to true. |
|
protectedinherited |
Enable/disable delaying packets (Nagle algorithm)
| enable | disable Nagle algorithm when set to true. |
|
inherited |
Set ouput queue CryptoContext.
The endQueue method (provided by RTPQueue) deletes all registered CryptoContexts.
| cc | Pointer to initialized CryptoContext. |
|
inlineinherited |
|
inherited |
|
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 180 of file queuebase.h.
set the peer address to send message packets to.
This can be set before every send() call if nessisary.
| host | address to send packets to. |
| port | number to deliver packets to. |
set the peer address to send message packets to.
This can be set before every send() call if nessisary.
| host | address to send packets to. |
| port | number to deliver packets to. |
|
inherited |
Associate socket with a named connection.
|
inherited |
Associate socket with a named connection.
|
inlineinherited |
|
inlineinherited |
|
inlineprotectedinherited |
|
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 |
|
inlineinherited |
|
inlineprotectedinherited |
Set the multicast time to live for a multicast socket.
| ttl | time to live. |
| fam | family of protocol. |
Set the multicast time to live for a multicast socket.
| ttl | time to live. |
| fam | family of protocol. |
|
inlineinherited |
Specify the kind of service the application expects to use.
| tos | type of service the application expects to use |
Set packet scheduling on platforms which support ip quality of service conventions.
This effects how packets in the queue are scheduled through the interface.
| service | type of service enumerated type. |
|
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.
|
inlineprotectedvirtualinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
protectedvirtualinherited |
Write a block of len bytes to socket.
| buf | pointer to byte allocation. |
| len | maximum length to write. |
| t | timeout for pending data in milliseconds. |
|
inlineprotectedinherited |
|
protectedinherited |
|
protectedinherited |
|
mutableprotectedinherited |
|
mutableprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
protectedinherited |
|
protectedinherited |
| struct { ... } Socket::flags |
| struct { ... } Socket::flags |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
| union { ... } UDPSocket::peer |
| union { ... } UDPSocket::peer |
|
protectedinherited |
|
protectedinherited |
|
mutableprotectedinherited |
|
staticprotectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
1.8.6