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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// examples
//
// = FILENAME
// Thread_Timer_Queue_Test.h
//
// = DESCRIPTION
// This code exercises the <ACE_Thread_Timer_Queue_Adapter> using
// an <ACE_Timer_Heap_T>
//
// = AUTHORS
// Carlos O'Ryan <coryan@cs.wustl.edu> and
// Sergio Flores-Gaitan <sergio@cs.wustl.edu>
//
// ============================================================================
#if !defined (_THREAD_TIMER_QUEUE_TEST_H_)
#define _THREAD_TIMER_QUEUE_TEST_H_
#include "ace/Task.h"
#include "ace/Timer_Heap_T.h"
#include "ace/Timer_Queue_Adapters.h"
#include "Driver.h"
// These typedefs ensure that we use the minimal amount of locking
// necessary.
typedef ACE_Event_Handler_Handle_Timeout_Upcall<ACE_Null_Mutex>
Upcall;
typedef ACE_Timer_Heap_T<ACE_Event_Handler *,
Upcall,
ACE_Null_Mutex>
Timer_Heap;
typedef ACE_Timer_Heap_Iterator_T<ACE_Event_Handler *,
Upcall,
ACE_Null_Mutex>
Timer_Heap_Iterator;
typedef ACE_Thread_Timer_Queue_Adapter<Timer_Heap>
Thread_Timer_Queue;
// Forward declaration
class Thread_Timer_Queue_Test_Driver;
class Input_Task : public ACE_Task_Base
// = TITLE
// Read user actions on the Timer_Queue from stdin.
//
// = DESCRIPTION
// This class reads user input from stdin; those commands permit
// the control of a Timer_Queue, which is dispatched by another
// thread.
{
public:
typedef int (Input_Task::*ACTION) (void *);
Input_Task (Thread_Timer_Queue *queue,
Thread_Timer_Queue_Test_Driver &timer_queue_driver);
virtual int svc (void);
// This method runs the event loop in the new thread.
// = Some helper methods.
int add_timer (void *);
// Add a new timer to expire in <seconds> more.
int cancel_timer (void *);
// Cancel timer <id>.
int list_timer (void *);
// List the current scheduled timers.
int shutdown_timer (void *);
// Shutdown task.
void dump (void);
// Dump the state of the timer queue.
private:
Thread_Timer_Queue *queue_;
// The timer queue implementation.
const int usecs_;
// How many micro seconds are in a second.
Timer_Queue_Test_Driver<Thread_Timer_Queue, Input_Task, Input_Task::ACTION> &driver_;
// The thread timer queue test driver
};
class Thread_Timer_Queue_Test_Driver : public Timer_Queue_Test_Driver <Thread_Timer_Queue, Input_Task, Input_Task::ACTION>
// = TITLE
// Implements an example application that exercises <Thread_Timer_Queue>
// timer queue.
//
// = DESCRIPTION
// This class implements a simple test driver for the
// <Thread_Timer_Queue>. The <display_menu> hook method is
// called from the base class to print a menu specific to the
// thread implementation of the timer queue.
{
public:
Thread_Timer_Queue_Test_Driver (void);
~Thread_Timer_Queue_Test_Driver (void);
virtual int display_menu (void);
virtual int init (void);
virtual int run_test (void);
private:
Input_Task input_task_;
// Subclassed from ACE_Task.
};
class Handler : public ACE_Event_Handler
// = TITLE
// Event handler for the timer queue timeout events.
//
// = DESCRIPTION
// The <handle_timeout> hook method prints out the current
// time, prints the time when this timer expired and deletes "this".
{
public:
Handler (const ACE_Time_Value &expiration_time);
~Handler (void);
void set_id (int id);
// Store an "id" for the Handler, which is only use to print better
// messages.
virtual int handle_timeout (const ACE_Time_Value ¤t_time,
const void *arg);
// Call back hook.
virtual int cancelled (void);
private:
ACE_Time_Value expires_;
// Store the expected time of expiration, it is used to print a nice
// message saying how much delay was at the actual expiration time.
int id_;
// Store an "id" for the Handler, which is only use to print better
// messages.
};
#endif /* _THREAD_TIMER_QUEUE_TEST_H_ */
|
