TAO/tests/MT_BiDir/Sender_i.h

   1 // -*- C++ -*-
   2 #ifndef MT_BIDIR_RECEIVER_H
   3 #define MT_BIDIR_RECEIVER_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "SenderS.h"
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9 class ACE_Manual_Event;
  10 ACE_END_VERSIONED_NAMESPACE_DECL
  11
  12 /**
  13  * Simply print count how many bytes were received.
  14  */
  15 class Sender_i
  16   : public virtual POA_Sender
  17 {
  18 public:
  19   /// Constructor
  20   Sender_i (CORBA::ULong no_clients,
  21             ACE_Manual_Event &event);
  22
  23   virtual ~Sender_i (void);
  24
  25   // = The skeleton methods
  26   virtual CORBA::Long receiver_object (Receiver *recv);
  27
  28   /// Public method defined locally
  29   void send_message (void);
  30
  31 private:
  32   /// Synchronizing acces to this class
  33   TAO_SYNCH_MUTEX mutex_;
  34
  35   /// An event for waking other threads
  36   ACE_Manual_Event &event_;
  37
  38   /// An array of receiver pointers
  39   Receiver_var *receivers_;
  40
  41   /// Size of the <this->receivers_> array
  42   CORBA::ULong no_clients_;
  43
  44   /// Receiver index
  45   CORBA::ULong last_index_;
  46
  47   /// Payload that is being sent
  48   Receiver::Payload payload_;
  49 };
  50
  51 #include /**/ "ace/post.h"
  52 #endif /* MUXING_RECEIVER_H */