parent
d0861a546f
commit
5c7fb384bc
|
@ -96,7 +96,7 @@ class RSync(object):
|
||||||
""" Sends a sourcedir to all added targets.
|
""" Sends a sourcedir to all added targets.
|
||||||
"""
|
"""
|
||||||
if not self._channels:
|
if not self._channels:
|
||||||
raise IOError("no targets available, maybing you "
|
raise IOError("no targets available, maybe you "
|
||||||
"are trying call send() twice?")
|
"are trying call send() twice?")
|
||||||
self._sourcedir = str(sourcedir)
|
self._sourcedir = str(sourcedir)
|
||||||
# normalize a trailing '/' away
|
# normalize a trailing '/' away
|
||||||
|
@ -143,7 +143,6 @@ class RSync(object):
|
||||||
channel.send((str(destdir), self._options))
|
channel.send((str(destdir), self._options))
|
||||||
self._channels[channel] = finishedcallback
|
self._channels[channel] = finishedcallback
|
||||||
|
|
||||||
|
|
||||||
def _broadcast(self, msg):
|
def _broadcast(self, msg):
|
||||||
for channel in self._channels:
|
for channel in self._channels:
|
||||||
channel.send(msg)
|
channel.send(msg)
|
||||||
|
|
Loading…
Reference in New Issue