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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// examples
//
// = FILENAME
// Driver.h
//
// = DESCRIPTION
// This code builds an abstraction to factor out common code for
// the different implementations of the Timer_Queue.
//
// = AUTHORS
// Sergio Flores-Gaitan <sergio@cs.wustl.edu>
//
// ============================================================================
#if !defined (_DRIVER_H_)
#define _DRIVER_H_
#include "ace/Task.h"
#include "ace/Timer_Heap_T.h"
#include "ace/Timer_Queue_Adapters.h"
template <class RECEIVER, class ACTION>
class Command
// = TITLE
// Defines an abstract class that allows us to invoke commands
// without knowing anything about the implementation. This class
// is used in the <Timer_Queue_Test_Driver> to invoke operations
// of the driver.
//
// = DESCRIPTION
// This class declares an interface to execute operations,
// binding a RECEIVER object with an ACTION. The RECEIVER knows
// how to implement the operation. A class can invoke operations
// without knowing anything about it, or how it was implemented.
{
public:
Command (RECEIVER &recvr, ACTION action);
// Sets the <receiver_> of the Command to recvr, and the
// <action_> of the Command to <action>.
virtual int execute (void *arg);
// Invokes the method <action_> from the object <receiver_>.
private:
RECEIVER &receiver_;
// object where the method resides.
ACTION action_;
// method that is going to be invoked.
};
template <class TQ, class RECEIVER, class ACTION>
class Timer_Queue_Test_Driver
// = TITLE
// Defines a class that provides a simmple implementation for
// a test driver for timer queues.
//
// = DESCRIPTION
// This is the place where the common code to test the different
// implementations of the timer queue resides. This class has
// the logic for the parse_commands() method, the run_test(),
// read_input() and the get_next_request(). Subclasses can
// override these methods if there is some logic that is specific
// to that implementation.
{
public:
virtual int parse_commands (const char *buf);
// Breaks up the input string buffer into pieces and executes
// the appropriate method to handle that operation.
virtual int run_test (void);
// This is the main entry point to the test driver. The user
// of the class should normally invoke this method.
// Returns 0 when successful, or 0 otherwise.
virtual int get_next_request (void);
// This internal method gets the next request from the user.
// Returns -1 when user wants to exit. Returns 0 otherwise.
virtual ssize_t read_input (char *buf, size_t bufsiz);
// Reads input from the user into the buffer <buf> with a maximum
// of <bufsiz> bytes. Returns the amount of bytes actually read
// Otherwise, a -1 is returned and errno is set to indicate the error.
// = Template Methods.
virtual int display_menu (void)=0;
// Prints the user interface for the driver to STDOUT.
virtual int init (void)=0;
// Initializes values and operations for the driver.
protected:
TQ timer_queue_;
// timer queue
// = Set of <Command>s to be executed.
Command<RECEIVER, ACTION> *schedule_cmd_;
// schedule timer command
Command<RECEIVER, ACTION> *cancel_cmd_;
// cancel timer command.
Command<RECEIVER, ACTION> *list_cmd_;
// list timers command.
Command<RECEIVER, ACTION> *shutdown_cmd_;
// shutdown the driver.
};
#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "Driver.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
#pragma implementation ("Driver.cpp")
#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
#endif /* _DRIVER_H_ */
|
