[[using locked(m_GroupLock)]];
| 1022 | |
| 1023 | // [[using locked(m_GroupLock)]]; |
| 1024 | void CUDTGroup::syncWithSocket(const CUDT& core, const HandshakeSide side) |
| 1025 | { |
| 1026 | if (side == HSD_RESPONDER) |
| 1027 | { |
| 1028 | // On the listener side you should synchronize ISN with the incoming |
| 1029 | // socket, which is done immediately after creating the socket and |
| 1030 | // adding it to the group. On the caller side the ISN is defined in |
| 1031 | // the group directly, before any member socket is created. |
| 1032 | set_currentSchedSequence(core.ISN()); |
| 1033 | } |
| 1034 | |
| 1035 | // Only set if was not initialized to avoid problems on a running connection. |
| 1036 | if (m_RcvBaseSeqNo == SRT_SEQNO_NONE) |
| 1037 | m_RcvBaseSeqNo = CSeqNo::decseq(core.m_iPeerISN); |
| 1038 | |
| 1039 | // Get the latency (possibly fixed against the opposite side) |
| 1040 | // from the first socket (core.m_iTsbPdDelay_ms), |
| 1041 | // and set it on the current socket. |
| 1042 | set_latency_us(core.m_iTsbPdDelay_ms * int64_t(1000)); |
| 1043 | } |
| 1044 | |
| 1045 | void CUDTGroup::close() |
| 1046 | { |
no test coverage detected