---

evaluationmanager.c

Go to the documentation of this file.

/*
 *   Copyright (c) 2003 EU DataGrid        http://www.eu-datagrid.org/
 *
 *   $Id: evaluationmanager.c,v 1.21 2003/08/15 12:55:40 martijn Exp $
 *
 *   Copyright (c) 2003 by
 *      G.M. Venekamp <venekamp@nikhef.nl>
 *      NIKHEF Amsterdam, the Netherlands
 *
 *   This software is distributed under a BSD-style open source
 *   licence. For a complete description of the licence take a look
 *   at: http://eu-datagrid.web.cern.ch/eu-datagrid/license.html
 *
 */


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

#include "_lcmaps_pluginmanager.h"
#include "lcmaps_log.h"
#include "evaluationmanager.h"

static lcmaps_db_entry_t* global_plugin_list = NULL;

int free_lcmaps_db_entry();


int startEvaluationManager(const char* name)
{
  if (pdl_init(name) < 0) {
    stopEvaluationManager();
    return -1;
  }

  /*  Let's see if the config file makes sence.  */
  yyparse();

  /*
   *  Check if there were any errors. Ifo so, there is not much point
   *  on continuing.
   */
  if (yyparse_errors()) {
    stopEvaluationManager();
    return -1;
  }

  /*
   *  Check to see if there are any recustions in the config file.
   *  If so, continuing might/will cause an infinite loop.
   */
  if (check_policies_for_recursion())
    return -1;

  /*
   *  We need to replace the variables found in the policy rules by
   *  their respective values.
   */
  reduce_policies();

  return 0;
}


int getPluginNameAndArgs(lcmaps_db_entry_t** plugins)
{
  const plugin_t* p_list, *tmp_p_list;
  lcmaps_db_entry_t* p=0;
  int path_length;
  char* path;
  BOOL string_too_long;

  string_too_long = FALSE;

  /*  Check if the plugins have been requested before.  */
  if (global_plugin_list) {
    *plugins = global_plugin_list;
    return 0;
  }

  /*  Set to a safe default value.  */
  *plugins = 0;

  if (!pdl_path()) {
    lcmaps_log(1, "Initialization of the EvaluationManager either failed or was not done.\n");
    return -1; 
  }

  path = strdup(pdl_path());
  path_length = strlen(path);

  if (path[path_length-1] != '/') {
    path = (char *)realloc(path, path_length+2);
    path[path_length] = '/';
    path[path_length+1] = '\0';

    path_length = strlen(path);
  }

  p_list = get_plugins();

  while (p_list) {
    if (!*plugins) {
      *plugins = (lcmaps_db_entry_t*)malloc(sizeof(lcmaps_db_entry_t));
      p = *plugins;
    } else {
      p->next = (lcmaps_db_entry_t*)malloc(sizeof(lcmaps_db_entry_t));
      p = p->next;
    }

    /*  Copy the name and arguments while respecting max. lengths.  */
    strncpy(p->pluginname, path, LCMAPS_MAXPATHLEN);
    strncpy(p->pluginname+path_length, p_list->name, LCMAPS_MAXPATHLEN-path_length);

    if ((strlen(path) + strlen(p_list->name))>=LCMAPS_MAXPATHLEN) {
      lcmaps_log(1, "String too long to copy. Max length = %d\n", LCMAPS_MAXPATHLEN);
      string_too_long = TRUE;
    }

    if (p_list->args) {
      strncpy(p->pluginargs, p_list->args, LCMAPS_MAXARGSTRING);
      if (strlen(p_list->args)>LCMAPS_MAXARGSTRING) {
        lcmaps_log(1, "String too long to copy. Max length = %d\n", LCMAPS_MAXARGSTRING);
        string_too_long = TRUE;
      }
    }
    else
      *p->pluginargs = '\0';
    p->next = 0;

    tmp_p_list = p_list->next;

    if (p_list->name)  free(p_list->name);
    if (p_list->args)  free(p_list->args);
    free((plugin_t*)p_list);

    p_list = tmp_p_list;

    /*  Output some debug info.  */
    lcmaps_log_debug(1, "%s\n", p->pluginname);
    lcmaps_log_debug(1, "%s\n", p->pluginargs);
  }

  free(path);

  global_plugin_list = *plugins;

  return string_too_long ? -1 : 0;
}


int runEvaluationManager(void)
{
  const char* plugin_name;
  plugin_status_t result;
  policy_t* policy;

  lcmaps_log_debug(1, "runEvaluationManager called\n");

  result = EVALUATION_START;
  while ((plugin_name=pdl_next_plugin(result))) {
    result = (runPlugin(plugin_name) ? EVALUATION_FAILURE : EVALUATION_SUCCESS);
    
    lcmaps_log_debug(1, "runEvaluationManager: running plugin: %s.\n", plugin_name);
    lcmaps_log_debug(1, "                    : result %s.\n", (result==EVALUATION_SUCCESS) ? "true" : "false");
    
    free((char *)plugin_name);
  }

  if (result==EVALUATION_START)
    lcmaps_log(1, "Initialization of the EvaluationManager either failed or was not done.\n");

  return result==EVALUATION_SUCCESS ? 0 : 1;
}


int stopEvaluationManager(void)
{
  lcmaps_log_debug(1, "stopEvaluationManager: cleaning up!\n");

  free_resources();

  free_lcmaps_db_entry();

  return 0;
}


int free_lcmaps_db_entry()
{
  lcmaps_db_entry_t* plugin = global_plugin_list;

  while (plugin) {
    lcmaps_db_entry_t* tmp = plugin->next;
    free(plugin);
    plugin = tmp;
  }

  global_plugin_list = NULL;

  return 0;
}

---