diff options
Diffstat (limited to 'cpp/src/IceStorm/KeepAliveThread.h')
-rw-r--r-- | cpp/src/IceStorm/KeepAliveThread.h | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/cpp/src/IceStorm/KeepAliveThread.h b/cpp/src/IceStorm/KeepAliveThread.h deleted file mode 100644 index 97eb063a0bc..00000000000 --- a/cpp/src/IceStorm/KeepAliveThread.h +++ /dev/null @@ -1,53 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2006 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -#ifndef KEEP_ALIVE_THREAD_I_H -#define KEEP_ALIVE_THREAD_I_H - -#include <IceStorm/LinkRecord.h> -#include <IceUtil/Thread.h> -#include <IceUtil/Monitor.h> -#include <list> - -namespace IceStorm -{ - -class Instance; -typedef IceUtil::Handle<Instance> InstancePtr; - -class KeepAliveThread : public IceUtil::Thread, public IceUtil::Monitor<IceUtil::Mutex> -{ -public: - - KeepAliveThread(const InstancePtr&); - ~KeepAliveThread(); - - void add(const IceStorm::TopicUpstreamLinkPrx&); - void remove(const IceStorm::TopicUpstreamLinkPrx&); - void startPinging(); - void destroy(); - bool filter(IceStorm::TopicUpstreamLinkPrxSeq&); - virtual void run(); - -private: - - void failed(const IceStorm::TopicUpstreamLinkPrx&); - - const InstancePtr _instance; - const IceUtil::Time _timeout; - bool _publish; - bool _destroy; - std::list<IceStorm::TopicUpstreamLinkPrx> _upstream; - std::list<IceStorm::TopicUpstreamLinkPrx> _failed; -}; -typedef IceUtil::Handle<KeepAliveThread> KeepAliveThreadPtr; - -} - -#endif |