X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a96f7edb18f2feb5d94d7d1b6024c381d21bb559..7d195832dafde68afd749dd614e9a14d697bdb92:/include/simgrid/s4u/Mailbox.hpp diff --git a/include/simgrid/s4u/Mailbox.hpp b/include/simgrid/s4u/Mailbox.hpp index 6837914c36..9687ef9ea9 100644 --- a/include/simgrid/s4u/Mailbox.hpp +++ b/include/simgrid/s4u/Mailbox.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2021. 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. */ @@ -20,9 +20,11 @@ namespace s4u { /** @brief Mailboxes: Network rendez-vous points. */ class XBT_PUBLIC Mailbox { +#ifndef DOXYGEN friend Comm; friend smpi::Request; friend kernel::activity::MailboxImpl; +#endif kernel::activity::MailboxImpl* const pimpl_; @@ -44,6 +46,9 @@ public: /** Returns whether the mailbox contains queued communications */ bool empty() const; + /* Returns the number of queued communications */ + size_t size() const; + /** Check if there is a communication going on in a mailbox. */ bool listen() const; @@ -81,14 +86,26 @@ public: /** Creates (but don't start) a data transmission to that mailbox */ CommPtr put_init(); - /** Creates (but don't start) a data transmission to that mailbox */ + /** Creates (but don't start) a data transmission to that mailbox. + * + * Please note that if you send a pointer to some data, you must ensure that your data remains live during the + * communication, or the receiver will get a pointer to a garbled memory area. + */ CommPtr put_init(void* data, uint64_t simulated_size_in_bytes); - /** Creates and start a data transmission to that mailbox */ + /** Creates and start a data transmission to that mailbox. + * + * Please note that if you send a pointer to some data, you must ensure that your data remains live during the + * communication, or the receiver will get a pointer to a garbled memory area. + */ CommPtr put_async(void* data, uint64_t simulated_size_in_bytes); kernel::activity::ActivityImplPtr iprobe(int type, bool (*match_fun)(void*, void*, kernel::activity::CommImpl*), void* data); - /** Blocking data transmission */ + /** Blocking data transmission. + * + * Please note that if you send a pointer to some data, you must ensure that your data remains live during the + * communication, or the receiver will get a pointer to a garbled memory area. + */ void put(void* payload, uint64_t simulated_size_in_bytes); /** Blocking data transmission with timeout */ void put(void* payload, uint64_t simulated_size_in_bytes, double timeout); @@ -96,24 +113,26 @@ public: /** Creates (but don't start) a data reception onto that mailbox */ CommPtr get_init(); /** Creates and start an async data reception to that mailbox */ - XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get_async<>()") CommPtr get_async(void** data); template CommPtr get_async(T** data); /** Blocking data reception */ template T* get(); - XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get<>()") void* get(); template std::unique_ptr get_unique() { return std::unique_ptr(get()); } /** Blocking data reception with timeout */ template T* get(double timeout); - XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get<>()") void* get(double timeout); template std::unique_ptr get_unique(double timeout) { return std::unique_ptr(get(timeout)); } + +#ifndef DOXYGEN + XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get_async<>()") CommPtr get_async(void** data); + XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get<>()") void* get(); + XBT_ATTRIB_DEPRECATED_v331("Please use typed template Mailbox::get<>()") void* get(double timeout); +#endif }; template CommPtr Mailbox::get_async(T** data) { - CommPtr res = get_init(); - res->set_dst_data(reinterpret_cast(data), sizeof(void*)); + CommPtr res = get_init()->set_dst_data(reinterpret_cast(data), sizeof(void*)); res->vetoable_start(); return res; } @@ -132,6 +151,7 @@ template T* Mailbox::get(double timeout) return res; } +#ifndef DOXYGEN inline CommPtr Mailbox::get_async(void** data) // XBT_ATTRIB_DEPRECATED_v331 { return get_async(data); @@ -144,7 +164,7 @@ inline void* Mailbox::get(double timeout) // XBT_ATTRIB_DEPRECATED_v331 { return get(timeout); } - +#endif } // namespace s4u } // namespace simgrid