X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/74a055ca8f5532759cfb537ade1983d9b4c344d3..9b1376be778d6666bee2de4b185c1769a09d2cbb:/src/gras/Transport/sg_transport.c diff --git a/src/gras/Transport/sg_transport.c b/src/gras/Transport/sg_transport.c index 83586d21c1..9056dd1bcd 100644 --- a/src/gras/Transport/sg_transport.c +++ b/src/gras/Transport/sg_transport.c @@ -32,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; @@ -41,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); @@ -70,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; } @@ -103,25 +103,25 @@ 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; + 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; }