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
|
// $Id$
//==============================================================
/**
* @file client.cpp
*
* This is a simple client test program that interact with the RoundTrip
* component implementation. The single threaded client issues
* two-way operations, the total latency (response time) is measured
* NOTE: this client implementation has been adapted from the
* $TAO_ROOT/performance-results/Latency/Single_Threaded/
*
* @author Arvind S. Krishna <arvindk@dre.vanderbilt.edu>
*/
//==============================================================
#include "RoundTripC.h"
#include "ace/Get_Opt.h"
#include "ace/High_Res_Timer.h"
#include "ace/Sched_Params.h"
#include "ace/Stats.h"
#include "ace/Sample_History.h"
#include "ace/OS_NS_errno.h"
#include "ace/Throughput_Stats.h"
const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
int niterations = 100;
int do_dump_history = 0;
int
parse_args (int argc, ACE_TCHAR *argv[])
{
// Parse arguments.
ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("hxk:i:"));
int c;
while ((c = get_opts ()) != -1)
switch (c)
{
case 'h':
do_dump_history = 1;
break;
case 'k':
ior = get_opts.opt_arg ();
break;
case 'i':
niterations = ACE_OS::atoi (get_opts.opt_arg ());
break;
case '?':
default:
/* Could be any other parameter like -ORBSvcConf file so ignore */
break;
}
// Indicates sucessful parsing of the command line
return 0;
}
void
set_priority ()
{
int priority =
(ACE_Sched_Params::priority_min (ACE_SCHED_FIFO)
+ ACE_Sched_Params::priority_max (ACE_SCHED_FIFO)) / 2;
// Enable FIFO scheduling, e.g., RT scheduling class on Solaris.
if (ACE_OS::sched_params (ACE_Sched_Params (ACE_SCHED_FIFO,
priority,
ACE_SCOPE_PROCESS)) != 0)
{
if (ACE_OS::last_error () == EPERM)
{
ACE_DEBUG ((LM_DEBUG,
"client (%P|%t): user is not superuser, "
"test runs in time-shared class\n"));
}
else
ACE_ERROR ((LM_ERROR,
"client (%P|%t): sched_params failed\n"));
}
}
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
try
{
// Set priority on the platform
set_priority();
// Initialize orb
CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
if (parse_args(argc, argv) == -1)
{
ACE_DEBUG ((LM_DEBUG, "Error parsing Arguments\n"));
return -1;
}
// Resolve HomeFinder interface
CORBA::Object_var obj
= orb->string_to_object (ior);
Benchmark::RoundTripHome_var home
= Benchmark::RoundTripHome::_narrow (obj.in ());
if (CORBA::is_nil (home.in ()))
ACE_ERROR_RETURN ((LM_ERROR, "Unable to acquire TestHome objref\n"), -1);
Benchmark::RoundTrip_var test = home->create ();
// Get the RoundTrip reference
obj = test->provide_facet ("latency");
Benchmark::LatencyTest_var round_trip =
Benchmark::LatencyTest::_narrow (obj.in ());
if (CORBA::is_nil (round_trip.in ()))
ACE_ERROR_RETURN ((LM_ERROR, "Unable to acquire LatencyTest objref\n"), -1);
// Warmup the System by making some empty calls
for (int j = 0; j < 100; ++j)
{
round_trip->makeCall (0L);
}
///// Start Test ////////////////////////////////////////////
ACE_Sample_History history (niterations);
ACE_hrtime_t test_start = ACE_OS::gethrtime ();
for (int i = 0; i < niterations; ++i)
{
ACE_hrtime_t start = ACE_OS::gethrtime ();
//Test value to be sent to the server
long test = 0;
(void) round_trip->makeCall (test);
ACE_hrtime_t now = ACE_OS::gethrtime ();
history.sample (now - start);
}
ACE_hrtime_t test_end = ACE_OS::gethrtime ();
ACE_DEBUG ((LM_DEBUG, "test finished\n"));
ACE_DEBUG ((LM_DEBUG, "High resolution timer calibration...."));
ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor ();
ACE_DEBUG ((LM_DEBUG, "done\n"));
if (do_dump_history)
{
history.dump_samples (ACE_TEXT("HISTORY"), gsf);
}
ACE_Basic_Stats stats;
history.collect_basic_stats (stats);
stats.dump_results (ACE_TEXT("Total"), gsf);
ACE_Throughput_Stats::dump_throughput (ACE_TEXT("Total"), gsf,
test_end - test_start,
stats.samples_count ());
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Exception Handled:");
return 1;
}
return 0;
}
|
