diff options
| author | 2014-02-08 22:40:30 +0100 | |
|---|---|---|
| committer | 2014-02-08 22:40:30 +0100 | |
| commit | 689996cb8856af43a033eb5ca1cb9df7475c0854 (patch) | |
| tree | 258bbb81046a8cefe49a65d4f15ea36779352261 /src/socketengines/socketengine_kqueue.cpp | |
| parent | Update SocketEngine::CurrentSetSize in AddFdRef()/DelFdRef() (diff) | |
Move socketengine stats into a new class
Diffstat (limited to 'src/socketengines/socketengine_kqueue.cpp')
| -rw-r--r-- | src/socketengines/socketengine_kqueue.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/socketengines/socketengine_kqueue.cpp b/src/socketengines/socketengine_kqueue.cpp index c51789b29..0a9a0a399 100644 --- a/src/socketengines/socketengine_kqueue.cpp +++ b/src/socketengines/socketengine_kqueue.cpp @@ -207,7 +207,7 @@ int KQueueEngine::DispatchEvents() if (i < 0) return i; - TotalEvents += i; + stats.TotalEvents += i; for (int j = 0; j < i; j++) { @@ -223,13 +223,13 @@ int KQueueEngine::DispatchEvents() if (kev.flags & EV_EOF) { - ErrorEvents++; + stats.ErrorEvents++; eh->HandleEvent(EVENT_ERROR, kev.fflags); continue; } if (filter == EVFILT_WRITE) { - WriteEvents++; + stats.WriteEvents++; /* When mask is FD_WANT_FAST_WRITE or FD_WANT_SINGLE_WRITE, * we set a one-shot write, so we need to clear that bit * to detect when it set again. @@ -240,7 +240,7 @@ int KQueueEngine::DispatchEvents() } else if (filter == EVFILT_READ) { - ReadEvents++; + stats.ReadEvents++; SetEventMask(eh, eh->GetEventMask() & ~FD_READ_WILL_BLOCK); eh->HandleEvent(EVENT_READ); } |
