From 9ffa95877b8e1f165ec744a27c94e899f6494e38 Mon Sep 17 00:00:00 2001 From: Henry Winkel Date: Wed, 5 Jul 2023 18:20:37 +0200 Subject: [PATCH] FIX: fixed the tcp client --- include/DirectCommunicationClient.hpp | 3 +++ src/DirectCommunicationClient.cpp | 6 ++++-- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/include/DirectCommunicationClient.hpp b/include/DirectCommunicationClient.hpp index 80669b9..838999a 100644 --- a/include/DirectCommunicationClient.hpp +++ b/include/DirectCommunicationClient.hpp @@ -38,6 +38,9 @@ namespace DirectCommunication std::thread Worker_; std::atomic_bool stopWorker_; + std::atomic_bool isConnected = true; + + WHISPER::threadSafeQueue receivedMessages_; diff --git a/src/DirectCommunicationClient.cpp b/src/DirectCommunicationClient.cpp index 98f05e5..f59c015 100644 --- a/src/DirectCommunicationClient.cpp +++ b/src/DirectCommunicationClient.cpp @@ -41,7 +41,9 @@ namespace DirectCommunication zmq::message_t zmqMsg(msg.begin(),msg.end()); - socket_.send(zmqMsg,zmq::send_flags::dontwait); + if (isConnected == true) { + socket_.send(zmqMsg,zmq::send_flags::dontwait); + } } @@ -70,7 +72,7 @@ namespace DirectCommunication if (msg.to_string() == "CLOSE") { - + isConnected = false; socket_.disconnect("tcp://"+serverAddress_+":"+std::to_string(port_)); }else