Changeset - d0f64b1f3376
Parent rev.
Child rev.
[Not reviewed]
default
0 3 0
Ethan Zonca (ethanzonca) - 16 years ago 2010-03-17 19:39:56
e@ethanzonca.com
Added benchmarking and render_power setting
3 files changed with 93 insertions and 7 deletions:
src/server/simpleslave.c
13
src/server/slavefuncs.c
78
5
src/server/slavefuncs.h
2
2
0 comments (0 inline, 0 general)
src/server/simpleslave.c
➞
Show inline comments
 
@@ -105,48 +105,61 @@ int main(int argc, char *argv[])
 
  // 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 uncomressed testing

			




	
	
	
		
 
  char *urltoJobfile;

			




	
	
	
		
 

			




	
	
	
		
 
  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,"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;

			




	
	
	
		
 
  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

			




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

			




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

			




	
	
	
		
 

			




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

			




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

			




	
	
	
		
 
        int dlret = downloadTar(urltoJobfile, pathtoJobfile);

			




        

    


    
    

    

        

                

                    src/server/slavefuncs.c
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -18,48 +18,49 @@

			




	
	
	
		
 
*/

			




	
	
	
		
 

			




	
	
	
		
 
#include "distrenjob.h"

			




	
	
	
		
 
#include "slavefuncs.h"

			




	
	
	
		
 

			




	
	
	
		
 
#include "common/asprintf.h"

			




	
	
	
		
 
#include "common/execio.h"

			




	
	
	
		
 
#include "common/protocol.h"

			




	
	
	
		
 
#include "common/remoteio.h"

			




	
	
	
		
 

			




	
	
	
		
 
#include <curl/curl.h>

			




	
	
	
		
 
#include <curl/easy.h>

			




	
	
	
		
 
#include <curl/types.h>

			




	
	
	
		
 

			




	
	
	
		
 
#include <archive.h>

			




	
	
	
		
 
#include <archive_entry.h>

			




	
	
	
		
 

			




	
	
	
		
 
#include <stdio.h>

			




	
	
	
		
 
#include <string.h>

			




	
	
	
		
 
#include <unistd.h>

			




	
	
	
		
 
#include <stdlib.h>

			




	
	
	
		
 
#include <sys/stat.h>

			




	
	
	
		
 
#include <fcntl.h>

			




	
	
	
		
 

			




	
	
	
		
 
#include <time.h>

			




	
	
	
		
 

			




	
	
	
		
 
/**

			




	
	
	
		
 
   Sends the server a single request (see protocol.h)

			




	
	
	
		
 
*/

			




	
	
	
		
 
int sendSignal(struct remoteio *rem, char signal)

			




	
	
	
		
 
{

			




	
	
	
		
 
  size_t written;

			




	
	
	
		
 
  size_t towrite;

			




	
	
	
		
 
  char *ssignal;

			




	
	
	
		
 

			




	
	
	
		
 
  _distren_asprintf(&ssignal, "%c", signal);

			




	
	
	
		
 
  towrite = strlen(ssignal);

			




	
	
	
		
 
  while( towrite

			




	
	
	
		
 
	 && !remoteio_write(rem, ssignal, towrite, &written))

			




	
	
	
		
 
    {

			




	
	
	
		
 
      fprintf(stderr, "Sending request...\n");

			




	
	
	
		
 
      towrite -= written;

			




	
	
	
		
 
    }

			




	
	
	
		
 
  if(written)

			




	
	
	
		
 
    return 0;

			




	
	
	
		
 

			




	
	
	
		
 
  /**

			




	
	
	
		
 
     if remoteio_write returned 1, the connection

			




	
	
	
		
 
     is probably dead or there was a real error

			




	
	
		
 
@@ -281,49 +282,49 @@ int conf_replace(char *conffile, char *w

			




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

			




	
	
	
		
 

			




	
	
	
		
 
/** Executor function for Blender operations */

			




	
	
	
		
 
int exec_blender(char *input, char *output, int frame)

			




	
	
	
		
 
{

			




	
	
	
		
 
  int ret;

			




	
	
	
		
 
  char *frame_str;

			




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

			




	
	
	
		
 

			




	
	
	
		
 
  char *command = "blender"; // @TODO: We currently expect this to be in PATH

			




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

			




	
	
	
		
 
  char *cmd[] = { command, "-b", input, "-o", output, "-f", frame_str, "-t", "0", (char *)NULL }; // arguments for blender

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"Preparing to execute command: %s -b %s -o %s -f %s\n", command, input, output, frame_str);

			




	
	
	
		
 

			




	
	
	
		
 
  char buf[10];

			




	
	
	
		
 
  struct execio *testrem;

			




	
	
	
		
 
  size_t readlen;

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"Executing: %s\n", frame_str);

			




	
	
	
		
 
  ret = execio_open(&testrem, command, cmd);

			




	
	
	
		
 
  buf[20] = '\0';

			




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

			




	
	
	
		
 
    {

			




	
	
	
		
 
      if(readlen > 20) {

			




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

			




	
	
	
		
 
       }

			




	
	
	
		
 
       buf[readlen] = '\0';

			




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

			




	
	
	
		
 
    }

			




	
	
	
		
 
  execio_close(testrem);

			




	
	
	
		
 

			




	
	
	
		
 
  return ret;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
void xmlinit()

			




	
	
		
 
@@ -366,55 +367,52 @@ int job_build_path(char *filename, unsig

			




	
	
	
		
 
{

			




	
	
	
		
 
  return 0;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
int downloadTar(char *url, char *destinationPath){

			




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

			




	
	
	
		
 
  struct stat buffer;

			




	
	
	
		
 
  int fstatus = stat(destinationPath, &buffer);

			




	
	
	
		
 
  if(fstatus == -1)

			




	
	
	
		
 
    {

			




	
	
	
		
 
      // Download the Tar

			




	
	
	
		
 
      int ret = curlget(url, destinationPath);

			




	
	
	
		
 
      if(ret == 0){

			




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

			




	
	
	
		
 
        // free(url); @FIXME: causes doublefree! Curl must free the url?

			




	
	
	
		
 
        return 0;

			




	
	
	
		
 
      }

			




	
	
	
		
 
      else if(ret == 1){

			




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

			




	
	
	
		
 
        free(url);

			




	
	
	
		
 
        return 1; // Eventually make a retry loop

			




	
	
	
		
 
      }

			




	
	
	
		
 
    }

			




	
	
	
		
 
  else{

			




	
	
	
		
 
    fprintf(stderr, "Tar already exists! Download cancelled.\n");

			




	
	
	
		
 
    return 2;

			




	
	
	
		
 
  }

			




	
	
	
		
 

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
int uploadOutput(char *pathtoOutput, char *urltoOutput, int jobnum, int framenum, int slavekey){

			




	
	
	
		
 
  //fprintf(stderr,"Uploading output %s to url %s for job %d and frame %d for slavekey %d", pathtoOutput, urltoOutput, jobnum, framenum, slavekey);

			




	
	
	
		
 
  if( !curlpost(pathtoOutput, urltoOutput, jobnum, framenum, slavekey)) // Uploads output

			




	
	
	
		
 
    {

			




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

			




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

			




	
	
	
		
 
      return 0;

			




	
	
	
		
 
    }

			




	
	
	
		
 
  else

			




	
	
	
		
 
    {

			




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

			




	
	
	
		
 
      int tries=1;

			




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

			




	
	
	
		
 
        {

			




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

			




	
	
	
		
 
          tries++;

			




	
	
	
		
 
          sleep(10);

			




	
	
	
		
 
        }

			




	
	
	
		
 
      return 1; // Upload failed after multiple tries

			




	
	
	
		
 
      // @FUTURE: Keep track of files that we were unable to upload, and upload them later

			




	
	
	
		
 
    }

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
		
 
@@ -688,61 +686,136 @@ struct _web_memorystruct _web_getrequest

			




	
	
	
		
 
void _web_finishframe(int slavekey, char *slavepass, int jobnum, int framenum){

			




	
	
	
		
 
  char *url;

			




	
	
	
		
 
  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=finishframe&slavekey=%d&slavepass=%s&jobnum=%d&framenum=%d", slavekey, slavepass, jobnum, framenum);

			




	
	
	
		
 
  struct _web_memorystruct data = _web_getrequest(url);

			




	
	
	
		
 
  free(url);

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"%s\n", data.memory);

			




	
	
	
		
 
  if(data.memory)

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
void _web_resetframe(int slavekey, char *slavepass, int jobnum, int framenum){

			




	
	
	
		
 
  fprintf(stderr,"Resetting frame %d in job %d on server... ",framenum,jobnum);

			




	
	
	
		
 
  char *url;

			




	
	
	
		
 
  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=resetframe&slavekey=%d&slavepass=%s&jobnum=%d&framenum=%d", slavekey, slavepass, jobnum, framenum);

			




	
	
	
		
 
  struct _web_memorystruct data = _web_getrequest(url);

			




	
	
	
		
 
  free(url);

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"%s\n", data.memory);

			




	
	
	
		
 
  if(data.memory)

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
void _web_startframe(int slavekey, char *slavepass, int jobnum, int framenum){

			




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

			




	
	
	
		
 
  char *url;

			




	
	
	
		
 
  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=startframe&slavekey=%d&slavepass=%s&jobnum=%d&framenum=%d", slavekey, slavepass, jobnum, framenum);

			




	
	
	
		
 
  struct _web_memorystruct data = _web_getrequest(url);

			




	
	
	
		
 
  free(url);

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"%s\n", data.memory);

			




	
	
	
		
 
  if(data.memory)

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
int _web_getwork(int slavekey, char *slavepass, int *jobnum, int *framenum){

			




	
	
	
		
 
  char *url;

			




	
	
	
		
 
  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=getwork&slavekey=%d&slavepass=%s", slavekey, slavepass);

			




	
	
	
		
 
  struct _web_memorystruct data = _web_getrequest(url);

			




	
	
	
		
 
  free(url);

			




	
	
	
		
 

			




	
	
	
		
 
  if(!data.memory || !strcmp(data.memory,",")){

			




	
	
	
		
 
    fprintf(stderr,"No work available on server!\n");

			




	
	
	
		
 
    return 0;

			




	
	
	
		
 
  }

			




	
	
	
		
 
  else if(!strcmp(data.memory, "ERROR_BADKEY")){

			




	
	
	
		
 
    fprintf(stderr,"*** Slave %d does not exist!\n",slavekey);

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
    return 0;

			




	
	
	
		
 
  }

			




	
	
	
		
 
  else{

			




	
	
	
		
 
    *jobnum = atoi(data.memory);

			




	
	
	
		
 
    *framenum = atoi(strchr(data.memory, ',') + 1);

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
    return 1;

			




	
	
	
		
 
  }

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
void _web_setrenderpower(int slavekey, char *slavepass, int jobnum, int framenum){

			




	
	
	
		
 
void _web_setrenderpower(int slavekey, char *slavepass, int renderpower){

			




	
	
	
		
 
  fprintf(stderr,"Setting render power on server... ");

			




	
	
	
		
 
  char *url;

			




	
	
	
		
 
  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=setrenderpower&slavekey=%d&slavepass=%s&renderpower=%d", slavekey, slavepass, renderpower);

			




	
	
	
		
 
  struct _web_memorystruct data = _web_getrequest(url);

			




	
	
	
		
 
  free(url);

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"%s\n", data.memory);

			




	
	
	
		
 
  if(data.memory)

			




	
	
	
		
 
    free(data.memory);

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
int slaveBenchmark(char *datadir, int *benchmarkTime, int *renderPower){

			




	
	
	
		
 
  int ret;

			




	
	
	
		
 
  int frameToRender = 1;

			




	
	
	
		
 
  char *frame_str;

			




	
	
	
		
 
  _distren_asprintf(&frame_str, "%d", frameToRender); // Render frame 1

			




	
	
	
		
 

			




	
	
	
		
 
  char *output;

			




	
	
	
		
 
  _distren_asprintf(&output, "%s/benchmark#.jpg", datadir); // Where to save benchmark output

			




	
	
	
		
 

			




	
	
	
		
 
  char *realOutput;

			




	
	
	
		
 
  _distren_asprintf(&realOutput, "%s/benchmark%d.jpg", datadir, frameToRender); // Where to save benchmark output

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
  char *input;

			




	
	
	
		
 
  _distren_asprintf(&input, "%s/benchmark.blend", datadir); // Input file

			




	
	
	
		
 

			




	
	
	
		
 
  fprintf(stderr,"Downloading benchmark data...\n");

			




	
	
	
		
 
  curlget("http://data.distren.org/benchmark.blend", input); // Download to input file location

			




	
	
	
		
 

			




	
	
	
		
 
  char *command = "blender"; // @TODO: We currently expect this to be in PATH

			




	
	
	
		
 
  char *cmd[] = { command, "-b", input, "-o", output, "-f", frame_str, "-t", "0", (char *)NULL }; // arguments for blender

			




	
	
	
		
 

			




	
	
	
		
 
  // fprintf(stderr,"Preparing to execute command: %s -b %s -o %s -f %s\n", command, input, output, frame_str);

			




	
	
	
		
 
  fprintf(stderr,"Running benchmark...\n");

			




	
	
	
		
 

			




	
	
	
		
 
  long startTime;

			




	
	
	
		
 
  long endTime;

			




	
	
	
		
 

			




	
	
	
		
 
  time(&startTime);

			




	
	
	
		
 

			




	
	
	
		
 
  char buf[10];

			




	
	
	
		
 
  struct execio *testrem;

			




	
	
	
		
 
  size_t readlen;

			




	
	
	
		
 

			




	
	
	
		
 
  ret = execio_open(&testrem, command, cmd);

			




	
	
	
		
 
  buf[20] = '\0';

			




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

			




	
	
	
		
 
    {

			




	
	
	
		
 
      if(readlen > 20) {

			




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

			




	
	
	
		
 
}

			




	
	
	
		
 
       buf[readlen] = '\0';

			




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

			




	
	
	
		
 
    }

			




	
	
	
		
 
  execio_close(testrem);

			




	
	
	
		
 

			




	
	
	
		
 
  time(&endTime);

			




	
	
	
		
 

			




	
	
	
		
 
  struct stat buffer;

			




	
	
	
		
 
  int ostatus = stat(realOutput, &buffer);

			




	
	
	
		
 
  if(ostatus == -1){

			




	
	
	
		
 
    ret = 1; // Return error if output wasn't generated

			




	
	
	
		
 
  }

			




	
	
	
		
 
  else

			




	
	
	
		
 
    remove(output);

			




	
	
	
		
 

			




	
	
	
		
 
  free(frame_str);

			




	
	
	
		
 
  free(input);

			




	
	
	
		
 
  free(output);

			




	
	
	
		
 

			




	
	
	
		
 
  *benchmarkTime = abs(difftime(startTime,endTime));

			




	
	
	
		
 
  float tmp = *benchmarkTime;

			




	
	
	
		
 
  tmp = (1/tmp) * 50000;

			




	
	
	
		
 
  *renderPower = (int)tmp;

			




	
	
	
		
 
  return ret;

			




	
	
	
		
 
}

			




        

    


    
    

    

        

                

                    src/server/slavefuncs.h
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -41,28 +41,28 @@ int ssh_keygen();

			




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

			




	
	
	
		
 
int login_user(char *username);

			




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

			




	
	
	
		
 
int exec_blender(char *input, char *output, int frame);

			




	
	
	
		
 
void xmlinit();

			




	
	
	
		
 
void xmlcleanup();

			




	
	
	
		
 
int distren_mkdir_recurse(char *dirname);

			




	
	
	
		
 
int job_build_path(char *filename, unsigned int jobnum);

			




	
	
	
		
 
int downloadTar(char *url, char *destinationPath);

			




	
	
	
		
 
int uploadOutput(char *pathtoOutput, char *urltoOutput, int jobnum, int framenum, int slavekey);

			




	
	
	
		
 
int unpackJob(char *outdir, char *pathtoTar);

			




	
	
	
		
 
void prepareJobPaths(int jobnum, int framenum, char *outputExt, char *datadir, char **urltoTar,char **pathtoTar,char **pathtoTardir,char **pathtoJob, char **pathtoJobfile,char **urltoJobfile,char **urltoOutput,char **pathtoOutput, char **pathtoRenderOutput, char **pathtoOutdir);

			




	
	
	
		
 
int checkUsername(char *username);

			




	
	
	
		
 
void slaveTest();

			




	
	
	
		
 

			




	
	
	
		
 
/* Simple slave */

			




	
	
	
		
 
struct _web_memorystruct;

			




	
	
	
		
 
static void *_web_myrealloc(void *ptr, size_t size);

			




	
	
	
		
 
static size_t _web_writememorycallback(void *ptr, size_t size, size_t nmemb, void *data);

			




	
	
	
		
 
struct _web_memorystruct _web_getrequest(char *url);

			




	
	
	
		
 
void _web_finishframe(int slavekey, char *slavepass, int jobnum, int framenum);

			




	
	
	
		
 
void _web_startframe(int slavekey, char *slavepass, int jobnum, int framenum);

			




	
	
	
		
 
void _web_resetframe(int slavekey, char *slavepass, int jobnum, int framenum);

			




	
	
	
		
 
int _web_getwork(int slavekey, char *slavepass, int *jobnum, int *framenum);

			




	
	
	
		
 
void _web_setrenderpower(int slavekey, char *slavepass, int jobnum, int framenum);

			




	
	
	
		
 

			




	
	
	
		
 
void _web_setrenderpower(int slavekey, char *slavepass, int renderpower);

			




	
	
	
		
 
int slaveBenchmark(char *datadir, int *benchmarkTime, int *renderPower);

			




	
	
	
		
 

			




	
	
	
		
 
#endif

			




        

    



    


    



    



      

      





    
    0 comments (0 inline, 0 general)
    





    


  

  







  


    




    








    
        Server instance: zserverv-307515
    
    
        This site is powered by
            Kallithea,
        which is
        © 2010–2021 by various authors & licensed under GPLv3.
            – Support