diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2011-01-28 14:10:46 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2011-01-28 14:10:46 +0100 |
| commit | 7b2fe01e2b06aa92a824d5406f23f7574f8d01df (patch) | |
| tree | 190764a542e35ac574cb638d035dd496e502433e | |
| parent | e1faded2e90cf3692aa2cfac910ca48642c1dbf5 (diff) | |
| download | rsyslog-7b2fe01e2b06aa92a824d5406f23f7574f8d01df.tar.gz rsyslog-7b2fe01e2b06aa92a824d5406f23f7574f8d01df.tar.xz rsyslog-7b2fe01e2b06aa92a824d5406f23f7574f8d01df.zip | |
small speedup to imptcp: read more than one events in epoll call
| -rw-r--r-- | plugins/imptcp/imptcp.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/plugins/imptcp/imptcp.c b/plugins/imptcp/imptcp.c index 7e50707e..33bfa81c 100644 --- a/plugins/imptcp/imptcp.c +++ b/plugins/imptcp/imptcp.c @@ -1007,13 +1007,14 @@ finalize_it: BEGINrunInput int i; int nfds; - struct epoll_event events[1]; + struct epoll_event events[128]; epolld_t *epd; CODESTARTrunInput DBGPRINTF("imptcp: now beginning to process input data\n"); while(glbl.GetGlobalInputTermState() == 0) { DBGPRINTF("imptcp going on epoll_wait\n"); nfds = epoll_wait(epollfd, events, sizeof(events)/sizeof(struct epoll_event), -1); + DBGPRINTF("imptcp: epoll returned %d events\n", nfds); for(i = 0 ; (i < nfds) && (glbl.GetGlobalInputTermState() == 0) ; ++i) { /* support for larger batches (later, TODO) */ epd = (epolld_t*) events[i].data.ptr; switch(epd->typ) { |