From 10b5eab3e2ba705b73ce3d8b7d8c623ba09bfc82 Mon Sep 17 00:00:00 2001 From: dec05eba Date: Sat, 13 Oct 2018 20:26:02 +0200 Subject: remove test code --- src/BootstrapConnection.cpp | 2 +- src/DirectConnection.cpp | 32 +------------------------------- 2 files changed, 2 insertions(+), 32 deletions(-) (limited to 'src') diff --git a/src/BootstrapConnection.cpp b/src/BootstrapConnection.cpp index 924fcff..9a19943 100644 --- a/src/BootstrapConnection.cpp +++ b/src/BootstrapConnection.cpp @@ -61,7 +61,7 @@ namespace sibs newPeerAddress.address.sin_addr.s_addr = ipv4Address; newPeerAddress.address.sin_port = port; memset(newPeerAddress.address.sin_zero, 0, sizeof(newPeerAddress.address.sin_zero)); - connections.connect(newPeerAddress, peer, [this, pubsubKey](std::shared_ptr newPeer, PubSubResult result, const std::string &resultStr) + connections.connect(newPeerAddress, [this, pubsubKey](std::shared_ptr newPeer, PubSubResult result, const std::string &resultStr) { if(result == PubSubResult::OK) { diff --git a/src/DirectConnection.cpp b/src/DirectConnection.cpp index c19fa63..4a2c829 100644 --- a/src/DirectConnection.cpp +++ b/src/DirectConnection.cpp @@ -75,43 +75,13 @@ namespace sibs void DirectConnections::connectServer(const Ipv4 &address, PubSubConnectCallback connectCallbackFunc, PubSubReceiveDataCallback receiveDataCallbackFunc) { - connect(address, true, true, connectCallbackFunc, receiveDataCallbackFunc, true); + connect(address, false, true, connectCallbackFunc, receiveDataCallbackFunc, true); } void DirectConnections::connect(const Ipv4 &address, PubSubConnectCallback connectCallbackFunc, PubSubReceiveDataCallback receiveDataCallbackFunc) { connect(address, true, true, connectCallbackFunc, receiveDataCallbackFunc, true); } - - void DirectConnections::connect(const Ipv4 &address, std::shared_ptr serverPeer, PubSubConnectCallback connectCallbackFunc, PubSubReceiveDataCallback receiveDataCallbackFunc) - { - std::thread([this, address, connectCallbackFunc, receiveDataCallbackFunc, serverPeer]() - { - if(UDT::bind(serverPeer->socket, (sockaddr*)&address.address, sizeof(address.address)) == UDT::ERROR) - { - std::string errMsg = "UDT: Failed to bind, error: "; - errMsg += UDT::getlasterror_desc(); - throw SocketCreateException(errMsg); - } - - Log::debug("DirectConnections: Connecting to peer (ip: %s, port: %d, rendezvous: yes)", address.getAddress().c_str(), address.getPort()); - if(UDT::connect(serverPeer->socket, (sockaddr*)&address.address, sizeof(address.address)) == UDT::ERROR) - { - if(connectCallbackFunc) - connectCallbackFunc(serverPeer, PubSubResult::ERROR, UDT::getlasterror_desc()); - return; - } - - serverPeer->address = address; - serverPeer->receiveDataCallbackFunc = receiveDataCallbackFunc; - peersMutex.lock(); - peers[serverPeer->socket] = serverPeer; - peersMutex.unlock(); - - if(connectCallbackFunc) - connectCallbackFunc(serverPeer, PubSubResult::OK, ""); - }).detach(); - } void DirectConnections::connect(const Ipv4 &address, bool rendezvous, bool reuseAddr, PubSubConnectCallback connectCallbackFunc, PubSubReceiveDataCallback receiveDataCallbackFunc, bool bind) { -- cgit v1.2.3