aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/DirectConnection.cpp20
1 files changed, 20 insertions, 0 deletions
diff --git a/src/DirectConnection.cpp b/src/DirectConnection.cpp
index ce63eaf..e6b5645 100644
--- a/src/DirectConnection.cpp
+++ b/src/DirectConnection.cpp
@@ -158,6 +158,25 @@ namespace sibs
return wasRemoved;
}
+ void DirectConnections::removeDisconnectedPeers()
+ {
+ peersMutex.lock();
+ for(std::unordered_map<int, std::shared_ptr<DirectConnectionPeer>>::iterator it = peers.begin(); it != peers.end(); )
+ {
+ UDTSTATUS peerSocketStatus = UDT::getsockstate(it->first);
+ if(peerSocketStatus == UDTSTATUS::BROKEN || peerSocketStatus == UDTSTATUS::CLOSING || peerSocketStatus == UDTSTATUS::CLOSED || peerSocketStatus == UDTSTATUS::NONEXIST)
+ {
+ int socket = it->first;
+ Log::debug("UDT: Connection was broken to socket %d (peer most likely disconnected), removing peer", socket);
+ it = peers.erase(it);
+ Log::debug("UDT: Removed peer socket %d", socket);
+ }
+ else
+ ++it;
+ }
+ peersMutex.unlock();
+ }
+
void DirectConnections::receiveData()
{
std::vector<char> data;
@@ -167,6 +186,7 @@ namespace sibs
std::set<UDTSOCKET> readfds;
while(alive)
{
+ removeDisconnectedPeers();
int numfsReady = UDT::epoll_wait(eid, &readfds, nullptr, 1000);
if(numfsReady == 0)
{