summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/ImplRepo_Service/LiveCheck.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/ImplRepo_Service/LiveCheck.h')
-rw-r--r--TAO/orbsvcs/ImplRepo_Service/LiveCheck.h52
1 files changed, 1 insertions, 51 deletions
diff --git a/TAO/orbsvcs/ImplRepo_Service/LiveCheck.h b/TAO/orbsvcs/ImplRepo_Service/LiveCheck.h
index 293c215e9f2..005ae3a3005 100644
--- a/TAO/orbsvcs/ImplRepo_Service/LiveCheck.h
+++ b/TAO/orbsvcs/ImplRepo_Service/LiveCheck.h
@@ -27,7 +27,6 @@
class LiveCheck;
class LiveEntry;
-class PingReceiver;
//---------------------------------------------------------------------------
/*
@@ -93,6 +92,7 @@ class Locator_Export LiveListener
protected:
ACE_CString server_;
+ const LiveEntry *entry_;
private:
int refcount_;
@@ -121,7 +121,6 @@ class Locator_Export LiveEntry
ImplementationRepository::ServerObject_ptr ref);
~LiveEntry (void);
- void release_callback (void);
void add_listener (LiveListener *ll);
LiveStatus status (void) const;
void status (LiveStatus l);
@@ -138,7 +137,6 @@ class Locator_Export LiveEntry
bool reping_available (void);
int next_reping (void);
void max_retry_msec (int max);
- const char *server_name (void) const;
private:
LiveCheck *owner_;
@@ -153,8 +151,6 @@ class Locator_Export LiveEntry
typedef ACE_Unbounded_Set<LiveListener_ptr> Listen_Set;
Listen_Set listeners_;
TAO_SYNCH_MUTEX lock_;
- PortableServer::ServantBase_var callback_;
-
static const int reping_msec_ [];
static int reping_limit_;
@@ -176,14 +172,7 @@ class Locator_Export PingReceiver :
PingReceiver (LiveEntry * entry, PortableServer::POA_ptr poa);
virtual ~PingReceiver (void);
- /// Called by the entry if it is no longer interested in the result of
- /// a ping.
- void cancel (void);
-
- /// Called when an anticipated ping reply is received
void ping (void);
-
- /// Called when an anticipated ping raises an exception
void ping_excep (Messaging::ExceptionHolder * excep_holder);
private:
@@ -191,40 +180,6 @@ class Locator_Export PingReceiver :
LiveEntry * entry_;
};
-
-//---------------------------------------------------------------------------
-/*
- * @class LC_TimeoutGuard
- *
- * @brief A helper object to avoid reentrancy in the handle_timout method
- *
- * The LiveCheck::handle_timeout may be called reentrantly on a single thread
- * if the sending of a ping uses non-blocking connection establishment. If a
- * connection must be established before the ping can be sent, that may involve
- * waiting in the reactor, possibly handing other requests, and possibly even
- * subsequent timeouts.
- * */
-
-class Locator_Export LC_TimeoutGuard
-{
- public:
- /// construct a new stack-based guard. This sets a flag in the owner that will
- /// be cleared on destruction.
- LC_TimeoutGuard (LiveCheck *owner, int token);
-
- /// releases the flag. If the LiveCheck received any requests for an immediate
- /// or defered ping during this time, schedule it now.
- ~LC_TimeoutGuard (void);
-
- /// Returns true if the busy flag in the owner was already set.
- bool blocked (void);
-
- private:
- LiveCheck *owner_;
- int token_;
- bool blocked_;
-};
-
//---------------------------------------------------------------------------
/*
* @class LiveCheck
@@ -239,8 +194,6 @@ class Locator_Export LC_TimeoutGuard
class Locator_Export LiveCheck : public ACE_Event_Handler
{
public:
- friend class LC_TimeoutGuard;
-
LiveCheck ();
~LiveCheck (void);
@@ -288,9 +241,6 @@ class Locator_Export LiveCheck : public ACE_Event_Handler
ACE_Time_Value ping_interval_;
bool running_;
int token_;
- int handle_timeout_busy_;
- bool want_timeout_;
- ACE_Time_Value deferred_timeout_;
};
#endif /* IMR_LIVECHECK_H_ */