ccRTP
RTPDataQueue Member List

This is the complete list of members for RTPDataQueue, including all inherited members.

addConflict(const InetAddress &na, tpport_t dtp, tpport_t ctp)ConflictHandlerprotected
addContributor(uint32 csrc)OutgoingDataQueue
addDestination(const InetHostAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)OutgoingDataQueue
addDestination(const InetMcastAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)OutgoingDataQueue
addDestinationToList(const InetAddress &ia, tpport_t data, tpport_t control)DestinationListHandlerprotected
addParticipant(RTPApplication &app, Participant &part)ApplicationHandlerinlineprotected
ApplicationHandler()ApplicationHandlerinlineprotected
begin()IncomingDataQueueinline
BYESource(uint32 ssrc)MembershipBookkeepingprotected
checkSSRCInIncomingRTPPkt(SyncSourceLink &sourceLink, bool is_new, InetAddress &na, tpport_t tp)IncomingDataQueueprotected
completeOutgoingDataQueue
ConflictHandler()ConflictHandlerinlineprotected
IncomingDataQueue::cryptoContextsIncomingDataQueueprotected
OutgoingDataQueue::cryptoContextsOutgoingDataQueueprotected
IncomingDataQueue::cryptoMutexIncomingDataQueuemutableprotected
OutgoingDataQueue::cryptoMutexOutgoingDataQueuemutableprotected
defaultMaxPacketDropoutIncomingDataQueueprotectedstatic
defaultMaxPacketMisorderIncomingDataQueueprotectedstatic
defaultMembersHashSizeMembershipBookkeepingprotectedstatic
defaultMembersSizeIncomingDataQueueprotectedstatic
defaultMinValidPacketSequenceIncomingDataQueueprotectedstatic
DestinationListHandler()DestinationListHandlerprotected
destListDestinationListHandlerprotected
disableStack()RTPDataQueueinline
dispatchBYE(const std::string &)RTPQueueBaseinlineprotectedvirtual
dispatchDataPacket()OutgoingDataQueueprotected
dispatchImmediate(OutgoingRTPPkt *packet)OutgoingDataQueueprotected
enableStack()RTPDataQueueinline
end()IncomingDataQueueinline
end2EndDelayed(IncomingRTPPktLink &)IncomingDataQueueinlineprotectedvirtual
endQueue()RTPDataQueueprotected
firstConflictConflictHandlerprotected
forgetDestination(const InetHostAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)OutgoingDataQueue
forgetDestination(const InetMcastAddress &ia, tpport_t dataPort=DefaultRTPDataPort, tpport_t controlPort=0)OutgoingDataQueue
getCurrentPayloadType() constRTPQueueBaseinline
getCurrentRTPClockRate() constRTPQueueBaseinline
getCurrentSeqNum(void)OutgoingDataQueueinlineprotected
getCurrentTimestamp() constRTPDataQueue
getData(uint32 stamp, const SyncSource *src=NULL)IncomingDataQueue
getDefaultExpireTimeout() constOutgoingDataQueueinline
getDefaultMaxPacketDropout() constIncomingDataQueueinline
getDefaultMaxPacketMisorder() constIncomingDataQueueinline
getDefaultMaxRecvPacketSize() constIncomingDataQueueBaseinline
getDefaultMaxSendSegmentSize()OutgoingDataQueueBaseinline
getDefaultMembersHashSize()MembershipBookkeepinginlineprotected
getDefaultMembersSize()IncomingDataQueueinlinestatic
getDefaultMinValidPacketSequence() constIncomingDataQueueinline
getDefaultSchedulingTimeout() constOutgoingDataQueueinline
getDefaultSessionBandwidth() constRTPDataQueueinline
getExpireTimeout() constOutgoingDataQueueinline
getFirst()MembershipBookkeepinginlineprotected
getFirstDestination() constDestinationListHandlerinlineprotected
getFirstTimestamp(const SyncSource *src=NULL) constIncomingDataQueue
getInitialTime() constRTPQueueBaseinline
getInitialTimestamp()OutgoingDataQueueinlineprotected
getInQueueCryptoContext(uint32 ssrc)IncomingDataQueue
getLast()MembershipBookkeepinginlineprotected
getLink(const SyncSource &source) constMembershipBookkeepinginlineprotected
getLocalSSRC() constRTPQueueBaseinline
getLocalSSRCNetwork() constRTPQueueBaseinlineprotected
getMark() constOutgoingDataQueueinline
getMaxPacketDropout() constIncomingDataQueueinline
getMaxPacketMisorder() constIncomingDataQueueinline
getMaxRecvPacketSize() constIncomingDataQueueBaseinline
getMaxSendSegmentSize()OutgoingDataQueueBaseinline
getMembersCount()MembershipBookkeepinginlineprotected
getMinValidPacketSequence() constIncomingDataQueueinline
getNextDataPacketSize() const =0IncomingDataQueueprotectedpure virtual
getOutQueueCryptoContext(uint32 ssrc)OutgoingDataQueue
getSchedulingTimeout()OutgoingDataQueueprotected
getSendersCount()MembershipBookkeepinginlineprotected
getSendOctetCount() constOutgoingDataQueueinline
getSendPacketCount() constOutgoingDataQueueinline
getSequenceNumber() constOutgoingDataQueueinline
getSessionBandwidth() constRTPDataQueueinline
getSourceBySSRC(uint32 ssrc, bool &created)MembershipBookkeepingprotected
getTimeclock() constRTPDataQueueinline
getWaiting(uint32 timestamp, const SyncSource *src=NULL)IncomingDataQueueprotected
IncomingDataQueue(uint32 size)IncomingDataQueueprotected
IncomingDataQueueBase()IncomingDataQueueBaseinlineprotected
insertRecvPacket(IncomingRTPPktLink *packetLink)IncomingDataQueueprotected
isActive() constRTPDataQueueinline
isMine(const SyncSource &source) constMembershipBookkeepinginlineprotected
isPendingData(microtimeout_t timeout)=0RTPDataQueueprotectedpure virtual
isRegistered(uint32 ssrc)MembershipBookkeepingprotected
isSending() constOutgoingDataQueue
isSingleDestination() constDestinationListHandlerinlineprotected
isWaiting(const SyncSource *src=NULL) constIncomingDataQueue
lastConflictConflictHandlerprotected
lockDestinationList() constDestinationListHandlerinlineprotected
markedOutgoingDataQueue
maxPacketDropoutIncomingDataQueueprotected
maxPacketMisorderIncomingDataQueueprotected
MembershipBookkeeping(uint32 initialSize=defaultMembersHashSize)MembershipBookkeepingprotected
minValidPacketSequenceIncomingDataQueueprotected
octetCountOutgoingDataQueue
onExpireRecv(IncomingRTPPkt &)IncomingDataQueueinlineprotectedvirtual
onNewSyncSource(const SyncSource &)IncomingDataQueueinlineprotectedvirtual
onRTPPacketRecv(IncomingRTPPkt &)IncomingDataQueueinlineprotectedvirtual
onSRTPPacketError(IncomingRTPPkt &pkt, int32 errorCode)IncomingDataQueueinlineprotectedvirtual
OutgoingDataQueue()OutgoingDataQueueprotected
OutgoingDataQueueBase()OutgoingDataQueueBaseprotected
overflowTimeOutgoingDataQueue
packetCountOutgoingDataQueue
paddinglenOutgoingDataQueue
ParticipantHandler()ParticipantHandlerinlineprotected
purgeIncomingQueue()IncomingDataQueueprotected
purgeOutgoingQueue()OutgoingDataQueueprotected
putData(uint32 stamp, const unsigned char *data=NULL, size_t len=0)OutgoingDataQueue
recordExtraction(const IncomingRTPPkt &pkt)IncomingDataQueueprotected
recordReception(SyncSourceLink &srcLink, const IncomingRTPPkt &pkt, const timeval recvtime)IncomingDataQueueprotected
recvData(unsigned char *buffer, size_t length, InetHostAddress &host, tpport_t &port)=0IncomingDataQueueprotectedpure virtual
recvFirstIncomingDataQueueprotected
recvLastIncomingDataQueueprotected
recvLockIncomingDataQueuemutableprotected
removeContributor(uint32 csrc)OutgoingDataQueue
removeDestinationFromList(const InetAddress &ia, tpport_t dataPort, tpport_t controlPort)DestinationListHandlerprotected
removeInQueueCryptoContext(CryptoContext *cc)IncomingDataQueue
removeOutQueueCryptoContext(CryptoContext *cc)OutgoingDataQueue
removeParticipant(RTPApplication &app, RTPApplication::ParticipantLink *pl)ApplicationHandlerinlineprotected
removeSource(uint32 ssrc)MembershipBookkeepingprotected
renewLocalSSRC()RTPDataQueueinlineprotectedvirtual
RTPDataQueue(uint32 size=defaultMembersHashSize)RTPDataQueueprotected
RTPDataQueue(uint32 *ssrc, uint32 size=defaultMembersHashSize)RTPDataQueueprotected
RTPQueueBase(uint32 *ssrc=NULL)RTPQueueBaseprotected
searchControlConflict(InetAddress na, tpport_t ctp)ConflictHandlerprotected
searchDataConflict(InetAddress na, tpport_t dtp)ConflictHandlerprotected
sendCCOutgoingDataQueue
sendImmediate(uint32 stamp, const unsigned char *data=NULL, size_t len=0)OutgoingDataQueue
sendSeqOutgoingDataQueue
sendSourcesOutgoingDataQueue
SEQNUMMODMembershipBookkeepingprotectedstatic
setControlPeer(const InetAddress &host, tpport_t port)OutgoingDataQueueinlineprotectedvirtual
setControlTransportPort(SyncSource &source, tpport_t p)SyncSourceHandlerinlineprotected
setDataTransportPort(SyncSource &source, tpport_t p)SyncSourceHandlerinlineprotected
setExpireTimeout(microtimeout_t to)OutgoingDataQueueinline
setInitialTimestamp(uint32 ts)OutgoingDataQueueinlineprotected
setInQueueCryptoContext(CryptoContext *cc)IncomingDataQueue
setLink(SyncSource &source, void *link)SyncSourceHandlerinlineprotected
setLocalSSRC(uint32 ssrc)RTPQueueBaseinlineprotected
setMark(bool mark)OutgoingDataQueueinline
setMaxPacketDropout(uint16 packets)IncomingDataQueueinline
setMaxPacketMisorder(uint16 packets)IncomingDataQueueinline
setMaxRecvPacketSize(size_t maxsize)IncomingDataQueueBaseinline
setMaxSendSegmentSize(size_t size)OutgoingDataQueueBaseinline
setMembersCount(uint32 n)MembershipBookkeepinginlineprotected
setMinValidPacketSequence(uint8 packets)IncomingDataQueueinline
setNetworkAddress(SyncSource &source, InetAddress addr)SyncSourceHandlerinlineprotected
setNextSeqNum(uint32 seqNum)OutgoingDataQueueinlineprotected
setOutQueueCryptoContext(CryptoContext *cc)OutgoingDataQueue
setPadding(uint8 paddinglen)OutgoingDataQueueinline
setPartial(uint32 timestamp, unsigned char *data, size_t offset, size_t max)OutgoingDataQueue
setParticipant(SyncSource &source, Participant &p)SyncSourceHandlerinlineprotected
setPayloadFormat(const PayloadFormat &pf)RTPQueueBaseinline
setPRIVPrefix(Participant *part, const std::string val)ParticipantHandlerinlineprotected
setSchedulingTimeout(microtimeout_t to)OutgoingDataQueueinline
setSDESItem(Participant *part, SDESItemType item, const std::string &val)ParticipantHandlerinlineprotected
setSender(SyncSource &source, bool active)SyncSourceHandlerinlineprotected
setSessionBandwidth(uint32 bw)RTPDataQueueinline
setSourceExpirationPeriod(uint8 intervals)IncomingDataQueueinlineprotected
setState(SyncSource &source, SyncSource::State ns)SyncSourceHandlerinlineprotected
setTimeclock()RTPDataQueueinline
setTypeOfService(Tos tos)RTPDataQueueinline
sourceExpirationPeriodIncomingDataQueueprotected
SyncSourceHandler()SyncSourceHandlerinlineprotected
takeInDataPacket()IncomingDataQueueprotectedvirtual
timerTick()RTPDataQueueinlineprotectedvirtual
Tos enum nameRTPDataQueue
tosBestEffort enum valueRTPDataQueue
tosEnhanced enum valueRTPDataQueue
unlockDestinationList() constDestinationListHandlerinlineprotected
updateConflict(ConflictingTransportAddress &ca)ConflictHandlerinlineprotected
writeLockDestinationList() constDestinationListHandlerinlineprotected
~ApplicationHandler()ApplicationHandlerinlineprotectedvirtual
~ConflictHandler()ConflictHandlerinlineprotectedvirtual
~DestinationListHandler()DestinationListHandlerprotected
~IncomingDataQueue()IncomingDataQueueinlineprotectedvirtual
~IncomingDataQueueBase()IncomingDataQueueBaseinlineprotectedvirtual
~MembershipBookkeeping()MembershipBookkeepinginlineprotectedvirtual
~OutgoingDataQueue()OutgoingDataQueueinlineprotectedvirtual
~OutgoingDataQueueBase()OutgoingDataQueueBaseinlineprotectedvirtual
~ParticipantHandler()ParticipantHandlerinlineprotectedvirtual
~RTPDataQueue()RTPDataQueueinlineprotectedvirtual
~RTPQueueBase()RTPQueueBaseinlineprotectedvirtual
~SyncSourceHandler()SyncSourceHandlerinlineprotectedvirtual