r10192 - /branches/multi_processor_merge/multi/multi_processor_base.py -- January 13, 2010 - 11:36

Author: bugman
Date: Wed Jan 13 11:36:48 2010
New Revision: 10192

URL: http://svn.gna.org/viewcvs/relax?rev=10192&view=rev
Log:
Cleaned up the run_command_queue() method idle and running set print outs.

The code has also been commented.


Modified:
    branches/multi_processor_merge/multi/multi_processor_base.py

Modified: branches/multi_processor_merge/multi/multi_processor_base.py
URL: 
http://svn.gna.org/viewcvs/relax/branches/multi_processor_merge/multi/multi_processor_base.py?rev=10192&r1=10191&r2=10192&view=diff
==============================================================================
--- branches/multi_processor_merge/multi/multi_processor_base.py (original)
+++ branches/multi_processor_merge/multi/multi_processor_base.py Wed Jan 13 
11:36:48 2010
@@ -303,16 +303,23 @@
                     else:
                         break
 
+                # Loop until the queue of calculations is depleted.
                 while len(running_set) != 0:
+                    # Get the result.
                     result = self.master_recieve_result()
-                    #if isinstance(result, Result_exception):
-                    #    print 'result', result
-                    #    sys.exit()
-
+
+                    # Print out.
+                    print('\nIdle set:    %s' % idle_set)
+                    print('Running set: %s' % running_set)
+
+                    # Completed.
                     if result.completed:
+                        # First flush the buffers.
+                        sys.stdout.flush()
+                        sys.stderr.flush()
+
+                        # Shift the processor rank to the idle set.
                         idle_set.add(result.rank)
-                        print('idle set', repr(idle_set))
-                        print('running_set', repr(running_set))
                         running_set.remove(result.rank)
 
                     result_queue.put(result)