X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b1acf7fe2f1886e9adcb4313f53548c9995a906c..f4f8bd3804ff1e7a3c5d7c179c6cc63ee14d3059:/src/gras/Transport/rl_transport.c diff --git a/src/gras/Transport/rl_transport.c b/src/gras/Transport/rl_transport.c index 279e4b3fdb..858ba73186 100644 --- a/src/gras/Transport/rl_transport.c +++ b/src/gras/Transport/rl_transport.c @@ -34,6 +34,7 @@ gras_trp_select(double timeout, gras_socket_t **dst) { gras_error_t errcode; + gras_dynar_t *sockets= gras_socketset_get(); int done = -1; double wakeup = gras_time() + 1000000*timeout; double now = 0; @@ -60,7 +61,7 @@ gras_trp_select(double timeout, /* construct the set of socket to ear from */ FD_ZERO(&FDS); - gras_dynar_foreach(_gras_trp_sockets,cursor,sock_iter) { + gras_dynar_foreach(sockets,cursor,sock_iter) { if (sock_iter->incoming) { if (max_fds < sock_iter->sd) max_fds = sock_iter->sd; @@ -115,7 +116,7 @@ gras_trp_select(double timeout, continue; /* this was a timeout */ } - gras_dynar_foreach(_gras_trp_sockets,cursor,sock_iter) { + gras_dynar_foreach(sockets,cursor,sock_iter) { if(!FD_ISSET(sock_iter->sd, &FDS)) { /* this socket is not ready */ continue; } @@ -129,7 +130,7 @@ gras_trp_select(double timeout, gras_socket_t *accepted; TRY(sock_iter->plugin->socket_accept(sock_iter,&accepted)); - TRY(gras_dynar_push(_gras_trp_sockets,&accepted)); + accepted->raw = sock_iter->raw; } else { #if 0 FIXME: this fails of files. quite logical @@ -168,3 +169,7 @@ gras_trp_select(double timeout, return timeout_error; } + +gras_error_t gras_trp_sg_setup(gras_trp_plugin_t *plug) { + return mismatch_error; +}