| 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} | |