From 03e96c4ee3dcf14873a1cdad12509683006a3329 Mon Sep 17 00:00:00 2001 From: Determinant Date: Sun, 7 Apr 2019 17:46:53 -0400 Subject: stop the workers before MsgNetwork releases the queue --- include/salticidae/event.h | 3 --- 1 file changed, 3 deletions(-) (limited to 'include/salticidae/event.h') diff --git a/include/salticidae/event.h b/include/salticidae/event.h index df49c58..946dda1 100644 --- a/include/salticidae/event.h +++ b/include/salticidae/event.h @@ -547,7 +547,6 @@ class MPMCQueueEventDriven: public MPMCQueue { class ThreadCall { public: class Handle; private: - int ctl_fd[2]; EventContext ec; const size_t burst_size; using queue_t = MPSCQueueEventDriven; @@ -621,8 +620,6 @@ class ThreadCall { ~ThreadCall() { Handle *h; while (q.try_dequeue(h)) delete h; - close(ctl_fd[0]); - close(ctl_fd[1]); } template -- cgit v1.2.3