summaryrefslogtreecommitdiff
path: root/ACE/ace/Log_Msg_IPC.cpp
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2008-03-04 13:56:48 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2008-03-04 13:56:48 +0000
commitc4078c377d74290ebe4e66da0b4975da91732376 (patch)
tree1816ef391e42a07929304908ac0e21f4c2f6cb7b /ACE/ace/Log_Msg_IPC.cpp
parent700d1c1a6be348c6c70a2085e559baeb8f4a62ea (diff)
downloadATCD-c4078c377d74290ebe4e66da0b4975da91732376.tar.gz
swap in externals for ACE and TAO
Diffstat (limited to 'ACE/ace/Log_Msg_IPC.cpp')
-rw-r--r--ACE/ace/Log_Msg_IPC.cpp111
1 files changed, 0 insertions, 111 deletions
diff --git a/ACE/ace/Log_Msg_IPC.cpp b/ACE/ace/Log_Msg_IPC.cpp
deleted file mode 100644
index 82411a3cf92..00000000000
--- a/ACE/ace/Log_Msg_IPC.cpp
+++ /dev/null
@@ -1,111 +0,0 @@
-// $Id$
-
-#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$")
-
-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);
- payload << log_record;
-
- // 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 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);
- header << ACE_OutputCDR::from_boolean (ACE_CDR_BYTE_ORDER);
-
- // Store the size of the payload that follows
- header << ACE_CDR::ULong (length);
-
- // 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 defined (ACE_HAS_STREAM_PIPES)
- // 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_PIPES */
-}
-
-ACE_END_VERSIONED_NAMESPACE_DECL