mtcp_epoll.h

Go to the documentation of this file.

#ifndef __MTCP_EPOLL_H_
#define __MTCP_EPOLL_H_

#include "mtcp_api.h"

#ifdef __cplusplus
extern "C" {
#endif

enum mtcp_epoll_op
{
    MOS_EPOLL_CTL_ADD = 1,
    MOS_EPOLL_CTL_DEL = 2,
    MOS_EPOLL_CTL_MOD = 3,
};

enum epoll_event_type
{
    /* mtcp-defined epoll events */
    MOS_EPOLLNONE       = (0x1<<0),
    MOS_EPOLLIN         = (0x1<<1),
    MOS_EPOLLPRI        = (0x1<<2),
    MOS_EPOLLOUT        = (0x1<<3),
    MOS_EPOLLRDNORM     = (0x1<<4),
    MOS_EPOLLRDBAND     = (0x1<<5),
    MOS_EPOLLWRNORM     = (0x1<<6),
    MOS_EPOLLWRBAND     = (0x1<<7),
    MOS_EPOLLMSG        = (0x1<<8),
    MOS_EPOLLERR        = (0x1<<9),
    MOS_EPOLLHUP        = (0x1<<10),
    MOS_EPOLLRDHUP      = (0x1<<11),

    /* mtcp-defined epoll events */
    MOS_EPOLLONESHOT    = (0x1 << 30),
    MOS_EPOLLET         = (0x1 << 31)
};

enum mtcp_action
{
    /* mtcp action */
    MOS_ACT_SEND_DATA   =   (0x01<<1),
    MOS_ACT_SEND_ACK_NOW    =   (0x01<<2),
    MOS_ACT_SEND_ACK_AGG    =   (0x01<<3),
    MOS_ACT_SEND_CONTROL    =   (0x01<<4),
    MOS_ACT_SEND_RST    =   (0x01<<5),
    MOS_ACT_DESTROY     =   (0x01<<6),
    /* only used by monitoring socket */
    MOS_ACT_READ_DATA   =   (0x01<<7),
    MOS_ACT_CNT
};

typedef union mtcp_epoll_data
{
    void *ptr;
    int sock;
    uint32_t u32;
    uint64_t u64;
} mtcp_epoll_data_t;

struct mtcp_epoll_event
{
    uint64_t events;
    mtcp_epoll_data_t data;
};

int
mtcp_epoll_create(mctx_t mctx, int size);

int
mtcp_epoll_ctl(mctx_t mctx, int epid,
        int op, int sock, struct mtcp_epoll_event *event);

int
mtcp_epoll_wait(mctx_t mctx, int epid,
        struct mtcp_epoll_event *events, int maxevents, int timeout);

char *
EventToString(uint32_t event);

#ifdef __cplusplus
};
#endif

#endif /* __MTCP_EPOLL_H_ */