}

    */

  /** MySQL Connection */

  if(mysqlConnect(&general_info.conn))

    {

      fprintf(stderr, "%s:%d: mysqlConnect() failed\n", __FILE__, __LINE__);

      return 1;

    }

  /** pre-loaded jobs for testing */

  // prepare_distrenjob(&general_info, 1, "awesome", "LordOfWar", 8, 1, 100, 640, 480);

  // prepare_distrenjob(&general_info, 1, "hamburger", "ohnobinki", 3, 1, 50, 1280, 720);

  /** Execute test function */

  // interactiveTest(test, general_info);

  distrend_listen(general_info.config, &clients);

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

  /* Main Loop */

  while(!general_info.config->die)

    {

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

      distrend_accept(general_info.config, clients);

      /* Make the following code more event-driven */

      frame_watchdog(&general_info.head);

      struct frameset *frame;

      struct distrenjob *job;

      /* If the client is idle, must be modified for climbing through linked list of clients (client->clientnum) */

      if(clientstatus == CLIENTSTATUS_IDLE)

	{

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

	  if(returnnum)

	    {

	      fprintf(stderr,"No frames are available to render at this time. Idling...\n");

	      sleep(10);

	    }

	  else

	    remotio_send_to_client(frame->num, job->jobnum); // Pseudo-sends data to client

	}

      /* If the client states that they finished the frame */

      	if(clientsays == DISTREN_REQUEST_DONEFRAME){

      	  clientstatus = CLIENTSTATUS_IDLE; // Sets the client back to idle

      	}

    }

  distrend_unlisten(general_info.config->listens, clients);

  distrend_config_free(general_info.config);

  xmlcleanup();

  /** free() paths */

  free(general_info.files.geninfo);

  mysqlDisconnect(general_info.conn);

  return 0;

}

/* ********************** Functions ************************* */

/** Dumps all data in RAM to an xml file (such as current jobs, etc) which is parsed by start_data. Remember to invoke this before shutting down! @TODO: Fill this stub*/

// @QUERY: Obselete function, get rid of me!

/*

int xml_dump()

{

  return 0;

}

*/

/**

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

*/

int distrend_do()

{

  return 0;

}

/** 

    Fill variables at startup from XML dumps or defaults

 */

// @QUERY: Obselete function, as data is stored in sql now.

/*

int start_data(struct general_info *general_info)

{

  struct stat buffer;

// defaults

  the Free Software Foundation, either version 3 of the License, or

  (at your option) any later version.

  DistRen 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 Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License

  along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

*/

#include "mysql.h"

#include <mysql/mysql.h>

#include "common/asprintf.h"

#include "common/protocol.h"

#include <stdio.h>

#include <string.h>

#include <unistd.h>

#include <stdlib.h>

#include <sys/stat.h>

#include <fcntl.h>

/**

   local types

 */

#define SEVENTY_FIVE 75

#define FORTY_TWO 42

/**

   performs mysql query.

   errors will be logged to the user by this function.

   @return pointer to query handle on success, NULL on failure

 */

distrend_mysql_result_t mysqlQuery(distrend_mysql_conn_t conn, char *query);

/**

   frees mysql query result. Accepts a NULL pointer and ignores it to

   help deal with one-shot calls to mysqlQuery so that you don't have to

   check if it returned NULL or not.

   @return 0 on success

 */

int mysqlResultFree(distrend_mysql_result_t result);

struct distrend_mysql_conn

{

  MYSQL *mysqlconn;

  short pointlesscheck;

};

struct distrend_mysql_result

{

  MYSQL_RES *mysqlresult;

  short pointlesscheck;

};

/**

    funcs

 */

int mysqlConnect(distrend_mysql_conn_t *conn)

{

  MYSQL *mysqlconn;

  char *server = "zserver1";

  char *user = "distren";

  char *password = "secretpassword";

  char *database = "distren";

  mysqlconn = mysql_init(NULL);

  mysql_options(mysqlconn, MYSQL_OPT_RECONNECT,"true");

  if(!mysql_real_connect(mysqlconn, server, user, password, database, 0, NULL, 0))

    {

      fprintf(stderr, "%s\n", mysql_error(mysqlconn));

      return 1;

    }

  *conn = malloc(sizeof(struct distrend_mysql_conn));

  if(!*conn)

    {

      mysql_close(mysqlconn);

      mysql_server_end();

      return 2;

    }

  (*conn)->mysqlconn = mysqlconn;

  (*conn)->pointlesscheck = SEVENTY_FIVE;

  return 0;

}

  _distren_asprintf(&query, "CALL `distren`.`Frame_Complete`(%d,%d,%d);", slavekey, jobkey, framenum);

  result = mysqlQuery(conn, query);

  free(query);

  mysqlResultFree(result);

}

void start_frame(distrend_mysql_conn_t conn, int32_t slavekey, int32_t jobkey, int32_t framenum)

{

  char *query;

  distrend_mysql_result_t result;

  _distren_asprintf(&query, "CALL `distren`.`Frame_Start`(%d,%d,%d);", slavekey, jobkey, framenum);

  result = mysqlQuery(conn, query);

  free(query);

  mysqlResultFree(result);

}

int change_job_priority(distrend_mysql_conn_t conn, int32_t jobkey, int32_t newpriority)

{

  char *query;

  distrend_mysql_result_t result;

  _distren_asprintf(&query, "UPDATE `distren`.`Job` SET `Priority`=%d WHERE `Job_Key`=%d",

		    newpriority, jobkey);

  result = mysqlQuery(conn, query);

  mysqlResultFree(result);

  return 0;

}

int find_jobframe(distrend_mysql_conn_t conn, int32_t slavekey, int32_t jobkey, int32_t framenum)

{

  distrend_mysql_result_t result;

  char *query;

  MYSQL_ROW row;

  _distren_asprintf(&query, "`distren`.`Frame_Get`( %d, @Job_Key, @Frame_Key); SELECT @Job_Key, @Frame_Key",

		    slavekey);

  result = mysqlQuery(conn, query);

  free(query);

  if(!result)

    return 1;

  mysqlResultFree(result);

  return 0;

}

  it under the terms of the GNU Affero General Public License as published by

  the Free Software Foundation, either version 3 of the License, or

  (at your option) any later version.

  DistRen 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 Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License

  along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

*/

#ifndef MYSQL_H_

#define MYSQL_H_

#include <stdint.h>

struct distrend_mysql_conn;

struct distrend_mysql_result;

typedef struct distrend_mysql_conn *distrend_mysql_conn_t;

typedef struct distrend_mysql_result *distrend_mysql_result_t;

/**

   initiates a MySQL connection

   @param conn, pointer will be set to the struct

   @return 0 on success

 */

int mysqlConnect(distrend_mysql_conn_t *conn);

/**

   cleans and disconnects MySQL connection

   @param conn connection to clean

   @return 0 on success

*/

int mysqlDisconnect(distrend_mysql_conn_t conn);

/**

   Mark a frame as finished in the database and calculate the seconds spent on that frame.

 */

void finish_frame(distrend_mysql_conn_t conn, int32_t slavekey, int32_t jobkey, int32_t framenum);

/**

   Mark a frame as started in the database and save the time at which it started.

 */

/**

   Changes the priority of an existing (and maybe running) job. @arg head I may end up changing the head if job == head

*/

int change_job_priority(distrend_mysql_conn_t conn, int32_t jobkey, int32_t newpriority);

/**

  Frame Finder: Finds a frame for a slave to render

*/

int find_jobframe(distrend_mysql_conn_t conn, int32_t slaveKey, int32_t jobKey, int32_t frameNum);

#endif /* MYSQL_H_ */