diff options
Diffstat (limited to 'externals/ace/Log_Msg_IPC.cpp')
-rw-r--r-- | externals/ace/Log_Msg_IPC.cpp | 114 |
1 files changed, 0 insertions, 114 deletions
diff --git a/externals/ace/Log_Msg_IPC.cpp b/externals/ace/Log_Msg_IPC.cpp deleted file mode 100644 index 830ebdfccb8..00000000000 --- a/externals/ace/Log_Msg_IPC.cpp +++ /dev/null @@ -1,114 +0,0 @@ -// $Id: Log_Msg_IPC.cpp 84527 2009-02-19 14:01:42Z johnnyw $ - -#include "ace/Log_Msg_IPC.h" -#include "ace/Log_Record.h" -#include "ace/CDR_Stream.h" -#include "ace/Truncate.h" - -ACE_RCSID(ace, Log_Msg_IPC, "$Id: Log_Msg_IPC.cpp 84527 2009-02-19 14:01:42Z johnnyw $") - -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -ACE_Log_Msg_IPC::ACE_Log_Msg_IPC (void) -{ -} - -ACE_Log_Msg_IPC::~ACE_Log_Msg_IPC (void) -{ - (void) this->close (); -} - -int -ACE_Log_Msg_IPC::open (const ACE_TCHAR *logger_key) -{ - ACE_LOG_MSG_IPC_CONNECTOR con; - return con.connect (this->message_queue_, - ACE_LOG_MSG_IPC_ADDR (logger_key)); -} - -int -ACE_Log_Msg_IPC::reset (void) -{ - if (this->message_queue_.get_handle () != ACE_INVALID_HANDLE) - { - // If we don't do this, handles aren't reused on Win32 and the - // server eventually crashes! - return this->close (); - } - return 0; -} - -int -ACE_Log_Msg_IPC::close (void) -{ - return this->message_queue_.close (); -} - -ssize_t -ACE_Log_Msg_IPC::log (ACE_Log_Record &log_record) -{ - // Serialize the log record using a CDR stream, allocate enough - // space for the complete <ACE_Log_Record>. - size_t const max_payload_size = - 4 // type - + 4 // pid - + 12 // timestamp - + 4 // process id - + 4 // data length -#if defined (ACE_USES_WCHAR) - + (log_record.msg_data_len () * ACE_OutputCDR::wchar_maxbytes()) // message -#else - + log_record.msg_data_len () // message -#endif - + ACE_CDR::MAX_ALIGNMENT; // padding; - - // Insert contents of <log_record> into payload stream. - ACE_OutputCDR payload (max_payload_size); - if (!(payload << log_record)) - return -1; - - // Get the number of bytes used by the CDR stream. If it becomes desireable - // to support payloads more than 4GB, this field will need to be changed - // to a 64-bit value. - ACE_CDR::ULong const length = - ACE_Utils::truncate_cast<ACE_CDR::ULong> (payload.total_length ()); - - // Send a header so the receiver can determine the byte order and - // size of the incoming CDR stream. - ACE_OutputCDR header (ACE_CDR::MAX_ALIGNMENT + 8); - if (!(header << ACE_OutputCDR::from_boolean (ACE_CDR_BYTE_ORDER))) - return -1; - - // Store the size of the payload that follows - if (!(header << ACE_CDR::ULong (length))) - return -1; - - // Use an iovec to send both buffer and payload simultaneously. - iovec iov[2]; - iov[0].iov_base = header.begin ()->rd_ptr (); - iov[0].iov_len = 8; - iov[1].iov_base = payload.begin ()->rd_ptr (); - iov[1].iov_len = length; - -#if (ACE_HAS_STREAM_LOG_MSG_IPC == 1) - // Use the <putpmsg> API if supported to ensure correct message - // queueing according to priority. - - ACE_Str_Buf header_msg (static_cast<void *> (header.begin ()->rd_ptr ()), - static_cast<int> (8)); - - ACE_Str_Buf payload_msg (static_cast<void *> (payload.begin ()->rd_ptr ()), - static_cast<int> (length)); - - return this->message_queue_.send (&header_msg, - &payload_msg, - static_cast<int> (log_record.priority ()), - MSG_BAND); -#else - // We're running over sockets, so send header and payload - // efficiently using "gather-write". - return this->message_queue_.sendv_n (iov, 2); -#endif /* ACE_HAS_STREAM_LOG_MSG_IPC */ -} - -ACE_END_VERSIONED_NAMESPACE_DECL |