Changeset 3628

Timestamp:

Sep 20, 2006, 11:03:02 AM (18 years ago)

Author:

ole

Message:

Work on parallel abstraction allowing sequential execution

Location:

anuga_core/source/anuga_parallel

Files:

• parallel_abstraction.py (added)
• parallel_api.py (modified) (4 diffs)

anuga_core/source/anuga_parallel/parallel_api.py

@@ -5 +5 @@
 
 # Parallelism
-import pypar   # The Python-MPI interface
+# The Python-MPI interface
+from pypar import size, rank, get_processor_name, finalize, send, receive
+from anuga_parallel.parallel_abstraction import size, rank, get_processor_name, finalize #,send, receive
 from anuga_parallel.pmesh_divide  import pmesh_divide_metis
 from anuga_parallel.build_submesh import build_submesh
@@ -17 +19 @@
 #------------------------------------------------------------------------------
 
-numprocs = pypar.size()
-myid = pypar.rank()
-processor_name = pypar.Get_processor_name()
+numprocs = size()
+myid = rank()
+processor_name = get_processor_name()
 print 'I am processor %d of %d on node %s' %(myid, numprocs, processor_name)
 
@@ -37 +39 @@
 
         for p in range(1, numprocs):
-            pypar.send((domain_name, domain_dir), p)
+            send((domain_name, domain_dir), p)
     else:
         if verbose: print 'P%d: Receiving domain attributes' %(myid)
 
-        domain_name, domain_dir = pypar.receive(0)
+        domain_name, domain_dir = receive(0)
 
 
@@ -51 +53 @@
         boundary_map = domain.boundary_map
         for p in range(1, numprocs):
-            pypar.send(boundary_map, p)
+            send(boundary_map, p)
     else:
         if verbose: print 'P%d: Receiving boundary map' %(myid)        
 
-        boundary_map = pypar.receive(0)
+        boundary_map = receive(0)