mailr15589 - in /1.3/multi: __init__.py processor.py


Others Months | Index by Date | Thread Index
>>   [Date Prev] [Date Next] [Thread Prev] [Thread Next]

Header


Content

Posted by edward on March 21, 2012 - 11:52:
Author: bugman
Date: Wed Mar 21 11:52:11 2012
New Revision: 15589

URL: http://svn.gna.org/viewcvs/relax?rev=15589&view=rev
Log:
The multi.data_upload() API fn now forwards the call to the Processor classes.

This still needs an implementation for each processor fabric.


Modified:
    1.3/multi/__init__.py
    1.3/multi/processor.py

Modified: 1.3/multi/__init__.py
URL: 
http://svn.gna.org/viewcvs/relax/1.3/multi/__init__.py?rev=15589&r1=15588&r2=15589&view=diff
==============================================================================
--- 1.3/multi/__init__.py (original)
+++ 1.3/multi/__init__.py Wed Mar 21 11:52:11 2012
@@ -230,6 +230,9 @@
     # Load the Processor_box.
     processor_box = Processor_box()
 
+    # Forward the call to the processor instance.
+    processor_box.processor.data_upload(name=name, value=value, rank=rank)
+
 
 
 class Application_callback(object):

Modified: 1.3/multi/processor.py
URL: 
http://svn.gna.org/viewcvs/relax/1.3/multi/processor.py?rev=15589&r1=15588&r2=15589&view=diff
==============================================================================
--- 1.3/multi/processor.py (original)
+++ 1.3/multi/processor.py Wed Mar 21 11:52:11 2012
@@ -213,6 +213,23 @@
 #        raise_unimplemented(self.exit)
 
 
+    def data_upload(self, name=None, value=None, rank=None):
+        """API function for sending data to be stored on the Processor of 
the given rank.
+
+        This can be used for transferring data from Processor instance i to 
the data store of Processor instance j.
+
+
+        @keyword name:  The name of the data structure to store.
+        @type name:     str
+        @keyword value: The data structure.
+        @type value:    anything
+        @keyword rank:  An optional argument to send data only to the 
Processor of the given rank.  If None, then the data will be sent to all 
Processor instances.
+        @type rank:     None or int
+        """
+
+        raise_unimplemented(self.data_upload)
+
+
     def get_intro_string(self):
         """Get a string describing the multi processor - designed for 
overriding.
 




Related Messages


Powered by MHonArc, Updated Wed Mar 21 12:40:01 2012