讨论：怎样在epoll中实现全工TCP？？？

79hy

问题描述： 怎样在epoll中实现全工TCP？？？

场景：

epoll一直在用，但是都是在半双工模式。

一般我只把读放进epoll中，我们的应用写很少（大部分都是这种情况吧）就放在队列中等epoll timeout出来转一圈，把该写的数据写出去。

tcp是全双工的，epoll怎么来实现全双工？

思考很久，没有写例子，希望大家帮忙推导一下可能出现的问题，以及解决方案。


思路如下：

1. 启动2线程，一个读（R_EPOLL），一个写(信号量通知，建立一个key是fd的hash表-W_HASH）

2. 每accept一个socket加入R_EPOLL 和 W_HASH

3. 当没错误的时候，一切正常不表。 如果当read出错，或write出错，会发生什么情况？

3-1：read/write出错，write/read也会出错吗？
3-2：当本地或对端shutdown_read,shutdown_write 会导致对方什么情况？
3-3：会发生断开一半，而另外一半正常的情况吗？


各位CUer， 喷我吧~~~

79hy

回复 2# linux_c_py_php


    和非阻塞读写没关系。呵呵。我的意思是在epoll中怎么来实现读写并发操作，然后出错怎么处理。

不知道大家有想过这些问题了不，我没想明白，拿出来和大家讨论下。大家随意拍。

79hy

hanxin83 发表于 2013-09-24 09:16
同没有理解什么叫"同时读写"...

全双工就是 对一个socket同时读写。  比如1个fd，用2个线程，1个线程读，1个线程写，并行。

epoll是单线程的，监听了读写事件后，在同一时间操作fd，要不只能读，要不就只能写。这就是半双工。

我说的你们能理解吗？

79hy

回复 6# solu


    epoll注册了读写事件后只能在同一事件单一的读或者写。不能同时读写。所以这是半双工。

79hy

回复 5# egmkang


    同时就是想 如果有个场景是读写都比较频繁的时候，效率高点。让tcp真正的全双工。

79hy

回复 7# kdkgod


    你的方法还是半双工的。而且频繁的去操作epoll，增加或减少事件，会很降低效率的。

79hy

回复 22# kdkgod


    也不是一直关心写。有数据写的时候就写。没数据就阻塞休息。 主要是要同一个socket实现同时读写。

79hy

李营长 发表于 2013-09-24 14:17
回复 17# hellioncu

如果在一个线程池里读写，怎么做到同步？ 如果对一个fd进行多线程读、写， 怎么保证读出错，写怎么处理？？？

79hy

回复 26# kdkgod


    谢谢。就是我就是妄想症发了。

其实我现在的处理方式是用ET模式，把IN，OUT都放到epoll里监听。

每个fd上都挂一个sendlist，和recvbuf， 1个SendEnable（SocketMap）

如果有OUT事件，就把SendEnable设置 1. 发送阻塞时设置成0.

每次epoll都0.5s超时出来都遍历一下 SocketMap. 把SendEnable 为1的 sendlist不为空的数据发出去。


我想有没有可能避免掉遍历呢？？？？？？？

79hy

kdkgod 发表于 2013-09-25 16:52
sendlist和recvbuff你是怎么实现的？
我当是也是这么干的，sendlist是每一次应用层在调send接口的时候push ...

握爪。  哈哈。


我的recvbuff相当于2块内存，1个固定大小的头，然后一个指针，根据头里的数据大小分配一个内存块。收完后push到业务层去。

sendlist就更简单了，就是个结构体+List，里面存了个已发送字节数和一个要发送的数据块。