blob: f959bdbc9a0c1f1ab180c476c2721db55c351ca5 (
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
|
//=============================================================================
/**
* @file Logging_Sup.h
*
* 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 LOGGING_SUP_H
#define LOGGING_SUP_H
//#include <ctype.h>
//#include <stdio.h>
#include "NavWeapC.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 Logging_Supplier
*
* @brief Event Supplier.
*
* Reads Scheduler 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
*/
class Logging_Supplier
{
public:
Logging_Supplier (int argc, ACE_TCHAR** argv);
~Logging_Supplier (void);
/// connect the DOVE_Supplier
int init (void);
/// here is really something going on,
/// here we deliver the messages
void start_generating_events (void);
/// Load the scheduling information into memory
void load_schedule_data (ACE_Unbounded_Queue<Schedule_Viewer_Data *> &schedule_data);
private:
/// just a helper to put all the information into the CORBA::Any
void insert_event_data (CORBA::Any &data,
ACE_Unbounded_Queue_Iterator<Schedule_Viewer_Data *> &schedule_iter);
unsigned int get_options (int argc, ACE_TCHAR *argv []);
DOVE_Supplier dOVE_Supplier_;
Navigation navigation_;
Weapons weapons_;
int argc_;
ACE_TCHAR **argv_;
unsigned long total_messages_;
ACE_TCHAR *input_file_name_;
unsigned long update_data_;
const ACE_TCHAR* schedule_file_name_;
};
#endif /* LOGGING_SUP_H */
|
