1
# (C) 2005 Canonical Ltd
3
# This program is free software; you can redistribute it and/or modify
4
# it under the terms of the GNU General Public License as published by
5
# the Free Software Foundation; either version 2 of the License, or
6
# (at your option) any later version.
8
# This program is distributed in the hope that it will be useful,
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11
# GNU General Public License for more details.
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
import stat, os, sha, time
18
from binascii import b2a_qp, a2b_qp
20
from trace import mutter
21
from errors import BzrError, BzrCheckError
24
"""File stat cache to speed up tree comparisons.
26
This module basically gives a quick way to find the SHA-1 and related
27
information of a file in the working directory, without actually
28
reading and hashing the whole file.
35
Users of this module should not need to know about how this is
36
implemented, and in particular should not depend on the particular
37
data which is stored or its format.
39
This is done by maintaining a cache indexed by a file fingerprint of
40
(path, size, mtime, ctime, ino, dev) pointing to the SHA-1. If the
41
fingerprint has changed, we assume the file content has not changed
42
either and the SHA-1 is therefore the same.
44
If any of the fingerprint fields have changed then the file content
45
*may* have changed, or it may not have. We need to reread the file
46
contents to make sure, but this is not visible to the user or
47
higher-level code (except as a delay of course).
49
The mtime and ctime are stored with nanosecond fields, but not all
50
filesystems give this level of precision. There is therefore a
51
possible race: the file might be modified twice within a second
52
without changing the size or mtime, and a SHA-1 cached from the first
53
version would be wrong. We handle this by not recording a cached hash
54
for any files which were modified in the current second and that
55
therefore have the chance to change again before the second is up.
57
The only known hole in this design is if the system clock jumps
58
backwards crossing invocations of bzr. Please don't do that; use ntp
59
to gradually adjust your clock or don't use bzr over the step.
61
At the moment this is stored in a simple textfile; it might be nice
64
The cache is represented as a map from file_id to a tuple of (file_id,
65
sha1, path, size, mtime, ctime, ino, dev).
67
The SHA-1 is stored in memory as a hexdigest.
69
File names are written out as the quoted-printable encoding of their
73
# order of fields returned by fingerprint()
80
# order of fields in the statcache file and in the in-memory map
92
CACHE_HEADER = "### bzr statcache v2"
95
def fingerprint(abspath):
97
fs = os.lstat(abspath)
99
# might be missing, etc
102
if stat.S_ISDIR(fs.st_mode):
105
return (fs.st_size, fs.st_mtime,
106
fs.st_ctime, fs.st_ino, fs.st_dev)
109
def _write_cache(basedir, entry_iter, dangerfiles):
110
from atomicfile import AtomicFile
112
cachefn = os.path.join(basedir, '.bzr', 'stat-cache')
113
outf = AtomicFile(cachefn, 'wb')
114
outf.write(CACHE_HEADER + '\n')
116
for entry in entry_iter:
118
raise ValueError("invalid statcache entry tuple %r" % entry)
120
if entry[SC_FILE_ID] in dangerfiles:
121
continue # changed too recently
122
outf.write(entry[0]) # file id
124
outf.write(entry[1]) # hex sha1
126
outf.write(b2a_qp(entry[2].encode('utf-8'), True)) # name
128
outf.write(' %d' % nf)
137
def load_cache(basedir):
143
cachefn = os.path.join(basedir, '.bzr', 'stat-cache')
144
cachefile = open(cachefn, 'rb')
148
line1 = cachefile.readline().rstrip('\r\n')
149
if line1 != CACHE_HEADER:
150
mutter('cache header marker not found at top of %s' % cachefn)
158
raise BzrError("duplicated file_id in cache: {%s}" % file_id)
160
path = a2b_qp(f[2]).decode('utf-8')
161
if path in seen_paths:
162
raise BzrCheckError("duplicated path in cache: %r" % path)
165
entry = (file_id, f[1], path) + tuple([long(x) for x in f[3:]])
167
raise ValueError("invalid statcache entry tuple %r" % entry)
169
cache[file_id] = entry
175
def _files_from_inventory(inv):
176
for path, ie in inv.iter_entries():
177
if ie.kind != 'file':
179
yield ie.file_id, path
183
def update_cache(basedir, inv, flush=False):
184
"""Update and return the cache for the branch.
186
The returned cache may contain entries that have not been written
187
to disk for files recently touched.
189
flush -- discard any previous cache and recalculate from scratch.
193
# TODO: It's supposed to be faster to stat the files in order by inum.
194
# We don't directly know the inum of the files of course but we do
195
# know where they were last sighted, so we can sort by that.
197
assert isinstance(flush, bool)
201
cache = load_cache(basedir)
202
return _update_cache_from_list(basedir, cache, _files_from_inventory(inv))
206
def _update_cache_from_list(basedir, cache, to_update):
207
"""Update and return the cache for given files.
209
cache -- Previously cached values to be validated.
211
to_update -- Sequence of (file_id, path) pairs to check.
216
stat_cnt = missing_cnt = hardcheck = change_cnt = 0
218
# files that have been recently touched and can't be
219
# committed to a persistent cache yet.
222
now = int(time.time())
224
## mutter('update statcache under %r' % basedir)
225
for file_id, path in to_update:
226
abspath = os.path.join(basedir, path)
227
fp = fingerprint(abspath)
230
cacheentry = cache.get(file_id)
232
if fp == None: # not here
239
if (fp[FP_MTIME] >= now) or (fp[FP_CTIME] >= now):
240
dangerfiles.add(file_id)
242
if cacheentry and (cacheentry[3:] == fp):
243
continue # all stat fields unchanged
247
dig = sha.new(file(abspath, 'rb').read()).hexdigest()
249
# We update the cache even if the digest has not changed from
250
# last time we looked, so that the fingerprint fields will
252
cacheentry = (file_id, dig, path) + fp
253
cache[file_id] = cacheentry
256
mutter('statcache: statted %d files, read %d files, %d changed, %d dangerous, '
258
% (stat_cnt, hardcheck, change_cnt, len(dangerfiles), len(cache)))
261
mutter('updating on-disk statcache')
262
_write_cache(basedir, cache.itervalues(), dangerfiles)
added
removed
bzrlib/statcache.py
