X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1bf8ac043266839571c3a5fa789557fff825db5a..c67615c315f42bc56b88034eb591007c23e26667:/include/simgrid/s4u/Mailbox.hpp diff --git a/include/simgrid/s4u/Mailbox.hpp b/include/simgrid/s4u/Mailbox.hpp index 9d52198b07..3ca34595a0 100644 --- a/include/simgrid/s4u/Mailbox.hpp +++ b/include/simgrid/s4u/Mailbox.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2015. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2017. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -9,6 +9,7 @@ #include #include +#include #include #include @@ -26,7 +27,7 @@ namespace s4u { * Rendez-vous point for network communications, similar to URLs on * which you could post and retrieve data. Actually, the mailboxes are * not involved in the communication once it starts, but only to find - * the contact with which you want to communicate. + * the contact with which you want to communicate. * Here are some mechanisms similar to the mailbox in other * communication systems: The phone number, which allows the caller to @@ -93,8 +94,8 @@ namespace s4u { * starts to flow as soon as the sender posts it, even if the receiver * did not post its recv() yet. This can obviously lead to bad * simulation timings, as the simulated communications do not start at - * the exact same time than the real ones. - * + * the exact same time than the real ones. + * * If the simulation timings are very important to you, you can * declare a specific receiver to a given mailbox (with the function * setReceiver()). That way, any send() posted to that mailbox will @@ -120,8 +121,10 @@ public: /** private function, do not use. FIXME: make me protected */ kernel::activity::MailboxImpl* getImpl() { return pimpl_; } - /** Gets the name of that mailbox */ - const char *name(); + /** @brief Retrieves the name of that mailbox as a C++ string */ + const simgrid::xbt::string& getName() const; + /** @brief Retrieves the name of that mailbox as a C string */ + const char* getCname() const; /** Retrieve the mailbox associated to the given C string */ static MailboxPtr byName(const char *name); @@ -132,6 +135,9 @@ public: /** Returns whether the mailbox contains queued communications */ bool empty(); + /** Check if there is a communication going on in a mailbox. */ + bool listen(); + /** Gets the first element in the queue (without dequeuing it), or nullptr if none is there */ smx_activity_t front(); @@ -144,7 +150,29 @@ public: void setReceiver(ActorPtr actor); /** Return the actor declared as permanent receiver, or nullptr if none **/ - ActorPtr receiver(); + ActorPtr getReceiver(); + + /** Creates (but don't start) a data emission to that mailbox */ + CommPtr put_init(); + /** Creates (but don't start) a data emission to that mailbox */ + CommPtr put_init(void* data, uint64_t simulatedSizeInBytes); + /** Creates and start a data emission to that mailbox */ + CommPtr put_async(void* data, uint64_t simulatedSizeInBytes); + + /** Blocking data emission */ + void put(void* payload, uint64_t simulatedSizeInBytes); + /** Blocking data emission with timeout */ + void put(void* payload, uint64_t simulatedSizeInBytes, double timeout); + + /** Creates (but don't start) a data reception onto that mailbox */ + CommPtr get_init(); + /** Creates and start an async data reception to that mailbox */ + CommPtr get_async(void** data); + + /** Blocking data reception */ + void* get(); + /** Blocking data reception with timeout */ + void* get(double timeout); }; }} // namespace simgrid::s4u