TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp

   1 #include "SharedIntf_i.h"
   2 #include "worker.h"
   3 #include "chatter.h"
   4
   5 Chatter::Chatter (CORBA::ORB_ptr orb, const ACE_TCHAR *ior, ACE_Condition<ACE_Mutex>& cond)
   6  : Worker (orb),
   7    nrequests_ (0),
   8    nreplies_ (0),
   9    ior_ (ior),
  10    cond_ (cond)
  11 {
  12 }
  13
  14 long
  15 Chatter::nreplies ()
  16 {
  17   return this->nreplies_;
  18 }
  19
  20 long
  21 Chatter::nrequests ()
  22 {
  23   return this->nrequests_;
  24 }
  25
  26 int
  27 Chatter::svc ()
  28 {
  29   long nrq = -1;
  30   try
  31   {
  32      //sleep(1);
  33
  34      // get server ior from file
  35      CORBA::Object_var rawObject = orb_->string_to_object(ior_);
  36
  37      Test_Idl::SharedIntf_var intf_var =
  38         Test_Idl::SharedIntf::_narrow(rawObject.in());
  39
  40      if (CORBA::is_nil (intf_var.in ()))
  41        ACE_ERROR_RETURN ((LM_ERROR, "Nil reference <%s>\n", ior_), -1);
  42
  43      // make call on server
  44      {
  45        ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, request_reply_count_mutex_, -1);
  46        nrq= nrequests ();
  47        nrequests_++;
  48      }
  49      ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d] started for %s\n", nrq, ior_));
  50      intf_var->ping();
  51      {
  52        ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, request_reply_count_mutex_, -1);
  53        nreplies_++;
  54      }
  55
  56      ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d,%d,%d] completed for %s\n", nrq, nrequests_, nreplies_, ior_));
  57      cond_.signal();
  58      return 0;
  59    }
  60    catch (const CORBA::Exception& ex)
  61    {
  62       ex._tao_print_exception ("Exception caught:");
  63       ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d] %p for %s\n", nrq, "failed", ior_));
  64    }
  65    return -1;
  66 }
  67
  68 int
  69 Chatter::farewell ()
  70 {
  71   try
  72   {
  73      ACE_DEBUG((LM_INFO,"(%P|%t) Farewell requested for %s\n", ior_));
  74
  75      // get server ior from file
  76      CORBA::Object_var rawObject = orb_->string_to_object( ior_);
  77
  78      Test_Idl::SharedIntf_var intf_var =
  79         Test_Idl::SharedIntf::_narrow(rawObject.in());
  80
  81      if (CORBA::is_nil (intf_var.in ()))
  82        ACE_ERROR_RETURN ((LM_ERROR, "Nil reference <%s>\n", ior_), -1);
  83
  84      // make call on server
  85      ACE_DEBUG((LM_INFO,"(%P|%t) farewell START for %s\n", ior_));
  86       intf_var->farewell();
  87
  88       ACE_DEBUG((LM_INFO,"(%P|%t) farewell COMPLETE for %s\n", ior_));
  89    }
  90    catch (const CORBA::Exception& ex)
  91    {
  92       ex._tao_print_exception ("Exception caught:");
  93       ACE_DEBUG((LM_INFO,"(%P|%t) %p for %s\n", "farewell FAILED", ior_));
  94    }
  95    return 0;
  96 }
  97
  98