Files @ b5cec357249a
Branch filter:

Location: DistRen/src/server/slave.c - annotation

ethanzonca
TODO updates
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
1f744ce71f83
c88f2cae0705
c88f2cae0705
3bd3e05fffc8
c88f2cae0705
c88f2cae0705
c88f2cae0705
c88f2cae0705
c88f2cae0705
c88f2cae0705
901eddfe43e9
144cab775ebd
b95115259ec9
2833fc79e696
c89c9fbb46f7
cb6cee4cc6a4
144cab775ebd
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
1f744ce71f83
0b48f673ed7f
eabe88569bb3
eabe88569bb3
eabe88569bb3
eabe88569bb3
50729768e5d3
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
0b48f673ed7f
c89c9fbb46f7
c89c9fbb46f7
f70cfbc2aa25
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
c89c9fbb46f7
58a86e0655cb
f70cfbc2aa25
0b48f673ed7f
c89c9fbb46f7
c89c9fbb46f7
71b7b74b07a9
71b7b74b07a9
71b7b74b07a9
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
6015db8cc605
6015db8cc605
6015db8cc605
b95115259ec9
b95115259ec9
6015db8cc605
6015db8cc605
71b7b74b07a9
b95115259ec9
71b7b74b07a9
71b7b74b07a9
b95115259ec9
f1480587e5ca
0b48f673ed7f
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
b95115259ec9
0b48f673ed7f
50729768e5d3
50729768e5d3
7598c8d2871a
eabe88569bb3
50729768e5d3
50729768e5d3
2507e13f4197
901eddfe43e9
6015db8cc605
901eddfe43e9
901eddfe43e9
901eddfe43e9
901eddfe43e9
6015db8cc605
0b48f673ed7f
6015db8cc605
50729768e5d3
50729768e5d3
50729768e5d3
50729768e5d3
0b48f673ed7f
0b48f673ed7f
1f744ce71f83
c88f2cae0705
/*
  Copyright 2009 Nathan Phillip Brink, Ethan Zonca, Matthew Orlando

  This file is a part of DistRen.

  DistRen is free software: you can redistribute it and/or modify
  it under the terms of the GNU Affero General Public License as published by
  the Free Software Foundation, either version 3 of the License, or
  (at your option) any later version.

  DistRen is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License
  along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

 */

/*
 * **********************************************************************************
 * Slave functions / etc resides below. Wouldn't a separate file make this easier??
 *
 * Slave listens on server for a command in the format of each function...
 * We need if's for returns... ==> watchdog
 * **********************************************************************************
*/

// Provides DISTREN_REQUEST* which is in reality, DISTREN_SEND(signal) in the minds of your average joe
#include "protocol.h"
#include "options.h" // Confuse, etc.
#include "slavefuncs.h" // Slave functions
#include <string.h>
#include <stdio.h>

int slavestatus = 0; // Ugh global vars

int main(int argc, char *argv[])
{

int jobnum;
char *jobname;
int framenum;


/* Parses arguments, skips if there are no args */
	if(argc>1
		&& (strcmp("-c", argv[1]) == 0))
	{
		char *username;
		char *email;

		if(argc != 4)
		{
			fprintf(stderr, "I need more arguments!\n%d is not enough!\n Invoke 'distrenslave -c <username> <emailaddr> to register. \n Already registered? Edit your distrenslave.conf file!'", argc - 1);
			return 234;
		}

		username = argv[2];
		email = argv[3];

		if(!strchr(email, '@'))
		{
			fprintf(stderr, "I want to see an '@' in your email address!\n%s may be good enough for you, but I need more!\n", email);
			return 235;
		}
		register_user(username, email); // register_user returns a uniquely random url to a key
		fprintf(stderr, "You registered, hopefully successfully. Invoke distrenslave with no args now.");
	}
/* End arg parser */



/* Option getter: Creates vars to grab stuff from conf, uses the options include to grab this data */
char *username;
char *key;
username = NULL;
key = NULL;
cfg_t * my_cfg;
cfg_opt_t myopts[] = {
		CFG_SIMPLE_STR("username", &username),
		CFG_SIMPLE_STR("key", &key),
		CFG_END()
		};
struct options_common *commonopts;
options_init(argc,argv,&my_cfg, myopts, "slave", &commonopts);
/* End option getter */


/* If there's no key or username in the conf, let them know! */
	if(key == NULL || username == NULL){
	  fprintf(stderr, "You didn't register! Please register (Invoke '%s -c <username> <emailaddr> to register) or add your username to distrenslave.conf\n", argv[0]);
	}
	else if(key != NULL || username != NULL){
		loginuser(username); // Logs in user to the server
	}
	else{
		fprintf(stderr,"Something is terribly wrong!!!");
	}



/* Rendering code */
	if('slave recieves "start frame#, job#"'){
		fprintf(stderr, "Got frame %d in job %d, preparing to render...",framenum,jobnum);
		get('http://distren.protofusion.org/srv/job%d.tgz', jobnum); // use curl
		exec('tar -xvf job%d.tgz /tmp/distren/job%d',jobnum,jobnum); // somehow
		exec_blender("GIVE ME SOME ARGS!"); // (check the args, we'll need to adjust for different output formats, include this in the blendjob struct later)
			while('blender is running'){
				slavestatus=1; // really quite pointless now, but why not. Could be nice for logging.
				tell_the_server(DISTREN_REQUEST_PROGRESS);
				fprintf(stderr, "Rendering frame %d in job %d...",framenum,jobnum);
				delay(1000); // or not... this should be more event-driven, but should still give a heartbeat to the server
			}
		slavestatus=2; // When done rendering, set this.
	}
	if(slavestatus==2){
		fprintf(stderr, "Finished frame %d in job %d, uploading...",framenum,jobnum);
		curl_POST("/path/to/output.jpg", "http://protofusion.org/distren/output/job%d",jobnum);
		tell_the_server(DISTREN_REQUEST_DONEFRAME); // AKA "I'm done rendering that frame you sent me"
		// Slave now becomes idle, doesn't need to tell the server anything, ssh handles this.
	}

  return 0;
}