我在边缘触发模式下使用epoll。为避免饥饿,代码从一个套接字一次读取了MAX_FREAD_LENGTH个字节。之后组装碎片,直到发生EOL。我注意到当MAX_FREAD_LENGTH很小时,epoll卡住了。我认为它适用于任何大小的读取块。它可以很好地使用512字节,但有时会挂起(这意味着没有EPOLLIN事件)。如果我增加MAX_FREAD_LENGTH,它将变得更加稳定。我该如何解决这个问题?

非常感谢您考虑我的问题!


  EPOLL初始化


int res;
epFd = epoll_create(EPOLL_SIZE);
event.data.fd = serverFd;
event.events = EPOLLIN|EPOLLET;
res=epoll_ctl(epFd, EPOLL_CTL_ADD, serverFd, &event);
if (res == -1){
  perror ("epoll_ctl error: ");
  return EH_ERROR;
}
events = calloc (MAX_EVENTS, sizeof event);



  注册网络事件:


while (TRUE){
  int nfds;
  do{
    nfds = epoll_wait(epFd, events, MAX_EVENTS, -1);
  } while (nfds < 0 && errno == EINTR);

  int i = 0;
  for (;i<nfds;i++){
    if ( (events[i].data.fd == serverFd) && (events[i].events & EPOLLIN)){
      if ((clientFd = accept(serverFd,(struct sockaddr *) &clientAddr, &clientLen)) < 0){
        char log[255];
        sprintf(log,"dispatch_net_event: Socket accept failed: %s",strerror(errno));
        logger->log(LOGG_ERROR,log);
      }
      if(newclient(clientFd)!=EH_ERROR){
        /* client created */
        setnonblocking(fd,NONBLOCKING);
        event.data.fd = clientFd;
        event.events = EPOLLIN |EPOLLET;
        if(epoll_ctl(epFd, EPOLL_CTL_ADD, fd, &event)<0){
          fprintf(stderr,"Epoll insertion error (fd=%d): ",clientFd);
          return EH_ERROR;
        }
        continue;
      }
      else{
        logger->log(LOGG_ERROR,"Client creation error");
        continue;
      }
    }
    else{
     dispatch_event(events[i].data.fd,NET_EVENT);
    }
  }
}



  处理网络事件


#define SMTP_MAX_LINE_LENGTH MAX_FREAD_LENGTH
ssize_t count;
char buf[SMTP_MAX_LINE_LENGTH];

memset(buf,'\0', SMTP_MAX_LINE_LENGTH);
count = read (fd, buf,MAX_FREAD_LENGTH );

if (count==-1){
  if (errno == EAGAIN)
    return KEEP_IT;
  else if (errno == EWOULDBLOCK)
    return KEEP_IT;
  else{
    char log[255];
    sprintf(log,"handle_net_event: Read error: %s",strerror(errno));
    logger->log(LOGG_ERROR,log);
  }
}
else{   /* count > 0 there are data in the buffer */
  /* assemble possible partial lines, TRUE if line is whole (end with \r\n)*/
  whole=assemble_line(count,client,&buf[0]);
}
 /* process the line */



  编辑:


我忘了提一下,epoll在与其他部分不同的单独线程中运行

最佳答案

我认为您使用的EPOLLET错误。尝试不使用EPOLLET(即使用级别触发模式),看看是否可行。如果是这样,则意味着您的根本问题是您没有按照边沿触发模式的要求进行操作,而是继续从任何准备好的描述符中读取,直到获得EAGAIN。

关于c - epoll(EPOLLET)取决于读取字节数?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/15569845/

10-11 23:12
查看更多