Colony

/** @file client.c

 *

 *  @author Jason Knichel

 *  @author Eugene Marinelli

 *

 * @bug Weird segfault when processing tokens

 */

#include <string.h>

#include <stdio.h>

#include <unistd.h>

#include <ctype.h>

#include <errno.h>

#include <colonet_wireless.h>

#include "includes/client.h"

#include "includes/options.h"

#include "includes/ConnectionPool.h"

/* Globals */

static ColonetWireless* wireless;

extern ConnectionPool connection_pool;

/* Public functions */

int wirelessMessageHandler(ColonetPacket* pkt)

{

  printf("Received wireless message!!!\n");

  if (!pkt)

  {

    printf("The packet pointer was null.\n");

    return -1;

  }

  if ((int)pkt->msg_type == COLONET_RESPONSE)

  {

    printf("response\n");

    int dest = (int)(pkt->msg_dest);

    if (dest < connection_pool.get_next_available_slot())

    {

      char buffer[WRITE_BUFFER_SIZE];

      int value = (int)(pkt->data[0]);

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

      //TODO:make a connection pool write function and move this code into it

      int len = strlen(buffer);

      if (len > (WRITE_BUFFER_SIZE-connection_pool.get_write_buffer_size(dest)))

      {

        printf("There is not enough room in the write buffer to send the data to the client.\n");

        return -1;

      }

      memcpy(connection_pool.get_write_buffer(dest), buffer, len);

      connection_pool.set_write_buffer_size(dest, len);

      printf("Put data in write buffer for client.\n");

    }

    else

    {

      printf("The robot wanted to pass the data to a client not in our pool.\n");

      return -1;

    }

  }

  else

  {

    printf("not a response\n");

  }

  pkt = 0;

  return 0;

}

int initWireless()

{

  char* log_filename = NULL;

  if (optionsG.logging_enabled) {

    log_filename = optionsG.log_filename;

  }

  wireless = new ColonetWireless(optionsG.wireless_port, 

                                 wirelessMessageHandler, log_filename, 

                                 /*!optionsG.listener_mode*/false, true);

  //Note: last arg set to true ignores token ring;  in general, this should

  //probably be false (changed for demo purposes)

  if (!wireless->run_listener_thread()) {

                return -1;

        }

        return 0;

}

void send_wireless_message(unsigned char msg_dest, unsigned char msg_type, 

                          unsigned char msg_code, unsigned char* data) {

  wireless->send(msg_dest, msg_type, msg_code, data);

}