Channel.h

#pragma once

#include "Timer.h"

#include <sys/epoll.h>
#include <memory>

class EventLoop;
class HttpData;

class Channel {
private:
    typedef std::function<void()> CallBack;

public:
    Channel(EventLoop* loop);
    Channel(EventLoop* loop, int fd);
    ~Channel();
    int getFd();
    void setFd(int fd);

    void setHolder(std::shared_ptr<HttpData> holder) { holder_ = holder; }
    std::shared_ptr<HttpData> getHolder() {
        std::shared_ptr<HttpData> ret(holder_.lock());
        return ret;
    }
    // &&是右值引用，避免拷贝带来的性能开销
    void setReadHandler(CallBack&& readHandler) { readHandler_ = readHandler; }
    void setWriteHandler(CallBack&& writeHandler) {
        writeHandler_ = writeHandler;
    }
    void setErrorHandler(CallBack&& errorHandler) {
        errorHandler_ = errorHandler;
    }
    void setConnHandler(CallBack&& connHandler) { connHandler_ = connHandler; }

    void handleEvents() {
        events_ = 0;
        if ((revents_ & EPOLLHUP) && !(revents_ & EPOLLIN)) {
            events_ = 0;
            return;
        }
        if (revents_ & EPOLLERR) {
            if (errorHandler_) errorHandler_();
            events_ = 0;
            return;
        }
        if(revents_ & (EPOLLIN | EPOLLPRI | EPOLLRDHUP)) {
            handleRead();
        }
        if (revents_ & EPOLLOUT) {
            handleWrite();
        }
        handleConn();
    }
    void handleRead();
    void handleWrite();
    void handleError(int fd, int err_num, std::string short_msg);
    void handleConn();

    void setRevents(__uint32_t ev) { revents_ = ev; }
    
    void setEvents(__uint32_t ev) { events_ = ev; }
    __uint32_t& getEvents() { return events_; }

    bool EqualAndUpdateLastEvents() {
        bool ret = (lastEvents_ == events_);
        lastEvents_ = events_;
        return ret;
    }

    __uint32_t getLastEvents() { return lastEvents_; }

private:
    EventLoop* loop_;
    int fd_;
    __uint32_t events_;
    __uint32_t revents_;
    __uint32_t lastEvents_;

    std::weak_ptr<HttpData> holder_;

    int parse_URI();
    int parse_Headers();
    int analysisRequest();

    CallBack readHandler_;
    CallBack writeHandler_;
    CallBack errorHandler_;
    CallBack connHandler_;
};