: prev_(prev), next_(next), num_pieces(num_pieces)
{
}
- ~ChainMessage() = default;
};
class FilePiece {
public:
FilePiece() = default;
- ~FilePiece() = default;
};
class Peer {
unsigned int total_pieces = 0;
Peer() { me = simgrid::s4u::Mailbox::by_name(simgrid::s4u::Host::current()->get_cname()); }
- ~Peer() = default;
void joinChain()
{
mailboxes.push_back(simgrid::s4u::Mailbox::by_name(name));
}
}
-
- ~Broadcaster() = default;
};
static void peer()
public:
explicit Answer(unsigned int destination_id) : destination_id_(destination_id) {}
- virtual ~Answer() = default;
unsigned int getDestinationId() const { return destination_id_; }
size_t getSize() const { return nodes_.size(); }
const std::vector<std::pair<unsigned int, unsigned int>>& getNodes() const { return nodes_; }
public:
Future() = default;
explicit Future(std::shared_ptr<FutureState<T>> state) : state_(std::move(state)) {}
- ~Future() = default;
// Move type:
Future(Future&) = delete;
enum class Type { Host, Router, NetZone };
NetPoint(const std::string& name, NetPoint::Type component_type, NetZoneImpl* netzone_p);
- ~NetPoint() = default;
// Our rank in the vertices_ array of the netzone that contains us.
unsigned int id() const { return id_; }
public:
static xbt::Extension<NetPoint, Coords> EXTENSION_ID;
explicit Coords(NetPoint* host, const std::string& str);
- virtual ~Coords() = default;
std::vector<double> coords;
};
explicit WifiZone(NetZoneImpl* father, const std::string& name, resource::NetworkModel* netmodel);
WifiZone(const WifiZone&) = delete;
WifiZone& operator=(const WifiZone) = delete;
- ~WifiZone() override = default;
void seal() override;
void get_local_route(NetPoint* src, NetPoint* dst, RouteCreationArgs* into, double* latency) override;
/** Creates a barrier for the given amount of actors */
explicit Barrier(unsigned int expected_actors) : expected_actors_(expected_actors) {}
#ifndef DOXYGEN
- ~Barrier() = default;
Barrier(Barrier const&) = delete;
Barrier& operator=(Barrier const&) = delete;
#endif
explicit Exec(kernel::activity::ExecImplPtr pimpl);
public:
- ~Exec() override = default;
#ifndef DOXYGEN
Exec(Exec const&) = delete;
Exec& operator=(Exec const&) = delete;
-
#endif
static xbt::signal<void(Exec const&)> on_start;
static xbt::signal<void(Exec const&)> on_completion;
public:
#ifndef DOXYGEN
friend Disk; // Factory of IOs
-
- ~Io() override = default;
#endif
static xbt::signal<void(Io const&)> on_start;
: Type(event_type, name, alias, "", father){};
ValueType(PajeEventType event_type, const std::string& name, Type* father)
: Type(event_type, name, name, "", father){};
- ~ValueType() override = default;
void add_entity_value(const std::string& name, const std::string& color);
void add_entity_value(const std::string& name);
EntityValue* get_entity_value(const std::string& name);
public:
ConditionVariableImpl() : piface_(this){};
- ~ConditionVariableImpl() = default;
void remove_sleeping_actor(actor::ActorImpl& actor) { xbt::intrusive_erase(sleeping_, actor); }
const s4u::ConditionVariable* get_iface() const { return &piface_; }
public:
explicit SemaphoreImpl(unsigned int value) : value_(value){};
- ~SemaphoreImpl() = default;
SemaphoreImpl(SemaphoreImpl const&) = delete;
SemaphoreImpl& operator=(SemaphoreImpl const&) = delete;
int original_num = -1; // num field of the VisitedState to which I was declared equal to (used for dot_output)
explicit VisitedState(unsigned long state_number);
- ~VisitedState() = default;
};
class XBT_PRIVATE VisitedStates {
bool exploration_started = false;
explicit Pair(unsigned long expanded_pairs);
- ~Pair() = default;
Pair(Pair const&) = delete;
Pair& operator=(Pair const&) = delete;
VisitedPair(int pair_num, xbt_automaton_state_t automaton_state,
std::shared_ptr<const std::vector<int>> atomic_propositions, std::shared_ptr<State> graph_state);
- ~VisitedPair() = default;
};
class XBT_PRIVATE LivenessChecker : public Checker {
public:
explicit LivenessChecker();
- ~LivenessChecker() override = default;
void run() override;
RecordTrace get_record_trace() override;
std::vector<std::string> get_textual_trace() override;
public:
explicit SafetyChecker();
- ~SafetyChecker() override = default;
void run() override;
RecordTrace get_record_trace() override;
std::vector<std::string> get_textual_trace() override;
class XBT_PRIVATE UdporChecker : public Checker {
public:
explicit UdporChecker();
- ~UdporChecker() override = default;
void run() override;
RecordTrace get_record_trace() override;
std::vector<std::string> get_textual_trace() override;
public:
Region(RegionType type, void* start_addr, size_t size);
- ~Region() = default;
Region(Region const&) = delete;
Region& operator=(Region const&) = delete;
Region(Region&& that) = delete;
public:
/* Initialization */
Snapshot(int num_state, RemoteSimulation* get_remote_simulation = &mc_model_checker->get_remote_simulation());
- ~Snapshot() override = default;
/* Regular use */
bool on_heap(const void* address) const
Configuration(const Configuration&) = default;
Configuration& operator=(Configuration const&) = default;
Configuration(Configuration&&) = default;
- ~Configuration() = default;
};
class UnfoldingEvent {
UnfoldingEvent(const UnfoldingEvent&) = default;
UnfoldingEvent& operator=(UnfoldingEvent const&) = default;
UnfoldingEvent(UnfoldingEvent&&) = default;
- ~UnfoldingEvent() = default;
EventSet getHistory() const;
Task(const Task&) = delete;
Task& operator=(const Task&) = delete;
- ~Task() = default;
bool is_used() const { return is_used_; }
bool is_parallel() const { return parallel_; }
double get_max_downtime() const { return max_downtime_; }
static simgrid::xbt::Extension<VirtualMachineImpl, DirtyPageTrackingExt> EXTENSION_ID;
- virtual ~DirtyPageTrackingExt() = default;
DirtyPageTrackingExt() = default;
};
, current_flops_(host_->get_load())
{
}
- ~HostLoad() = default;
HostLoad() = delete;
explicit HostLoad(simgrid::s4u::Host& ptr) = delete;
explicit HostLoad(simgrid::s4u::Host&& ptr) = delete;
static simgrid::xbt::Extension<simgrid::s4u::Link, LinkEnergy> EXTENSION_ID;
explicit LinkEnergy(simgrid::s4u::Link* ptr) : link_(ptr), last_updated_(surf_get_clock()) {}
- ~LinkEnergy() = default;
void init_watts_range_list();
double get_consumed_energy();
static simgrid::xbt::Extension<simgrid::s4u::Link, LinkEnergyWifi> EXTENSION_ID;
explicit LinkEnergyWifi(simgrid::s4u::Link* ptr) : link_(ptr) {}
-
- ~LinkEnergyWifi() = default;
LinkEnergyWifi() = delete;
/**
static simgrid::xbt::Extension<simgrid::s4u::Link, LinkLoad> EXTENSION_ID;
explicit LinkLoad(simgrid::s4u::Link* ptr);
- ~LinkLoad() = default;
void track();
void untrack();
class VmHostExt {
public:
static simgrid::xbt::Extension<simgrid::s4u::Host, VmHostExt> EXTENSION_ID;
- virtual ~VmHostExt() = default;
sg_size_t ramsize = 0; /* available ramsize (0= not taken into account) */
bool overcommit = true; /* Whether the host allows overcommiting more VM than the avail ramsize allows */
s4u::ActorPtr tx_ = nullptr;
s4u::ActorPtr rx_ = nullptr;
static simgrid::xbt::Extension<simgrid::s4u::Host, VmMigrationExt> EXTENSION_ID;
- virtual ~VmMigrationExt() = default;
explicit VmMigrationExt(s4u::ActorPtr issuer, s4u::ActorPtr rx, s4u::ActorPtr tx) : issuer_(issuer), tx_(tx), rx_(rx)
{
}
static xbt::Extension<s4u::Host, smpi::Host> EXTENSION_ID;
explicit Host(s4u::Host* ptr);
- ~Host() = default;
double orecv(size_t size);
double osend(size_t size);
public:
explicit Info() {this->add_f();}
explicit Info(const Info* orig) : map_(orig->map_) {this->add_f();}
- ~Info() override = default;
void ref();
static void unref(MPI_Info info);
void set(const char* key, const char* value) { map_[key] = value; }
class CpuCas01 : public Cpu {
public:
CpuCas01(s4u::Host* host, const std::vector<double>& speed_per_pstate) : Cpu(host, speed_per_pstate) {}
- ~CpuCas01() = default;
CpuCas01(const CpuCas01&) = delete;
CpuCas01& operator=(const CpuCas01&) = delete;
void apply_event(profile::Event* event, double value) override;
class NetworkCm02Model : public NetworkModel {
public:
NetworkCm02Model();
- ~NetworkCm02Model() override = default;
LinkImpl* create_link(const std::string& name, const std::vector<double>& bandwidths,
s4u::Link::SharingPolicy policy) override;
void update_actions_state_lazy(double now, double delta) override;
class NetworkCm02Link : public LinkImpl {
public:
NetworkCm02Link(const std::string& name, double bandwidth, s4u::Link::SharingPolicy policy, lmm::System* system);
- ~NetworkCm02Link() override = default;
void apply_event(kernel::profile::Event* event, double value) override;
void set_bandwidth(double value) override;
LinkImpl* set_latency(double value) override;
public:
using NetworkAction::NetworkAction;
- ~NetworkCm02Action() override = default;
void update_remains_lazy(double now) override;
};
}
// number of comms the node is receiving
int nbActiveCommsDown = 0;
explicit IBNode(int id) : id(id){};
- virtual ~IBNode() = default;
};
class XBT_PRIVATE NetworkIBModel : public NetworkSmpiModel {
class NetworkNS3Model : public NetworkModel {
public:
NetworkNS3Model();
- ~NetworkNS3Model() override = default;
LinkImpl* create_link(const std::string& name, const std::vector<double>& bandwidth,
s4u::Link::SharingPolicy policy) override;
Action* communicate(s4u::Host* src, s4u::Host* dst, double size, double rate) override;
class XBT_PRIVATE NetworkSmpiModel : public NetworkCm02Model {
public:
NetworkSmpiModel();
- ~NetworkSmpiModel() override = default;
double get_latency_factor(double size) override;
double get_bandwidth_factor(double size) override;
class CpuL07 : public kernel::resource::Cpu {
public:
CpuL07(s4u::Host* host, const std::vector<double>& speed_per_pstate) : Cpu(host, speed_per_pstate){};
- ~CpuL07() = default;
CpuL07(const CpuL07&) = delete;
CpuL07& operator=(const CpuL07&) = delete;
TypedConfigurationElement(const std::string& key, const std::string& desc, T value, std::function<void(T&)> callback)
: ConfigurationElement(key, desc), content(std::move(value)), callback(std::move(callback))
{}
- ~TypedConfigurationElement() override = default;
std::string get_string_value() override;
const char* get_type_name() override;
