X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3a3c36e5310194dd4a519f115eaf377a044c20dd..16bbb8a8212497d9c44c81333ed2c0e689e0c5af:/include/simgrid/s4u/comm.hpp diff --git a/include/simgrid/s4u/comm.hpp b/include/simgrid/s4u/comm.hpp index c2d3a59e17..ded149660e 100644 --- a/include/simgrid/s4u/comm.hpp +++ b/include/simgrid/s4u/comm.hpp @@ -7,76 +7,74 @@ #ifndef SIMGRID_S4U_COMM_HPP #define SIMGRID_S4U_COMM_HPP -#include "simgrid/s4u/async.hpp" -#include "simgrid/s4u/mailbox.hpp" +#include +#include +#include +#include namespace simgrid { namespace s4u { -class Mailbox; - /** @brief Communication async * * Represents all asynchronous communications, that you can test or wait onto. */ -class Comm : public Async { - Comm() : Async() {} +XBT_PUBLIC_CLASS Comm : public Async { + Comm() : Async() {} public: - virtual ~Comm(); + virtual ~Comm(); 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 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(Mailbox &from); - /** Creates and start an async recv to the mailbox #from */ - //static Comm &recv_async(Mailbox &from, void *data); + 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); - void start() override; - void wait() override; - void wait(double timeout) override; + void start() override; + void wait() override; + void wait(double timeout) override; private: - double p_rate=-1; + double p_rate=-1; public: - /** Sets the maximal communication rate (in byte/sec). Must be done before start */ - void setRate(double rate); + /** Sets the maximal communication rate (in byte/sec). Must be done before start */ + void setRate(double rate); private: - void *p_dstBuff = NULL; - size_t p_dstBuffSize = 0; - void *p_srcBuff = NULL; - size_t p_srcBuffSize = sizeof(void*); + void *p_dstBuff = NULL; + size_t p_dstBuffSize = 0; + void *p_srcBuff = NULL; + size_t p_srcBuffSize = sizeof(void*); public: - /** Specify the data to send */ - void setSrcData(void * buff); - /** Specify the size of the data to send */ - void setSrcDataSize(size_t size); - /** Specify the data to send and its size */ - void setSrcData(void * buff, size_t size); + /** Specify the data to send */ + void setSrcData(void * buff); + /** Specify the size of the data to send */ + void setSrcDataSize(size_t size); + /** Specify the data to send and its size */ + void setSrcData(void * buff, size_t size); - /** Specify where to receive the data */ - void setDstData(void ** buff); - /** Specify the buffer in which the data should be received */ - void setDstData(void ** buff, size_t size); - /** Retrieve the size of the received data */ - size_t getDstDataSize(); + /** Specify where to receive the data */ + void setDstData(void ** buff); + /** Specify the buffer in which the data should be received */ + void setDstData(void ** buff, size_t size); + /** Retrieve the size of the received data */ + size_t getDstDataSize(); private: /* FIXME: expose these elements in the API */ - int p_detached = 0; + int p_detached = 0; int (*p_matchFunction)(void *, void *, smx_synchro_t) = NULL; void (*p_cleanFunction)(void *) = NULL; void (*p_copyDataFunction)(smx_synchro_t, void*, size_t) = NULL; - - - private: - Actor *p_sender = NULL; - Mailbox *p_mailbox = NULL; + Actor *p_sender = NULL; + Actor *p_receiver = NULL; + Mailbox *p_mailbox = NULL; }; }} // namespace simgrid::s4u