Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
stay with double for payload size (fix 32bit issues?
authorSUTER Frederic <frederic.suter@cc.in2p3.fr>
Fri, 4 Feb 2022 09:25:03 +0000 (10:25 +0100)
committerSUTER Frederic <frederic.suter@cc.in2p3.fr>
Fri, 4 Feb 2022 09:25:30 +0000 (10:25 +0100)
src/kernel/actor/SimcallObserver.hpp
src/s4u/s4u_Comm.cpp

index a009e6b..633f7e3 100644 (file)
@@ -246,7 +246,7 @@ public:
 
 class CommIsendSimcall : public ResultingSimcall<activity::ActivityImplPtr> {
   activity::MailboxImpl* mbox_;
-  size_t payload_size_;
+  double payload_size_;
   double rate_;
   unsigned char* src_buff_;
   size_t src_buff_size_;
@@ -258,7 +258,7 @@ public:
   void (*clean_fun_)(void*); // used to free the synchro in case of problem after a detached send
   void (*copy_data_fun_)(activity::CommImpl*, void*, size_t); // used to copy data if not default one
 
-  CommIsendSimcall(ActorImpl* actor, activity::MailboxImpl* mbox, size_t payload_size, double rate,
+  CommIsendSimcall(ActorImpl* actor, activity::MailboxImpl* mbox, double payload_size, double rate,
                    unsigned char* src_buff, size_t src_buff_size, bool (*match_fun)(void*, void*, activity::CommImpl*),
                    void (*clean_fun)(void*), // used to free the synchro in case of problem after a detached send
                    void (*copy_data_fun)(activity::CommImpl*, void*, size_t), // used to copy data if not default one
@@ -288,7 +288,7 @@ public:
     return SimcallObserver::dot_label(times_considered) + "iSend";
   }
   activity::MailboxImpl* get_mailbox() const { return mbox_; }
-  size_t get_payload_size() const { return payload_size_; }
+  double get_payload_size() const { return payload_size_; }
   double get_rate() const { return rate_; }
   unsigned char* get_src_buff() const { return src_buff_; }
   size_t get_src_buff_size() const { return src_buff_size_; }
index 6ae30c0..c77b32a 100644 (file)
@@ -221,7 +221,7 @@ Comm* Comm::start()
     on_send(*this);
     kernel::actor::CommIsendSimcall observer{sender_,
                                              mailbox_->get_impl(),
-                                             static_cast<size_t>(remains_),
+                                             remains_,
                                              rate_,
                                              static_cast<unsigned char*>(src_buff_),
                                              src_buff_size_,