Моя программа всегда использовала зависящий от платформы синхронный прием, который блокировал выполнение до истечения времени ожидания или получения события, например:
recv(buf, size, timeout);
Теперь я хочу заменить этот код на boost, чтобы сделать его кроссплатформенным. Я нашел решение, но я думаю, что оно довольно уродливо (по сравнению с вызовом одной функции). Я написал это:
void IPV4_HOST::recv_timer_handler(const boost::system::error_code & e)
{
if (e.value() == boost::system::errc::success) {
f_recv_timeout = true;
asio_socket.cancel();
}
}
void IPV4_HOST::recv_handler(const boost::system::error_code & , size_t bytes)
{
recv_timer.cancel();
bytes_received = bytes;
}
int IPV4_HOST::receive(void * buf, size_t buf_size, TIME::INTERVAL timeout)
{
f_recv_timeout = false;
bytes_received = 0;
recv_timer.expires_from_now(timeout.get_boost_milli());
recv_timer.async_wait(boost::bind(&IPV4_HOST::recv_timer_handler, this, boost::asio::placeholders::error));
asio_socket.async_read_some(boost::asio::buffer(buf, buf_size),
boost::bind(&IPV4_HOST::recv_handler, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));
io_service.run();
if (f_recv_timeout)
throw IO::TimeoutReceiveException();
return bytes_received;
}
Не подскажете, правильно я делаю или нет? Есть ли более простой способ сделать это?