TAO/tests/MT_BiDir/Receiver_i.cpp

   1 #include "Receiver_i.h"
   2
   3 Receiver_i::Receiver_i ()
   4   :  message_count_ (0)
   5   ,  byte_count_ (0)
   6 {
   7 }
   8
   9
  10 void
  11 Receiver_i::receive_payload (const Receiver::Payload &payload)
  12 {
  13   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
  14   this->message_count_++;
  15   this->byte_count_ += payload.length ();
  16 }
  17
  18 CORBA::Long
  19 Receiver_i::get_event_count ()
  20 {
  21   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->mutex_, 0);
  22   return this->message_count_;
  23 }