# selective compilation

AC_ARG_ENABLE([server],

	[AS_HELP_STRING([--disable-server],[Don't build the distren server])],

	[enable_server=$enableval],

	[enable_server=yes])

AM_CONDITIONAL([ENABLE_SERVER],

	[test "x$enable_server" = "xyes"])

# to grab GNU-specific function prototypes for the following functions:

# getline

AC_DEFINE([_GNU_SOURCE], [1])

#package dependencies:

PKG_PROG_PKG_CONFIG(0.17.2)

PKGCONFIG_OHNOWRAP([DISTLIBS], [libconfuse >= 2.5 libcurl libxml-2.0 liblist >= 2.2.1])

PKGCONFIG_OHNOWRAP([CHECK], [check >= 0.9.3])

# define paths for configuration files:

AC_DEFINE_DIR([LOCALSTATEDIR], [localstatedir], [Default directory for storing state information])

AC_CONFIG_FILES([Makefile

src/Makefile

src/tests/Makefile

etc/distrendaemon.conf

etc/distrenslave.conf

])

AC_OUTPUT

SUBDIRS = . tests

AM_CPPFLAGS = -DSYSCONFDIR='"$(sysconfdir)"' \

	-DLOCALSTATEDIR='"$(localstatedir)"' \

	-I. -I$(top_srcdir)/src/common

AM_CFLAGS = $(DISTLIBS_CFLAGS)

AM_LDFLAGS = $(DISTLIBS_LDFLAGS)

# LIBS, LDFLAGS, Huh!?

LIBS = $(DISTLIBS_LDADD)

LDADD = libdistrencommon.la

include_HEADERS = client/distren.h

bin_PROGRAMS = distren

if ENABLE_SERVER

bin_PROGRAMS += distrend distrenslave

endif

lib_LTLIBRARIES = libdistren.la

pkglib_LTLIBRARIES = libdistrencommon.la

# libdistrencommon.la:

libdistrencommon_la_SOURCES = common/options.c \

	common/options.h \

	common/execio.h \

	common/execio.c \

	common/remoteio.h \

	common/libremoteio.h \

#include "distrenjob.h"

#include "execio.h"

#include "listen.h"

#include "options.h"

#include "protocol.h"

#include "slavefuncs.h"

#include <confuse.h>

#include <malloc.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <time.h>

#include <unistd.h>

#include <libxml/encoding.h>

#include <libxml/parser.h>

#include <libxml/tree.h>

#include <libxml/xmlmemory.h>

#include <libxml/xmlreader.h>

#include <libxml/xmlwriter.h>

/* ******************* Structs ************************ */

struct general_info

{

  struct distrenjob head;

  struct distrend_config *config;

  struct

  {

    /** general_info.xml */

    char *geninfo;

  } files;

  int jobs_in_queue;

  unsigned int free_clients;

  unsigned int rendering_clients;

  unsigned int total_finished_jobs;

  unsigned int total_frames_rendered;

  unsigned int highest_jobnum;

  int hibernate;

  time_t timestamp;

  unsigned long total_render_power;

int find_jobframe_new(struct general_info *geninfo, int rend_pwr, struct distrenjob **job, struct frameset **frame)

{

  if(geninfo->hibernate)

    return 1;

  float power_difference;

  float greatest_power_difference;

  unsigned short int found;

  struct distrenjob *job_to_render;

  struct distrenjob *distrenjob_ptr;

  greatest_power_difference = -10000;

  found = 0;

  /* iterate through jobs from first to last */

  for(distrenjob_ptr = geninfo->head.next;

      distrenjob_ptr && !distrenjob_ptr->hibernate;

      distrenjob_ptr = distrenjob_ptr->next)

  {

	  if(distrenjob_ptr->prev_frame_index < (distrenjob_ptr->total_frames - 1))

	  {

	    /**

	       Why is the number 11 found here again? --ohnobinki

	     */

		  power_difference = power_difference - (float)distrenjob_ptr->assigned_render_power;

		  fprintf(stderr, "job num %d\npower difference: %f\n", distrenjob_ptr->jobnum, power_difference);

		  if(power_difference > greatest_power_difference)

		  {

			  job_to_render = distrenjob_ptr;

			  greatest_power_difference = power_difference;

			  found = 1;

		  }

	  }

  }

  if(!found)

    {

      fprintf(stderr, "No more jobs to render\n");

      return 1;

    }

  find_jobframe_from_job(job_to_render, job, frame);

  job_to_render->assigned_render_power = job_to_render->assigned_render_power + rend_pwr;

  return 0;

}

  xmlTextWriterStartDocument(writer, NULL, "utf-8", NULL);

  /**

     create root element job_list

  */

  xmlTextWriterStartElement(writer, (xmlChar*)"job_list");

  _distren_asprintf(&tmp, "%d", geninfo->timestamp);

  xmlTextWriterWriteAttribute(writer, (xmlChar*)"timestamp", (xmlChar*)tmp);

  free(tmp);

  geninfo->total_priority_pieces = 0;

  counter = 0;

  for(job = geninfo->head.next; job; job = job->next)

    {

      _distren_asprintf(&tmp, "%d", job->jobnum);

      xmlTextWriterWriteElement(writer, (xmlChar*)"jobnum", (xmlChar*)tmp);

      free(tmp);

      /**

	this is needed for the new frame finder to work 

	Why the random constant numeral 11? --ohnobinki

      */

      counter++;

    }

  xmlTextWriterEndElement(writer);

  /**

     close elements and end document

  */

  xmlTextWriterEndDocument(writer);

  /**

     free writer and save xml file to disk

  */

  xmlFreeTextWriter(writer);

  return 0;

}

/**

 returns 0 if completed successfully

 this reads a list of jobs in the queue before DistRen was shut down

 and then adds the jobs to the queue, as if it were never shut down

*/

int createQueueFromXML(struct general_info *geninfo)