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
|
// -*- C++ -*-
#include "ace/Reactor.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE ACE_Select_Reactor_Handler_Repository::size_type
ACE_Select_Reactor_Handler_Repository::size (void) const
{
#ifdef ACE_WIN32
return this->event_handlers_.total_size ();
#else
return this->event_handlers_.size ();
#endif /* ACE_WIN32 */
}
ACE_INLINE ACE_Select_Reactor_Handler_Repository::max_handlep1_type
ACE_Select_Reactor_Handler_Repository::max_handlep1 (void) const
{
#ifdef ACE_WIN32
return this->event_handlers_.current_size ();
#else
return this->max_handlep1_;
#endif /* ACE_WIN32 */
}
ACE_INLINE int
ACE_Select_Reactor_Handler_Repository::unbind (ACE_HANDLE handle,
ACE_Reactor_Mask mask)
{
// Do not refactor this code to optimize the call to the unbind impl.
// To resolve bug 2653, unbind must be called even when find_eh returns
// event_handlers_.end().
return !this->handle_in_range (handle) ? -1
: this->unbind (handle,
this->find_eh (handle),
mask);
}
ACE_INLINE ACE_Event_Handler *
ACE_Select_Reactor_Handler_Repository::find (ACE_HANDLE handle)
{
ACE_TRACE ("ACE_Select_Reactor_Handler_Repository::find");
ACE_Event_Handler * eh = 0;
if (this->handle_in_range (handle))
{
map_type::iterator const pos = this->find_eh (handle);
if (pos != this->event_handlers_.end ())
{
#ifdef ACE_WIN32
eh = (*pos).item ();
#else
eh = *pos;
#endif /* ACE_WIN32 */
}
}
// Don't bother setting errno. It isn't used in the select()-based
// reactors and incurs a TSS access.
// else
// {
// errno = ENOENT;
// }
return eh;
}
// ------------------------------------------------------------------
ACE_INLINE bool
ACE_Select_Reactor_Handler_Repository_Iterator::done (void) const
{
#ifdef ACE_WIN32
return this->current_ == this->rep_->event_handlers_.end ();
#else
return this->current_ == (this->rep_->event_handlers_.begin ()
+ this->rep_->max_handlep1 ());
#endif /* ACE_WIN32 */
}
// ------------------------------------------------------------------
ACE_INLINE
ACE_Event_Tuple::ACE_Event_Tuple (void)
: handle_ (ACE_INVALID_HANDLE),
event_handler_ (0)
{
}
ACE_INLINE
ACE_Event_Tuple::ACE_Event_Tuple (ACE_Event_Handler* eh,
ACE_HANDLE h)
: handle_ (h),
event_handler_ (eh)
{
}
ACE_INLINE bool
ACE_Event_Tuple::operator== (const ACE_Event_Tuple &rhs) const
{
return this->handle_ == rhs.handle_;
}
ACE_INLINE bool
ACE_Event_Tuple::operator!= (const ACE_Event_Tuple &rhs) const
{
return !(*this == rhs);
}
#if defined (ACE_WIN32_VC8) || defined (ACE_WIN32_VC9)
# pragma warning (push)
# pragma warning (disable:4355) /* Use of 'this' in initializer list */
#endif
ACE_INLINE
ACE_Select_Reactor_Impl::ACE_Select_Reactor_Impl (bool ms)
: handler_rep_ (*this)
, timer_queue_ (0)
, signal_handler_ (0)
, notify_handler_ (0)
, delete_timer_queue_ (false)
, delete_signal_handler_ (false)
, delete_notify_handler_ (false)
, initialized_ (false)
, restart_ (0)
, requeue_position_ (-1) // Requeue at end of waiters by default.
, state_changed_ (0)
, mask_signals_ (ms)
, supress_renew_ (0)
{
}
#if defined (ACE_WIN32_VC8) || defined (ACE_WIN32_VC9)
# pragma warning (pop)
#endif
ACE_INLINE int
ACE_Select_Reactor_Impl::supress_notify_renew (void)
{
return this->supress_renew_;
}
ACE_INLINE void
ACE_Select_Reactor_Impl::supress_notify_renew (int sr)
{
this->supress_renew_ = sr;
}
ACE_END_VERSIONED_NAMESPACE_DECL
|
