Changes between Version 18 and Version 19 of MessagePassing

Timestamp:

09/13/13 09:37:29 (13 years ago)

Author:

siegel

Comment:

--

MessagePassing

@@ -99 +99 @@
 void MPI_Recv(int pid, void *buf, int count, MPI_Datataype type, int source, int tag, MPI_Comm comm, MPI_Status *status) {
   int size = sizeofDatatype(type)*count;
-  // the following is a system function with built-in guard:
-  $message m = $comm_dequeue(*comm, source, pid, tag);
 
-  status->size = $message_size(m);
-  status->source = $message_source(m);
-  status->dest = $message_dest(m);
-  $message_unpack(m, buf, size); // will throw exception if message too big
+  when ($comm_probe(*comm, source, pid, tag)) {
+    int index = $comm_seek(*comm, source, pid, tag);
+    $message m = $comm_get(*comm, source, pid, index);
+
+    *comm = $comm_dequeue(*comm, source, pid, index);
+    status->size = $message_size(m);
+    status->source = $message_source(m);
+    status->dest = $message_dest(m);
+    $message_unpack(m, buf, size); // will throw exception if message too big
+  }
 }