X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/421e2f7dd584b6aa936de631a730fb3b21ca7565..1a2592601e29b027872580cbfc364194f8b01ba6:/src/gras/Virtu/virtu_sg.h diff --git a/src/gras/Virtu/virtu_sg.h b/src/gras/Virtu/virtu_sg.h index 2090257e6f..0180b9abbe 100644 --- a/src/gras/Virtu/virtu_sg.h +++ b/src/gras/Virtu/virtu_sg.h @@ -1,44 +1,54 @@ -/* $Id$ */ - /* virtu_sg - specific GRAS implementation for simulator */ -/* Authors: Martin Quinson */ -/* Copyright (C) 2003,2004 da GRAS posse. */ +/* Copyright (c) 2004, 2005, 2006, 2007, 2009, 2010. The SimGrid Team. + * 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. */ #ifndef VIRTU_SG_H #define VIRTU_SG_H -#include "gras/Virtu/virtu_interface.h" -#include /* SimGrid header */ - -#define GRAS_MAX_CHANNEL 10 +#include "gras/Virtu/virtu_private.h" +#include "xbt/dynar.h" +#include "simix/simix.h" /* SimGrid header */ +#include "gras/Transport/transport_private.h" typedef struct { - int port; /* list of ports used by a server socket */ - int tochan; /* the channel it points to */ - int raw; /* (boolean) the channel is in raw mode or for messages */ -} gras_sg_portrec_t; + int port; /* list of ports used by a server socket */ + int meas:1; /* (boolean) the channel is for measurements or for messages */ + smx_process_t server; + smx_rdv_t rdv; +} s_gras_sg_portrec_t, *gras_sg_portrec_t; /* Data for each host */ typedef struct { - int proc[GRAS_MAX_CHANNEL]; /* PID of who's connected to each channel */ - /* If =0, then free */ + int refcount; - gras_dynar_t ports; + xbt_dynar_t ports; } gras_hostdata_t; /* data for each socket (FIXME: find a better location for that)*/ typedef struct { - int from_PID; /* process which sent this message */ - int to_PID; /* process to which this message is destinated */ + smx_process_t server; + smx_process_t client; + + smx_rdv_t rdv_server; /* The rendez-vous point to use */ + smx_rdv_t rdv_client; /* The rendez-vous point to use */ + smx_comm_t comm_recv; /* The comm of irecv on receiver side */ + + int server_port; + int client_port; +} s_gras_trp_sg_sock_data_t, *gras_trp_sg_sock_data_t; - m_host_t to_host; /* Who's on other side */ - m_channel_t to_chan;/* Channel on which the other side is earing */ -} gras_trp_sg_sock_data_t; +void *gras_libdata_by_name_from_remote(const char *name, smx_process_t p); +/* The same function by id would be really dangerous. + * + * Indeed, it would rely on the fact that all process register libdatas in + * the same order, which is wrong if they init amok modules in different + * order. + */ -#endif /* VIRTU_SG_H */ +#endif /* VIRTU_SG_H */