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
|
// $Id$
// ================================================================
//
// = LIBRARY
// examples/Reactor/Misc/
//
// = FILENAME
// test_early_timeouts.cpp
//
// = DESCRIPTION
// On some platforms, select() returns before the time value
// specified. This tests counts the number of times this happens
// and the max early timeout.
//
// = AUTHOR
// Irfan Pyarali
//
// ================================================================
#include "ace/Handle_Set.h"
#include "ace/Pipe.h"
ACE_RCSID(Misc, test_early_timeouts, "$Id$")
int
main (int, char *[])
{
// Mumber of seconds this test should run
int runtime_in_seconds = 10;
// Iterations
int iterations = runtime_in_seconds * 10;
// 100 millisecond timeout
ACE_Time_Value timeout (0, 100000);
// Time before starting select
ACE_Time_Value starting_time_of_day;
// Time before starting select
ACE_Time_Value ending_time_of_day;
// Number of times the timer expired early
int no_of_early_timers = 0;
// Maximum early timeout
ACE_Time_Value maximum_early_timeout;
//
// Dummy handle and handle set
// Note that some OS do not like "empty selects"
//
// Dummy handle set
ACE_Handle_Set dummy_handle_set;
// Dummy pipe
ACE_Pipe dummy_pipe;
int result = dummy_pipe.open ();
ACE_ASSERT (result == 0);
ACE_UNUSED_ARG (result); // To avoid compile warning with ACE_NDEBUG.
for (int i = 1; i <= iterations; i++)
{
// Add dummy handle to dummy set
dummy_handle_set.set_bit (dummy_pipe.read_handle ());
// Note the time before select
starting_time_of_day = ACE_OS::gettimeofday ();
// Wait for timeout
result = ACE_OS::select ((int) dummy_pipe.read_handle (), dummy_handle_set, 0, 0, &timeout);
ACE_ASSERT (result == 0);
// Note the time after select
ending_time_of_day = ACE_OS::gettimeofday ();
// Expected ending time
ACE_Time_Value expected_ending_time_of_day =
starting_time_of_day + timeout;
// If the timer expired early
if (ending_time_of_day < expected_ending_time_of_day)
{
// How early
ACE_Time_Value early_timeout = expected_ending_time_of_day - ending_time_of_day;
// Increment number of early timers
no_of_early_timers++;
// Check max early timeout
if (early_timeout > maximum_early_timeout)
{
maximum_early_timeout = early_timeout;
}
}
}
ACE_DEBUG ((LM_DEBUG,
"There were %d early timers out of %d calls to select() (%f%%)\n"
"The max early timeout was: %dsec %dusec\n",
no_of_early_timers,
iterations,
float (no_of_early_timers) / iterations * 100,
maximum_early_timeout.sec (),
maximum_early_timeout.usec ()));
return 0;
}
|
