diff options
author | Aleksi Lindeman <dec05eba@protonmail.com> | 2018-11-25 00:22:29 +0100 |
---|---|---|
committer | Aleksi Lindeman <dec05eba@protonmail.com> | 2018-11-25 00:22:29 +0100 |
commit | 3f6c75b1ee660b9fceefa1a021bae59b581637b7 (patch) | |
tree | c4adab6b586d6c7f55fcfb7266d577cbf6db4ba1 /src/DirectConnection.cpp | |
parent | 84fc5532fd447cfb43ed26dca0240eee669b8338 (diff) |
Remove duplicate user add if same pubsub key, do not add user until connected
Diffstat (limited to 'src/DirectConnection.cpp')
-rw-r--r-- | src/DirectConnection.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/DirectConnection.cpp b/src/DirectConnection.cpp index 175dae3..d92c972 100644 --- a/src/DirectConnection.cpp +++ b/src/DirectConnection.cpp @@ -160,8 +160,6 @@ namespace sibs int socketId = socket->udtSocket; if(!server) { - UDT::epoll_add_usock(eid, socketId); - socket->eid = eid; peersMutex.lock(); peers[socketId] = peer; peer->socket = std::move(socket); @@ -184,8 +182,6 @@ namespace sibs if(server) { - UDT::epoll_add_usock(eid, socketId); - socket->eid = eid; peersMutex.lock(); peers[socketId] = peer; peer->socket = std::move(socket); @@ -195,6 +191,8 @@ namespace sibs peer->sharedKeys = 1; peersMutex.unlock(); } + UDT::epoll_add_usock(eid, socketId); + peer->socket->eid = eid; peer->routed = false; if(connectCallbackFunc) |