TAO/tests/DIOP/UDP_i.cpp

   1 #include "UDP_i.h"
   2
   3 // Constructor
   4 UDP_i::UDP_i (CORBA::ORB_ptr o) :
   5   orb_(CORBA::ORB::_duplicate (o))
   6 {
   7 }
   8
   9 // Destructor
  10 UDP_i::~UDP_i ()
  11 {
  12 }
  13
  14 void
  15 UDP_i::invoke (const char * client_name,
  16                UDP_ptr udpHandler,
  17                CORBA::Long request_id)
  18 {
  19   try
  20     {
  21       ACE_DEBUG ((LM_DEBUG,
  22                   "UDP_i::invoke: name = %C request id = %d.\n",
  23                   client_name,
  24                   request_id));
  25
  26       CORBA::Long last_request_id = 0;
  27       if (request_id_table_.find (client_name,
  28                                   last_request_id) != -1)
  29         {
  30           if (last_request_id + 1 != request_id)
  31             ACE_ERROR ((LM_ERROR,
  32                         "UDP_i::invoke: failure on %C expected id = %d, got %d\n",
  33                         client_name,
  34                         last_request_id+1,
  35                         request_id));
  36         }
  37
  38       request_id_table_.rebind (client_name,
  39                                 request_id);
  40
  41       if (!CORBA::is_nil (udpHandler))
  42         {
  43           udpHandler->invoke (client_name,
  44                               UDP::_nil (),
  45                               request_id);
  46         }
  47
  48     }
  49   catch (const CORBA::Exception&)
  50     {
  51        ACE_ERROR ((LM_ERROR,
  52                    "UDP_i::svc: Received exception\n"));
  53     }
  54 }
  55
  56 // Shutdown.
  57
  58 void
  59 UDP_i::shutdown ()
  60 {
  61   ACE_DEBUG ((LM_DEBUG,
  62               "UDP_i is shutting down\n"));
  63
  64   // Instruct the ORB to shutdown.
  65   this->orb_->shutdown ();
  66 }
  67