logging_client.h

ACE 学习代码。用ACE实现的学习代码

/*
** Logging_Client.cpp,v 1.11 2003/11/10 01:48:03 dhinton Exp
**
** Copyright 2001 Addison Wesley. All Rights Reserved.
*/

#include "ace/OS_NS_sys_time.h"
#include "ace/CDR_Stream.h"
#include "ace/INET_Addr.h"
//#include "ace/SOCK_Connector.h"
//#include "ace/SOCK_Stream.h"

// FUZZ: disable check_for_streams_include
//#include "ace/streams.h"

#if defined (ACE_WIN32) && (!defined (ACE_HAS_STANDARD_CPP_LIBRARY) || \
                            (ACE_HAS_STANDARD_CPP_LIBRARY == 0))
#  include <stdio.h>
#else
#  include <string>
#endif

#define MAX_NAME_LENGTH 255

class Logging_Client {
private:
  ACE_SOCK_Stream logging_peer_;

public:
  ACE_SOCK_Stream &peer () { return logging_peer_; }

  int send_msg (const char* msg_record,const int msg_length) {

    ACE_OutputCDR payload (ACE_CDR::MAX_ALIGNMENT + msg_length);
    payload.write_char_array(msg_record,msg_length);
    ACE_CDR::ULong length = payload.total_length ();

    ACE_OutputCDR header (ACE_CDR::MAX_ALIGNMENT + 8);
    header << ACE_OutputCDR::from_boolean (ACE_CDR_BYTE_ORDER);

    // Store the size of the payload that follows
    header << ACE_CDR::ULong (msg_length);
    // Use an iovec to send both buffer and payload simultaneously.
    iovec iov[2];
    iov[0].iov_base = header.begin ()->rd_ptr ();
    iov[0].iov_len  = 8;
    iov[1].iov_base = payload.begin ()->rd_ptr ();
    iov[1].iov_len  = length;

    // Send header and payload efficiently using "gather-write".
    return logging_peer_.sendv_n (iov, 2);
  }

  int send_file (const char* filename,const char* msg_record,const int msg_length) 
  {
	//内容
    ACE_OutputCDR payload (ACE_CDR::MAX_ALIGNMENT + MAX_NAME_LENGTH + msg_length);
    payload.write_char_array(filename,MAX_NAME_LENGTH);
	payload.write_char_array(msg_record,msg_length);
    
	//head
    ACE_OutputCDR header(ACE_CDR::MAX_ALIGNMENT + 8);
    header<< ACE_OutputCDR::from_boolean (ACE_CDR_BYTE_ORDER);
    header<< ACE_CDR::ULong (MAX_NAME_LENGTH+msg_length);
	
    // Use an iovec to send both buffer and payload simultaneously.
    iovec iov[2];
	iov[0].iov_base = header.begin ()->rd_ptr ();
    iov[0].iov_len  = 8;
    iov[1].iov_base = payload.begin ()->rd_ptr ();
    iov[1].iov_len  = MAX_NAME_LENGTH+msg_length;

    // Send header and payload efficiently using "gather-write".
    return logging_peer_.sendv_n (iov, 2);
  }

  ~Logging_Client () { logging_peer_.close (); }
};
Logging_Client logging_client;