idl_request.c

Go to the documentation of this file.

/* $Id: idl_request.c,v 1.5 2007/03/01 22:52:31 seymour Exp $ */
/* $UTK_Copyright: $ */

#include <stdio.h>
#include "idl_request.h"
#include "translate.h"

GS_IDL_Request requests[MAX_GRPC_REQUESTS];

void
gs_init_req()
{
  int i;

  for(i=0;i<MAX_GRPC_REQUESTS;i++) {
    requests[i].gs_req_id = GS_IDL_NULL_ID;
    requests[i].argc = 0;
    requests[i].pd = NULL;
    requests[i].argv_idl = NULL; 
  }
}

void 
gs_requests(int argc, IDL_VPTR* argv_idl) {
  int i;

  if(argc == 0) {
    for(i=0;i<MAX_GRPC_REQUESTS;i++) {
      if(requests[i].gs_req_id != GS_IDL_NULL_ID) {
        if(requests[i].pd)
          printf("%d: %s\n", i, requests[i].pd->name);
        else
          printf("%d: Error: null problem description.\n", i);
      }
    }
  }
  else {
    IDL_ENSURE_SCALAR(argv_idl[0]);

    i = argv_idl[0]->value.l;

    if((i < 0) || (i >= MAX_GRPC_REQUESTS)) {
      IDL_Message(IDL_M_GENERIC,IDL_MSG_INFO, "Error: bad request id\n");
      return;
    }

    if(requests[i].gs_req_id != GS_IDL_NULL_ID) {
      if(requests[i].pd)
        printf("%d: %s\n", i, requests[i].pd->name);
      else
        printf("%d: Error: null problem description.\n", i);
    }
    else 
      printf("%d: no request using this id\n", i);
  }

  return;
}

IDL_VPTR *
argv_idl_dup(IDL_VPTR* argv_idl, int num) {
  int        i;
  IDL_VPTR*  argv_ret;
  IDL_VPTR   arg;

  argv_ret = (IDL_VPTR*) malloc(sizeof(IDL_VPTR)*num);

  if(!argv_ret)
    return NULL;

  for(i = 0; i < num; i++) {
    arg = argv_idl[i];
    /* clone if it is a temp var */
    if((arg->flags & IDL_V_TEMP) || (arg->flags & IDL_V_CONST)) {
      argv_ret[i] = (IDL_VPTR) malloc(sizeof(IDL_VARIABLE));

      if(!argv_ret[i])
        return NULL;

      *argv_ret[i] = *argv_idl[i];

      if((arg->flags & IDL_V_ARR) != 0) {
    argv_ret[i]->value.arr    = (IDL_ARRAY*) malloc(sizeof(IDL_ARRAY));
        if(!argv_ret[i]->value.arr)
          return NULL;

    *(argv_ret[i]->value.arr) = *(argv_idl[i]->value.arr);
      }      
    } else {
      argv_ret[i] = arg; /* keep the original non-tmp var */
    }

  }

  return argv_ret;
}

void
argv_idl_free(IDL_VPTR* argv_idl, int num) {
  int i;

  for (i = 0; i < num; i++) {
    if((argv_idl[i]->flags & IDL_V_TEMP) || (argv_idl[i]->flags & IDL_V_CONST)) {
      /* malloc happened only when temp idl_vptr was used */
      if ((argv_idl[i]->flags & IDL_V_ARR) != 0) {
    free(argv_idl[i]->value.arr);
      }
      free(argv_idl[i]);
    }
  }

  free(argv_idl);
}

int
add_req(grpc_sessionid_t id, gs_problem_t* pd, int argc, 
        IDL_VPTR* argv_idl)
{
  if((id < 0) || (id >= MAX_GRPC_REQUESTS))
    return -1;

  requests[id].gs_req_id = id;
  requests[id].pd        = pd;
  requests[id].argc      = argc;
  requests[id].argv_idl  = argv_idl_dup(argv_idl, argc);

  if(!requests[id].argv_idl)
    return -1;

  return 0;
}

int
del_req(grpc_sessionid_t id)
{
  if((id < 0) || (id >= MAX_GRPC_REQUESTS))
    return -1;

  /* post processing */
  postproc_argv_c(requests[id].pd, requests[id].argv_idl);

  /* free those cloned argv_idl */
  argv_idl_free(requests[id].argv_idl, requests[id].argc);

  requests[id].gs_req_id = GS_IDL_NULL_ID;
  requests[id].pd = NULL;
  requests[id].argv_idl = NULL;

  return 0;
}