X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6260d187764dc644d699e1a53454f7efdcc682df..cfb3987654b857620ba388fab9883a095debeb72:/src/kernel/activity/CommImpl.hpp diff --git a/src/kernel/activity/CommImpl.hpp b/src/kernel/activity/CommImpl.hpp index 340a19d2ff..f3d98399ca 100644 --- a/src/kernel/activity/CommImpl.hpp +++ b/src/kernel/activity/CommImpl.hpp @@ -32,8 +32,11 @@ class XBT_PUBLIC CommImpl : public ActivityImpl_T { s4u::Host* to_ = nullptr; /* Otherwise, computed at start() time from the actors */ CommImplType type_ = CommImplType::SEND; /* Type of the communication (SEND or RECEIVE) */ + static unsigned next_id_; // Next ID to be given (for MC) + const unsigned id_ = ++next_id_; // ID of this comm (for MC) -- 0 as an ID denotes "invalid/unknown comm" + public: - CommImpl() = default; + CommImpl(); static void set_copy_data_callback(const std::function& callback); @@ -52,7 +55,8 @@ public: double get_rate() const { return rate_; } MailboxImpl* get_mailbox() const { return mbox_; } - long get_mailbox_id() const { return mbox_id_; } + unsigned get_mailbox_id() const { return mbox_id_; } + unsigned get_id() const { return id_; } bool is_detached() const { return detached_; } bool is_assigned() const { return (to_ != nullptr && from_ != nullptr); } @@ -79,6 +83,9 @@ looking if a given communication matches my needs. For that, myself must match t expectations of the other side, too. See */ std::function copy_data_fun; + /* In stateful MC, we need to ignore some private memory that is not relevant to the application state */ + static void setup_mc(); + /* Model actions */ timeout_action_type src_timeout_{nullptr, [](resource::Action* a) { a->unref(); }}; /* timeout set by the sender */ timeout_action_type dst_timeout_{nullptr, [](resource::Action* a) { a->unref(); }}; /* timeout set by the receiver */ @@ -91,6 +98,7 @@ expectations of the other side, too. See */ unsigned char* dst_buff_ = nullptr; size_t src_buff_size_ = 0; size_t* dst_buff_size_ = nullptr; + void* payload_ = nullptr; // If dst_buff_ is NULL, the default copy callback puts the data here void* src_data_ = nullptr; /* User data associated to the communication */ void* dst_data_ = nullptr;