Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Now, you can send a task of length 0 in a no latency model... Otherwise the emitter...
authoralegrand <alegrand@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Wed, 19 Jan 2005 18:16:43 +0000 (18:16 +0000)
committeralegrand <alegrand@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Wed, 19 Jan 2005 18:16:43 +0000 (18:16 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@763 48e7efb5-ca39-0410-a469-dd3cf9ba447f

src/msg/gos.c

index 77fa324..feb7153 100644 (file)
@@ -192,18 +192,19 @@ MSG_error_t MSG_task_put(m_task_t task,
   if(remote_host->simdata->sleeping[channel]) 
     __MSG_process_unblock(remote_host->simdata->sleeping[channel]);
 /*   else { */
-    process->simdata->put_host = dest;
-    process->simdata->put_channel = channel;
-    while(!(task_simdata->comm)) 
-      __MSG_process_block();
-    process->simdata->put_host = NULL;
-    process->simdata->put_channel = -1;
+  process->simdata->put_host = dest;
+  process->simdata->put_channel = channel;
+  while(!(task_simdata->comm)) 
+    __MSG_process_block();
+  process->simdata->put_host = NULL;
+  process->simdata->put_channel = -1;
 /*   } */
 
-  do {
+  state=surf_workstation_resource->common_public->action_get_state(task_simdata->comm);
+  while (state==SURF_ACTION_RUNNING) {
     __MSG_task_wait_event(process, task);
     state=surf_workstation_resource->common_public->action_get_state(task_simdata->comm);
-  } while (state==SURF_ACTION_RUNNING);
+  }
     
   MSG_task_destroy(task);