ChangeLogTag:Tue Oct 10 17:25:32 2000 Carlos O'Ryan <coryan@uci.edu>

1 files changed, 54 insertions, 0 deletions

diff --git a/protocols/ace/RMCast/RMCast_Sequencer.h b/protocols/ace/RMCast/RMCast_Sequencer.h
new file mode 100644
index 00000000000..321d778853e
--- /dev/null
+++ b/protocols/ace/RMCast/RMCast_Sequencer.h
@@ -0,0 +1,54 @@
+/* -*- C++ -*- */
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    ace/RMCast
+//
+// = AUTHOR
+//    Carlos O'Ryan <coryan@uci.edu>
+//
+// ============================================================================
+
+#ifndef ACE_RMCAST_SEQUENCER_H
+#define ACE_RMCAST_SEQUENCER_H
+#include "ace/pre.h"
+
+#include "RMCast_Module.h"
+#include "ace/Synch.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+/// Assign sequence numbers to outgoing messages
+/**
+ * On the sender side we must assign sequence numbers to the messages
+ * <B>before</B> they are put in the retransmission queue.
+ */
+class ACE_RMCast_Export ACE_RMCast_Sequencer : public ACE_RMCast_Module
+{
+public:
+  /// Constructor
+  ACE_RMCast_Sequencer (void);
+
+  /// Destructor
+  virtual ~ACE_RMCast_Sequencer (void);
+
+  virtual int data (ACE_RMCast::Data &);
+
+protected:
+  /// Create the sequence numbers
+  ACE_UINT32 sequence_number_generator_;
+
+  /// Synchronization
+  ACE_SYNCH_MUTEX mutex_;
+};
+
+#if defined (__ACE_INLINE__)
+#include "RMCast_Sequencer.i"
+#endif /* __ACE_INLINE__ */
+
+#include "ace/post.h"
+#endif /* ACE_RMCAST_SEQUENCER_H */