blob: e4cde846df6904b7a71ead20341bb5122e781d6f (
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
133
134
|
// $Id$
#include "tao/corba.h"
#include "orbsvcs/Time_Utilities.h"
#include "orbsvcs/Notify/Properties.h"
#include "orbsvcs/Notify/Supplier.h"
#include "tao/debug.h"
#include "tao/Messaging/Messaging_TypesC.h"
#if ! defined (__ACE_INLINE__)
#include "orbsvcs/Notify/Supplier.inl"
#endif /* __ACE_INLINE__ */
ACE_RCSID(Notify, TAO_Notify_Supplier, "$Id$")
#include "orbsvcs/Notify/ProxyConsumer.h"
#include "orbsvcs/Notify/Proxy.h"
#ifndef DEBUG_LEVEL
# define DEBUG_LEVEL TAO_debug_level
#endif //DEBUG_LEVEL
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_Notify_Supplier::TAO_Notify_Supplier (TAO_Notify_ProxyConsumer* proxy)
: proxy_ (proxy)
{
}
TAO_Notify_Supplier::~TAO_Notify_Supplier ()
{
}
TAO_Notify_Proxy*
TAO_Notify_Supplier::proxy (void)
{
return this->proxy_consumer ();
}
void
TAO_Notify_Supplier::dispatch_updates_i (
const CosNotification::EventTypeSeq& added,
const CosNotification::EventTypeSeq& removed)
{
if (!CORBA::is_nil (this->subscribe_.in ()))
this->subscribe_->subscription_change (added, removed);
}
bool
TAO_Notify_Supplier::is_alive (bool allow_nil_supplier)
{
bool status = false;
CORBA::Object_var supplier = this->get_supplier ();
if (CORBA::is_nil (supplier.in ()))
{
// The supplier may not connected or the supplier did
// not provide a callback. In this case, the liveliness
// check should return true so it will be validated in
// next period.
if (allow_nil_supplier)
return true;
else
return status;
}
CORBA::PolicyList policy_list;
try
{
bool do_liveliness_check = false;
ACE_Time_Value now = ACE_OS::gettimeofday ();
ACE_Time_Value last_ping = proxy_->last_ping();
if (CORBA::is_nil (this->rtt_obj_.in ()))
{
// We need to determine if the supplier on the other end is still
// alive. Since we may be in an upcall from the owner of the
// original supplier, we have to put a timeout on the call in case
// the client side is not processing ORB requests at this time. In
// the event that the timeout exception occurs, we will assume that
// the original supplier is still around. If we get any other
// exception we will say that the original supplier is not
// available anymore.
TimeBase::TimeT timeout = 10000000;
CORBA::Any timeout_any;
timeout_any <<= timeout;
policy_list.length (1);
policy_list[0] = TAO_Notify_PROPERTIES::instance()->orb()->
create_policy (
Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
timeout_any);
rtt_obj_ =
supplier->_set_policy_overrides (policy_list,
CORBA::ADD_OVERRIDE);
// Clean up the policy that was allocated in the try/catch
for (CORBA::ULong i = 0; i < policy_list.length (); i++)
policy_list[i]->destroy ();
do_liveliness_check
= (last_ping == ACE_Time_Value::zero ? true
: now - last_ping >= TAO_Notify_PROPERTIES::instance()->validate_client_delay ());
}
else
do_liveliness_check =
now - last_ping >= TAO_Notify_PROPERTIES::instance()->validate_client_interval ();
if (CORBA::is_nil (rtt_obj_.in ()))
status = false;
else if (do_liveliness_check || allow_nil_supplier)
{
this->proxy_->last_ping (now);
status = !rtt_obj_->_non_existent ();
}
else
status = true;
}
catch (CORBA::TIMEOUT&)
{
status = true;
}
catch (CORBA::Exception& ex)
{
if (DEBUG_LEVEL > 0)
{
ex._tao_print_exception ("TAO_Notify_Supplier::is_alive: false");
}
}
return status;
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
