← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hashcache.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2009-02-23 17:00:36 UTC
  • mfrom: (4032.1.4 jam-integration)
  • Revision ID: pqm@pqm.ubuntu.com-20090223170036-3q1v68ewdt8i0to5
(Marius Kruger) Remove all trailing whitespace and add tests to
        enforce this.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/hashcache.py
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
 
# TODO: Up-front, stat all files in order and remove those which are deleted or 
18
 
# out-of-date.  Don't actually re-read them until they're needed.  That ought 
19
 
# to bring all the inodes into core so that future stats to them are fast, and 
 
17
# TODO: Up-front, stat all files in order and remove those which are deleted or
 
18
# out-of-date.  Don't actually re-read them until they're needed.  That ought
 
19
# to bring all the inodes into core so that future stats to them are fast, and
20
20
# it preserves the nice property that any caller will always get up-to-date
21
21
# data except in unavoidable cases.
22
22
 
73
73
    hit_count
74
74
        number of times files have been retrieved from the cache, avoiding a
75
75
        re-read
76
 
        
 
76
 
77
77
    miss_count
78
78
        number of misses (times files have been completely re-read)
79
79
    """
106
106
 
107
107
    def scan(self):
108
108
        """Scan all files and remove entries where the cache entry is obsolete.
109
 
        
 
109
 
110
110
        Obsolete entries are those where the file has been modified or deleted
111
 
        since the entry was inserted.        
 
111
        since the entry was inserted.
112
112
        """
113
113
        # FIXME optimisation opportunity, on linux [and check other oses]:
114
114
        # rather than iteritems order, stat in inode order.
115
115
        prep = [(ce[1][3], path, ce) for (path, ce) in self._cache.iteritems()]
116
116
        prep.sort()
117
 
        
 
117
 
118
118
        for inum, path, cache_entry in prep:
119
119
            abspath = pathjoin(self.root, path)
120
120
            fp = self._fingerprint(abspath)
121
121
            self.stat_count += 1
122
 
            
 
122
 
123
123
            cache_fp = cache_entry[1]
124
 
    
 
124
 
125
125
            if (not fp) or (cache_fp != fp):
126
126
                # not here or not a regular file anymore
127
127
                self.removed_count += 1
137
137
            abspath = pathjoin(self.root, path)
138
138
        self.stat_count += 1
139
139
        file_fp = self._fingerprint(abspath, stat_value)
140
 
        
 
140
 
141
141
        if not file_fp:
142
142
            # not a regular file or not existing
143
143
            if path in self._cache:
144
144
                self.removed_count += 1
145
145
                self.needs_write = True
146
146
                del self._cache[path]
147
 
            return None        
 
147
            return None
148
148
 
149
149
        if path in self._cache:
150
150
            cache_sha1, cache_fp = self._cache[path]
156
156
            ## mutter("now = %s", time.time())
157
157
            self.hit_count += 1
158
158
            return cache_sha1
159
 
        
 
159
 
160
160
        self.miss_count += 1
161
161
 
162
162
        mode = file_fp[FP_MODE_COLUMN]
201
201
    def _really_sha1_file(self, abspath):
202
202
        """Calculate the SHA1 of a file by reading the full text"""
203
203
        return sha_file(file(abspath, 'rb', buffering=65000))
204
 
        
 
204
 
205
205
    def write(self):
206
206
        """Write contents of cache to file."""
207
207
        outf = AtomicFile(self.cache_file_name(), 'wb', new_mode=self._mode)
227
227
 
228
228
        Overwrites existing cache.
229
229
 
230
 
        If the cache file has the wrong version marker, this just clears 
 
230
        If the cache file has the wrong version marker, this just clears
231
231
        the cache."""
232
232
        self._cache = {}
233
233
 
278
278
        undetectably modified and so can't be cached.
279
279
        """
280
280
        return int(time.time()) - 3
281
 
           
 
281
 
282
282
    def _fingerprint(self, abspath, stat_value=None):
283
283
        if stat_value is None:
284
284
            try:
291
291
        # we discard any high precision because it's not reliable; perhaps we
292
292
        # could do better on some systems?
293
293
        return (stat_value.st_size, long(stat_value.st_mtime),
294
 
                long(stat_value.st_ctime), stat_value.st_ino, 
 
294
                long(stat_value.st_ctime), stat_value.st_ino,
295
295
                stat_value.st_dev, stat_value.st_mode)