summaryrefslogtreecommitdiff
path: root/ACE/TAO/tests/MT_BiDir/Sender_i.h
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/TAO/tests/MT_BiDir/Sender_i.h')
-rw-r--r--ACE/TAO/tests/MT_BiDir/Sender_i.h53
1 files changed, 53 insertions, 0 deletions
diff --git a/ACE/TAO/tests/MT_BiDir/Sender_i.h b/ACE/TAO/tests/MT_BiDir/Sender_i.h
new file mode 100644
index 00000000000..419e333f0b4
--- /dev/null
+++ b/ACE/TAO/tests/MT_BiDir/Sender_i.h
@@ -0,0 +1,53 @@
+// -*- C++ -*-
+//
+// $Id$
+
+#ifndef MT_BIDIR_RECEIVER_H
+#define MT_BIDIR_RECEIVER_H
+#include /**/ "ace/pre.h"
+
+#include "SenderS.h"
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+class ACE_Manual_Event;
+ACE_END_VERSIONED_NAMESPACE_DECL
+
+/**
+ * Simply print count how many bytes were received.
+ */
+class Sender_i
+ : public virtual POA_Sender
+{
+public:
+ /// Constructor
+ Sender_i (int no_clients,
+ ACE_Manual_Event &event);
+
+ // = The skeleton methods
+ virtual CORBA::Long receiver_object (Receiver *recv);
+
+ /// Public method defined locally
+ void send_message (void);
+
+private:
+ /// Synchronizing acces to this class
+ TAO_SYNCH_MUTEX mutex_;
+
+ /// An event for waking other threads
+ ACE_Manual_Event &event_;
+
+ /// An array of receiver pointers
+ Receiver **receivers_;
+
+ /// Size of the <this->receivers_> array
+ int no_clients_;
+
+ /// Receiver index
+ int last_index_;
+
+ /// Payload that is being sent
+ Receiver::Payload payload_;
+};
+
+#include /**/ "ace/post.h"
+#endif /* MUXING_RECEIVER_H */