Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
SG don't get buffered by default (since only measurement sockets use it now)
[simgrid.git] / src / gras / Transport / transport.c
index 444f8c4..d88a401 100644 (file)
@@ -195,8 +195,7 @@ gras_socket_server_ext(unsigned short port,
   DEBUG2("Create a server socket from plugin %s on port %d",
         gras_if_RL() ? "tcp" : "sg",
         port);
-  trp = gras_trp_plugin_get_by_name((measurement? (gras_if_RL() ? "tcp" : "sg")
-                                               :"buf"));
+  trp = gras_trp_plugin_get_by_name(gras_if_SG() ? "sg":(measurement?"tcp":"buf"));
 
   /* defaults settings */
   gras_trp_socket_new(1,&sock);
@@ -238,8 +237,7 @@ gras_socket_client_ext(const char *host,
   gras_trp_plugin_t trp;
   gras_socket_t sock;
 
-  trp = gras_trp_plugin_get_by_name((measurement? (gras_if_RL() ? "tcp" : "sg")
-                                               : "buf"));
+  trp = gras_trp_plugin_get_by_name(gras_if_SG() ? "sg":(measurement?"tcp":"buf"));
 
   DEBUG1("Create a client socket from plugin %s",gras_if_RL() ? "tcp" : "sg");
   /* defaults settings */
@@ -347,7 +345,7 @@ gras_trp_chunk_recv(gras_socket_t sd,
   xbt_assert1(sd->plugin->chunk_recv,
               "No function chunk_recv on transport plugin %s",
               sd->plugin->name);
-  (sd->plugin->chunk_recv)(sd,data,size);
+  (sd->plugin->chunk_recv)(sd,data,size,size);
 }
 
 /**