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
|
// -*- C++ -*-
//=============================================================================
/**
* @file Msg_WFMO_Reactor.h
*
* @author Beskrovny Evgeny <evgeny_beskrovny@icomverse.com>
* @author Irfan Pyarali <irfan@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACE_MSG_WFMO_REACTOR_H
#define ACE_MSG_WFMO_REACTOR_H
#include /**/ "ace/pre.h"
#include /**/ "ace/ACE_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_WIN32)
#include "ace/WFMO_Reactor.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
/**
* @class ACE_Msg_WFMO_Reactor
*
* @brief An OO event demultiplexor and event handler dispatcher for
* Win32 <MsgWaitForMultipleObjects>.
*
* The ACE_Msg_WFMO_Reactor is an OO event demultiplexor and
* event handler Reactor. It differs from ACE_WFMO_Reactor by
* its ability to react on Windows messages. It is needed when
* the task should serve also as a COM/DCOM server.
*/
class ACE_Export ACE_Msg_WFMO_Reactor : public ACE_WFMO_Reactor
{
public:
/// Initialize ACE_Msg_WFMO_Reactor with the default size.
ACE_Msg_WFMO_Reactor (ACE_Sig_Handler * = 0,
ACE_Timer_Queue * = 0);
/**
* Initialize ACE_Msg_WFMO_Reactor with size @a size. Two slots will be
* added to the @a size parameter which will store handles used for
* internal management purposes.
*/
ACE_Msg_WFMO_Reactor (size_t size,
int unused = 0,
ACE_Sig_Handler * = 0,
ACE_Timer_Queue * = 0);
/// Close down the ACE_Msg_WFMO_Reactor and release all of its resources.
virtual ~ACE_Msg_WFMO_Reactor ();
/**
* This event loop driver blocks for up to @a max_wait_time before
* returning. It will return earlier if timer events, I/O events,
* window events, or signal events occur. Note that @a max_wait_time
* can be 0, in which case this method blocks indefinitely until
* events occur.
*
* @a max_wait_time is decremented to reflect how much time this call
* took. For instance, if a time value of 3 seconds is passed to
* handle_events and an event occurs after 2 seconds,
* @a max_wait_time will equal 1 second. This can be used if an
* application wishes to handle events for some fixed amount of
* time.
*
* <MsgWaitForMultipleObjects> is used as the demultiplexing call
*
* Returns the total number of ACE_Event_Handlers that were
* dispatched, 0 if the @a max_wait_time elapsed without dispatching
* any handlers, or -1 if an error occurs.
*
* The only difference between <alertable_handle_events> and
* <handle_events> is that in the alertable case, MWMO_ALERTABLE is
* passed to <MsgWaitForMultipleObjects> for the <bAlertable>
* option.
*/
virtual int handle_events (ACE_Time_Value *max_wait_time = 0);
virtual int alertable_handle_events (ACE_Time_Value *max_wait_time = 0);
/**
* This method is just like the one above, except the
* @a max_wait_time value is a reference and can therefore never be
* NULL.
*/
virtual int handle_events (ACE_Time_Value &max_wait_time);
virtual int alertable_handle_events (ACE_Time_Value &max_wait_time);
protected:
/// Wait for timer and I/O events to occur.
virtual DWORD wait_for_multiple_events (int timeout,
int alertable);
/// Check for activity on remaining handles.
virtual DWORD poll_remaining_handles (DWORD index);
/// Dispatches window messages.
virtual int dispatch_window_messages ();
};
ACE_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "ace/Msg_WFMO_Reactor.inl"
#endif /* __ACE_INLINE__ */
#endif /* ACE_WIN32 */
#include /**/ "ace/post.h"
#endif /* ACE_MSG_WFMO_REACTOR_H */
|
