1 files changed, 178 insertions, 0 deletions
diff --git a/trunk/ACE/netsvcs/lib/Log_Message_Receiver.cpp b/trunk/ACE/netsvcs/lib/Log_Message_Receiver.cpp
new file mode 100644
index 00000000000..b6496232bd3
--- /dev/null
+++ b/trunk/ACE/netsvcs/lib/Log_Message_Receiver.cpp
@@ -0,0 +1,178 @@
+// $Id$
+
+#if !defined (LOG_MESSAGE_RECEIVER_CPP)
+#define LOG_MESSAGE_RECEIVER_CPP
+
+#include "ace/Log_Msg.h"
+#include "Log_Message_Receiver.h"
+
+ACE_RCSID(lib, Log_Message_Receiver, "$Id$")
+
+// Type based log message receiver
+template<ACE_SYNCH_DECL> void
+Static_Log_Message_Receiver<ACE_SYNCH_USE>::log_record (const ACE_TCHAR *hostname,
+                                                        ACE_Log_Record &record)
+{
+#if defined (ACE_HAS_THREADS)
+    static ACE_SYNCH_MUTEX_T lock_;
+    ACE_GUARD (ACE_SYNCH_MUTEX_T, guard, lock_);
+#endif /* ACE_HAS_THREADS */
+
+  record.print (hostname,
+                ACE_Log_Msg::instance ()->flags (),
+                stderr);
+}
+
+template<ACE_SYNCH_DECL> void
+Static_Log_Message_Receiver<ACE_SYNCH_USE>::log_output (const ACE_TCHAR *hostname,
+                                                        ACE_Log_Record &record,
+                                                        ostream *outputfile)
+{
+  if (outputfile != 0)
+    {
+#if defined (ACE_HAS_THREADS)
+      static ACE_SYNCH_MUTEX_T lock_;
+      ACE_GUARD (ACE_SYNCH_MUTEX_T, guard, lock_);
+#endif /* ACE_HAS_THREADS */
+      record.print (hostname,
+                    ACE_Log_Msg::instance ()->flags (),
+                    *outputfile);
+    }
+}
+
+#if !defined (ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES)
+template<ACE_SYNCH_DECL>
+ACE_SYNCH_MUTEX_T Log_Message_Receiver_Impl<ACE_SYNCH_USE>::copy_lock_;
+#else
+static ACE_SYNCH_MUTEX global_copy_lock_;
+#endif /* ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES */
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::Log_Message_Receiver_Impl (void)
+  : count_ (0)
+{
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver_Impl<ACE_SYNCH_USE> *
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::create (void)
+{
+  return new Log_Message_Receiver_Impl<ACE_SYNCH_USE>;
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver_Impl<ACE_SYNCH_USE> *
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::attach (Log_Message_Receiver_Impl<ACE_SYNCH_USE> *body)
+{
+  ACE_ASSERT (body != 0);
+
+#if defined (ACE_HAS_THREADS)
+#  if !defined (ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES)
+  Guard guard (copy_lock_);
+  if (guard.locked () == 0)
+    return 0;
+#  else
+  // Use the "body"s print lock as copy lock.
+  ACE_GUARD_RETURN (ACE_SYNCH_MUTEX,
+                    guard,
+                    global_copy_lock_,
+                    0);
+#  endif /* ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES */
+#endif /* ACE_HAS_THREADS */
+  ++body->count_;
+  return body;
+}
+
+template<ACE_SYNCH_DECL> void
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::detach (Log_Message_Receiver_Impl<ACE_SYNCH_USE> *body)
+{
+  ACE_ASSERT (body != 0);
+
+#if defined (ACE_HAS_THREADS)
+#  if !defined (ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES)
+  Guard guard (copy_lock_);
+  if (guard.locked () == 0)
+    return;
+#  else
+  // Use the "body"s print lock as copy lock.
+  ACE_GUARD (ACE_SYNCH_MUTEX,
+             guard,
+             global_copy_lock_);
+#  endif /* ACE_LACKS_STATIC_DATA_MEMBER_TEMPLATES */
+#endif /* ACE_HAS_THREADS */
+  if (body->count_-- == 0)
+    delete body;
+}
+
+// Type based log message receiver
+template<ACE_SYNCH_DECL> void
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::log_record (const ACE_TCHAR *hostname,
+                                                      ACE_Log_Record &record)
+{
+  ACE_MT (ACE_GUARD (ACE_SYNCH_MUTEX_T, guard, print_lock_));
+  record.print (hostname,
+                ACE_Log_Msg::instance ()->flags (),
+                stderr);
+}
+
+template<ACE_SYNCH_DECL> void
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::log_output (const ACE_TCHAR *hostname,
+                                                      ACE_Log_Record &record,
+                                                      ostream *outputfile)
+{
+  if (outputfile != 0)
+    {
+      ACE_MT (ACE_GUARD (ACE_SYNCH_MUTEX_T, guard, print_lock_));
+      record.print (hostname,
+                    ACE_Log_Msg::instance ()->flags (),
+                    *outputfile);
+    }
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver_Impl<ACE_SYNCH_USE>::~Log_Message_Receiver_Impl (void)
+{
+  ACE_ASSERT (count_ == 0 - 1);
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver<ACE_SYNCH_USE>::Log_Message_Receiver (void)
+  : receiver_impl_ (Log_Message_Receiver_Impl<ACE_SYNCH_USE>::create ())
+{
+  ACE_ASSERT (receiver_impl_ != 0);
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver<ACE_SYNCH_USE>::Log_Message_Receiver
+  (Log_Message_Receiver<ACE_SYNCH_USE> const &rhs)
+    : receiver_impl_ (Log_Message_Receiver_Impl<ACE_SYNCH_USE>::attach (rhs.receiver_impl_))
+{
+  ACE_ASSERT (receiver_impl_ != 0);
+}
+
+// Type based log message receiver
+template<ACE_SYNCH_DECL> void
+Log_Message_Receiver<ACE_SYNCH_USE>::log_record(const ACE_TCHAR *hostname,
+                                                ACE_Log_Record &record)
+{
+  ACE_ASSERT (receiver_impl_ != 0);
+  receiver_impl_->log_record (hostname, record);
+}
+
+template<ACE_SYNCH_DECL> void
+Log_Message_Receiver<ACE_SYNCH_USE>::log_output(const ACE_TCHAR *hostname,
+                                                ACE_Log_Record &record,
+                                                ostream *outputfile)
+{
+  ACE_ASSERT (receiver_impl_ != 0);
+  receiver_impl_->log_output (hostname, record, outputfile);
+}
+
+template<ACE_SYNCH_DECL>
+Log_Message_Receiver<ACE_SYNCH_USE>::~Log_Message_Receiver (void)
+{
+  ACE_ASSERT (receiver_impl_ != 0);
+  Log_Message_Receiver_Impl<ACE_SYNCH_USE>::detach (receiver_impl_);
+}
+
+#endif /* LOG_MESSAGE_RECEIVER_CPP */