diff options
Diffstat (limited to 'protocols/ace/RMCast/Retransmit.h')
-rw-r--r-- | protocols/ace/RMCast/Retransmit.h | 98 |
1 files changed, 0 insertions, 98 deletions
diff --git a/protocols/ace/RMCast/Retransmit.h b/protocols/ace/RMCast/Retransmit.h deleted file mode 100644 index fa910ee2837..00000000000 --- a/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" - -namespace ACE_RMCast -{ - class Retransmit : public Element - { - public: - Retransmit (); - - 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 () - : data_ (), count_ (0) - { - } - - Descr (Data_ptr d) - : data_ (d), count_ (0) - { - } - - unsigned long - inc () - { - return ++count_; - } - - void - reset () - { - count_ = 0; - } - - // It would be logical to return data_ptr but ACE ref_auto_ptr - // hasn't learned how to convert between pointers yet. - // - Profile_ptr - data () const - { - return Profile_ptr (new Data (*data_)); - } - - private: - Data_ptr data_; - 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: - Queue queue_; - Mutex mutex_; - Condition cond_; - - bool stop_; - ACE_Thread_Manager tracker_mgr_; - }; -} - - -#endif // ACE_RMCAST_RETRANSMIT_H |