Configuration file for distren.

  Currently, this file is being prepared as the goal for this project. For instance, the ability to support connecting and communicating with servers is suggested by the server sections.

*/

/*

  currently, server's are only supported rudimentarily. If a job has n frames and there are s servers, n / (s + 1) frames will be sent to each individual server and also rendered on the machine the job was submitted to. There will be no recursive distribution of jobs, but I want to make that possible in the future. AND, I want job IDs to have significance based on 1: the files, 2: the versions of software used to render just like git, mercurial, or bazaar's commit IDs have significance. This will allow global distribution of renderjobs without requiring central servers to coordinate the jobs - a network only need be distributed. And complex algorithms based on timeouts and completion of jobs should allow slow servers to reassign jobs to fast ones and, possibly, find shorter routes to return the resulting images to the original job submitter. Multiple server declarations are currently included, but an implementation for multiple servers is lacking.

*/

server protofusion

{

  hostname = "protofusion.org"

  username = "distrenc"

  method = "ssh"

  types = {"submit", "distribution"} /* submit means it accepts jobs, distribution means it can host files */

}

server ohnopublishing

{

  hostname = "ohnopublishing.net"

  username = "distrenc"

  method = "ssh"

  types = {"distribution"}

}

/*

  Copyright 2010 Nathan Phillip Brink

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

*/

#ifndef _DISTREN_LIBREMOTEIO_H

#define _DISTREN_LIBREMOTEIO_H

#include "remoteio.h"

#include <confuse.h>

/**

  private declarations for remoteio, to be included by options.c and remoteio.c

 */

enum remoteio_method

  {

    REMOTEIO_METHOD_SSH = 0,

#ifndef WINDOWS

    REMOTEIO_METHOD_UNIX = 1,

#endif

    REMOTEIO_METHOD_TCP = 2,

    /*    REMOETIO_METHOD_XMLRPC */ /*< maybe someday */

    REMOTEIO_METHOD_MAX = 3 /*< This is a number used to check the consitency of remoteio_server structs */

  };

struct remoteio_server

{

  char *name; /*< The friendly named passed to remoteio_open() */

  char *hostname;

  char *username;

  enum remoteio_method method;

  unsigned int types; /*< See ``Server types'' in protocol.h */

};

struct remoteio_opts

{

  char *ssh_command;

};

struct remoteio {

  enum remoteio_method method;

  struct remoteio_opts *opts;

  struct execio *execio;

#ifndef WINDOWS

  int sock;

#endif

};

/* lookup table */

typedef int remoteio_open_func_t(struct remoteio *rem, struct remoteio_server *server);

typedef int remoteio_read_func_t(struct remoteio *rem, void *buf, size_t len, size_t *bytesread);

typedef int remoteio_write_func_t(struct remoteio *rem, void *buf, size_t len, size_t *bytesread);

typedef int remoteio_close_func_t(struct remoteio *rem);

struct remoteio_method_funcmap

{

  enum remoteio_method method;

  remoteio_open_func_t *open_func;

  remoteio_read_func_t *read_func;

/*

  Copyright 2010 Nathan Phillip Brink

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

*/

#include "libremoteio.h"

#include "execio.h"

#include "asprintf.h"

#include <errno.h>

#ifndef _WIN32

#include <netdb.h>

#endif

#include <stdlib.h>

#include <stdio.h>

#include <string.h>

#include <sys/types.h>

#ifdef _WIN32

#include <winsock2.h>

#include <ws2tcpip.h>

#else

#include <sys/socket.h>

#endif

#include <unistd.h>

#ifndef _WIN32

#include <sys/un.h>

#endif

/* local */

#define REMOTEIO_DEFAULT_PORT "4050"

int _remoteio_tcp_close(struct remoteio *rem);

/**

  lookup table for different methods of remoteio:

  the enum remoteio_method is the index of the entry to use for that method. 

  Regardless, a NULL terminator is required because the configuration function

  searches through this table for the method specified in the config file.

*/

struct remoteio_method_funcmap funcmap[] = 

  {

    /* [REMOTEIO_METHOD_SSH] */

    {REMOTEIO_METHOD_SSH, &_remoteio_ssh_open, &_remoteio_ssh_read, &_remoteio_ssh_write, &_remoteio_ssh_close, "ssh"},

#ifndef _WIN32

    {REMOTEIO_METHOD_UNIX, &_remoteio_sock_open, &_remoteio_sock_read, &_remoteio_sock_write, &_remoteio_sock_close, "unix"},

#endif

    {REMOTEIO_METHOD_TCP, &_remoteio_tcp_open, &_remoteio_sock_read, &_remoteio_sock_write, &_remoteio_tcp_close, "tcp"},

    {REMOTEIO_METHOD_MAX, NULL, NULL, NULL, NULL, NULL}

  };

struct remoteio_server *remoteio_getserver(const struct remoteio_opts *opts, const char *servername);

int remoteio_config(cfg_t *cfg, struct remoteio_opts *opts)

{

  size_t numservers;

  static int haslisted_methods = 0;

  if(!opts->servers)

    {

      fprintf(stderr, "@todo cleanup!\n");

      abort();

    }

  for(counter = 0; counter < numservers; counter ++)

    {

      cfg_t *cfg_aserver;

      char *method;

      cfg_aserver = cfg_getnsec(cfg, "server", counter);

      method = cfg_getstr(cfg_aserver, "method");

	{

	  fprintf(stderr, "No such method as %s\n", method);

	  if(!haslisted_methods)

	    {

	      fprintf(stderr, "Available methods:\n");

	      haslisted_methods ++;

	    }

	  abort();

	}

    }

  return 0;

}

int remoteio_open(struct remoteio **remoteio, struct remoteio_opts *opts, const char *servername)

{

  struct remoteio_server *theserver;

  struct remoteio *rem;

  int tmp;

  if(!opts)

    {

      fprintf(stderr, "%s:%d: no null opts!\n\tThis is a bug, please report it (after making sure it isn't already reported)\n", __FILE__, __LINE__);

      return 1;

    }

  theserver = remoteio_getserver(opts, servername);

  if(!theserver)

    {

      fprintf(stderr, "%s:%d: Could not find server named ``%s''\n", __FILE__, __LINE__, servername);

      return 1;

  return 0;

}

int remoteio_read(struct remoteio *rem, void *buf, size_t len, size_t *bytesread)

{

  return funcmap[rem->method].read_func(rem, buf, len, bytesread);

}

int remoteio_write(struct remoteio *rem, void *buf, size_t len, size_t *byteswritten)

{

  return funcmap[rem->method].write_func(rem, buf, len, byteswritten);

}

int remoteio_close(struct remoteio *rem)

{

  int rtn;

  rtn = funcmap[rem->method].close_func(rem);

  free(rem);

  return rtn;

}

struct remoteio_server *remoteio_getserver(const struct remoteio_opts *opts, const char *servername)

{

  return (struct remoteio_server *)NULL;

}

/**

   different remoteio methods' implementations:

 */

/*

  SSH, via execio

*/

int _remoteio_ssh_open(struct remoteio *rem, struct remoteio_server *server)

{

  char *userhost;

  char *sshargs[] = {rem->opts->ssh_command, NULL /* userhost */, "distrend", "-d", (char *)NULL};

  int rtn;

  if(server->username)

    _distren_asprintf(&userhost, "%s@%s", server->username, server->hostname);