Merge pull request tkn-tub#28 from edalm/fix-zmq-deprecated-functions

Fix use of ZMQ's deprecated send() and recv() functions
rotcx · Jun 9, 2020 · 19bfe0a · 19bfe0a
2 parents 470362b + bdd4ccc
commit 19bfe0a
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/opengym/model/opengym_interface.cc b/src/opengym/model/opengym_interface.cc
@@ -150,7 +150,7 @@ OpenGymInterface::SetExecuteActionsCb(Callback<bool, Ptr<OpenGymDataContainer> >
   m_actionCb = cb;
 }
 
-void 
+void
 OpenGymInterface::Init()
 {
   NS_LOG_FUNCTION (this);
@@ -189,12 +189,12 @@ OpenGymInterface::Init()
   // send init msg to python
   zmq::message_t request(simInitMsg.ByteSize());;
   simInitMsg.SerializeToArray(request.data(), simInitMsg.ByteSize());
-  m_zmq_socket.send (request);
+  m_zmq_socket.send (request, zmq::send_flags::none);
 
   // receive init ack msg form python
   ns3opengym::SimInitAck simInitAck;
   zmq::message_t reply;
-  m_zmq_socket.recv (&reply);
+  (void) m_zmq_socket.recv (reply, zmq::recv_flags::none);
   simInitAck.ParseFromArray(reply.data(), reply.size());
 
   bool done = simInitAck.done();
@@ -256,12 +256,12 @@ OpenGymInterface::NotifyCurrentState()
   // send env state msg to python
   zmq::message_t request(envStateMsg.ByteSize());;
   envStateMsg.SerializeToArray(request.data(), envStateMsg.ByteSize());
-  m_zmq_socket.send (request);
+  m_zmq_socket.send (request, zmq::send_flags::none);
 
   // receive act msg form python
   ns3opengym::EnvActMsg envActMsg;
   zmq::message_t reply;
-  m_zmq_socket.recv (&reply);
+  (void) m_zmq_socket.recv (reply, zmq::recv_flags::none);
   envActMsg.ParseFromArray(reply.data(), reply.size());
 
   if (m_simEnd) {