blob: 34582c21a3279e55f1fdc91af295decf82d426a6 (
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Activity.h
*
* An activity is a process that contains Tasks.
* Each Task is composed of certain units of Jobs.
* A Job can perform work that is local/remote.
* Each Job is identified with a name.
*
* @author Pradeep Gore <pradeep@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACTIVITY_H
#define ACTIVITY_H
#include "ace/Singleton.h"
#include "ace/Sched_Params.h"
#include "orbsvcs/CosNamingC.h"
#include "tao/RTPortableServer/RTPortableServer.h"
#include "tao/RTCORBA/Priority_Mapping_Manager.h"
#include "ace/Null_Mutex.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ACE_Barrier;
ACE_END_VERSIONED_NAMESPACE_DECL
class Job_i;
class Periodic_Task;
class Builder;
/**
* @class Activity
*
* @brief Driver class that maintains the orb and collections of objects for
* generating activity in this process.
*/
class Activity
{
friend class ACE_Singleton<Activity, ACE_Null_Mutex>;
private:
Activity ();
~Activity ();
public:
/// initialize the ORB et. al.
int init (int& argc, ACE_TCHAR *argv []);
/// Activate the tasks, jobs, poas.
void run (int argc, ACE_TCHAR *argv[]);
/// Resolve the naming service.
int resolve_naming_service ();
/// = Accessors
CORBA::ORB_ptr orb ();
RTCORBA::Current_ptr current ();
void builder (Builder* builder);
/// Returns priority if server declared model else -1
CORBA::Short get_server_priority (CORBA::Object_ptr server);
/// = Callbacks
/// Task ended notification
void task_ended (Periodic_Task* ended_task);
/// Job shutdown notification
void job_ended (Job_i* ended_job);
protected:
/// = Activation methods.
/// Activate the POA's
void activate_poa_list ();
/// Activate the task list.
void activate_schedule ();
/// Activate the Job's
void activate_job_list ();
/// Check if we should process exit
void check_ifexit ();
/// Create a file whose name is specified in the -Started_Flag <file_name> argument at startup.
/// This file flags that the Activity has finished its bootstrapping step.
void create_started_flag_file (int argc, ACE_TCHAR *argv[]);
/// = Data members
/// The Builder object.
Builder* builder_;
/// ACE_Barrier to synch. tasks.
ACE_Barrier* barrier_;
/// Mutex to serialize access to our internal state.
ACE_Lock* state_lock_;
/// The ORB that we use.
CORBA::ORB_var orb_;
/// RT ORB
RTCORBA::RTORB_var rt_orb_;
/// Current
RTCORBA::Current_var current_;
/// Reference to the root poa.
PortableServer::POA_var root_poa_;
/// A naming context.
CosNaming::NamingContextExt_ptr naming_;
/// The Priority Mapping helper.
RTCORBA::PriorityMapping *priority_mapping_;
/// Count the number of periodic tasks active.
int active_task_count_;
/// Count the number of Jobs active
int active_job_count_;
};
typedef ACE_Singleton<Activity, ACE_Null_Mutex> ACTIVITY;
#endif /* ACTIVITY_H */
|
