WorkunitExecutor.h
78 void runMulticoreComputation(double flops, double parallel_efficiency, bool simulate_computation_as_sleep);
91 // a reference to the job it is a part of (currently required for creating the /tmp directory in scratch space)
void kill(bool job_termination)
Kill the worker thread.
Definition: WorkunitExecutor.cpp:126
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
A simulation timestamp class for WorkflowTask failure times.
Definition: SimulationTimestampTypes.h:98
std::set< WorkflowFile * > getFilesStoredInScratch()
Retrieve the list of files stored in scratch space storage.
Definition: WorkunitExecutor.cpp:572
A class to describe a unit of work that's a sub-component of a StandardJob.
Definition: Workunit.h:35
std::shared_ptr< Workunit > workunit
The Workunit this WorkunitExecutor is supposed to perform.
Definition: WorkunitExecutor.h:63
std::string hostname
The name of the host on which the daemon is running.
Definition: S4U_Daemon.h:51
unsigned long getNumCores()
Returns the number of cores the service has been allocated.
Definition: WorkunitExecutor.cpp:556
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
StandardJob * getJob()
Retrieve the job the WorkunitExecutor is working for.
Definition: WorkunitExecutor.cpp:580
WorkunitExecutor(std::string hostname, unsigned long num_cores, double ram_utilization, std::string callback_mailbox, std::shared_ptr< Workunit > workunit, std::shared_ptr< StorageService > scratch_space, StandardJob *job, double thread_startup_overhead, bool simulate_computation_as_sleep)
Constructor.
Definition: WorkunitExecutor.cpp:52
double getMemoryUtilization()
Returns the RAM the service has been allocated.
Definition: WorkunitExecutor.cpp:564
Definition: Alarm.cpp:19