my epoll

浅浅的花香味﹌ 2022-08-13 19:59 148阅读 0赞

/*  
     * reads input from pipes p1, p2  
     * using select() for multiplexing  
     * 
     * tty1：cat > ./p1 
     * tty2：cat > ./p2 
     * tty3: ./epoll
    */   
    
    
    #include <stdio.h>
    #include <stdlib.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <sys/epoll.h>
    #include <unistd.h>
    
    
    
    struct epoll_event ev;
    
    int main(void)
    {	
    	int pfd1, pfd2;
    
    	if( (pfd1 = open("p1", O_RDONLY|O_NONBLOCK)) == -1 ){
    		perror("open  p1 error\n");
    		exit(1);
    	}
    	if( (pfd2 = open("p2", O_RDONLY|O_NONBLOCK)) == -1 ){
    		perror("open p2 error\n");
    		exit(1);
    	}
    /*
    typedef union epoll_data {
        void *ptr;
        int fd;
        __uint32_t u32;
        __uint64_t u64;
    } epoll_data_t;
    
    struct epoll_event {
        __uint32_t events; // Epoll events 
        epoll_data_t data; ///User data variable 
    */
    
    	int epfd = epoll_create(1);
    
    	ev.data.fd = pfd1;
    	ev.events = EPOLLIN|EPOLLET;
    	epoll_ctl(epfd, EPOLL_CTL_ADD, pfd1, &ev);
    /*
    epoll的事件注册函数，它不同与select()是在监听事件时告诉内核要监听什么类型的事件，而是在这里先注册要监听的事件类型。第一个参数是epoll_create()的返回值，第二个参数表示动作，用三个宏来表示：
    EPOLL_CTL_ADD：注册新的fd到epfd中；
    EPOLL_CTL_MOD：修改已经注册的fd的监听事件；
    EPOLL_CTL_DEL：从epfd中删除一个fd；
    第三个参数是需要监听的fd，第四个参数是告诉内核需要监听什么事，struct epoll_event结构如下
    */
    /*
    events可以是以下几个宏的集合：
    EPOLLIN ：表示对应的文件描述符可以读（包括对端SOCKET正常关闭）；
    EPOLLOUT：表示对应的文件描述符可以写；
    EPOLLPRI：表示对应的文件描述符有紧急的数据可读（这里应该表示有带外数据到来）；
    EPOLLERR：表示对应的文件描述符发生错误；
    EPOLLHUP：表示对应的文件描述符被挂断；
    EPOLLET： 将EPOLL设为边缘触发(Edge Triggered)模式，这是相对于水平触发(Level Triggered)来说的。
    EPOLLONESHOT：只监听一次事件，当监听完这次事件之后，如果还需要继续监听这个socket的话，需要再次把这个socket加入到EPOLL队列里
    */
    	ev.data.fd = pfd2;
    	ev.events = EPOLLIN|EPOLLET;
    	epoll_ctl(epfd, EPOLL_CTL_ADD, pfd2, &ev);
    
    	while(1){
    		char buf[32];
    		epoll_wait(epfd, &ev, 1, -1);
    		int fd = ev.data.fd;
    /*
    int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
    等待事件的产生，类似于select()调用。参数events用来从内核得到事件的集合，maxevents告之内核这个events有多大，这个 maxevents的值不能大于创建epoll_create()时的size，参数timeout是超时时间（毫秒，0会立即返回，-1将不确定，也有说法说是永久阻塞）。该函数返回需要处理的事件数目，如返回0表示已超时。
    */
    		int len;
    		while( (len = read(fd, buf, 16)) > 0){
    			buf[len] = '\0';
    			printf("fd:%d\n%s\n", fd, buf);
    		}
    	}
    
    	return 0;
    }