X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c3789d017953e10867f46f196b546ec7bd16ab75..149c63f36e15b8500b1e826bda5138318ff7ba2b:/src/kernel/activity/ActivityImpl.hpp diff --git a/src/kernel/activity/ActivityImpl.hpp b/src/kernel/activity/ActivityImpl.hpp index 0d16180e30..c1c8de5bb8 100644 --- a/src/kernel/activity/ActivityImpl.hpp +++ b/src/kernel/activity/ActivityImpl.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -19,23 +19,42 @@ namespace simgrid { namespace kernel { namespace activity { +enum class State { + WAITING = 0, + READY, + RUNNING, + DONE, + CANCELED, + FAILED, + SRC_HOST_FAILURE, + DST_HOST_FAILURE, + TIMEOUT, + SRC_TIMEOUT, + DST_TIMEOUT, + LINK_FAILURE +}; class XBT_PUBLIC ActivityImpl { std::atomic_int_fast32_t refcount_{0}; + public: virtual ~ActivityImpl(); ActivityImpl() = default; - e_smx_state_t state_ = SIMIX_WAITING; /* State of the activity */ + State state_ = State::WAITING; /* State of the activity */ std::list simcalls_; /* List of simcalls waiting for this activity */ resource::Action* surf_action_ = nullptr; virtual void suspend(); virtual void resume(); virtual void cancel(); - virtual void post() = 0; // What to do when a simcall terminates - virtual void finish() = 0; - virtual void clean_action(); + virtual void post() = 0; // Called by the main loop when the activity is marked as terminated or failed by its model. + // Setups the status, clean things up, and call finish() + virtual void finish() = 0; // Unlock all simcalls blocked on that activity, either because it was marked as done by + // the model or because it terminated without waiting for the model + + virtual void register_simcall(smx_simcall_t simcall); + void clean_action(); virtual double get_remaining() const; // boost::intrusive_ptr support: friend XBT_PUBLIC void intrusive_ptr_add_ref(ActivityImpl* activity);