| 19 | |
| 20 | |
| 21 | def test_wal_push_fetch(pg_xlog, tmpdir, config): |
| 22 | contents = 'abcdefghijlmnopqrstuvwxyz\n' * 10000 |
| 23 | seg_name = '00000001' * 3 |
| 24 | pg_xlog.touch(seg_name, '.ready') |
| 25 | pg_xlog.seg(seg_name).write(contents) |
| 26 | config.main('wal-push', 'pg_xlog/' + seg_name) |
| 27 | |
| 28 | # Recall file and check for equality. |
| 29 | download_file = tmpdir.join('TEST-DOWNLOADED') |
| 30 | config.main('wal-fetch', '-p0', seg_name, str(download_file)) |
| 31 | assert download_file.read() == contents |
| 32 | |
| 33 | config.main('wal-prefetch', path.dirname(str(download_file)), seg_name) |
| 34 | assert tmpdir.join('.wal-e', 'prefetch', seg_name).check(file=1) |
| 35 | |
| 36 | |
| 37 | def test_wal_push_parallel(pg_xlog, config, monkeypatch): |