HttpServer/Event.cpp at main · linnaeushuang/HttpServer · GitHub

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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

#include "Event.h"
#include <unistd.h>
#include <cstdlib>
#include "Epoll.h"
#include "EventLoop.h"

Event::Event(EventLoop *loop)
	: loop_(loop), events_(0), lastEvents_(0), fd_(0) {}

Event::Event(EventLoop *loop, int fd)
    : loop_(loop), events_(0), lastEvents_(0), fd_(fd) {}

Event::~Event(){}

int Event::getFd() { return fd_; }

void Event::setFd(int fd) { fd_ = fd; }

void Event::setHttpHolder(std::shared_ptr<HttpData> holder) {holder_ = holder; }

std::shared_ptr<HttpData> Event::getHttpHolder() {
	std::shared_ptr<HttpData> ret(holder_.lock());
	return ret;
}


void Event::setReadHandler(CallBack &&readHandler) { readHandler_ = readHandler; }

void Event::setWriteHandler(CallBack &&writeHandler) { writeHandler_ = writeHandler; }

void Event::setErrorHandler(CallBack &&errorHandler) { errorHandler_ = errorHandler; }

void Event::setConnHandler(CallBack &&connHandler) { connHandler_ = connHandler; }

void Event::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 Event::handleRead() {
	if (readHandler_) {
		readHandler_();
	}
}

void Event::handleWrite() {
	if (writeHandler_) {
		writeHandler_();
	}
}


void Event::handleConn() {
	if (connHandler_) {
		connHandler_();
	}
}


void Event::handleError(){
	//TODO: do something
};

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

bool Event::EqualAndUpdateLastEvents() {
	bool ret = (lastEvents_ == events_);
	lastEvents_ = events_;
	return ret;
}
__uint32_t Event::getLastEvents() { return lastEvents_; }