StandardJobExecutorMessage.h
1 
11 #ifndef WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H
12 #define WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H
13 
14 #include <vector>
15 
16 #include "wrench/services/compute/workunit_executor/WorkunitExecutor.h"
17 #include "wrench/services/compute/ComputeServiceMessage.h"
18 
19 namespace wrench {
20 
21  class WorkflowTask;
22 
23  class StandardJobExecutor;
24 
25  class WorkunitMultiCoreExecutor;
26 
27  /***********************/
29  /***********************/
30 
35  protected:
36  StandardJobExecutorMessage(std::string name, double payload);
37  };
38 
43  public:
45  std::shared_ptr<WorkunitExecutor> workunit_executor,
46  std::shared_ptr<Workunit> workunit,
47  double payload);
48 
50  std::shared_ptr<WorkunitExecutor> workunit_executor;
52  std::shared_ptr<Workunit> workunit;
53  };
54 
59  public:
61  std::shared_ptr<WorkunitExecutor> workunit_executor,
62  std::shared_ptr<Workunit> workunit,
63  std::shared_ptr<FailureCause> cause,
64  double payload);
65 
67  std::shared_ptr<WorkunitExecutor> workunit_executor;
69  std::shared_ptr<Workunit> workunit;
71  std::shared_ptr<FailureCause> cause;
72  };
73 
74 
79  public:
82  std::shared_ptr<StandardJobExecutor> executor,
83  double payload);
84 
86  std::shared_ptr<StandardJobExecutor> executor;
89 
90  };
91 
96  public:
99  std::shared_ptr<StandardJobExecutor> executor,
100  std::shared_ptr<FailureCause> cause,
101  double payload);
102 
104  std::shared_ptr<StandardJobExecutor> executor;
108  std::shared_ptr<FailureCause> cause;
109 
110  };
111 
112 
117  public:
119 
120  };
121 
122 
123  /***********************/
125  /***********************/
126 };
127 
128 #endif //WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H
std::shared_ptr< StandardJobExecutor > executor
The standard job executor that has ailed to complete the standard job.
Definition: StandardJobExecutorMessage.h:104
std::shared_ptr< FailureCause > cause
The cause of the failure.
Definition: StandardJobExecutorMessage.h:108
std::string name
The message name.
Definition: SimulationMessage.h:37
A message sent by a StandardJobExecutor to notify that its StandardJob has failed.
Definition: StandardJobExecutorMessage.h:95
std::shared_ptr< StandardJobExecutor > executor
The standard job executor that has completed the standard job.
Definition: StandardJobExecutorMessage.h:86
StandardJobExecutorMessage(std::string name, double payload)
Constructor.
Definition: StandardJobExecutorMessage.cpp:22
ComputeThreadDoneMessage()
Constructor.
Definition: StandardJobExecutorMessage.cpp:98
A message sent by a StandardJobExecutor to notify that it has completed a StandardJob.
Definition: StandardJobExecutorMessage.h:78
std::shared_ptr< WorkunitExecutor > workunit_executor
The work unit executor that has completed the work unit.
Definition: StandardJobExecutorMessage.h:50
Top-level class to describe a message communicated by processes in the simulation.
Definition: SimulationMessage.h:27
WorkunitExecutorFailedMessage(std::shared_ptr< WorkunitExecutor > workunit_executor, std::shared_ptr< Workunit > workunit, std::shared_ptr< FailureCause > cause, double payload)
Constructor.
Definition: StandardJobExecutorMessage.cpp:49
A standard (i.e., non-pilot) workflow job that can be submitted to a ComputeService by a WMS (via a J...
Definition: StandardJob.h:37
Definition: Alarm.cpp:20
double payload
The message size in bytes.
Definition: SimulationMessage.h:39
A message sent by a ComputeThread once it's done performing its computation.
Definition: StandardJobExecutorMessage.h:116
std::shared_ptr< Workunit > workunit
The work unit that has completed.
Definition: StandardJobExecutorMessage.h:52
std::shared_ptr< FailureCause > cause
The cause of the failure.
Definition: StandardJobExecutorMessage.h:71
StandardJob * job
The standard job that has failed.
Definition: StandardJobExecutorMessage.h:106
std::shared_ptr< Workunit > workunit
The work unit that has failed.
Definition: StandardJobExecutorMessage.h:69
A message sent by a WorkunitExecutor to notify that it has completed a WorkUnit.
Definition: StandardJobExecutorMessage.h:42
std::shared_ptr< WorkunitExecutor > workunit_executor
The worker unit executor that has failed to perform the work unit.
Definition: StandardJobExecutorMessage.h:67
Top-level class for messages received/sent by a StandardJobExecutor.
Definition: StandardJobExecutorMessage.h:34
StandardJobExecutorDoneMessage(StandardJob *job, std::shared_ptr< StandardJobExecutor > executor, double payload)
Constructor.
Definition: StandardJobExecutorMessage.cpp:66
StandardJobExecutorFailedMessage(StandardJob *job, std::shared_ptr< StandardJobExecutor > executor, std::shared_ptr< FailureCause > cause, double payload)
Constructor.
Definition: StandardJobExecutorMessage.cpp:82
A message sent by a WorkunitExecutor to notify that its WorkUnit as failed.
Definition: StandardJobExecutorMessage.h:58
WorkunitExecutorDoneMessage(std::shared_ptr< WorkunitExecutor > workunit_executor, std::shared_ptr< Workunit > workunit, double payload)
Constructor.
Definition: StandardJobExecutorMessage.cpp:33
StandardJob * job
The standard job that has completed.
Definition: StandardJobExecutorMessage.h:88