【问题标题】:Is there a way to avoid HUP once you used O_NONBLOCK on a socket?在套接字上使用 O_NONBLOCK 后有没有办法避免 HUP?
【发布时间】:2015-12-06 02:05:37
【问题描述】:

当我在阻塞模式下使用套接字时,我可以有一个简单的系统来做这样的事情:

client            server

A -------------------> B
      register

A <------------------> B
   (various messages)

A -------------------> B
      unregister

发送unregister消息后,进程A可以立即退出,而B按预期收到消息。

如果我在 A 的套接字上打开非阻塞模式,B 永远不会收到 unregister 如果 A 发送该消息然后立即退出(我通过在发送 unregister 后添加 sleep(1) 进行测试,在这种情况下它可以工作正如预期的那样。)因此,或多或少,我的客户无法彻底取消注册。

注意:当 B poll() A 的套接字时,我收到一个挂断信号 (POLLHUP) 而不是最后一个 unregister 消息,然后挂断。

我尝试添加一个调用以重新打开阻塞模式,但不知何故它没有任何区别。我使用下面的代码来改变阻塞模式:

int optval(0 or 1);
ioctl(get_socket(), FIONBIO, &optval);

以防万一,我也尝试使用fcntl(),尽管我确信就内核而言它会调整相同的标志。

int flags(fcntl(get_socket(), F_GETFL));
flags |= O_NONBLOCK;   // use this line to turn ON
flags &= ~O_NONBLOCK;  // use this line to turn OFF
fcntl(get_socket(), F_SETFL, flags);

附带说明,我使用 read()write() 函数发送和接收消息。


更新:

对于那些感兴趣的人,测试现在在我们的 git 中:

服务器:https://sourceforge.net/p/snapcpp/code/ci/master/tree/snapwebsites/tests/test_shutdown_server.cpp
客户:https://sourceforge.net/p/snapcpp/code/ci/master/tree/snapwebsites/tests/test_shutdown_client.cpp

这些使用 snap 库,主要是依赖于 tcp 客户端/服务器的 snap_communicator:

tcp:https://sourceforge.net/p/snapcpp/code/ci/master/tree/snapwebsites/lib/tcp_client_server.cpp
通讯员:https://sourceforge.net/p/snapcpp/code/ci/master/tree/snapwebsites/lib/snap_communicator.cpp

【问题讨论】:

    标签: c linux sockets nonblocking


    【解决方案1】:

    正如您所发现的,套接字上的send 仅对要发送的数据进行排队。这实际上并不意味着服务器得到了它。这适用于阻塞和非阻塞套接字。

    几种可能性:

    1. 确保在客户端程序退出之前调用套接字上的close。您没有在问题中说明是否发生这种情况,但这可能是个好主意。

    2. 如果 #1 不起作用,请在套接字上使用 SO_LINGER 选项。设置适当的超时间隔。

    类似下面的东西

      struct linger ling;
      ling.l_onoff = 1;
      ling.l_linger = 3; // 3 second wait for data to finish being set.
      setsockopt(s, SOL_SOCKET, SO_LINGER, &ling, sizeof(ling));
    
    1. #2 的替代方法是修改您的协议,以便客户端在关闭套接字并退出之前从服务器获得某种确认消息。或者为了简单起见,客户端在退出之前等待服务器关闭套接字。 (recv 会在服务器关闭套接字时返回 0)

    我的建议是确保您已实施 #1。如果这不适合您,请评估#3。 #2,如果没有别的。

    【讨论】:

    • blog.netherlabs.nl/articles/2009/01/18/… 对此有很长的解释(请注意,它可能不像在所有情况下都启用 SO_LINGER 那样简单——尤其是在您使用非阻塞套接字时)
    • 啊!其实A可以等待HUP,因为一旦注销,B关闭A的socket。这在我的情况下最有意义!
    【解决方案2】:

    听起来您实际上并没有在退出之前关闭套接字。在正常情况下,所有带有 SO_LINGER 的恶作剧都不应该是必要的。

    【讨论】:

    • 我使用 C++,所以很难错过析构函数……除非该对象永远不会被删除。仅当未删除对象时,我的事件循环才不会退出。由于该过程正常终止,我确信它会发生。我添加了一些日志来查看,我现在 100% 确定。话虽如此,HUP 信号才是我真正需要使用的。所以 A 发送unregister 然后等待 HUP 而不是立即退出。我更新了我的测试,现在它可以按预期工作了。
    • 说了这么多,我没有添加任何关于逗留的内容。我同意这不是必需的。
    猜你喜欢
    • 2019-09-07
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-05-29
    • 2011-09-13
    • 1970-01-01
    • 2015-10-06
    • 2013-04-17
    相关资源
    最近更新 更多