From e5e9d4074f1e914ba669a685b415d3da684cf00f Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 6 May 2020 15:40:20 +0200 Subject: [PATCH] Remove zmq context from thread parameter --- core-buffer/include/LiveRecvModule.hpp | 2 +- core-buffer/src/LiveRecvModule.cpp | 6 ++---- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/core-buffer/include/LiveRecvModule.hpp b/core-buffer/include/LiveRecvModule.hpp index 868f6e7..b6ea20f 100644 --- a/core-buffer/include/LiveRecvModule.hpp +++ b/core-buffer/include/LiveRecvModule.hpp @@ -24,7 +24,7 @@ public: virtual ~LiveRecvModule(); void* connect_socket(size_t module_id); void recv_single_module(void* socket, ModuleFrame* metadata, char* data); - void receive_thread(const size_t n_modules, void* ctx); + void receive_thread(const size_t n_modules); }; diff --git a/core-buffer/src/LiveRecvModule.cpp b/core-buffer/src/LiveRecvModule.cpp index 7871b5a..e222cf8 100644 --- a/core-buffer/src/LiveRecvModule.cpp +++ b/core-buffer/src/LiveRecvModule.cpp @@ -28,9 +28,7 @@ LiveRecvModule::LiveRecvModule( #endif receiving_thread_ = thread( - &LiveRecvModule::receive_thread, this, - n_modules, - ctx_); + &LiveRecvModule::receive_thread, this, n_modules); } LiveRecvModule::~LiveRecvModule() @@ -98,7 +96,7 @@ void LiveRecvModule::recv_single_module( } } -void LiveRecvModule::receive_thread(const size_t n_modules, void* ctx_) +void LiveRecvModule::receive_thread(const size_t n_modules) { try {