diff options
Diffstat (limited to 'ACE/examples/Reactor/Multicast/Log_Wrapper.cpp')
-rw-r--r-- | ACE/examples/Reactor/Multicast/Log_Wrapper.cpp | 81 |
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; -} - |