aboutsummaryrefslogtreecommitdiff
path: root/src/socketengines/socketengine_epoll.cpp
diff options
context:
space:
mode:
authorGravatar Attila Molnar2014-02-08 22:40:30 +0100
committerGravatar Attila Molnar2014-02-08 22:40:30 +0100
commit689996cb8856af43a033eb5ca1cb9df7475c0854 (patch)
tree258bbb81046a8cefe49a65d4f15ea36779352261 /src/socketengines/socketengine_epoll.cpp
parentUpdate SocketEngine::CurrentSetSize in AddFdRef()/DelFdRef() (diff)
Move socketengine stats into a new class
Diffstat (limited to 'src/socketengines/socketengine_epoll.cpp')
-rw-r--r--src/socketengines/socketengine_epoll.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/socketengines/socketengine_epoll.cpp b/src/socketengines/socketengine_epoll.cpp
index 7ee01b2cc..39cc60606 100644
--- a/src/socketengines/socketengine_epoll.cpp
+++ b/src/socketengines/socketengine_epoll.cpp
@@ -185,7 +185,7 @@ int EPollEngine::DispatchEvents()
int i = epoll_wait(EngineHandle, &events[0], events.size(), 1000);
ServerInstance->UpdateTime();
- TotalEvents += i;
+ stats.TotalEvents += i;
for (int j = 0; j < i; j++)
{
@@ -202,14 +202,14 @@ int EPollEngine::DispatchEvents()
if (ev.events & EPOLLHUP)
{
- ErrorEvents++;
+ stats.ErrorEvents++;
eh->HandleEvent(EVENT_ERROR, 0);
continue;
}
if (ev.events & EPOLLERR)
{
- ErrorEvents++;
+ stats.ErrorEvents++;
/* Get error number */
socklen_t codesize = sizeof(int);
int errcode;
@@ -235,7 +235,7 @@ int EPollEngine::DispatchEvents()
SetEventMask(eh, mask);
if (ev.events & EPOLLIN)
{
- ReadEvents++;
+ stats.ReadEvents++;
eh->HandleEvent(EVENT_READ);
if (eh != GetRef(ev.data.fd))
// whoa! we got deleted, better not give out the write event
@@ -243,7 +243,7 @@ int EPollEngine::DispatchEvents()
}
if (ev.events & EPOLLOUT)
{
- WriteEvents++;
+ stats.WriteEvents++;
eh->HandleEvent(EVENT_WRITE);
}
}