From fdbbf63f42c8bee7a5afc43e96271d573487dd76 Mon Sep 17 00:00:00 2001 From: dec05eba Date: Sat, 9 Jun 2018 20:25:34 +0200 Subject: Remove disconnected sockets --- include/sibs/DirectConnection.hpp | 1 + 1 file changed, 1 insertion(+) (limited to 'include/sibs/DirectConnection.hpp') diff --git a/include/sibs/DirectConnection.hpp b/include/sibs/DirectConnection.hpp index 10359f9..9786c64 100644 --- a/include/sibs/DirectConnection.hpp +++ b/include/sibs/DirectConnection.hpp @@ -56,6 +56,7 @@ namespace sibs int createSocket(const Ipv4 &addressToBind, bool rendezvous, bool reuseAddr, bool bind = true); private: void connect(const Ipv4 &address, bool rendezvous, bool reuseAddr, PubSubConnectCallback connectCallbackFunc, PubSubReceiveDataCallback receiveDataCallbackFunc); + void removeDisconnectedPeers(); void receiveData(); int receiveDataFromPeer(const int socket, char *output, usize *receivedTotalSize); bool removePeer(int peerSocket); -- cgit v1.2.3