Changeset 107

Timestamp:

11/22/07 13:03:16 (1 year ago)

Author:

edsuom

Message:

Nodes can now be directed to allow certain classes (and their modules) regardless of existing PB security settings

Files:

• projects/AsynCluster/trunk/asyncluster/master/control.py (modified) (3 diffs)
• projects/AsynCluster/trunk/asyncluster/master/jobs.py (modified) (1 diff)

projects/AsynCluster/trunk/asyncluster/master/control.py

@@ -24 +24 @@
-
-from twisted.python.failure import Failure
+from twisted.python.reflect import namedObject
-from twisted.internet import defer, reactor, task
-from twisted.spread import pb
@@ -300 +301 @@
-        return d
-
+    def remote_allowClasses(self, *args):
+        """
+        Instructs my broker to allow the classes specified by the argument(s),
+        and instructs the jobber to have all current and future nodes do the
+        same with their brokers.
+        
+        The classes are specified by their string representations::
+        
+            <package(s).module.class>
+        
+        """
+        for stringRep in args:
+            # Load the class for the string representation
+            cls = namedObject(stringRep)
+            # Allow instances of the class, including its type and module
+            pb.globalSecurity.allowInstancesOf(cls)
+        return self.ctl.jobber.allowClasses(*args)
+
-    def remote_newJob(self, jobCode, niceness=0):
-        """
@@ -316 +335 @@
-        """
-        return self.ctl.jobber.update(jobID, callName, *args, **kw)
-
+
-    def remote_runJob(self, jobID, callName, *args, **kw):
-        """

projects/AsynCluster/trunk/asyncluster/master/jobs.py

@@ -120 +120 @@
-        raise Exception("No job registered!")
-
+    def allowClasses(self, *args):
+        """
+        Instructs the controller to allow the classes specified by the
+        argument(s) and arrange and update to have its nodes do the same.
+
+        The classes are specified by their string representations::
+        
+            <package(s).module.class>
+        
+        """
+        return self.root.callRemote('allowClasses', *args)
+
-    def run(self, cmd, *args, **kw):
-        """