X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/17e66beb16f52e6ed5191e24b8220a2694805007..458ff11:/include/simgrid/s4u/comm.hpp diff --git a/include/simgrid/s4u/comm.hpp b/include/simgrid/s4u/comm.hpp index c9d615c8bf..47c7332c91 100644 --- a/include/simgrid/s4u/comm.hpp +++ b/include/simgrid/s4u/comm.hpp @@ -8,6 +8,7 @@ #define SIMGRID_S4U_COMM_HPP #include + #include #include #include @@ -22,34 +23,25 @@ namespace s4u { XBT_PUBLIC_CLASS Comm : public Activity { Comm() : Activity() {} public: - virtual ~Comm(); + ~Comm() override; public: - /** Creates (but don't start) an async send to the mailbox #dest */ - static Comm &send_init(Actor *sender, Mailbox &dest); - /** Creates and start an async send to the mailbox #dest */ - static Comm &send_async(s4u::Actor *sender, Mailbox &dest, void *data, int simulatedByteAmount); - /** 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(s4u::Actor *receiver, Mailbox &from, void **data); + /** Creates (but don't start) an async send to the mailbox @p dest */ + static Comm &send_init(Mailbox &dest); + /** Creates and start an async send to the mailbox @p dest */ + static Comm &send_async(Mailbox &dest, void *data, int simulatedByteAmount); + /** Creates (but don't start) an async recv onto the mailbox @p from */ + static Comm &recv_init(Mailbox &from); + /** Creates and start an async recv to the mailbox @p from */ + static Comm &recv_async(Mailbox &from, void **data); void start() override; void wait() override; void wait(double timeout) override; -private: - double rate_=-1; -public: /** Sets the maximal communication rate (in byte/sec). Must be done before start */ void setRate(double rate); -private: - void *dstBuff_ = NULL; - size_t dstBuffSize_ = 0; - void *srcBuff_ = NULL; - size_t srcBuffSize_ = sizeof(void*); -public: /** Specify the data to send */ void setSrcData(void * buff); /** Specify the size of the data to send */ @@ -65,16 +57,22 @@ public: size_t getDstDataSize(); -private: /* FIXME: expose these elements in the API */ +private: + double rate_ = -1; + void *dstBuff_ = nullptr; + size_t dstBuffSize_ = 0; + void *srcBuff_ = nullptr; + size_t srcBuffSize_ = sizeof(void*); + + /* FIXME: expose these elements in the API */ int detached_ = 0; - int (*matchFunction_)(void *, void *, smx_synchro_t) = NULL; - void (*cleanFunction_)(void *) = NULL; - void (*copyDataFunction_)(smx_synchro_t, void*, size_t) = NULL; + int (*matchFunction_)(void *, void *, smx_synchro_t) = nullptr; + void (*cleanFunction_)(void *) = nullptr; + void (*copyDataFunction_)(smx_synchro_t, void*, size_t) = nullptr; -private: - Actor *sender_ = NULL; - Actor *receiver_ = NULL; - Mailbox *mailbox_ = NULL; + smx_process_t sender_ = nullptr; + smx_process_t receiver_ = nullptr; + Mailbox *mailbox_ = nullptr; }; }} // namespace simgrid::s4u