log.c

h.248源代码

/********************************************************************
 *
 * File:        log.c
 *
 * Description:
 *         Log functionality.
 *
 * Revisions:
 *   04-may-01    J.H and S.J.M        initial version.
 *
 * Copyright 2003 Netergy Microelectronics, Inc. All rights reserved.
 *
 ********************************************************************/

#include "NNstyle.h"

#include <sys/types.h>    /* for socket() */
#include <sys/socket.h>   /* for socket() */
#include <netinet/in.h>   /* for inet_ntoa() */
#include <arpa/inet.h>    /* for inet_ntoa() */
#include <unistd.h>       /* for fcntl() */
#include <fcntl.h>        /* for fcntl() */
#include <sys/time.h>
#include <string.h>

#include "protocol.h"
#include "configapi.h"
#include "stdlib.h"

#define MSGLOG_IP   "132.177.125.179"

WORD g_wMsgPort = 5700;

void MessageLog(int nConn, E_PROTOCOL_TXRX eTxRx, char* pchData, int nLen)
{
  static int nSocket = 0;
  static struct sockaddr_in sinAddr;
  static char sBuffer[1500];
  struct timeval tv;

  gettimeofday(&tv, NULL);

  if (nSocket == 0) {
    DWORD dwIpAddr;

    nSocket = socket(AF_INET, SOCK_DGRAM, 0);
    ASSERT(nSocket);
#ifndef _NNOS
    inet_pton(AF_INET, MSGLOG_IP, (struct in_addr *)&dwIpAddr);
#else
    {
      char chParamValue[CONFIG_MAXPARAMLENGTH+1];
      // get MG port
      if (ConfigGetParam("MSGLOGIP", chParamValue, CONFIG_MAXPARAMLENGTH) ==
          CONFIG_OK){
	inet_pton(AF_INET, chParamValue, (struct in_addr *)&dwIpAddr);
      }
      else {
	inet_pton(AF_INET, MSGLOG_IP, (struct in_addr *)&dwIpAddr);
      }

      if (ConfigGetParam("MSGLOGPORT", chParamValue, CONFIG_MAXPARAMLENGTH) ==
          CONFIG_OK){
	g_wMsgPort = (DWORD)strtoul(chParamValue,NULL,0);
      }
    }
#endif
    memset(&sinAddr, 0, sizeof(sinAddr));
    sinAddr.sin_family = AF_INET;
    sinAddr.sin_port = htons(g_wMsgPort);
    sinAddr.sin_addr.s_addr = dwIpAddr;
  }

  if (eTxRx == PROTOCOL_TXRX_RX) {
    sprintf(sBuffer,
            "===== Received Message ===== time %ld:%ld, socket %d\n%s\n",
	    (DWORD)tv.tv_sec, (DWORD)tv.tv_usec, nConn, pchData);
  }
  else if (eTxRx == PROTOCOL_TXRX_TX) {
    sprintf(sBuffer, "===== Sent Message ===== time %ld:%ld, socket %d\n%s\n",
	    (DWORD)tv.tv_sec, (DWORD)tv.tv_usec, nConn, pchData);
  }

  sendto(nSocket, sBuffer, strlen(sBuffer), 0,
	 (struct sockaddr *) &sinAddr, sizeof(sinAddr));
}