Chinaunix首页 | 论坛 | 博客
  • 博客访问: 885262
  • 博文数量: 254
  • 博客积分: 5350
  • 博客等级: 大校
  • 技术积分: 2045
  • 用 户 组: 普通用户
  • 注册时间: 2008-06-27 13:27
文章分类

全部博文(254)

文章存档

2015年(1)

2014年(9)

2013年(17)

2012年(30)

2011年(150)

2010年(17)

2009年(28)

2008年(2)

分类: C/C++

2012-03-12 10:58:06


ET模式称为边缘触发模式,顾名思义,不到边缘情况,是不会触发的。

EPOLLOUT事件:
EPOLLOUT事件只有在连接时触发一次,表示可写,其他时候想要触发,那你要先准备好下面条件:
1.某次write,写满了发送缓冲区,返回错误码为EAGAIN。
2.对端读取了一些数据,又重新可写了,此时会触发EPOLLOUT。
简单地说:EPOLLOUT事件只有在不可写到可写的转变时刻,才会触发一次,所以叫边缘触发,这叫法没错的!

其实,如果你真的想强制触发一次,也是有办法的,直接调用epoll_ctl重新设置一下event就可以了,event跟原来的设置一模一样都行(但必须包含EPOLLOUT),关键是重新设置,就会马上触发一次EPOLLOUT事件。

EPOLLIN事件:
EPOLLIN事件则只有当对端有数据写入时才会触发,所以触发一次后需要不断读取所有数据直到读完EAGAIN为止。否则剩下的数据只有在下次对端有写入时才能一起取出来了。
现在明白为什么说epoll必须要求异步socket了吧?如果同步socket,而且要求读完所有数据,那么最终就会在堵死在阻塞里。


=====

recv 等错误处理注意

EAGAIN、EWOULDBLOCK、EINTR与非阻塞 长连接

EWOULDBLOCK用于非阻塞模式,不需要重新读或者写

EINTR指操作被中断唤醒,需要重新读/写

在Linux环境下开发经常会碰到很多错误(设置errno),其中EAGAIN是其中比较常见的一个错误(比如用在非阻塞操作中)。
从字面上来看,是提示再试一次。这个错误经常出现在当应用程序进行一些非阻塞(non-blocking)操作(对文件或socket)的时候。例如,以 O_NONBLOCK的标志打开文件/socket/FIFO,如果你连续做read操作而没有数据可读。此时程序不会阻塞起来等待数据准备就绪返 回,read函数会返回一个错误EAGAIN,提示你的应用程序现在没有数据可读请稍后再试。
又例如,当一个系统调用(比如fork)因为没有足够的资源(比如虚拟内存)而执行失败,返回EAGAIN提示其再调用一次(也许下次就能成功)。
Linux - 非阻塞socket编程处理EAGAIN错误
在linux进行非阻塞的socket接收数据时经常出现Resource temporarily unavailable,errno代码为11(EAGAIN),这是什么意思?
这表明你在非阻塞模式下调用了阻塞操作,在该操作没有完成就返回这个错误,这个错误不会破坏socket的同步,不用管它,下次循环接着recv就可以。 对非阻塞socket而言,EAGAIN不是一种错误。在VxWorks和Windows上,EAGAIN的名字叫做EWOULDBLOCK。
另外,如果出现EINTR即errno为4,错误描述Interrupted system call,操作也应该继续。
最后,如果recv的返回值为0,那表明连接已经断开,我们的接收操作也应该结束。

针对出此类编程可按处不处理分两类写法,灵活调用

点击(此处)折叠或打开

  1. int CTcpSocket::Recv(char* buf,const int len)
  2. {
  3.     int iret = recv(m_sock, buf, len, 0);
  4.     if(iret < 0)
  5.     {
  6.         return -1;
  7.     }

  8.     if(iret == 0) //对方关闭连接
  9.     {
  10.         return 0;
  11.     }

  12.     return iret;
  13. }

  14. int CTcpSocket::RecvLen(char *buf,const int len)
  15. {
  16.     char *pPos = buf;
  17.     int lenth = len;
  18.     int index = 0;
  19.     int iret = 0;
  20.     int icount = 5;

  21.     int data_len = 0; //实际收到的数据长度
  22.     while(icount > 0)
  23.     {
  24.         iret = recv(m_sock, &pPos[index], lenth, 0);
  25.         if(iret < 0)
  26.         {
  27.             if(errno == EAGAIN || errno == EINTR)
  28.             {
  29.                 icount --;
  30.                 continue;
  31.             }
  32.             else
  33.             {
  34.                 return -1;
  35.             }
  36.         }

  37.         if(iret == 0) //对方关闭连接
  38.         {
  39.             return 0;
  40.         }

  41.         if(iret == lenth)
  42.         {
  43.             return len;
  44.         }
  45.         else
  46.         {
  47.             index += iret;
  48.             lenth -= iret;

  49.             data_len += iret;
  50.             icount --;
  51.         }
  52.     }
  53.     
  54.     return data_len; //返回实际接到数据的长度 0 -- 没有接到数据
  55. }


阅读(1762) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~