blob: 8a0332eb4e179aff990b045fcf16f6dc718a74e9 (
plain)
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
|
// -*- C++ -*-
#include "ace/Log_Category.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE
ACE_Dev_Poll_Reactor::Event_Tuple::Event_Tuple (ACE_Event_Handler *eh,
ACE_Reactor_Mask m,
bool is_suspended,
bool is_controlled)
: event_handler (eh),
mask (m),
suspended (is_suspended),
controlled (is_controlled)
{
}
// ---------------------------------------------------------------------
ACE_INLINE size_t
ACE_Dev_Poll_Reactor::Handler_Repository::size () const
{
ACE_TRACE ("ACE_Dev_Poll_Reactor::Handler_Repository::size");
return this->size_;
}
ACE_INLINE size_t
ACE_Dev_Poll_Reactor::Handler_Repository::max_size () const
{
ACE_TRACE ("ACE_Dev_Poll_Reactor::Handler_Repository::max_size");
return this->max_size_;
}
// -----------------------------------------------------------------
ACE_INLINE
ACE_Dev_Poll_Handler_Guard::ACE_Dev_Poll_Handler_Guard
(ACE_Event_Handler *eh,
bool do_incr)
: eh_ (eh),
refcounted_ (false)
{
if (eh == 0)
return;
this->refcounted_ =
eh->reference_counting_policy ().value () ==
ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
if (do_incr && this->refcounted_)
eh->add_reference ();
}
ACE_INLINE
ACE_Dev_Poll_Handler_Guard::~ACE_Dev_Poll_Handler_Guard (void)
{
if (this->refcounted_ && this->eh_ != 0)
this->eh_->remove_reference ();
}
ACE_INLINE void
ACE_Dev_Poll_Handler_Guard::release (void)
{
this->eh_ = 0;
}
// ---------------------------------------------------------------------
ACE_INLINE int
ACE_Dev_Poll_Reactor::upcall (ACE_Event_Handler *event_handler,
int (ACE_Event_Handler::*callback)(ACE_HANDLE),
ACE_HANDLE handle)
{
// If the handler returns positive value (requesting a reactor
// callback) just call back as many times as the handler requests
// it. The handler is suspended internally and other threads are off
// handling other things.
int status = 0;
do
{
status = (event_handler->*callback) (handle);
}
while (status > 0 && event_handler != this->notify_handler_);
return status;
}
/************************************************************************/
// Methods for ACE_Dev_Poll_Reactor::Token_Guard
/************************************************************************/
ACE_INLINE
ACE_Dev_Poll_Reactor::Token_Guard::Token_Guard (ACE_Dev_Poll_Reactor_Token &token)
: token_ (token),
owner_ (false)
{
}
ACE_INLINE
ACE_Dev_Poll_Reactor::Token_Guard::~Token_Guard (void)
{
if (this->owner_)
{
ACE_MT (this->token_.release ());
this->owner_ = false;
}
}
ACE_INLINE void
ACE_Dev_Poll_Reactor::Token_Guard::release_token (void)
{
if (this->owner_)
{
ACE_MT (this->token_.release ());
// We are not the owner anymore..
this->owner_ = false;
}
}
ACE_INLINE bool
ACE_Dev_Poll_Reactor::Token_Guard::is_owner (void)
{
return this->owner_;
}
ACE_END_VERSIONED_NAMESPACE_DECL
|
