Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Rename method for consistency.
authorArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Wed, 2 Mar 2022 22:06:48 +0000 (23:06 +0100)
committerArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Wed, 2 Mar 2022 22:07:06 +0000 (23:07 +0100)
src/kernel/activity/CommImpl.hpp
src/kernel/activity/MailboxImpl.cpp
src/s4u/s4u_Comm.cpp
src/smpi/internals/smpi_global.cpp

index ad9f4ab..723b090 100644 (file)
@@ -54,7 +54,7 @@ public:
   double get_rate() const { return rate_; }
   MailboxImpl* get_mailbox() const { return mbox_; }
   long get_mailbox_id() const { return mbox_id_; }
-  bool detached() const { return detached_; }
+  bool is_detached() const { return detached_; }
   bool is_assigned() const { return (to_ != nullptr && from_ != nullptr); }
 
   std::vector<s4u::Link*> get_traversed_links() const;
index 3cb2e1c..4b8a307 100644 (file)
@@ -80,7 +80,7 @@ void MailboxImpl::clear()
   // CommImpl::cancel() will remove the comm from the mailbox..
   while (not comm_queue_.empty()) {
     auto comm = comm_queue_.back();
-    if (comm->get_state() == State::WAITING && not comm->detached()) {
+    if (comm->get_state() == State::WAITING && not comm->is_detached()) {
       comm->cancel();
       comm->set_state(State::DST_HOST_FAILURE);
     } else
index cff5e62..2d2ed31 100644 (file)
@@ -34,8 +34,8 @@ void Comm::copy_buffer_callback(kernel::activity::CommImpl* comm, void* buff, si
 {
   XBT_DEBUG("Copy the data over");
   memcpy(comm->dst_buff_, buff, buff_size);
-  if (comm->detached()) { // if this is a detached send, the source buffer was duplicated by SMPI sender to make the
-                          // original buffer available to the application ASAP
+  if (comm->is_detached()) { // if this is a detached send, the source buffer was duplicated by SMPI sender to make the
+                             // original buffer available to the application ASAP
     xbt_free(buff);
     comm->src_buff_ = nullptr;
   }
index b8297e4..681c183 100644 (file)
@@ -149,7 +149,7 @@ static void check_blocks(const std::vector<std::pair<size_t, size_t>>& private_b
 }
 
 static void smpi_cleanup_comm_after_copy(simgrid::kernel::activity::CommImpl* comm, void* buff){
-  if (comm->detached()) {
+  if (comm->is_detached()) {
     // if this is a detached send, the source buffer was duplicated by SMPI
     // sender to make the original buffer available to the application ASAP
     xbt_free(buff);