[svn r38022] be a bit more verbose before rsync.

--HG--
branch : trunk

py/test/rsession/hostmanage.py

@@ -120,18 +120,17 @@ class HostManager(object):
             roots = [self.config.topdir]
         self.roots = roots
 
-    def prepare_gateways(self):
+    def prepare_gateways(self, reporter):
         dist_remotepython = self.config.getvalue("dist_remotepython")
         for host in self.hosts:
             host.initgateway(python=dist_remotepython)
+            reporter(repevent.HostGatewayReady(host, self.roots))
             host.gw.host = host
 
     def init_rsync(self, reporter):
         # send each rsync root
         ignores = self.config.getvalue_pathlist("dist_rsync_ignore")
-        self.prepare_gateways()
-        for host in self.hosts:
-            reporter(repevent.HostRSyncRoots(host, self.roots))
+        self.prepare_gateways(reporter)
         for root in self.roots:
             rsync = HostRSync(ignores=ignores)
             destrelpath = root.relto(self.config.topdir)

py/test/rsession/repevent.py

@@ -77,7 +77,7 @@ class HostRSyncing(ReportEvent):
     def __init__(self, host):
         self.host = host
 
-class HostRSyncRoots(ReportEvent):
+class HostGatewayReady(ReportEvent):
     def __init__(self, host, roots):
         self.host = host
         self.roots = roots

py/test/rsession/reporter.py

@@ -60,8 +60,10 @@ class AbstractReporter(object):
         print "%10s: RSYNC ==> %s" % (item.host.hostname[:10],
                                       item.host.relpath)
 
-    def report_HostRSyncRoots(self, item):
+    def report_HostGatewayReady(self, item):
         self.to_rsync[item.host] = len(item.roots)
+        self.out.write("%10s: gateway initialised (PYTHONPATH = %s)\n"\
+                       % (item.host.hostname, item.host.gw_remotepath))
 
     def report_HostRSyncRootReady(self, item):
         self.to_rsync[item.host] -= 1

py/test/rsession/rest.py

@@ -63,6 +63,9 @@ class RestReporter(AbstractReporter):
     def report_ImmediateFailure(self, item):
         pass
 
+    def report_HostGatewayReady(self, item):
+        self.to_rsync[item.host] = len(item.roots)
+
     def report_ItemStart(self, event):
         item = event.item
         if isinstance(item, py.test.collect.Module):

py/test/rsession/testing/test_reporter.py

@@ -162,7 +162,7 @@ class AbstractTestReporter(object):
         r = self.reporter(config, hosts)
         r.report(repevent.TestStarted(hosts, config.topdir, ["a", "b", "c"]))
         for host in hosts:
-            r.report(repevent.HostRSyncRoots(host, ["a", "b", "c"]))
+            r.report(repevent.HostGatewayReady(host, ["a", "b", "c"]))
         for host in hosts:
             for root in ["a", "b", "c"]:
                 r.report(repevent.HostRSyncRootReady(host, root))

py/test/rsession/testing/test_rest.py

@@ -60,7 +60,7 @@ class TestRestUnits(object):
     def test_report_HostRSyncRootReady(self):
         h = HostInfo('localhost')
         reporter.hosts_to_rsync = 1
-        reporter.report(repevent.HostRSyncRoots(h, ["a"]))
+        reporter.report(repevent.HostGatewayReady(h, ["a"]))
         event = repevent.HostRSyncRootReady(h, "a")
         reporter.report(event)
         assert stdout.getvalue() == '::\n\n   localhost: READY\n\n'

py/test/rsession/web.py

@@ -303,7 +303,7 @@ class ExportedMethods(BasicExternal):
     def _host_ready(self, event):
         self.pending_events.put(event)
 
-    def report_HostRSyncRoots(self, item):
+    def report_HostGatewayReady(self, item):
         self.to_rsync[item.host] = len(item.roots)
 
     def report_HostRSyncRootReady(self, item):