X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4e4a69258bc6825a548dabc242d5caeaf82ac634..4c8b729ca205a05b34613dfe73d5f1b542c189f6:/include/simgrid/simix/blocking_simcall.hpp diff --git a/include/simgrid/simix/blocking_simcall.hpp b/include/simgrid/simix/blocking_simcall.hpp index a856eca0ee..ccfc8a1e5a 100644 --- a/include/simgrid/simix/blocking_simcall.hpp +++ b/include/simgrid/simix/blocking_simcall.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2016-2017. The SimGrid Team. +/* Copyright (c) 2016-2018. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -19,12 +19,12 @@ #include #include -XBT_PUBLIC(void) simcall_run_blocking(std::function const& code); +XBT_PUBLIC void simcall_run_blocking(std::function const& code); namespace simgrid { namespace simix { -XBT_PUBLIC(void) unblock(smx_actor_t process); +XBT_PUBLIC void unblock(smx_actor_t process); /** Execute some code in kernel mode and wakes up the actor when * the result is available. @@ -59,8 +59,8 @@ auto kernelSync(F code) -> decltype(code().get()) simcall_run_blocking([&result, self, &code]{ try { auto future = code(); - future.then_([&result, self](simgrid::kernel::Future value) { - simgrid::xbt::setPromise(result, value); + future.then_([&result, self](std::shared_ptr>&& value) { + simgrid::xbt::setPromise(result, simgrid::kernel::Future(value)); simgrid::simix::unblock(self); }); } @@ -94,9 +94,9 @@ public: simcall_run_blocking([this, &result, self]{ try { // When the kernel future is ready... - this->future_.then_([&result, self](simgrid::kernel::Future value) { + this->future_.then_([&result, self](std::shared_ptr>&& value) { // ... wake up the process with the result of the kernel future. - simgrid::xbt::setPromise(result, value); + simgrid::xbt::setPromise(result, simgrid::kernel::Future(value)); simgrid::simix::unblock(self); }); } @@ -124,9 +124,9 @@ public: simcall_run_blocking([this, &exception, self]{ try { // When the kernel future is ready... - this->future_.then_([this, self](simgrid::kernel::Future value) { + this->future_.then_([this, self](std::shared_ptr>&& value) { // ...store it the simix kernel and wake up. - this->future_ = std::move(value); + this->future_ = std::move(simgrid::kernel::Future(value)); simgrid::simix::unblock(self); }); }