summaryrefslogtreecommitdiff
path: root/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/examples/Reactor/Multicast/Log_Wrapper.cpp')
-rw-r--r--ACE/examples/Reactor/Multicast/Log_Wrapper.cpp81
1 files changed, 0 insertions, 81 deletions
diff --git a/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp b/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp
deleted file mode 100644
index 4a5a6c78938..00000000000
--- a/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp
+++ /dev/null
@@ -1,81 +0,0 @@
-// $Id$
-
-// client.C
-
-#include "Log_Wrapper.h"
-#include "ace/OS_NS_unistd.h"
-#include "ace/OS_NS_sys_utsname.h"
-#include "ace/OS_NS_string.h"
-#include "ace/OS_NS_netdb.h"
-#include "ace/OS_NS_stdio.h"
-#include "ace/OS_NS_time.h"
-#include "ace/OS_NS_stdlib.h"
-
-ACE_RCSID(Multicast, Log_Wrapper, "$Id$")
-
-Log_Wrapper::Log_Wrapper (void)
-{
- sequence_number_ = 0;
- this->log_msg_.app_id = ACE_OS::getpid ();
-}
-
-Log_Wrapper::~Log_Wrapper (void)
-{
-}
-
-// Set the log_msg_ host address.
-
-int
-Log_Wrapper::open (const int port, const char *mcast_addr)
-{
- struct hostent *host_info;
- ACE_utsname host_data;
-
- if (ACE_OS::uname (&host_data) < 0)
- return -1;
-
- if ((host_info = ACE_OS::gethostbyname (host_data.nodename)) == 0)
- return -1;
- else
- ACE_OS::memcpy ((char *) &this->log_msg_.host,
- (char *) host_info->h_addr,
- host_info->h_length);
-
- // This starts out initialized to all zeros!
- server_ = ACE_INET_Addr (port, mcast_addr);
-
- if (logger_.join (server_) == -1)
- ACE_OS::perror("can't join to multicast group"), ACE_OS::exit(1);
-
- // success.
- return 0;
-}
-
-// Send the message to a logger object.
-// This wrapper fills in all the log_record info for you.
-// uses iovector stuff to make contiguous header and message.
-
-int
-Log_Wrapper::log_message (Log_Priority type, char *message)
-{
- sequence_number_++;
-
- this->log_msg_.type = type;
- // Casting time() to long will start causing bad results sometime in 2038
- // but the receiver isn't looking at the time, so who cares?
- this->log_msg_.time = (long) ACE_OS::time (0);
- this->log_msg_.msg_length = ACE_OS::strlen(message)+1;
- this->log_msg_.sequence_number = ACE_HTONL(sequence_number_);
-
- iovec iovp[2];
- iovp[0].iov_base = reinterpret_cast<char*> (&log_msg_);
- iovp[0].iov_len = sizeof (log_msg_);
- iovp[1].iov_base = message;
- iovp[1].iov_len = log_msg_.msg_length;
-
- logger_.send (iovp, 2);
-
- // success.
- return 0;
-}
-