FIFO管道

FIFO (First in, First out)为一种特殊的文件类型，它在文件系统中有对应的路径。当一个进程以读(r)的方式打开该文件，而另一个进程以写(w)的方式打开该文件，那么内核就会在这两个进程之间建立管道，所以FIFO实际上也由内核管理，不与硬盘打交道

#include < sys/types.h >
#include < sys/stat.h >
int mknod(const char *path,mode_t mod,dev_t dev); 
int mkfifo(const char *path,mode_t mode);
函数mknod参数中path为创建的命名管道的全路径名：mod为创建的命名管道的模式，指明其存取权限；dev为设备值，该值取决于文件创建的种类，它只在创建设备文件时才会用到。这两个函数调用成功都返回0，失败都返回－1。

1. 如果当前打开操作是为读而打开FIFO时
    1) 若已经有相应进程为写而打开该FIFO，则当前打开操作将成功返回
    2) 否则，可能阻塞直到有相应进程为写而打开该FIFO(当前打开操作设置了阻塞标志)
    3) 或者，成功返回(当前打开操作没有设置阻塞标志)
2. 如果当前打开操作是为写而打开FIFO时
    1) 如果已经有相应进程为读而打开该FIFO，则当前打开操作将成功返回
    2) 否则，可能阻塞直到有相应进程为读而打开该FIFO(当前打开操作设置了阻塞标志)
    3) 或者，返回ENXIO错误(当前打开操作没有设置阻塞标志)

1. 从FIFO中读取数据: 如果一个进程为了从FIFO中读取数据而阻塞打开FIFO，那么称该进程内的读操作为设置了阻塞标志的读操作。
    1) 如果有进程写打开FIFO，且当前FIFO内没有数据，则对于设置了阻塞标志的读操作来说，将一直阻塞。对于没有设置阻塞标志读操作来说则返回-1，当前errno值为EAGAIN，提醒以后再试 
    2) 对于设置了阻塞标志的读操作说，造成阻塞的原因有两种，解阻塞的原因则是FIFO中有新的数据写入，不论信写入数据量的大小，也不论读操作请求多少数据量 
        2.1) 当前FIFO内有数据，但有其它进程在读这些数据
        2.2) 另外就是FIFO内没有数据 
    3) 读打开的阻塞标志只对本进程第一个读操作施加作用，如果本进程内有多个读操作序列，则在第一个读操作被唤醒并完成读操作后，其它将要执行的读操作将不再阻塞，即使在执行读操作时，FIFO中没有数据也一样(此时，读操作返回0)
    4) 如果没有进程写打开FIFO，则设置了阻塞标志的读操作会阻塞 
 
2. 向FIFO中写入数据: 如果一个进程为了向FIFO中写入数据而阻塞打开FIFO，那么称该进程内的写操作为设置了阻塞标志的写操作 
    1) 对于设置了阻塞标志的写操作 
        1.1) 当要写入的数据量不大于PIPE_BUF时，linux将保证写入的原子性。如果此时管道空闲缓冲区不足以容纳要写入的字节数，则进入睡眠，直到当缓冲区中能够容纳要写入的字节数时，才开始进行一次性写操作 
        1.2) 当要写入的数据量大于PIPE_BUF时，linux将不再保证写入的原子性。FIFO缓冲区一有空闲区域，写进程就会试图向管道写入数据，写操作在写完所有请求写的数据后返回 
    2) 对于没有设置阻塞标志的写操作 
        2.1) 当要写入的数据量大于PIPE_BUF时，linux将不再保证写入的原子性。在写满所有FIFO空闲缓冲区后，写操作返回 
        2.2) 当要写入的数据量不大于PIPE_BUF时，linux将保证写入的原子性。如果当前FIFO空闲缓冲区能够容纳请求写入的字节数，写完后成功返回；如果当前FIFO空闲缓冲区不能够容纳请求写入的字节数，则返回EAGAIN错误，提醒以后再写 

使用命名管道时，必须先调用open()将其打开。因为命名管道是一个存在于硬盘上的文件，而管道是存在于内存中的特殊文件。需要注意的是，调用open()打开命名管道的进程可能会被阻塞。但如果同时用读写方式（O_RDWR）打开，

则一定不会导致阻塞；如果以只读方式（O_RDONLY）打开，则调用open()函数的进程将会被阻塞直到有写方打开管道；同样以写方式（O_WRONLY）打开也会阻塞直到有读方式打开管道。

//fifo.c
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include "unpipc.h"
#include "fifo.h"
#include "client.h"
#include "server.h"

#define FIFO1 "/tmp/fifo.1"
#define FIFO2 "/tmp/fifo.2"

int main()
{
    int readfd,writefd;
    pid_t cpid;
    
    if((mkfifo(FIFO1,FILE_MODE)<0)&&(errno!=EEXIST))
      err_sys("can‘t create %s",FIFO1);
    if((mkfifo(FIFO2,FILE_MODE)<0)&&(errno!=EEXIST))
    {
        unlink(FIFO1);
        err_sys("can‘t create %s",FIFO1);
    }

    if((cpid=fork())==0)
    {
        readfd=open(FIFO1,O_RDONLY,0);
        writefd=open(FIFO2,O_WRONLY,0);

        server(readfd,writefd);
        exit(0);
    }

    writefd=open(FIFO1,O_WRONLY,0);
    readfd=open(FIFO2,O_RDONLY,0);
    client(readfd,writefd);

    waitpid(cpid,NULL,0);
    close(readfd);
    close(writefd);
    unlink(FIFO1);
    unlink(FIFO2);
    exit(0);
}

//client.h 
#include <string.h>
#include "unpipc.h"
//#include "my_err.h"
#define MAXLINE 4096

void client(int readfd,int writefd)
{
    char buff[MAXLINE];
    fgets(buff,MAXLINE,stdin);

    size_t len=strlen(buff);
    if(buff[len-1]==‘\n‘)
      len--;

    write(writefd,buff,len);

    ssize_t n;
    while((n=read(readfd,buff,MAXLINE))>0)
      write(STDOUT_FILENO,buff,n);
}

//server.h 
#include "unpipc.h"
#include "my_err.h"
#include <string.h>

void server(int readfd,int writefd)
{
    int fd;
    ssize_t n;
    char buff[MAXLINE+1];

    if((n=read(readfd,buff,MAXLINE))==0)
      err_quit("end-of-file while reading pathname");
    buff[n]=‘\0‘;

    if((fd=open(buff,O_RDONLY))<0)
    {
         snprintf(buff+n,sizeof(buff)-n,":can‘t open, %s\n",strerror(errno));
        n=strlen(buff);
        write(writefd,buff,n);
    }
    else
    {
        while((n=read(fd,buff,MAXLINE))>0)
          write(writefd,buff,n);

        close(fd);
    }
}

//client.c
#include <sys/types.h>
#include <sys/stat.h>
#include "fifo.h"
#include "client.h"

int main()
{
    int readfd,writefd;
    writefd=open(FIFO1,O_WRONLY,0);
    readfd=open(FIFO2,O_RDONLY,0);

    client(readfd,writefd);

    close(readfd);
    close(writefd);

    unlink(FIFO1);
    unlink(FIFO2);
    exit(0);
}

//server.c
#include <sys/types.h>
#include <sys/stat.h>
#include "fifo.h"
#include "unpipc.h"
#include "server.h"

int main()
{
    int readfd,writefd;
    
    if((mkfifo(FIFO1,FILE_MODE)<0)&&(errno!=EEXIST))
      err_sys("can‘t create %s",FIFO1);
    if((mkfifo(FIFO2,FILE_MODE)<0)&&(errno!=EEXIST))
    {
        unlink(FIFO1);
        err_sys("can‘t create %s",FIFO2);
    }

    readfd=open(FIFO1,O_RDONLY,0);
    writefd=open(FIFO2,O_WRONLY,0);

    server(readfd,writefd);
    exit(0);
}

//fifo.h
#include "unpipc.h"
#define FIFO1 "/tmp/fifo.1"
#define FIFO2 "/tmp/fifo.2"