Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
We use the buffer transport when creating new sockets, even if that induce gross...
authormquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Sun, 8 Aug 2004 04:34:07 +0000 (04:34 +0000)
committermquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Sun, 8 Aug 2004 04:34:07 +0000 (04:34 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@364 48e7efb5-ca39-0410-a469-dd3cf9ba447f

src/gras/Transport/sg_transport.c

index 2b23182..5dbe4ec 100644 (file)
@@ -68,7 +68,7 @@ gras_trp_select(double timeout,
       /* Socket to expeditor not created yet */
       DEBUG0("Create a socket to the expeditor");
 
       /* Socket to expeditor not created yet */
       DEBUG0("Create a socket to the expeditor");
 
-      TRY(gras_trp_plugin_get_by_name("sg",&trp));
+      TRY(gras_trp_plugin_get_by_name("buf",&trp));
 
       TRY(gras_trp_socket_new(1,dst));
       (*dst)->plugin   = trp;
 
       TRY(gras_trp_socket_new(1,dst));
       (*dst)->plugin   = trp;
@@ -87,6 +87,7 @@ gras_trp_select(double timeout,
       sockdata->to_PID   = r_pid;
       sockdata->to_host  = MSG_process_get_host(MSG_process_from_PID(r_pid));
       (*dst)->data = sockdata;
       sockdata->to_PID   = r_pid;
       sockdata->to_host  = MSG_process_get_host(MSG_process_from_PID(r_pid));
       (*dst)->data = sockdata;
+      gras_trp_buf_init_sock(*dst);
 
       (*dst)->peer_name = strdup(MSG_host_get_name(sockdata->to_host));
 
 
       (*dst)->peer_name = strdup(MSG_host_get_name(sockdata->to_host));