From a0b8a3ea288a97ee138b90d79fcd53167ba076b2 Mon Sep 17 00:00:00 2001 From: mquinson Date: Sun, 8 Aug 2004 04:37:34 +0000 Subject: [PATCH 1/1] add a flush function; move module init/exit declarations to gras_private; cosmetic on API git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@368 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- src/gras/Transport/transport_interface.h | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) 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) */ -- 2.20.1