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

gatrequest_tests.c Go to the documentation of this file. /** @file gatrequest_tests.c * * Test the GATRequest functionality. * * @date Sun Feb 01 2004 * * @version $Header: /export/cvs-gridlab/wp-1/Codes/GATEngine/C-reference/test/internal/gatrequest_tests.c,v 1.8 2004/04/20 17:04:43 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/internal/gatrequest_tests.c,v 1.8 2004/04/20 17:04:43 hartmutkaiser Exp $"; /* System Header Files */ #include <stdio.h> #include <stdlib.h> #include <unistd.h> /* GAT Header Files */ #include "GAT.h" #include "GATTestUtils.h" /* Macros */ /* Structures, unions and enums */ /* Static function prototypes */ static GATResult on_checkpoint_issued_1(void *context_data, GATRequest_const request); static GATResult on_checkpoint_issued_2(void *context_data, GATRequest_const request); /* File scope variables */ /* External functions */ int main(int argc, const char * const argv[]) { GATResult retcode = GAT_SUCCESS; GATContext context = NULL; GATuint32 cookie_1 = 0; GATBool break_loop_1 = GATFalse; int i; int ok = 0; GAT_TEST_INIT(-1); GAT_TEST_SUITE("GATRequest"); 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); GAT_TEST_START("GATRequest listener test"); retcode = GATSelf_AddRequestListener(context, on_checkpoint_issued_1, &break_loop_1, GATRequestType_Command, NULL, "checkpoint1", &cookie_1); GAT_TEST_TRACE(GAT_SUCCEEDED(retcode) && 0 != cookie_1, context); /* this for loop waits for the adaptor to fire the on_checkpoint_issued */ for (i = 0; i < 5; i++ ) { retcode = GATContext_ServiceActions (context, 0); if (GAT_FAILED(retcode) || GATTrue == break_loop_1) { ok = 1; break; } sleep (1); } GAT_TEST_TRACE(0 != ok, context); GAT_TEST_TRACE(GAT_SUCCEEDED(retcode), context); retcode = GATSelf_RemoveRequestListener(context, cookie_1); GAT_TEST_TRACE(GAT_SUCCEEDED(retcode), context); GAT_TEST_STOP(); GATContext_Destroy(&context); GAT_TEST_FINISH(); return 0; } /* This is the GATRequestListener, which get's called, whenever the "checkpoint" command is issued */ static GATResult on_checkpoint_issued_1(void *context_data, GATRequest_const request) { GATResult retval = GAT_INVALID_HANDLE; fprintf (stderr, "checkpoint now!\n"); if (NULL != request) { GATRequestNotifier_const notifier = NULL; retval = GATRequest_GetRequestNotifier(request, &notifier); GAT_TEST(GAT_SUCCEEDED(retval)); if (NULL != notifier) { GATTable table = GATTable_Create(); GAT_TEST(NULL != table); /* add the name of the checkpoint file to the table */ retval = GATTable_Add_String(table, "checkpoint_file1", "some_name"); GAT_TEST(GAT_SUCCEEDED(retval)); /* send the notifiertable back to the adaptor */ retval = GATRequestNotifier_Respond(notifier, table); GAT_TEST(GAT_SUCCEEDED(retval)); GATTable_Destroy(&table); } else { retval = GAT_FAIL; /* completely unexpected */ } } if (NULL != context_data) { *(GATBool *)context_data = GATTrue; /* break the forever loop above */ } return retval; }