RetroSearch Browse

Showing content from https://github.com/Haivision/srt/commit/85185585b6af006dcb31c0cd17040e5d141fe1fb below:

File tree Expand file treeCollapse file tree 1 file changed

-2

lines changed

Filter options

Expand file treeCollapse file tree 1 file changed

-2

lines changed Original file line number Diff line number Diff line change


 @@ -8824,11 +8824,14 @@ void srt::CUDT::processCtrlDropReq(const CPacket& ctrlpkt)

8824 8824

8825 8825


 UniqueLock rlock(m_RecvLock);

8826 8826


 const bool using_rexmit_flag = m_bPeerRexmitFlag;

8827

+
 {

8828

+
 ScopedLock rblock(m_RcvBufferLock);

8827 8829


 #if ENABLE_NEW_RCVBUFFER

8828

-
 m_pRcvBuffer->dropMessage(dropdata[0], dropdata[1], ctrlpkt.getMsgSeq(using_rexmit_flag));

8830

+
  m_pRcvBuffer->dropMessage(dropdata[0], dropdata[1], ctrlpkt.getMsgSeq(using_rexmit_flag));

8829 8831


 #else

8830

-
 m_pRcvBuffer->dropMsg(ctrlpkt.getMsgSeq(using_rexmit_flag), using_rexmit_flag);

8832

+
  m_pRcvBuffer->dropMsg(ctrlpkt.getMsgSeq(using_rexmit_flag), using_rexmit_flag);

8831 8833


 #endif

8834

+
 }

8832 8835


 // When the drop request was received, it means that there are

8833 8836


 // packets for which there will never be ACK sent; if the TSBPD thread

8834 8837


 // is currently in the ACK-waiting state, it may never exit.

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