[Linux]FIFO程序出错

Kidult

server.c

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <sys/stat.h>
   
5. #include <sys/types.h>
   
6. #include <unistd.h>
   
7. #include <errno.h>
   
8. #include <fcntl.h>
   
9. #include <string.h>
   
10. #include <signal.h>
    
11. #define MSGSIZE 50
    
12. 
    
13. char *fifo1="fifo1";char *fifo2="fifo2";
    
14. main()
    
15. {           
    
16.      char msgbuf[MSGSIZE];           
    
17.      pid_t pid;        int fd1,fd2;
    
18.        
    
19.      system("clear");       
    
20.      printf("************** SERVER SIDE ***************\n");
    
21.      if ((mkfifo(fifo1, 0666) == -1) && (errno != EEXIST))       
    
22.      {                    perror("Error creating the named pipe");                    exit (1);        }               
    
23.      if ((mkfifo(fifo2, 0666) == -1) && (errno != EEXIST))        
    
24.      {                    perror("Error creating the named pipe");                    exit (1);        }
    
25.      
    
26.      if((fd2=open(fifo2, O_RDONLY|O_NONBLOCK))<0)               
    
27.              perror("fifo2 open failed");
    
28.      if((fd1=open(fifo1, O_WRONLY|O_NONBLOCK))<0)      
    
29.              perror("fifo1 open failed");
    
30. 
    
31.      pid = fork();        //loop:   
    
32.        
    
33.      if (pid < 0)         {                //failure in creating a child               
    
34.               perror ("fork");                      exit(2);            }
    
35.      else if (pid == 0)         {      
    
36.               if(read(fd2, msgbuf, MSGSIZE+1)<0)         perror("Message read failed");        printf("Received message: %s", msgbuf);   }
    
37.      else        {       
    
38.               if(fgets(msgbuf,MSGSIZE, stdin) != NULL)         {                       
    
39.                          if(write(fd1, msgbuf, MSGSIZE+1)<0)                               
    
40.                                    perror("Message write failed");                }        }            //        goto loop;}

复制代码

client.c

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <sys/stat.h>
   
5. #include <sys/types.h>
   
6. #include <unistd.h>
   
7. #include <errno.h>
   
8. #include <fcntl.h>
   
9. #include <string.h>
   
10. #include <signal.h>
    
11. #define MSGSIZE 50
    
12. 
    
13. char *fifo1="fifo1";char *fifo2="fifo2";
    
14. 
    
15. main()
    
16. {              
    
17.           char msgbuf[MSGSIZE];       
    
18.           int fd1,fd2;           
    
19.           pid_t pid;
    
20.        
    
21.           system("clear");       
    
22.           printf("************** CLIENT SIDE ***************\n");            
    
23.           if ((mkfifo(fifo1, 0666) == -1) && (errno != EEXIST))        
    
24.           {                   
    
25.                   perror("Error creating the named pipe");                   
    
26.                   exit (1);        
    
27.            }
    
28.         
    
29.            if ((mkfifo(fifo2, 0666) == -1) && (errno != EEXIST))        
    
30.           {            
    
31.                     perror("Error creating the named pipe");            
    
32.                     exit (1);        
    
33.            }
    
34.           
    
35.           if((fd2=open(fifo1, O_WRONLY|O_NONBLOCK))<0)                perror("fifo1 open failed");
    
36.           if((fd1=open(fifo2, O_RDONLY|O_NONBLOCK))<0)                perror("fifo2 open failed");
    
37.           pid = fork(); //
    
38. loop:           
    
39.            if (pid < 0)         {                //failure in creating a child                perror ("fork");                exit(2);            }
    
40.                else if (pid == 0)        
    
41.           {                
    
42.                    if(read(fd1, msgbuf, MSGSIZE+1)<0)                       
    
43.                             perror("message read failed");               
    
44.                             printf("Received message: %s", msgbuf);           
    
45.           }   
    
46.           else       
    
47.           {                if(fgets(msgbuf,MSGSIZE, stdin) != NULL)                
    
48.                         {         if(write(fd2, msgbuf, MSGSIZE+1)<0)                                perror("Message write failed");                }                           
    
49.            } //   
    
50. 
    
51. goto loop;
    
52. }
    

复制代码

output不对劲啊~
请大家帮忙看看
我这个程序到底哪出问题了
拜托了~

yeenfei

我觉得你应该把代码整理一下。。。怎样看