reactor_server_cpp/server/event_handler.cc at main · mwfj/reactor_server_cpp · 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
92
93
94
95
#include "event_handler.h"
#include "channel.h"
#include "log/logger.h"

EventHandler::EventHandler(){
#if defined(__linux__)
    epoll_event_ = std::unique_ptr<EpollHandler>(new EpollHandler());
#elif defined(__APPLE__) || defined(__MACH__)
    kqueue_event_ = std::unique_ptr<KqueueHandler>(new KqueueHandler());
#endif
}

void EventHandler::UpdateEvent(std::shared_ptr<Channel> ch){
#if defined(__linux__)
    if(!epoll_event_){
        logging::Get()->error("Nullptr of epoll_event");
        throw std::runtime_error("Nullptr of epoll_event");
    }
    epoll_event_ -> UpdateEvent(ch);
#elif defined(__APPLE__) || defined(__MACH__)
    if(!kqueue_event_){
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    kqueue_event_ -> UpdateEvent(ch);
#endif
}

void EventHandler::RemoveChannel(std::shared_ptr<Channel> ch) {
#if defined(__linux__)
    if(!epoll_event_){
        logging::Get()->error("Nullptr of epoll_event");
        throw std::runtime_error("Nullptr of epoll_event");
    }
    epoll_event_ -> RemoveChannel(ch);
#elif defined(__APPLE__) || defined(__MACH__)
    if(!kqueue_event_){
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    kqueue_event_ -> RemoveChannel(ch);
#endif
}

std::vector<std::shared_ptr<Channel>> EventHandler::WaitForEvent(int timeout) {
#if defined(__linux__)
    if(!epoll_event_){
        logging::Get()->error("Nullptr of epoll_event");
        throw std::runtime_error("Nullptr of epoll_event");
    }
    return epoll_event_ -> WaitForEvent(timeout);
#elif defined(__APPLE__) || defined(__MACH__)
    if(!kqueue_event_){
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    return kqueue_event_ -> WaitForEvent(timeout);
#endif
}

void EventHandler::RegisterTimer(int interval_sec) {
#if defined(__APPLE__) || defined(__MACH__)
    if (!kqueue_event_) {
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    kqueue_event_->RegisterTimer(interval_sec);
#else
    (void)interval_sec;  // Linux uses timerfd Channel — no-op here
#endif
}

void EventHandler::ResetTimer(int interval_sec) {
#if defined(__APPLE__) || defined(__MACH__)
    if (!kqueue_event_) {
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    kqueue_event_->ResetTimer(interval_sec);
#else
    (void)interval_sec;
#endif
}

bool EventHandler::ConsumeTimerFired() {
#if defined(__APPLE__) || defined(__MACH__)
    if (!kqueue_event_) {
        logging::Get()->error("Nullptr of kqueue_event");
        throw std::runtime_error("Nullptr of kqueue_event");
    }
    return kqueue_event_->ConsumeTimerFired();
#else
    return false;
#endif
}