Chinaunix

标题: 关于read和write设置超时的实现 [打印本页]

作者: wjywhl    时间: 2005-09-26 16:20
标题: 关于read和write设置超时的实现
仿照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    时间: 2005-09-26 17:07
标题: 关于read和write设置超时的实现
如果是套接字
是否可用setsockopt实现?
作者: 思一克    时间: 2005-09-26 17:14
标题: 关于read和write设置超时的实现
用select或poll实现。仅仅setsockopt不行吧
作者: wjywhl    时间: 2005-09-26 17:25
标题: 关于read和write设置超时的实现
程序本身在select控制下

如果可读:在规定时间内读取n个字节。
如果可写:在规定时间内写入n个字节。
作者: 思一克    时间: 2005-09-26 17:28
标题: 关于read和write设置超时的实现
用select实现timeout_read, timeout_write十分简单,在网上应该可以查到原程序
作者: wjywhl    时间: 2005-09-26 17:37
标题: 关于read和write设置超时的实现
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    时间: 2005-09-26 17:38
标题: 关于read和write设置超时的实现
在读写函数里再套一个select也应该可以实现
作者: renstone921    时间: 2005-09-26 18:12
标题: 关于read和write设置超时的实现
看看这里,从C++到C只不过传递了一个该类的this成员作为参数的函数。
http://www.cs.berkeley.edu/~demm ... /IO_8cc-source.html
作者: wjywhl    时间: 2005-09-26 18:18
标题: 关于read和write设置超时的实现
谢谢
正在看
作者: wjywhl    时间: 2005-09-26 18:21
标题: 关于read和write设置超时的实现
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 }




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2