/* Code-filled Variables  */

  int jobnum;          /* The job number that we're currently working */

  int framenum;        /* @TODO: Remotio should fill this */

  int busy = 0;        /* Client business 1=busy 0=idle */

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

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

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

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

  char *pathtoXml;     /* Full path to the job's xml file */

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

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

  char *tarcmd;        /* Command to run for tar. Migrate to libtar sometime */

  char *outdir;        /* Output Directory for tar */

  char *jobdatapath;   /* Path to job data */

  struct distrenjob *myjob; /* Structure to hold data gathered from the XML file */

  while(cont)

    {

    /* If we got a frame */

    if(framesInLocalQueue > 0)

      {

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

        jobnum = 0;

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

        framenum = 0;

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

        /**

           Variable Preparation

           @todo find where to free() all of these

        */

        _distren_asprintf(&jobdatapath, "job%d", jobnum);

        _distren_asprintf(&urltoTar, "http://protofusion.org/distren/stor/job%d/job%d.tar.gz", jobnum); // Prepares URL to download from

        _distren_asprintf(&pathtoTar, "%s/stor/jobdata/job%d.tar.gz", datadir, jobnum); // Prepares destination to save to

        _distren_asprintf(&pathtoJobfile, "%s/%s/job.blend", datadir, jobdatapath ); // Prepares the path to the jobfile

        _distren_asprintf(&urltoOutput, "http://protofusion.org/distren/stor/tmp/", jobdatapath ); // Prepares the URL where output is posted

        _distren_asprintf(&pathtoXml, "%s/job%d/job%d.xml", datadir, jobnum ); // Prepares the path to the job's XML file

        free(tarcmd);

        /* Parses a job's XML file, puts data in the myjob struct */

        if(xml2distrenjob(&myjob, pathtoXml) == 0)

          {

            fprintf(stderr, "Well, the XML craziness may have worked. Maybe. \n");

            /* Frees things up if it was successful. xml2distrenjob() really (usually) only fails if malloc'ing inside it fails */

            distrenjob_free(&myjob);

          }

        else

          {

            fprintf(stderr, "I think the XML craziness may have failed, so I'll terminate just for fun.\n");

            return 1;

          }

        /* Variable-fillers which require XML */

        outputExt = myjob->output_format; /* @TODO: FIXME! <-- I WILL! */

        /* Prepares the path to the jobfile */

        _distren_asprintf(&pathtoOutput, "%s/job%d/output/job%d-frame%d.%s", datadir, jobnum, jobnum, framenum, outputExt );

        /** Series of ifs for jobtype based on xml content */

        while(1 == 1){

          break;

        }

        /* When blender is finished, run this... */

        fprintf(stderr, "Finished frame %d in job %d, uploading...", framenum, jobnum);

        curlpost(pathtoOutput, urltoOutput); /* uploads (HTML POST) the output at outputpath to the server at outputurl */

        tell_the_server(DISTREN_REQUEST_DONEFRAME); /* Tells the server that it's finished rendering this frame */

        busy = 0;

        /* Slave now becomes idle, doesn't need to tell the server anything, ssh handles this. */

        framesInLocalQueue--;

      }

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

    if(1 == 0){

      delete_jobdata(jobnum, datadir);

    }

  }

  return 0;

}

      {

        buff_ptr = buffer;

        while ((find_ptr = strstr(buff_ptr,text2find)))

        {

           while(buff_ptr < find_ptr)

             fputc((int)*buff_ptr++,fp2);

           fputs(text2repl,fp2);

           buff_ptr += find_len;

         }

         fputs(buff_ptr,fp2);

      }

    rename(fileRepl, fileOrig);

  }

  fclose(fp2);

  fclose(fp1);

  fprintf(stderr,"Wrote conf file...\n");

return 1; // Success

}

/* Executors */

/** Executor function for Blender operations */

{

  int ret;

  char *frame_str;

  /* start execio code */

  char *command = "blender"; // @TODO: append .exe if win32?

  char *cmd[] = { command, "-b", "-o", output, input, "-f", frame_str, (char *)NULL };

  char buf[10];

  struct execio *testrem;

  size_t readlen;

  _distren_asprintf(&frame_str, "%i", frame);

  ret = execio_open(&testrem, command, cmd); // This path will be absolute for testing, @TODO: should be relative to install on production

  buf[9] = '\0';

  while(!execio_read(testrem, buf, 9, &readlen))

    {

      if(readlen > 9) {

        fprintf(stderr, "Something is terribly wrong!\n");

       }

       buf[readlen] = '\0';

       fprintf(stderr, "read \"%s\"\n", buf);

       // @TODO: Better location for this code?

      tell_the_server(DISTREN_REQUEST_PROGRESS);

    }

  execio_close(testrem);

  /* end execio code */

  if(ret == 1){

    fprintf(stderr,"Error starting Blender. Check your install.\n");

  }

  else{

  }

  // Consider placing the following in the exec_blender() function

}

void xmlinit()

{

  xmlInitParser();

  xmlXPathInit();

}

void xmlcleanup()

{

  xmlCleanupParser();

}

  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 _DISTREN_SLAVEFUNCS_H

#define _DISTREN_SLAVEFUNCS_H

#include "distrenjob.h"

#include <libxml/xpath.h>

#include <stdio.h>

xmlNodePtr xml_quickxpath(xmlXPathContextPtr xpathctxt, xmlChar *path);

int software_updatecheck();

void tell_the_server(int stuff);

int delete_jobdata(int jobnum, char *datadir);

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

int curlget(char *url, char *out);

int curlpost(char *filename, char *url);

int ssh_keygen();

int register_user(char *username, char *email);

int login_user(char *username);

int conf_replace(char *username);

void xmlinit();

void xmlcleanup();

#endif