|
| VirtualizedClusterComputeService (const std::string &hostname, std::vector< std::string > &execution_hosts, std::string scratch_space_mount_point, WRENCH_PROPERTY_COLLECTION_TYPE property_list={}, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list={}) |
| Constructor. More...
|
|
virtual void | migrateVM (const std::string &vm_name, const std::string &dest_pm_hostname) |
| Synchronously migrate a VM to another physical host. More...
|
|
virtual std::shared_ptr< BareMetalComputeService > | startVM (const std::string &vm_name) |
| Start a VM. More...
|
|
virtual std::shared_ptr< BareMetalComputeService > | startVM (const std::string &vm_name, const std::string &pm_name) |
| Start a VM. More...
|
|
| CloudComputeService (const std::string &hostname, std::vector< std::string > execution_hosts, std::string scratch_space_mount_point, WRENCH_PROPERTY_COLLECTION_TYPE property_list={}, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list={}) |
| Constructor. More...
|
|
| ~CloudComputeService () |
| Destructor.
|
|
virtual std::string | createVM (unsigned long num_cores, double ram_memory, std::string desired_vm_name, WRENCH_PROPERTY_COLLECTION_TYPE property_list={}, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list={}) |
| Create a BareMetalComputeService VM (balances load on execution hosts) More...
|
|
virtual std::string | createVM (unsigned long num_cores, double ram_memory, WRENCH_PROPERTY_COLLECTION_TYPE property_list={}, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list={}) |
| Create a BareMetalComputeService VM (balances load on execution hosts) More...
|
|
virtual void | destroyVM (const std::string &vm_name) |
| Destroy a VM. More...
|
|
std::vector< std::string > | getExecutionHosts () |
| Get the list of execution hosts available to run VMs. More...
|
|
virtual std::shared_ptr< BareMetalComputeService > | getVMComputeService (const std::string &vm_name) |
| Get the compute service running on a VM, if any. More...
|
|
virtual std::string | getVMPhysicalHostname (const std::string &vm_name) |
| Get the name of the physical host on which a VM is running. More...
|
|
virtual bool | isVMDown (const std::string &vm_name) |
| Method to check whether a VM is currently down. More...
|
|
virtual bool | isVMRunning (const std::string &vm_name) |
| Method to check whether a VM is currently running. More...
|
|
virtual bool | isVMSuspended (const std::string &vm_name) |
| Method to check whether a VM is currently running. More...
|
|
virtual void | resumeVM (const std::string &vm_name) |
| Resume a suspended VM. More...
|
|
virtual void | shutdownVM (const std::string &vm_name) |
| Shutdown an active VM. More...
|
|
virtual void | shutdownVM (const std::string &vm_name, bool send_failure_notifications, ComputeService::TerminationCause termination_cause) |
| Shutdown an active VM. More...
|
|
virtual std::shared_ptr< BareMetalComputeService > | startVM (const std::string &vm_name) |
| Start a VM. More...
|
|
void | submitCompoundJob (std::shared_ptr< CompoundJob > job, const std::map< std::string, std::string > &service_specific_args) override |
| Method to submit a compound job to the service. More...
|
|
virtual bool | supportsCompoundJobs () override |
| Returns true if the service supports compound jobs. More...
|
|
virtual bool | supportsPilotJobs () override |
| Returns true if the service supports pilot jobs. More...
|
|
virtual bool | supportsStandardJobs () override |
| Returns true if the service supports standard jobs. More...
|
|
virtual void | suspendVM (const std::string &vm_name) |
| Suspend a running VM. More...
|
|
void | terminateCompoundJob (std::shared_ptr< CompoundJob > job) override |
| Method to terminate a compound job. More...
|
|
void | validateProperties () |
| Validate the service's properties. More...
|
|
| ComputeService (const std::string &hostname, std::string service_name, std::string scratch_space_mount_point) |
| Constructor. More...
|
|
std::map< std::string, double > | getCoreFlopRate () |
| Get the per-core flop rate of the compute service's hosts. More...
|
|
double | getFreeScratchSpaceSize () |
| Get the free space on the compute service's scratch storage space. More...
|
|
std::vector< std::string > | getHosts () |
| Get the list of the compute service's compute host. More...
|
|
std::map< std::string, double > | getMemoryCapacity () |
| Get the RAM capacities for each of the compute service's hosts. More...
|
|
unsigned long | getNumHosts () |
| Get the number of hosts that the compute service manages. More...
|
|
std::map< std::string, double > | getPerHostAvailableMemoryCapacity () |
| Get ram availability for each of the compute service's host. More...
|
|
std::map< std::string, unsigned long > | getPerHostNumCores () |
| Get core counts for each of the compute service's host. More...
|
|
std::map< std::string, unsigned long > | getPerHostNumIdleCores () |
| Get idle core counts for each of the compute service's host. More...
|
|
std::shared_ptr< StorageService > | getScratch () |
| Get the compute service's scratch storage space. More...
|
|
unsigned long | getTotalNumCores () |
| Get the total core counts for all hosts of the compute service. More...
|
|
virtual unsigned long | getTotalNumIdleCores () |
| Get the total idle core count for all hosts of the compute service. Note that this doesn't mean that asking for these cores right will mean immediate execution (since jobs may be pending and "ahead" in the queue, e.g., because they depend on current actions that are not using all available resources). More...
|
|
double | getTotalScratchSpaceSize () |
| Get the total capacity of the compute service's scratch storage space. More...
|
|
double | getTTL () |
| Get the time-to-live of the compute service. More...
|
|
virtual bool | hasScratch () const |
| Checks if the compute service has a scratch space. More...
|
|
virtual bool | isThereAtLeastOneHostWithIdleResources (unsigned long num_cores, double ram) |
| Method to find out if, right now, the compute service has at least one host with some idle number of cores and some available RAM. Note that this doesn't mean that asking for these resources right will mean immediate execution (since jobs may be pending and "ahead" in the queue, e.g., because they depend on current actions that are not using all available resources). More...
|
|
void | stop () override |
| Stop the compute service.
|
|
virtual void | stop (bool send_failure_notifications, ComputeService::TerminationCause termination_cause) |
| Stop the compute service. More...
|
|
void | terminateJob (std::shared_ptr< CompoundJob > job) |
| Terminate a previously-submitted job (which may or may not be running yet) More...
|
|
void | assertServiceIsUp () |
| Throws an exception if the service is not up. More...
|
|
std::string | getHostname () |
| Get the name of the host on which the service is / will be running. More...
|
|
const WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE & | getMessagePayloadList () const |
| Get all message payloads and their values of the Service. More...
|
|
double | getMessagePayloadValue (WRENCH_MESSAGEPAYLOAD_TYPE) |
| Get a message payload of the Service as a double. More...
|
|
double | getNetworkTimeoutValue () |
| Returns the service's network timeout value. More...
|
|
std::string | getPhysicalHostname () |
| Get the physical name of the host on which the service is / will be running. More...
|
|
bool | getPropertyValueAsBoolean (WRENCH_PROPERTY_TYPE) |
| Get a property of the Service as a boolean. More...
|
|
double | getPropertyValueAsDouble (WRENCH_PROPERTY_TYPE) |
| Get a property of the Service as a double. More...
|
|
std::string | getPropertyValueAsString (WRENCH_PROPERTY_TYPE) |
| Get a property of the Service as a string. More...
|
|
unsigned long | getPropertyValueAsUnsignedLong (WRENCH_PROPERTY_TYPE) |
| Get a property of the Service as an unsigned long. More...
|
|
bool | isUp () |
| Returns true if the service is UP, false otherwise. More...
|
|
void | resume () |
| Resume the service. More...
|
|
void | setNetworkTimeoutValue (double value) |
| Sets the service's network timeout value. More...
|
|
void | setStateToDown () |
| Set the state of the service to DOWN.
|
|
void | start (std::shared_ptr< Service > this_service, bool daemonize, bool auto_restart) |
| Start the service. More...
|
|
void | suspend () |
| Suspend the service.
|
|
| S4U_Daemon (std::string hostname, std::string process_name_prefix) |
| Constructor (daemon with a mailbox) More...
|
|
void | acquireDaemonLock () |
| Method to acquire the daemon's lock. More...
|
|
virtual void | cleanup (bool has_returned_from_main, int return_value) |
| Cleanup function called when the daemon terminates (for whatever reason). The default behavior is to throw an exception if the host is off. This method should be overriden in a daemons implements some fault-tolerant behavior, or is naturally tolerant. More...
|
|
void | createLifeSaver (std::shared_ptr< S4U_Daemon > reference) |
| Create a life saver for the daemon. More...
|
|
std::string | getName () |
| Retrieve the process name. More...
|
|
int | getReturnValue () |
| Returns the value returned by main() (if the daemon has returned from main) More...
|
|
Simulation * | getSimulation () |
| Get the service's simulation. More...
|
|
S4U_Daemon::State | getState () |
| Get the daemon's state. More...
|
|
bool | hasReturnedFromMain () |
| Returns true if the daemon has returned from main() (i.e., not brutally killed) More...
|
|
bool | isDaemonized () |
| Return the daemonized status of the daemon. More...
|
|
bool | isSetToAutoRestart () |
| Return the auto-restart status of the daemon. More...
|
|
std::pair< bool, int > | join () |
| Join (i.e., wait for) the daemon. More...
|
|
void | releaseDaemonLock () |
| Method to release the daemon's lock. More...
|
|
void | resumeActor () |
| Resume the daemon/actor.
|
|
void | setSimulation (Simulation *simulation) |
| Set the service's simulation. More...
|
|
void | setupOnExitFunction () |
| Sets up the on_exit function for the actor.
|
|
void | startDaemon (bool _daemonized, bool _auto_restart) |
| Start the daemon. More...
|
|
void | suspendActor () |
| Suspend the daemon/actor.
|
|