/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to breezy/memorytree.py

  • Committer: Gustav Hartvigsson
  • Date: 2021-01-09 21:36:27 UTC
  • Revision ID: gustav.hartvigsson@gmail.com-20210109213627-h1xwcutzy9m7a99b
Added 'Case Preserving Working Tree Use Cases' from Canonical Wiki

* Addod a page from the Canonical Bazaar wiki
  with information on the scmeatics of case
  perserving filesystems an a case insensitive
  filesystem works.
  
  * Needs re-work, but this will do as it is the
    same inforamoton as what was on the linked
    page in the currint documentation.

Show diffs side-by-side

added added

removed removed

Lines of Context:
breezy/memorytree.py
19
19
See MemoryTree for more details.
20
20
"""
21
21
 
22
 
 
23
22
import os
 
23
import stat
24
24
 
25
 
from bzrlib import (
 
25
from . import (
26
26
    errors,
27
 
    mutabletree,
 
27
    lock,
28
28
    revision as _mod_revision,
29
29
    )
30
 
from bzrlib.decorators import needs_read_lock
31
 
from bzrlib.osutils import sha_file
32
 
from bzrlib.mutabletree import needs_tree_write_lock
33
 
from bzrlib.transport.memory import MemoryTransport
34
 
 
35
 
 
36
 
class MemoryTree(mutabletree.MutableTree):
 
30
from .bzr.inventory import Inventory
 
31
from .bzr.inventorytree import MutableInventoryTree
 
32
from .osutils import sha_file
 
33
from .transport.memory import MemoryTransport
 
34
 
 
35
 
 
36
class MemoryTree(MutableInventoryTree):
37
37
    """A MemoryTree is a specialisation of MutableTree.
38
38
 
39
39
    It maintains nearly no state outside of read_lock and write_lock
44
44
    def __init__(self, branch, revision_id):
45
45
        """Construct a MemoryTree for branch using revision_id."""
46
46
        self.branch = branch
47
 
        self.bzrdir = branch.bzrdir
 
47
        self.controldir = branch.controldir
48
48
        self._branch_revision_id = revision_id
49
49
        self._locks = 0
50
50
        self._lock_mode = None
51
51
 
52
 
    @needs_tree_write_lock
 
52
    def supports_symlinks(self):
 
53
        return True
 
54
 
 
55
    def supports_tree_reference(self):
 
56
        return False
 
57
 
 
58
    def get_config_stack(self):
 
59
        return self.branch.get_config_stack()
 
60
 
 
61
    def is_control_filename(self, filename):
 
62
        # Memory tree doesn't have any control filenames
 
63
        return False
 
64
 
53
65
    def _add(self, files, ids, kinds):
54
66
        """See MutableTree._add."""
55
 
        for f, file_id, kind in zip(files, ids, kinds):
56
 
            if kind is None:
57
 
                kind = 'file'
58
 
            if file_id is None:
59
 
                self._inventory.add_path(f, kind=kind)
60
 
            else:
61
 
                self._inventory.add_path(f, kind=kind, file_id=file_id)
 
67
        with self.lock_tree_write():
 
68
            for f, file_id, kind in zip(files, ids, kinds):
 
69
                if kind is None:
 
70
                    st_mode = self._file_transport.stat(f).st_mode
 
71
                    if stat.S_ISREG(st_mode):
 
72
                        kind = 'file'
 
73
                    elif stat.S_ISLNK(st_mode):
 
74
                        kind = 'symlink'
 
75
                    elif stat.S_ISDIR(st_mode):
 
76
                        kind = 'directory'
 
77
                    else:
 
78
                        raise AssertionError('Unknown file kind')
 
79
                if file_id is None:
 
80
                    self._inventory.add_path(f, kind=kind)
 
81
                else:
 
82
                    self._inventory.add_path(f, kind=kind, file_id=file_id)
62
83
 
63
84
    def basis_tree(self):
64
85
        """See Tree.basis_tree()."""
77
98
        missing files, so is a no-op.
78
99
        """
79
100
 
80
 
    def get_file(self, file_id, path=None):
 
101
    def get_file(self, path):
81
102
        """See Tree.get_file."""
82
 
        if path is None:
83
 
            path = self.id2path(file_id)
84
103
        return self._file_transport.get(path)
85
104
 
86
 
    def get_file_sha1(self, file_id, path=None, stat_value=None):
 
105
    def get_file_sha1(self, path, stat_value=None):
87
106
        """See Tree.get_file_sha1()."""
88
 
        if path is None:
89
 
            path = self.id2path(file_id)
90
107
        stream = self._file_transport.get(path)
91
108
        return sha_file(stream)
92
109
 
93
 
    def get_root_id(self):
94
 
        return self.path2id('')
95
 
 
96
110
    def _comparison_data(self, entry, path):
97
111
        """See Tree._comparison_data."""
98
112
        if entry is None:
99
113
            return None, False, None
100
114
        return entry.kind, entry.executable, None
101
115
 
102
 
    @needs_tree_write_lock
103
116
    def rename_one(self, from_rel, to_rel):
104
 
        file_id = self.path2id(from_rel)
105
 
        to_dir, to_tail = os.path.split(to_rel)
106
 
        to_parent_id = self.path2id(to_dir)
107
 
        self._file_transport.move(from_rel, to_rel)
108
 
        self._inventory.rename(file_id, to_parent_id, to_tail)
 
117
        with self.lock_tree_write():
 
118
            file_id = self.path2id(from_rel)
 
119
            to_dir, to_tail = os.path.split(to_rel)
 
120
            to_parent_id = self.path2id(to_dir)
 
121
            self._file_transport.move(from_rel, to_rel)
 
122
            self._inventory.rename(file_id, to_parent_id, to_tail)
109
123
 
110
124
    def path_content_summary(self, path):
111
125
        """See Tree.path_content_summary."""
112
126
        id = self.path2id(path)
113
127
        if id is None:
114
128
            return 'missing', None, None, None
115
 
        kind = self.kind(id)
 
129
        kind = self.kind(path, id)
116
130
        if kind == 'file':
117
131
            bytes = self._file_transport.get_bytes(path)
118
132
            size = len(bytes)
119
133
            executable = self._inventory[id].executable
120
 
            sha1 = None # no stat cache
 
134
            sha1 = None  # no stat cache
121
135
            return (kind, size, executable, sha1)
122
136
        elif kind == 'directory':
123
137
            # memory tree does not support nested trees yet.
124
138
            return kind, None, None, None
125
139
        elif kind == 'symlink':
126
 
            raise NotImplementedError('symlink support')
 
140
            return kind, None, None, self._inventory[id].symlink_target
127
141
        else:
128
142
            raise NotImplementedError('unknown kind')
129
143
 
130
 
    def _file_size(self, entry, stat_value):
131
 
        """See Tree._file_size."""
132
 
        if entry is None:
133
 
            return 0
134
 
        return entry.text_size
135
 
 
136
 
    @needs_read_lock
137
144
    def get_parent_ids(self):
138
145
        """See Tree.get_parent_ids.
139
146
 
140
147
        This implementation returns the current cached value from
141
148
            self._parent_ids.
142
149
        """
143
 
        return list(self._parent_ids)
 
150
        with self.lock_read():
 
151
            return list(self._parent_ids)
144
152
 
145
153
    def has_filename(self, filename):
146
154
        """See Tree.has_filename()."""
147
155
        return self._file_transport.has(filename)
148
156
 
149
 
    def is_executable(self, file_id, path=None):
150
 
        return self._inventory[file_id].executable
 
157
    def is_executable(self, path):
 
158
        return self._inventory.get_entry_by_path(path).executable
151
159
 
152
 
    def kind(self, file_id):
153
 
        return self._inventory[file_id].kind
 
160
    def kind(self, path):
 
161
        return self._inventory.get_entry_by_path(path).kind
154
162
 
155
163
    def mkdir(self, path, file_id=None):
156
164
        """See MutableTree.mkdir()."""
160
168
        self._file_transport.mkdir(path)
161
169
        return file_id
162
170
 
163
 
    @needs_read_lock
164
171
    def last_revision(self):
165
172
        """See MutableTree.last_revision."""
166
 
        return self._branch_revision_id
 
173
        with self.lock_read():
 
174
            return self._branch_revision_id
167
175
 
168
176
    def lock_read(self):
169
177
        """Lock the memory tree for reading.
176
184
                self.branch.lock_read()
177
185
                self._lock_mode = "r"
178
186
                self._populate_from_branch()
179
 
        except:
 
187
            return lock.LogicalLockResult(self.unlock)
 
188
        except BaseException:
180
189
            self._locks -= 1
181
190
            raise
182
191
 
190
199
                self._populate_from_branch()
191
200
            elif self._lock_mode == "r":
192
201
                raise errors.ReadOnlyError(self)
193
 
        except:
 
202
        except BaseException:
194
203
            self._locks -= 1
195
204
            raise
 
205
        return lock.LogicalLockResult(self.unlock)
196
206
 
197
207
    def lock_write(self):
198
208
        """See MutableTree.lock_write()."""
204
214
                self._populate_from_branch()
205
215
            elif self._lock_mode == "r":
206
216
                raise errors.ReadOnlyError(self)
207
 
        except:
 
217
            return lock.LogicalLockResult(self.unlock)
 
218
        except BaseException:
208
219
            self._locks -= 1
209
220
            raise
210
221
 
215
226
            self._parent_ids = []
216
227
        else:
217
228
            self._parent_ids = [self._branch_revision_id]
218
 
        self._inventory = self._basis_tree._inventory._get_mutable_inventory()
 
229
        self._inventory = Inventory(None, self._basis_tree.get_revision_id())
219
230
        self._file_transport = MemoryTransport()
220
231
        # TODO copy the revision trees content, or do it lazy, or something.
221
 
        inventory_entries = self._inventory.iter_entries()
 
232
        inventory_entries = self._basis_tree.iter_entries_by_dir()
222
233
        for path, entry in inventory_entries:
 
234
            self._inventory.add(entry.copy())
223
235
            if path == '':
224
236
                continue
225
237
            if entry.kind == 'directory':
226
238
                self._file_transport.mkdir(path)
 
239
            elif entry.kind == 'symlink':
 
240
                self._file_transport.symlink(entry.symlink_target, path)
227
241
            elif entry.kind == 'file':
228
 
                self._file_transport.put_file(path,
229
 
                    self._basis_tree.get_file(entry.file_id))
 
242
                self._file_transport.put_file(
 
243
                    path, self._basis_tree.get_file(path))
230
244
            else:
231
245
                raise NotImplementedError(self._populate_from_branch)
232
246
 
233
 
    def put_file_bytes_non_atomic(self, file_id, bytes):
 
247
    def put_file_bytes_non_atomic(self, path, bytes):
234
248
        """See MutableTree.put_file_bytes_non_atomic."""
235
 
        self._file_transport.put_bytes(self.id2path(file_id), bytes)
 
249
        self._file_transport.put_bytes(path, bytes)
236
250
 
237
251
    def unlock(self):
238
252
        """Release a lock.
252
266
        else:
253
267
            self._locks -= 1
254
268
 
255
 
    @needs_tree_write_lock
256
 
    def unversion(self, file_ids):
257
 
        """Remove the file ids in file_ids from the current versioned set.
 
269
    def unversion(self, paths):
 
270
        """Remove the paths from the current versioned set.
258
271
 
259
272
        When a file_id is unversioned, all of its children are automatically
260
273
        unversioned.
261
274
 
262
 
        :param file_ids: The file ids to stop versioning.
 
275
        :param paths: The paths to stop versioning.
263
276
        :raises: NoSuchId if any fileid is not currently versioned.
264
277
        """
265
 
        # XXX: This should be in mutabletree, but the inventory-save action
266
 
        # is not relevant to memory tree. Until that is done in unlock by
267
 
        # working tree, we cannot share the implementation.
268
 
        for file_id in file_ids:
269
 
            if self._inventory.has_id(file_id):
270
 
                self._inventory.remove_recursive_id(file_id)
271
 
            else:
272
 
                raise errors.NoSuchId(self, file_id)
 
278
        with self.lock_tree_write():
 
279
            # XXX: This should be in mutabletree, but the inventory-save action
 
280
            # is not relevant to memory tree. Until that is done in unlock by
 
281
            # working tree, we cannot share the implementation.
 
282
            file_ids = set()
 
283
            for path in paths:
 
284
                file_id = self.path2id(path)
 
285
                if file_id is None:
 
286
                    raise errors.NoSuchFile(path)
 
287
                file_ids.add(file_id)
 
288
            for file_id in file_ids:
 
289
                if self._inventory.has_id(file_id):
 
290
                    self._inventory.remove_recursive_id(file_id)
273
291
 
274
292
    def set_parent_ids(self, revision_ids, allow_leftmost_as_ghost=False):
275
293
        """See MutableTree.set_parent_trees()."""
283
301
            self._branch_revision_id = revision_ids[0]
284
302
        self._allow_leftmost_as_ghost = allow_leftmost_as_ghost
285
303
        self._set_basis()
286
 
    
 
304
 
287
305
    def _set_basis(self):
288
306
        try:
289
307
            self._basis_tree = self.branch.repository.revision_tree(
295
313
            else:
296
314
                raise
297
315
 
 
316
    def get_symlink_target(self, path):
 
317
        with self.lock_read():
 
318
            return self._file_transport.readlink(path)
 
319
 
298
320
    def set_parent_trees(self, parents_list, allow_leftmost_as_ghost=False):
299
321
        """See MutableTree.set_parent_trees()."""
300
322
        if len(parents_list) == 0:
301
323
            self._parent_ids = []
302
324
            self._basis_tree = self.branch.repository.revision_tree(
303
 
                                   _mod_revision.NULL_REVISION)
 
325
                _mod_revision.NULL_REVISION)
304
326
        else:
305
327
            if parents_list[0][1] is None and not allow_leftmost_as_ghost:
306
328
                # a ghost in the left most parent
307
329
                raise errors.GhostRevisionUnusableHere(parents_list[0][0])
308
330
            self._parent_ids = [parent_id for parent_id, tree in parents_list]
309
 
            if parents_list[0][1] is None or parents_list[0][1] == 'null:':
 
331
            if parents_list[0][1] is None or parents_list[0][1] == b'null:':
310
332
                self._basis_tree = self.branch.repository.revision_tree(
311
 
                                       _mod_revision.NULL_REVISION)
 
333
                    _mod_revision.NULL_REVISION)
312
334
            else:
313
335
                self._basis_tree = parents_list[0][1]
314
336
            self._branch_revision_id = parents_list[0][0]