2 from __future__ import absolute_import, print_function
7 from bup import index, metadata
8 from bup.compat import fsencode
9 from bup.helpers import mkdirp, resolve_parent
10 from buptest import no_lingering_errors, test_tempdir
11 import bup.xstat as xstat
14 lib_t_dir = os.path.dirname(fsencode(__file__))
19 with no_lingering_errors():
20 cd = os.path.realpath(b'../')
22 sd = os.path.realpath(cd + b'/sampledata')
23 WVPASSEQ(resolve_parent(cd + b'/sampledata'), sd)
24 WVPASSEQ(os.path.realpath(cd + b'/sampledata/x'), sd + b'/x')
25 WVPASSEQ(os.path.realpath(cd + b'/sampledata/var/abs-symlink'),
26 sd + b'/var/abs-symlink-target')
27 WVPASSEQ(resolve_parent(cd + b'/sampledata/var/abs-symlink'),
28 sd + b'/var/abs-symlink')
33 with no_lingering_errors():
34 with test_tempdir(b'bup-tindex-') as tmpdir:
35 orig_cwd = os.getcwd()
39 fs = xstat.stat(lib_t_dir + b'/test_index.py')
40 ms = index.MetaStoreWriter(b'index.meta.tmp');
41 tmax = (time.time() - 1) * 10**9
42 w = index.Writer(b'index.tmp', ms, tmax)
43 w.add(b'/var/tmp/sporky', fs, 0)
44 w.add(b'/etc/passwd', fs, 0)
45 w.add(b'/etc/', ds, 0)
55 print('%s%s %s' % (e.is_valid() and ' ' or 'M',
56 e.is_fake() and 'F' or ' ',
59 def fake_validate(*l):
62 e.validate(0o100644, index.FAKE_SHA)
71 def index_negative_timestamps():
72 with no_lingering_errors():
73 with test_tempdir(b'bup-tindex-') as tmpdir:
75 foopath = tmpdir + b'/foo'
76 f = open(foopath, 'wb')
80 os.utime(foopath, (-86400, -86400))
82 tmax = (time.time() - 1) * ns_per_sec
83 e = index.BlankNewEntry(foopath, 0, tmax)
84 e.update_from_stat(xstat.stat(foopath), 0)
88 os.utime(foopath, (-0x80000000, -0x80000000))
89 e = index.BlankNewEntry(foopath, 0, tmax)
90 e.update_from_stat(xstat.stat(foopath), 0)
96 with no_lingering_errors():
97 with test_tempdir(b'bup-tindex-') as tmpdir:
98 orig_cwd = os.getcwd()
101 default_meta = metadata.Metadata()
102 ms1 = index.MetaStoreWriter(b'index.meta.tmp')
103 ms2 = index.MetaStoreWriter(b'index2.meta.tmp')
104 ms3 = index.MetaStoreWriter(b'index3.meta.tmp')
105 meta_ofs1 = ms1.store(default_meta)
106 meta_ofs2 = ms2.store(default_meta)
107 meta_ofs3 = ms3.store(default_meta)
109 ds = xstat.stat(lib_t_dir)
110 fs = xstat.stat(lib_t_dir + b'/test_index.py')
111 tmax = (time.time() - 1) * 10**9
113 w1 = index.Writer(b'index.tmp', ms1, tmax)
114 w1.add(b'/a/b/x', fs, meta_ofs1)
115 w1.add(b'/a/b/c', fs, meta_ofs1)
116 w1.add(b'/a/b/', ds, meta_ofs1)
117 w1.add(b'/a/', ds, meta_ofs1)
121 w2 = index.Writer(b'index2.tmp', ms2, tmax)
122 w2.add(b'/a/b/n/2', fs, meta_ofs2)
126 w3 = index.Writer(b'index3.tmp', ms3, tmax)
127 w3.add(b'/a/c/n/3', fs, meta_ofs3)
136 r1all = [e.name for e in r1]
138 [b'/a/b/x', b'/a/b/c', b'/a/b/', b'/a/', b'/'])
139 r2all = [e.name for e in r2]
141 [b'/a/b/n/2', b'/a/b/n/', b'/a/b/', b'/a/', b'/'])
142 r3all = [e.name for e in r3]
144 [b'/a/c/n/3', b'/a/c/n/', b'/a/c/', b'/a/', b'/'])
145 all = [e.name for e in index.merge(r2, r1, r3)]
147 [b'/a/c/n/3', b'/a/c/n/', b'/a/c/',
148 b'/a/b/x', b'/a/b/n/2', b'/a/b/n/', b'/a/b/c',
149 b'/a/b/', b'/a/', b'/'])
153 print([hex(e.flags) for e in r1])
154 WVPASSEQ([e.name for e in r1 if e.is_valid()], r1all)
155 WVPASSEQ([e.name for e in r1 if not e.is_valid()], [])
156 WVPASSEQ([e.name for e in index.merge(r2, r1, r3) if not e.is_valid()],
157 [b'/a/c/n/3', b'/a/c/n/', b'/a/c/',
158 b'/a/b/n/2', b'/a/b/n/', b'/a/b/', b'/a/', b'/'])
160 expect_invalid = [b'/'] + r2all + r3all
161 expect_real = (set(r1all) - set(r2all) - set(r3all)) \
162 | set([b'/a/b/n/2', b'/a/c/n/3'])
163 dump(index.merge(r2, r1, r3))
164 for e in index.merge(r2, r1, r3):
165 print(e.name, hex(e.flags), e.ctime)
166 eiv = e.name in expect_invalid
167 er = e.name in expect_real
168 WVPASSEQ(eiv, not e.is_valid())
169 WVPASSEQ(er, e.is_real())
170 fake_validate(r2, r3)
171 dump(index.merge(r2, r1, r3))
172 WVPASSEQ([e.name for e in index.merge(r2, r1, r3) if not e.is_valid()], [])
174 e = eget(index.merge(r2, r1, r3), b'/a/b/c')
177 dump(index.merge(r2, r1, r3))
178 WVPASSEQ([e.name for e in index.merge(r2, r1, r3) if not e.is_valid()],
179 [b'/a/b/c', b'/a/b/', b'/a/', b'/'])