TAO/DevGuideExamples/BiDirectionalGIOP/simple_i.cpp

   1 #include "bidir_giop_pch.h"
   2
   3 #include "simple_i.h"
   4
   5 #include "tao/ORB_Core.h"
   6 #include "tao/Transport_Cache_Manager.h"
   7 #include "tao/Thread_Lane_Resources.h"
   8
   9 #include <iostream>
  10
  11 Simple_i::Simple_i (CORBA::ORB_ptr orb, int callback_count)
  12 : orb_(CORBA::ORB::_duplicate(orb))
  13 , ready_for_callback_(0)
  14 , callback_count_(callback_count)
  15 , callback_(0)
  16 {
  17 }
  18
  19 Simple_i::~Simple_i (void)
  20 {
  21 }
  22
  23 CORBA::Long Simple_i::test_method (CORBA::Boolean do_callback)
  24 {
  25   if (do_callback) {
  26     ready_for_callback_ = 1;
  27   }
  28   return 0;
  29 }
  30
  31 void Simple_i::callback_object (Callback_ptr cb)
  32 {
  33   callback_ = Callback::_duplicate(cb);
  34 }
  35
  36 void Simple_i::shutdown ()
  37 {
  38   CORBA::Boolean wait = false;
  39   orb_->shutdown(wait);
  40 }
  41
  42 int
  43 Simple_i::call_client()
  44 {
  45   if (ready_for_callback_) {
  46
  47     ready_for_callback_ = 0;
  48
  49     for (int times = 0; times < callback_count_; ++times) {
  50
  51       callback_->callback_method();
  52
  53       if (orb_->orb_core()->lane_resources().transport_cache().current_size() > 1)
  54       {
  55         std::cerr << "The connection cache has grown.  "
  56           << "BiDirection did not work. aborting..." << std::endl;
  57         ACE_OS::abort(); // Should probably define and throw a UserException
  58       }
  59     }
  60
  61     callback_->shutdown();
  62
  63     return 1;
  64   }
  65
  66   return 0;
  67 }
  68