From a96f7edb18f2feb5d94d7d1b6024c381d21bb559 Mon Sep 17 00:00:00 2001 From: Arnaud Giersch Date: Fri, 18 Dec 2020 10:15:52 +0100 Subject: [PATCH] No need for specialization. --- include/simgrid/s4u/Mailbox.hpp | 31 +++++++++++++++++++++++++------ src/s4u/s4u_Mailbox.cpp | 28 ---------------------------- 2 files changed, 25 insertions(+), 34 deletions(-) diff --git a/include/simgrid/s4u/Mailbox.hpp b/include/simgrid/s4u/Mailbox.hpp index aac352a533..6837914c36 100644 --- a/include/simgrid/s4u/Mailbox.hpp +++ b/include/simgrid/s4u/Mailbox.hpp @@ -8,6 +8,7 @@ #include #include +#include #include #include @@ -96,22 +97,40 @@ public: 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) { return get_async(reinterpret_cast(data)); } + template CommPtr get_async(T** data); /** Blocking data reception */ - template T* get() { return static_cast(get()); } + 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) { return static_cast(get(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)); } }; -template <> XBT_PUBLIC CommPtr Mailbox::get_async(void** data); -template <> XBT_PUBLIC void* Mailbox::get(); -template <> XBT_PUBLIC void* Mailbox::get(double timeout); +template CommPtr Mailbox::get_async(T** data) +{ + CommPtr res = get_init(); + res->set_dst_data(reinterpret_cast(data), sizeof(void*)); + res->vetoable_start(); + return res; +} + +template T* Mailbox::get() +{ + T* res = nullptr; + get_async(&res)->wait(); + return res; +} + +template T* Mailbox::get(double timeout) +{ + T* res = nullptr; + get_async(&res)->wait_for(timeout); + return res; +} inline CommPtr Mailbox::get_async(void** data) // XBT_ATTRIB_DEPRECATED_v331 { diff --git a/src/s4u/s4u_Mailbox.cpp b/src/s4u/s4u_Mailbox.cpp index 83b8d72242..1dd3ffd902 100644 --- a/src/s4u/s4u_Mailbox.cpp +++ b/src/s4u/s4u_Mailbox.cpp @@ -138,34 +138,6 @@ CommPtr Mailbox::get_init() return res; } -template <> CommPtr Mailbox::get_async(void** data) -{ - CommPtr res = get_init(); - res->set_dst_data(data, sizeof(*data)); - res->vetoable_start(); - return res; -} - -template <> void* Mailbox::get() -{ - void* res = nullptr; - CommPtr c = get_init(); - c->set_dst_data(&res, sizeof(res)); - c->vetoable_start(); - c->wait(); - return res; -} - -template <> void* Mailbox::get(double timeout) -{ - void* res = nullptr; - CommPtr c = get_init(); - c->set_dst_data(&res, sizeof(res)); - c->vetoable_start(); - c->wait_for(timeout); - return res; -} - kernel::activity::ActivityImplPtr Mailbox::iprobe(int type, bool (*match_fun)(void*, void*, kernel::activity::CommImpl*), void* data) { -- 2.20.1