diff options
Diffstat (limited to 'src/fuzzy_storage.c')
| -rw-r--r-- | src/fuzzy_storage.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/fuzzy_storage.c b/src/fuzzy_storage.c index 51bcc1001..3795383d3 100644 --- a/src/fuzzy_storage.c +++ b/src/fuzzy_storage.c @@ -386,6 +386,8 @@ accept_fuzzy_socket (gint fd, short what, void *arg) /* Got some data */ if (what == EV_READ) { + worker->nconns++; + while ((r = rspamd_inet_address_recvfrom (fd, buf, sizeof (buf), 0, &session.addr)) == -1) { if (errno == EINTR) { @@ -408,6 +410,7 @@ accept_fuzzy_socket (gint fd, short what, void *arg) } rspamd_inet_address_destroy (session.addr); + worker->nconns --; } rspamd_explicit_memzero (session.nm, sizeof (session.nm)); |