X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b48a2fd4e7621cbc0f96e39bf7db3a0263232908..87468a9f6b682ee41edc3a16a100554ef48032c9:/src/gras/Transport/transport_interface.h

diff --git a/src/gras/Transport/transport_interface.h b/src/gras/Transport/transport_interface.h
index 249db65393..5766ffda9f 100644
--- a/src/gras/Transport/transport_interface.h
+++ b/src/gras/Transport/transport_interface.h
@@ -15,12 +15,9 @@
 /***
  *** Main user functions
  ***/
-void gras_trp_chunk_send(gras_socket_t sd,
-			 char *data,
-			 long int size);
-void gras_trp_chunk_recv(gras_socket_t sd,
-			 char *data,
-			 long int size);
+/* stable if we know the storage will keep as is until the next trp_flush */
+void gras_trp_send(gras_socket_t sd, char *data, long int size, int stable);
+void gras_trp_recv(gras_socket_t sd, char *data, long int size);
 void gras_trp_flush(gras_socket_t sd);
 
 /* Find which socket needs to be read next */
@@ -53,13 +50,21 @@ struct gras_trp_plugin_ {
     but should not free the socket itself (beside the specific part) */
   void (*socket_close)(gras_socket_t sd);
     
-  void (*chunk_send)(gras_socket_t sd,
-		     const char *data,
-		     unsigned long int size);
-  void (*chunk_recv)(gras_socket_t sd,
-		     char *data,
-		     unsigned long int size,
-		     unsigned long int bufsize);
+  /* send/recv may be buffered */
+  void (*send)(gras_socket_t sd,
+	       const char *data,
+	       unsigned long int size,
+	       int stable /* storage will survive until flush*/);
+  int (*recv)(gras_socket_t sd,
+	      char *data,
+	      unsigned long int size);
+  /* raw_send/raw_recv is never buffered (use it for measurement stuff) */
+  void (*raw_send)(gras_socket_t sd,
+		   const char *data,
+		   unsigned long int size);
+  int (*raw_recv)(gras_socket_t sd,
+		  char *data,
+		  unsigned long int size);
 
   /* flush has to make sure that the pending communications are achieved */
   void (*flush)(gras_socket_t sd);