DistRen Changeset - ac130e840b4b · protofusion repositories

Changeset - ac130e840b4b

Parent rev.

Child rev.

[Not reviewed]

default

0 3 0

Ethan Zonca (ethanzonca) - 16 years ago 2010-03-13 22:19:53
e@ethanzonca.com

Added basic getwork to simpleslave

3 files changed with 27 insertions and 7 deletions:

Makefile.am

src/server/slavefuncs.c

src/server/slavefuncs.h

0 comments (0 inline, 0 general)

Makefile.am

➞

Show inline comments

@@ @@ -7,13 +7,13 @@ AM_CPPFLAGS = -DSYSCONFDIR='"$(sysconfdi @@
 AM_CFLAGS = $(DISTLIBS_CFLAGS)
 LIBS = $(DISTLIBS_LDADD) $(DISTLIBS_LDFLAGS)
 LDADD = libdistrencommon.la
 bin_PROGRAMS =
 if ENABLE_SERVER
 bin_PROGRAMS += distrend distrenslave
+bin_PROGRAMS += distrend distrenslave distrensimpleslave
 endif
 pkglib_LTLIBRARIES = libdistrencommon.la
 # libdistrencommon.la:
 libdistrencommon_la_SOURCES = src/common/asprintf.c src/common/asprintf.h \
@@ @@ -44,16 +44,19 @@ distrend_SOURCES = $(SERVER_SOURCES) \ @@
 	src/server/listen.c \
 	src/server/mysql.h \
 	src/server/mysql.c
 distrend_LDADD = libdistrencommon.la
 # distrenslave:
 distrenslave_SOURCES = $(SERVER_SOURCES) \
 	src/server/slave.c \
 	src/server/simpleslave.c
 	src/server/slave.c
 distrenslave_LDADD = libdistrencommon.la
 # distrensimpleslave:
 distrensimpleslave_SOURCES = $(SERVER_SOURCES) \
         src/server/simpleslave.c
 distrensimpleslave_LDADD = libdistrencommon.la
 # configuration files:
 dist_sysconf_DATA = etc/distrencommon.conf
 nodist_sysconf_DATA = etc/distrendaemon.conf \
 	etc/distrenslave.conf

src/server/slavefuncs.c

➞

Show inline comments

@@ @@ -593,13 +593,13 @@ static size_t _web_writememorycallback(v @@
     mem->memory[mem->size] = 0;
+  }
   return realsize;
+}
 struct _web_memorystruct _web_getrequest(char *url){
   fprintf(stderr,"Preparing to get request at %s",url);
+  // fprintf(stderr,"Preparing to get request at %s",url);
   CURL *curl;
   CURLcode res;
   struct _web_memorystruct chunk;
   chunk.memory=NULL; /* we expect realloc(NULL, size) to work */
@@ @@ -624,25 +624,42 @@ 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,"Got data: %s\n", data.memory);
   if(data.memory)
     free(data.memory);
+}
 void _web_startframe(int slavekey, char *slavepass, int jobnum, int framenum){
+}
 void _web_getwork(int slavekey, char *slavepass, int *jobnum, int *framenum){
 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);
   //fprintf(stderr,"Got data for getwork: %s!\n", data.memory);
   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){
+}

src/server/slavefuncs.h

➞

Show inline comments

@@ @@ -57,11 +57,11 @@ void slaveTest(); @@
 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_getwork(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);
 #endif

0 comments (0 inline, 0 general)