Changeset 126 for pypar/pypar.py

Timestamp:

Jul 11, 2005, 6:07:06 PM (19 years ago)

Author:

ole

Message:

Added bypass to reduce and broadcast

File:

• pypar/pypar.py (modified) (4 diffs)

pypar/pypar.py

@@ -47 +47 @@
 
 # Meta data
-__version__ = '1.9.1'
-__date__ = '15 December 2003'
+__version__ = '1.9.2'
+__date__ = '11 July 2005'
 __author__ = 'Ole M. Nielsen'
 
@@ -208 +208 @@
 
 
-def broadcast(buffer, root, vanilla=False):
+def broadcast(buffer, root, vanilla=False, bypass=False):
     """Wrapper for MPI bcast.
 
@@ -221 +221 @@
        Setting vanilla = 1 forces vanilla mode for any type.
 
-    """
+       If bypass is True, all admin and error checks
+       get bypassed to reduce the latency.
+
+    """
+
+    if bypass:
+        broadcast_array(buffer, root)
+        return
+    
 
     import types
@@ -350 +358 @@
 
 
-def reduce(x, op, root, buffer=None, vanilla=0):
+def reduce(x, op, root, buffer=None, vanilla=0, bypass=False):
     """Reduce elements in x to buffer (of the same size as x)
        at root applying operation op elementwise.
-    """
-
-    import types
-    
+
+       If bypass is True, all admin and error checks
+       get bypassed to reduce the latency.
+       The buffer must be specified explicitly in this case.
+    """
+
+
+
+    if bypass:
+        reduce_array(x, buffer, op, root)
+        return
+    
+
+    import types    
     from mpiext import size
     numproc = size()         #Needed to determine buffer size