关于read和write设置超时的实现

wjywhl

仿照ace中的原型定义：

ssize_t  readn(int fd, void *buf, size_t len, struct timeval *timeout)
ssize_t  writen(int fd, void *buf, size_t len, struct timeval *timeout)

条件及需求：
1、fd设置为nonblock，如果为block，可能实现更困难。
2、如果在规定时间内没有len个字节的读写，返回已读写字节数，并设置errno表明超时。
3、如果出错，返回


请大家谈谈在那个流程判断超时比较合理。

wjywhl

如果是套接字
是否可用setsockopt实现？

思一克

用select或poll实现。仅仅setsockopt不行吧

wjywhl

程序本身在select控制下

如果可读：在规定时间内读取n个字节。
如果可写：在规定时间内写入n个字节。

思一克

用select实现timeout_read, timeout_write十分简单，在网上应该可以查到原程序

wjywhl

int nNetTimeout=1000;//1秒

　　//发送时限

　　setsockopt(socket，SOL_S0CKET,SO_SNDTIMEO，(char *)&nNetTimeout,sizeof(int));

　　//接收时限

　　setsockopt(socket，SOL_S0CKET,SO_RCVTIMEO，(char *)&nNetTimeout,sizeof(int));


如果在超时后，设置errno= EAGIN

wjywhl

在读写函数里再套一个select也应该可以实现

renstone921

看看这里，从C++到C只不过传递了一个该类的this成员作为参数的函数。
http://www.cs.berkeley.edu/~demm ... /IO_8cc-source.html

wjywhl

谢谢
正在看

wjywhl

int
00210 IO::timeout_read(int fd, char* bp, size_t len, int timeout_ms,
00211                  const char* log)
00212 {
00213     ASSERT(timeout_ms >; 0);
00214     
00215     int ret = poll(fd, POLLIN | POLLPRI, timeout_ms);
00216     if (ret < 0)
00217         return IOERROR;
00218
00219     if (ret == 0) {
00220         if (log) logf(log, LOG_DEBUG, "poll timed out";
00221         return IOTIMEOUT;
00222     }
00223     
00224     ASSERT(ret == 1);
00225     
00226     ret = read(fd, bp, len);
00227     
00228     if (ret < 0) {
00229         if (log) logf(log, LOG_ERR, "timeout_read error: %s", strerror(errno));
00230         return IOERROR;
00231     }
00232
00233     if (ret == 0) {
00234         return IOEOF;
00235     }
00236
00237     return ret;
00238 }