Почему Boost Deadline_timer, используемый в качестве таймаута для async_connect, не работает в Unix?

У меня есть программа, которая использует Boost Asio для асинхронного подключения к 3 сокетов TCP с помощью deadline_timer в качестве таймаута подключения. На windows все работает как положено. Время соединения истекает через 5 секунд. Однако в Unix (Ubuntu на WSL, Linux Mint VM, macOS) connectDeadline никогда не запускается. Операция async_connect просто выполняется вечно. Почему это не работает и как я могу заставить это работать и в Unix?

Код:
Примечание: connect вызывается из основного потока (который также является потоком GUI).

#include "NetManager.h"
NetManager::NetManager(NetManagerListener& listener) :  listener(listener),
connectDeadline(io),
socket1(io),
socket2(io),
socket3(io),
asioThread(&NetManager::handleAsioOperations, this){

}
NetManager::~NetManager() {
running = false;
io.stop();
asioThread.join();
}

void NetManager::connect(){
connectCounter = 0;
hasHandledConnectError = false;
socket1.async_connect(
tcp::endpoint(boost::asio::ip::address::from_string(IP_STRING), PORT_1),
boost::bind(&NetManager::handleConnect, this, _1));
socket2.async_connect(
tcp::endpoint(boost::asio::ip::address::from_string(IP_STRING), PORT_2),
boost::bind(&NetManager::handleConnect, this, _1));
socket3.async_connect(
tcp::endpoint(boost::asio::ip::address::from_string(IP_STRING), PORT_3),
boost::bind(&NetManager::handleConnect, this, _1));
connectDeadline.expires_from_now(boost::posix_time::seconds(CONNECT_TIMEOUT));
connectDeadline.async_wait(boost::bind(&NetManager::handleConnectTimeout, this, _1));
}

void NetManager::disconnect(){
//NOTE: Close also cancels incomplete async operations
socket1.close();
socket2.close();
socket3.close();
}

////////////////////////////////////////////////////////////////////////
/// ASIO Handlers
////////////////////////////////////////////////////////////////////////
void NetManager::handleAsioOperations(){
while(running){
io.run(); // Run any async operations
}
}

void NetManager::handleConnect(const boost::system::error_code &ec){
// When connections are canceled the handler is called with operation_aborted. No need to respond to that.
if(ec && ec != boost::asio::error::operation_aborted && !hasHandledConnectError){
hasHandledConnectError = true; // Likely to be 3 repeated errors. Make sure to only handle the first one
cerr << "Connect Failed: " << ec.message() << endl;
connectDeadline.cancel(); // Don't fire the timeout
disconnect(); // Disconnect any already connected sockets
connectedToRobot = false;
listener.onConnect(false);
}else if (!ec){
connectCounter++;
}

if(connectCounter == 3){
cout << "Successful connect" << endl;
connectDeadline.cancel(); // Don't fire the timeout
connectedToRobot = true;
listener.onConnect(true);
}
}

void NetManager::handleConnectTimeout(const boost::system::error_code &ec){
if(ec != boost::asio::error::operation_aborted){
cerr << "Connect timed out." << endl;
disconnect(); // Disconnect any already connected sockets
connectedToRobot = false;
listener.onConnect(false);
}
}

РЕДАКТИРОВАТЬ:

Смущает, что это прекрасно работает на Unix-системах:

#include <boost/asio.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <iostream>
#include <thread>

using namespace boost::asio;
using namespace boost::asio::ip;

int main(){
io_service io;
deadline_timer timer1(io);
tcp::socket sock(io);

timer1.expires_from_now(boost::posix_time::seconds(3));
sock.async_connect(tcp::endpoint(boost::asio::ip::address::from_string("10.50.30.1"), 8090), [](const boost::system::error_code &ec){
std::cout << "SocketError: " << ec.message() << std::endl;
});
timer1.async_wait([&](const boost::system::error_code &ec){
std::cout << "First timer" << std::endl;
sock.close();
});
std::thread worker([&](){
while(true){
io.run();
}
});
worker.detach();
while(true){} // Simulate the unavailable main (GUI) thread
}

Выход:

First timer
SocketError: Operation canceled

0

Решение

boost::io_service::run останавливается, если нет работы. Вы не должны вызывать его в таком цикле, потому что, как указано в документации:

Обычный выход из функции run () подразумевает, что io_service
объект остановлен (функция stop () возвращает true). последующее
вызовы run (), run_one (), poll () или poll_one () вернутся
немедленно, если нет предварительного вызова reset ().

Вы не показываете, когда вызываете connect () в первом примере, я полагаю, что это произойдет не скоро, поэтому тот факт, что он работает или нет, зависит от скорости запуска потока и run() звонок выполнен.

Вы можете обойти это поведение, используя boost::io_service::work что предотвратит io_service от работы без работы.

0

Другие решения

Хорошо, я нашел ответ после тестирования множества различных сценариев как в Ubuntu, так и в Windows. Оказывается, используя поток для непрерывного вызова io_service::run не работает на ОС Unix, если поток вызывает io_service.run создается перед асинхронными задачами (async_wait, async_connect) запущены. Во втором примере я разместил разрывы (в Unix, а не в Windows), если рабочий поток был создан до обращения к async_connect а также async_wait, Я только что изменил свой класс NetManger, чтобы удалить постоянно работающий поток.

#include <boost/asio.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <thread>

using namespace boost::asio;
using namespace boost::asio::ip;

class NetManager{
private:
io_service io;
tcp::socket socket1, socket2, socket3;
deadline_timer connectDeadline;
int connectCounter = 0;

void handleConnect(const boost::system::error_code &ec){
if(ec){
std::cout << "Connect error: " << ec.message() << std::endl;
connectDeadline.cancel();
disconnect();
}else
connectCounter++;
if(connectCounter == 3)
std::cout << "Connected" << std::endl;

}
void handleConnectTimeout(const boost::system::error_code &ec){
std::cout << "Timeout fired." << std::endl;
disconnect();
}
public:
void connect(){
connectCounter = 0;
connectDeadline.expires_from_now(boost::posix_time::seconds(5));
socket1.async_connect(tcp::endpoint(boost::asio::ip::address::from_string("10.50.30.1"), 8090), boost::bind(&NetManager::handleConnect, this, _1));
socket2.async_connect(tcp::endpoint(boost::asio::ip::address::from_string("10.50.30.1"), 8091), boost::bind(&NetManager::handleConnect, this, _1));
socket3.async_connect(tcp::endpoint(boost::asio::ip::address::from_string("10.50.30.1"), 8092), boost::bind(&NetManager::handleConnect, this, _1));
connectDeadline.async_wait(boost::bind(&NetManager::handleConnectTimeout, this, _1));
std::thread([&]{io.run();}).detach(); // Run the async operations on a separate thread
}
void disconnect(){
socket1.close();
socket2.close();
socket3.close();
}
NetManager(): connectDeadline(io),
socket1(io),
socket2(io),
socket3(io){

}
~NetManager(){
io.stop();
}
};

int main(){
NetManager manager;
manager.connect();
std::cout << "Trying to connect..." << std::endl;
while(true); // Simulate the busy main (GUI) thread.
}
0

По вопросам рекламы [email protected]