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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file TkReactor.h
*
* $Id$
*
* @author Nagarajan Surendran <naga@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACE_TKREACTOR_H
#define ACE_TKREACTOR_H
#include "ace/pre.h"
#include "ace/Select_Reactor.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_TK)
#include <tk.h>
/**
* @class ACE_TkReactorID
*
* @brief This little class is necessary due to the way that Microsoft
* implements sockets to be pointers rather than indices.
*/
class ACE_Export ACE_TkReactorID
{
public:
/// Underlying handle.
ACE_HANDLE handle_;
/// Pointer to next node in the linked list.
ACE_TkReactorID *next_;
};
class ACE_TkReactor;
class ACE_Export ACE_TkReactor_Input_Callback
{
public:
ACE_TkReactor *reactor_;
ACE_HANDLE handle_;
};
/**
* @class ACE_TkReactor
*
* @brief An object-oriented event demultiplexor and event handler
* dispatcher that uses the Tk functions.
*/
class ACE_Export ACE_TkReactor : public ACE_Select_Reactor
{
public:
// = Initialization and termination methods.
ACE_TkReactor (size_t size = DEFAULT_SIZE,
int restart = 0,
ACE_Sig_Handler * = 0);
virtual ~ACE_TkReactor (void);
// = Timer operations.
virtual long schedule_timer (ACE_Event_Handler *handler,
const void *arg,
const ACE_Time_Value &delta_time,
const ACE_Time_Value &interval);
virtual int reset_timer_interval (long timer_id,
const ACE_Time_Value &interval);
virtual int cancel_timer (ACE_Event_Handler *handler,
int dont_call_handle_close = 1);
virtual int cancel_timer (long timer_id,
const void **arg = 0,
int dont_call_handle_close = 1);
protected:
// = Register timers/handles with Tk.
/// Register a single <handler>.
virtual int register_handler_i (ACE_HANDLE handle,
ACE_Event_Handler *handler,
ACE_Reactor_Mask mask);
/// Register a set of <handlers>.
virtual int register_handler_i (const ACE_Handle_Set &handles,
ACE_Event_Handler *handler,
ACE_Reactor_Mask mask);
/// Remove the <handler> associated with this <handle>.
virtual int remove_handler_i (ACE_HANDLE handle,
ACE_Reactor_Mask mask);
/// Remove a set of <handles>.
virtual int remove_handler_i (const ACE_Handle_Set &handles,
ACE_Reactor_Mask);
/// Removes an Tk FileHandler.
virtual void remove_TkFileHandler (ACE_HANDLE handle);
/// Wait for events to occur.
virtual int wait_for_multiple_events (ACE_Select_Reactor_Handle_Set &,
ACE_Time_Value *);
///Wait for Tk events to occur.
virtual int TkWaitForMultipleEvents (int,
ACE_Select_Reactor_Handle_Set &,
ACE_Time_Value *);
ACE_TkReactorID *ids_;
Tk_TimerToken timeout_;
private:
/// This method ensures there's a Tk timeout for the first timeout in
/// the Reactor's Timer_Queue.
void reset_timeout (void);
// = Integrate with the X callback function mechanism.
static void TimerCallbackProc (ClientData cd);
static void InputCallbackProc (ClientData cd,int mask);
/// Deny access since member-wise won't work...
ACE_TkReactor (const ACE_TkReactor &);
ACE_TkReactor &operator = (const ACE_TkReactor &);
};
#endif /* ACE_HAS_TK */
#include "ace/post.h"
#endif /* ACE_TK_REACTOR_H */
|
