select和pipe的一個新的認識

kgn28

先看程序：

1. #include<iostream>
   
2. using namespace std ;
   
3. 
   
4. #include <fcntl.h>
   
5. #include<unistd.h>
   
6. #include<stdlib.h>
   
7. #include<sys/types.h>
   
8. #include<sys/wait.h>
   
9. 
   
10. int inline my_sleep(int times){
    
11.         struct timeval t;
    
12.         t.tv_sec = times / 1000;
    
13.         t.tv_usec = (times % 1000) * 1000;
    
14.         select(0, NULL, NULL, NULL, &t);
    
15. }
    
16. 
    
17. int  main(int argc, char * argv)
    
18. {
    
19.         int n, fd[2];
    
20.         pid_t p;
    
21.         char buf[2048];
    
22.         int maxfds;
    
23.         struct timeval timeout;
    
24.         int select_ret;
    
25. 
    
26.         if(pipe(fd) < 0){
    
27.                 perror("pipe create error");
    
28.                 exit(2);
    
29.         }
    
30. 
    
31.         if((p = fork()) < 0){
    
32.                 perror("fork error");
    
33.         }else if( p  == 0) {
    
34.                 close(fd[0]);
    
35.                 cout<<"hi, I am the child process"<<endl;
    
36.                 close(1);
    
37.                 if(dup2(fd[1],1) < 0){
    
38.                         perror("dup2 error");
    
39.                         exit(1);
    
40.                 }
    
41. 
    
42.                 int ret = system("./scipt.sh ");
    
43. 
    
44.                 if(ret < 0 ) {
    
45.                         perror("system() error!\n");
    
46.                 }else{
    
47.                         if(ret == 127){
    
48.                                 cout<<"Startup shell script error"<<endl;
    
49.                         }else if(ret == 0){
    
50.                                 cout<<"success!"<<endl;
    
51.                         }else{
    
52.                                 cout<<"Executing command error!"<<endl;
    
53.                         }
    
54.                 }
    
55.                 sleep(200);
    
56. //                while(1);
    
57.                 exit(1);
    
58.         }else{
    
59.                 cout<<"Hi, i am the parent process"<<endl;
    
60.                 close(fd[1]); //close write fd
    
61.                 fd_set readfds;
    
62.                 FD_ZERO(&readfds);
    
63.                 FD_SET(fd[0],&readfds);
    
64.                 maxfds = fd[0]+1;
    
65.                 timeout.tv_sec =2 ;
    
66.                 timeout.tv_usec = 0;
    
67.                 while(true){
    
68.                         select_ret = select(maxfds,&readfds,NULL,NULL,&timeout);
    
69.                         if(select_ret > 0){
    
70.                                 int len;
    
71.                                 printf("select_ret is %d\n", select_ret);
    
72.                                 if(FD_ISSET(fd[0], &readfds)){
    
73.                                         len = read(fd[0],buf,2048);
    
74.                                         buf[len] = '\0';
    
75.                                         printf("the message recv form child pross is :%s# len=%d\n",buf, len);
    
76.                                         memset(buf, 0x0, 2048);
    
77.                                 }
    
78.                         } else {
    
79.                                 printf("select timeout\n");
    
80.                         }
    
81.                         timeout.tv_sec =2 ;
    
82.                         timeout.tv_usec = 0;
    
83.                 }
    
84.                 wait(NULL);
    
85.                 return 0;
    
86.         }
    
87. }
    

復制代碼

起初，子進程在printf后馬上退出（exit），然后產(chǎn)生的情況就是父進程這么select會很快的返回，并且read的返回值也是0. 加了sleep之后父進程的select都是timeout。這個現(xiàn)象說明：

1，重新考察select的功能，select測試的是文件描述符是否（可讀、可寫、例外），如果對一個文件描述符的read不會被block，那么在測試該描述符可讀時，select馬上返回。

2，pipe，如果子進程把write的文件描述符關(guān)閉，那么父進程read的時候不會被block并且會一直返回0以示write端已經(jīng)被關(guān)閉，所以這是去select，肯定是馬上返回，read的返回值也就是0了。

mydawaa

今天也遇到類似的問題，如果是命名管道的話，可以通過以O(shè)_RDWR open讀端的方式來解決

原文：http://www.myvoipapp.com/blogs/y ... ifo%E4%B8%8Eselect/