X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ce41071a83edfed39b226ef047905f25ddf7c2bf..7d0c4c0adbba2982f29444f00d1e70ad6b6aacdf:/src/gras/Virtu/process.c diff --git a/src/gras/Virtu/process.c b/src/gras/Virtu/process.c index 938aea93d6..a978ba3e31 100644 --- a/src/gras/Virtu/process.c +++ b/src/gras/Virtu/process.c @@ -2,15 +2,60 @@ /* process - GRAS process handling (common code for RL and SG) */ -/* Authors: Martin Quinson */ -/* Copyright (C) 2003,2004 da GRAS posse. */ +/* Copyright (c) 2003, 2004 Martin Quinson. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it - under the terms of the license (GNU LGPL) which comes with this package. */ + * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "gras_private.h" -#include "Virtu/virtu_interface.h" +#include "xbt/ex.h" +#include "xbt/sysdep.h" +#include "xbt/log.h" +#include "gras/transport.h" +#include "gras/datadesc.h" +#include "gras/messages.h" +#include "gras_modinter.h" +#include "gras/Virtu/virtu_private.h" + +XBT_LOG_NEW_SUBCATEGORY(gras_virtu,gras,"Virtualization code"); +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_virtu_process,gras_virtu,"Process manipulation code"); + +/* Functions to handle gras_procdata_t->libdata cells*/ +typedef struct { + char *name; + pvoid_f_void_t constructor; + void_f_pvoid_t destructor; +} s_gras_procdata_fabric_t, *gras_procdata_fabric_t; + +static xbt_dynar_t _gras_procdata_fabrics = NULL; /* content: s_gras_procdata_fabric_t */ + +static void gras_procdata_fabric_free(void *fab) { + free( ((gras_procdata_fabric_t)fab)->name ); +} + +/** @brief declare the functions in charge of creating/destructing the procdata of a module + * + * This is intended to be called from the gras__register function. + * This returns the module ID you can use for gras_libdata_by_id() + */ +int gras_procdata_add(const char *name, pvoid_f_void_t constructor,void_f_pvoid_t destructor) { + + gras_procdata_fabric_t fab; + + if (!_gras_procdata_fabrics) { + /* create the dynar if needed */ + _gras_procdata_fabrics = xbt_dynar_new(sizeof(s_gras_procdata_fabric_t), + gras_procdata_fabric_free); + } + + fab=xbt_dynar_push_ptr(_gras_procdata_fabrics); + + fab->name = xbt_strdup(name); + fab->constructor = constructor; + fab->destructor = destructor; + + return xbt_dynar_length(_gras_procdata_fabrics)-1; +} /* ************************************************************************** * Process data @@ -26,27 +71,108 @@ void gras_userdata_set(void *ud) { pd->userdata = ud; } -gras_error_t +void *gras_libdata_by_name(const char *name) { + gras_procdata_t *pd=gras_procdata_get(); + return gras_libdata_by_name_from_procdata(name,pd); +} + +/* this function is splitted from previous to allow SG to get libdata from remote hosts */ +void *gras_libdata_by_name_from_procdata(const char*name, gras_procdata_t* pd) { + void *res=NULL; + xbt_ex_t e; + if (xbt_set_length(pd->libdata) < xbt_dynar_length(_gras_procdata_fabrics)) { + /* Damn, some new modules were added since procdata_init(). Amok? */ + /* Get 'em all */ + gras_procdata_init(); + } + TRY { + res = xbt_set_get_by_name(pd->libdata, name); + } CATCH(e) { + RETHROW1("Cannot retrieve the libdata associated to %s: %s",name); + } + return res; +} + +void *gras_libdata_by_id(int id) { + gras_procdata_t *pd=gras_procdata_get(); + if (xbt_set_length(pd->libdata) < xbt_dynar_length(_gras_procdata_fabrics)) { + /* Damn, some new modules were added since procdata_init(). Amok? */ + /* Get 'em all */ + gras_procdata_init(); + } + return xbt_set_get_by_id(pd->libdata, id); +} + + +void gras_procdata_init() { - gras_error_t errcode; gras_procdata_t *pd=gras_procdata_get(); - pd->userdata = NULL; - TRY(gras_dynar_new(&(pd->msg_queue), sizeof(gras_msg_t), NULL)); - TRY(gras_dynar_new(&(pd->cbl_list), sizeof(gras_cblist_t *),gras_cbl_free)); - TRY(gras_dynar_new(&(pd->sockets), sizeof(gras_socket_t*), NULL)); - return no_error; + s_gras_procdata_fabric_t fab; + + int cursor; + + xbt_ex_t e; + xbt_set_elm_t elem; + + if (!pd->libdata) { + pd->userdata = NULL; + pd->libdata = xbt_set_new(); + } + + xbt_dynar_foreach(_gras_procdata_fabrics,cursor,fab){ + volatile int found = 0; + + if (cursor+1 <= (int)xbt_set_length(pd->libdata)) { + DEBUG2("Skip fabric %d: there is already %ld libdata", + cursor, xbt_set_length(pd->libdata)); + continue; /* allow to recall this function to get recently added fabrics */ + } + DEBUG2("Go ahead for cursor %d, there is %ld libdata", + cursor,xbt_set_length(pd->libdata)); + + xbt_assert1(fab.name,"Name of fabric #%d is NULL!",cursor); + DEBUG1("Create the procdata for %s",fab.name); + /* Check for our own errors */ + TRY { + xbt_set_get_by_name(pd->libdata, fab.name); + found = 1; + } CATCH(e) { + xbt_ex_free(e); + found = 0; + } + if (found) + THROW1(unknown_error,0,"MayDay: two modules use '%s' as libdata name", fab.name); + + /* Add the data in place, after some more sanity checking */ + elem = (*(fab.constructor))(); + if (elem->name_len && elem->name_len != strlen(elem->name)) { + elem->name_len = strlen(elem->name); + WARN1("Module '%s' constructor is borken: it does not set elem->name_len", + fab.name); + } + xbt_set_add(pd->libdata, elem, fab.destructor); + } } void gras_procdata_exit() { + int len; gras_procdata_t *pd=gras_procdata_get(); - gras_dynar_free(pd->msg_queue); - gras_dynar_free(pd->cbl_list); - gras_dynar_free(pd->sockets); + xbt_set_free(&( pd->libdata )); + + /* Remove procdata in reverse order wrt creation */ + while ((len=xbt_dynar_length(_gras_procdata_fabrics))) { + xbt_dynar_remove_at(_gras_procdata_fabrics,len-1,NULL); + } + xbt_dynar_free( & _gras_procdata_fabrics ); } -gras_dynar_t * -gras_socketset_get(void) { - return gras_procdata_get()->sockets; + +const char *gras_os_hostport() { + static char *res=NULL; + if (res) + free(res); /* my port may have changed */ + res = bprintf("%s:%d",gras_os_myname(),gras_os_myport()); + return (const char*)res; }