TAO/examples/Callback_Quoter/Supplier_Timer_Handler.cpp

   1 //=============================================================================
   2 /**
   3  *  Implementation of the Supplier_Time_Handler class.
   4  *
   5  *  @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
   6  */
   7 //=============================================================================
   8
   9
  10 #include "ace/ACE.h"
  11
  12 #include "Supplier_Timer_Handler.h"
  13
  14 // The supplier refernce is got so that the mathods in the supplier
  15 // can be accessed.
  16
  17 Supplier_Timer_Handler:: Supplier_Timer_Handler (Supplier *supplier,
  18                                                  ACE_Reactor *reactor,
  19                                                  FILE *file_ptr)
  20     :supplier_obj_ (supplier),
  21      reactor_ (reactor),
  22      file_ptr_ (file_ptr)
  23 {
  24   // No-op.
  25 }
  26
  27 // Destructor.
  28
  29  Supplier_Timer_Handler::~Supplier_Timer_Handler (void)
  30 {
  31   // No-op.
  32 }
  33
  34 // Method which will be called by the reactor on timeout.
  35
  36 int
  37 Supplier_Timer_Handler:: handle_timeout (const ACE_Time_Value & /* tv */,
  38                                          const void * /* arg */)
  39 {
  40
  41   ACE_DEBUG ((LM_DEBUG,
  42               "Sending Stock Market Information to Notifier...\n"));
  43
  44   // The next current stock rates are obtained from a file.
  45   if (this->get_stock_information () == -1)
  46     return 0;
  47
  48
  49   // Send the stock information to the notifier.  Graceful exit when
  50   // the notifier doesnt accept the information.
  51   if (this->supplier_obj_->send_market_status (stockname_,
  52                                                value_) < 0)
  53     {
  54       this->reactor_->end_event_loop ();
  55       ACE_ERROR_RETURN ((LM_ERROR,
  56                          "handle_timeout: send_market_status failed! %p\n",
  57                          "send_market_status"),
  58                         -1);
  59     }
  60
  61   return 0;
  62 }
  63
  64 // Get the stock information from a file.
  65
  66 int
  67 Supplier_Timer_Handler::get_stock_information (void)
  68 {
  69   // Scan the file and obtain the stock information.
  70   if (fscanf (file_ptr_,
  71               "%s %ld\n",
  72               stockname_,
  73               &value_) != EOF)
  74     {
  75       ACE_DEBUG ((LM_DEBUG,
  76                   "Stockname: %s, Stockvalue: %d\n",
  77                   stockname_,
  78                   value_));
  79       return 0;
  80     }
  81   else
  82     {
  83       // Close down the Reactor.
  84       this->reactor_->end_event_loop ();
  85       return -1;
  86     }
  87 }
  88