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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/*
*
* (C) 2003-2024 Anope Team
* Contact us at team@anope.org
*
* Please read COPYING and README for further details.
*
* Based on the original code of Epona by Lara.
* Based on the original code of Services by Andy Church.
*/
#include "services.h"
#include "anope.h"
#include "sockets.h"
#include "socketengine.h"
#include "logger.h"
#include "config.h"
#include <sys/types.h>
#include <sys/event.h>
#include <sys/time.h>
#include <errno.h>
static int kq_fd;
static std::vector<struct kevent> change_events, event_events;
static unsigned change_count;
static inline struct kevent *GetChangeEvent()
{
if (change_count == change_events.size())
change_events.resize(change_count * 2);
return &change_events[change_count++];
}
void SocketEngine::Init()
{
kq_fd = kqueue();
if (kq_fd < 0)
throw SocketException("Unable to create kqueue engine: " + Anope::LastError());
change_events.resize(DefaultSize);
event_events.resize(DefaultSize);
}
void SocketEngine::Shutdown()
{
while (!Sockets.empty())
delete Sockets.begin()->second;
}
void SocketEngine::Change(Socket *s, bool set, SocketFlag flag)
{
if (set == s->flags[flag])
return;
s->flags[flag] = set;
int mod;
if (flag == SF_READABLE)
mod = EVFILT_READ;
else if (flag == SF_WRITABLE)
mod = EVFILT_WRITE;
else
return;
struct kevent *event = GetChangeEvent();
EV_SET(event, s->GetFD(), mod, set ? EV_ADD : EV_DELETE, 0, 0, NULL);
}
void SocketEngine::Process()
{
if (Sockets.size() > event_events.size())
event_events.resize(event_events.size() * 2);
static timespec kq_timespec = { Config->ReadTimeout, 0 };
int total = kevent(kq_fd, &change_events.front(), change_count, &event_events.front(), event_events.size(), &kq_timespec);
change_count = 0;
Anope::CurTime = time(NULL);
/* EINTR can be given if the read timeout expires */
if (total == -1)
{
if (errno != EINTR)
Log() << "SockEngine::Process(): error: " << Anope::LastError();
return;
}
for (int i = 0; i < total; ++i)
{
struct kevent &event = event_events[i];
if (event.flags & EV_ERROR)
continue;
std::map<int, Socket *>::iterator it = Sockets.find(event.ident);
if (it == Sockets.end())
continue;
Socket *s = it->second;
if (event.flags & EV_EOF)
{
s->ProcessError();
delete s;
continue;
}
if (!s->Process())
{
if (s->flags[SF_DEAD])
delete s;
continue;
}
if (event.filter == EVFILT_READ && !s->ProcessRead())
s->flags[SF_DEAD] = true;
else if (event.filter == EVFILT_WRITE && !s->ProcessWrite())
s->flags[SF_DEAD] = true;
if (s->flags[SF_DEAD])
delete s;
}
}
|
