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 "slavefuncs.h"

#include "common/asprintf.h"

#include "common/options.h"

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/stat.h>

#include <unistd.h>

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

{

  char *datadir;

  char *server;

  char *username;

  char *password;

  char *hostname;

  cfg_opt_t myopts[] = {

    CFG_SIMPLE_STR("username", &username),

    CFG_SIMPLE_STR("password", &password),

    CFG_SIMPLE_STR("datadir", &datadir),

    CFG_SIMPLE_STR("server", &server),

    CFG_SIMPLE_STR("hostname", &hostname),

    CFG_END()

  };

  cfg_t * my_cfg;

  struct options_common *commonopts;

  /**

     initializations

  */

  int quit = 0;

  fprintf(stderr,"DistRenSimpleSlave Pre-Alpha\n\t- this version of DistRen is still experimental\n\t  so things might go horribly wrong!\n");

  int benchmarkTime = 0;

  int renderPower = 0;

  char option[1] = "";

  fprintf(stderr,"Do you want to recalculate render power? (y/n): ");

  scanf("%s", option);

  if(!strcmp(option, "y"))

    {

      if(slaveBenchmark(datadir, &benchmarkTime, &renderPower))

	{

	  fprintf(stderr,"Benchmark failed! Exiting.\n");

	  return 1;

	}

      else

	{

	  fprintf(stderr,"Benchmark successful, time taken was %d seconds, giving you a render power of %d.\n",

		  benchmarkTime, renderPower);

	  _web_setrenderpower(slavekey, password, renderPower);

	}

    }

  // Main loop

  while(!quit)

    {

    // request work

    haveWork = _web_getwork(slavekey, password, &jobnum, &framenum);

    /* If we got a frame */

    if(haveWork)

      {

        fprintf(stderr,"Got work from server...\n");

        /* @TODO: Add remotio hooks */

        // jobnum = remoteio_read(jobnum); /* Set jobnum from remoteio (we could use info from struct, but we need this info to download the xmlfile */

        // framenum = remoteio_read(jobnum); /* Set framenum from remoteio */

        // outputExt = remotio)read(outputExt); /* Set output extension from remotio */

        prepareJobPaths(jobnum, framenum, outputExt, datadir, &urltoTar, &pathtoTar, &pathtoTardir, &pathtoJob, &pathtoJobfile, &urltoJobfile, &urltoOutput, &pathtoOutput, &pathtoRenderOutput, &pathtoOutdir);

        //free(outputExt);

        mkdir(pathtoTardir, 0700);

        // int dlret = downloadTar(urltoTar, pathtoTar);

        int dlret = downloadTar(urltoJobfile, pathtoJobfile);

        if(dlret == 0)

        else if(dlret == 3){

          _web_resetframe(slavekey, password, jobnum, framenum);  // Unassign the frame on the server so other slaves can render it

          return 0; // ouput dir doesn't exist

        }

        else

          //fprintf(stderr,"Using existing tarball %s...\n", pathtoTar);

        /* // Commented for decompression

        struct stat jbuffer;

        int jstatus = stat(pathtoJobfile, &jbuffer);

        if(jstatus == -1){

          fprintf(stderr,"Main job file does not exist, extracting...\n");

          // If error unpacking tarball

          if(unpackJob(pathtoJob, pathtoTar)){

            _web_resetframe(slavekey, password, jobnum, framenum);  // Unassign the frame on the server so other slaves can render it

            return 1;

          }

        }

        */

        /* ignore return because directory may exist already */

        mkdir(pathtoOutdir, 0700);

        _web_startframe(slavekey, password, jobnum, framenum);

        /* Execute blender */

        if(exec_blender(pathtoJobfile, pathtoRenderOutput, framenum))

          {

            fprintf(stderr,"Error running Blender. Check your installation and/or your PATH.\n");

            _web_resetframe(slavekey, password, jobnum, framenum);  // Unassign the frame on the server so other slaves can render it

            return 1;

          }

        free(pathtoJobfile);

        pathtoJobfile = NULL;

        struct stat buffer;

        int fstatus = stat(pathtoOutput, &buffer);

        if(fstatus == -1){

          fprintf(stderr,"*** %s doesn't exist! Scene may not have camera, or your blender installation is not working.\n", pathtoOutput);

          _web_resetframe(slavekey, password, jobnum, framenum);  // Unassign the frame on the server so other slaves can render it

          return 1;

        }

        else{

          /* Post-execution */

          uploadOutput(pathtoOutput, urltoOutput, jobnum, framenum, slavekey); // @TODO: Handle return value

          free(urltoOutput);

          free(pathtoOutput);

          urltoOutput = NULL;

          pathtoOutput = NULL;

          // Tell the server that rendering and upload are complete

          _web_finishframe(slavekey, password, jobnum, framenum);

        }

      }

    else{

      sleep(300); // Poll every 300 seconds @TODO: remove polling

    }

    // @TODO: If the server says that every frame for the last jobnum is finished, OR if the data is getting old

    if(1 == 0)

      {

        // Note: individual frames are already deleted after uploading,

        // except for ones that couldn't be uploaded

        delete_jobdata(jobnum, datadir);

      }

  }

  free(my_cfg);

  free(outputExt);

  free(datadir);

  free(urltoTar);

  free(pathtoTar);

  free(pathtoTardir);

  free(pathtoJob);

  free(pathtoJobfile);

  free(urltoJobfile);

  free(urltoOutput);

  free(pathtoRenderOutput);

  free(pathtoOutdir);