ComputeThread.h
1 
11 #ifndef WRENCH_COMPUTETHREADTEST_H
12 #define WRENCH_COMPUTETHREADTEST_H
13 
14 #include <wrench/simgrid_S4U_util/S4U_Mailbox.h>
15 #include "wrench/simgrid_S4U_util/S4U_Simulation.h"
16 #include "helper_services/standard_job_executor/StandardJobExecutorMessage.h"
17 
18 
19 namespace wrench {
20 
21  /***********************/
23  /***********************/
24 
25  class Simulation;
26 
32  class ComputeThread : public Service {
33 
34  public:
35 
36  ComputeThread(std::string hostname, double flops, std::string reply_mailbox);
37 
38  int main() override;
39 
40  void cleanup(bool has_returned_from_main, int return_value) override;
41 
42  void kill();
43 
44  private:
45  double flops;
46  std::string reply_mailbox;
47 
48  };
49 
50  /***********************/
52  /***********************/
53 };
54 
55 #endif //WRENCH_COMPUTETHREADTEST_H
ComputeThread(std::string hostname, double flops, std::string reply_mailbox)
Constructor.
Definition: ComputeThread.cpp:26
Definition: Alarm.cpp:20
int main() override
The main method of the compute thread.
Definition: ComputeThread.cpp:37
void cleanup(bool has_returned_from_main, int return_value) override
Cleanup method that overrides the base method and does nothing as a compute thread does not need to i...
Definition: ComputeThread.cpp:63
std::string hostname
The name of the host on which the daemon is running.
Definition: S4U_Daemon.h:51
A one-shot service that simulates a CPU-bound thread that performs a given number of flops and then r...
Definition: ComputeThread.h:32
void kill()
Terminate (brutally) the compute thread.
Definition: ComputeThread.cpp:52
A service that can be added to the simulation and that can be used by a WMS when executing a workflow...
Definition: Service.h:26