A network proximity service that continuously estimates inter-host latencies and can be queried for such estimates.
More...
|
| | NetworkProximityService (std::string db_hostname, std::vector< std::string > hosts_in_network, WRENCH_PROPERTY_COLLECTION_TYPE property_list={}, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list={}) |
| | Constructor. More...
|
| |
|
| ~NetworkProximityService () override |
| | Destructor.
|
| |
| std::pair< std::pair< double, double >, double > | getHostCoordinate (std::string) |
| | Look up the current (x,y) coordinates of a given host (only for a Vivaldi network service type) More...
|
| |
| std::vector< std::string > | getHostnameList () |
| | Gets the list of hosts monitored by this service (does not involve simulated network communications with the service) More...
|
| |
| std::pair< double, double > | getHostPairDistance (std::pair< std::string, std::string > hosts) |
| | Look up a proximity value in database. More...
|
| |
| std::string | getNetworkProximityServiceType () |
| | Get the network proximity service type. 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...
|
| |
| virtual void | stop () |
| | Synchronously stop the service (does nothing if the service is already stopped) 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.
|
| |
|
| enum | State { UP,
DOWN,
SUSPENDED
} |
| | Daemon states. More...
|
| |
| static simgrid::s4u::Mailbox * | getRunningActorRecvMailbox () |
| | Return the running actor's recv mailbox. More...
|
| |
|
std::string | hostname |
| | The name of the host on which the daemon is running.
|
| |
|
LifeSaver * | life_saver = nullptr |
| | The daemon's life saver.
|
| |
|
simgrid::s4u::Mailbox * | mailbox |
| | The daemon's mailbox.
|
| |
|
std::string | process_name |
| | The name of the daemon.
|
| |
|
simgrid::s4u::Mailbox * | recv_mailbox |
| | The daemon's receive mailbox (to send to another daemon so that that daemon can reply)
|
| |
| | Service (std::string hostname, std::string process_name_prefix) |
| | Constructor. More...
|
| |
|
| ~Service () override |
| | 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 (WRENCH_MESSAGEPAYLOAD_TYPE, double) |
| | Set a message payload of the Service. More...
|
| |
| void | setMessagePayloads (WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE default_messagepayload_values, WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE overriden_messagepayload_values) |
| | Set default and user-defined message payloads. More...
|
| |
| void | setProperties (WRENCH_PROPERTY_COLLECTION_TYPE default_property_values, WRENCH_PROPERTY_COLLECTION_TYPE overriden_property_values) |
| | Set default and user-defined properties. More...
|
| |
| void | setProperty (WRENCH_PROPERTY_TYPE, const std::string &) |
| | Set a property of the Service. More...
|
| |
| bool | killActor () |
| | Kill the daemon/actor (does nothing if already dead) More...
|
| |
|
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...
|
| |
|
WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE | 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)
|
| |
|
WRENCH_PROPERTY_COLLECTION_TYPE | property_list |
| | The service's property list.
|
| |
|
bool | shutting_down = false |
| | A boolean that indicates if the service is in the middle of shutting down.
|
| |
|
unsigned int | num_starts = 0 |
| | The number of time that this daemon has started (i.e., 1 + number of restarts)
|
| |
|
Simulation * | simulation |
| | a pointer to the simulation object
|
| |
|
State | state |
| | The service's state.
|
| |
A network proximity service that continuously estimates inter-host latencies and can be queried for such estimates.
Public Member Functions inherited from wrench::Service