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

advertservice.c Go to the documentation of this file. /** @file advertservice.c * Source file for the GATAdvertServiceCPI provider class for the * request adaptor. * * TODO: Fill in the description of the new CPI provider here * * @date Thu Mar 18 2004 * * @version $Header: /export/cvs-gridlab/wp-1/Codes/GATEngine/C-reference/adaptors/advertservice_adaptor/advertservice.c,v 1.13 2004/04/26 15:44:59 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/adaptors/advertservice_adaptor/advertservice.c,v 1.13 2004/04/26 15:44:59 hartmutkaiser Exp $"; /* System Header Files */ #include <stdio.h> #include <stdlib.h> #include <string.h> /* GAT Header Files */ #include "GATCPI.h" #include "GATMemoryStream.h" #include "GATUtil.h" #include "advertservice.h" #include "advertservice_database.h" /* Macros */ /* Structures, unions and enums */ /* Instance data */ typedef struct GATAdvertServiceCPIInstance_Data { int dummy; /* no data yet */ } GATAdvertServiceCPIInstance_Data; /* Static function prototypes */ static void advertservice_adaptor_GATAdvertServiceCPI_Destroy(void *data); /* Instance data */ static GATAdvertServiceCPIInstance_Data *GATAdvertServiceCPIInstance_Data_Create(void); static void GATAdvertServiceCPIInstance_Data_Destroy(GATAdvertServiceCPIInstance_Data **); static GATResult GATAdvertServiceCPIInstance_Data_Clone(GATAdvertServiceCPIInstance_Data const *, GATAdvertServiceCPIInstance_Data **); static GATResult GATAdvertServiceCPIInstance_Data_Equals( GATAdvertServiceCPIInstance_Data const *, GATAdvertServiceCPIInstance_Data const *, GATBool *); /* instance specific functions */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_ServiceActions(void *data, GATAdvertServiceCPI_Instance *instance_data, GATTimePeriod_const timeout /* = 0 */); static GATResult advertservice_adaptor_GATAdvertServiceCPI_CreateInstance( void *data, GATAdvertServiceCPI_Instance *instance_data); static void advertservice_adaptor_GATAdvertServiceCPI_DestroyInstance( void *data, GATAdvertServiceCPI_Instance *instance_data); static GATResult advertservice_adaptor_GATAdvertServiceCPI_CloneInstance( void *data, GATAdvertServiceCPI_Instance const *instance_data, GATAdvertServiceCPI_Instance *new_instance_data); static GATResult advertservice_adaptor_GATAdvertServiceCPI_EqualsInstance( void *data, GATAdvertServiceCPI_Instance const *lhs, GATAdvertServiceCPI_Instance const *rhs, GATBool *isequal); /* CPI API functionality */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_Add( void *, GATAdvertServiceCPI_Instance *, GATObject_const, GATTable_const, GATString_const); static GATResult advertservice_adaptor_GATAdvertServiceCPI_Delete( void *, GATAdvertServiceCPI_Instance *, GATString_const); static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetaData( void *, GATAdvertServiceCPI_Instance const *, GATString_const, GATTable *); static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetAdvertisable( void *, GATAdvertServiceCPI_Instance const *, GATString_const, GATObject *); static GATResult advertservice_adaptor_GATAdvertServiceCPI_Find( void *, GATAdvertServiceCPI_Instance const *, GATTable_const, GATList_String *); /* Monitoring support */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetrics(void *data, GATAdvertServiceCPI_Instance const *instance_data, GATList_GATMetric *metrics); static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetricEvent(void *data, GATAdvertServiceCPI_Instance const *instance_data, GATMetric metric, GATMetricEvent *event); /* local functions */ static GATResult advertservice_adapter_resolve_path( GATAdvertServiceCPI_Instance const *instance_data, GATString_const path, char **absolute); /* File scope variables */ /* External functions */ /* Register the CPI to implement */ GATResult advertservice_adaptor_Register_GATAdvertServiceCPI( GATContext error_context, GATRegistry registry, GATTable_const system_config, GATTable_const instance_config, void *token) { GAT_USES_STATUS(error_context, "advertservice_adaptor_Register_GATAdvertServiceCPI"); GATAdvertServiceCPI cpi = NULL; GATAdvertServiceCPI_Data cpidata; memset(&cpidata, 0, sizeof(GATAdvertServiceCPI_Data)); /* * provide the appropriate callback functions */ cpidata.data = NULL; cpidata.destroy = advertservice_adaptor_GATAdvertServiceCPI_Destroy; /* instance data handling */ cpidata.service_actions = advertservice_adaptor_GATAdvertServiceCPI_ServiceActions; cpidata.create_instance = advertservice_adaptor_GATAdvertServiceCPI_CreateInstance; cpidata.destroy_instance = advertservice_adaptor_GATAdvertServiceCPI_DestroyInstance; cpidata.clone_instance = advertservice_adaptor_GATAdvertServiceCPI_CloneInstance; cpidata.equals_instance = advertservice_adaptor_GATAdvertServiceCPI_EqualsInstance; /* CPI specific API functions */ cpidata.add_entry = advertservice_adaptor_GATAdvertServiceCPI_Add; cpidata.delete_entry = advertservice_adaptor_GATAdvertServiceCPI_Delete; cpidata.get_metadata = advertservice_adaptor_GATAdvertServiceCPI_GetMetaData; cpidata.get_advertisable = advertservice_adaptor_GATAdvertServiceCPI_GetAdvertisable; cpidata.find_entries = advertservice_adaptor_GATAdvertServiceCPI_Find; /* monitoring support */ cpidata.get_metrics = advertservice_adaptor_GATAdvertServiceCPI_GetMetrics; cpidata.get_metric_event = advertservice_adaptor_GATAdvertServiceCPI_GetMetricEvent; /* Create a GATAdvertServiceCPI object. */ cpi = GATAdvertServiceCPI_Create(GATADVERTSERVICECPI_VERSION, &cpidata); if (NULL != cpi) { /* Need to pass preferences to allow matching * of a user's preferences with what this adaptor does. */ GATPreferences preferences = GATPreferences_Create(); if (NULL != preferences) { GAT_CREATE_STATUS(GATPreferences_Add(preferences, "Name", "advertservice_adaptor")); GAT_CREATE_STATUS(GATPreferences_Add(preferences, "Security", "none")); GAT_CREATE_STATUS(GATPreferences_Add(preferences, "Local", "true")); GAT_CREATE_STATUS(GATRegistry_AddGATAdvertServiceCPI(registry, cpi, token, preferences)); GATPreferences_Destroy(&preferences); } else { GAT_CREATE_STATUS(GAT_MEMORYFAILURE); } } else { GAT_CREATE_STATUS(GAT_MEMORYFAILURE); } if (GAT_FAILED(GAT_CURRENT_STATUS())) { GATAdvertServiceCPI_Destroy(&cpi); } return GAT_RETURN_STATUS(); } /* Local functions */ static void advertservice_adaptor_GATAdvertServiceCPI_Destroy(void *data) { } /* instance specific functions */ /** advertservice_adaptor_GATAdvertServiceCPI_ServiceActions * * The function advertservice_adaptor_GATAdvertServiceCPI_ServiceActions is called, whenever * the client calls GATContext_ServiceActions. This function is called for * every created object. * This function should be used to update all instance specific data, which * may have been changed asynchronously or to fire pending events. * * @param data Adaptor-provided data object. * @param instance_data The instance data of this CPI object * @param timeout This may be a 0 timeout to indicate no timeout at all, or * a specific time length. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_ServiceActions(void *data, GATAdvertServiceCPI_Instance *instance_data, GATTimePeriod_const timeout) { return GAT_NOTIMPL; } /** advertservice_adaptor_GATAdvertServiceCPI_CreateInstance * Create a new CPI object instance. * Adaptor implementation of create instance capability. * * @param data Adaptor-provided data object. * @param context The GATContext for this CPI instance * @param target The location of the file in question. * @param new_instance_data The pointer to the variable, where the instance * data of this CPI object is to be returned to. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_CreateInstance(void *data, GATAdvertServiceCPI_Instance *new_instance_data) { if (NULL != new_instance_data) { sqlite *db = NULL; GAT_USES_STATUS(new_instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_CreateInstance"); /* create instance data */ new_instance_data->instance_data = GATAdvertServiceCPIInstance_Data_Create(); GAT_CREATE_STATUS_IF(NULL == new_instance_data->instance_data, GAT_MEMORYFAILURE); /* try to initialise the database */ GAT_CREATE_STATUS(advertservice_db_init(new_instance_data->context, &db)); advertservice_db_close(&db); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_DestroyInstance * Destroy a CPI object instance. * Adaptor implementation of destroy instance capability. * * @param data Adaptor-provided data object. * @param instance_data The instance data of the CPI object to destroy. */ static void advertservice_adaptor_GATAdvertServiceCPI_DestroyInstance(void *data, GATAdvertServiceCPI_Instance *instance_data) { GATAdvertServiceCPIInstance_Data_Destroy( (GATAdvertServiceCPIInstance_Data **) &instance_data->instance_data); } /** advertservice_adaptor_GATAdvertServiceCPI_CloneInstance * Clone a CPI object instance. * Adaptor implementation of the clone instance capability. * * @param data Adaptor-provided data object. * @param instance_data The instance data of this CPI object * @param new_instance_data The pointer to the variable, where the instance * data of the cloned CPI object is to be returned to. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_CloneInstance( void *data, GATAdvertServiceCPI_Instance const *instance_data, GATAdvertServiceCPI_Instance *new_instance_data) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_CloneInstance"); if (NULL != new_instance_data) { GAT_CREATE_STATUS(GATAdvertServiceCPIInstance_Data_Clone( (GATAdvertServiceCPIInstance_Data const *)instance_data->instance_data, (GATAdvertServiceCPIInstance_Data **)&new_instance_data->instance_data)); } else { GAT_CREATE_STATUS(GAT_INVALID_PARAMETER); } return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_EqualsInstance * Clone a CPI object instance. * Adaptor implementation of the clone instance capability. * * @param data Adaptor-provided data object. * @param lhs The instance data of the left CPI object. * @param lhs The instance data of the right CPI object. * @param isequal The pointer to the variable, where the result is to be * returned to. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_EqualsInstance( void *data, GATAdvertServiceCPI_Instance const *lhs, GATAdvertServiceCPI_Instance const *rhs, GATBool *isequal) { if (NULL != lhs && NULL != rhs) { GAT_USES_STATUS(lhs->context, "advertservice_adaptor_GATAdvertServiceCPI_EqualsInstance"); GAT_CREATE_STATUS(GATAdvertServiceCPIInstance_Data_Equals( (GATAdvertServiceCPIInstance_Data const *) lhs->instance_data, (GATAdvertServiceCPIInstance_Data const *) rhs->instance_data, isequal)); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /* CPI API functionality */ /** advertservice_adaptor_GATAdvertServiceCPI_Add * * Add a new entry to the advert service. * * @param data The adaptor instance data. * @param instance_data The instance data of the CPI object to add the entry * to. * @param advertisable The advertisable object, which should be stored in the * given advertservice. * @param metadata The meta data to rassociate with the newly created entry. * @param path The path inside the advert service, where the newly created * entry is to be stored. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_Add( void *data, GATAdvertServiceCPI_Instance *instance_data, GATObject_const advertisable, GATTable_const metadata, GATString_const path) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_Add"); sqlite *db = NULL; char *buffer = NULL; GATuint32 buffer_size = 0; char *pathstr = NULL; GATMemoryStream stream = NULL; /* create the memory based stream and stream the advertisable into this */ stream = GATMemoryStream_Create(0, 0, GATFalse); GAT_CREATE_STATUS_IF(NULL == stream, GAT_MEMORYFAILURE); GAT_CREATE_STATUS(GATSerialisable_Serialise((GATObject)advertisable, GATMemoryStream_ToGATObject(stream), GATFalse)); /* retrieve the streamed data */ buffer = GATMemoryStream_GetBuffer (stream, &buffer_size, GATFalse); GAT_CREATE_STATUS_IF(NULL == buffer || 0 == buffer_size, GAT_MEMORYFAILURE); buffer[buffer_size] = '\0'; /* retrieve the path, where to store the data */ GAT_CREATE_STATUS(advertservice_adapter_resolve_path(instance_data, path, &pathstr)); /* write the serialised data to the database */ GAT_CREATE_STATUS(advertservice_db_init(instance_data->context, &db)); GAT_CREATE_STATUS(advertservice_db_write_advert_data( instance_data->context, db, pathstr, buffer, metadata)); advertservice_db_close(&db); GATMemoryStream_Destroy(&stream); free(pathstr); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_Delete * * Delete an entry from the advert service. * * @param data The adaptor instance data. * @param instance_data The instance data of the CPI object to delete the entry * from. * @param path The path of the entry to delete from the given advert service. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_Delete( void *data, GATAdvertServiceCPI_Instance *instance_data, GATString_const path) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_Delete"); sqlite *db = NULL; char *pathstr = NULL; /* retrieve the path, where to store the data */ GAT_CREATE_STATUS(advertservice_adapter_resolve_path(instance_data, path, &pathstr)); /* delete the given data element */ GAT_CREATE_STATUS(advertservice_db_init(instance_data->context, &db)); GAT_CREATE_STATUS(advertservice_db_delete_advert_data( instance_data->context, db, pathstr)); advertservice_db_close(&db); free(pathstr); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_GetMetaData * * Retrieve the meta data of a given entry in the advert service. * * @param data The adaptor instance data. * @param instance_data The instance data of the CPI object to get the meta * data for a certain entry from. * @param path The path of the entry, for which the meta data should be * retrieved. * @param The pointer to a variable, which receives the requested meta data. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetaData( void *data, GATAdvertServiceCPI_Instance const *instance_data, GATString_const path, GATTable *metadata) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_GetMetaData"); sqlite *db = NULL; char *pathstr = NULL; /* retrieve the path, where to store the data */ GAT_CREATE_STATUS(advertservice_adapter_resolve_path(instance_data, path, &pathstr)); /* retrieve the metadata associated with the given data element */ GAT_CREATE_STATUS(advertservice_db_init(instance_data->context, &db)); GAT_CREATE_STATUS(advertservice_db_get_metadata( instance_data->context, db, pathstr, metadata)); advertservice_db_close(&db); free(pathstr); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_GetAdvertisable * * Retrieve the advertisable object stored in a given entry in the advert * service. * * @param data The adaptor instance data. * @param instance_data The instance data of the CPI object to get the * advertised object for a certain entry from. * @param path The path of the entry, for which the stroed advertisable should * be retrieved. * @param advertisable The pointer to a variable, which should receive the * requested advertisable object. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetAdvertisable( void *data, GATAdvertServiceCPI_Instance const *instance_data, GATString_const path, GATObject *advertisable) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_GetAdvertisable"); sqlite *db = NULL; char *pathstr = NULL; char *data = NULL; GATMemoryStream stream = NULL; GATObject object = NULL; GATResult retval = GAT_SUCCESS; /* retrieve the path, where to store the data */ GAT_CREATE_STATUS(advertservice_adapter_resolve_path(instance_data, path, &pathstr)); /* retrieve the metadata associated with the given data element */ GAT_CREATE_STATUS(advertservice_db_init(instance_data->context, &db)); GAT_CREATE_STATUS(advertservice_db_get_advert_data( instance_data->context, db, pathstr, &data)); advertservice_db_close(&db); /* recreate the GATObject from the serialised data */ if (GAT_SUCCEEDED(GAT_CURRENT_STATUS())) { stream = GATMemoryStream_Create(data, strlen(data), GATTrue); GAT_CREATE_STATUS_IF(NULL == stream, GAT_MEMORYFAILURE); } /* deserialise the streamed GAT object */ if (GAT_SUCCEEDED(GAT_CURRENT_STATUS())) { object = GATSerialisable_DeSerialise(instance_data->context, GATMemoryStream_ToGATObject(stream), &retval); GAT_CREATE_STATUS_UNCOND(retval); } GATMemoryStream_Destroy(&stream); /* return the new object */ if (NULL != advertisable) { *advertisable = object; } else { GATObject_Destroy(&object); GAT_CREATE_STATUS_UNCOND(GAT_INVALID_PARAMETER); } free(pathstr); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /** advertservice_adaptor_GATAdvertServiceCPI_Find * * Find a list of matching entries in the advert service. * * @param data The adaptor instance data. * @param instance_data The instance data of the CPI object, where to find the * matching entries. * @param metadata The meta data search criteria to use for the query. * @param paths The pointer to a variable, which should receive the list of * paths pointing to matching entries inside the given advert service. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_Find( void *data, GATAdvertServiceCPI_Instance const *instance_data, GATTable_const metadata, GATList_String *paths) { if (NULL != instance_data) { GAT_USES_STATUS(instance_data->context, "advertservice_adaptor_GATAdvertServiceCPI_GetMetaData"); sqlite *db = NULL; /* retrieve the metadata associated with the given data element */ GAT_CREATE_STATUS(advertservice_db_init(instance_data->context, &db)); GAT_CREATE_STATUS(advertservice_db_find( instance_data->context, db, metadata, paths)); advertservice_db_close(&db); return GAT_RETURN_STATUS(); } return GAT_INVALID_HANDLE; } /* Monitoring support */ /** advertservice_adaptor_GATAdvertServiceCPI_GetMetrics * * The function advertservice_adaptor_GATAdvertServiceCPI_GetMetrics should return a * list of GATMetric objects supported by this adaptor. I.e. the adaptor is * capable to fire GATMetricEvents for the returned metrics. This list should * include all the supported metrics, event like and continuous ones. * * @param data Adaptor-provided data object. * @param instance_data Instance data for the CPI provider object. * @param metrics The pointer to the variable, which receives the returned * list of metrics. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetrics(void *data, GATAdvertServiceCPI_Instance const *instance_data, GATList_GATMetric *metrics) { // return GATMetric_CreateListOfMetrics(metric_data, __countof(metric_data), // metrics); return GAT_NOTIMPL; } /** advertservice_adaptor_GATAdvertServiceCPI_GetMetricEvent * * The function advertservice_adaptor_GATAdvertServiceCPI_GetMetricEvent should * return the GATMetricEvent associated with the given continuous metric. This * function gets called for continuous metrics only, since returning the * metric event object to the caller is th only way for the client to get * access to it. * * @param data Adaptor-provided data object. * @param instance_data Instance data for the CPI provider object. * @param metric The metric instance describing the metric event to return. * This metric should be equivalent to one of the metrics returned by * our own GetMetrics CPI function (see above). If this is another * (not known to us metric), an error should be returned. * @param event The pointer to the variable, which receives the metric event * to return. * * @return An error code. */ static GATResult advertservice_adaptor_GATAdvertServiceCPI_GetMetricEvent(void *data, GATAdvertServiceCPI_Instance const *instance_data, GATMetric metric, GATMetricEvent *event) { /* this adaptor supports no continuous metrics */ GATResult retval = GAT_SUCCESS; return retval; } /* instance data */ /** GATAdvertServiceCPIInstance_Data_Create * * The function GATAdvertServiceCPIInstance_Data_Create creates a new * instance of the internal CPI instance data. * * @return The pointer to the newly created and initialised data structure. */ static GATAdvertServiceCPIInstance_Data * GATAdvertServiceCPIInstance_Data_Create(void) { GATAdvertServiceCPIInstance_Data *retval = (GATAdvertServiceCPIInstance_Data *)malloc( sizeof(struct GATAdvertServiceCPIInstance_Data)); if (NULL != retval) { memset(retval, 0, sizeof(struct GATAdvertServiceCPIInstance_Data)); } return retval; } /** GATAdvertServiceCPIInstance_Data_Destroy * * The function GATAdvertServiceCPIInstance_Data_Destroy is called to * free all the memory associated with the given instance data item. * * @param instance_data The pointer to a variable holding the old instance * data item, this is set to zero on exit. */ static void GATAdvertServiceCPIInstance_Data_Destroy( GATAdvertServiceCPIInstance_Data **instance_data) { if (NULL != instance_data && NULL != *instance_data) { free(*instance_data); instance_data = NULL; } } /** GATAdvertServiceCPIInstance_Data_Clone * * The function GATAdvertServiceCPIInstance_Data_Clone is called to make * a copy of the given instance data item. * * @param instance_data The instance data item to copy. * @param new_instance_Data The pointer to a variable, which receives the * newly created copy of the instance data item. * * @return An error code. */ static GATResult GATAdvertServiceCPIInstance_Data_Clone( GATAdvertServiceCPIInstance_Data const *instance_data, GATAdvertServiceCPIInstance_Data **new_instance_data) { GATResult retval = GAT_INVALID_PARAMETER; if (NULL != new_instance_data) { GATAdvertServiceCPIInstance_Data *new_data = (GATAdvertServiceCPIInstance_Data *)malloc(sizeof(struct GATAdvertServiceCPIInstance_Data)); if (NULL != new_data) { *new_instance_data = new_data; retval = GAT_SUCCESS; } else { retval = GAT_MEMORYFAILURE; } } return retval; } /** GATAdvertServiceCPIInstance_Data_Equals * * The function GATAdvertServiceCPIInstance_Data_Equals is called, * whenever the engine needs to compare for equality two different instance * data items. * * @param lhs The first instance data item to compare. * @param rhs The second instance data item to compare. * @param isequal The pointer to a variable, which receives the result of the * compare operation. * * @result An error code. */ static GATResult GATAdvertServiceCPIInstance_Data_Equals( GATAdvertServiceCPIInstance_Data const *lhs, GATAdvertServiceCPIInstance_Data const *rhs, GATBool *isequal) { *isequal = GATTrue; return GAT_SUCCESS; } /* Error message handler functions */ /** advertservice_adapter_resolve_path * */ static GATResult advertservice_adapter_resolve_path( GATAdvertServiceCPI_Instance const *instance_data, GATString_const path, char **absolute_path) { char *new_path = NULL; char const *pwd = GATString_GetBuffer(instance_data->pwd); char const *pathstr = GATString_GetBuffer(path); if (NULL != pwd && NULL != pathstr) { int len = strlen(pwd); if (0 == len) { return GAT_INVALID_PARAMETER; } if ('/' != pathstr[0]) { /* the given path is relative */ GATResult retval = GATUtil_appendstring(&new_path, pwd); if (GAT_FAILED(retval)) { return retval; } if ('/' != new_path[len-1]) { /* make sure the pwd ends with an '/' */ retval = GATUtil_appendstring(&new_path, "/"); if (GAT_FAILED(retval)) { return retval; } } /* append the relative part of the path */ retval = GATUtil_appendstring(&new_path, pathstr); if (GAT_FAILED(retval)) { return retval; } } else { new_path = GATUtil_strdup(pathstr); if (NULL == new_path) { return GAT_MEMORYFAILURE; } } /* return the complete path */ if (NULL != absolute_path) { *absolute_path = new_path; } else { free(new_path); return GAT_INVALID_PARAMETER; } } else { return GAT_INVALID_PARAMETER; } return GAT_SUCCESS; }