r21098 - in /branches/relax_disp: ./ multi/processor.py -- October 14, 2013 - 20:09

Author: bugman
Date: Mon Oct 14 20:09:15 2013
New Revision: 21098

URL: http://svn.gna.org/viewcvs/relax?rev=21098&view=rev
Log:
Merged revisions 21097 via svnmerge from 
svn+ssh://bugman@xxxxxxxxxxx/svn/relax/trunk

........
  r21097 | bugman | 2013-10-14 20:06:24 +0200 (Mon, 14 Oct 2013) | 6 lines
  
  Addded a new is_queued() method to the Processor object of the multi 
package.
  
  This allows the Processor object for the uni and mpi4py multi-processor to 
be queried to see if any
  slave commands have been queued.
........

Modified:
    branches/relax_disp/   (props changed)
    branches/relax_disp/multi/processor.py

Propchange: branches/relax_disp/
------------------------------------------------------------------------------
--- svnmerge-integrated (original)
+++ svnmerge-integrated Mon Oct 14 20:09:15 2013
@@ -1,1 +1,1 @@
-/trunk:1-21089
+/trunk:1-21097

Modified: branches/relax_disp/multi/processor.py
URL: 
http://svn.gna.org/viewcvs/relax/branches/relax_disp/multi/processor.py?rev=21098&r1=21097&r2=21098&view=diff
==============================================================================
--- branches/relax_disp/multi/processor.py (original)
+++ branches/relax_disp/multi/processor.py Mon Oct 14 20:09:15 2013
@@ -344,6 +344,21 @@
         return time_delta_str
 
 
+    def is_queued(self):
+        """Determine if any slave commands are queued.
+
+        @return:    True if slave commands are in the queue, False otherwise.
+        @rtype:     bool
+        """
+
+        # The standard command queue.
+        if len(self.command_queue):
+            return True
+
+        # Nothing.
+        return False
+
+
     def master_queue_command(self, command, dest):
         """Slave to master processor data transfer - send the result command 
from the slave.