root/trunk/src/remote_output.c @ 8

/*
 * File: remote_output.c
 * 
 * Authors: ANDREU François-Xavier 
 *
 * Copyright (C) 2005 GIP RENATER 
 */

/*  This file is part of renetcol. 
 *
 *  renetcol is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  renetcol is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with renetcol; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include <string.h> /* for memset */
#include "remote_output.h"


void 
printHostDef(RemoteHostPtr rHPtr)
{
  char buf[256];
  fprintf(stderr, " socket : %d\n", rHPtr->sockId);
  switch (rHPtr->hostAddressPtr->ss_family){
  case AF_INET:
    fprintf(stderr, " address : %s\n", 
            inet_ntop(rHPtr->hostAddressPtr->ss_family,
                      &((struct sockaddr_in *)rHPtr->hostAddressPtr)->sin_addr,
                      buf, 256));
    break;
  case AF_INET6:
    fprintf(stderr, " address : %s\n",
            inet_ntop(rHPtr->hostAddressPtr->ss_family,
                      &((struct sockaddr_in6 *)rHPtr->hostAddressPtr)->sin6_addr,
                      buf, 256));
    break;
  }
}

/*
 * freeRemoteHost()
 */
void
freeRemoteHost(RemoteHostPtr rHPtr)
{
  if (rHPtr->hostAddressPtr){
    free(rHPtr->hostAddressPtr);
    rHPtr->hostAddressPtr = NULL;
  }
  free(rHPtr);
  rHPtr = NULL;
}

/*
 * freeDb()
 */
void
freeDb(DbPtr dbPtr)
{
  if (dbPtr->dbName){
    free(dbPtr->dbName);
    dbPtr->dbName = NULL;
  }
  if (dbPtr->password){
    free(dbPtr->password);
    dbPtr->password = NULL;
  }
  if (dbPtr->tableName){
    free(dbPtr->tableName);
    dbPtr->tableName = NULL;
  }  
  free(dbPtr);
  dbPtr = NULL;
}

/*
 * freeFile()
 */
void
freeFile(FilePtr fPtr)
{
  if (fPtr->fileName){
    free(fPtr->fileName);
    fPtr->fileName = NULL;
  }
  free(fPtr);
  fPtr = NULL;
}

/*
 * create_socket
 */
int 
create_socket(char *remote_address, char *remote_port, struct sockaddr_storage *addr)
{
  int s;
  struct addrinfo index, *res=NULL;
  int code;

  memset(&index, 0, sizeof index);
  index.ai_family = AF_UNSPEC;
  index.ai_socktype = SOCK_DGRAM;
  index.ai_protocol = IPPROTO_UDP;  
  code = getaddrinfo(remote_address, remote_port, &index, &res);
  if (code!=0) {
    syslog(LOG_ERR, "Error, %s : %s", gai_strerror(code), remote_address);
    return 0;
  }
  s = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
  if (s < 0)
    {
      syslog(LOG_ERR,"Error during opening datagram socket %s", 
             strerror(errno));
      return 0;
    }
  switch (res->ai_family){
  case AF_INET6:
    addr->ss_family = AF_INET6;
    ((struct sockaddr_in6 *)addr)->sin6_addr = ((struct sockaddr_in6 *)res->ai_addr)->sin6_addr;
    ((struct sockaddr_in6 *)addr)->sin6_port = 
      htons((unsigned short)atoi(remote_port));
    break;
  case AF_INET:
    ((struct sockaddr_in *)addr)->sin_addr = ((struct sockaddr_in *)res->ai_addr)->sin_addr;
    addr->ss_family = AF_INET;
    ((struct sockaddr_in *)addr)->sin_port = 
      htons((unsigned short)atoi(remote_port));
    break;
  case AF_UNSPEC:
    break;
  }
  freeaddrinfo(res);
  return s;
}

/*
 * send_message
 */
int 
sendMessage(int socket_number, unsigned char *msg, int msgSize,
            struct sockaddr_storage *addr)
{
  int s;
  socklen_t addrlen = sizeof(struct sockaddr_storage);
  if ((s=sendto(socket_number, msg, (size_t)msgSize, 0, 
                (struct sockaddr *)addr, addrlen)) < 0)
    {
      syslog(LOG_ERR, "Error: %d bytes sent, %s",
             s, strerror(errno));
      exit(1);
    }
  return s;
}