기본 콘텐츠로 건너뛰기

I/O - epoll

epoll 은 감시해야 하는 fd가 많을 때 select나 poll에 비해 성능이 좋다.

epoll_create() epoll 인스턴스를 생성, 이 인스턴스를 참조하는 fd를 리턴한다.
epoll_ctl() 관심 목록 설정할때 사용. 새 fd를 추가 하거나 기존 목록에서 제고 할 수 있고 이벤트 감시를 변경 할 수 있다.
epoll_wait() 인스턴스에서 준비 목록을 리턴한다.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
#include "sys/epoll.h"
int epoll_create( int size );
// 성공하면 fd 리턴, 에러가 발생하면 -1
// 리눅스 2.6.8이전에는 커널에게 초기 데이터 구조체를 어떻게 설정하는지에 대한 거였다는데..... 이제는 필요 없단다
int epoll_create1() // 대신 이게 새로 생김
int epoll_ctl( int efd, int op, int fd, struct epoll_event* ev );
// 성공하면 fd 리턴, 에러가 발생하면 -1
// fd에는 pipe, pifo, socket, posix message queue, inotify instanc, divice, 다른 epoll 디스크립터등..이 될 수 있다.
// 만약 안되는놈을 지정하면 EPERM 에러를 발생 한다.
struct epoll_event {
    uint32_t events;
    epoll_data_t data;
}
typedef union epoll_data {
    void* ptr;
    int fd;
    uint32_t u32;
    uint64_t u64;
} epoll_data_t;
/** /proc/sys/fs/epoll 디렉토리에 있는 max_user_watches 에서 한도값을 확인 하고 수정 할 수 있다.**/


op 인자에 추가되는 flag
 EPOLL_CTL_ADD
 fd 를 epfd의 관심 목록에 추가, 이미 목록에 존재한다면 EEXIST 에러를 발생 시킨다.
 event 집합은 *ev에 저장 된다.
 EPOLL_CTL_MOD
 *ev에 지정된 정보를 이용해 fd 설정 변경. 관심 목록에 없는 fd라면 ENOENT 에러를 발생 시킨다.
 EPOLL_CTL_DEL
 epfd 에서 fd를 제공 한다. epfd 관심 목록에 없는 fd를 제거하려면 ENOENT 에러를 발생 한다.
 fd를 닫으면 epoll 관심 목록에서 자동 제거 된다.


?
1
2
3
4
5
6
7
8
9
10
11
12
#include "sys/epoll.h"
int epoll_wait( int epfd, struct epoll_event* evlist, int maxevents, int timeout );
// 성공하면 준비된 fd count를 리턴 한다.
// 타임 아웃이면 0, 에러면 -1을 리턴
// 준비된 fd는.. evlist가 가리키는 epoll_event구조체 배열로 리턴됨.
// timeout 이 -1이면 epfd의 관심 목록에 있는 fd중 하나에서 이벤트나 시그널이 발생할때까지 블럭
// timeout 이 0이면 epfd에서 현재 이용 할 수 있는 fd가 있는지를 비블로킹 방식으로 검사
// timeout이 0보다 크면, epfd중 fd하나에서 이벤트나 시그널이 발생할때까지 timeout 밀리초만큼 블록 한다.
//** 멀티쓰레드에서 한 쓰레드는 epoll_wait 하고 있고 다른 스레드에서 epoll_ctl을 수행해 epfd에 add할 경우, **//
//**  새로 추가된 fd가 바로 적용된다. epoll_wait는 새로 추가된 fd의 준비 여부를 리턴 결과에 포함 한다. **//


비트
설명
EPOLLIN
높은 우선순위 데이터 외의 데이터를 읽을 수 있다.
EPOLLPRI
높은 우선순위 데이터를 읽을 수 있다
EPOLLRDHUP상대편 소켓 셧다운
EPOLLOUT일반 데이터를 기록 할 수 있다
EPOLLET 에지 트리거 이벤트 통지를 적용
EPOLLONESHOT
 이벤트 통지 뒤에 감시를 비활성화 한다.
EPOLLERR에러 발생
EPOLLHUP장애 발생 (hangup)



하늘색은 EPOLL_CTL의 입력, WAIT 리턴 둘다 사용
주황색은 CTL의 입력에서만 사용
회색은 WAIT 리턴에서만 사용

EPOLLONESHOT
기본적으론 epoll_ctl로 관심목록에 추가하면 제거할때까지 활성 상태로 남게 된다.
특정 fd로부터 통지를 받으려면 ev.ents값에 EPOLLONESHOT 를 지정하면 됨. 지정하고 wait를 호출하며 해당 fd가 ready상태인지 알려준뒤 해당 fd를 비활성화가 되고 이후에 다시 wait를 호출하면 비활성화된 fd는 안알려준다. (필요할 경우 EPOLL_CTL_MOD 를 사용해 재활성화 해야 함. )


?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#include "sys/epoll.h"
void epoll( const char* pName )
{
    int epCnt = 10;
    epfd = epoll_create( epCnt );
    if ( -1 == epfd ) return;
    for ( int i = 0; i < 5; ++i ) {
        int fd = open( pName, O_RDONLY );
        if ( -1 == fd ) return;
        printf("Opened : %s, fd %d\n", pName, fd );
        struct epoll_event event;
        event.events =  EPOLLIN;
        ev.data.fd = fd;
        if ( -1 == epoll_ctl( epfd, EPOLL_CTL_ADD, fd, &event ) )
            return;
        while ( epCnt - 1 > 0 ) {
            printf("About to epoll_wait\n");
            // 한번에 처리 가능한 이벤트 갯수
            const int MAX_EVENTS = 5;
            struct epoll_event eventList[ MAX_EVENTS ];
            int ready = epoll_wait( epfd, MAX_EVENTS, -1 );
            if ( -1 == ready ) {
                if ( EINTR == errno )
                    continue; // 시그널에 의해 중단되면 실행 재개
                else
                    return; // 준비된 fd 없음..
            }
            printf("Ready : %d\n", ready );
            for ( int eventIndex = 0; eventIndex < ready; ++eventIndex ) {
                printf("fd %d, EPOLLIN? %s, EPOLLHUP? %s, EPOLLERR? %s\n",
                    eventList[ eventIndex ].data.fd,
                    eventList[ eventIndex ].events & EPOLLIN ? "true" : "false",
                    eventList[ eventIndex ].events & EPOLLHUP ? "true" : "false",
                    eventList[ eventIndex ].events & EPOLLERR ? "true" : "false"
                    );
            }
            if ( eventList[ eventIndex ].events & EPOLLIN ) {
                int s = read( eventList[ eventIndex ].data.fd, buf, 1024 );
                if ( -1 == s ) return; // 읽기 에러
                printf("reaad %d bytes : %s\n", s, buf );
            }
            else
            {
                printf("closing fd %d\n", eventList[ eventIndex ].data.fd );
                if ( -1 == close( eventList[ eventIndex ].data.fd ))
                    return;
                --epCnt;
            }
        }
    }
    printf("All file descriptors closed; bye\n");
}


댓글

댓글 쓰기

이 블로그의 인기 게시물

UNIX C errno 정리( 에러 번호 )

#define EPERM   1   /* Operation not permitted      */ #define ENOENT  2   /* No such file or directory        */ #define ESRCH   3   /* No such process          */ #define EINTR   4   /* interrupted system call      */ #define EIO 5   /* I/O error                */ #define ENXIO   6   /* No such device or address        */ #define E2BIG   7   /* Arg list too long            */ #define ENOEXEC 8   /* Exec format error            */ #define EBADF   9   /* Bad file descriptor          */ #define ECHILD  10  /* No child processes           */ #define EAGAIN  11  /* Resource temporarily unavailable */ #define ENOMEM  12  /* Not enough space         */ #define EACCES  13  /* Permission denied            */ #define EFAULT  14  /* Bad address              */ #define ENOTBLK 15  /* Block device required        */ #define EBUSY   16  /* Resource busy            */ #define EEXIST  17  /* File exists              */ #define EXDEV   18  /* Improper link            */ #define ENODEV  19  /* No such
댓글 쓰기
자세한 내용 보기

시리얼(Serial) 이란?

출처 - http://www.ni.com/white-paper/2895/ko/#toc4 시리얼은 거의 모든 PC에서 표준으로 사용되는 디바이스 통신 프로토콜입니다. 시리얼의 개념을 USB의 개념과 잘 구분하십시오. 대부분의 컴퓨터에는 2개의 RS232 기반 시리얼 포트가 있습니다. 시리얼은 또한 여러가지 디바이스에서 계측을 위한 일반 통신 프로토콜이며, 여러 GPIB 호환 디바이스에는 RS232 포트가 장착되어 있습니다. 뿐만 아니라, 원격 샘플링 디바이스로 데이터 수집을 하는 경우에도 시리얼 통신을 사용할 수 있습니다. 시리얼 통신의 개념은 간단합니다. 시리얼 포트는 정보의 바이트를 한번에 한 비트씩 순차적으로 송수신합니다. 한번에 전체 바이트를 동시에 전달하는 병렬 통신과 비교하면 시리얼 통신은 속도가 느리지만 훨씬 간단하며 장거리에도 사용할 수 있습니다. 예를 들어, 병렬 통신용 IEEE 488 스펙을 보면 기기간 케이블링은 총 20 m 미만이어야 하며, 두 개의 디바이스간은 2 m 미만이어야 합니다. 반면 시리얼 통신은 최대 1.2 Km의 통신거리를 보장합니다. 통상 엔지니어들은 ASCII 데이터를 전송할 때 시리얼 통신을 사용합니다. 이 때 송신용 (Tx), 수신용 (Rx), 그라운드용 (GND)의 세 가지의 전송 라인을 사용하여 통신합니다. 시리얼은 비동기식이므로 포트는 한 라인에서 데이터를 전송하고 다른 라인에서 데이터를 수신합니다. 핸드쉐이킹용 라인도 사용 가능하지만 필수 요구사항은 아닙니다. 시리얼 통신의 가장 중요한 특징에는 보드 속도 (baud rate), 데이터 비트, 정지 비트, 패리티가 있습니다. 두 개의 포트가 통신하기 위해서는 이러한 파라미터가 반드시 적절하게 맞춰져야 합니다. 보드 속도는 통신의 속도를 측정하는 수치이며 초당 비트 전송 숫자로 표시됩니다. 예를 들어 300 보드 속도는 초당 300 비트를 의미합니다. 엔지니어들이 흔히 말하는 클럭 주기는 보드 속도를 의미합니다. 따라서 프로토콜에 4800
댓글 쓰기
자세한 내용 보기

[C언어] epoll 설명

출처 -  http://biscuit.cafe24.com/moniwiki/wiki.php/epoll 1  준비 2  socket 프로그래밍 기본 3  비동기 입출력 (Asyncronous I/O) & 입출력 다중화 (I/O Multiplexing) 4  select 5  select 와  poll  그리고 epoll. 그 차이 6  epoll 프로그래밍 흐름 7  epoll 함수들 8  epoll References 빈폴도 아니고, 이폴이란 대체 무엇일까? 당신은 서버한대로 몇 명의 동시접속자를 수용할 수 있습니까? 최근에 인터넷에 떠돌아다니는  c10k_problem 은 대당 10K, 즉 1만명의 동시접속(concurrent users)을 받아보자는 문제다. 서버 프로그래밍을 해 본 사람이라면 이게 그리 만만한 문제가 아니라는 것을 직감할 듯 --; 요즘의 Massive 온라인게임은 '분산처리'가 기본이라 한 대에서 많은 이용자를 커버하기보다는 여러대가 하나의 세트로써 구성하는 것이 인기가 있고 다수의 커넥션보다는 소수 커넥션에서의 대용량 전송이 더 중요한 요소이기도 하다. c10k problem에 나또한 관심을 가지게 되었고, epoll 이 최근 급부상하는 솔루션으로 인기가 있다기에 한 번 파보자 하고 결심하고 이 글을 시작했다. 마침 wiki에도 관심이 있던 차라, wiki 공부도 할 겸해서 epoll 을 연구하는 과정을 이 wiki에 담아 보고자 한다. 1  준비  # * 누구를 위한 epoll 인가? epoll은 '한 대의 서버에서 아주많은 동시접속자를 처리하기 위한 수단'이다. 이미 당신이 그 수단을 알고 있다면 - epoll 이건 아니건 - 이 글은 별로 도움이 안될듯하다. 동시접속자가 천명을 넘지않는다면 구닥다리 방법을 이용하는 것과 큰 차이가 없으리라 본다. 또한, epoll은  Linux 프로그래머의 도구 이다. M$ wind
댓글 쓰기
자세한 내용 보기