blob: 1ad5f7910348d4d802d52db0b6ab47975e7b5178 (
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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
|
// $Id$
// ============================================================================
//
// = FILENAME
// DualEC_Sup.h
//
// = DESCRIPTION
// Event supplier for visualization of scheduling behavior, using
// arrival and dispatch data logged by an EC dispatch command object
//
// = AUTHOR
// Chris Gill (cdgill@cs.wustl.edu)
//
// Adapted from the orginal DOVE simulation event supplier written by
// Michael Kircher (mk1@cs.wustl.edu)
//
// ============================================================================
#ifndef DUALEC_SUP_H
#define DUALEC_SUP_H
//#include <ctype.h>
//#include <stdio.h>
#include "tao/corba.h"
#include "orbsvcs/RtecEventChannelAdminC.h"
#include "orbsvcs/RtecEventCommS.h"
#include "orbsvcs/Event_Utilities.h"
#include "orbsvcs/Event_Service_Constants.h"
#include "orbsvcs/Scheduler_Factory.h"
#include "orbsvcs/Event/Module_Factory.h"
#include "orbsvcs/Event/Event_Channel.h"
#include "NavWeapC.h"
#include "NavWeapS.h"
#include "DOVE_Supplier.h"
struct Schedule_Viewer_Data
{
char operation_name [BUFSIZ];
double utilitzation;
double overhead;
u_long arrival_time;
u_long deadline_time;
u_long completion_time;
u_long computation_time;
};
class DualEC_Supplier
{
// = TITLE
// Event Supplier.
//
// = DESCRIPTION
// Reads information out of a file and
// feeds it with additional navigation and
// weapon data into the dove_supplier, which
// is connected to the event channel
public:
DualEC_Supplier (int argc, char** argv);
~DualEC_Supplier (void);
int init (void);
// Initialize: set up, resolve ORB services,
// connect the DOVE_Suppliers.
void compute_schedules (void);
// Compute schedule priorities, possibly dump
// data into runtime scheduler header files.
void start_generating_events (void);
// here is really something going on,
// here we deliver the messages
void load_schedule_data ();
// Load the scheduling information into memory
private:
class Terminator : public POA_NavWeapTerminator
// = DESCRIPTION
// Private class that implements a termination servant.
{
void shutdown (CORBA::Environment &_env);
};
static void * run_orb (void *);
// Run the orb event loop.
static void * run_nav_thread (void *arg);
// Run navigation event generation thread.
static void * run_weap_thread (void *arg);
// Run weapons event generation thread.
int create_schedulers (void);
// Create two scheduling service instances, registers
// them with the Naming Service.
int create_event_channels (void);
// Create two event service instances, registers
// them with the Naming Service.
unsigned int get_options (int argc, char *argv []);
// Get command line options.
// Time values to pause before notifying the supplier each time.
ACE_Time_Value nav_pause_;
ACE_Time_Value weap_pause_;
// POA client references.
PortableServer::POA_var root_POA_var_;
PortableServer::POAManager_var poa_manager_;
// Naming Service client reference and names to use.
CosNaming::NamingContext_var naming_context_;
CosNaming::Name channel_hi_name_;
CosNaming::Name channel_lo_name_;
CosNaming::Name sched_hi_name_;
CosNaming::Name sched_lo_name_;
// Scheduling Service servant implementation pointers.
POA_RtecScheduler::Scheduler * sched_hi_impl_;
POA_RtecScheduler::Scheduler * sched_lo_impl_;
// Scheduling Service client references.
RtecScheduler::Scheduler_var sched_hi_;
RtecScheduler::Scheduler_var sched_lo_;
// Handles for the dummy rt_infos registered with the
// schedulers in order to force priority differentiation.
RtecScheduler::handle_t sched_hi_rt_info_hi_;
RtecScheduler::handle_t sched_hi_rt_info_lo_;
RtecScheduler::handle_t sched_lo_rt_info_hi_;
RtecScheduler::handle_t sched_lo_rt_info_lo_;
// Termination servant implementation and client reference
Terminator terminator_impl_;
NavWeapTerminator_var terminator_;
// Default EC module factory for Event
// Service servant implementations.
TAO_Default_Module_Factory default_module_factory_;
// Event Service servant implementation pointers.
POA_RtecEventChannelAdmin::EventChannel *ec_hi_impl_;
POA_RtecEventChannelAdmin::EventChannel *ec_lo_impl_;
// Event Service client references.
RtecEventChannelAdmin::EventChannel_var ec_hi_;
RtecEventChannelAdmin::EventChannel_var ec_lo_;
DOVE_Supplier weapons_Supplier_;
DOVE_Supplier navigation_Supplier_;
// Data for registering RT_Infos
ACE_Scheduler_Factory::POD_RT_Info rt_info_nav_hi_;
ACE_Scheduler_Factory::POD_RT_Info rt_info_nav_lo_;
ACE_Scheduler_Factory::POD_RT_Info rt_info_weap_hi_;
ACE_Scheduler_Factory::POD_RT_Info rt_info_weap_lo_;
ACE_Scheduler_Factory::POD_RT_Info rt_info_dummy_hi_;
ACE_Scheduler_Factory::POD_RT_Info rt_info_dummy_lo_;
// References for CORBA RtecScheduler data structures
RtecScheduler::RT_Info_Set_var infos_hi_;
RtecScheduler::Config_Info_Set_var configs_hi_;
RtecScheduler::Scheduling_Anomaly_Set_var anomalies_hi_;
RtecScheduler::RT_Info_Set_var infos_lo_;
RtecScheduler::Config_Info_Set_var configs_lo_;
RtecScheduler::Scheduling_Anomaly_Set_var anomalies_lo_;
// Queues to store event carried data structures.
ACE_Unbounded_Queue<Navigation *> navigation_data_;
ACE_Unbounded_Queue<Weapons *> weapons_data_;
int argc_;
char **argv_;
long total_messages_;
long break_count_;
char *input_file_name_;
unsigned long update_data_;
int dump_schedule_headers_;
int use_runtime_schedulers_;
int suppress_priority_;
const char * hi_schedule_file_name_;
const char * lo_schedule_file_name_;
CORBA::Long nav_roll_;
CORBA::Long nav_pitch_;
};
#endif /* DUALEC_SUP_H */
|
