parent
66c64e6b97
commit
ae412d3757
|
@ -23,12 +23,6 @@ class GatewayManager:
|
||||||
self.specs.append(spec)
|
self.specs.append(spec)
|
||||||
self.api = py._com.PluginAPI(py.execnet._API)
|
self.api = py._com.PluginAPI(py.execnet._API)
|
||||||
|
|
||||||
def trace(self, msg):
|
|
||||||
self.notify("trace", "gatewaymanage", msg)
|
|
||||||
|
|
||||||
def notify(self, eventname, *args, **kwargs):
|
|
||||||
py._com.pyplugins.notify(eventname, *args, **kwargs)
|
|
||||||
|
|
||||||
def makegateways(self):
|
def makegateways(self):
|
||||||
assert not self.gateways
|
assert not self.gateways
|
||||||
for spec in self.specs:
|
for spec in self.specs:
|
||||||
|
@ -90,13 +84,10 @@ class GatewayManager:
|
||||||
source=source,
|
source=source,
|
||||||
gateways=seen.values()
|
gateways=seen.values()
|
||||||
)
|
)
|
||||||
else:
|
|
||||||
self.trace("rsync: nothing to do.")
|
|
||||||
|
|
||||||
def exit(self):
|
def exit(self):
|
||||||
while self.gateways:
|
while self.gateways:
|
||||||
gw = self.gateways.pop()
|
gw = self.gateways.pop()
|
||||||
self.trace("exiting gateway %s" % gw)
|
|
||||||
gw.exit()
|
gw.exit()
|
||||||
|
|
||||||
class HostRSync(py.execnet.RSync):
|
class HostRSync(py.execnet.RSync):
|
||||||
|
|
Loading…
Reference in New Issue