X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d36e9a7ac2032c4fddcb236753b99c6573129893..6b8dc0899319667769a220397df30b6dac0e2b8f:/src/kernel/activity/ActivityImpl.hpp diff --git a/src/kernel/activity/ActivityImpl.hpp b/src/kernel/activity/ActivityImpl.hpp index f9532eb13f..c2636daf30 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,16 +19,35 @@ 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; + bool test(); + void wait_for(actor::ActorImpl* issuer, double timeout); + virtual ActivityImpl& set_timeout(double timeout) { THROW_UNIMPLEMENTED; } + virtual void suspend(); virtual void resume(); virtual void cancel(); @@ -41,7 +60,7 @@ public: virtual void register_simcall(smx_simcall_t simcall); void clean_action(); virtual double get_remaining() const; - // boost::intrusive_ptr support: + // Support for the boost::intrusive_ptr datatype friend XBT_PUBLIC void intrusive_ptr_add_ref(ActivityImpl* activity); friend XBT_PUBLIC void intrusive_ptr_release(ActivityImpl* activity);