summaryrefslogtreecommitdiff
path: root/ACE/protocols/ace/RMCast/Retransmit.h
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/protocols/ace/RMCast/Retransmit.h')
-rw-r--r--ACE/protocols/ace/RMCast/Retransmit.h98
1 files changed, 0 insertions, 98 deletions
diff --git a/ACE/protocols/ace/RMCast/Retransmit.h b/ACE/protocols/ace/RMCast/Retransmit.h
deleted file mode 100644
index 0a3a8f72bd7..00000000000
--- a/ACE/protocols/ace/RMCast/Retransmit.h
+++ /dev/null
@@ -1,98 +0,0 @@
-// file : ace/RMCast/Retransmit.h
-// author : Boris Kolpackov <boris@kolpackov.net>
-// cvs-id : $Id$
-
-#ifndef ACE_RMCAST_RETRANSMIT_H
-#define ACE_RMCAST_RETRANSMIT_H
-
-#include "ace/Hash_Map_Manager.h"
-#include "ace/Thread_Manager.h"
-
-#include "Stack.h"
-#include "Protocol.h"
-#include "Bits.h"
-#include "Parameters.h"
-
-namespace ACE_RMCast
-{
- class Retransmit : public Element
- {
- public:
- Retransmit (Parameters const& params);
-
- virtual void
- out_start (Out_Element* out);
-
- virtual void
- out_stop ();
-
- public:
- virtual void
- send (Message_ptr m);
-
- virtual void
- recv (Message_ptr m);
-
- private:
- struct Descr
- {
- // Shouldn't be available but ACE_Hash_Map needs it.
- //
- Descr ()
- : msg_ (), count_ (0)
- {
- }
-
- Descr (Message_ptr msg)
- : msg_ (msg), count_ (0)
- {
- }
-
- unsigned long
- inc ()
- {
- return ++count_;
- }
-
- void
- reset ()
- {
- count_ = 0;
- }
-
- Message_ptr
- message () const
- {
- return msg_->clone ();
- }
-
- private:
- Message_ptr msg_;
- unsigned long count_;
- };
-
- typedef
- ACE_Hash_Map_Manager<u64, Descr, ACE_Null_Mutex>
- Queue;
-
- private:
- void
- track ();
-
- static ACE_THR_FUNC_RETURN
- track_thunk (void* obj);
-
- private:
- Parameters const& params_;
-
- Queue queue_;
- Mutex mutex_;
- Condition cond_;
-
- bool stop_;
- ACE_Thread_Manager tracker_mgr_;
- };
-}
-
-
-#endif // ACE_RMCAST_RETRANSMIT_H