Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge branch 'doc_link' into 'master'
authorArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Wed, 28 Jul 2021 12:48:24 +0000 (12:48 +0000)
committerArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Wed, 28 Jul 2021 12:48:24 +0000 (12:48 +0000)
Fix broken link to releases in doc

See merge request simgrid/simgrid!68

include/simgrid/plugins/ProducerConsumer.hpp
src/s4u/s4u_Comm.cpp

index f446dac..02c54da 100644 (file)
@@ -9,6 +9,7 @@
 #include <simgrid/s4u/ConditionVariable.hpp>
 #include <simgrid/s4u/Mailbox.hpp>
 #include <simgrid/s4u/Mutex.hpp>
+#include <simgrid/simix.h>
 #include <xbt/asserts.h>
 #include <xbt/log.h>
 
@@ -145,7 +146,9 @@ public:
     while (size() >= max_queue_size_)
       can_put_->wait(lock);
     if (tmode_ == TransferMode::MAILBOX) {
-      comm = mbox_->put_async(data, simulated_size_in_bytes);
+      comm = mbox_->put_init(data, simulated_size_in_bytes)
+                 ->set_copy_data_callback(SIMIX_comm_copy_pointer_callback)
+                 ->start();
     } else
       queue_.push(data);
     can_get_->notify_all();
@@ -180,7 +183,10 @@ public:
     while (empty())
       can_get_->wait(lock);
     if (tmode_ == TransferMode::MAILBOX)
-      comm = mbox_->get_async<T>(data);
+      comm = mbox_->get_init()
+                 ->set_dst_data(reinterpret_cast<void**>(data), sizeof(void*))
+                 ->set_copy_data_callback(SIMIX_comm_copy_pointer_callback)
+                 ->start();
     else {
       *data = queue_.front();
       queue_.pop();
index 36b5702..bcf557d 100644 (file)
@@ -299,11 +299,7 @@ Actor* Comm::get_sender() const
 
 CommPtr Comm::set_copy_data_callback(void (*callback)(kernel::activity::CommImpl*, void*, size_t))
 {
-  static void (*saved_callback)(kernel::activity::CommImpl*, void*, size_t);
-  saved_callback      = callback;
-  copy_data_function_ = [](simgrid::kernel::activity::CommImpl* comm, void* buff, size_t size) {
-    saved_callback(comm, buff, size);
-  };
+  copy_data_function_ = callback;
   return this;
 }