unsigned int total_finished_jobs;

  unsigned int total_frames_rendered;

  unsigned int highest_jobnum;

  int hibernate;

  time_t timestamp;

  unsigned long total_render_power;

  unsigned long total_priority_pieces;

};

/* *********************************************

   Function Prototypes

   ********************************************* */

/* ************General Functions************* */

int distrend_do();

int distrend_do_config(int argc, char *argv[], struct distrend_config **config);

int distrend_config_free(struct distrend_config *config);

int distrend_handle_request(struct distrend_listens *listens, struct distrend_client *client, struct distren_request *req, void *reqdata, struct general_info *geninfo);

/**

   client request handlers

 */

int distrend_handle_version(struct general_info *geninfo, struct distrend_client *client, size_t req_len, void *req_data);

/* **************XML Functions**************** */

void update_general_info(struct general_info *geninfo);

int import_general_info(struct general_info *general_info);

int update_xml_joblist(struct general_info *geninfo);

/* **************Test Functions**************** */

int interactiveTest(int test, struct general_info *general_info);

/* **************** Main ********************* */

int main(int argc, char *argv[])

{

  /* Parse arguments */

  int counter;

  int test = 0; /*< Interactive mode if 1 */

  int tmp;

  struct general_info general_info;

  enum clientstatus

  {

    CLIENTSTATUS_UNINITIALIZED = 0,

    CLIENTSTATUS_BUSY = 1,

    CLIENTSTATUS_IDLE = 2

  } clientstatus;

      return 1;

    }

  fprintf(stderr,"Finished connecting!\n");

  /** Execute test function */

  interactiveTest(test, &general_info);

  general_info.config->listens = distrend_listens_new(&general_info);

  if(!general_info.config->listens)

    {

      fprintf(stderr, "error initializing listens\n");

      return 1;

    }

  for(counter = 0; general_info.config->listen_ports[counter]; counter ++)

    {

      tmp = distrend_listen_add(general_info.config->listens, general_info.config->listen_ports[counter]);

      if(tmp)

	{

	  fprintf(stderr, "Error listening on port %d\n", general_info.config->listen_ports[counter]);

	  return 1;

	}

    }

  distrend_listen_handler_add(general_info.config->listens, DISTREN_REQUEST_VERSION, &distrend_handle_version);

  int slaveKey = 0; // Remotio should set me on a per-slave basis

  /* Main Loop */

  general_info.config->die = 0;

  while(!general_info.config->die)

    {

      int clientrequest = 0; /*< temporary example variable, will be replaced when we can handle messages */

      distrend_accept(general_info.config->listens);

      /* Run the watchdog, @TODO: like every 10 mins or something */

      frame_watchdog(general_info.conn);

      struct frameset frame;

      struct distrenjob *job;

      distrenjob_new(&job);

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

      /** If client requests work */

      if(clientrequest == DISTREN_REQUEST_GETWORK)

	{

	  int returnnum = find_jobframe(general_info.conn, slaveKey, &job->jobnum, &frame.num); // Finds a frame to render @FIXME: Slavenum :D

	  if(returnnum); /* No work on server */

      client->state = DISTREND_CLIENT_PREAUTH;

      distren_request_new(&newreq, strlen(PACKAGE_STRING), DISTREN_REQUEST_VERSION);

      distrend_client_write_request(geninfo->config->listens, client, newreq, PACKAGE_STRING);

      distren_request_free(newreq);

    }

  else

    {

      /**

	 The client claims to be of a different version of distren.

	 Now we will just send a disconnect packet and disconnect the client.

      */

      strncpy(fixedbuf, req_data, 31);

      fixedbuf[31] = '\0';

      if(req_len < 31)

	fixedbuf[req_len] = '\0';

      _distren_asprintf(&tmp_str, "You have tried to connect to a %s server when your client claims to be running %s. Bye ;-)\n", PACKAGE_STRING, fixedbuf);

      distrend_send_disconnect(geninfo->config->listens, client, tmp_str);

    }

  return 0;

}

/**

   Performs command stored in a client's request. @TODO: Fill stub

*/

int distrend_do()

{

  return 0;

}

/* Grabs config info from confs */

int distrend_do_config(int argc, char *argv[], struct distrend_config **config)

{

  unsigned int counter;

  cfg_opt_t myopts_listen[] =

    {

      CFG_SIMPLE_STR("type", NULL),

      CFG_SIMPLE_STR("path", NULL),

      CFG_SIMPLE_INT("port", NULL),

      CFG_END()

    };

  cfg_opt_t myopts[] =

    {

      CFG_SEC("listen",  /* this must be imported into struct listens (which must still be declared) */

          myopts_listen,

	  fprintf(stderr, "error handling some data from client\n");

	  distren_request_free(req);

	  client->state = DISTREND_CLIENT_DEAD;

	  return 1;

	}

      reqdata = malloc(req->len);

      if(!reqdata)

	{

	  fprintf(stderr, "OOM\n");

	  distren_request_free(req);

	  return 1;

	}

      memcpy(reqdata, ((void *)packet->data) + sizeof(struct distren_request), req->len);

      memmove(packet->data,

	      ((void *)packet->data) + client->expectlen,

	      packet->len - client->expectlen);

      packet->len -= client->expectlen;

      client->inlen -= client->expectlen;

      client->expectlen = 0;

      distrend_dispatch_request(listens, client, req, reqdata);

      distren_request_free(req);

    }

  return 0;

}

struct distrend_accept_client_proc_data

{

  struct distrend_listens *listens;

  time_t current_time;

};

int distrend_accept_client_proc(struct distrend_accept_client_proc_data *data,

				struct distrend_client *client)

{

  struct distrend_packet *packet;

  ssize_t written_amount;

  short revents;

  if(client->state == DISTREND_CLIENT_DEAD)

    return TRUE;

  /**

     Manage timing-out clients.

   */

  if(data->current_time > client->cleanup_time)