ComputeServiceMessage.h
59 ComputeServiceSubmitStandardJobAnswerMessage(StandardJob *, std::shared_ptr<ComputeService>, bool success,
77 ComputeServiceStandardJobDoneMessage(StandardJob *, std::shared_ptr<ComputeService>, double payload);
107 ComputeServiceTerminateStandardJobRequestMessage(std::string answer_mailbox, StandardJob *, double payload);
120 ComputeServiceTerminateStandardJobAnswerMessage(StandardJob *, std::shared_ptr<ComputeService>, bool success,
155 ComputeServiceSubmitPilotJobAnswerMessage(PilotJob *, std::shared_ptr<ComputeService>, bool success,
175 ComputeServicePilotJobStartedMessage(PilotJob *, std::shared_ptr<ComputeService>, double payload);
188 ComputeServicePilotJobExpiredMessage(PilotJob *, std::shared_ptr<ComputeService>, double payload);
201 ComputeServicePilotJobFailedMessage(PilotJob *, std::shared_ptr<ComputeService>, double payload);
214 ComputeServiceTerminatePilotJobRequestMessage(std::string answer_mailbox, PilotJob *, double payload);
227 ComputeServiceTerminatePilotJobAnswerMessage(PilotJob *, std::shared_ptr<ComputeService> compute_service,
258 ComputeServiceResourceInformationAnswerMessage(std::map<std::string, std::map<std::string, double>> info,
Top-level class for messages received/sent by a ComputeService.
Definition: ComputeServiceMessage.h:32
A message sent by a ComputeService when a PilotJob has failed.
Definition: ComputeServiceMessage.h:199
PilotJob * job
The pilot job that has failed.
Definition: ComputeServiceMessage.h:204
StandardJob * job
The job that has completed.
Definition: ComputeServiceMessage.h:80
A message sent by a ComputeService in answer to a StandardJob termination request.
Definition: ComputeServiceMessage.h:118
A message sent by a ComputeService when a PilotJob has started its execution.
Definition: ComputeServiceMessage.h:173
A message sent by a ComputeService when a PilotJob has expired.
Definition: ComputeServiceMessage.h:186
A message sent by a ComputeService in answer to a resource information request.
Definition: ComputeServiceMessage.h:256
std::shared_ptr< ComputeService > compute_service
The compute service to which the job had been submitted.
Definition: ComputeServiceMessage.h:126
PilotJob * job
The submitted pilot job.
Definition: ComputeServiceMessage.h:160
StandardJob * job
The standard job to terminate.
Definition: ComputeServiceMessage.h:124
std::shared_ptr< ComputeService > compute_service
The compute service on which the pilot job failed.
Definition: ComputeServiceMessage.h:206
std::map< std::string, std::map< std::string, double > > info
The resource information map.
Definition: ComputeServiceMessage.h:262
bool success
Whether to job submission was successful.
Definition: ComputeServiceMessage.h:67
A message sent by a ComputeService when a StandardJob has failed to execute.
Definition: ComputeServiceMessage.h:88
std::shared_ptr< FailureCause > cause
The cause of the failure.
Definition: ComputeServiceMessage.h:99
double payload
The message size in bytes.
Definition: SimulationMessage.h:39
StandardJob * job
The submitted job.
Definition: ComputeServiceMessage.h:49
A message sent to a ComputeService to submit a StandardJob for execution.
Definition: ComputeServiceMessage.h:40
PilotJob * job
The pilot job that has expired.
Definition: ComputeServiceMessage.h:191
std::shared_ptr< FailureCause > failure_cause
The cause of the failure, or nullptr on success.
Definition: ComputeServiceMessage.h:69
StandardJob * job
The job that has failed.
Definition: ComputeServiceMessage.h:95
std::shared_ptr< ComputeService > compute_service
The compute service to which the job had been submitted.
Definition: ComputeServiceMessage.h:234
A message sent by a ComputeService in answer to a StandardJob submission request. ...
Definition: ComputeServiceMessage.h:57
std::shared_ptr< ComputeService > compute_service
The compute service to which the job was submitted.
Definition: ComputeServiceMessage.h:162
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has completed.
Definition: ComputeServiceMessage.h:82
A pilot (i.e., non-standard) workflow job that can be submitted to a ComputeService by a WMS (via a J...
Definition: PilotJob.h:29
A standard (i.e., non-pilot) workflow job that can be submitted to a ComputeService by a WMS (via a J...
Definition: StandardJob.h:38
std::shared_ptr< FailureCause > failure_cause
The cause of the failure, or nullptr on success.
Definition: ComputeServiceMessage.h:238
A message sent by a ComputeService in answer to a PilotJob submission request.
Definition: ComputeServiceMessage.h:153
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: ComputeServiceMessage.h:97
std::map< std::string, std::string > service_specific_args
Service specific arguments.
Definition: ComputeServiceMessage.h:51
PilotJob * job
The pilot job that has started.
Definition: ComputeServiceMessage.h:178
A message sent to a ComputeService to request information on its compute resources.
Definition: ComputeServiceMessage.h:245
PilotJob * job
The submitted pilot job.
Definition: ComputeServiceMessage.h:145
std::shared_ptr< ComputeService > compute_service
The compute service on which the pilot job has expired.
Definition: ComputeServiceMessage.h:193
A message sent by a ComputeService in answer to a PilotJob termination request.
Definition: ComputeServiceMessage.h:225
StandardJob * job
The job to terminate.
Definition: ComputeServiceMessage.h:112
A message sent to a ComputeService to terminate a PilotJob previously submitted for execution...
Definition: ComputeServiceMessage.h:212
PilotJob * job
The job to terminate.
Definition: ComputeServiceMessage.h:219
ComputeServiceMessage(std::string name, double payload)
Constructor.
Definition: ComputeServiceMessage.cpp:21
Top-level class for messages received/sent by a Service.
Definition: ServiceMessage.h:27
std::string answer_mailbox
The mailbox to which the answer message should be sent.
Definition: ComputeServiceMessage.h:110
std::shared_ptr< ComputeService > compute_service
The compute service on which the pilot job has started.
Definition: ComputeServiceMessage.h:180
bool success
Whether the job submission was successful or not.
Definition: ComputeServiceMessage.h:164
std::shared_ptr< ComputeService > compute_service
The compute service to which the job was submitted.
Definition: ComputeServiceMessage.h:65
std::string answer_mailbox
The mailbox to which the answer message should be sent.
Definition: ComputeServiceMessage.h:217
bool success
Whether to job termination was successful.
Definition: ComputeServiceMessage.h:128
std::shared_ptr< FailureCause > failure_cause
The cause of the failure, or nullptr on success.
Definition: ComputeServiceMessage.h:130
A message sent to a ComputeService to terminate a StandardJob previously submitted for execution...
Definition: ComputeServiceMessage.h:105
std::string answer_mailbox
The mailbox to which the answer message should be sent.
Definition: ComputeServiceMessage.h:143
A message sent to a ComputeService to submit a PilotJob for execution.
Definition: ComputeServiceMessage.h:136
PilotJob * job
The job to terminate.
Definition: ComputeServiceMessage.h:232
std::map< std::string, std::string > service_specific_args
Service specific arguments.
Definition: ComputeServiceMessage.h:147
std::shared_ptr< FailureCause > failure_cause
The cause of the failure, or nullptr on success.
Definition: ComputeServiceMessage.h:166
std::string answer_mailbox
The mailbox to which the answer should be sent.
Definition: ComputeServiceMessage.h:250
A message sent by a ComputeService when a StandardJob has completed execution.
Definition: ComputeServiceMessage.h:75
std::string answer_mailbox
The mailbox to which the answer message should be sent.
Definition: ComputeServiceMessage.h:47
Definition: Alarm.cpp:19
StandardJob * job
The standard job that was submitted.
Definition: ComputeServiceMessage.h:63
bool success
Whether to job termination was successful.
Definition: ComputeServiceMessage.h:236