From ddde32a8c20c23411a07308933657837e96f3119 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Fri, 8 May 2020 10:37:09 +0200 Subject: [PATCH] Add thread stopping function --- core-buffer/include/LiveRecvModule.hpp | 2 ++ core-buffer/src/LiveRecvModule.cpp | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/core-buffer/include/LiveRecvModule.hpp b/core-buffer/include/LiveRecvModule.hpp index 27b72c0..d63357a 100644 --- a/core-buffer/include/LiveRecvModule.hpp +++ b/core-buffer/include/LiveRecvModule.hpp @@ -31,6 +31,8 @@ public: ModuleFrameBuffer *metadata, char *data); + void stop(); + }; diff --git a/core-buffer/src/LiveRecvModule.cpp b/core-buffer/src/LiveRecvModule.cpp index 082ca85..691222c 100644 --- a/core-buffer/src/LiveRecvModule.cpp +++ b/core-buffer/src/LiveRecvModule.cpp @@ -32,6 +32,11 @@ LiveRecvModule::LiveRecvModule( } LiveRecvModule::~LiveRecvModule() +{ + stop(); +} + +void LiveRecvModule::stop() { is_receiving_ = false; receiving_thread_.join();