接受套接字函数超时

Question

我试图在接受套接字函数上设置超时但没有成功。我希望接受功能块直到超时延迟结束。 是否可以不将接受功能设置为非阻塞？ 我尝试了很多可能性都没有成功。

感谢您的回答。

下面是我的代码：

struct timeval tv;
fd_set readfds;

tv.tv_sec = 1;
tv.tv_usec = 0;

int s, s_remote;
struct sockaddr_un remote;
struct sockaddr_un local;

if ((s = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
  perror("socket");
  exit(1);
}

FD_ZERO(&readfds);
FD_SET(s, &readfds);

if (select(s+1, &readfds, NULL, NULL, &tv) > 0) {

  printf("Waiting for a connection...\n");

  memset(&local, 0, sizeof(local));
  local.sun_family = AF_UNIX;
  strcpy(local.sun_path, SOCK_PATH);
  unlink(local.sun_path);

  if (bind(s, (struct sockaddr *)&local, sizeof(local)) == -1) {
    perror("UnixSocketClient :: error bind.\n");
    close(s);
    return -1;
  }

  if (listen(s, 5) == -1) {
    perror("UnixSocketClient :: error listen.\n");
    close(s);
    return -1;
  }

  socklen_t remote_len = sizeof(remote);
  printf("Accept :\n\r");

  if ((s_remote = accept(s, (struct sockaddr *)&remote, &remote_len)) == -1) {
    perror("UnixSocket :: error accept.\n");
    return -1;
  }
  printf("Client accepted\n\r");
}

Answer 1

您的代码毫无意义。您必须致电：

• socket()
• 绑定()
• 听()
• 选择（）
• 接受()

按这个顺序。

Answer 2

在设置了超时的侦听套接字调用 select() 并且仅在 select() 未超时时调用 accept()。

更新：

上述方法（实际上与this answer 中的方法相同）确实引入了比赛，正如 cmets 对此答案中所讨论的那样。如果选择返回指示传入连接，则在调用接受之前存在（短）延迟。如果在此延迟期间连接断开，则accept() 将阻塞。

解决此问题的唯一方法是在调用 accept() 时使用非阻塞套接字。

---

如果要求（无论出于何种原因）是使用阻塞套接字，那么一个可能的解决方案是向accept() 中阻塞的进程发送信号，使其返回值-1 和将errno 设置为EINTR。

void handle_sigalarm(int sig)
{
  /* do nothing */
}


  ...

  sigaction(SIGALRM , &(struct sigaction){handle_sigalarm}); /* Setup handler for 
     alarm signal to override the default behaviour which would be to 
     end the process . */

  alarm(3); /* Arranges for a SIGALRM signal to be delivered to the calling
   process in 3 seconds. */

  {
    int accepted_socket = accept(...);
    int errno_save = errno;
    alarm(0); /* Cancel any pending alarm. */
    if (-1 == accepted_socket)
    {
      if (EINTR == errno_save)
      {
        fprintf(stderr, "accept() timed out\n");
      }

      /* handling other errors here. */
    }

    ...