X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dff9e15c44ab6340d27215957c56fa72fad246a2..9b1376be778d6666bee2de4b185c1769a09d2cbb:/src/gras/Transport/sg_transport.c diff --git a/src/gras/Transport/sg_transport.c b/src/gras/Transport/sg_transport.c index 1084617576..9056dd1bcd 100644 --- a/src/gras/Transport/sg_transport.c +++ b/src/gras/Transport/sg_transport.c @@ -1,8 +1,7 @@ -/* $Id$ */ - /* sg_transport - SG specific functions for transport */ -/* Copyright (c) 2004 Martin Quinson. All rights reserved. */ +/* 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. */ @@ -13,9 +12,11 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(gras_trp); -/* check transport_private.h for an explanation of this variable; this just need to be defined to NULL in SG */ +/* check transport_private.h for an explanation of this variable; + * this just need to be defined to NULL in SG */ gras_socket_t _gras_lastly_selected_socket = NULL; +#ifdef KILLME /** * gras_trp_select: * @@ -31,7 +32,7 @@ gras_socket_t gras_trp_select(double timeout) { gras_socket_t res; gras_trp_procdata_t pd = - (gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id); + (gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id); gras_trp_sg_sock_data_t *sockdata; gras_trp_plugin_t trp; gras_socket_t active_socket = NULL; @@ -40,8 +41,8 @@ gras_socket_t gras_trp_select(double timeout) unsigned int cursor; DEBUG3("select on %s@%s with timeout=%f", - SIMIX_process_get_name(SIMIX_process_self()), - SIMIX_host_get_name(SIMIX_host_self()), timeout); + SIMIX_process_self_get_name(), + SIMIX_host_self_get_name(), timeout); if (timeout >= 0) { xbt_queue_shift_timed(pd->msg_selectable_sockets, &active_socket, timeout); @@ -69,7 +70,7 @@ gras_socket_t gras_trp_select(double timeout) if ((sock_data->to_socket == active_socket) && (sock_data->to_host == - SIMIX_process_get_host(active_socket_data->from_process))) { + SIMIX_req_process_get_host(active_socket_data->from_process))) { xbt_dynar_cursor_unlock(pd->sockets); return sock_iter; } @@ -101,30 +102,30 @@ gras_socket_t gras_trp_select(double timeout) res->peer_port = ((gras_trp_procdata_t) gras_libdata_by_name_from_remote("gras_trp", - sockdata-> - to_process))->myport; + sockdata->to_process))-> + myport; sockdata->to_socket = active_socket; /*update the peer to_socket variable */ active_socket_data->to_socket = res; - sockdata->cond = SIMIX_cond_init(); - sockdata->mutex = SIMIX_mutex_init(); + sockdata->cond = SIMIX_req_cond_init(); + sockdata->mutex = SIMIX_req_mutex_init(); sockdata->to_host = - SIMIX_process_get_host(active_socket_data->from_process); + SIMIX_req_process_get_host(active_socket_data->from_process); res->data = sockdata; - res->peer_name = strdup(SIMIX_host_get_name(sockdata->to_host)); + res->peer_name = strdup(SIMIX_req_host_get_name(sockdata->to_host)); gras_trp_buf_init_sock(res); DEBUG4("Create socket to process:%s(Port %d) from process: %s(Port %d)", - SIMIX_process_get_name(sockdata->from_process), + SIMIX_req_process_get_name(sockdata->from_process), res->peer_port, - SIMIX_process_get_name(sockdata->to_process), res->port); + SIMIX_req_process_get_name(sockdata->to_process), res->port); return res; } - +#endif /* dummy implementations of the functions used in RL mode */