Made it all compile with Batsched

Removed ZMQ deprecation warnings
wrench-project · Oct 6, 2023 · 2a8b7ac · 2a8b7ac
1 parent 43a464d
commit 2a8b7ac
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/wrench/services/compute/batch/BatschedNetworkListener.cpp b/src/wrench/services/compute/batch/BatschedNetworkListener.cpp
@@ -137,7 +137,8 @@ namespace wrench {
         useconds_t trials;
         for (trials = 0; trials < max_num_trials; trials++) {
             usleep(100 + 100 * trials * trials);
-            int ret = socket.recv(&reply, ZMQ_DONTWAIT);
+//            int ret = socket.recv(&reply, ZMQ_DONTWAIT);
+            zmq::recv_result_t ret = socket.recv(reply, zmq::recv_flags::dontwait);
             if (ret > 0) {
                 break;
             }

diff --git a/src/wrench/services/compute/batch/batch_schedulers/batsched/BatschedBatchScheduler.cpp b/src/wrench/services/compute/batch/batch_schedulers/batsched/BatschedBatchScheduler.cpp
@@ -290,7 +290,7 @@ namespace wrench {
 
         //  Get the reply.
         zmq::message_t reply;
-        socket.recv(&reply);
+        auto ret = socket.recv(reply, zmq::recv_flags::none);
 
         // Process the reply
         std::string reply_data;