TAO/examples/Callback_Quoter/Consumer_Signal_Handler.cpp

   1 /* -*- C++ -*- */
   2
   3 //=============================================================================
   4 /**
   5  *  @file    Consumer_Signal_Handler.cpp
   6  *
   7  *  Implementation of the Consumer_Signal_Handler class.
   8  *
   9  *  @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
  10  */
  11 //=============================================================================
  12
  13 #include "Consumer_Signal_Handler.h"
  14
  15 Consumer_Signal_Handler::Consumer_Signal_Handler (Consumer_Handler *consumer_handler)
  16   : consumer_handler_ (consumer_handler)
  17 {
  18 }
  19
  20 // Method to handle the ^C signal.
  21 int
  22 Consumer_Signal_Handler::handle_signal (int /* signum */,
  23                                         siginfo_t*,
  24                                         ucontext_t*)
  25 {
  26   ACE_DEBUG ((LM_DEBUG, " Exiting on receiving ^C\n"));
  27
  28   quit_on_signal ();
  29
  30   return 0;
  31 }
  32
  33 // Method called before the Event_Handler dies.
  34 int
  35 Consumer_Signal_Handler::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
  36 {
  37   // End of the signal handler.
  38   delete this;
  39
  40   return 0;
  41 }
  42
  43 int
  44 Consumer_Signal_Handler::quit_on_signal ()
  45 {
  46   // Only if the consumer is registered and wants to shut down, its
  47   // necessary to unregister and then shutdown.
  48   try
  49     {
  50       if (consumer_handler_->unregistered_ != 1
  51           && consumer_handler_->registered_ == 1)
  52         {
  53           this->consumer_handler_->server_->unregister_callback
  54             (this->consumer_handler_->consumer_var_.in ());
  55           ACE_DEBUG ((LM_DEBUG,
  56                       "Consumer Unregistered\n"));
  57         }
  58       this->consumer_handler_->consumer_servant_->shutdown ();
  59     }
  60   catch (const CORBA::Exception& ex)
  61     {
  62       ex._tao_print_exception (
  63         "Consumer_Input_Handler::quit_consumer_process()");
  64       return -1;
  65     }
  66
  67   return 0;
  68 }