Commits

Rune Bromer  committed c1996e5

stuff

  • Participants
  • Parent commits 1ffae15

Comments (0)

Files changed (1)

File pupympi/mpi/__init__.py

                     (rank, msg_type, tag, ack, comm_id, coll_class_id, raw_data) = item
                     match = False
                     for request in self.pending_collective_requests:
-                    if request.communicator.id == comm_id and request.tag == tag:
-                        if request._coll_class_id == coll_class_id:
-                            match = request.accept_msg(rank, raw_data, msg_type)
-                        else:
-                            if not request.is_dirty():
-                                cls = request.communicator.collective_controller.class_ids[coll_class_id]
-                                request.overtake(cls)
+                        if request.communicator.id == comm_id and request.tag == tag:
+                            if request._coll_class_id == coll_class_id:
                                 match = request.accept_msg(rank, raw_data, msg_type)
+                            else:
+                                if not request.is_dirty():
+                                    cls = request.communicator.collective_controller.class_ids[coll_class_id]
+                                    request.overtake(cls)
+                                    match = request.accept_msg(rank, raw_data, msg_type)
 
-                        if match:
-                            request.mark_dirty() # from now on the request cannot change algo
-                            # is the request all done?
-                            if request.test():
-                                prune = True
-                            break
+                            if match:
+                                request.mark_dirty() # from now on the request cannot change algo
+                                # is the request all done?
+                                if request.test():
+                                    prune = True
+                                break
                 if not match:
                     unmatched_data_list.append( item )