henry/whisper-com
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

FIX:fixed issue with sending message

Browse Source
This commit is contained in:
Henry Winkel
2023-08-09 17:03:33 +02:00
parent 27987081d7
commit e01cc3a562
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/DirectCommunicationClient.cpp
View File

@@ -14,10 +14,13 @@ namespace DirectCommunication
DirectCommunicationClient::DirectCommunicationClient(ushort port, std::string ServerAddress):port_(port),serverAddress_(ServerAddress) DirectCommunicationClient::DirectCommunicationClient(ushort port, std::string ServerAddress):port_(port),serverAddress_(ServerAddress)
{ {
context_ = zmq::context_t(1); context_ = zmq::context_t();
socket_ = zmq::socket_t(context_,zmq::socket_type::client); socket_ = zmq::socket_t(context_,zmq::socket_type::client);
LOG_S(INFO)<< "tcp://"+serverAddress_+":"+std::to_string(port_);
socket_.connect("tcp://"+serverAddress_+":"+std::to_string(port_)); socket_.connect("tcp://"+serverAddress_+":"+std::to_string(port_));
isConnected = true;
socket_.set(zmq::sockopt::rcvtimeo,100); socket_.set(zmq::sockopt::rcvtimeo,100);
socket_.set(zmq::sockopt::sndtimeo,500); socket_.set(zmq::sockopt::sndtimeo,500);
@@ -31,6 +34,8 @@ namespace DirectCommunication
DirectCommunicationClient::~DirectCommunicationClient() DirectCommunicationClient::~DirectCommunicationClient()
{ {
sendMessage("CLOSE"); sendMessage("CLOSE");
isConnected = false;
stopWorker_ = true; stopWorker_ = true;
Worker_.join(); Worker_.join();