BiscuitWiki: Epoll Class

이제는, 다른 프로그래머가 epoll이 뭔지 몰라도 이 좋은 성능을 맘껏 이용할 수 있도록 추상화를 시켜야겠다.

1 Class 설계의 고민

1.1 ?TEpoll constructor & destructor 구현
1.2 Add() 와 Delete() 의 구현
1.3 Do() 함수의 구현

1 Class 설계의 고민 #

네트워크 서버도 하도 가지가지라서, 어떤 설계를 할 지 고민을 해 봤다. 여러가지 방법들이 있겠지만, 단지 Epoll함수들을 추상화하도록 만들어 보기로 했다.

프로그래머가 선호하는 소켓이벤트 처리 시점, 즉 epoll_wait 를 콜 하는 시점이 사람마다 다를 수 있기 때문에, Do 라는 별도 public 함수를 만들어서 콜하도록 한다.
epoll에 관심 fd 를 추가하거나 삭제하는 것은 모두 수동으로 한다.
listen 소켓의 event처리, 즉 accept도 따로 처리한다.

class TEpoll
{
private :
    int fd_epoll;

public :
    bool is_epoll_init;
    
    TEpoll(const int size);
    ~TEpoll(); 
            
    int Add(const int fd);
    int Delete(const int fd);
    
    int Do(TPEpollEvent events, const int nwait);
};

1.1 ?TEpoll constructor & destructor 구현 #

생성자와 소멸자 구현은 특별할만한게 없다. 생성자에서는 epoll_create 해주고, 소멸자에서는 fd_epoll 에 대해서 close 처리를 해준다. 각 fd마다 epoll에서 delete할 필요는 없고, 각 fd의 close는 사용자가 알아서 해줘야 한다

TEpoll::TEpoll(const int size)
{
    is_epoll_init = (fd_epoll = epoll_create(size)) > 0);
}

TEpoll::~TEpoll()
{
    if(is_epoll_init) close(fd_epoll);
}

is_epoll_init boolean 변수를 두어, 초기화 실패시 대응하도록 하였다. 초기화변수 size는 최대 동접수를 의미.

1.2 Add() 와 Delete() 의 구현 #

// �瞿� typedef
typedef struct epoll_event TEpollEvent;
typedef TEpollEvent * TPEpollEvent;

int TEpoll::Add(const int fd)
{       
    if(! is_epoll_init) return -1;
    TEpollEvent ev;
                
    ev.events  = EPOLLIN | EPOLLOUT | EPOLLERR | EPOLLET;
    ev.data.fd = fd;
                
    return epoll_ctl(fd_epoll, EPOLL_CTL_ADD, fd, &ev);
}       

int TEpoll::Delete(const int fd)
{       
    if(! is_epoll_init) return -1;
    TEpollEvent ev;
        
    ev.events  = EPOLLIN | EPOLLOUT | EPOLLERR;
    ev.data.fd = fd;
        
    return epoll_ctl(fd_epoll, EPOLL_CTL_DEL, fd, &ev);
}

1.3 Do() 함수의 구현 #

Do 함수는, 클래스 외부와의 가장 중요한 인터페이스 함수로 설계했다. 사용자(프로그래머)는 적당히 fd들을 생성해서 TEpoll:?:Add()를 통해 epoll의 관심fd로 등록을 하고, 이 Do 함수를 통해 이벤트가 발생한 fd들을 알아내도록 한다.

int TEpoll::Do(TPEpollEvent events, const int nwait)
{
    if(! is_epoll_init) return -1;
    return epoll_wait(fd_epoll, events, MAX_EVENTS, nwait);
}