Colony

/** 

 * @file initialization.c

 *

 *  @author Jason Knichel

 *  @author Eugene Marinelli

 */

#include <sys/socket.h>

#include <sys/types.h>

#include <netinet/in.h>

#include <string.h>

#include <fcntl.h>

#include <unistd.h>

#include <stdio.h>

#include <stdlib.h>

#include "includes/initialization.h"

#include "includes/client.h"

#include "includes/options.h"

#include "includes/Logging.h"

extern int listenSocket;

/*

int parseCommandLine(int argc, char * argv[], commandParams_t * params)

{

  printf("Parsing Command Line...\n");

  if (!params)

    return -1;

  //if no command line parameters were specified, set to defaults

  if (argc == 1) {

    printf("No port was specified for listening for client connections."

           "  Defaulting to %d\n", DEFAULTPORT);

    params->listenPort = DEFAULTPORT;

  }

  if (!argv)

    return -1;

  int i;

  for (i = 1; i < argc; i++) {

    char * temp = argv[i];

    if (temp[0] != '-')

      {

        printUsage(argv[0]);

        return -1;

      }

    switch(temp[1])

      {

      case 'h': printUsage(argv[0]);

        break;

      case 'p': 

        {

          if (i >= argc-1)

            {

              printUsage(argv[0]);

              return -1;

            }

          i++;

          char * portString = argv[i];

          char * endptr = NULL;

          int port = strtol(portString, &endptr, 10);

          if (*endptr != '\0')

            {

              printf("Invalid port specified...%s, %d\n", endptr, port);

              return -1;

            }

          if (port < SMALLEST_POSS_LISTEN_PORT)

            {

              printf("You cannot listen on a port less than %d.\n",

                     SMALLEST_POSS_LISTEN_PORT);

              return -1;

            }

          params->listenPort = port;

          printf("Setting port to listen on to %d.\n", params->listenPort);

        }

        break;

      default: printUsage(argv[0]);

        return -1;

        break;

      }

  }

  return 0;

}

*/

int initConnection(int port)

{

  printf("Initializing connection that will be used to listen for " 

         "clients...\n");

  int opts = 1;

  struct sockaddr_in my_addr;

  //get a socket fd

  if ((listenSocket = socket(AF_INET, SOCK_STREAM, 0)) < 0) {

    printf("\tThere was an error creating a socket\n");

    return -1;

  }

  //set up the address struct

  memset(&my_addr,'\0',sizeof(my_addr));

  my_addr.sin_family = AF_INET;

  my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

  my_addr.sin_port = htons(port);

  setsockopt(listenSocket, SOL_SOCKET, SO_REUSEADDR, &opts, sizeof(opts));

  //get the current socket options

  if ((opts = fcntl(listenSocket, F_GETFL)) < 0) {

    printf("\tThere was an error getting the socket options.\n");

    return -1;

  }

  //set the socket to non blocking

  opts = (opts | O_NONBLOCK);

  if (fcntl(listenSocket, F_SETFL, opts) < 0) {

    printf("\tThere was an error setting the socket to be non blocking.\n");

    return -1;

  }

  //bind the socket to listen on the specified port

  if (bind(listenSocket, (struct sockaddr *) &my_addr, sizeof(my_addr)) < 0) {

    printf("\tThere was an error binding the socket\n");

    return -1;

  }

  return 0;

}