blob: b01a1acc4b68dcb9171e414d3132cbcef55efadb (
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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/tests
//
// = FILENAME
// client.h
//
// = AUTHOR
// Andy Gokhale, Brian Mendel, Sumedh Mungee, Sergio Flores-Gaitan
// and Nagarajan Surendran.
//
// ============================================================================
#include "ace/Task.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Thread_Manager.h"
#include "ace/Get_Opt.h"
#include "ace/Sched_Params.h"
#include "cubitC.h"
#include "Task_Client.h"
#include "Util_Thread.h"
#include "Timer.h"
#if defined (CHORUS)
#include "pccTimer.h"
#endif /* CHORUS */
#if defined (VME_DRIVER)
#include <hostLib.h>
extern "C" STATUS vmeDrv (void);
extern "C" STATUS vmeDevCreate (char *);
#endif /* defined (VME_DRIVER) */
class Client_i : public virtual MT_Priority
{
// = TITLE
// Helper class implementing the Multi-Threaded Cubit client.
public:
Client_i (void);
//constructor.
~Client_i (void);
// destructor.
int init (int argc, char *argv[]);
// Initialize the state of <Client_i>.
void run (void);
// Run the tests.
int do_priority_inversion_test (void);
// Performs the priority inversion test.
int do_thread_per_rate_test (void);
// Performs the test with 4 threads each sending requests at rates
// of 20, 10, 5, and 1Hz.
int start_servant (void);
// Starts the client utilization thread.
void output_latency (void);
// output the latency results for the requests.
#if defined (VXWORKS)
void output_taskinfo (void);
// Outputs the details of this task to a file taskinfo.txt.
#endif /* VXWORKS */
private:
void init_low_priority (void);
// Sets the priority to be used for the low priority clients.
void calc_util_time (void);
// Calculate the time for one util computation.
int activate_high_client (void);
// Activates the high priority client.
int activate_low_client (void);
// Activates the low priority client.
int activate_util_thread (void);
// Activates the utilization thread.
void print_priority_inversion_stats (void);
// Prints the results of the tests.
void print_context_stats (void);
// Prints the context switch results.
void print_util_stats (void);
// Prints the utilization test results.
void print_latency_stats (void);
// Prints the latency and jitter results.
void get_context_switches (void);
// gets the number of context switches.
Client *high_priority_client_;
// Pointer to the high priority client object.
Client **low_priority_client_;
// Array to hold pointers to the low priority tasks.
ACE_High_Res_Timer timer_;
// Timer for timing the tests.
MT_Priority priority_;
// Priority helper object.
Util_Thread *util_thread_;
// Utilization thread.
ACE_Thread_Manager util_thread_manager_;
// Utilization thread manager.
ACE_timer_t util_task_duration_;
// Time for one computation of utilization thread.
Task_State *ts_;
// Pointer to task state.
ACE_Sched_Priority high_priority_;
// Priority used for the high priority client.
ACE_Sched_Priority low_priority_;
// Priority used by the low priority clients.
u_int num_low_priority_;
// Number of low priority clients
u_int num_priorities_;
// Number of priorities used.
u_int grain_;
// Granularity of the assignment of the priorities. Some OSs have
// fewer levels of priorities than we have threads in our test, so
// with this mechanism we assign priorities to groups of threads
// when there are more threads than priorities.
u_int counter_;
// counter of the number of priorities used within a grain.
char *task_id_;
// Set a task_id string starting with "@", so we are able to
// accurately count the number of context switches.
ACE_Time_Value delta_;
// elapsed time for the latency tests.
int argc_;
// number of command line arguments.
char **argv_;
// command line argument array.
ACE_Thread_Manager client_thread_manager_;
// Create a separate manager for the client. This allows the use of
// its wait () method on VxWorks, without interfering with the
// server's (global) thread manager.
u_int context_switch_;
// Stores the total number of context switches incurred by the
// program while making CORBA requests
ACE_Thread_Manager server_thread_manager_;
// Thread manager for the servant used for utilization.
#if (defined (ACE_HAS_PRUSAGE_T) || defined (ACE_HAS_GETRUSAGE)) && !defined (ACE_WIN32)
ACE_Profile_Timer timer_for_context_switch;
ACE_Profile_Timer::Rusage usage;
#endif /* (defined (ACE_HAS_PRUSAGE_T) || defined (ACE_HAS_GETRUSAGE)) && !defined (ACE_WIN32) */
};
|
