src/s4u/s4u_exec.cpp

   1 /* Copyright (c) 2006-2017. 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_ = started;
  21   return this;
  22 }
  23
  24 Activity* Exec::wait()
  25 {
  26   simcall_execution_wait(pimpl_);
  27   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_ == inited || state_ == started || state_ == finished);
  40
  41   if (state_ == finished) {
  42     return true;
  43   }
  44
  45   if (state_ == inited) {
  46     this->start();
  47   }
  48
  49   if (simcall_execution_test(pimpl_)) {
  50     state_ = finished;
  51     return true;
  52   }
  53
  54   return false;
  55 }
  56
  57 ExecPtr Exec::setPriority(double priority)
  58 {
  59   xbt_assert(state_ == inited, "Cannot change the priority of an exec after its start");
  60   priority_ = priority;
  61   return this;
  62 }
  63
  64 ExecPtr Exec::setBound(double bound)
  65 {
  66   xbt_assert(state_ == inited, "Cannot change the bound of an exec after its start");
  67   bound_ = bound;
  68   return this;
  69 }
  70
  71 ExecPtr Exec::setHost(Host* host)
  72 {
  73   xbt_assert(state_ == inited || state_ == started, "Cannot change the host of an exec once it's done (state: %d)", state_);
  74   if (state_ == started)
  75     boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->migrate(host);
  76   host_ = host;
  77   return this;
  78 }
  79
  80 double Exec::getRemains()
  81 {
  82   return simgrid::simix::kernelImmediate(
  83       [this]() { return boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->remains(); });
  84 }
  85 double Exec::getRemainingRatio()
  86 {
  87   return simgrid::simix::kernelImmediate(
  88       [this]() { return boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(pimpl_)->remainingRatio(); });
  89 }
  90
  91 void intrusive_ptr_release(simgrid::s4u::Exec* e)
  92 {
  93   if (e->refcount_.fetch_sub(1, std::memory_order_release) == 1) {
  94     std::atomic_thread_fence(std::memory_order_acquire);
  95     delete e;
  96   }
  97 }
  98
  99 void intrusive_ptr_add_ref(simgrid::s4u::Exec* e)
 100 {
 101   e->refcount_.fetch_add(1, std::memory_order_relaxed);
 102 }
 103 }
 104 }