aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorYunchih Chen <yunchih.cat@gmail.com>2018-03-20 10:25:52 +0800
committerYunchih Chen <yunchih.cat@gmail.com>2018-03-20 10:28:02 +0800
commit5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1 (patch)
treebb1042c36db705a2a49f3be4e622b311c32f7305
parente6698bc32ce45dda55823825d837291b5850ac8b (diff)
downloadnfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar.gz
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar.bz2
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar.lz
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar.xz
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.tar.zst
nfcollect-5a0f59d6b766cd8aa624f07a2b19f2b377ff51d1.zip
Remove pthread cancellation points
-rw-r--r--lib/collect.c3
1 files changed, 0 insertions, 3 deletions
diff --git a/lib/collect.c b/lib/collect.c
index 5ca8139..9a4e52b 100644
--- a/lib/collect.c
+++ b/lib/collect.c
@@ -51,8 +51,6 @@ static int handle_packet(struct nflog_g_handle *gh, struct nfgenmsg *nfmsg,
int payload_len = nflog_get_payload(nfa, &payload);
nfl_state_t *nf = (nfl_state_t *)_nf;
- pthread_testcancel(); /* cancellation point */
-
// only process ipv4 packet
if (unlikely(payload_len < 0) || ((payload[0] & 0xf0) != 0x40))
return 1;
@@ -143,7 +141,6 @@ void *nfl_collect_worker(void *targs) {
int rv;
char buf[4096];
while (*p_cnt_now < cnt_max) {
- pthread_testcancel(); /* cancellation point */
if ((rv = recv(fd, buf, sizeof(buf), 0)) && rv > 0) {
debug("Recv worker #%u: nflog packet received (len=%u)",
nf->header->id, rv);