Grid Application Toolkit A simple API for Grid Applications

Menu Home API-Specification API-Overview Status C Reference Manual Download Java Java-Reference General GridLab - WP-1 Links

resourcesubsystem_tests.c Go to the documentation of this file. /** @file resourcesubsystem_tests.c * Source file for the resourcesubsystem tests. * * This tests examines the resourcebroker_adaptor functionality. * * @date Fri Oct 24 2003 * * @version $Header: /export/cvs-gridlab/wp-1/Codes/GATEngine/C-reference/test/simple/resourcesubsystem_tests.c,v 1.14 2004/04/26 12:29:08 hartmutkaiser Exp $ * * Copyright (C) Hartmut Kaiser * This file is part of the GAT Engine. * Contributed by Hartmut Kaiser <hartmutkaiser [at] t-online [dot] de>. * * Use, modification and distribution is subject to the Gridlab Software * License. (See accompanying file GLlicense.txt or copy at * http://www.gridlab.org/GLlicense.txt) */ static const char *rcsid = "$Header: /export/cvs-gridlab/wp-1/Codes/GATEngine/C-reference/test/simple/resourcesubsystem_tests.c,v 1.14 2004/04/26 12:29:08 hartmutkaiser Exp $"; /* System Header Files */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/utsname.h> /* GAT Header Files */ #include "GAT.h" #include <GATTestUtils.h> /* Macros */ /* Structures, unions and enums */ /* Static function prototypes */ static GATSoftwareDescription create_software_description(const char* exe, int nargs, const char** args); static GATResourceDescription create_hardware_resource_description(void); /* File scope variables */ /* External functions */ int main (void) { char* exe = strdup ("/bin/date"); int nargs = 0; char** args = NULL; // GATBool isequal = GATFalse; GATResult retval = GAT_FAIL; GATContext context = NULL; GATResourceBroker broker = NULL; GATJob job1 = NULL; GATJob job2 = NULL; GATSoftwareDescription sd = NULL; GATResourceDescription hrd = NULL; GAT_TEST_INIT (-1); GAT_TEST_SUITE ("Resource subsystem") context = GATContext_Create(); GAT_TEST(NULL != context); /* the following test makes sure, that there were no errors during the creation of the GATContext object */ GAT_TEST_TRACE(GATType_GATContext == GATContext_GetType(context), context); /* ask for the job object, which represent this executable */ { GATJob self_job = NULL; GATJobID_const jobid = NULL; GAT_TEST_START ("self job tests (resource description)"); retval = GATSelf_GetJob(context, &self_job); GAT_TEST_TRACE(GAT_SUCCEEDED(retval), context); retval = GATJob_GetJobID(self_job, &jobid); GAT_TEST_TRACE(GAT_SUCCEEDED(retval), context); /* The GAT jobid of this executable is taken from the environment.*/ GAT_TEST_TRACE(NULL != jobid && !strcmp(GATString_GetBuffer(jobid), getenv("GAT_JOBID")), context); GATJob_Destroy(&self_job); GAT_TEST_STOP (); } /* submit the job to the resource broker */ broker = GATResourceBroker_Create(context, 0, 0); GAT_TEST(NULL != broker); /* create the software description of the job to start */ sd = create_software_description(exe, nargs, args); GAT_TEST_TRACE(NULL != sd, context); /* create a hardware resource description describing the required job environment */ hrd = create_hardware_resource_description(); GAT_TEST_TRACE(NULL != hrd, context); /* test job submission through a resource description */ { GATJobID_const jobid = NULL; /* make a job description out of the software and hardware resource description */ GATJobDescription jd = NULL; GAT_TEST_START ("submit job to broker (resource description)"); jd = GATJobDescription_Create_Description(context, sd, hrd); GAT_TEST_TRACE(NULL != jd, context); /* submit a new job */ GAT_TEST_TRACE(NULL != broker, context); retval = GATResourceBroker_SubmitJob(broker, jd, &job1); GAT_TEST_TRACE(GAT_SUCCEEDED(retval), context); /* retrieve the GAT job id of the newly created job */ retval = GATJob_GetJobID(job1, &jobid); GAT_TEST_TRACE(GAT_SUCCEEDED(retval) && NULL != jobid, context); /* clean up memory */ GATJobDescription_Destroy(&jd); GAT_TEST_STOP (); } /* test job submission on a specified resource */ { GATJobID_const jobid = NULL; GATList_GATResource_Iterator first = NULL; GATResource_const *resource = NULL; GATJobDescription jd = NULL; /* find a matching resource */ GATList_GATResource resources = NULL; GAT_TEST_START ("submit job to broker (specific resource)"); retval = GATResourceBroker_FindResources(broker, hrd, &resources); GAT_TEST_TRACE(GAT_SUCCEEDED(retval), context); /* make a job description out of the software resource description and the given resource */ first = GATList_GATResource_Begin(resources); GAT_TEST_TRACE(NULL != first, context); resource = GATList_GATResource_Get(first); GAT_TEST_TRACE(NULL != resource, context); jd = GATJobDescription_Create(context, sd, *resource); GAT_TEST_TRACE(NULL != jd, context); /* submit a new job */ retval = GATResourceBroker_SubmitJob(broker, jd, &job2); GAT_TEST_TRACE(GAT_SUCCEEDED(retval), context); /* retrieve the GAT job id of the newly created job */ retval = GATJob_GetJobID(job2, &jobid); GAT_TEST_TRACE(GAT_SUCCEEDED(retval) && NULL != jobid, context); /* clean up memory */ GATList_GATResource_Destroy(&resources); GATJobDescription_Destroy(&jd); GAT_TEST_STOP (); } /* the two submitted jobs should be identical here */ // retval = GATJob_Equals(job1, job2, &isequal); // GAT_TEST(GAT_SUCCEEDED(retval) && GATTrue == isequal); /* free up all allocated memory */ GATJob_Destroy(&job1); GATJob_Destroy(&job2); GATResourceBroker_Destroy(&broker); GATResourceDescription_Destroy(&hrd); GATSoftwareDescription_Destroy(&sd); GATContext_Destroy(&context); GAT_TEST_FINISH (); free(exe); return 0; } /* Local functions */ /* create a software description describing the job to start */ static GATSoftwareDescription create_software_description(const char* exe, int nargs, const char** args) { GATSoftwareDescription sw_desc = NULL; GATLocation location = NULL; GATList_String arguments = NULL; int i = 0; GATTable attributes = NULL; GAT_TEST_START ("create software description"); /* create and fill the attribute table */ attributes = GATTable_Create (); GAT_TEST (NULL != attributes); /* create "location" attribute" */ location = GATLocation_Create (exe); GAT_TEST (NULL != location); GATTable_Add_GATObject(attributes, "location", GATLocation_ToGATObject_const (location)); /* create and fill the "arguments" attribute */ arguments = GATList_String_Create (); GAT_TEST (NULL != arguments); for (i = 0; i < nargs; ++i) { GATResult retval = (GATList_String_Insert(arguments, GATList_String_End(arguments), args[i])) ? GAT_SUCCESS : GAT_MEMORYFAILURE; GAT_TEST (GAT_SUCCESS == retval); } GATTable_Add_GATObject(attributes, "arguments", GATList_String_ToGATObject_const (arguments)); /* create the software description object */ sw_desc = GATSoftwareDescription_Create (attributes); GAT_TEST (NULL != sw_desc); /* free the allocated memory */ GATList_String_Destroy (&arguments); GATLocation_Destroy (&location); GATTable_Destroy (&attributes); GAT_TEST_STOP (); return sw_desc; } /* create a hardware resource description describing the required job environment */ static GATResourceDescription create_hardware_resource_description (void) { GATHardwareResourceDescription hw_desc = NULL; GATTable requirements = NULL; struct utsname sysinfo; GAT_TEST_START ("create hardware description"); /* create and fill the requirements table */ requirements = GATTable_Create (); GAT_TEST (NULL != requirements); /* query for the system information */ GAT_TEST (uname (&sysinfo) >= 0); /* add required OS parameters to the requirements table */ GATTable_Add_float (requirements, "memory.size", 0.256f); GATTable_Add_String (requirements, "machine.type", sysinfo.machine); GATTable_Add_String (requirements, "machine.node", sysinfo.nodename); GATTable_Add_String (requirements, "cpu.type", "unknown"); GATTable_Add_float (requirements, "cpu.speed", 1.f); GATTable_Add_float (requirements, "disk.size", 10.f); /* create the software Resource description */ hw_desc = GATHardwareResourceDescription_Create(requirements); GAT_TEST (NULL != hw_desc); GATTable_Destroy (&requirements); GAT_TEST_STOP (); return (GATHardwareResourceDescription_ToGATResourceDescription (hw_desc)); }