TAO/tao/Reactive_Flushing_Strategy.cpp

   1 // -*- C++ -*-
   2 #include "tao/Reactive_Flushing_Strategy.h"
   3 #include "tao/Transport.h"
   4 #include "tao/ORB_Core.h"
   5 #include "tao/Queued_Message.h"
   6
   7 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   8
   9 int
  10 TAO_Reactive_Flushing_Strategy::schedule_output (TAO_Transport *transport)
  11 {
  12   return transport->schedule_output_i ();
  13 }
  14
  15 int
  16 TAO_Reactive_Flushing_Strategy::cancel_output (TAO_Transport *transport)
  17 {
  18   return transport->cancel_output_i ();
  19 }
  20
  21 int
  22 TAO_Reactive_Flushing_Strategy::flush_message (TAO_Transport *transport,
  23                                                TAO_Queued_Message *msg,
  24                                                ACE_Time_Value *max_wait_time)
  25 {
  26   int result = 0;
  27
  28   // @@ Should we pass this down?  Can we?
  29   try
  30     {
  31       TAO_ORB_Core * const orb_core = transport->orb_core ();
  32
  33       while (!msg->all_data_sent () && result >= 0)
  34         {
  35           result = orb_core->run (max_wait_time, 1);
  36
  37           if (max_wait_time != nullptr) {
  38             if (*max_wait_time <= ACE_Time_Value::zero) {
  39               errno = ETIME;
  40               result = -1;
  41             }
  42           }
  43         }
  44     }
  45   catch (const ::CORBA::Exception&)
  46     {
  47       return -1;
  48     }
  49
  50   return result;
  51 }
  52
  53 int
  54 TAO_Reactive_Flushing_Strategy::flush_transport (TAO_Transport *transport
  55                                                  , ACE_Time_Value *max_wait_time)
  56 {
  57   try
  58     {
  59       TAO_ORB_Core * const orb_core = transport->orb_core ();
  60
  61       while (!transport->queue_is_empty ())
  62         {
  63           if (orb_core->run (max_wait_time, 1) == -1)
  64             return -1;
  65
  66           if (max_wait_time != nullptr) {
  67             if (*max_wait_time <= ACE_Time_Value::zero) {
  68               errno = ETIME;
  69               return -1;
  70             }
  71           }
  72         }
  73     }
  74   catch (const ::CORBA::Exception&)
  75     {
  76       return -1;
  77     }
  78
  79   return 0;
  80 }
  81
  82 TAO_END_VERSIONED_NAMESPACE_DECL