This function is called by the same premises as the CUDT::CUDT(const CUDT&) (copy constructor). The intention is to rewrite the part that comprises se

@brief Performs an atomic exchange operation. The value of the atomic object is unconditionally updated to the new value, and the old value is return

Returns true if the buffer is full. Requires locking.

[[nullable]]*/

[[using locked(this->m_GroupLock)]];

Retrieve input bitrate in bytes per second

Mark the key as already sent. When no 'runtime' (during the handshake) it actually does nothing so that this will be retried as long as the handshake

Check if the key stored at @c ki shall be sent. When during the handshake, it only matters if the KM message for that index is recorded at all. Otherw

Return moving average of acked data pkts, bytes, and timespan (ms) of the receive buffer */

[[using assert(pg->m_iBusy > 0)]]

Parse Keying Material message */

* Prepare context switch * both odd & even keys announced */

NOTE: this operator is not reversible. The syntax must use: muxer_entry == socket_entry

Validate iPktSeqno is in range (iBaseSeqno - m_iSeqNoTH/2; iBaseSeqno + m_iSeqNoTH). EXPECT_EQ(isValidSeqno(125, 124), true); // behind EXPECT_EQ(isV

@returns the current value of the atomic object. @note Be careful about how this is used, since any operations on the returned value are inherently no

Script designed to generate release notes template with main sections, contributors list, and detailed changelog out of .csv SRT git log file

Tells if an early ACK is needed (before the next Full ACK happening every 10ms). In FileCC, treat non-full-payload as an end-of-message (stream) and r

XXX NOTE: TSan reports here false positive against the call to CRcvQueue::removeListener. This here will apply shared lock on m_GlobControlLock in the

Utility used for closing a listening socket immediately to free the socket