c++ linuxaccept()在套接字关闭后阻塞

Question

我有一个线程侦听新连接

new_fd = accept(Listen_fd, (struct sockaddr *) & their_addr, &sin_size);

，另一个线程在需要关闭程序时关闭 Listen_fd 。然而，Listen_fd 关闭后，它仍然阻塞。当我使用 GDB 尝试调试accept() 时，它不会阻塞。我认为这可能是 SO_LINGER 的问题，但默认情况下它不应该打开，并且在使用 GDB 时不应该改变。知道发生了什么，或者有任何其他关闭列表套接字的建议吗？

Answer 1

使用：sock.shutdown (socket.SHUT_RD)

然后accept将返回EINVAL。不需要难看的跨线程信号！

来自 Python 文档：
"注意 close() 会释放与连接相关的资源，但不一定立即关闭连接。如果您想及时关闭连接，请调用 shutdown() 在 close() 之前。”

http://docs.python.org/3/library/socket .html#socket.socket.close

几年前，我在用 C 编程时遇到了这个问题。但直到今天，在 Python 中遇到了同样的问题，并思考使用信号之后，我才找到了解决方案（恶心！） ,然后记住有关关闭的注释！

至于评论说你不应该跨线程关闭/使用套接字......在 CPython 中，全局解释器锁应该保护你（假设你使用的是文件对象而不是原始的整数文件描述符）。

这是示例代码：

import socket, threading, time

sock = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
sock.setsockopt (socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind (('', 8000))
sock.listen (5)

def child ():
  print ('child  accept ...')
  try:  sock.accept ()
  except OSError as exc :  print ('child  exception  %s' % exc)
  print ('child  exit')

threading.Thread ( target = child ).start ()

time.sleep (1)
print ('main   shutdown')
sock.shutdown (socket.SHUT_RD)

time.sleep (1)
print ('main   close')
sock.close ()

time.sleep (1)
print ('main   exit')

Answer 2

当调用非有效套接字 FD 时，accept 的行为是未定义的。 “不是有效的套接字FD”包括曾经是有效套接字但后来被关闭的数字。您可能会说“但是 Borealid，它应该返回 EINVAL！”，但这并不能保证 - 例如，相同的 FD 编号可能会在 close 和 accept< 之间重新分配给不同的套接字。 /code> 调用。

因此，即使您要隔离并纠正导致程序失败的任何因素，您将来仍然可能再次失败。不要这样做 - 更正导致您尝试接受已关闭套接字上的连接的错误。

如果您的意思是之前进行的accept调用继续在close之后阻塞，那么您应该做什么向在 accept 中阻塞的线程发送信号。这将为它提供 EINTR，并且它可以完全脱离 - 然后然后关闭套接字。不要从使用它的线程以外的线程中关闭它。

Answer 3

shutdown() 函数可能就是您正在寻找的。调用 shutdown(Listen_fd, SHUT_RDWR) 将导致任何对 accept() 的阻塞调用返回 EINVAL。将调用 shutdown() 与原子标志的使用结合起来可以帮助确定 EINVAL 的原因。

例如，如果您有此标志：

std::atomic<bool> safe_shutdown(false);

那么您可以通过以下方式指示另一个线程停止侦听：

shutdown_handler([&]() {
  safe_shutdown = true;
  shutdown(Listen_fd, SHUT_RDWR);
});

为了完整起见，以下是您的线程如何调用接受：

while (true) {
  sockaddr_in clientAddr = {0};
  socklen_t clientAddrSize = sizeof(clientAddr);
  int connSd = accept(Listen_fd, (sockaddr *)&clientAddr, &clientAddrSize);
  if (connSd < 0) {
    // If shutdown_handler() was called, then exit gracefully
    if (errno == EINVAL && safe_shutdown)
      break;
    // Otherwise, it's an unrecoverable error
    std::terminate();
  }
  char clientname[1024];
  std::cout << "Connected to "
            << inet_ntop(AF_INET, &clientAddr.sin_addr, clientname,
                         sizeof(clientname))
            << std::endl;
  service_connection(connSd);
}

Answer 4

这是一种解决方法，但您可以在超时的情况下对 Listen_fd 进行 select，如果发生超时，请检查您是否要关闭该程序。如果是，则退出循环，如果不是，则返回步骤 1 并执行下一个 select。

Answer 5

您是否检查 close 的返回值？
来自Linux手册页，（http://www.kernel.org/doc/man-pages/online/pages/man2/close.2.html）
“当同一进程中的其他线程中的系统调用可能正在使用文件描述符时，关闭它们可能是不明智的。由于文件描述符可能会被重用，因此存在一些模糊的竞争条件，可能会导致意想不到的副作用”。
您可以使用选择而不是接受并等待来自另一个线程的某些事件，然后关闭侦听器线程中的套接字。