X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/94231df1406b77ceef622699e8f7721fd90307be..a0b8a3ea288a97ee138b90d79fcd53167ba076b2:/src/gras/Transport/transport_interface.h diff --git a/src/gras/Transport/transport_interface.h b/src/gras/Transport/transport_interface.h index 4540a5e702..3265203840 100644 --- a/src/gras/Transport/transport_interface.h +++ b/src/gras/Transport/transport_interface.h @@ -22,6 +22,7 @@ gras_error_t gras_trp_chunk_send(gras_socket_t *sd, gras_error_t gras_trp_chunk_recv(gras_socket_t *sd, char *data, long int size); +gras_error_t gras_trp_flush(gras_socket_t *sd); /* Find which socket needs to be read next */ gras_error_t @@ -29,12 +30,6 @@ gras_trp_select(double timeout, gras_socket_t **dst); -/*** - *** Module declaration - ***/ -gras_error_t gras_trp_init(void); -void gras_trp_exit(void); - /*** *** Plugin mecanism ***/ @@ -65,13 +60,16 @@ struct gras_trp_plugin_ { void (*socket_close)(gras_socket_t *sd); gras_error_t (*chunk_send)(gras_socket_t *sd, - char *data, + const char *data, long int size); gras_error_t (*chunk_recv)(gras_socket_t *sd, char *Data, long int size); - void *data; + /* flush has to make sure that the pending communications are achieved */ + gras_error_t (*flush)(gras_socket_t *sd); + + void *data; /* plugin-specific data */ /* exit is responsible for freeing data and telling the OS this plugin goes */ /* if it's NULL, data gets freed. (ie exit needed only when data contains pointers) */