5

以下はすべてman epollページからのものです。

関数 do_use_fd() は、read(2) または write(2) によって EAGAIN が返されるまで、新しい準備完了ファイル記述子を使用します。

ET トリガーのコード例:

   for(;;) {
       nfds = epoll_wait(kdpfd, events, maxevents, -1);

       for(n = 0; n < nfds; ++n) {
           if(events[n].data.fd == listener) {
               client = accept(listener, (struct sockaddr *) &local,
                               &addrlen);
               if(client < 0){
                   perror("accept");
                   continue;
               }
               setnonblocking(client);
               ev.events = EPOLLIN | EPOLLET;
               ev.events = EPOLLIN | EPOLLET;
               ev.data.fd = client;
               if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, client, &ev) < 0) {
                   fprintf(stderr, "epoll set insertion error: fd=%d\n",
                           client);
                   return -1;
               }
           }
           else
               do_use_fd(events[n].data.fd);
       }
   }

したがって、read/write操作については、 a が受信されるまでループする必要がありEAGAINますが、なぜそうでないのacceptですか?

IMO 上記のコードは、複数のクライアント ソケットが受け入れられるのを待っている場合、いくつかの要求を見逃します。1 つのクライアント ソケットしか受け入れないため、EAGAIN受信するまでループでラップする必要もあります。

それとも、私が見逃しているものがありますか？

4

1 に答える 1

6

リスナー ソケットが にどのように追加されるかを見てくださいepollfd。

ev.events = EPOLLIN;       // this is the crucial bit
ev.data.fd = listen_sock;

エッジトリガーでは追加されず、レベルトリガーで追加されます。そのため、そのループまでループする必要はありませんEAGAIN。

于 2011-06-19T09:50:05.953 に答える