WRENCH  1.11
Cyberinfrastructure Simulation Workbench
Overview Installation Getting Started WRENCH 101 WRENCH 102
JobManagerMessage.h
1 
10 #ifndef WRENCH_JOBMANAGERMESSAGE_H
11 #define WRENCH_JOBMANAGERMESSAGE_H
12 
13 #include "wrench/simulation/SimulationMessage.h"
14 #include "wrench/services/compute/ComputeService.h"
15 #include "wrench/job/StandardJob.h"
16 #include "wrench-dev.h"
17 
18 namespace wrench {
19 
20 
21  /***********************/
23  /***********************/
24 
29  protected:
30  explicit JobManagerMessage();
31  };
32 
37  public:
39  };
40 
45  public:
46  JobManagerCompoundJobCompletedMessage(std::shared_ptr<CompoundJob> job, std::shared_ptr<ComputeService> compute_service);
47 
49  std::shared_ptr<CompoundJob> job;
51  std::shared_ptr<ComputeService> compute_service;
52  };
53 
58  public:
59  JobManagerCompoundJobFailedMessage(std::shared_ptr<CompoundJob> job,
60  std::shared_ptr<ComputeService> compute_service,
61  std::shared_ptr<FailureCause> cause);
62 
63 
65  std::shared_ptr<CompoundJob> job;
67  std::shared_ptr<ComputeService> compute_service;
69  std::shared_ptr<FailureCause> cause;
70  };
71 
72 
77  public:
78  JobManagerStandardJobCompletedMessage(std::shared_ptr<StandardJob> job, std::shared_ptr<ComputeService> compute_service,
79  std::map<std::shared_ptr<WorkflowTask>, WorkflowTask::State> necessary_state_changes);
80 
81 
83  std::shared_ptr<StandardJob> job;
85  std::shared_ptr<ComputeService> compute_service;
87  std::map<std::shared_ptr<WorkflowTask>, WorkflowTask::State> necessary_state_changes;
88  };
89 
94  public:
95  JobManagerStandardJobFailedMessage(std::shared_ptr<StandardJob> job, std::shared_ptr<ComputeService> compute_service,
96  std::map<std::shared_ptr<WorkflowTask>, WorkflowTask::State> necessary_state_changes,
97  std::set<std::shared_ptr<WorkflowTask>> necessary_failure_count_increments,
98  std::shared_ptr<FailureCause> cause);
99 
100 
102  std::shared_ptr<StandardJob> job;
104  std::shared_ptr<ComputeService> compute_service;
106  std::map<std::shared_ptr<WorkflowTask>, WorkflowTask::State> necessary_state_changes;
108  std::set<std::shared_ptr<WorkflowTask>> necessary_failure_count_increments;
110  std::shared_ptr<FailureCause> cause;
111  };
112 
117  public:
118  JobManagerPilotJobFailedMessage(std::shared_ptr<PilotJob> job,
119  std::shared_ptr<ComputeService> compute_service,
120  std::shared_ptr<FailureCause> cause);
121 
122 
124  std::shared_ptr<PilotJob> job;
126  std::shared_ptr<ComputeService> compute_service;
128  std::shared_ptr<FailureCause> cause;
129  };
130 
131  /***********************/
133  /***********************/
134 
135 };
136 
137 #endif //WRENCH_JOBMANAGERMESSAGE_H
wrench::JobManagerPilotJobFailedMessage::compute_service
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:126
wrench::JobManagerCompoundJobCompletedMessage::job
std::shared_ptr< CompoundJob > job
The job that is done.
Definition: JobManagerMessage.h:49
wrench::JobManagerCompoundJobCompletedMessage::compute_service
std::shared_ptr< ComputeService > compute_service
The compute service on which the job ran.
Definition: JobManagerMessage.h:51
wrench::WorkflowTask::State
State
Task states.
Definition: WorkflowTask.h:72
wrench::JobManagerStandardJobCompletedMessage::necessary_state_changes
std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes
The necessary task1 state changes.
Definition: JobManagerMessage.h:87
wrench::JobManagerPilotJobFailedMessage::JobManagerPilotJobFailedMessage
JobManagerPilotJobFailedMessage(std::shared_ptr< PilotJob > job, std::shared_ptr< ComputeService > compute_service, std::shared_ptr< FailureCause > cause)
Constructor.
Definition: JobManagerMessage.cpp:69
wrench::JobManagerStandardJobFailedMessage::job
std::shared_ptr< StandardJob > job
The job that has failed.
Definition: JobManagerMessage.h:102
wrench::SimulationMessage
Top-level class to describe a message communicated by processes in the simulation.
Definition: SimulationMessage.h:28
wrench::JobManagerWakeupMessage::JobManagerWakeupMessage
JobManagerWakeupMessage()
Message sent to the job manager to wake it up.
Definition: JobManagerMessage.cpp:109
wrench::JobManagerStandardJobCompletedMessage
A message sent by the JobManager to notify some submitter that a StandardJob has completed.
Definition: JobManagerMessage.h:76
wrench::JobManagerStandardJobFailedMessage::necessary_failure_count_increments
std::set< std::shared_ptr< WorkflowTask > > necessary_failure_count_increments
The tasks whose failure counts need to be incremented.
Definition: JobManagerMessage.h:108
wrench::JobManagerStandardJobCompletedMessage::compute_service
std::shared_ptr< ComputeService > compute_service
The compute service on which the job ran.
Definition: JobManagerMessage.h:85
wrench::JobManagerStandardJobFailedMessage::necessary_state_changes
std::map< std::shared_ptr< WorkflowTask >, WorkflowTask::State > necessary_state_changes
The task1 state change that should be made.
Definition: JobManagerMessage.h:106
wrench::JobManagerWakeupMessage
A message sent to a JobManager to wake it up.
Definition: JobManagerMessage.h:36
wrench
Definition: Action.cpp:28
wrench::JobManagerCompoundJobFailedMessage::job
std::shared_ptr< CompoundJob > job
The job that has failed.
Definition: JobManagerMessage.h:65
wrench::JobManagerStandardJobFailedMessage::JobManagerStandardJobFailedMessage
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
wrench::JobManagerPilotJobFailedMessage::job
std::shared_ptr< PilotJob > job
The job that has failed.
Definition: JobManagerMessage.h:124
wrench::JobManagerCompoundJobFailedMessage::cause
std::shared_ptr< FailureCause > cause
The failure cause.
Definition: JobManagerMessage.h:69
wrench::JobManagerMessage::JobManagerMessage
JobManagerMessage()
Constructor.
Definition: JobManagerMessage.cpp:21
wrench::JobManagerCompoundJobCompletedMessage::JobManagerCompoundJobCompletedMessage
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
wrench::JobManagerStandardJobFailedMessage::compute_service
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:104
wrench::JobManagerStandardJobFailedMessage::cause
std::shared_ptr< FailureCause > cause
The cause of the failure.
Definition: JobManagerMessage.h:110
wrench::JobManagerMessage
Top-level class for messages received/sent by a JobManager.
Definition: JobManagerMessage.h:28
wrench::JobManagerStandardJobFailedMessage
A message sent by the JobManager to notify some submitter that a StandardJob has failed.
Definition: JobManagerMessage.h:93
wrench::JobManagerCompoundJobCompletedMessage
A message sent by the JobManager to notify some submitter that a CompoundJob has completed.
Definition: JobManagerMessage.h:44
wrench::JobManagerStandardJobCompletedMessage::job
std::shared_ptr< StandardJob > job
The job that is done.
Definition: JobManagerMessage.h:83
wrench::JobManagerCompoundJobFailedMessage::JobManagerCompoundJobFailedMessage
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
wrench::JobManagerCompoundJobFailedMessage::compute_service
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: JobManagerMessage.h:67
wrench::JobManagerStandardJobCompletedMessage::JobManagerStandardJobCompletedMessage
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
wrench::JobManagerPilotJobFailedMessage
A message sent by the JobManager to notify some submitter that a PilotJob has failed.
Definition: JobManagerMessage.h:116
wrench::JobManagerCompoundJobFailedMessage
A message sent by the JobManager to notify some submitter that a CompoundJob has failed.
Definition: JobManagerMessage.h:57
wrench::JobManagerPilotJobFailedMessage::cause
std::shared_ptr< FailureCause > cause
The failure cause.
Definition: JobManagerMessage.h:128