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
|
// -*- C++ -*-
// $Id$
// TAO Load Balancer test client
#include "HasherC.h"
#include "ace/Get_Opt.h"
#include "ace/Stats.h"
#include "ace/High_Res_Timer.h"
static void run_test (int iterations,
int timeout,
Hasher_ptr hasher,
CORBA::Environment &ACE_TRY_ENV);
int
main (int argc, char *argv[])
{
ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
// Initialize ORB.
CORBA::ORB_var orb =
CORBA::ORB_init (argc, argv, "", ACE_TRY_ENV);
ACE_TRY_CHECK;
const char *ior = "file://test.ior";
long timeout = 50; // timeout in msecs
long iterations = 10000; // iterations
// Parse the application options after the ORB has been
// initialized.
ACE_Get_Opt options (argc, argv, "k:t:i:");
int c = 0;
while ((c = options ()) != -1)
switch (c)
{
case 'k':
ior = options.optarg;
break;
case 't':
timeout = ACE_OS::atoi (options.optarg);
break;
case 'i':
iterations = ACE_OS::atoi (options.optarg);
break;
default:
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("Usage: %s ")
ACE_TEXT ("[-k ReplicaIOR] ")
ACE_TEXT ("[-t timeout (msecs)] ")
ACE_TEXT ("[-i iterations] ")
ACE_TEXT ("\n"),
argv[0]),
-1);
}
CORBA::Object_var obj =
orb->string_to_object (ior, ACE_TRY_ENV);
ACE_TRY_CHECK;
Hasher_var hasher =
Hasher::_unchecked_narrow (obj.in (),
ACE_TRY_ENV);
ACE_TRY_CHECK;
if (CORBA::is_nil (hasher.in ()))
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("Invalid replica IOR.\n")),
-1);
run_test (iterations, timeout, hasher.in (), ACE_TRY_ENV);
ACE_TRY_CHECK;
orb->destroy (ACE_TRY_ENV);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "SYS_EX");
}
ACE_ENDTRY;
return 0;
}
void
run_test (int iterations,
int timeout,
Hasher_ptr hasher,
CORBA::Environment &ACE_TRY_ENV)
{
ACE_Time_Value tv (0, timeout * 1000);
ACE_Throughput_Stats stats;
ACE_UINT64 test_start = ACE_OS::gethrtime ();
for (long i = 0; i != iterations; ++i)
{
ACE_UINT64 call_start = ACE_OS::gethrtime ();
hasher->do_hash ("This is a silly test", ACE_TRY_ENV);
ACE_CHECK;
ACE_UINT64 end = ACE_OS::gethrtime ();
stats.sample (end - test_start, end - call_start);
ACE_OS::sleep (tv);
}
ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor ();
stats.dump_results ("Hash Stats", gsf);
}
|
