blob: bbda86288143a367ac6ae8955fc5f27c418bbd69 (
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
|
// $Id$
#include "tao/Single_Reactor.h"
#include "tao/ORB_Core.h"
#include "tao/Resource_Factory.h"
#include "tao/Leader_Follower.h"
#include "ace/Reactor.h"
#if !defined (__ACE_INLINE__)
# include "tao/Single_Reactor.i"
#endif /* ! __ACE_INLINE__ */
ACE_RCSID(tao, Single_Reactor, "$Id$")
TAO_Single_Reactor::~TAO_Single_Reactor (void)
{
delete this->leader_follower_;
}
void
TAO_Single_Reactor::open (TAO_ORB_Core *orb_core)
{
this->TAO_Reactor_Registry::open (orb_core);
ACE_NEW (this->leader_follower_,
TAO_Leader_Follower (this->orb_core ()));
}
ACE_Reactor *
TAO_Single_Reactor::reactor (void)
{
return this->leader_follower_->reactor ();
}
ACE_Reactor *
TAO_Single_Reactor::reactor (TAO_Acceptor *)
{
return this->reactor ();
}
TAO_Leader_Follower &
TAO_Single_Reactor::leader_follower (void)
{
return *this->leader_follower_;
}
TAO_Leader_Follower &
TAO_Single_Reactor::leader_follower (TAO_Acceptor *)
{
return *this->leader_follower_;
}
void
TAO_Single_Reactor::destroy_tss_cookie (void*)
{
}
int
TAO_Single_Reactor::shutdown_all (void)
{
TAO_Leader_Follower &leader_follower =
this->leader_follower ();
ACE_GUARD_RETURN (ACE_SYNCH_MUTEX,
ace_mon,
leader_follower.lock (),
-1);
// Wakeup all the threads waiting blocked in the event loop, this
// does not guarantee that they will all go away, but reduces the
// load on the POA....
ACE_Reactor *reactor =
this->reactor ();
reactor->wakeup_all_threads ();
// If there are some client threads running we have to wait until
// they finish, when the last one does it will shutdown the
// reactor for us. Meanwhile no new requests will be accepted
// because the POA will not process them.
if (!leader_follower.has_clients ())
{
// Wake up all waiting threads in the reactor.
reactor->end_reactor_event_loop ();
}
return 0;
}
|
