Colony

 * @file ColonetServer.cpp

 *

 * @brief colonet_server - primary server application for Colonet

      }

      char log_buffer[LOG_BUFFER_LENGTH];

	       inet_ntoa(client_addr.sin_addr));

      logger.log_string(LOG_TYPE_CONNECT, log_buffer);

	continue;

      }

	       inet_ntoa(client_addr.sin_addr));

      logger.log_string(LOG_TYPE_CONNECT, log_buffer);

    }

    printf("response\n");

    char buffer[WRITE_BUFFER_SIZE];

    int value = (int)(data[0]);

    snprintf(buffer, WRITE_BUFFER_SIZE, "%d\n", value);

    int buflen = strlen(buffer);

    if (connection_pool.write_to_client(dest, buffer, buflen)

        == ERROR_INVALID_CLIENT_ID) {

    log_filename = optionsG.log_filename;

  }

    fprintf(stderr, "%s: colonet_wl_run_listener_thread failed.\n",

    return -1;

  return 0;

}

 * @return 0 on success, negative error code on error

 */

int ColonetServer::initialize_connection(int port) {

         "clients...\n");

  int options = 1;

  struct sockaddr_in my_address;

  my_address.sin_family = AF_INET;

  my_address.sin_addr.s_addr = htonl(INADDR_ANY);

  my_address.sin_port = htons(port);

  setsockopt(listen_socket, SOL_SOCKET, SO_REUSEADDR, &options, sizeof(options));

  //get the current socket options

    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(listen_socket, (struct sockaddr *) &my_address, sizeof(my_address)) < 0) {

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

    return -1;

  }

  return 0;

}

  if (colonet_server.start_listening() < 0) {

    return -1;

  }

  colonet_server.run_server();

  return 0;