ACE/ace/FIFO_Send_Msg.inl

   1 // -*- C++ -*-
   2 #include "ace/OS_NS_stropts.h"
   3
   4 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 ACE_INLINE ssize_t
   7 ACE_FIFO_Send_Msg::send (const void *buf, size_t len)
   8 {
   9   ACE_TRACE ("ACE_FIFO_Send_Msg::send");
  10   ACE_Str_Buf send_msg ((char *) buf, static_cast<int> (len));
  11
  12   return this->send (send_msg);
  13 }
  14
  15 #if defined (ACE_HAS_STREAM_PIPES)
  16 ACE_INLINE ssize_t
  17 ACE_FIFO_Send_Msg::send (const ACE_Str_Buf *data,
  18                          const ACE_Str_Buf *cntl,
  19                          int flags)
  20 {
  21   ACE_TRACE ("ACE_FIFO_Send_Msg::send");
  22   if (ACE_OS::putmsg (this->get_handle (),
  23                       (strbuf *) cntl,
  24                       (strbuf *) data,
  25                       flags) == -1)
  26     return-1;
  27   else
  28     return (cntl == 0 ? 0 : cntl->len) + (data == 0 ? 0 : data->len);
  29 }
  30
  31 ACE_INLINE ssize_t
  32 ACE_FIFO_Send_Msg::send (int band,
  33                          const ACE_Str_Buf *data,
  34                          const ACE_Str_Buf *cntl,
  35                          int flags)
  36 {
  37   ACE_TRACE ("ACE_FIFO_Send_Msg::send");
  38
  39   if (ACE_OS::putpmsg (this->get_handle (),
  40                        (strbuf *) cntl,
  41                        (strbuf *) data,
  42                        band,
  43                        flags) == -1)
  44     return -1;
  45   else
  46     return (cntl == 0 ? 0 : cntl->len) + (data == 0 ? 0 : data->len);
  47 }
  48 #endif /* ACE_HAS_STREAM_PIPES */
  49
  50 ACE_END_VERSIONED_NAMESPACE_DECL