[py-svn] r31482 - py/branch/distributed/py/test/rsession

[hpk at codespeak.net]

Author: hpk
Date: Tue Aug 22 16:45:28 2006
New Revision: 31482

Added:
   py/branch/distributed/py/test/rsession/slave_main.py   (contents, props changed)
Log:
(fijal, hpk) draft slave_main loop


Added: py/branch/distributed/py/test/rsession/slave_main.py
==============================================================================
--- (empty file)
+++ py/branch/distributed/py/test/rsession/slave_main.py	Tue Aug 22 16:45:28 2006
@@ -0,0 +1,16 @@
+
+# master side: 
+# gw = SshGateway(sshhost)
+# rsync -az --delete --exclude=.svn %(source)s %(sshhost)s:%(path)s
+# c = gw.remote_exec(slave_main) 
+# c.send(path)
+#
+def slave_main(receive, send): 
+    path = receive()
+    node = SlaveNode(path) 
+    while 1:
+        nextitem = receive()
+        if nextitem is None:
+            break
+        res = node.run(nextitem) 
+        send(res)