10 #ifndef WRENCH_JOBMANAGERMESSAGE_H
11 #define WRENCH_JOBMANAGERMESSAGE_H
13 #include "wrench/simulation/SimulationMessage.h"
14 #include "wrench/services/compute/ComputeService.h"
15 #include "wrench/job/StandardJob.h"
16 #include "wrench-dev.h"
49 std::shared_ptr<CompoundJob>
job;
61 std::shared_ptr<FailureCause>
cause);
65 std::shared_ptr<CompoundJob>
job;
69 std::shared_ptr<FailureCause>
cause;
83 std::shared_ptr<StandardJob>
job;
98 std::shared_ptr<FailureCause>
cause);
102 std::shared_ptr<StandardJob>
job;
110 std::shared_ptr<FailureCause>
cause;
120 std::shared_ptr<FailureCause>
cause);
124 std::shared_ptr<PilotJob>
job;
128 std::shared_ptr<FailureCause>
cause;
137 #endif //WRENCH_JOBMANAGERMESSAGE_H
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:126
std::shared_ptr< CompoundJob > job
The job that is done.
Definition: JobManagerMessage.h:49
std::shared_ptr< ComputeService > compute_service
The compute service on which the job ran.
Definition: JobManagerMessage.h:51
State
Task states.
Definition: WorkflowTask.h:72
std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes
The necessary task1 state changes.
Definition: JobManagerMessage.h:87
JobManagerPilotJobFailedMessage(std::shared_ptr< PilotJob > job, std::shared_ptr< ComputeService > compute_service, std::shared_ptr< FailureCause > cause)
Constructor.
Definition: JobManagerMessage.cpp:69
std::shared_ptr< StandardJob > job
The job that has failed.
Definition: JobManagerMessage.h:102
Top-level class to describe a message communicated by processes in the simulation.
Definition: SimulationMessage.h:28
JobManagerWakeupMessage()
Message sent to the job manager to wake it up.
Definition: JobManagerMessage.cpp:109
A message sent by the JobManager to notify some submitter that a StandardJob has completed.
Definition: JobManagerMessage.h:76
std::set< std::shared_ptr< WorkflowTask > > necessary_failure_count_increments
The tasks whose failure counts need to be incremented.
Definition: JobManagerMessage.h:108
std::shared_ptr< ComputeService > compute_service
The compute service on which the job ran.
Definition: JobManagerMessage.h:85
std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes
The task1 state change that should be made.
Definition: JobManagerMessage.h:106
A message sent to a JobManager to wake it up.
Definition: JobManagerMessage.h:36
Definition: Action.cpp:28
std::shared_ptr< CompoundJob > job
The job that has failed.
Definition: JobManagerMessage.h:65
JobManagerStandardJobFailedMessage(std::shared_ptr< StandardJob > job, std::shared_ptr< ComputeService > compute_service, std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes, std::set< std::shared_ptr< WorkflowTask >> necessary_failure_count_increments, std::shared_ptr< FailureCause > cause)
Constructor.
Definition: JobManagerMessage.cpp:50
std::shared_ptr< PilotJob > job
The job that has failed.
Definition: JobManagerMessage.h:124
std::shared_ptr< FailureCause > cause
The failure cause.
Definition: JobManagerMessage.h:69
JobManagerMessage()
Constructor.
Definition: JobManagerMessage.cpp:21
JobManagerCompoundJobCompletedMessage(std::shared_ptr< CompoundJob > job, std::shared_ptr< ComputeService > compute_service)
Message from by job manager to notify somebody of a standard job successfully completed.
Definition: JobManagerMessage.cpp:84
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:104
std::shared_ptr< FailureCause > cause
The cause of the failure.
Definition: JobManagerMessage.h:110
Top-level class for messages received/sent by a JobManager.
Definition: JobManagerMessage.h:28
A message sent by the JobManager to notify some submitter that a StandardJob has failed.
Definition: JobManagerMessage.h:93
A message sent by the JobManager to notify some submitter that a CompoundJob has completed.
Definition: JobManagerMessage.h:44
std::shared_ptr< StandardJob > job
The job that is done.
Definition: JobManagerMessage.h:83
JobManagerCompoundJobFailedMessage(std::shared_ptr< CompoundJob > job, std::shared_ptr< ComputeService > compute_service, std::shared_ptr< FailureCause > cause)
Message from by job manager to notify somebody of a standard job has failed to complete.
Definition: JobManagerMessage.cpp:97
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:67
JobManagerStandardJobCompletedMessage(std::shared_ptr< StandardJob > job, std::shared_ptr< ComputeService > compute_service, std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes)
Constructor.
Definition: JobManagerMessage.cpp:32
A message sent by the JobManager to notify some submitter that a PilotJob has failed.
Definition: JobManagerMessage.h:116
A message sent by the JobManager to notify some submitter that a CompoundJob has failed.
Definition: JobManagerMessage.h:57
std::shared_ptr< FailureCause > cause
The failure cause.
Definition: JobManagerMessage.h:128