root/trunk/src/remote_output.c @ 6

/*
 * 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)
{
  fprintf(stderr, " socket : %d\n", rHPtr->sockId);
  fprintf(stderr, " address : %s:%u\n", 
          inet_ntoa(rHPtr->hostAddressPtr->sin_addr), 
          ntohs(rHPtr->hostAddressPtr->sin_port));
}

/*
 * freeRemoteHost()
 */
void
freeRemoteHost(RemoteHostPtr rHPtr)
{
  if (rHPtr->msgIpv4){
    free(rHPtr->msgIpv4);
    rHPtr->msgIpv4 = NULL;
  }
  if (rHPtr->msgIpv6){
    free(rHPtr->msgIpv6);
    rHPtr->msgIpv6 = NULL;
  }
  if (rHPtr->msgXcast){
    free(rHPtr->msgXcast);
    rHPtr->msgXcast = 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, int remote_port, struct sockaddr_in *addr)
{
  int s;
  s = socket(AF_INET, SOCK_DGRAM, 0);
  if (s < 0)
    {
      perror("opening datagram socket");
      exit(1);
    }
  memset(addr, 0, sizeof(struct sockaddr_in));
  addr->sin_addr.s_addr = inet_addr(remote_address); /* FIXME obsolete */
  addr->sin_family = AF_INET;
  addr->sin_port = htons(remote_port);
  return s;
}

/*
 * send_message
 */
int 
sendMessage(int socket_number, unsigned char *msg, int msgSize,
            struct sockaddr_in *addr)
{
  int s;
  if ((s=sendto(socket_number, msg, (size_t)msgSize, 0, 
                (struct sockaddr *)addr,
                sizeof(struct sockaddr_in))) < 0)
    {
      fprintf(stderr, "Error ******** : %d bytes sent\n", s);
      perror("sending packet");
      exit(1);
    }
  return s;
}