src/s4u/s4u_Exec.cpp

   1 /* Copyright (c) 2006-2018. The SimGrid Team. All rights reserved.          */
   2
   3 /* This program is free software; you can redistribute it and/or modify it
   4  * under the terms of the license (GNU LGPL) which comes with this package. */
   5 #include "xbt/log.h"
   6
   7 #include "simgrid/s4u/Actor.hpp"
   8 #include "simgrid/s4u/Exec.hpp"
   9 #include "src/kernel/activity/ExecImpl.hpp"
  10
  11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_exec, s4u_activity, "S4U asynchronous executions");
  12
  13 namespace simgrid {
  14 namespace s4u {
  15
  16 Activity* Exec::start()
  17 {
  18   pimpl_ = simcall_execution_start(nullptr, flops_amount_, 1 / priority_, 0., host_);
  19   boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->setBound(bound_);
  20   state_ = State::started;
  21   return this;
  22 }
  23
  24 Activity* Exec::wait()
  25 {
  26   simcall_execution_wait(pimpl_);
  27   state_ = State::finished;
  28   return this;
  29 }
  30
  31 Activity* Exec::wait(double timeout)
  32 {
  33   THROW_UNIMPLEMENTED;
  34   return this;
  35 }
  36
  37 bool Exec::test()
  38 {
  39   xbt_assert(state_ == State::inited || state_ == State::started || state_ == State::finished);
  40
  41   if (state_ == State::finished)
  42     return true;
  43
  44   if (state_ == State::inited)
  45     this->start();
  46
  47   if (simcall_execution_test(pimpl_)) {
  48     state_ = State::finished;
  49     return true;
  50   }
  51
  52   return false;
  53 }
  54
  55 ExecPtr Exec::setPriority(double priority)
  56 {
  57   xbt_assert(state_ == State::inited, "Cannot change the priority of an exec after its start");
  58   priority_ = priority;
  59   return this;
  60 }
  61
  62 ExecPtr Exec::setBound(double bound)
  63 {
  64   xbt_assert(state_ == State::inited, "Cannot change the bound of an exec after its start");
  65   bound_ = bound;
  66   return this;
  67 }
  68
  69 ExecPtr Exec::setHost(Host* host)
  70 {
  71   xbt_assert(state_ == State::inited || state_ == State::started,
  72              "Cannot change the host of an exec once it's done (state: %d)", (int)state_);
  73   if (state_ == State::started)
  74     boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->migrate(host);
  75   host_ = host;
  76   return this;
  77 }
  78
  79 double Exec::get_remaining()
  80 {
  81   return simgrid::simix::kernelImmediate(
  82       [this]() { return boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->remains(); });
  83 }
  84 double Exec::getRemainingRatio()
  85 {
  86   return simgrid::simix::kernelImmediate(
  87       [this]() { return boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->remainingRatio(); });
  88 }
  89
  90 void intrusive_ptr_release(simgrid::s4u::Exec* e)
  91 {
  92   if (e->refcount_.fetch_sub(1, std::memory_order_release) == 1) {
  93     std::atomic_thread_fence(std::memory_order_acquire);
  94     delete e;
  95   }
  96 }
  97
  98 void intrusive_ptr_add_ref(simgrid::s4u::Exec* e)
  99 {
 100   e->refcount_.fetch_add(1, std::memory_order_relaxed);
 101 }
 102 } // namespace s4u
 103 } // namespace simgrid