diff options
Diffstat (limited to 'ACE/TAO/tests/MT_BiDir/Sender_i.h')
-rw-r--r-- | ACE/TAO/tests/MT_BiDir/Sender_i.h | 53 |
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 */ |