TAO/tests/Muxing/Receiver.h

   1
   2 #ifndef MUXING_RECEIVER_H
   3 #define MUXING_RECEIVER_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "TestS.h"
   7
   8 #if defined (_MSC_VER)
   9 # pragma warning(push)
  10 # pragma warning (disable:4250)
  11 #endif /* _MSC_VER */
  12
  13 /// Implement the Test::Receiver interface
  14 /**
  15  * Simply print count how many bytes were received.
  16  */
  17 class Receiver
  18   : public POA_Test::Receiver
  19 {
  20 public:
  21   /// Constructor
  22   Receiver (CORBA::ORB_ptr orb);
  23
  24   /// Print out the results
  25   void dump_results ();
  26
  27   // = The skeleton methods
  28   virtual void receive_data (const Test::Payload &payload);
  29   virtual CORBA::Long get_event_count ();
  30
  31   virtual void shutdown ();
  32
  33 private:
  34   TAO_SYNCH_MUTEX mutex_;
  35   CORBA::ULong message_count_;
  36   CORBA::ULong byte_count_;
  37   /// Use an ORB reference to shutdown
  38   /// the application.
  39   CORBA::ORB_var orb_;
  40 };
  41
  42 #if defined(_MSC_VER)
  43 # pragma warning(pop)
  44 #endif /* _MSC_VER */
  45
  46 #include /**/ "ace/post.h"
  47 #endif /* MUXING_RECEIVER_H */