ACE/apps/JAWS3/jaws3/Jaws_IO.cpp

   1 #ifndef JAWS_BUILD_DLL
   2 #define JAWS_BUILD_DLL
   3 #endif /*JAWS_BUILD_DLL*/
   4
   5 #include "ace/OS_NS_strings.h"
   6
   7 #include "jaws3/Jaws_IO.h"
   8 #include "jaws3/Asynch_IO.h"
   9 #include "jaws3/Synch_IO.h"
  10 #include "jaws3/Reactive_IO.h"
  11 #include "jaws3/Options.h"
  12
  13 JAWS_IO::JAWS_IO (JAWS_IO_Impl *impl)
  14   : impl_ (impl)
  15 {
  16   // Use synchronous IO by default.  It is the most efficient
  17   // in terms of calls needed, but provides the least amount
  18   // of support for concurrency.
  19
  20   if (this->impl_ == 0)
  21     {
  22       const char *io_type = JAWS_Options::instance ()->getenv ("JAWS_IO");
  23       if (io_type == 0)
  24         io_type = JAWS_DEFAULT_IO;
  25
  26       if (ACE_OS::strcasecmp (io_type, "SYNCH") == 0)
  27         this->impl_ = JAWS_Synch_IO::instance ();
  28       else if (ACE_OS::strcasecmp (io_type, "ASYNCH") == 0)
  29         this->impl_ = JAWS_Asynch_IO::instance ();
  30       else if (ACE_OS::strcasecmp (io_type, "REACTIVE") == 0)
  31         this->impl_ = JAWS_Reactive_IO::instance ();
  32       else
  33         this->impl_ = JAWS_Synch_IO::instance ();
  34     }
  35 }
  36
  37 JAWS_IO::~JAWS_IO ()
  38 {
  39 }
  40
  41
  42 void
  43 JAWS_IO::send ( ACE_HANDLE handle
  44               , ACE_Message_Block *mb
  45               , JAWS_Event_Completer *completer
  46               , void *act
  47               )
  48 {
  49   this->impl_->send (handle, mb, completer, act);
  50 }
  51
  52
  53 void
  54 JAWS_IO::recv ( ACE_HANDLE handle
  55               , ACE_Message_Block *mb
  56               , JAWS_Event_Completer *completer
  57               , void *act
  58               )
  59 {
  60   this->impl_->recv (handle, mb, completer, act);
  61 }
  62
  63
  64 void
  65 JAWS_IO::transmit ( ACE_HANDLE handle
  66                   , ACE_HANDLE source
  67                   , JAWS_Event_Completer *completer
  68                   , void *act
  69                   , ACE_Message_Block *header
  70                   , ACE_Message_Block *trailer
  71                   )
  72 {
  73   this->impl_->transmit (handle, source, completer, act, header, trailer);
  74 }
  75
  76
  77 void
  78 JAWS_IO::send ( ACE_HANDLE handle
  79               , ACE_Message_Block *mb
  80               , JAWS_Event_Completer *completer
  81               , const ACE_Time_Value &tv
  82               , void *act
  83               )
  84 {
  85   this->impl_->send (handle, mb, completer, tv, act);
  86 }
  87
  88
  89 void
  90 JAWS_IO::recv ( ACE_HANDLE handle
  91               , ACE_Message_Block *mb
  92               , JAWS_Event_Completer *completer
  93               , const ACE_Time_Value &tv
  94               , void *act
  95               )
  96 {
  97   this->impl_->recv (handle, mb, completer, tv, act);
  98 }
  99
 100
 101 void
 102 JAWS_IO::transmit ( ACE_HANDLE handle
 103                   , ACE_HANDLE source
 104                   , JAWS_Event_Completer *completer
 105                   , const ACE_Time_Value &tv
 106                   , void *act
 107                   , ACE_Message_Block *header
 108                   , ACE_Message_Block *trailer
 109                   )
 110 {
 111   this->impl_->transmit (handle, source, completer, tv, act, header, trailer);
 112 }