diff options
| author | dec05eba <dec05eba@protonmail.com> | 2018-06-09 20:25:34 +0200 |
|---|---|---|
| committer | dec05eba <dec05eba@protonmail.com> | 2020-08-18 22:56:48 +0200 |
| commit | fdbbf63f42c8bee7a5afc43e96271d573487dd76 (patch) | |
| tree | 2535682c7e80b4dc860a4325daa7ca5bcfa18ff8 /include/sibs | |
| parent | 2ab647fd5f17cd59cae13206d03e1415c63c31bc (diff) | |
Remove disconnected sockets
Diffstat (limited to 'include/sibs')
| -rw-r--r-- | include/sibs/DirectConnection.hpp | 1 |
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); |