O_NONBLOCK模式下写fifo的注意事项

后台网络通信框架一般采用fifo来作为事件通知的机制:创建一个fifo,然后以非阻塞读和非阻塞写的方式打开fifo,然后把fd加到epoll里面,作为通知网络事件的fd.

在这里有个隐晦的问题容易被忽视.fifo在以非阻塞模式打开时,必须先打开读,然后打开写.不然会报错No such device or address.即如下代码所示是正确的

#define FIFO_FILE "/tmp/fifo.xxx"
#define FIFO_MODE FILE_MODE S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH

mkfifo(FIFO_FILE, FIFO_MODE);
int readfd  = open(FIFO_FILE, O_RDONLY | O_NONBLOCK, 0);
int writefd = open(FIFO_FILE, O_WRONLY | O_NONBLOCK, 0);

上述代码中的两个open不能反过来,不然会报错: No such device or address

注意到这种情况,那即使以后我们写代码是在两个进程间通过fifo来通信,也不用关心以写的方式打开fifo之前,fifo是否已经以读的方式打开,因为我们可以设置一个dummy fd,如下所示:

int dummyfd = open(FIFO_FILE, O_RDONLY | O_NONBLOCK, 0);
int writefd = open(FIFO_FILE, O_WRONLY | O_NONBLOCK, 0);

敢兴趣的朋友可以把下面的代码复制过去,看看输出结果:

1/注释L18

2/不注释L18

#include <unistd.h>                                                                                 
#include <sys/types.h>                                                                              
#include <sys/stat.h>                                                                               
#include <fcntl.h>                                                                                  
                                                                                                    
#include <errno.h>                                                                                  
#include <stdio.h>                                                                                  
#include <string.h>                                                                                 
                                                                                                    
#define FILE_MODE S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH                         
#define FIFO_FILE "/tmp/fifo.test_nonblock_write"                                                   
                                                                                                    
int main(void)                                                                                      
{                                                                                                   
    mkfifo(FIFO_FILE, FILE_MODE);                                                                   
    fprintf(stderr, "mkfifo, errno=%d, error=%s
", errno, strerror(errno));                        
                                                                                                    
    //open(FIFO_FILE, O_RDONLY|O_NONBLOCK, 0);                                                      
    fprintf(stderr, "open(O_RDONLY), errno=%d, error=%s
", errno, strerror(errno));                
                                                                                                    
    open(FIFO_FILE, O_WRONLY|O_NONBLOCK, 0);                                          
    fprintf(stderr, "open(O_WRONLY), errno=%d, error=%s
", errno, strerror(errno));                
                                                                                                    
    unlink(FIFO_FILE);                                                                          
                                                                                                    
    return 0;                                                                                       
}