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)

	{

	  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

      	  finish_frame(general_info.conn, 0, job->jobnum, frame->num); // @TODO: Make sure this actually works.

  return 0;

}

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

/** Interactive test for the queuing system */

/* @QUEUE: Test uses methods not present in C code using mysql web-based system */

int interactiveTest(int test, struct general_info general_info, distrend_mysql_conn_t conn){

  int command;

  fprintf(stderr,"Hello!\n");

  int32_t slaveKey = 1;

  int32_t frameNum = 0;

  int32_t newPriority = 0;

  int tmp = 0;

  while(test == 1)

   {

     fprintf(stderr, "Welcome to DistRen Alpha Interactive Test Mode\n\n");

     fprintf(stderr, "\t1 \tGet a frame to render\n");

     fprintf(stderr, "\t2 \tChange job priority\n");

     fprintf(stderr, "\t3 \tSet frame finished\n");

     fprintf(stderr, "\t4 \tSet frame started\n");

     fprintf(stderr, "\t5 \tQuit\n");

{

  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;

}

{

  distrend_mysql_result_t result;

  char *query;

  MYSQL_ROW row;

  _distren_asprintf(&query, "CALL `distren`.`Frame_Get`(%d);", slavekey);

  result = mysqlQuery(conn, query);

  free(query);

  if(!result)

    return 1;

  row = mysql_fetch_row(result->mysqlresult);

  if(!row)

    {

      mysqlResultFree(result);

      return 1;

    }

  distrend_mysql_getint(row, 1, framenum);

  mysqlResultFree(result);

  return 0;

}

  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

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

 */

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

/**

   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

*/

#endif /* MYSQL_H_ */