非阻塞read/write的问题

xiaozhu2007

该程序是APUE2第14章程序清单14-1

1. 
   
2. #include "head.h"
   
3. 
   
4. char            buf[500000];
   
5. 
   
6. int main(int argc, char** argv)
   
7. {
   
8.         int                     nwrite, ntowrite;
   
9.         char                    *ptr = NULL;
   
10. 
    
11.         ntowrite = read(STDIN_FILENO, buf, sizeof(buf));
    
12.         fprintf(stderr, "read %d bytes\n", ntowrite);
    
13. 
    
14.         set_fl(STDOUT_FILENO, O_NONBLOCK);
    
15.         ptr = buf;
    
16.         while(ntowrite > 0){
    
17.                 errno = 0;
    
18.                 nwrite = write(STDOUT_FILENO, ptr, ntowrite);
    
19.                 fprintf(stderr, "nwrite = %d bytes, errno = %d\n", nwrite, errno);
    
20. 
    
21.                 if(nwrite > 0){
    
22.                         ntowrite -= nwrite;
    
23.                         ptr += nwrite;
    
24.                 }
    
25.         }
    
26. 
    
27.         clr_fl(STDOUT_FILENO, O_NONBLOCK);
    
28. 
    
29.         exit(0);
    
30. }
    
31. 
    
32. static int set_fl(int fd, int flags)
    
33. {
    
34.         int             val;
    
35. 
    
36.         val = fcntl(fd, F_GETFL, 0);
    
37.         if(val < 0){
    
38.                 perror("fcntl get error");
    
39.                 exit(1);
    
40.         }
    
41. 
    
42.         val |= flags;
    
43.         if(fcntl(fd, F_SETFL, val) < 0){
    
44.                 perror("fcntl set error");
    
45.                 exit(2);
    
46.         }
    
47. 
    
48.         return 0;
    
49. }
    
50. 
    
51. static int clr_fl(int fd, int flags)
    
52. {
    
53.         int             val;
    
54.         
    
55.         val = fcntl(fd, F_GETFL, 0);
    
56.         if(val < 0){
    
57.                 perror("fcntl get error");
    
58.                 exit(3);
    
59.         }
    
60. 
    
61.         val &= ~flags;
    
62.         if(fcntl(fd, F_SETFL, val) < 0){
    
63.                 perror("fcntl clr error");
    
64.                 exit(4);
    
65.         }
    
66. 
    
67.         return 0;
    
68. }
    

复制代码

运行结果：
[xxxx@localhost chap14]$ ./a.out </etc/termcap >temp.file
read 500000 bytes
nwrite = 500000 bytes, errno = 0


[xxxx@localhost chap14]$ ./a.out </etc/termcap  2>stderr.out
[xxxx@localhost chap14]$ cat strerr.out
...............................
nwrite = -1 bytes, errno = 11
nwrite = -1 bytes, errno = 11
nwrite = -1 bytes, errno = 11
nwrite = -1 bytes, errno = 11
nwrite = -1 bytes, errno = 11
............................
nwrite = -1 bytes, errno = 11
nwrite = -1 bytes, errno = 11
nwrite = 109270 bytes, errno = 0

程序从标准输入中读取500000个字节的数据到进程缓冲区buf中，然后将标准输出设置为非阻塞模式，将buf缓冲区里的数据输出至标准输出
1.为什么当标准输出重定向到一个普通文件的时候，程序一次输出到文件成功，而当标准输出是终端时，为什么有write出现errno呢？
书中说：这个实例中，程序发出数千个write调用，但只有10-20个是真正输出数据的，其余的出错返回，这种形式的循环即轮询，在多
用户系统上它浪费CPU时间，这里“程序发出数千个write调用，但只有10-20个是真正输出数据的”不明白是怎么回事？

2. 书中说：虽然读写磁盘操作会使调用者短时间内阻塞，但不能将与磁盘操作有关的系统调用称为“低速”。
而低速系统调用是可能使进程永远阻塞的系统调用，read/write调用也可能使进程永远阻塞啊，难道read/write不是
低速系统调用吗？

xi2008wang

1.设置了O_NONBLOCK标志后,如果进程在缓冲区没有空间时(受终端驱动程序一次接收量的大小限制)调用了write,并不会阻塞,系统会立即返回EAGAIN :Resource temporarily unavailable

2.注意这句:不能将与磁盘操作有关的系统调用称为“低速”。
write终端会阻塞,但write文件(与磁盘操作有关)不会阻塞

个人理解,不知道对不对

xiaozhu2007

原帖由 xi2008wang 于 2008-1-15 23:10 发表
1.设置了O_NONBLOCK标志后,如果进程在缓冲区没有空间时(受终端驱动程序一次接收量的大小限制)调用了write,并不会阻塞,系统会立即返回EAGAIN :Resource temporarily unavailable

2.注意这句:不能将与磁盘操作 ...

对于1.觉得你的理解是对 的，这样说誓不是更好点：
当设置了O_NONBLOCK标志后，如果内核缓冲区（写队列）没有空间时（已经满了，守护进程updata还没来得及把写队列的数据冲洗到终端上）再次调用write往内核的写队列写数据时，并不会阻塞，系统立即返回EAGAIN
觉得你 所说的进程在缓冲区没有空间说的好像不对。:wink: :wink: :wink:

xiaozhu2007

write调用首先是把我们自己定义的缓冲区里的内容复制到内核缓冲区中,然后将内核缓冲区的内容放入写队列后write返回,系统的守护进程update会定期的调用sysn函数冲洗内核缓冲区写队列的内容.

xiaozhu2007

问题2还是不理解