blob: 8cf276d14465132298a04c7ffe15dede586d84e9 (
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
61
62
63
|
//$Id$
#ifndef DT_CREATOR_H
#define DT_CREATOR_H
#include "ace/Service_Config.h"
#include "ace/Service_Object.h"
#include "tao/RTScheduling/RTScheduler.h"
class Thread_Task;
class Task;
typedef Thread_Task **DT_LIST;
class DT_Creator : public ACE_Service_Object
{
public:
~DT_Creator (void);
int init (int argc, char *argv []);
virtual void create_distributable_threads (CORBA::ORB_ptr orb,
RTScheduling::Current_ptr current
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
virtual void yield (int suspend_time,
Thread_Task* task) = 0;
virtual CORBA::Policy_ptr sched_param (int importance) = 0;
virtual Thread_Task* create_thr_task (int importance,
int start_time,
int load) = 0;
// virtual Task* task (void) = 0;
int dt_count (void);
void dt_ended (void);
void check_ifexit (void);
void log_msg (char* msg);
CORBA::ORB_ptr orb (void);
protected:
DT_LIST dt_list_;
//Fixed_Priority_Scheduler* scheduler_;
ACE_Barrier* barrier_;
int dt_count_;
CORBA::ORB_var orb_;
/// Mutex to serialize access to our internal state.
ACE_Lock* state_lock_;
ACE_Lock* shutdown_lock_;
int active_dt_count_;
char** log;
ACE_Time_Value* base_time_;
RTScheduling::Current_var current_;
};
#endif /*DT_CREATOR_H*/
|
