|
enum | State { UP,
DOWN,
SUSPENDED
} |
| Daemon states. More...
|
|
static void | cleanupTrackedServices () |
| Go through the tracked services and remove all entries with a refcount of 1!
|
|
static void | clearTrackedServices () |
| Forget all tracked services.
|
|
static void | increaseNumCompletedServicesCount () |
| Increase the completed service count.
|
|
std::string | hostname |
| The name of the host on which the daemon is running.
|
|
std::string | initial_mailbox_name |
| The initial name of the daemon's mailbox.
|
|
LifeSaver * | life_saver = nullptr |
| The daemon's life saver.
|
|
std::string | mailbox_name |
| The current name of the daemon's mailbox.
|
|
std::string | process_name |
| The name of the daemon.
|
|
Simulation * | simulation |
| a pointer to the simulation object
|
|
| WMS (std::unique_ptr< StandardJobScheduler > standard_job_scheduler, std::unique_ptr< PilotJobScheduler > pilot_job_scheduler, const std::set< std::shared_ptr< ComputeService >> &compute_services, const std::set< std::shared_ptr< StorageService >> &storage_services, const std::set< std::shared_ptr< NetworkProximityService >> &network_proximity_services, std::shared_ptr< FileRegistryService > file_registry_service, const std::string &hostname, const std::string suffix) |
| Constructor: a WMS with a workflow instance, a scheduler implementation, and a list of compute services. More...
|
|
void | checkDeferredStart () |
| Check whether the WMS has a deferred start simulation time (likely the first call in the main() routine of any WMS. More...
|
|
std::shared_ptr< DataMovementManager > | createDataMovementManager () |
| Instantiate and start a data movement manager. More...
|
|
std::shared_ptr< EnergyMeterService > | createEnergyMeter (const std::map< std::string, double > &measurement_periods) |
| Instantiate and start an energy meter. More...
|
|
std::shared_ptr< EnergyMeterService > | createEnergyMeter (const std::vector< std::string > &hostnames, double measurement_period) |
| Instantiate and start an energy meter. More...
|
|
std::shared_ptr< JobManager > | createJobManager () |
| Instantiate and start a job manager. More...
|
|
template<class T > |
std::set< std::shared_ptr< T > > | getAvailableComputeServices () |
| Obtain the list of compute services available to the WMS. More...
|
|
std::shared_ptr< FileRegistryService > | getAvailableFileRegistryService () |
| Obtain the file registry service available to the WMS. More...
|
|
std::set< std::shared_ptr< NetworkProximityService > > | getAvailableNetworkProximityServices () |
| Obtain the list of network proximity services available to the WMS. More...
|
|
std::set< std::shared_ptr< StorageService > > | getAvailableStorageServices () |
| Obtain the list of storage services available to the WMS. More...
|
|
virtual void | processEventFileCopyCompletion (std::shared_ptr< FileCopyCompletedEvent >) |
| Process a file copy completion event. More...
|
|
virtual void | processEventFileCopyFailure (std::shared_ptr< FileCopyFailedEvent >) |
| Process a file copy failure event. More...
|
|
virtual void | processEventPilotJobExpiration (std::shared_ptr< PilotJobExpiredEvent >) |
| Process a pilot job expiration event. More...
|
|
virtual void | processEventPilotJobStart (std::shared_ptr< PilotJobStartedEvent >) |
| Process a pilot job start event. More...
|
|
virtual void | processEventStandardJobCompletion (std::shared_ptr< StandardJobCompletedEvent >) |
| Process a standard job completion event. More...
|
|
virtual void | processEventStandardJobFailure (std::shared_ptr< StandardJobFailedEvent >) |
| Process a standard job failure event. More...
|
|
virtual void | processEventTimer (std::shared_ptr< TimerEvent >) |
| Process a timer event. More...
|
|
void | runDynamicOptimizations () |
| Perform dynamic optimizations. Optimizations are executed in order of insertion.
|
|
void | runStaticOptimizations () |
| Perform static optimizations. Optimizations are executed in order of insertion.
|
|
void | setTimer (double date, std::string message) |
| Sets a timer (which, when it goes off, will generate a TimerEvent) More...
|
|
void | waitForAndProcessNextEvent () |
| Wait for a workflow execution event and then call the associated function to process that event.
|
|
bool | waitForAndProcessNextEvent (double timeout) |
| Wait for a workflow execution event and then call the associated function to process that event. More...
|
|
std::shared_ptr< WorkflowExecutionEvent > | waitForNextEvent () |
| Wait for a workflow execution event. More...
|
|
std::shared_ptr< WorkflowExecutionEvent > | waitForNextEvent (double timeout) |
| Wait for a workflow execution event. More...
|
|
| Service (std::string hostname, std::string process_name_prefix, std::string mailbox_name_prefix) |
| Constructor. More...
|
|
| ~Service () |
| Destructor.
|
|
template<class T > |
std::shared_ptr< T > | getSharedPtr () |
| Method to retrieve the shared_ptr to a service. More...
|
|
void | serviceSanityCheck () |
| Check whether the service is properly configured and running. More...
|
|
void | setMessagePayload (std::string, double) |
| Set a message payload of the Service. More...
|
|
void | setMessagePayloads (std::map< std::string, double > default_messagepayload_values, std::map< std::string, double > overriden_messagepayload_values) |
| Set default and user-defined message payloads. More...
|
|
void | setProperties (std::map< std::string, std::string > default_property_values, std::map< std::string, std::string > overriden_property_values) |
| Set default and user-defined properties. More...
|
|
void | setProperty (std::string, std::string) |
| Set a property of the Service. More...
|
|
void | acquireDaemonLock () |
| Lock the daemon's lock.
|
|
void | killActor () |
| Kill the daemon/actor (does nothing if already dead) More...
|
|
void | releaseDaemonLock () |
| Unlock the daemon's lock.
|
|
void | runMainMethod () |
| Method that run's the user-defined main method (that's called by the S4U actor class)
|
|
static void | assertServiceIsUp (std::shared_ptr< Service > s) |
| Assert for the service being up. More...
|
|
template<class T > |
static std::shared_ptr< T > | getServiceByName (std::string name) |
| Method to retrieve the shared_ptr to a service based on the service's name (not efficient) More...
|
|
std::map< std::string, double > | messagepayload_list |
| The service's messagepayload list.
|
|
std::string | name |
| The service's name.
|
|
double | network_timeout = 30.0 |
| The time (in seconds) after which a service that doesn't send back a reply (control) message causes a NetworkTimeOut exception. (default: 30 second; if <0 never timeout)
|
|
std::map< std::string, std::string > | property_list |
| The service's property list.
|
|
unsigned int | num_starts = 0 |
| The number of time that this daemon has started (i.e., 1 + number of restarts)
|
|
State | state |
| The service's state.
|
|