X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a5c102f3397e8112b97c27981bfdbcaac76d79f6..8a94013d0abeeb5824c06070251b4d0760ed6b43:/src/simix/libsmx.cpp diff --git a/src/simix/libsmx.cpp b/src/simix/libsmx.cpp index df3df95899..b44eb2d597 100644 --- a/src/simix/libsmx.cpp +++ b/src/simix/libsmx.cpp @@ -21,8 +21,6 @@ #include "src/mc/mc_replay.hpp" #include "src/plugins/vm/VirtualMachineImpl.hpp" -XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix); - #include "popping_bodies.cpp" /** @@ -36,9 +34,9 @@ e_smx_state_t simcall_execution_wait(const smx_activity_t& execution) return (e_smx_state_t)simcall_BODY_execution_wait(static_cast(execution.get())); } -e_smx_state_t simcall_execution_test(const smx_activity_t& execution) +bool simcall_execution_test(const smx_activity_t& execution) { - return (e_smx_state_t)simcall_BODY_execution_test(static_cast(execution.get())); + return simcall_BODY_execution_test(static_cast(execution.get())); } void simcall_process_join(smx_actor_t process, double timeout) @@ -110,7 +108,7 @@ smx_activity_t simcall_comm_isend(smx_actor_t sender, smx_mailbox_t mbox, double int (*match_fun)(void*, void*, simgrid::kernel::activity::CommImpl*), void (*clean_fun)(void*), void (*copy_data_fun)(simgrid::kernel::activity::CommImpl*, void*, size_t), - void* data, int detached) + void* data, bool detached) { /* checking for infinite values */ xbt_assert(std::isfinite(task_size), "task_size is not finite!"); @@ -223,7 +221,7 @@ void simcall_comm_wait(const smx_activity_t& comm, double timeout) * @ingroup simix_comm_management * */ -int simcall_comm_test(const smx_activity_t& comm) +bool simcall_comm_test(const smx_activity_t& comm) { return simcall_BODY_comm_test(static_cast(comm.get())); } @@ -384,11 +382,16 @@ smx_activity_t simcall_execution_start(const std::string& name, const std::strin double priority, double bound, sg_host_t host) { return simgrid::simix::simcall([name, category, flops_amount, priority, bound, host] { - return simgrid::kernel::activity::ExecImplPtr(new simgrid::kernel::activity::ExecImpl()) - ->set_name(name) - ->set_tracing_category(category) - ->set_host(host) - ->start(flops_amount, priority, bound); + simgrid::kernel::activity::ExecImpl* exec = new simgrid::kernel::activity::ExecImpl(); + (*exec) + .set_name(name) + .set_tracing_category(category) + .set_host(host) + .set_priority(priority) + .set_bound(bound) + .set_flops_amount(flops_amount) + .start(); + return simgrid::kernel::activity::ExecImplPtr(exec); }); } @@ -425,10 +428,15 @@ smx_activity_t simcall_execution_parallel_start(const std::string& name, int hos if (bytes_amount != nullptr) bytes_parallel_amount = std::vector(bytes_amount, bytes_amount + host_nb * host_nb); return simgrid::simix::simcall([name, hosts, flops_parallel_amount, bytes_parallel_amount, timeout] { - return simgrid::kernel::activity::ExecImplPtr(new simgrid::kernel::activity::ExecImpl()) - ->set_name(name) - ->set_timeout(timeout) - ->start(hosts, flops_parallel_amount, bytes_parallel_amount); + simgrid::kernel::activity::ExecImpl* exec = new simgrid::kernel::activity::ExecImpl(); + (*exec) + .set_name(name) + .set_hosts(hosts) + .set_timeout(timeout) + .set_flops_amounts(flops_parallel_amount) + .set_bytes_amounts(bytes_parallel_amount) + .start(); + return simgrid::kernel::activity::ExecImplPtr(exec); }); }