implement s4u::Comm::recv_async()

diff --git a/include/simgrid/s4u/comm.hpp b/include/simgrid/s4u/comm.hpp
index bf0f7cb..94b74cb 100644 (file)
--- a/include/simgrid/s4u/comm.hpp
+++ b/include/simgrid/s4u/comm.hpp
@@ -32,7 +32,7 @@ public:
     /** Creates (but don't start) an async recv onto the mailbox #from */
        static Comm &recv_init(s4u::Actor *receiver, Mailbox &from);
        /** Creates and start an async recv to the mailbox #from */
-       //static Comm &recv_async(Mailbox &from, void *data);
+       static Comm &recv_async(s4u::Actor *receiver, Mailbox &from, void **data);
 
        void start() override;
        void wait() override;

diff --git a/src/s4u/s4u_actor.cpp b/src/s4u/s4u_actor.cpp
index 8a5dd1c..7d3be59 100644 (file)
--- a/src/s4u/s4u_actor.cpp
+++ b/src/s4u/s4u_actor.cpp
@@ -102,6 +102,7 @@ void s4u::Actor::send(Mailbox &chan, void *payload, size_t simulatedSize) {
        Comm c = Comm::send_init(this,chan);
        c.setRemains(simulatedSize);
        c.setSrcData(payload);
+       // c.start() is optional.
        c.wait();
 }
 

diff --git a/src/s4u/s4u_comm.cpp b/src/s4u/s4u_comm.cpp
index e24b4ec..02f5e98 100644 (file)
--- a/src/s4u/s4u_comm.cpp
+++ b/src/s4u/s4u_comm.cpp
@@ -141,3 +141,12 @@ s4u::Comm &s4u::Comm::send_async(s4u::Actor *sender, Mailbox &dest, void *data,
        return res;
 }
 
+s4u::Comm &s4u::Comm::recv_async(s4u::Actor *receiver, Mailbox &dest, void **data) {
+       s4u::Comm &res = s4u::Comm::recv_init(receiver, dest);
+
+       res.setDstData(data);
+
+       res.start();
+       return res;
+}
+