BTH/axyz
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Connect Fix for TCP Client

Browse Source
This commit is contained in:
Jocke
2016-02-10 20:10:20 +01:00
parent 7cbdc33f84
commit 95fa1f4bbd
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Engine/Network/TCPClient.cpp
+14 -5
View File
@@ -19,16 +19,25 @@ void TCPClient::Connect(std::string playerName, std::string address, int port)
Send(packet); Send(packet);
LOG_INFO("Connect message sent again!"); LOG_INFO("Connect message sent again!");
} }
return; else {
boost::system::error_code error = boost::asio::error::host_not_found;
m_Socket->connect(m_Endpoint, error);
if (!error) {
m_IsConnected = true;
Packet packet(MessageType::Connect, m_SendPacketID);
packet.WriteString(playerName);
Send(packet);
LOG_INFO("Connect message sent!");
}
}
} }
if (!m_IsConnected) { else if (!m_IsConnected) {
boost::system::error_code error = boost::asio::error::host_not_found; boost::system::error_code error = boost::asio::error::host_not_found;
m_Endpoint = tcp::endpoint(boost::asio::ip::address::from_string(address), port); m_Endpoint = tcp::endpoint(boost::asio::ip::address::from_string(address), port);
m_Socket = std::unique_ptr<tcp::socket>(new tcp::socket(m_IOService, m_Endpoint)); m_Socket = std::unique_ptr<tcp::socket>(new tcp::socket(m_IOService));
m_Socket->connect(m_Endpoint, error);
tcp::no_delay option(true); tcp::no_delay option(true);
m_Socket->set_option(option); m_Socket->set_option(option);
m_Socket->close();
m_Socket->connect(m_Endpoint, error);
LOG_INFO(error.message().c_str()); LOG_INFO(error.message().c_str());
if (!error) { if (!error) {
m_IsConnected = true; m_IsConnected = true;