+7
-0
lines changedFilter options
+7
-0
lines changed Original file line number Diff line number Diff line change
@@ -325,6 +325,8 @@ class CRcvBufferNew
325
325
326
326
void setPeerRexmitFlag(bool flag) { m_bPeerRexmitFlag = flag; }
327
327
328
+
void applyGroupISN(int rcv_isn) { m_iStartSeqNo = rcv_isn; }
329
+
328
330
void applyGroupTime(const time_point& timebase, bool wrp, uint32_t delay, const duration& udrift);
329
331
330
332
void applyGroupDrift(const time_point& timebase, bool wrp, const duration& udrift);
Original file line number Diff line number Diff line change
@@ -3333,6 +3333,11 @@ void srt::CUDT::synchronizeWithGroup(CUDTGroup* gp)
3333
3333
<< " (shift by " << CSeqNo::seqcmp(snd_isn, m_iSndLastAck) << ")");
3334
3334
setInitialRcvSeq(rcv_isn);
3335
3335
setInitialSndSeq(snd_isn);
3336
+
#if ENABLE_NEW_RCVBUFFER
3337
+
enterCS(m_RecvLock);
3338
+
m_pRcvBuffer->applyGroupISN(rcv_isn);
3339
+
leaveCS(m_RecvLock);
3340
+
#endif
3336
3341
}
3337
3342
else
3338
3343
{
You can’t perform that action at this time.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4