TAO/tests/Oneway_Buffering/Oneway_Buffering.cpp

   1 #include "Oneway_Buffering.h"
   2
   3 Oneway_Buffering::Oneway_Buffering (CORBA::ORB_ptr orb,
   4                                     Test::Oneway_Buffering_Admin_ptr admin)
   5   : orb_ (CORBA::ORB::_duplicate (orb))
   6   , admin_ (Test::Oneway_Buffering_Admin::_duplicate (admin))
   7 {
   8 }
   9
  10 void
  11 Oneway_Buffering::receive_data (const Test::Payload &the_payload)
  12 {
  13   this->admin_->request_received (the_payload.length ());
  14 }
  15
  16 void
  17 Oneway_Buffering::flush ()
  18 {
  19 }
  20
  21 void
  22 Oneway_Buffering::sync ()
  23 {
  24   this->admin_->flush ();
  25 }
  26
  27 void
  28 Oneway_Buffering::shutdown ()
  29 {
  30   this->orb_->shutdown (false);
  31 }