{

    // request work

    fprintf(stderr,"Requesting work...\n");

    sendSignal(comm_slave, DISTREN_REQUEST_GETWORK);

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

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

        // Variable Preparation

        _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(jobdatapath);

        // Prepare to download the job tar if it isn't  present

        struct stat buffer;

        int fstatus = stat(pathtoJobfile, &buffer);

        if(fstatus == -1)

          {

            // Download the Tar

            if( curlget(urltoTar, pathtoTar) == 0){

              fprintf(stderr, "Job data retrieved successfully\n");

              free(urltoTar);

            }

            else {

              fprintf(stderr, "Downloading job data from %s failed. Check your network connection.\n",urltoTar);

              return 1; // Eventually make a retry loop

            }

          }

        else

          fprintf(stderr, "Using cached job file...\n");

        _distren_asprintf(&outdir, "/tmp/distren/job%d", jobnum);

        mkdir("/tmp/distren", 0750); /* @FIXME: Change to tmpdir once it exists */

        mkdir(outdir, 0750);

        system(tarcmd);

        free(tarcmd);

        free(pathtoTar);

        free(outdir);

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

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

          {

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

            free(pathtoXml);

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

            distrenjob_free(&myjob);

          }

        else

          {

            fprintf(stderr, "XML job data parsing has failed. Please contact a developer, or try again.\n");

            return 1;

          }

        /* Variable-fillers which require XML */

        outputExt = myjob->output_format;

        /* Prepares the path to the jobfile */

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

        free(outputExt);

        /* Execute blender */

        if(exec_blender(pathtoJobfile, pathtoOutput, framenum))

          {

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

            return 1;

          }

        free(pathtoJobfile);

        /* Post-execution */

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

        if( !curlpost(pathtoOutput, urltoOutput)) // Uploads output

          {

            fprintf(stderr,"Upload successful, removing old output...\n");

            remove(pathtoOutput); // Delete the file after its uploaded

          }

        else

          {

            fprintf(stderr,"Upload failed. Check your network connection. Retrying upload...\n");

            int tries=1;

            while(tries<=10 && curlpost(pathtoOutput, urltoOutput))

              {

                fprintf(stderr, "Upload failed. Trying again in 10 seconds... (attempt %d of 10)\n", tries);

                tries++;

                sleep(10);

              }

          }

        free(urltoOutput);

        free(pathtoOutput);

      }

    else

      fprintf(stderr,"Nothing to do. Idling...\n");

    // 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);

      }

    sleep(5); // Poll 5 seconds. @TODO: Remove all polling

  }

  fprintf(stderr,"Closing connection to server...\n");

  remoteio_close(comm_slave);

  return 0;

}

  CURL *curl;

  CURLcode res;

  struct curl_httppost *formpost=NULL;

  struct curl_httppost *lastptr=NULL;

  struct curl_slist *headerlist=NULL;

  static const char buf[] = "Expect:";

  curl_global_init(CURL_GLOBAL_ALL);

  /* upload field... */

  curl_formadd(&formpost,

               &lastptr,

               CURLFORM_COPYNAME, targetname,

               CURLFORM_FILE, filename,

               CURLFORM_END);

  /* filename field... */

  curl_formadd(&formpost,

               &lastptr,

               CURLFORM_COPYNAME, "filename",

               CURLFORM_COPYCONTENTS, filename,

               CURLFORM_END);

  /* submit field, not usually needed, just in case... */

  curl_formadd(&formpost,

               &lastptr,

               CURLFORM_COPYNAME, "submit",

               CURLFORM_COPYCONTENTS, "send",

               CURLFORM_END);

  curl = curl_easy_init();

  headerlist = curl_slist_append(headerlist, buf);

  if(curl) {

    /* Setting the URL to get the post, and the contents of the post */

    curl_easy_setopt(curl, CURLOPT_URL, url);

    curl_easy_setopt(curl, CURLOPT_HTTPPOST, formpost);

    res = curl_easy_perform(curl);

    curl_easy_cleanup(curl);

    /* cleanup the formpost junk */

    curl_formfree(formpost);

    curl_slist_free_all (headerlist);

  }

  return res;

}

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

int login_user(char *username)

{

  return 1; // success

}

/** Replaces wordtoreplace with replacewith in conffile (relative to SYSCONFDIR) */

int conf_replace(char *conffile, char *wordtoreplace, char *replacewith){

  int maxlinelen = 120;

  char *fileOrig;

  char *fileRepl;

  _distren_asprintf(&fileOrig, "%s/%s", SYSCONFDIR, conffile);

  _distren_asprintf(&fileRepl, "%s%s.edited", SYSCONFDIR, conffile);

  char buffer[maxlinelen+2];

  char *buff_ptr, *find_ptr;

  FILE *fp1, *fp2;

  size_t find_len = strlen(wordtoreplace);

  fp1 = fopen(fileOrig,"r");

  fp2 = fopen(fileRepl,"w");

  if (fp1 ==NULL){

    fprintf(stderr, "%s doesn't exist\n",fileOrig);

    return 0;

  }

  else if(fp2 ==NULL){

    fprintf(stderr, "Can't write a file to disk! Check permissions.\n");

    return 0;

  }

  else{

    while(fgets(buffer,maxlinelen+2,fp1))

      {

        buff_ptr = buffer;

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

        {

           while(buff_ptr < find_ptr)

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

           fputs(replacewith,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 */