diff options
| author | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-08-10 01:35:38 +0000 |
|---|---|---|
| committer | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-08-10 01:35:38 +0000 |
| commit | e39942fe042f92687c5d0ce63887019dd94d2112 (patch) | |
| tree | 07a14c4b9e0aaa80db64fdb1b0b4bb099c3666bb /protocols/ace/RMCast/RMCast_Fragment.h | |
| parent | 53fdb2c7112f899fbef1e19c69fbe6fdae9553b0 (diff) | |
| download | ATCD-e39942fe042f92687c5d0ce63887019dd94d2112.tar.gz | |
ChangeLogTag:Wed Aug 9 18:16:26 2000 Carlos O'Ryan <coryan@uci.edu>
Diffstat (limited to 'protocols/ace/RMCast/RMCast_Fragment.h')
| -rw-r--r-- | protocols/ace/RMCast/RMCast_Fragment.h | 28 |
1 files changed, 7 insertions, 21 deletions
diff --git a/protocols/ace/RMCast/RMCast_Fragment.h b/protocols/ace/RMCast/RMCast_Fragment.h index 8aa7024770e..e42440b6c12 100644 --- a/protocols/ace/RMCast/RMCast_Fragment.h +++ b/protocols/ace/RMCast/RMCast_Fragment.h @@ -6,7 +6,7 @@ // The fragmentation task for the reliable multicast library // // = AUTHOR -// Carlos O'Ryan <coryan@cs.wustl.edu> +// Carlos O'Ryan <coryan@uci.edu> // // ============================================================================ @@ -14,8 +14,8 @@ #define ACE_RMCAST_FRAGMENT_H #include "ace/pre.h" -#include "RMCast_Export.h" -#include "ace/Task.h" +#include "RMCast_Module.h" +#include "ace/Synch.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once @@ -25,12 +25,10 @@ # define ACE_RMCAST_DEFAULT_FRAGMENT_SIZE 1024 #endif /* ACE_RMCAST_DEFAULT_FRAGMENT_SIZE */ -template <ACE_SYNCH_DECL> -class ACE_RMCast_Export ACE_RMCast_Fragment : public ACE_Task<ACE_SYNCH_USE> +class ACE_RMCast_Export ACE_RMCast_Fragment : public ACE_RMCast_Module { public: - ACE_RMCast_Fragment (ACE_Thread_Manager *thr_mgr = 0, - ACE_Message_Queue<ACE_SYNCH_USE> *mq = 0); + ACE_RMCast_Fragment (void); // Constructor virtual ~ACE_RMCast_Fragment (void); @@ -41,28 +39,16 @@ public: // There is no modifier, the maximum fragment size is obtained using // feedback from the lower layer (transport?) - // = The ACE_Task methods - int put (ACE_Message_Block *, ACE_Time_Value *timeout = 0); + // = The ACE_RMCast_Module methods + virtual int put_data (ACE_RMCast::Data &data); private: size_t max_fragment_size_; - - ACE_SYNCH_MUTEX_T mutex_; - ACE_UINT32 sequence_number_generator_; - // The sequence number generator }; #if defined (__ACE_INLINE__) #include "RMCast_Fragment.i" #endif /* __ACE_INLINE__ */ -#if defined (ACE_TEMPLATES_REQUIRE_SOURCE) -#include "RMCast_Fragment.cpp" -#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */ - -#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA) -#pragma implementation ("RMCast_Fragment.cpp") -#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */ - #include "ace/post.h" #endif /* ACE_RMCAST_FRAGMENT_H */ |