// ae.h
typedef struct aeFileEvent {
    // 事件類型：AE_READABLE(讀事件) / AE_WRITABLE(寫事件)
    int mask; 
    // 讀事件回調(diào)函數(shù)（客戶端發(fā)命令時(shí)觸發(fā)）
    aeFileProc *rfileProc;
    // 寫事件回調(diào)函數(shù)（給客戶端返回結(jié)果時(shí)觸發(fā)）
    aeFileProc *wfileProc;
    // 私有數(shù)據(jù)（通常指向客戶端連接結(jié)構(gòu)client）
    void *clientData;
} aeFileEvent;

// ae.h
typedef struct aeFiredEvent {
    int fd;     // 就緒的文件描述符
    int mask;   // 就緒的事件類型（AE_READABLE/AE_WRITABLE）
} aeFiredEvent;

// ae.h
typedef struct aeEventLoop {
    int maxfd;                          // 當(dāng)前監(jiān)聽的最大FD
    int setsize;                        // 最大支持的FD數(shù)量（可配置）
    long long timeEventNextId;          // 時(shí)間事件ID（定時(shí)任務(wù)用）
    time_t lastTime;                    // 最后一次處理時(shí)間事件的時(shí)間
    aeFileEvent *events;                // 所有注冊(cè)的文件事件（數(shù)組，下標(biāo)=FD）
    aeFiredEvent *fired;                // 就緒的文件事件（數(shù)組）
    aeTimeEvent *timeEventHead;         // 時(shí)間事件鏈表（定時(shí)任務(wù)）
    int stop;                           // 事件循環(huán)停止標(biāo)志
    void *apidata;                      // 多路復(fù)用器私有數(shù)據(jù)（如epoll的fd）
    aeBeforeSleepProc *beforesleep;     // 事件循環(huán)休眠前的回調(diào)
    aeBeforeSleepProc *aftersleep;      // 事件循環(huán)喚醒后的回調(diào)
} aeEventLoop;

// ae.c
aeEventLoop *aeCreateEventLoop(int setsize) {
    aeEventLoop *eventLoop = zmalloc(sizeof(aeEventLoop));
    eventLoop->setsize = setsize;
    eventLoop->maxfd = -1;
    // 初始化事件數(shù)組：下標(biāo)=FD，存儲(chǔ)該FD的監(jiān)聽事件
    eventLoop->events = zmalloc(sizeof(aeFileEvent)*setsize);
    // 初始化就緒事件數(shù)組：存儲(chǔ)epoll返回的就緒事件
    eventLoop->fired = zmalloc(sizeof(aeFiredEvent)*setsize);
    eventLoop->stop = 0;
    eventLoop->lastTime = time(NULL);
    
    // 初始化具體的多路復(fù)用器（epoll）
    // aeApiCreate會(huì)調(diào)用epoll_create()創(chuàng)建epoll實(shí)例
    if (aeApiCreate(eventLoop) == -1) {
        zfree(eventLoop->events);
        zfree(eventLoop->fired);
        zfree(eventLoop);
        return NULL;
    }
    return eventLoop;
}

// ae_epoll.c：epoll的初始化實(shí)現(xiàn)
static int aeApiCreate(aeEventLoop *eventLoop) {
    aeApiState *state = zmalloc(sizeof(aeApiState));
    // 創(chuàng)建epoll實(shí)例，返回epoll_fd
    state->epfd = epoll_create(1024); // 1024是歷史參數(shù)，現(xiàn)在無意義
    eventLoop->apidata = state;
    return (state->epfd == -1) ? -1 : 0;
}

// ae.c
int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
        aeFileProc *proc, void *clientData)
{
    if (fd >= eventLoop->setsize) {
        errno = ERANGE;
        return AE_ERR;
    }
    aeFileEvent *fe = &eventLoop->events[fd];

    // 調(diào)用epoll_ctl注冊(cè)事件到epoll實(shí)例
    if (aeApiAddEvent(eventLoop, fd, mask) == -1)
        return AE_ERR;
    
    // 設(shè)置事件的回調(diào)函數(shù)和私有數(shù)據(jù)
    fe->mask |= mask;
    if (mask & AE_READABLE) fe->rfileProc = proc;
    if (mask & AE_WRITABLE) fe->wfileProc = proc;
    fe->clientData = clientData;
    if (fd > eventLoop->maxfd)
        eventLoop->maxfd = fd;
    return AE_OK;
}

// ae_epoll.c：epoll添加事件的實(shí)現(xiàn)
static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) {
    aeApiState *state = eventLoop->apidata;
    struct epoll_event ee = {0}; // epoll_event結(jié)構(gòu)體
    // 獲取該FD已注冊(cè)的事件（避免重復(fù)注冊(cè)）
    int op = eventLoop->events[fd].mask == AE_NONE ?
            EPOLL_CTL_ADD : EPOLL_CTL_MOD;

    // 轉(zhuǎn)換Redis事件掩碼為epoll事件掩碼
    ee.events = 0;
    mask |= eventLoop->events[fd].mask; // 合并已有事件
    if (mask & AE_READABLE) ee.events |= EPOLLIN;
    if (mask & AE_WRITABLE) ee.events |= EPOLLOUT;
    ee.data.fd = fd;

    // 調(diào)用epoll_ctl注冊(cè)/修改事件
    if (epoll_ctl(state->epfd, op, fd, &ee) == -1) return -1;
    return 0;
}

// ae.c
void aeMain(aeEventLoop *eventLoop) {
    eventLoop->stop = 0;
    // 無限循環(huán)，直到stop被置1（Redis關(guān)閉）
    while (!eventLoop->stop) {
        // 休眠前的回調(diào)（比如處理定時(shí)任務(wù)、統(tǒng)計(jì)）
        if (eventLoop->beforesleep != NULL)
            eventLoop->beforesleep(eventLoop);
        // 核心：等待就緒事件，返回就緒的事件數(shù)量
        aeProcessEvents(eventLoop, AE_ALL_EVENTS);
    }
}

// ae.c：處理事件的核心函數(shù)
int aeProcessEvents(aeEventLoop *eventLoop, int flags) {
    int processed = 0, numevents;

    // 調(diào)用aeApiPoll（epoll_wait）等待就緒事件
    numevents = aeApiPoll(eventLoop, tvp);
    processed += numevents;

    // 遍歷所有就緒事件，逐個(gè)處理
    for (int j = 0; j < numevents; j++) {
        aeFileEvent *fe = &eventLoop->events[eventLoop->fired[j].fd];
        int mask = eventLoop->fired[j].mask;
        int fd = eventLoop->fired[j].fd;
        int rfired = 0;

        // 處理讀事件
        if (fe->mask & mask & AE_READABLE) {
            rfired = 1;
            // 調(diào)用讀事件回調(diào)（比如readQueryFromClient）
            fe->rfileProc(eventLoop, fd, fe->clientData, mask);
        }
        // 處理寫事件
        if (fe->mask & mask & AE_WRITABLE) {
            if (!rfired || fe->wfileProc != fe->rfileProc) {
                // 調(diào)用寫事件回調(diào)（比如sendReplyToClient）
                fe->wfileProc(eventLoop, fd, fe->clientData, mask);
            }
        }
        processed++;
    }
    // 處理時(shí)間事件（定時(shí)任務(wù)，如過期鍵清理）
    ...
    return processed;
}

// ae_epoll.c：epoll_wait等待就緒事件
static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) {
    aeApiState *state = eventLoop->apidata;
    int retval;
    // 調(diào)用epoll_wait，阻塞等待就緒事件，結(jié)果存入eventLoop->fired
    retval = epoll_wait(state->epfd, eventLoop->fired, eventLoop->setsize,
            tvp ? (tvp->tv_sec*1000 + tvp->tv_usec/1000) : -1);
    return retval;
}

// ae.c
void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask) {
    if (fd >= eventLoop->setsize) return;
    aeFileEvent *fe = &eventLoop->events[fd];
    if (fe->mask == AE_NONE) return;

    // 從epoll中刪除事件
    aeApiDelEvent(eventLoop, fd, mask);
    // 更新事件掩碼
    fe->mask = fe->mask & (~mask);
    if (fd == eventLoop->maxfd && fe->mask == AE_NONE) {
        // 更新maxfd，優(yōu)化后續(xù)遍歷
        while (eventLoop->maxfd >= 0 && eventLoop->events[eventLoop->maxfd].mask == AE_NONE)
            eventLoop->maxfd--;
    }
}

// ae_epoll.c
static int aeApiDelEvent(aeEventLoop *eventLoop, int fd, int delmask) {
    aeApiState *state = eventLoop->apidata;
    struct epoll_event ee = {0};
    int mask = eventLoop->events[fd].mask & (~delmask);

    ee.events = 0;
    if (mask & AE_READABLE) ee.events |= EPOLLIN;
    if (mask & AE_WRITABLE) ee.events |= EPOLLOUT;
    ee.data.fd = fd;
    int op = mask == AE_NONE ? EPOLL_CTL_DEL : EPOLL_CTL_MOD;
    // 調(diào)用epoll_ctl刪除/修改事件
    if (epoll_ctl(state->epfd, op, fd, &ee) == -1) return -1;
    return 0;
}