gs_probdesc.c

Go to the documentation of this file.

/* $Id: gs_probdesc.c,v 1.11 2007/04/11 16:47:35 seymour Exp $ */
/* $UTK_Copyright: $ */

#include "utility.h"

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

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

int
main(int argc, char **argv)
{
  gs_problem_t *problem = NULL;
  int sock, agentport, tag;
  char *msg = NULL;

  if(argc < 3) {
    fprintf(stderr,"Usage: GS_probdesc <agent name> <problem name>\n");
    exit(EXIT_FAILURE);
  }

  initialize_sockets();

  agentport = getenv_int("GRIDSOLVE_AGENT_PORT", GRIDSOLVE_AGENT_PORT_DEFAULT);
  if((sock = gs_connect_direct(argv[1], agentport)) == INVALID_SOCKET) {
    fprintf(stderr,"%s cannot be contacted\n", argv[1]);
    exit(EXIT_FAILURE);
  }

  if((gs_send_tag(sock, GS_PROT_PROBLEM_DESC) < 0) ||
     (gs_send_string(sock, VERSION) < 0)) {
    fprintf(stderr,"Cannot communicate with %s\n", argv[1]);
    fprintf(stderr,"Error sending tag GS_PROT_PROBLEM_DESC\n");
    exit(EXIT_FAILURE);
  }

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

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

  if(gs_send_string(sock, argv[2]) < 0) {
    fprintf(stderr,"Cannot communicate with %s\n", argv[1]);
    exit(EXIT_FAILURE);
  }

  if(gs_recv_string(sock, &msg) < 0) {
    fprintf(stderr,"Error communicating with agent.\n");
    exit(EXIT_FAILURE);
  }

  if(!strcmp(msg, "not found")) {
    fprintf(stderr,"Problem '%s' was not found.\n", argv[2]);
    exit(EXIT_FAILURE);
  }

  problem = (gs_problem_t *) CALLOC(1, sizeof(gs_problem_t));

  if(!problem) {
    fprintf(stderr,"Failed to allocate problem struct\n");
    return -1;
  }

  if(gs_decode_problem(msg, problem) < 0) {
    fprintf(stderr,"Error encoding problem description.\n");
    exit(EXIT_FAILURE);
  }

  gs_problem_dump(problem);

  cleanup_sockets();

  return 0;
}