|
| StorageService (const std::string &hostname, const std::set< std::string > mount_points, const std::string &service_name, const std::string &data_mailbox_name_prefix) |
| Constructor. More...
|
|
virtual std::map< std::string, double > | getFreeSpace () |
| Synchronously asks the storage service for its capacity at all its mount points. More...
|
|
std::string | getMountPoint () |
| Get the mount point (will throw is more than one) More...
|
|
std::set< std::string > | getMountPoints () |
| Get the set of mount points. More...
|
|
virtual std::map< std::string, double > | getTotalSpace () |
| Get the total static capacity of the storage service (in zero simulation time) More...
|
|
bool | hasMountPoint (std::string mp) |
| Checked whether the storage service has a particular mount point. More...
|
|
bool | hasMultipleMountPoints () |
| Checked whether the storage service has multiple mount points. More...
|
|
bool | isScratch () |
| Determines whether the storage service is a scratch service of a ComputeService. More...
|
|
void | setScratch () |
| Indicate that this storace service is a scratch service of a ComputeService.
|
|
void | stop () override |
| Stop the service.
|
|
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...
|
|
double | getMessagePayloadValue (std::string) |
| Get a message payload of the Service as a double. More...
|
|
double | getNetworkTimeoutValue () |
| Returns the service's network timeout value. More...
|
|
bool | getPropertyValueAsBoolean (std::string) |
| Get a property of the Service as a boolean. More...
|
|
double | getPropertyValueAsDouble (std::string) |
| Get a property of the Service as a double. More...
|
|
std::string | getPropertyValueAsString (std::string) |
| Get a property of the Service as a string. More...
|
|
unsigned long | getPropertyValueAsUnsignedLong (std::string) |
| 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, std::string mailbox_prefix) |
| Constructor (daemon with a mailbox) More...
|
|
virtual | ~S4U_Daemon () |
|
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...
|
|
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...
|
|
virtual int | main ()=0 |
| The daemon's main method, to be overridden. More...
|
|
void | resumeActor () |
| Resume the daemon/actor.
|
|
void | setupOnExitFunction () |
| Sets up the on_exit functionf for the actor.
|
|
void | startDaemon (bool daemonized, bool auto_restart) |
| Start the daemon. More...
|
|
void | suspendActor () |
| Suspend the daemon/actor.
|
|
|
static void | copyFile (WorkflowFile *file, std::shared_ptr< FileLocation > src_location, std::shared_ptr< FileLocation > dst_location) |
| Synchronously ask the storage service to read a file from another storage service. More...
|
|
static void | deleteFile (WorkflowFile *file, std::shared_ptr< FileLocation > location, std::shared_ptr< FileRegistryService > file_registry_service=nullptr) |
| Synchronously delete a file at a location. More...
|
|
static void | initiateFileCopy (std::string answer_mailbox, WorkflowFile *file, std::shared_ptr< FileLocation > src_location, std::shared_ptr< FileLocation > dst_location) |
| Asynchronously ask for a file copy between two storage services. More...
|
|
static bool | lookupFile (WorkflowFile *file, std::shared_ptr< FileLocation > location) |
| Synchronously asks the storage service whether it holds a file. More...
|
|
static void | readFile (WorkflowFile *file, std::shared_ptr< FileLocation > location) |
| Synchronously read a file from the storage service. More...
|
|
static void | readFiles (std::map< WorkflowFile *, std::shared_ptr< FileLocation >> locations) |
| Synchronously and sequentially read a set of files from storage services. More...
|
|
static void | writeFile (WorkflowFile *file, std::shared_ptr< FileLocation > location) |
| Synchronously write a file to the storage service. More...
|
|
static void | writeFiles (std::map< WorkflowFile *, std::shared_ptr< FileLocation >> locations) |
| Synchronously and sequentially upload a set of files from storage services. 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.
|
|
|
enum | State { UP,
DOWN,
SUSPENDED
} |
| Daemon states. More...
|
|
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
|
|
| 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)
|
|
The storage service base class.