@@ -6108,7 +6108,9 @@ int srt::CUDT::receiveBuffer(char *data, int len)
6108 6108
throw CUDTException(MJ_CONNECTION, MN_CONNLOST, 0);
6109 6109
}
6110 6110 6111 +
enterCS(m_RcvBufferLock);
6111 6112
const int res = m_pRcvBuffer->readBuffer(data, len);
6113 +
leaveCS(m_RcvBufferLock);
6112 6114 6113 6115
/* Kick TsbPd thread to schedule next wakeup (if running) */
6114 6116
if (m_bTsbPd)
@@ -7056,7 +7058,9 @@ int64_t srt::CUDT::recvfile(fstream &ofs, int64_t &offset, int64_t size, int blo
7056 7058
}
7057 7059 7058 7060
unitsize = int((torecv > block) ? block : torecv);
7061 +
enterCS(m_RcvBufferLock);
7059 7062
recvsize = m_pRcvBuffer->readBufferToFile(ofs, unitsize);
7063 +
leaveCS(m_RcvBufferLock);
7060 7064 7061 7065
if (recvsize > 0)
7062 7066
{
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