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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// XtReactor.h
//
// = AUTHOR
// Eric C. Newton's <ecn@clark.net>,
// Kirill Rybaltchenko <Kirill.Rybaltchenko@cern.ch>, and
// Douglas C. Schmidt <schmidt@cs.wustl.edu>
//
// ============================================================================
#ifndef ACE_XTREACTOR_H
#define ACE_XTREACTOR_H
#include "ace/Select_Reactor.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_XT)
//#define String XtString
#include /**/ <X11/Intrinsic.h>
//#undef String
class ACE_Export ACE_XtReactorID
{
// = TITLE
// This little class is necessary due to the way that Microsoft
// implements sockets to be pointers rather than indices.
public:
XtInputId id_;
// Magic cookie.
ACE_HANDLE handle_;
// Underlying handle.
ACE_XtReactorID *next_;
// Pointer to next node in the linked list.
};
class ACE_Export ACE_XtReactor : public ACE_Select_Reactor
{
// = TITLE
// An object-oriented event demultiplexor and event handler
// dispatcher that uses the X Toolkit functions.
public:
// = Initialization and termination methods.
ACE_XtReactor (XtAppContext context = 0,
size_t size = DEFAULT_SIZE,
int restart = 0,
ACE_Sig_Handler * = 0);
virtual ~ACE_XtReactor (void);
XtAppContext context (void) const;
void context (XtAppContext);
// = 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 Xt.
virtual int register_handler_i (ACE_HANDLE handle,
ACE_Event_Handler *handler,
ACE_Reactor_Mask mask);
// Register a single <handler>.
virtual int register_handler_i (const ACE_Handle_Set &handles,
ACE_Event_Handler *handler,
ACE_Reactor_Mask mask);
// Register a set of <handlers>.
virtual int remove_handler_i (ACE_HANDLE handle,
ACE_Reactor_Mask mask);
// Remove the <handler> associated with this <handle>.
virtual int remove_handler_i (const ACE_Handle_Set &handles,
ACE_Reactor_Mask);
// Remove a set of <handles>.
virtual void remove_XtInput (ACE_HANDLE handle);
// Removes an Xt handle.
virtual int wait_for_multiple_events (ACE_Select_Reactor_Handle_Set &,
ACE_Time_Value *);
// Wait for events to occur.
virtual int XtWaitForMultipleEvents (int,
ACE_Select_Reactor_Handle_Set &,
ACE_Time_Value *);
//Wait for Xt events to occur.
XtAppContext context_;
ACE_XtReactorID *ids_;
XtIntervalId timeout_;
private:
void reset_timeout (void);
// This method ensures there's an Xt timeout for the first timeout
// in the Reactor's Timer_Queue.
// = Integrate with the X callback function mechanism.
static void TimerCallbackProc (XtPointer closure, XtIntervalId *id);
static void InputCallbackProc (XtPointer closure, int* source, XtInputId *id);
ACE_XtReactor (const ACE_XtReactor &);
ACE_XtReactor &operator = (const ACE_XtReactor &);
// Deny access since member-wise won't work...
};
#endif /* ACE_HAS_XT */
#endif /* ACE_XTREACTOR_H */
|
