X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0e51c90b78469c7c2067935ef62bf9474d09891d..cf75523de37862d1f4eddaa1cbdd276f20755fea:/include/simgrid/s4u/comm.hpp diff --git a/include/simgrid/s4u/comm.hpp b/include/simgrid/s4u/comm.hpp index be969c2a6d..2929750de8 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 */ + /** 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 #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 #from */ + /** 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 #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 */ @@ -64,17 +56,25 @@ public: /** Retrieve the size of the received data */ size_t getDstDataSize(); + bool test(); -private: /* 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; private: - smx_process_t sender_ = NULL; - smx_process_t receiver_ = NULL; - Mailbox *mailbox_ = NULL; + 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) = nullptr; + void (*cleanFunction_)(void *) = nullptr; + void (*copyDataFunction_)(smx_synchro_t, void*, size_t) = nullptr; + + smx_process_t sender_ = nullptr; + smx_process_t receiver_ = nullptr; + Mailbox *mailbox_ = nullptr; }; }} // namespace simgrid::s4u