TAO/tests/Big_Request_Muxing/Payload_Receiver.h

   1
   2 #ifndef BIG_REQUEST_MUXING_PAYLOAD_RECEIVER_H
   3 #define BIG_REQUEST_MUXING_PAYLOAD_RECEIVER_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "TestS.h"
   7
   8 /// Implement the Test::Payload_Receiver interface
   9 /**
  10  * Simply print count how many bytes were received.
  11  */
  12 class Payload_Receiver
  13   : public virtual POA_Test::Payload_Receiver
  14 {
  15 public:
  16   Payload_Receiver ();
  17
  18   // = The skeleton methods
  19   virtual void more_data (const Test::Payload &payload,
  20                           CORBA::Boolean maybe_lost);
  21
  22   virtual void ping ();
  23
  24   int count (bool maybe_lost = false) const;
  25
  26 private:
  27   ACE_Atomic_Op<TAO_SYNCH_MUTEX, int> message_count_;
  28   ACE_Atomic_Op<TAO_SYNCH_MUTEX, int> maybe_lost_count_;
  29 };
  30
  31 #include /**/ "ace/post.h"
  32 #endif /* BIG_REQUEST_MUXING_PAYLOAD_RECEIVER_H */