TAO/tests/AMI_Buffering/AMI_Buffering.cpp

   1 #include "AMI_Buffering.h"
   2
   3 AMI_Buffering::AMI_Buffering (CORBA::ORB_ptr orb,
   4                               Test::AMI_Buffering_Admin_ptr admin)
   5   : orb_ (CORBA::ORB::_duplicate (orb)),
   6     admin_ (Test::AMI_Buffering_Admin::_duplicate (admin)),
   7     nest_ (0),
   8     max_nest_ (0),
   9     must_shutdown_ (false)
  10 {
  11 }
  12
  13 AMI_Buffering::Nest_Guard::Nest_Guard (AMI_Buffering &a)
  14   :target_(a)
  15 {
  16   ++target_.nest_;
  17   if (target_.nest_ > target_.max_nest_)
  18     target_.max_nest_ = target_.nest_;
  19 }
  20
  21 AMI_Buffering::Nest_Guard::~Nest_Guard (void)
  22 {
  23   --target_.nest_;
  24 }
  25
  26 void
  27 AMI_Buffering::receive_data (const Test::Payload &the_payload)
  28 {
  29   try
  30     {
  31       AMI_Buffering::Nest_Guard ng(*this);
  32       this->admin_->request_received (the_payload.length ());
  33     }
  34   catch (const CORBA::Exception&)
  35     {
  36       ACE_DEBUG ((LM_DEBUG,"(%P|%t) DEBUG: AMI_Buffering::receive_data"));
  37     }
  38
  39   this->try_shutdown();
  40 }
  41
  42 void
  43 AMI_Buffering::flush (void)
  44 {
  45 }
  46
  47 void
  48 AMI_Buffering::sync (void)
  49 {
  50   this->admin_->flush ();
  51 }
  52
  53 void
  54 AMI_Buffering::shutdown (void)
  55 {
  56   this->must_shutdown_ = true;
  57   this->try_shutdown();
  58 }
  59
  60 void
  61 AMI_Buffering::try_shutdown(void)
  62 {
  63   if (!this->must_shutdown_ || this->nest_ > 0)
  64     return;
  65   if (this->max_nest_ > 1)
  66     ACE_DEBUG ((LM_DEBUG, "(%P|%t) max nesting level: %d\n", max_nest_));
  67   this->admin_->shutdown();
  68
  69   this->orb_->shutdown (0);
  70 }