aboutsummaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authordec05eba <0xdec05eba@gmail.com>2018-06-09 20:25:34 +0200
committerdec05eba <0xdec05eba@gmail.com>2018-06-09 20:25:39 +0200
commitdb6b1132f4c92e038a8a80e21dec9a67aecf6a49 (patch)
tree63ee23ba23fabc5c28a213bdba48613c3e645edc /include
parent3c16f782c36348fa3b817d0d0ba779e0d06b442b (diff)
Remove disconnected sockets
Diffstat (limited to 'include')
-rw-r--r--include/sibs/DirectConnection.hpp1
1 files changed, 1 insertions, 0 deletions
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);