gs_stage_file.c

Go to the documentation of this file.

/* $Id: gs_stage_file.c,v 1.4 2007/07/16 19:56:53 yarkhan Exp $ */
/* $UTK_Copyright: $ */

#include "utility.h"

#include <stdlib.h>
#include <string.h>
#include <errno.h>

#include "comm_data.h"
#include "comm_basics.h"
#include "comm_encode.h"
#include "general.h"

int
main(int argc, char **argv)
{
  char *host, *filename, *remote_file_info;
  gs_server_t *gs_server = NULL;
  int server_sock, tag, port;
  struct hostent *hp;
  char cid[CID_LEN];
  ipaddr_t ipaddr;

  memset(cid, 0xFF, CID_LEN);

  if(argc < 3) {
    fprintf(stderr, "Usage: GS_stage_file <file name> <server name> [server port]\n");
    exit(EXIT_FAILURE);
  }

  filename = argv[1];
  host = argv[2];

  if(argc == 4)
    port = atoi(argv[3]);
  else
    port = GRIDSOLVE_SERVER_PORT_DEFAULT;
  
  DBGPRINTF("Connecting to host %s port %d\n", host, port);

  if ((hp = gethostbyname(host)) == NULL) {
    errno = errno_socket();
    ERRPRINTF("Could not gethostbyname for %s (errno %d) \n", host, errno);
    perror("gethostbyname()");
    return INVALID_SOCKET;
  }

  memcpy((void *) &ipaddr, hp->h_addr_list[0], sizeof(ipaddr));
  
  /* all ones will match any component ID */
  memset(cid, 0xFF, CID_LEN);

  server_sock = gs_connect_to_host(cid, ipaddr, port, 0, 0);

  if(server_sock < 0) {
    fprintf(stderr, "Unsuccessful (connecting server)\n");
    gs_server_free(gs_server);
    exit(EXIT_FAILURE);
  }

  if((gs_send_tag(server_sock, GS_PROT_STORE_FILE) < 0) ||
     (gs_send_string(server_sock, VERSION) < 0)) {
    fprintf(stderr, "Unsuccessful (sending tag to Server)\n");
    gs_server_free(gs_server);
    exit(EXIT_FAILURE);
  }

  if(gs_recv_tag(server_sock, &tag) < 0) {
    fprintf(stderr, "Error communicating with server.\n");
    exit(EXIT_FAILURE);
  }

  if(tag != GS_PROT_OK) {
    if(tag == GS_PROT_VERSION_MISMATCH)
      fprintf(stderr, "Error: Server is an incompatible version\n");
    else
      fprintf(stderr, "Error: Server refused with code %d\n", tag);
    exit(EXIT_FAILURE);
  }

  remote_file_info="foo";

  if(gs_send_string(server_sock, remote_file_info) < 0) {
    fprintf(stderr, "Unsuccessful (Sending remote_file_info)\n");
    gs_server_free(gs_server);
    exit(EXIT_FAILURE);
  }

  if(gs_send_arg_from_file(server_sock, filename) < 0) {
    fprintf(stderr, "Error sending from file '%s'\n", filename);
    gs_server_free(gs_server);
    exit(EXIT_FAILURE);
  }
  
  gs_server_free(gs_server);

  exit(EXIT_SUCCESS);
}