aboutsummaryrefslogtreecommitdiff
path: root/externals/ace/Log_Msg_IPC.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'externals/ace/Log_Msg_IPC.cpp')
-rw-r--r--externals/ace/Log_Msg_IPC.cpp114
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