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
|
#include "ace/Event_Handler.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE int
ACE_Event_Handler_Handle_Timeout_Upcall::
registration (ACE_Timer_Queue &,
ACE_Event_Handler *event_handler,
const void *)
{
event_handler->add_reference ();
return 0;
}
ACE_INLINE int
ACE_Event_Handler_Handle_Timeout_Upcall::
preinvoke (ACE_Timer_Queue &,
ACE_Event_Handler *event_handler,
const void *,
int,
const ACE_Time_Value &,
const void * & upcall_act)
{
bool const requires_reference_counting =
event_handler->reference_counting_policy ().value () ==
ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
if (requires_reference_counting)
{
event_handler->add_reference ();
upcall_act = &this->requires_reference_counting_;
}
return 0;
}
ACE_INLINE int
ACE_Event_Handler_Handle_Timeout_Upcall::
postinvoke (ACE_Timer_Queue & /* timer_queue */,
ACE_Event_Handler *event_handler,
const void * /* timer_act */,
int /* recurring_timer */,
const ACE_Time_Value & /* cur_time */,
const void *upcall_act)
{
if (upcall_act == &this->requires_reference_counting_)
{
event_handler->remove_reference ();
}
return 0;
}
ACE_INLINE int
ACE_Event_Handler_Handle_Timeout_Upcall::
cancel_timer (ACE_Timer_Queue &,
ACE_Event_Handler *event_handler,
int,
int requires_reference_counting)
{
if (requires_reference_counting)
event_handler->remove_reference ();
return 0;
}
ACE_END_VERSIONED_NAMESPACE_DECL
|
