x-Complete DB testing with php server workaround

  x-resolve conflict between liblist and libmysqlclient

  x-update frame assigner to distribute some frames for lower-priority jobs when there's a higher priority job (Ask LordOfWar if this is implemented in sprocs already(it is))

Slave

  B-UnpackJob() and supporting functions need to work

  E-Restore tar functionality after unpackJob() is functional

  E-Add calls to remoteio, once it works or even before it works -> write message API functions and API

  =-Make code more flexible for different types of jobs and operating systems (such as paths, libs, etc)

  =-Add code to allow pausing/resuming of the slave (including a running blender process) -> signal handling (SIGTSTP vs. SIGSTOP), distrenslave_control cmdline interface

  B-Add tmpdir variable (just like the datadir variable) that is compile-time or whatever -> simple API to allow configuration-file override while taking into account defaults set by ./configure

  =-Upload finished frames' output files while rendering subsequent frames

  x=Add lockout of slaves below a certain version

  x-Add simpleslave with code to work around nonexisting server codebase

  x-Backport SimpleSlave functionality to slave code

Options

  B-Push patch for relative includes in confuse to the confuse developers -- windows/mingw32 testing required first

  ?-Expand execio() to support stderr

  =-Rewrite some stuff, try to make it simpler

  =-Review all confuse interfacing

    }

  // Variables needed for main loop

  int jobnum = 0;

  int framenum = 0;

  int slavekey = atoi(username); // @TODO: Make this more friendly

  char *urltoTar;      /* Full URL to the server-side location of job#.tgz */

  char *pathtoTar;     /* Full path to the location of the job#.tgz */

  char *pathtoTardir;

  // Temporary for uncompressed testing

  char *urltoOutput;   /* Full URL where output is posted */

  char *pathtoOutput;  /* Full path to the output (rendered) file */

  char *pathtoOutdir;  /* Full path to output directory */

  char *pathtoRenderOutput; /* Contains blender framenum placeholder */

  char *pathtoJob; /* Path to job data folder */

  char *pathtoJobfile; /* Full path to the job's main file */

  char *outputExt = "jpg";     /* Output Extension (e.g., JPG) */

  int haveWork = 0;

  int quit = 0;

  fprintf(stderr,"\nDistRen SimpleSlave Pre-Alpha %s\n- Experimental build: Use at your own risk!\n\n", PACKAGE_VERSION);

  int benchmarkTime = 0;

  int renderPower = 0;

  while(!quit)

    {

    // request work

    if(DEBUG)

      fprintf(stderr,"Requesting work from %s...\n", hostname);

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

    /* If we got a frame */

    if(haveWork)

      {

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

        if(DEBUG)

          fprintf(stderr, "Preparing to render frame %d in job %d\n", framenum, jobnum);

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

        //free(outputExt);

        mkdir(pathtoTardir, 0700);

        if(dlret == 0)

          fprintf(stderr,"Data retrieved successfully!\n");

        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

          if(DEBUG)

        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 */

        if(DEBUG)

          fprintf(stderr,"Creating output directory %s\n", pathtoOutdir);

        mkdir(pathtoOutdir, 0700);

        if(DEBUG)

          fprintf(stderr,"Marking frame started on server... ");

        _web_startframe(slavekey, password, jobnum, framenum);

        /* Execute blender */

        if(DEBUG){

      fprintf(stderr, "XPath resolution failed for ``%s'' in ``%s'' (``%s'')\n", path, xpathctxt->doc->name, xpathctxt->doc->URL);

      return (xmlNodePtr)NULL;

    }

  toreturn = *(xmlxpathobjptr->nodesetval->nodeTab);

  xmlXPathFreeObject(xmlxpathobjptr);

  return toreturn;

}

int delete_jobdata(int jobnum, char *datadir)

{

  char *jobpath;

  _distren_asprintf(&jobpath, "%s/%d", datadir, jobnum);

  return 0;

}

/** Function referenced by curlget() to write data to disk. */

size_t curl_writetodisk(void *ptr, size_t size, size_t nmemb, FILE *stream)

 {

    return fwrite(ptr, size, nmemb, stream);

  }

/** Helper function for cURL's progress display */

int curl_progress(char *Bar, double t, double d, double ultotal, double ulnow)

{

      perror("chdir");

      return 1;

    }

  a = archive_read_new();

  ae = archive_entry_new();

  archive_read_support_compression_all(a);

  archive_read_support_format_raw(a);

  astatus = archive_read_open_filename(a, pathtoTar, 8192);

  if (astatus != ARCHIVE_OK)

    {

      return 1;

    }

  for(astatus = ARCHIVE_OK;

      astatus == ARCHIVE_OK

        || astatus == ARCHIVE_WARN;

      )

    {

      astatus = archive_read_next_header2(a, ae);

      if(astatus == ARCHIVE_WARN)

      if(astatus == ARCHIVE_OK

         || astatus == ARCHIVE_WARN)

        astatus = archive_read_extract(a, ae,

                                       ARCHIVE_EXTRACT_NO_OVERWRITE

                                       | ARCHIVE_EXTRACT_SECURE_SYMLINKS

                                       | ARCHIVE_EXTRACT_SECURE_NODOTDOT);

    }

  archive_entry_free(ae);

  archive_read_finish(a);

  if(astatus != ARCHIVE_EOF)

    {

      return 1;

    }

  return 0;

}

/** Logs the user into the server after ensuring that keys exist

    ohnobinki: I assume you could use this for remoteio, or just kill it

*/

int login_user(char *username)

{