summaryrefslogtreecommitdiff
path: root/examples/Reactor/Multicast/Log_Wrapper.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/Reactor/Multicast/Log_Wrapper.cpp')
-rw-r--r--examples/Reactor/Multicast/Log_Wrapper.cpp81
1 files changed, 0 insertions, 81 deletions
diff --git a/examples/Reactor/Multicast/Log_Wrapper.cpp b/examples/Reactor/Multicast/Log_Wrapper.cpp
deleted file mode 100644
index 055b57b9975..00000000000
--- a/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"
-
-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 defined (ACE_LACKS_UTSNAME_T)
- if ((host_info = ACE_OS::gethostbyname
- (ACE_TEXT_ALWAYS_CHAR(host_data.nodename))) == NULL)
-#else
- if ((host_info = ACE_OS::gethostbyname (host_data.nodename)) == NULL)
-#endif
- 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_.subscribe (server_) == -1)
- perror("can't subscribe to multicast group"), 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;
- this->log_msg_.time = time (0);
- this->log_msg_.msg_length = ACE_OS::strlen(message)+1;
- this->log_msg_.sequence_number = 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;
-}
-