116 |
117 |
118 |
119 |
120 |
121 |
122 |
123 |
124 |
125 |
126 |
127 |
128 |
129 |
130 | |
def test_callback(self): |
dest = self.dest1 |
source = self.source |
source.ensure("existant").write("a" * 100) |
source.ensure("existant2").write("a" * 10) |
total = {} |
def callback(cmd, lgt, channel): |
total[(cmd, lgt)] = True |
|
-> rsync = RSync(source, callback=callback) |
|
rsync.add_target(gw, dest) |
rsync.send() |
|
assert total == {("list", 110):True, ("ack", 100):True, ("ack", 10):True} | |