当前位置: 首页 > 面试题库 >

SO_RCVTIME和SO_RCVTIMEO不影响Boost.Asio操作

方兴旺
2023-03-14
问题内容

下面是我的代码

boost::asio::io_service io;
boost::asio::ip::tcp::acceptor::reuse_address option(true);
boost::asio::ip::tcp::acceptor accept(io);
boost::asio::ip::tcp::resolver resolver(io);
boost::asio::ip::tcp::resolver::query query("0.0.0.0", "8080");
boost::asio::ip::tcp::endpoint endpoint = *resolver.resolve(query);
accept.open(endpoint.protocol());
accept.set_option(option);
accept.bind(endpoint);
accept.listen(30);

boost::asio::ip::tcp::socket ps(io);

accept.accept(ps);

struct timeval tv;
tv.tv_sec = 1;
tv.tv_usec = 0;
//setsockopt(ps.native(), SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv));
setsockopt(ps.native(), SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
char buf[1024];
ps.async_receive(boost::asio::buffer(buf, 1024), boost::bind(fun));
io.run();

当我使用Telnet进行连接但不发送数据时,它不会与Telnet超时断开连接。需要做些setockopt踢吗?谢谢!

我已经将SO_RCVTIMEO修改为SO_SNDTIMEO。在指定的时间内仍无法超时


问题答案:

在Boost.Asio中使用SO_RCVTIMEOSO_SNDTIMEO套接字选项很少会产生所需的行为。考虑使用以下两种模式之一:

组成操作 async_wait()

可以使用Boost.Asio计时器和具有该async_wait()操作的async_receive()操作来构成具有超时的异步读取操作。Boost.Asio
超时示例中演示了这种方法,类似于:

// Start a timeout for the read.
boost::asio::deadline_timer timer(io_service);
timer.expires_from_now(boost::posix_time::seconds(1));
timer.async_wait(
  [&socket, &timer](const boost::system::error_code& error)
  {
    // On error, such as cancellation, return early.
    if (error) return;

    // Timer has expired, but the read operation's completion handler
    // may have already ran, setting expiration to be in the future.
    if (timer.expires_at() > boost::asio::deadline_timer::traits_type::now())
    {
      return;
    }

    // The read operation's completion handler has not ran.
    boost::system::error_code ignored_ec;
    socket.close(ignored_ec);
  });

// Start the read operation.
socket.async_receive(buffer,
  [&socket, &timer](const boost::system::error_code& error,
    std::size_t bytes_transferred)
  {
    // Update timeout state to indicate the handler has ran.  This
    // will cancel any pending timeouts.
    timer.expires_at(boost::posix_time::pos_infin);

    // On error, such as cancellation, return early.
    if (error) return;

    // At this point, the read was successful and buffer is populated.
    // However, if the timeout occurred and its completion handler ran first,
    // then the socket is closed (!socket.is_open()).
  });

请注意,两个异步操作都可能在同一迭代中完成,这使得两个完成处理程序都可以成功运行。因此,这是两个完成处理程序都需要更新和检查状态的原因。有关如何管理状态的更多详细信息,请参见此答案。

采用 std::future

Boost.Asio 支持C ++
11期货
。当boost::asio::use_future提供作为异步操作的完成处理程序时,初始化函数将返回a
std::future,该操作将在操作完成后实现。由于std::future支持定时等待,因此可以利用它来使操作超时。请注意,由于调用线程将被阻塞以等待将来,因此至少另一个线程必须正在处理,io_service以允许async_receive()操作进行并实现诺言:

// Use an asynchronous operation so that it can be cancelled on timeout.
std::future<std::size_t> read_result = socket.async_receive(
   buffer, boost::asio::use_future);

// If timeout occurs, then cancel the read operation.
if (read_result.wait_for(std::chrono::seconds(1)) == 
    std::future_status::timeout)
{
  socket.cancel();
}
// Otherwise, the operation completed (with success or error).
else
{
  // If the operation failed, then read_result.get() will throw a
  // boost::system::system_error.
  auto bytes_transferred = read_result.get();
  // process buffer
}

为什么SO_RCVTIMEO不起作用

系统行为

SO_RCVTIMEO文件指出,该选项仅影响系统调用执行套接字I /
O,如read()recvmsg()。它不会影响事件多路分解器(例如select()和)poll(),它们仅监视文件描述符来确定何时可以发生I
/ O而不会阻塞。此外,当确实发生超时时,I / O调用将无法返回-1并设置errnoEAGAINEWOULDBLOCK

指定接收或发送超时,直到报告错误。[…]如果没有数据被传输和达到超时然后-1返回,并将errno设置EAGAINEWOULDBLOCK[…]超时只对系统调用执行套接字I
/ O(效应,例如,read()recvmsg(),[。
..];超时有任何效果select()poll()epoll_wait(),等。

当底层的文件描述符设置为非阻塞,系统调用执行套接字I /
O将立即返回EAGAIN或者EWOULDBLOCK如果资源不立即可用。对于非阻塞套接字,SO_RCVTIMEO将不会有任何影响,因为调用成功或失败都会立即返回。因此,为了SO_RCVTIMEO影响系统I
/ O调用,套接字必须处于阻塞状态。

Boost.Asio行为

首先,Boost.Asio中的异步I /
O操作将使用事件多路分解器,例如select()poll()。因此,SO_RCVTIMEO将不会影响异步操作。

接下来,Boost.Asio的套接字具有两种非阻塞模式的概念(两种模式均默认为false):

  • native_non_blocking()模式大致对应于文件描述符的非阻塞状态。此模式影响系统I / O调用。例如,如果调用socket.native_non_blocking(true),则设置为或recv(socket.native_handle(), ...)可能会失败。每当在套接字上启动异步操作时,Boost.Asio都会启用此模式。errno``EAGAIN``EWOULDBLOCK
  • non_blocking()模式会影响Boost.Asio的同步套接字操作。设置true为时,Boost.Asio会将基础文件描述符设置为非阻塞,并且同步的Boost.Asio套接字操作可能会失败boost::asio::error::would_block(或等效的系统错误)。当设置为false,Boost.Asio的将阻塞,即使底层的文件描述符是无阻塞,通过轮询文件描述符和重新尝试的系统I / O操作是否EAGAINEWOULDBLOCK返回。

的行为non_blocking()防止SO_RCVTIMEO从产生所需的行为。假设socket.receive()调用并且数据既不可用也不接收:

  • 如果non_blocking()为false,则系统I / O调用将超时SO_RCVTIMEO。但是,Boost.Asio随后将立即阻止对文件描述符的轮询以使其可读,这不受的影响SO_RCVTIMEO。最终结果是呼叫者被阻塞,socket.receive()直到接收到数据或发生故障为止,例如远程对等方关闭连接。
  • 如果non_blocking()为true,则基础文件描述符也是非阻塞的。因此,系统I / O调用将忽略SO_RCVTIMEO,立即通过EAGAIN或返回EWOULDBLOCK,并导致socket.receive()失败boost::asio::error::would_block

理想情况下,SO_RCVTIMEO要与Boost.Asio配合使用,需要native_non_blocking()将其设置为false以使其SO_RCVTIMEO生效,但也需要non_blocking()将其设置为true以防止对描述符进行轮询。但是,Boost.Asio不支持此功能:

socket::native_non_blocking(bool mode)

如果mode为false,但is
的当前值为,non_blocking()true此功能将以失败boost::asio::error::invalid_argument,因为组合没有意义。



 类似资料:
  • 本文向大家介绍MySql删除和更新操作对性能有影响吗,包括了MySql删除和更新操作对性能有影响吗的使用技巧和注意事项,需要的朋友参考一下 删除和更新操作的开销往往比插入高,所以一个好的设计需要减少对数据库的更新和删除操作。 3.1更新操作 数据库的更新操作会带来一连串的“效应”:更新操作需要记录日志(以便错误时回滚);更新可变长字段(如,varchar类型)会带来数据物理存储的变化(记录的移动)

  • 10.4.1. 结果字符串 10.4.2. CONVERT() 10.4.3. CAST() 10.4.4. SHOW语句本节讨论在MySQL5.1中考虑到字符集信息的操作。 10.4.1. 结果字符串MySQL中有许多操作符和函数可以返回字符串。本节回答这个问题:返回的字符串使用什么字符集和校对规则? 对于简单的函数,即接收字符串输入然后返回一个字符串结果作为输出的函数,输出的字符集和校对规则与

  • 如图:右边红色的提示 怎么会这样呢?(头大~) 当父盒子背景色为白色时‘正常’,或者把select的i标签的过渡给取消也就‘正常’了 可利用下面代码测试

  • 问题内容: 当我使用chdir()更改当前工作目录时,为什么getenv(“ PWD”)没有给出当前的工作目录?我还需要setenv(“ PWD”,newDir,1)吗? 输出:(可执行文件的位置是/ home / user) 更改/启动 目录已更改。当前的工作目录是“ / home / user”“ / boot” 问题答案: 是的,如果要更改环境变量,则必须明确地执行此操作。 它是在事件的正常

  • 我在Azure上有3个主节点+3个数据节点elasticsearch集群。我试图执行批量操作,但我得到了关于节点本身的失败错误,以下是我如何设置客户端: 下面是批量操作: 它开始对1000个记录批次做出罚款响应,如下所示: 将执行由{1001}个操作组成的新大容量 然后我开始得到以下错误: 传输:383-[Stanley Stewart]未能获取{#传输#-1}{10.0.0.10}{10.0.0

  • 我应该担心JCenter被弃用吗? 为什么我要将我的库从JCenter迁移到其他Maven存储库? 我可以在Gradle构建脚本中继续使用jcenter()吗?