+9
-0
lines changedFilter options
+9
-0
lines changed Original file line number Diff line number Diff line change
@@ -2041,6 +2041,7 @@ vector<CUDTSocket*> CUDTGroup::recv_WaitForReadReady(const vector<CUDTSocket*>&
2041 2041
// This can only happen when 0 is passed as timeout and none is ready.
2042 2042
// And 0 is passed only in non-blocking mode. So this is none ready in
2043 2043
// non-blocking mode.
2044 +
m_Global.m_EPoll.update_events(id(), m_sPollID, SRT_EPOLL_IN, false);
2044 2045
throw CUDTException(MJ_AGAIN, MN_RDAVAIL, 0);
2045 2046
}
2046 2047
@@ -2329,6 +2330,14 @@ int CUDTGroup::recv(char* buf, int len, SRT_MSGCTRL& w_mc)
2329 2330
// m_GlobControlLock lifted, m_GroupLock still locked.
2330 2331
// Now we can safely do this scoped way.
2331 2332 2333 +
if (!m_bSynRecving && ready_sockets.empty())
2334 +
{
2335 +
HLOGC(grlog.Debug,
2336 +
log << "group/rcv $" << m_GroupID << ": Not available AT THIS TIME, NOT READ-READY now.");
2337 +
m_Global.m_EPoll.update_events(id(), m_sPollID, SRT_EPOLL_IN, false);
2338 +
throw CUDTException(MJ_AGAIN, MN_RDAVAIL, 0);
2339 +
}
2340 + 2332 2341
// Ok, now we need to have some extra qualifications:
2333 2342
// 1. If a socket has no registry yet, we read anyway, just
2334 2343
// to notify the current position. We read ONLY ONE PACKET this time,
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