Mercurial > public > mercurial-scm > hg-stable
diff mercurial/store.py @ 52043:e308439339e2
stream: rename TempCopyManager to VolatileManager
We are going to be more subtle in our management of volatile file, so use a more
semantic name.
author | Pierre-Yves David <pierre-yves.david@octobus.net> |
---|---|
date | Mon, 14 Oct 2024 15:11:49 +0200 |
parents | 2391a5fa111e |
children | 0ad269e24075 |
line wrap: on
line diff
--- a/mercurial/store.py Mon Oct 14 12:12:34 2024 -0400 +++ b/mercurial/store.py Mon Oct 14 15:11:49 2024 +0200 @@ -477,7 +477,7 @@ def has_size(self): return self._file_size is not None - def get_stream(self, vfs, copies): + def get_stream(self, vfs, volatiles): """return data "stream" information for this file (unencoded_file_path, content_iterator, content_size) @@ -485,7 +485,7 @@ size = self.file_size(None) def get_stream(): - actual_path = copies[vfs.join(self.unencoded_path)] + actual_path = volatiles[vfs.join(self.unencoded_path)] with open(actual_path, 'rb') as fp: yield None # ready to stream if size <= 65536: @@ -513,7 +513,7 @@ self, repo=None, vfs=None, - copies=None, + volatiles=None, max_changeset=None, preserve_file_count=False, ): @@ -522,7 +522,7 @@ return [(unencoded_file_path, content_iterator, content_size), …] """ assert vfs is not None - return [f.get_stream(vfs, copies) for f in self.files()] + return [f.get_stream(vfs, volatiles) for f in self.files()] @attr.s(slots=True, init=False) @@ -632,7 +632,7 @@ self, repo=None, vfs=None, - copies=None, + volatiles=None, max_changeset=None, preserve_file_count=False, ): @@ -648,13 +648,13 @@ return super().get_streams( repo=repo, vfs=vfs, - copies=copies, + volatiles=volatiles, max_changeset=max_changeset, preserve_file_count=preserve_file_count, ) elif not preserve_file_count: stream = [ - f.get_stream(vfs, copies) + f.get_stream(vfs, volatiles) for f in self.files() if not f.unencoded_path.endswith((b'.i', b'.d')) ] @@ -668,7 +668,7 @@ name_to_size[f.unencoded_path] = f.file_size(None) stream = [ - f.get_stream(vfs, copies) + f.get_stream(vfs, volatiles) for f in self.files() if not f.unencoded_path.endswith(b'.i') ]