X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a6c6d47c34f60557c93aa6f5f209e4b66528c3f1..4f2e9b5f5dd58b3493e5ce66014e52c76f68a777:/include/xbt/future.hpp diff --git a/include/xbt/future.hpp b/include/xbt/future.hpp index a7448c9525..521b02ba94 100644 --- a/include/xbt/future.hpp +++ b/include/xbt/future.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2015-2017. The SimGrid Team. +/* Copyright (c) 2015-2018. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -48,7 +48,7 @@ public: switch (that.status_) { case ResultStatus::invalid: break; - case ResultStatus::valid: + case ResultStatus::value: new (&value_) T(that.value); break; case ResultStatus::exception: @@ -69,7 +69,7 @@ public: switch (that.status_) { case ResultStatus::invalid: break; - case ResultStatus::valid: + case ResultStatus::value: new (&value_) T(std::move(that.value)); that.value.~T(); break; @@ -134,7 +134,7 @@ public: T value = std::move(value_); value_.~T(); status_ = ResultStatus::invalid; - return std::move(value); + return value; } case ResultStatus::exception: { std::exception_ptr exception = std::move(exception_); @@ -199,9 +199,17 @@ public: * @param code What we want to do * @param promise Where to want to store the result */ -template -auto fulfillPromise(R& promise, F&& code) --> decltype(promise.set_value(code())) +template auto fulfill_promise(R& promise, F&& code) -> decltype(promise.set_value(code())) +{ + try { + promise.set_value(std::forward(code)()); + } catch (...) { + promise.set_exception(std::current_exception()); + } +} +template +XBT_ATTRIB_DEPRECATED_v323("Please use xbt::fulfill_promise()") auto fulfillPromise(R& promise, F&& code) + -> decltype(promise.set_value(code())) { try { promise.set_value(std::forward(code)()); @@ -211,9 +219,18 @@ auto fulfillPromise(R& promise, F&& code) } } -template -auto fulfillPromise(P& promise, F&& code) --> decltype(promise.set_value()) +template auto fulfill_promise(P& promise, F&& code) -> decltype(promise.set_value()) +{ + try { + std::forward(code)(); + promise.set_value(); + } catch (...) { + promise.set_exception(std::current_exception()); + } +} +template +XBT_ATTRIB_DEPRECATED_v323("Please use xbt::fulfill_promise()") auto fulfillPromise(P& promise, F&& code) + -> decltype(promise.set_value()) { try { std::forward(code)(); @@ -238,10 +255,14 @@ auto fulfillPromise(P& promise, F&& code) * @param promise output (a valid future or a result) * @param future input (a ready/waitable future or a valid result) */ -template inline -void setPromise(P& promise, F&& future) +template inline void set_promise(P& promise, F&& future) +{ + fulfill_promise(promise, [&] { return std::forward(future).get(); }); +} +template +inline XBT_ATTRIB_DEPRECATED_v323("Please use xbt::set_promise()") void setPromise(P& promise, F&& future) { - fulfillPromise(promise, [&]{ return std::forward(future).get(); }); + fulfill_promise(promise, [&] { return std::forward(future).get(); }); } }