blob: 0079d0e256ee9da2e291c2ffb0d521cc245d0fa0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
#ifndef THREAD_TASK_H
#define THREAD_TASK_H
#include "JobC.h"
#include "rtschedtestlib_export.h"
#include "tao/RTScheduling/RTScheduler.h"
#include "ace/Task.h"
class Task_Stats;
class DT_Creator;
class RTSCHEDTESTLIB_Export Thread_Task : public ACE_Task <ACE_SYNCH>
{
public:
Thread_Task (void);
virtual int activate_task (RTScheduling::Current_ptr current,
CORBA::Policy_ptr sched_param,
long flags,
ACE_Time_Value* base_time) = 0;
virtual int perform_task (void);
int importance (void);
time_t start_time (void);
/// = Job get/set
/// Returns the name of the Job exec'ed by this Task.
const char* job (void);
/// Sets the Job to exec.
void job (Job_ptr job);
int dist (void);
void dump_stats (void);
protected:
/// task svc
virtual int svc ();
RTScheduling::Current_var current_;
CORBA::Policy_var sched_param_;
time_t start_time_;
int load_;
int iter_;
size_t count_;
int importance_;
DT_Creator *dt_creator_;
//Task *task_;
ACE_Time_Value* base_time_;
int dist_;
CORBA::String_var job_name_;
Job_var job_;
Task_Stats *task_stats_;
};
#endif /* THREAD_TASK_H */
|
