def add_target(self, gateway, destdir, |
finishedcallback=None, **options): |
""" Adds a remote target specified via a 'gateway' |
and a remote destination directory. |
""" |
assert finishedcallback is None or callable(finishedcallback) |
for name in options: |
assert name in ('delete',) |
def itemcallback(req): |
self._receivequeue.put((channel, req)) |
channel = gateway.remote_exec(REMOTE_SOURCE) |
-> channel.setcallback(itemcallback, endmarker = None) |
channel.send((str(destdir), options)) |
self._channels[channel] = finishedcallback |