Initial revision

1 files changed, 136 insertions, 0 deletions

diff --git a/ace/Log_Record.cpp b/ace/Log_Record.cpp
new file mode 100644
index 00000000000..cee731cb0da
--- /dev/null
+++ b/ace/Log_Record.cpp
@@ -0,0 +1,136 @@
+// Log_Record.cpp
+// $Id$
+
+#define ACE_BUILD_DLL
+#include "ace/Log_Msg.h"
+#include "ace/Log_Record.h"
+
+ACE_ALLOC_HOOK_DEFINE(ACE_Log_Record)
+
+void
+ACE_Log_Record::dump (void) const
+{
+  // ACE_TRACE ("ACE_Log_Record::dump");
+
+  ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this));
+  ACE_DEBUG ((LM_DEBUG, "type_ = %d\n", this->type_));
+  ACE_DEBUG ((LM_DEBUG, "\nlength_ = %d\n", this->length_));
+  ACE_DEBUG ((LM_DEBUG, "\nlength_ = %d\n", this->time_stamp_));
+  ACE_DEBUG ((LM_DEBUG, "\ntime_stamp_ = %s\n", this->pid_));
+  ACE_DEBUG ((LM_DEBUG, "\nmsg_data_ = %s\n", this->msg_data_));
+  ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP));
+}
+
+void 
+ACE_Log_Record::msg_data (const char *data)
+{
+  // ACE_TRACE ("ACE_Log_Record::msg_data");
+  ACE_OS::strncpy (this->msg_data_, data, ACE_Log_Record::MAXLOGMSGLEN);
+  this->round_up ();
+}
+
+ACE_Log_Record::ACE_Log_Record (ACE_Log_Priority lp, 
+				long ts, 
+				long p)
+  : type_ (long (lp)), 
+    length_ (0),
+    time_stamp_ (ts), 
+    pid_ (p)
+{
+  // ACE_TRACE ("ACE_Log_Record::ACE_Log_Record");
+}
+
+void
+ACE_Log_Record::round_up (void)
+{
+  // ACE_TRACE ("ACE_Log_Record::round_up");
+  // Determine the length of the payload.
+  int len = (sizeof *this - MAXLOGMSGLEN) 
+    + (ACE_OS::strlen (this->msg_data_) + 1);
+
+  // Round up to the alignment.
+  this->length_ = 1 + ((len + ACE_Log_Record::ALIGN_WORDB - 1) 
+		       & ~(ACE_Log_Record::ALIGN_WORDB - 1));
+}
+
+ACE_Log_Record::ACE_Log_Record (void)
+  : type_ (0),
+    length_ (0),
+    time_stamp_ (0),
+    pid_ (0)
+{
+  // ACE_TRACE ("ACE_Log_Record::ACE_Log_Record");
+}
+
+// Print out the record on the stderr stream with the appropriate
+// format.
+
+int
+ACE_Log_Record::print (const char host_name[],
+		       int verbose, 
+		       FILE *fp,
+		       size_t len)
+{
+  // ACE_TRACE ("ACE_Log_Record::print");
+
+  if (verbose)
+    {
+      time_t now = this->time_stamp_;
+      char ctp[26]; // 26 is a magic number...
+
+      if (ACE_OS::ctime_r (&now, ctp, sizeof ctp) == 0)
+	return -1;
+
+      /* 01234567890123456789012345 */
+      /* Wed Oct 18 14:25:36 1989n0 */
+
+      ctp[24] = '\0';
+
+      if (host_name == 0)
+	host_name = "<local_host>";
+
+      return ACE_OS::fprintf (fp, "%s@%s@%d@%d@%s", 
+			      ctp + 4, host_name, this->pid_,
+			      this->type_, this->msg_data_);
+    }
+  else
+    return ACE_OS::fprintf (fp, "%s", this->msg_data_);
+}
+
+int
+ACE_Log_Record::print (const char host_name[],
+		       int verbose, 
+		       ostream &s,
+		       size_t len)
+{
+  // ACE_TRACE ("ACE_Log_Record::print");
+
+  if (verbose)
+    {
+      time_t now = this->time_stamp_;
+      char ctp[26]; // 26 is a magic number...
+      if (ACE_OS::ctime_r (&now, ctp, sizeof ctp) == 0)
+	return -1;
+
+      /* 01234567890123456789012345 */
+      /* Wed Oct 18 14:25:36 1989n0 */
+
+      ctp[24] = '\0';
+
+      if (host_name == 0)
+	host_name = "<local_host>";
+
+      s << (ctp + 4)
+	<< '@'
+	<< host_name
+	<< '@'
+	<< this->pid_
+	<< '@'
+	<< this->type_
+	<< '@';
+    }
+
+  s << this->msg_data_;
+  s.flush ();
+  return 0;
+}