~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/versionedfile.py

  • Committer: Ian Clatworthy
  • Date: 2007-12-17 01:45:32 UTC
  • mto: (3119.1.1 ianc-integration)
  • mto: This revision was merged to the branch mainline in revision 3120.
  • Revision ID: ian.clatworthy@internode.on.net-20071217014532-dmbv2mm72nzq0ai6
follow-up tweaks to bzr.dev integration

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2010 Canonical Ltd
 
1
# Copyright (C) 2005, 2006 Canonical Ltd
2
2
#
3
3
# Authors:
4
4
#   Johan Rydberg <jrydberg@gnu.org>
15
15
#
16
16
# You should have received a copy of the GNU General Public License
17
17
# along with this program; if not, write to the Free Software
18
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
18
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19
19
 
20
20
"""Versioned text file storage api."""
21
21
 
22
 
from copy import copy
23
 
from cStringIO import StringIO
24
 
import os
25
 
import struct
26
 
from zlib import adler32
27
 
 
28
22
from bzrlib.lazy_import import lazy_import
29
23
lazy_import(globals(), """
30
 
import urllib
31
24
 
32
25
from bzrlib import (
33
 
    annotate,
34
26
    errors,
35
 
    graph as _mod_graph,
36
 
    groupcompress,
37
 
    index,
38
 
    knit,
39
27
    osutils,
40
28
    multiparent,
41
29
    tsort,
42
30
    revision,
43
31
    ui,
44
32
    )
45
 
from bzrlib.graph import DictParentsProvider, Graph, StackedParentsProvider
46
33
from bzrlib.transport.memory import MemoryTransport
47
34
""")
48
 
from bzrlib.registry import Registry
49
 
from bzrlib.symbol_versioning import *
 
35
 
 
36
from cStringIO import StringIO
 
37
 
 
38
from bzrlib.inter import InterObject
50
39
from bzrlib.textmerge import TextMerge
51
 
from bzrlib import bencode
52
 
 
53
 
 
54
 
adapter_registry = Registry()
55
 
adapter_registry.register_lazy(('knit-delta-gz', 'fulltext'), 'bzrlib.knit',
56
 
    'DeltaPlainToFullText')
57
 
adapter_registry.register_lazy(('knit-ft-gz', 'fulltext'), 'bzrlib.knit',
58
 
    'FTPlainToFullText')
59
 
adapter_registry.register_lazy(('knit-annotated-delta-gz', 'knit-delta-gz'),
60
 
    'bzrlib.knit', 'DeltaAnnotatedToUnannotated')
61
 
adapter_registry.register_lazy(('knit-annotated-delta-gz', 'fulltext'),
62
 
    'bzrlib.knit', 'DeltaAnnotatedToFullText')
63
 
adapter_registry.register_lazy(('knit-annotated-ft-gz', 'knit-ft-gz'),
64
 
    'bzrlib.knit', 'FTAnnotatedToUnannotated')
65
 
adapter_registry.register_lazy(('knit-annotated-ft-gz', 'fulltext'),
66
 
    'bzrlib.knit', 'FTAnnotatedToFullText')
67
 
# adapter_registry.register_lazy(('knit-annotated-ft-gz', 'chunked'),
68
 
#     'bzrlib.knit', 'FTAnnotatedToChunked')
69
 
 
70
 
 
71
 
class ContentFactory(object):
72
 
    """Abstract interface for insertion and retrieval from a VersionedFile.
73
 
 
74
 
    :ivar sha1: None, or the sha1 of the content fulltext.
75
 
    :ivar storage_kind: The native storage kind of this factory. One of
76
 
        'mpdiff', 'knit-annotated-ft', 'knit-annotated-delta', 'knit-ft',
77
 
        'knit-delta', 'fulltext', 'knit-annotated-ft-gz',
78
 
        'knit-annotated-delta-gz', 'knit-ft-gz', 'knit-delta-gz'.
79
 
    :ivar key: The key of this content. Each key is a tuple with a single
80
 
        string in it.
81
 
    :ivar parents: A tuple of parent keys for self.key. If the object has
82
 
        no parent information, None (as opposed to () for an empty list of
83
 
        parents).
84
 
    """
85
 
 
86
 
    def __init__(self):
87
 
        """Create a ContentFactory."""
88
 
        self.sha1 = None
89
 
        self.storage_kind = None
90
 
        self.key = None
91
 
        self.parents = None
92
 
 
93
 
 
94
 
class ChunkedContentFactory(ContentFactory):
95
 
    """Static data content factory.
96
 
 
97
 
    This takes a 'chunked' list of strings. The only requirement on 'chunked' is
98
 
    that ''.join(lines) becomes a valid fulltext. A tuple of a single string
99
 
    satisfies this, as does a list of lines.
100
 
 
101
 
    :ivar sha1: None, or the sha1 of the content fulltext.
102
 
    :ivar storage_kind: The native storage kind of this factory. Always
103
 
        'chunked'
104
 
    :ivar key: The key of this content. Each key is a tuple with a single
105
 
        string in it.
106
 
    :ivar parents: A tuple of parent keys for self.key. If the object has
107
 
        no parent information, None (as opposed to () for an empty list of
108
 
        parents).
109
 
     """
110
 
 
111
 
    def __init__(self, key, parents, sha1, chunks):
112
 
        """Create a ContentFactory."""
113
 
        self.sha1 = sha1
114
 
        self.storage_kind = 'chunked'
115
 
        self.key = key
116
 
        self.parents = parents
117
 
        self._chunks = chunks
118
 
 
119
 
    def get_bytes_as(self, storage_kind):
120
 
        if storage_kind == 'chunked':
121
 
            return self._chunks
122
 
        elif storage_kind == 'fulltext':
123
 
            return ''.join(self._chunks)
124
 
        raise errors.UnavailableRepresentation(self.key, storage_kind,
125
 
            self.storage_kind)
126
 
 
127
 
 
128
 
class FulltextContentFactory(ContentFactory):
129
 
    """Static data content factory.
130
 
 
131
 
    This takes a fulltext when created and just returns that during
132
 
    get_bytes_as('fulltext').
133
 
 
134
 
    :ivar sha1: None, or the sha1 of the content fulltext.
135
 
    :ivar storage_kind: The native storage kind of this factory. Always
136
 
        'fulltext'.
137
 
    :ivar key: The key of this content. Each key is a tuple with a single
138
 
        string in it.
139
 
    :ivar parents: A tuple of parent keys for self.key. If the object has
140
 
        no parent information, None (as opposed to () for an empty list of
141
 
        parents).
142
 
     """
143
 
 
144
 
    def __init__(self, key, parents, sha1, text):
145
 
        """Create a ContentFactory."""
146
 
        self.sha1 = sha1
147
 
        self.storage_kind = 'fulltext'
148
 
        self.key = key
149
 
        self.parents = parents
150
 
        self._text = text
151
 
 
152
 
    def get_bytes_as(self, storage_kind):
153
 
        if storage_kind == self.storage_kind:
154
 
            return self._text
155
 
        elif storage_kind == 'chunked':
156
 
            return [self._text]
157
 
        raise errors.UnavailableRepresentation(self.key, storage_kind,
158
 
            self.storage_kind)
159
 
 
160
 
 
161
 
class AbsentContentFactory(ContentFactory):
162
 
    """A placeholder content factory for unavailable texts.
163
 
 
164
 
    :ivar sha1: None.
165
 
    :ivar storage_kind: 'absent'.
166
 
    :ivar key: The key of this content. Each key is a tuple with a single
167
 
        string in it.
168
 
    :ivar parents: None.
169
 
    """
170
 
 
171
 
    def __init__(self, key):
172
 
        """Create a ContentFactory."""
173
 
        self.sha1 = None
174
 
        self.storage_kind = 'absent'
175
 
        self.key = key
176
 
        self.parents = None
177
 
 
178
 
    def get_bytes_as(self, storage_kind):
179
 
        raise ValueError('A request was made for key: %s, but that'
180
 
                         ' content is not available, and the calling'
181
 
                         ' code does not handle if it is missing.'
182
 
                         % (self.key,))
183
 
 
184
 
 
185
 
class AdapterFactory(ContentFactory):
186
 
    """A content factory to adapt between key prefix's."""
187
 
 
188
 
    def __init__(self, key, parents, adapted):
189
 
        """Create an adapter factory instance."""
190
 
        self.key = key
191
 
        self.parents = parents
192
 
        self._adapted = adapted
193
 
 
194
 
    def __getattr__(self, attr):
195
 
        """Return a member from the adapted object."""
196
 
        if attr in ('key', 'parents'):
197
 
            return self.__dict__[attr]
198
 
        else:
199
 
            return getattr(self._adapted, attr)
200
 
 
201
 
 
202
 
def filter_absent(record_stream):
203
 
    """Adapt a record stream to remove absent records."""
204
 
    for record in record_stream:
205
 
        if record.storage_kind != 'absent':
206
 
            yield record
207
40
 
208
41
 
209
42
class VersionedFile(object):
210
43
    """Versioned text file storage.
211
 
 
 
44
    
212
45
    A versioned file manages versions of line-based text files,
213
46
    keeping track of the originating version for each line.
214
47
 
220
53
    Texts are identified by a version-id string.
221
54
    """
222
55
 
 
56
    def __init__(self, access_mode):
 
57
        self.finished = False
 
58
        self._access_mode = access_mode
 
59
 
223
60
    @staticmethod
224
61
    def check_not_reserved_id(version_id):
225
62
        revision.check_not_reserved_id(version_id)
228
65
        """Copy this versioned file to name on transport."""
229
66
        raise NotImplementedError(self.copy_to)
230
67
 
231
 
    def get_record_stream(self, versions, ordering, include_delta_closure):
232
 
        """Get a stream of records for versions.
 
68
    def versions(self):
 
69
        """Return a unsorted list of versions."""
 
70
        raise NotImplementedError(self.versions)
233
71
 
234
 
        :param versions: The versions to include. Each version is a tuple
235
 
            (version,).
236
 
        :param ordering: Either 'unordered' or 'topological'. A topologically
237
 
            sorted stream has compression parents strictly before their
238
 
            children.
239
 
        :param include_delta_closure: If True then the closure across any
240
 
            compression parents will be included (in the data content of the
241
 
            stream, not in the emitted records). This guarantees that
242
 
            'fulltext' can be used successfully on every record.
243
 
        :return: An iterator of ContentFactory objects, each of which is only
244
 
            valid until the iterator is advanced.
245
 
        """
246
 
        raise NotImplementedError(self.get_record_stream)
 
72
    def has_ghost(self, version_id):
 
73
        """Returns whether version is present as a ghost."""
 
74
        raise NotImplementedError(self.has_ghost)
247
75
 
248
76
    def has_version(self, version_id):
249
77
        """Returns whether version is present."""
250
78
        raise NotImplementedError(self.has_version)
251
79
 
252
 
    def insert_record_stream(self, stream):
253
 
        """Insert a record stream into this versioned file.
254
 
 
255
 
        :param stream: A stream of records to insert.
256
 
        :return: None
257
 
        :seealso VersionedFile.get_record_stream:
258
 
        """
259
 
        raise NotImplementedError
260
 
 
261
80
    def add_lines(self, version_id, parents, lines, parent_texts=None,
262
81
        left_matching_blocks=None, nostore_sha=None, random_id=False,
263
82
        check_content=True):
277
96
            the data back accurately. (Checking the lines have been split
278
97
            correctly is expensive and extremely unlikely to catch bugs so it
279
98
            is not done at runtime unless check_content is True.)
280
 
        :param parent_texts: An optional dictionary containing the opaque
 
99
        :param parent_texts: An optional dictionary containing the opaque 
281
100
            representations of some or all of the parents of version_id to
282
101
            allow delta optimisations.  VERY IMPORTANT: the texts must be those
283
102
            returned by add_lines or data corruption can be caused.
309
128
 
310
129
    def add_lines_with_ghosts(self, version_id, parents, lines,
311
130
        parent_texts=None, nostore_sha=None, random_id=False,
312
 
        check_content=True, left_matching_blocks=None):
 
131
        check_content=True):
313
132
        """Add lines to the versioned file, allowing ghosts to be present.
314
 
 
 
133
        
315
134
        This takes the same parameters as add_lines and returns the same.
316
135
        """
317
136
        self._check_write_ok()
318
137
        return self._add_lines_with_ghosts(version_id, parents, lines,
319
 
            parent_texts, nostore_sha, random_id, check_content, left_matching_blocks)
 
138
            parent_texts, nostore_sha, random_id, check_content)
320
139
 
321
140
    def _add_lines_with_ghosts(self, version_id, parents, lines, parent_texts,
322
 
        nostore_sha, random_id, check_content, left_matching_blocks):
 
141
        nostore_sha, random_id, check_content):
323
142
        """Helper to do class specific add_lines_with_ghosts."""
324
143
        raise NotImplementedError(self.add_lines_with_ghosts)
325
144
 
339
158
            if '\n' in line[:-1]:
340
159
                raise errors.BzrBadParameterContainsNewline("lines")
341
160
 
 
161
    def _check_write_ok(self):
 
162
        """Is the versioned file marked as 'finished' ? Raise if it is."""
 
163
        if self.finished:
 
164
            raise errors.OutSideTransaction()
 
165
        if self._access_mode != 'w':
 
166
            raise errors.ReadOnlyObjectDirtiedError(self)
 
167
 
 
168
    def enable_cache(self):
 
169
        """Tell this versioned file that it should cache any data it reads.
 
170
        
 
171
        This is advisory, implementations do not have to support caching.
 
172
        """
 
173
        pass
 
174
    
 
175
    def clear_cache(self):
 
176
        """Remove any data cached in the versioned file object.
 
177
 
 
178
        This only needs to be supported if caches are supported
 
179
        """
 
180
        pass
 
181
 
 
182
    def clone_text(self, new_version_id, old_version_id, parents):
 
183
        """Add an identical text to old_version_id as new_version_id.
 
184
 
 
185
        Must raise RevisionNotPresent if the old version or any of the
 
186
        parents are not present in file history.
 
187
 
 
188
        Must raise RevisionAlreadyPresent if the new version is
 
189
        already present in file history."""
 
190
        self._check_write_ok()
 
191
        return self._clone_text(new_version_id, old_version_id, parents)
 
192
 
 
193
    def _clone_text(self, new_version_id, old_version_id, parents):
 
194
        """Helper function to do the _clone_text work."""
 
195
        raise NotImplementedError(self.clone_text)
 
196
 
 
197
    def create_empty(self, name, transport, mode=None):
 
198
        """Create a new versioned file of this exact type.
 
199
 
 
200
        :param name: the file name
 
201
        :param transport: the transport
 
202
        :param mode: optional file mode.
 
203
        """
 
204
        raise NotImplementedError(self.create_empty)
 
205
 
342
206
    def get_format_signature(self):
343
207
        """Get a text description of the data encoding in this file.
344
 
 
 
208
        
345
209
        :since: 0.90
346
210
        """
347
211
        raise NotImplementedError(self.get_format_signature)
349
213
    def make_mpdiffs(self, version_ids):
350
214
        """Create multiparent diffs for specified versions."""
351
215
        knit_versions = set()
352
 
        knit_versions.update(version_ids)
353
 
        parent_map = self.get_parent_map(version_ids)
354
216
        for version_id in version_ids:
355
 
            try:
356
 
                knit_versions.update(parent_map[version_id])
357
 
            except KeyError:
358
 
                raise errors.RevisionNotPresent(version_id, self)
359
 
        # We need to filter out ghosts, because we can't diff against them.
360
 
        knit_versions = set(self.get_parent_map(knit_versions).keys())
 
217
            knit_versions.add(version_id)
 
218
            knit_versions.update(self.get_parents(version_id))
361
219
        lines = dict(zip(knit_versions,
362
220
            self._get_lf_split_line_list(knit_versions)))
363
221
        diffs = []
364
222
        for version_id in version_ids:
365
223
            target = lines[version_id]
366
 
            try:
367
 
                parents = [lines[p] for p in parent_map[version_id] if p in
368
 
                    knit_versions]
369
 
            except KeyError:
370
 
                # I don't know how this could ever trigger.
371
 
                # parent_map[version_id] was already triggered in the previous
372
 
                # for loop, and lines[p] has the 'if p in knit_versions' check,
373
 
                # so we again won't have a KeyError.
374
 
                raise errors.RevisionNotPresent(version_id, self)
 
224
            parents = [lines[p] for p in self.get_parents(version_id)]
375
225
            if len(parents) > 0:
376
226
                left_parent_blocks = self._extract_blocks(version_id,
377
227
                                                          parents[0], target)
401
251
        for version, parent_ids, expected_sha1, mpdiff in records:
402
252
            needed_parents.update(p for p in parent_ids
403
253
                                  if not mpvf.has_version(p))
404
 
        present_parents = set(self.get_parent_map(needed_parents).keys())
405
 
        for parent_id, lines in zip(present_parents,
406
 
                                 self._get_lf_split_line_list(present_parents)):
 
254
        for parent_id, lines in zip(needed_parents,
 
255
                                 self._get_lf_split_line_list(needed_parents)):
407
256
            mpvf.add_version(lines, parent_id, [])
408
257
        for (version, parent_ids, expected_sha1, mpdiff), lines in\
409
258
            zip(records, mpvf.get_line_list(versions)):
412
261
                    mpvf.get_diff(parent_ids[0]).num_lines()))
413
262
            else:
414
263
                left_matching_blocks = None
415
 
            try:
416
 
                _, _, version_text = self.add_lines_with_ghosts(version,
417
 
                    parent_ids, lines, vf_parents,
418
 
                    left_matching_blocks=left_matching_blocks)
419
 
            except NotImplementedError:
420
 
                # The vf can't handle ghosts, so add lines normally, which will
421
 
                # (reasonably) fail if there are ghosts in the data.
422
 
                _, _, version_text = self.add_lines(version,
423
 
                    parent_ids, lines, vf_parents,
424
 
                    left_matching_blocks=left_matching_blocks)
 
264
            _, _, version_text = self.add_lines(version, parent_ids, lines,
 
265
                vf_parents, left_matching_blocks=left_matching_blocks)
425
266
            vf_parents[version] = version_text
426
 
        sha1s = self.get_sha1s(versions)
427
 
        for version, parent_ids, expected_sha1, mpdiff in records:
428
 
            if expected_sha1 != sha1s[version]:
 
267
        for (version, parent_ids, expected_sha1, mpdiff), sha1 in\
 
268
             zip(records, self.get_sha1s(versions)):
 
269
            if expected_sha1 != sha1:
429
270
                raise errors.VersionedFileInvalidChecksum(version)
430
271
 
 
272
    def get_sha1(self, version_id):
 
273
        """Get the stored sha1 sum for the given revision.
 
274
        
 
275
        :param version_id: The name of the version to lookup
 
276
        """
 
277
        raise NotImplementedError(self.get_sha1)
 
278
 
 
279
    def get_sha1s(self, version_ids):
 
280
        """Get the stored sha1 sums for the given revisions.
 
281
 
 
282
        :param version_ids: The names of the versions to lookup
 
283
        :return: a list of sha1s in order according to the version_ids
 
284
        """
 
285
        raise NotImplementedError(self.get_sha1s)
 
286
 
 
287
    def get_suffixes(self):
 
288
        """Return the file suffixes associated with this versioned file."""
 
289
        raise NotImplementedError(self.get_suffixes)
 
290
    
431
291
    def get_text(self, version_id):
432
292
        """Return version contents as a text string.
433
293
 
468
328
        if isinstance(version_ids, basestring):
469
329
            version_ids = [version_ids]
470
330
        raise NotImplementedError(self.get_ancestry)
471
 
 
 
331
        
472
332
    def get_ancestry_with_ghosts(self, version_ids):
473
333
        """Return a list of all ancestors of given version(s). This
474
334
        will not include the null revision.
475
335
 
476
336
        Must raise RevisionNotPresent if any of the given versions are
477
337
        not present in file history.
478
 
 
 
338
        
479
339
        Ghosts that are known about will be included in ancestry list,
480
340
        but are not explicitly marked.
481
341
        """
482
342
        raise NotImplementedError(self.get_ancestry_with_ghosts)
483
 
 
484
 
    def get_parent_map(self, version_ids):
485
 
        """Get a map of the parents of version_ids.
486
 
 
487
 
        :param version_ids: The version ids to look up parents for.
488
 
        :return: A mapping from version id to parents.
489
 
        """
490
 
        raise NotImplementedError(self.get_parent_map)
 
343
        
 
344
    def get_graph(self, version_ids=None):
 
345
        """Return a graph from the versioned file. 
 
346
        
 
347
        Ghosts are not listed or referenced in the graph.
 
348
        :param version_ids: Versions to select.
 
349
                            None means retrieve all versions.
 
350
        """
 
351
        if version_ids is None:
 
352
            return dict(self.iter_parents(self.versions()))
 
353
        result = {}
 
354
        pending = set(version_ids)
 
355
        while pending:
 
356
            this_iteration = pending
 
357
            pending = set()
 
358
            for version, parents in self.iter_parents(this_iteration):
 
359
                result[version] = parents
 
360
                for parent in parents:
 
361
                    if parent in result:
 
362
                        continue
 
363
                    pending.add(parent)
 
364
        return result
 
365
 
 
366
    def get_graph_with_ghosts(self):
 
367
        """Return a graph for the entire versioned file.
 
368
        
 
369
        Ghosts are referenced in parents list but are not
 
370
        explicitly listed.
 
371
        """
 
372
        raise NotImplementedError(self.get_graph_with_ghosts)
 
373
 
 
374
    def get_parents(self, version_id):
 
375
        """Return version names for parents of a version.
 
376
 
 
377
        Must raise RevisionNotPresent if version is not present in
 
378
        file history.
 
379
        """
 
380
        raise NotImplementedError(self.get_parents)
491
381
 
492
382
    def get_parents_with_ghosts(self, version_id):
493
383
        """Return version names for parents of version_id.
498
388
        Ghosts that are known about will be included in the parent list,
499
389
        but are not explicitly marked.
500
390
        """
501
 
        try:
502
 
            return list(self.get_parent_map([version_id])[version_id])
503
 
        except KeyError:
504
 
            raise errors.RevisionNotPresent(version_id, self)
 
391
        raise NotImplementedError(self.get_parents_with_ghosts)
 
392
 
 
393
    def annotate_iter(self, version_id):
 
394
        """Yield list of (version-id, line) pairs for the specified
 
395
        version.
 
396
 
 
397
        Must raise RevisionNotPresent if the given version is
 
398
        not present in file history.
 
399
        """
 
400
        raise NotImplementedError(self.annotate_iter)
505
401
 
506
402
    def annotate(self, version_id):
507
 
        """Return a list of (version-id, line) tuples for version_id.
508
 
 
509
 
        :raise RevisionNotPresent: If the given version is
510
 
        not present in file history.
 
403
        return list(self.annotate_iter(version_id))
 
404
 
 
405
    def join(self, other, pb=None, msg=None, version_ids=None,
 
406
             ignore_missing=False):
 
407
        """Integrate versions from other into this versioned file.
 
408
 
 
409
        If version_ids is None all versions from other should be
 
410
        incorporated into this versioned file.
 
411
 
 
412
        Must raise RevisionNotPresent if any of the specified versions
 
413
        are not present in the other file's history unless ignore_missing
 
414
        is supplied in which case they are silently skipped.
511
415
        """
512
 
        raise NotImplementedError(self.annotate)
 
416
        self._check_write_ok()
 
417
        return InterVersionedFile.get(other, self).join(
 
418
            pb,
 
419
            msg,
 
420
            version_ids,
 
421
            ignore_missing)
513
422
 
514
423
    def iter_lines_added_or_present_in_versions(self, version_ids=None,
515
424
                                                pb=None):
533
442
        """
534
443
        raise NotImplementedError(self.iter_lines_added_or_present_in_versions)
535
444
 
 
445
    def iter_parents(self, version_ids):
 
446
        """Iterate through the parents for many version ids.
 
447
 
 
448
        :param version_ids: An iterable yielding version_ids.
 
449
        :return: An iterator that yields (version_id, parents). Requested 
 
450
            version_ids not present in the versioned file are simply skipped.
 
451
            The order is undefined, allowing for different optimisations in
 
452
            the underlying implementation.
 
453
        """
 
454
        for version_id in version_ids:
 
455
            try:
 
456
                yield version_id, tuple(self.get_parents(version_id))
 
457
            except errors.RevisionNotPresent:
 
458
                pass
 
459
 
 
460
    def transaction_finished(self):
 
461
        """The transaction that this file was opened in has finished.
 
462
 
 
463
        This records self.finished = True and should cause all mutating
 
464
        operations to error.
 
465
        """
 
466
        self.finished = True
 
467
 
536
468
    def plan_merge(self, ver_a, ver_b):
537
469
        """Return pseudo-annotation indicating how the two versions merge.
538
470
 
549
481
        unchanged   Alive in both a and b (possibly created in both)
550
482
        new-a       Created in a
551
483
        new-b       Created in b
552
 
        ghost-a     Killed in a, unborn in b
 
484
        ghost-a     Killed in a, unborn in b    
553
485
        ghost-b     Killed in b, unborn in a
554
486
        irrelevant  Not in either revision
555
487
        """
556
488
        raise NotImplementedError(VersionedFile.plan_merge)
557
 
 
 
489
        
558
490
    def weave_merge(self, plan, a_marker=TextMerge.A_MARKER,
559
491
                    b_marker=TextMerge.B_MARKER):
560
492
        return PlanWeaveMerge(plan, a_marker, b_marker).merge_lines()[0]
561
493
 
562
494
 
563
 
class RecordingVersionedFilesDecorator(object):
564
 
    """A minimal versioned files that records calls made on it.
565
 
 
566
 
    Only enough methods have been added to support tests using it to date.
567
 
 
568
 
    :ivar calls: A list of the calls made; can be reset at any time by
569
 
        assigning [] to it.
570
 
    """
571
 
 
572
 
    def __init__(self, backing_vf):
573
 
        """Create a RecordingVersionedFilesDecorator decorating backing_vf.
574
 
 
575
 
        :param backing_vf: The versioned file to answer all methods.
576
 
        """
577
 
        self._backing_vf = backing_vf
578
 
        self.calls = []
579
 
 
580
 
    def add_lines(self, key, parents, lines, parent_texts=None,
581
 
        left_matching_blocks=None, nostore_sha=None, random_id=False,
582
 
        check_content=True):
583
 
        self.calls.append(("add_lines", key, parents, lines, parent_texts,
584
 
            left_matching_blocks, nostore_sha, random_id, check_content))
585
 
        return self._backing_vf.add_lines(key, parents, lines, parent_texts,
586
 
            left_matching_blocks, nostore_sha, random_id, check_content)
587
 
 
588
 
    def check(self):
589
 
        self._backing_vf.check()
590
 
 
591
 
    def get_parent_map(self, keys):
592
 
        self.calls.append(("get_parent_map", copy(keys)))
593
 
        return self._backing_vf.get_parent_map(keys)
594
 
 
595
 
    def get_record_stream(self, keys, sort_order, include_delta_closure):
596
 
        self.calls.append(("get_record_stream", list(keys), sort_order,
597
 
            include_delta_closure))
598
 
        return self._backing_vf.get_record_stream(keys, sort_order,
599
 
            include_delta_closure)
600
 
 
601
 
    def get_sha1s(self, keys):
602
 
        self.calls.append(("get_sha1s", copy(keys)))
603
 
        return self._backing_vf.get_sha1s(keys)
604
 
 
605
 
    def iter_lines_added_or_present_in_keys(self, keys, pb=None):
606
 
        self.calls.append(("iter_lines_added_or_present_in_keys", copy(keys)))
607
 
        return self._backing_vf.iter_lines_added_or_present_in_keys(keys, pb=pb)
608
 
 
609
 
    def keys(self):
610
 
        self.calls.append(("keys",))
611
 
        return self._backing_vf.keys()
612
 
 
613
 
 
614
 
class OrderingVersionedFilesDecorator(RecordingVersionedFilesDecorator):
615
 
    """A VF that records calls, and returns keys in specific order.
616
 
 
617
 
    :ivar calls: A list of the calls made; can be reset at any time by
618
 
        assigning [] to it.
619
 
    """
620
 
 
621
 
    def __init__(self, backing_vf, key_priority):
622
 
        """Create a RecordingVersionedFilesDecorator decorating backing_vf.
623
 
 
624
 
        :param backing_vf: The versioned file to answer all methods.
625
 
        :param key_priority: A dictionary defining what order keys should be
626
 
            returned from an 'unordered' get_record_stream request.
627
 
            Keys with lower priority are returned first, keys not present in
628
 
            the map get an implicit priority of 0, and are returned in
629
 
            lexicographical order.
630
 
        """
631
 
        RecordingVersionedFilesDecorator.__init__(self, backing_vf)
632
 
        self._key_priority = key_priority
633
 
 
634
 
    def get_record_stream(self, keys, sort_order, include_delta_closure):
635
 
        self.calls.append(("get_record_stream", list(keys), sort_order,
636
 
            include_delta_closure))
637
 
        if sort_order == 'unordered':
638
 
            def sort_key(key):
639
 
                return (self._key_priority.get(key, 0), key)
640
 
            # Use a defined order by asking for the keys one-by-one from the
641
 
            # backing_vf
642
 
            for key in sorted(keys, key=sort_key):
643
 
                for record in self._backing_vf.get_record_stream([key],
644
 
                                'unordered', include_delta_closure):
645
 
                    yield record
646
 
        else:
647
 
            for record in self._backing_vf.get_record_stream(keys, sort_order,
648
 
                            include_delta_closure):
649
 
                yield record
650
 
 
651
 
 
652
 
class KeyMapper(object):
653
 
    """KeyMappers map between keys and underlying partitioned storage."""
654
 
 
655
 
    def map(self, key):
656
 
        """Map key to an underlying storage identifier.
657
 
 
658
 
        :param key: A key tuple e.g. ('file-id', 'revision-id').
659
 
        :return: An underlying storage identifier, specific to the partitioning
660
 
            mechanism.
661
 
        """
662
 
        raise NotImplementedError(self.map)
663
 
 
664
 
    def unmap(self, partition_id):
665
 
        """Map a partitioned storage id back to a key prefix.
666
 
 
667
 
        :param partition_id: The underlying partition id.
668
 
        :return: As much of a key (or prefix) as is derivable from the partition
669
 
            id.
670
 
        """
671
 
        raise NotImplementedError(self.unmap)
672
 
 
673
 
 
674
 
class ConstantMapper(KeyMapper):
675
 
    """A key mapper that maps to a constant result."""
676
 
 
677
 
    def __init__(self, result):
678
 
        """Create a ConstantMapper which will return result for all maps."""
679
 
        self._result = result
680
 
 
681
 
    def map(self, key):
682
 
        """See KeyMapper.map()."""
683
 
        return self._result
684
 
 
685
 
 
686
 
class URLEscapeMapper(KeyMapper):
687
 
    """Base class for use with transport backed storage.
688
 
 
689
 
    This provides a map and unmap wrapper that respectively url escape and
690
 
    unescape their outputs and inputs.
691
 
    """
692
 
 
693
 
    def map(self, key):
694
 
        """See KeyMapper.map()."""
695
 
        return urllib.quote(self._map(key))
696
 
 
697
 
    def unmap(self, partition_id):
698
 
        """See KeyMapper.unmap()."""
699
 
        return self._unmap(urllib.unquote(partition_id))
700
 
 
701
 
 
702
 
class PrefixMapper(URLEscapeMapper):
703
 
    """A key mapper that extracts the first component of a key.
704
 
 
705
 
    This mapper is for use with a transport based backend.
706
 
    """
707
 
 
708
 
    def _map(self, key):
709
 
        """See KeyMapper.map()."""
710
 
        return key[0]
711
 
 
712
 
    def _unmap(self, partition_id):
713
 
        """See KeyMapper.unmap()."""
714
 
        return (partition_id,)
715
 
 
716
 
 
717
 
class HashPrefixMapper(URLEscapeMapper):
718
 
    """A key mapper that combines the first component of a key with a hash.
719
 
 
720
 
    This mapper is for use with a transport based backend.
721
 
    """
722
 
 
723
 
    def _map(self, key):
724
 
        """See KeyMapper.map()."""
725
 
        prefix = self._escape(key[0])
726
 
        return "%02x/%s" % (adler32(prefix) & 0xff, prefix)
727
 
 
728
 
    def _escape(self, prefix):
729
 
        """No escaping needed here."""
730
 
        return prefix
731
 
 
732
 
    def _unmap(self, partition_id):
733
 
        """See KeyMapper.unmap()."""
734
 
        return (self._unescape(osutils.basename(partition_id)),)
735
 
 
736
 
    def _unescape(self, basename):
737
 
        """No unescaping needed for HashPrefixMapper."""
738
 
        return basename
739
 
 
740
 
 
741
 
class HashEscapedPrefixMapper(HashPrefixMapper):
742
 
    """Combines the escaped first component of a key with a hash.
743
 
 
744
 
    This mapper is for use with a transport based backend.
745
 
    """
746
 
 
747
 
    _safe = "abcdefghijklmnopqrstuvwxyz0123456789-_@,."
748
 
 
749
 
    def _escape(self, prefix):
750
 
        """Turn a key element into a filesystem safe string.
751
 
 
752
 
        This is similar to a plain urllib.quote, except
753
 
        it uses specific safe characters, so that it doesn't
754
 
        have to translate a lot of valid file ids.
755
 
        """
756
 
        # @ does not get escaped. This is because it is a valid
757
 
        # filesystem character we use all the time, and it looks
758
 
        # a lot better than seeing %40 all the time.
759
 
        r = [((c in self._safe) and c or ('%%%02x' % ord(c)))
760
 
             for c in prefix]
761
 
        return ''.join(r)
762
 
 
763
 
    def _unescape(self, basename):
764
 
        """Escaped names are easily unescaped by urlutils."""
765
 
        return urllib.unquote(basename)
766
 
 
767
 
 
768
 
def make_versioned_files_factory(versioned_file_factory, mapper):
769
 
    """Create a ThunkedVersionedFiles factory.
770
 
 
771
 
    This will create a callable which when called creates a
772
 
    ThunkedVersionedFiles on a transport, using mapper to access individual
773
 
    versioned files, and versioned_file_factory to create each individual file.
774
 
    """
775
 
    def factory(transport):
776
 
        return ThunkedVersionedFiles(transport, versioned_file_factory, mapper,
777
 
            lambda:True)
778
 
    return factory
779
 
 
780
 
 
781
 
class VersionedFiles(object):
782
 
    """Storage for many versioned files.
783
 
 
784
 
    This object allows a single keyspace for accessing the history graph and
785
 
    contents of named bytestrings.
786
 
 
787
 
    Currently no implementation allows the graph of different key prefixes to
788
 
    intersect, but the API does allow such implementations in the future.
789
 
 
790
 
    The keyspace is expressed via simple tuples. Any instance of VersionedFiles
791
 
    may have a different length key-size, but that size will be constant for
792
 
    all texts added to or retrieved from it. For instance, bzrlib uses
793
 
    instances with a key-size of 2 for storing user files in a repository, with
794
 
    the first element the fileid, and the second the version of that file.
795
 
 
796
 
    The use of tuples allows a single code base to support several different
797
 
    uses with only the mapping logic changing from instance to instance.
798
 
    """
799
 
 
800
 
    def add_lines(self, key, parents, lines, parent_texts=None,
801
 
        left_matching_blocks=None, nostore_sha=None, random_id=False,
802
 
        check_content=True):
803
 
        """Add a text to the store.
804
 
 
805
 
        :param key: The key tuple of the text to add. If the last element is
806
 
            None, a CHK string will be generated during the addition.
807
 
        :param parents: The parents key tuples of the text to add.
808
 
        :param lines: A list of lines. Each line must be a bytestring. And all
809
 
            of them except the last must be terminated with \n and contain no
810
 
            other \n's. The last line may either contain no \n's or a single
811
 
            terminating \n. If the lines list does meet this constraint the add
812
 
            routine may error or may succeed - but you will be unable to read
813
 
            the data back accurately. (Checking the lines have been split
814
 
            correctly is expensive and extremely unlikely to catch bugs so it
815
 
            is not done at runtime unless check_content is True.)
816
 
        :param parent_texts: An optional dictionary containing the opaque
817
 
            representations of some or all of the parents of version_id to
818
 
            allow delta optimisations.  VERY IMPORTANT: the texts must be those
819
 
            returned by add_lines or data corruption can be caused.
820
 
        :param left_matching_blocks: a hint about which areas are common
821
 
            between the text and its left-hand-parent.  The format is
822
 
            the SequenceMatcher.get_matching_blocks format.
823
 
        :param nostore_sha: Raise ExistingContent and do not add the lines to
824
 
            the versioned file if the digest of the lines matches this.
825
 
        :param random_id: If True a random id has been selected rather than
826
 
            an id determined by some deterministic process such as a converter
827
 
            from a foreign VCS. When True the backend may choose not to check
828
 
            for uniqueness of the resulting key within the versioned file, so
829
 
            this should only be done when the result is expected to be unique
830
 
            anyway.
831
 
        :param check_content: If True, the lines supplied are verified to be
832
 
            bytestrings that are correctly formed lines.
833
 
        :return: The text sha1, the number of bytes in the text, and an opaque
834
 
                 representation of the inserted version which can be provided
835
 
                 back to future add_lines calls in the parent_texts dictionary.
836
 
        """
837
 
        raise NotImplementedError(self.add_lines)
838
 
 
839
 
    def _add_text(self, key, parents, text, nostore_sha=None, random_id=False):
840
 
        """Add a text to the store.
841
 
 
842
 
        This is a private function for use by CommitBuilder.
843
 
 
844
 
        :param key: The key tuple of the text to add. If the last element is
845
 
            None, a CHK string will be generated during the addition.
846
 
        :param parents: The parents key tuples of the text to add.
847
 
        :param text: A string containing the text to be committed.
848
 
        :param nostore_sha: Raise ExistingContent and do not add the lines to
849
 
            the versioned file if the digest of the lines matches this.
850
 
        :param random_id: If True a random id has been selected rather than
851
 
            an id determined by some deterministic process such as a converter
852
 
            from a foreign VCS. When True the backend may choose not to check
853
 
            for uniqueness of the resulting key within the versioned file, so
854
 
            this should only be done when the result is expected to be unique
855
 
            anyway.
856
 
        :param check_content: If True, the lines supplied are verified to be
857
 
            bytestrings that are correctly formed lines.
858
 
        :return: The text sha1, the number of bytes in the text, and an opaque
859
 
                 representation of the inserted version which can be provided
860
 
                 back to future _add_text calls in the parent_texts dictionary.
861
 
        """
862
 
        # The default implementation just thunks over to .add_lines(),
863
 
        # inefficient, but it works.
864
 
        return self.add_lines(key, parents, osutils.split_lines(text),
865
 
                              nostore_sha=nostore_sha,
866
 
                              random_id=random_id,
867
 
                              check_content=True)
868
 
 
869
 
    def add_mpdiffs(self, records):
870
 
        """Add mpdiffs to this VersionedFile.
871
 
 
872
 
        Records should be iterables of version, parents, expected_sha1,
873
 
        mpdiff. mpdiff should be a MultiParent instance.
874
 
        """
875
 
        vf_parents = {}
876
 
        mpvf = multiparent.MultiMemoryVersionedFile()
877
 
        versions = []
878
 
        for version, parent_ids, expected_sha1, mpdiff in records:
879
 
            versions.append(version)
880
 
            mpvf.add_diff(mpdiff, version, parent_ids)
881
 
        needed_parents = set()
882
 
        for version, parent_ids, expected_sha1, mpdiff in records:
883
 
            needed_parents.update(p for p in parent_ids
884
 
                                  if not mpvf.has_version(p))
885
 
        # It seems likely that adding all the present parents as fulltexts can
886
 
        # easily exhaust memory.
887
 
        chunks_to_lines = osutils.chunks_to_lines
888
 
        for record in self.get_record_stream(needed_parents, 'unordered',
889
 
            True):
890
 
            if record.storage_kind == 'absent':
891
 
                continue
892
 
            mpvf.add_version(chunks_to_lines(record.get_bytes_as('chunked')),
893
 
                record.key, [])
894
 
        for (key, parent_keys, expected_sha1, mpdiff), lines in\
895
 
            zip(records, mpvf.get_line_list(versions)):
896
 
            if len(parent_keys) == 1:
897
 
                left_matching_blocks = list(mpdiff.get_matching_blocks(0,
898
 
                    mpvf.get_diff(parent_keys[0]).num_lines()))
899
 
            else:
900
 
                left_matching_blocks = None
901
 
            version_sha1, _, version_text = self.add_lines(key,
902
 
                parent_keys, lines, vf_parents,
903
 
                left_matching_blocks=left_matching_blocks)
904
 
            if version_sha1 != expected_sha1:
905
 
                raise errors.VersionedFileInvalidChecksum(version)
906
 
            vf_parents[key] = version_text
907
 
 
908
 
    def annotate(self, key):
909
 
        """Return a list of (version-key, line) tuples for the text of key.
910
 
 
911
 
        :raise RevisionNotPresent: If the key is not present.
912
 
        """
913
 
        raise NotImplementedError(self.annotate)
914
 
 
915
 
    def check(self, progress_bar=None):
916
 
        """Check this object for integrity.
917
 
        
918
 
        :param progress_bar: A progress bar to output as the check progresses.
919
 
        :param keys: Specific keys within the VersionedFiles to check. When
920
 
            this parameter is not None, check() becomes a generator as per
921
 
            get_record_stream. The difference to get_record_stream is that
922
 
            more or deeper checks will be performed.
923
 
        :return: None, or if keys was supplied a generator as per
924
 
            get_record_stream.
925
 
        """
926
 
        raise NotImplementedError(self.check)
927
 
 
928
 
    @staticmethod
929
 
    def check_not_reserved_id(version_id):
930
 
        revision.check_not_reserved_id(version_id)
931
 
 
932
 
    def clear_cache(self):
933
 
        """Clear whatever caches this VersionedFile holds.
934
 
 
935
 
        This is generally called after an operation has been performed, when we
936
 
        don't expect to be using this versioned file again soon.
937
 
        """
938
 
 
939
 
    def _check_lines_not_unicode(self, lines):
940
 
        """Check that lines being added to a versioned file are not unicode."""
941
 
        for line in lines:
942
 
            if line.__class__ is not str:
943
 
                raise errors.BzrBadParameterUnicode("lines")
944
 
 
945
 
    def _check_lines_are_lines(self, lines):
946
 
        """Check that the lines really are full lines without inline EOL."""
947
 
        for line in lines:
948
 
            if '\n' in line[:-1]:
949
 
                raise errors.BzrBadParameterContainsNewline("lines")
950
 
 
951
 
    def get_known_graph_ancestry(self, keys):
952
 
        """Get a KnownGraph instance with the ancestry of keys."""
953
 
        # most basic implementation is a loop around get_parent_map
954
 
        pending = set(keys)
955
 
        parent_map = {}
956
 
        while pending:
957
 
            this_parent_map = self.get_parent_map(pending)
958
 
            parent_map.update(this_parent_map)
959
 
            pending = set()
960
 
            map(pending.update, this_parent_map.itervalues())
961
 
            pending = pending.difference(parent_map)
962
 
        kg = _mod_graph.KnownGraph(parent_map)
963
 
        return kg
964
 
 
965
 
    def get_parent_map(self, keys):
966
 
        """Get a map of the parents of keys.
967
 
 
968
 
        :param keys: The keys to look up parents for.
969
 
        :return: A mapping from keys to parents. Absent keys are absent from
970
 
            the mapping.
971
 
        """
972
 
        raise NotImplementedError(self.get_parent_map)
973
 
 
974
 
    def get_record_stream(self, keys, ordering, include_delta_closure):
975
 
        """Get a stream of records for keys.
976
 
 
977
 
        :param keys: The keys to include.
978
 
        :param ordering: Either 'unordered' or 'topological'. A topologically
979
 
            sorted stream has compression parents strictly before their
980
 
            children.
981
 
        :param include_delta_closure: If True then the closure across any
982
 
            compression parents will be included (in the opaque data).
983
 
        :return: An iterator of ContentFactory objects, each of which is only
984
 
            valid until the iterator is advanced.
985
 
        """
986
 
        raise NotImplementedError(self.get_record_stream)
987
 
 
988
 
    def get_sha1s(self, keys):
989
 
        """Get the sha1's of the texts for the given keys.
990
 
 
991
 
        :param keys: The names of the keys to lookup
992
 
        :return: a dict from key to sha1 digest. Keys of texts which are not
993
 
            present in the store are not present in the returned
994
 
            dictionary.
995
 
        """
996
 
        raise NotImplementedError(self.get_sha1s)
997
 
 
998
 
    has_key = index._has_key_from_parent_map
999
 
 
1000
 
    def get_missing_compression_parent_keys(self):
1001
 
        """Return an iterable of keys of missing compression parents.
1002
 
 
1003
 
        Check this after calling insert_record_stream to find out if there are
1004
 
        any missing compression parents.  If there are, the records that
1005
 
        depend on them are not able to be inserted safely. The precise
1006
 
        behaviour depends on the concrete VersionedFiles class in use.
1007
 
 
1008
 
        Classes that do not support this will raise NotImplementedError.
1009
 
        """
1010
 
        raise NotImplementedError(self.get_missing_compression_parent_keys)
1011
 
 
1012
 
    def insert_record_stream(self, stream):
1013
 
        """Insert a record stream into this container.
1014
 
 
1015
 
        :param stream: A stream of records to insert.
1016
 
        :return: None
1017
 
        :seealso VersionedFile.get_record_stream:
1018
 
        """
1019
 
        raise NotImplementedError
1020
 
 
1021
 
    def iter_lines_added_or_present_in_keys(self, keys, pb=None):
1022
 
        """Iterate over the lines in the versioned files from keys.
1023
 
 
1024
 
        This may return lines from other keys. Each item the returned
1025
 
        iterator yields is a tuple of a line and a text version that that line
1026
 
        is present in (not introduced in).
1027
 
 
1028
 
        Ordering of results is in whatever order is most suitable for the
1029
 
        underlying storage format.
1030
 
 
1031
 
        If a progress bar is supplied, it may be used to indicate progress.
1032
 
        The caller is responsible for cleaning up progress bars (because this
1033
 
        is an iterator).
1034
 
 
1035
 
        NOTES:
1036
 
         * Lines are normalised by the underlying store: they will all have \n
1037
 
           terminators.
1038
 
         * Lines are returned in arbitrary order.
1039
 
 
1040
 
        :return: An iterator over (line, key).
1041
 
        """
1042
 
        raise NotImplementedError(self.iter_lines_added_or_present_in_keys)
1043
 
 
1044
 
    def keys(self):
1045
 
        """Return a iterable of the keys for all the contained texts."""
1046
 
        raise NotImplementedError(self.keys)
1047
 
 
1048
 
    def make_mpdiffs(self, keys):
1049
 
        """Create multiparent diffs for specified keys."""
1050
 
        keys_order = tuple(keys)
1051
 
        keys = frozenset(keys)
1052
 
        knit_keys = set(keys)
1053
 
        parent_map = self.get_parent_map(keys)
1054
 
        for parent_keys in parent_map.itervalues():
1055
 
            if parent_keys:
1056
 
                knit_keys.update(parent_keys)
1057
 
        missing_keys = keys - set(parent_map)
1058
 
        if missing_keys:
1059
 
            raise errors.RevisionNotPresent(list(missing_keys)[0], self)
1060
 
        # We need to filter out ghosts, because we can't diff against them.
1061
 
        maybe_ghosts = knit_keys - keys
1062
 
        ghosts = maybe_ghosts - set(self.get_parent_map(maybe_ghosts))
1063
 
        knit_keys.difference_update(ghosts)
1064
 
        lines = {}
1065
 
        chunks_to_lines = osutils.chunks_to_lines
1066
 
        for record in self.get_record_stream(knit_keys, 'topological', True):
1067
 
            lines[record.key] = chunks_to_lines(record.get_bytes_as('chunked'))
1068
 
            # line_block_dict = {}
1069
 
            # for parent, blocks in record.extract_line_blocks():
1070
 
            #   line_blocks[parent] = blocks
1071
 
            # line_blocks[record.key] = line_block_dict
1072
 
        diffs = []
1073
 
        for key in keys_order:
1074
 
            target = lines[key]
1075
 
            parents = parent_map[key] or []
1076
 
            # Note that filtering knit_keys can lead to a parent difference
1077
 
            # between the creation and the application of the mpdiff.
1078
 
            parent_lines = [lines[p] for p in parents if p in knit_keys]
1079
 
            if len(parent_lines) > 0:
1080
 
                left_parent_blocks = self._extract_blocks(key, parent_lines[0],
1081
 
                    target)
1082
 
            else:
1083
 
                left_parent_blocks = None
1084
 
            diffs.append(multiparent.MultiParent.from_lines(target,
1085
 
                parent_lines, left_parent_blocks))
1086
 
        return diffs
1087
 
 
1088
 
    missing_keys = index._missing_keys_from_parent_map
1089
 
 
1090
 
    def _extract_blocks(self, version_id, source, target):
1091
 
        return None
1092
 
 
1093
 
 
1094
 
class ThunkedVersionedFiles(VersionedFiles):
1095
 
    """Storage for many versioned files thunked onto a 'VersionedFile' class.
1096
 
 
1097
 
    This object allows a single keyspace for accessing the history graph and
1098
 
    contents of named bytestrings.
1099
 
 
1100
 
    Currently no implementation allows the graph of different key prefixes to
1101
 
    intersect, but the API does allow such implementations in the future.
1102
 
    """
1103
 
 
1104
 
    def __init__(self, transport, file_factory, mapper, is_locked):
1105
 
        """Create a ThunkedVersionedFiles."""
1106
 
        self._transport = transport
1107
 
        self._file_factory = file_factory
1108
 
        self._mapper = mapper
1109
 
        self._is_locked = is_locked
1110
 
 
1111
 
    def add_lines(self, key, parents, lines, parent_texts=None,
1112
 
        left_matching_blocks=None, nostore_sha=None, random_id=False,
1113
 
        check_content=True):
1114
 
        """See VersionedFiles.add_lines()."""
1115
 
        path = self._mapper.map(key)
1116
 
        version_id = key[-1]
1117
 
        parents = [parent[-1] for parent in parents]
1118
 
        vf = self._get_vf(path)
1119
 
        try:
1120
 
            try:
1121
 
                return vf.add_lines_with_ghosts(version_id, parents, lines,
1122
 
                    parent_texts=parent_texts,
1123
 
                    left_matching_blocks=left_matching_blocks,
1124
 
                    nostore_sha=nostore_sha, random_id=random_id,
1125
 
                    check_content=check_content)
1126
 
            except NotImplementedError:
1127
 
                return vf.add_lines(version_id, parents, lines,
1128
 
                    parent_texts=parent_texts,
1129
 
                    left_matching_blocks=left_matching_blocks,
1130
 
                    nostore_sha=nostore_sha, random_id=random_id,
1131
 
                    check_content=check_content)
1132
 
        except errors.NoSuchFile:
1133
 
            # parent directory may be missing, try again.
1134
 
            self._transport.mkdir(osutils.dirname(path))
1135
 
            try:
1136
 
                return vf.add_lines_with_ghosts(version_id, parents, lines,
1137
 
                    parent_texts=parent_texts,
1138
 
                    left_matching_blocks=left_matching_blocks,
1139
 
                    nostore_sha=nostore_sha, random_id=random_id,
1140
 
                    check_content=check_content)
1141
 
            except NotImplementedError:
1142
 
                return vf.add_lines(version_id, parents, lines,
1143
 
                    parent_texts=parent_texts,
1144
 
                    left_matching_blocks=left_matching_blocks,
1145
 
                    nostore_sha=nostore_sha, random_id=random_id,
1146
 
                    check_content=check_content)
1147
 
 
1148
 
    def annotate(self, key):
1149
 
        """Return a list of (version-key, line) tuples for the text of key.
1150
 
 
1151
 
        :raise RevisionNotPresent: If the key is not present.
1152
 
        """
1153
 
        prefix = key[:-1]
1154
 
        path = self._mapper.map(prefix)
1155
 
        vf = self._get_vf(path)
1156
 
        origins = vf.annotate(key[-1])
1157
 
        result = []
1158
 
        for origin, line in origins:
1159
 
            result.append((prefix + (origin,), line))
1160
 
        return result
1161
 
 
1162
 
    def get_annotator(self):
1163
 
        return annotate.Annotator(self)
1164
 
 
1165
 
    def check(self, progress_bar=None, keys=None):
1166
 
        """See VersionedFiles.check()."""
1167
 
        # XXX: This is over-enthusiastic but as we only thunk for Weaves today
1168
 
        # this is tolerable. Ideally we'd pass keys down to check() and 
1169
 
        # have the older VersiondFile interface updated too.
1170
 
        for prefix, vf in self._iter_all_components():
1171
 
            vf.check()
1172
 
        if keys is not None:
1173
 
            return self.get_record_stream(keys, 'unordered', True)
1174
 
 
1175
 
    def get_parent_map(self, keys):
1176
 
        """Get a map of the parents of keys.
1177
 
 
1178
 
        :param keys: The keys to look up parents for.
1179
 
        :return: A mapping from keys to parents. Absent keys are absent from
1180
 
            the mapping.
1181
 
        """
1182
 
        prefixes = self._partition_keys(keys)
1183
 
        result = {}
1184
 
        for prefix, suffixes in prefixes.items():
1185
 
            path = self._mapper.map(prefix)
1186
 
            vf = self._get_vf(path)
1187
 
            parent_map = vf.get_parent_map(suffixes)
1188
 
            for key, parents in parent_map.items():
1189
 
                result[prefix + (key,)] = tuple(
1190
 
                    prefix + (parent,) for parent in parents)
1191
 
        return result
1192
 
 
1193
 
    def _get_vf(self, path):
1194
 
        if not self._is_locked():
1195
 
            raise errors.ObjectNotLocked(self)
1196
 
        return self._file_factory(path, self._transport, create=True,
1197
 
            get_scope=lambda:None)
1198
 
 
1199
 
    def _partition_keys(self, keys):
1200
 
        """Turn keys into a dict of prefix:suffix_list."""
1201
 
        result = {}
1202
 
        for key in keys:
1203
 
            prefix_keys = result.setdefault(key[:-1], [])
1204
 
            prefix_keys.append(key[-1])
1205
 
        return result
1206
 
 
1207
 
    def _get_all_prefixes(self):
1208
 
        # Identify all key prefixes.
1209
 
        # XXX: A bit hacky, needs polish.
1210
 
        if type(self._mapper) == ConstantMapper:
1211
 
            paths = [self._mapper.map(())]
1212
 
            prefixes = [()]
1213
 
        else:
1214
 
            relpaths = set()
1215
 
            for quoted_relpath in self._transport.iter_files_recursive():
1216
 
                path, ext = os.path.splitext(quoted_relpath)
1217
 
                relpaths.add(path)
1218
 
            paths = list(relpaths)
1219
 
            prefixes = [self._mapper.unmap(path) for path in paths]
1220
 
        return zip(paths, prefixes)
1221
 
 
1222
 
    def get_record_stream(self, keys, ordering, include_delta_closure):
1223
 
        """See VersionedFiles.get_record_stream()."""
1224
 
        # Ordering will be taken care of by each partitioned store; group keys
1225
 
        # by partition.
1226
 
        keys = sorted(keys)
1227
 
        for prefix, suffixes, vf in self._iter_keys_vf(keys):
1228
 
            suffixes = [(suffix,) for suffix in suffixes]
1229
 
            for record in vf.get_record_stream(suffixes, ordering,
1230
 
                include_delta_closure):
1231
 
                if record.parents is not None:
1232
 
                    record.parents = tuple(
1233
 
                        prefix + parent for parent in record.parents)
1234
 
                record.key = prefix + record.key
1235
 
                yield record
1236
 
 
1237
 
    def _iter_keys_vf(self, keys):
1238
 
        prefixes = self._partition_keys(keys)
1239
 
        sha1s = {}
1240
 
        for prefix, suffixes in prefixes.items():
1241
 
            path = self._mapper.map(prefix)
1242
 
            vf = self._get_vf(path)
1243
 
            yield prefix, suffixes, vf
1244
 
 
1245
 
    def get_sha1s(self, keys):
1246
 
        """See VersionedFiles.get_sha1s()."""
1247
 
        sha1s = {}
1248
 
        for prefix,suffixes, vf in self._iter_keys_vf(keys):
1249
 
            vf_sha1s = vf.get_sha1s(suffixes)
1250
 
            for suffix, sha1 in vf_sha1s.iteritems():
1251
 
                sha1s[prefix + (suffix,)] = sha1
1252
 
        return sha1s
1253
 
 
1254
 
    def insert_record_stream(self, stream):
1255
 
        """Insert a record stream into this container.
1256
 
 
1257
 
        :param stream: A stream of records to insert.
1258
 
        :return: None
1259
 
        :seealso VersionedFile.get_record_stream:
1260
 
        """
1261
 
        for record in stream:
1262
 
            prefix = record.key[:-1]
1263
 
            key = record.key[-1:]
1264
 
            if record.parents is not None:
1265
 
                parents = [parent[-1:] for parent in record.parents]
1266
 
            else:
1267
 
                parents = None
1268
 
            thunk_record = AdapterFactory(key, parents, record)
1269
 
            path = self._mapper.map(prefix)
1270
 
            # Note that this parses the file many times; we can do better but
1271
 
            # as this only impacts weaves in terms of performance, it is
1272
 
            # tolerable.
1273
 
            vf = self._get_vf(path)
1274
 
            vf.insert_record_stream([thunk_record])
1275
 
 
1276
 
    def iter_lines_added_or_present_in_keys(self, keys, pb=None):
1277
 
        """Iterate over the lines in the versioned files from keys.
1278
 
 
1279
 
        This may return lines from other keys. Each item the returned
1280
 
        iterator yields is a tuple of a line and a text version that that line
1281
 
        is present in (not introduced in).
1282
 
 
1283
 
        Ordering of results is in whatever order is most suitable for the
1284
 
        underlying storage format.
1285
 
 
1286
 
        If a progress bar is supplied, it may be used to indicate progress.
1287
 
        The caller is responsible for cleaning up progress bars (because this
1288
 
        is an iterator).
1289
 
 
1290
 
        NOTES:
1291
 
         * Lines are normalised by the underlying store: they will all have \n
1292
 
           terminators.
1293
 
         * Lines are returned in arbitrary order.
1294
 
 
1295
 
        :return: An iterator over (line, key).
1296
 
        """
1297
 
        for prefix, suffixes, vf in self._iter_keys_vf(keys):
1298
 
            for line, version in vf.iter_lines_added_or_present_in_versions(suffixes):
1299
 
                yield line, prefix + (version,)
1300
 
 
1301
 
    def _iter_all_components(self):
1302
 
        for path, prefix in self._get_all_prefixes():
1303
 
            yield prefix, self._get_vf(path)
1304
 
 
1305
 
    def keys(self):
1306
 
        """See VersionedFiles.keys()."""
1307
 
        result = set()
1308
 
        for prefix, vf in self._iter_all_components():
1309
 
            for suffix in vf.versions():
1310
 
                result.add(prefix + (suffix,))
1311
 
        return result
1312
 
 
1313
 
 
1314
 
class _PlanMergeVersionedFile(VersionedFiles):
 
495
class _PlanMergeVersionedFile(object):
1315
496
    """A VersionedFile for uncommitted and committed texts.
1316
497
 
1317
498
    It is intended to allow merges to be planned with working tree texts.
1318
 
    It implements only the small part of the VersionedFiles interface used by
 
499
    It implements only the small part of the VersionedFile interface used by
1319
500
    PlanMerge.  It falls back to multiple versionedfiles for data not stored in
1320
501
    _PlanMergeVersionedFile itself.
1321
 
 
1322
 
    :ivar: fallback_versionedfiles a list of VersionedFiles objects that can be
1323
 
        queried for missing texts.
1324
502
    """
1325
503
 
1326
 
    def __init__(self, file_id):
1327
 
        """Create a _PlanMergeVersionedFile.
 
504
    def __init__(self, file_id, fallback_versionedfiles=None):
 
505
        """Constuctor
1328
506
 
1329
 
        :param file_id: Used with _PlanMerge code which is not yet fully
1330
 
            tuple-keyspace aware.
 
507
        :param file_id: Used when raising exceptions.
 
508
        :param fallback_versionedfiles: If supplied, the set of fallbacks to
 
509
            use.  Otherwise, _PlanMergeVersionedFile.fallback_versionedfiles
 
510
            can be appended to later.
1331
511
        """
1332
512
        self._file_id = file_id
1333
 
        # fallback locations
1334
 
        self.fallback_versionedfiles = []
1335
 
        # Parents for locally held keys.
 
513
        if fallback_versionedfiles is None:
 
514
            self.fallback_versionedfiles = []
 
515
        else:
 
516
            self.fallback_versionedfiles = fallback_versionedfiles
1336
517
        self._parents = {}
1337
 
        # line data for locally held keys.
1338
518
        self._lines = {}
1339
 
        # key lookup providers
1340
 
        self._providers = [DictParentsProvider(self._parents)]
1341
519
 
1342
 
    def plan_merge(self, ver_a, ver_b, base=None):
 
520
    def plan_merge(self, ver_a, ver_b):
1343
521
        """See VersionedFile.plan_merge"""
1344
 
        from bzrlib.merge import _PlanMerge
1345
 
        if base is None:
1346
 
            return _PlanMerge(ver_a, ver_b, self, (self._file_id,)).plan_merge()
1347
 
        old_plan = list(_PlanMerge(ver_a, base, self, (self._file_id,)).plan_merge())
1348
 
        new_plan = list(_PlanMerge(ver_a, ver_b, self, (self._file_id,)).plan_merge())
1349
 
        return _PlanMerge._subtract_plans(old_plan, new_plan)
1350
 
 
1351
 
    def plan_lca_merge(self, ver_a, ver_b, base=None):
1352
 
        from bzrlib.merge import _PlanLCAMerge
1353
 
        graph = Graph(self)
1354
 
        new_plan = _PlanLCAMerge(ver_a, ver_b, self, (self._file_id,), graph).plan_merge()
1355
 
        if base is None:
1356
 
            return new_plan
1357
 
        old_plan = _PlanLCAMerge(ver_a, base, self, (self._file_id,), graph).plan_merge()
1358
 
        return _PlanLCAMerge._subtract_plans(list(old_plan), list(new_plan))
1359
 
 
1360
 
    def add_lines(self, key, parents, lines):
1361
 
        """See VersionedFiles.add_lines
1362
 
 
1363
 
        Lines are added locally, not to fallback versionedfiles.  Also, ghosts
1364
 
        are permitted.  Only reserved ids are permitted.
 
522
        from merge import _PlanMerge
 
523
        return _PlanMerge(ver_a, ver_b, self).plan_merge()
 
524
 
 
525
    def add_lines(self, version_id, parents, lines):
 
526
        """See VersionedFile.add_lines
 
527
 
 
528
        Lines are added locally, not fallback versionedfiles.  Also, ghosts are
 
529
        permitted.  Only reserved ids are permitted.
1365
530
        """
1366
 
        if type(key) is not tuple:
1367
 
            raise TypeError(key)
1368
 
        if not revision.is_reserved_id(key[-1]):
 
531
        if not revision.is_reserved_id(version_id):
1369
532
            raise ValueError('Only reserved ids may be used')
1370
533
        if parents is None:
1371
534
            raise ValueError('Parents may not be None')
1372
535
        if lines is None:
1373
536
            raise ValueError('Lines may not be None')
1374
 
        self._parents[key] = tuple(parents)
1375
 
        self._lines[key] = lines
 
537
        self._parents[version_id] = parents
 
538
        self._lines[version_id] = lines
1376
539
 
1377
 
    def get_record_stream(self, keys, ordering, include_delta_closure):
1378
 
        pending = set(keys)
1379
 
        for key in keys:
1380
 
            if key in self._lines:
1381
 
                lines = self._lines[key]
1382
 
                parents = self._parents[key]
1383
 
                pending.remove(key)
1384
 
                yield ChunkedContentFactory(key, parents, None, lines)
 
540
    def get_lines(self, version_id):
 
541
        """See VersionedFile.get_ancestry"""
 
542
        lines = self._lines.get(version_id)
 
543
        if lines is not None:
 
544
            return lines
1385
545
        for versionedfile in self.fallback_versionedfiles:
1386
 
            for record in versionedfile.get_record_stream(
1387
 
                pending, 'unordered', True):
1388
 
                if record.storage_kind == 'absent':
 
546
            try:
 
547
                return versionedfile.get_lines(version_id)
 
548
            except errors.RevisionNotPresent:
 
549
                continue
 
550
        else:
 
551
            raise errors.RevisionNotPresent(version_id, self._file_id)
 
552
 
 
553
    def get_ancestry(self, version_id, topo_sorted=False):
 
554
        """See VersionedFile.get_ancestry.
 
555
 
 
556
        Note that this implementation assumes that if a VersionedFile can
 
557
        answer get_ancestry at all, it can give an authoritative answer.  In
 
558
        fact, ghosts can invalidate this assumption.  But it's good enough
 
559
        99% of the time, and far cheaper/simpler.
 
560
 
 
561
        Also note that the results of this version are never topologically
 
562
        sorted, and are a set.
 
563
        """
 
564
        if topo_sorted:
 
565
            raise ValueError('This implementation does not provide sorting')
 
566
        parents = self._parents.get(version_id)
 
567
        if parents is None:
 
568
            for vf in self.fallback_versionedfiles:
 
569
                try:
 
570
                    return vf.get_ancestry(version_id, topo_sorted=False)
 
571
                except errors.RevisionNotPresent:
1389
572
                    continue
1390
 
                else:
1391
 
                    pending.remove(record.key)
1392
 
                    yield record
1393
 
            if not pending:
1394
 
                return
1395
 
        # report absent entries
1396
 
        for key in pending:
1397
 
            yield AbsentContentFactory(key)
 
573
            else:
 
574
                raise errors.RevisionNotPresent(version_id, self._file_id)
 
575
        ancestry = set([version_id])
 
576
        for parent in parents:
 
577
            ancestry.update(self.get_ancestry(parent, topo_sorted=False))
 
578
        return ancestry
1398
579
 
1399
 
    def get_parent_map(self, keys):
1400
 
        """See VersionedFiles.get_parent_map"""
1401
 
        # We create a new provider because a fallback may have been added.
1402
 
        # If we make fallbacks private we can update a stack list and avoid
1403
 
        # object creation thrashing.
1404
 
        keys = set(keys)
1405
 
        result = {}
1406
 
        if revision.NULL_REVISION in keys:
1407
 
            keys.remove(revision.NULL_REVISION)
1408
 
            result[revision.NULL_REVISION] = ()
1409
 
        self._providers = self._providers[:1] + self.fallback_versionedfiles
1410
 
        result.update(
1411
 
            StackedParentsProvider(self._providers).get_parent_map(keys))
1412
 
        for key, parents in result.iteritems():
1413
 
            if parents == ():
1414
 
                result[key] = (revision.NULL_REVISION,)
1415
 
        return result
 
580
    def get_parents(self, version_id):
 
581
        """See VersionedFile.get_parents"""
 
582
        parents = self._parents.get(version_id)
 
583
        if parents is not None:
 
584
            return parents
 
585
        for versionedfile in self.fallback_versionedfiles:
 
586
            try:
 
587
                return versionedfile.get_parents(version_id)
 
588
            except errors.RevisionNotPresent:
 
589
                continue
 
590
        else:
 
591
            raise errors.RevisionNotPresent(version_id, self._file_id)
1416
592
 
1417
593
 
1418
594
class PlanWeaveMerge(TextMerge):
1419
595
    """Weave merge that takes a plan as its input.
1420
 
 
 
596
    
1421
597
    This exists so that VersionedFile.plan_merge is implementable.
1422
598
    Most callers will want to use WeaveMerge instead.
1423
599
    """
1425
601
    def __init__(self, plan, a_marker=TextMerge.A_MARKER,
1426
602
                 b_marker=TextMerge.B_MARKER):
1427
603
        TextMerge.__init__(self, a_marker, b_marker)
1428
 
        self.plan = list(plan)
 
604
        self.plan = plan
1429
605
 
1430
606
    def _merge_struct(self):
1431
607
        lines_a = []
1444
620
                yield(lines_a,)
1445
621
            else:
1446
622
                yield (lines_a, lines_b)
1447
 
 
 
623
       
1448
624
        # We previously considered either 'unchanged' or 'killed-both' lines
1449
625
        # to be possible places to resynchronize.  However, assuming agreement
1450
626
        # on killed-both lines may be too aggressive. -- mbp 20060324
1456
632
                lines_a = []
1457
633
                lines_b = []
1458
634
                ch_a = ch_b = False
1459
 
 
 
635
                
1460
636
            if state == 'unchanged':
1461
637
                if line:
1462
638
                    yield ([line],)
1472
648
            elif state == 'new-b':
1473
649
                ch_b = True
1474
650
                lines_b.append(line)
1475
 
            elif state == 'conflicted-a':
1476
 
                ch_b = ch_a = True
1477
 
                lines_a.append(line)
1478
 
            elif state == 'conflicted-b':
1479
 
                ch_b = ch_a = True
1480
 
                lines_b.append(line)
1481
 
            elif state == 'killed-both':
1482
 
                # This counts as a change, even though there is no associated
1483
 
                # line
1484
 
                ch_b = ch_a = True
1485
651
            else:
1486
 
                if state not in ('irrelevant', 'ghost-a', 'ghost-b',
1487
 
                        'killed-base'):
1488
 
                    raise AssertionError(state)
 
652
                assert state in ('irrelevant', 'ghost-a', 'ghost-b', 
 
653
                                 'killed-base', 'killed-both'), state
1489
654
        for struct in outstanding_struct():
1490
655
            yield struct
1491
656
 
1492
 
    def base_from_plan(self):
1493
 
        """Construct a BASE file from the plan text."""
1494
 
        base_lines = []
1495
 
        for state, line in self.plan:
1496
 
            if state in ('killed-a', 'killed-b', 'killed-both', 'unchanged'):
1497
 
                # If unchanged, then this line is straight from base. If a or b
1498
 
                # or both killed the line, then it *used* to be in base.
1499
 
                base_lines.append(line)
1500
 
            else:
1501
 
                if state not in ('killed-base', 'irrelevant',
1502
 
                                 'ghost-a', 'ghost-b',
1503
 
                                 'new-a', 'new-b',
1504
 
                                 'conflicted-a', 'conflicted-b'):
1505
 
                    # killed-base, irrelevant means it doesn't apply
1506
 
                    # ghost-a/ghost-b are harder to say for sure, but they
1507
 
                    # aren't in the 'inc_c' which means they aren't in the
1508
 
                    # shared base of a & b. So we don't include them.  And
1509
 
                    # obviously if the line is newly inserted, it isn't in base
1510
 
 
1511
 
                    # If 'conflicted-a' or b, then it is new vs one base, but
1512
 
                    # old versus another base. However, if we make it present
1513
 
                    # in the base, it will be deleted from the target, and it
1514
 
                    # seems better to get a line doubled in the merge result,
1515
 
                    # rather than have it deleted entirely.
1516
 
                    # Example, each node is the 'text' at that point:
1517
 
                    #           MN
1518
 
                    #          /   \
1519
 
                    #        MaN   MbN
1520
 
                    #         |  X  |
1521
 
                    #        MabN MbaN
1522
 
                    #          \   /
1523
 
                    #           ???
1524
 
                    # There was a criss-cross conflict merge. Both sides
1525
 
                    # include the other, but put themselves first.
1526
 
                    # Weave marks this as a 'clean' merge, picking OTHER over
1527
 
                    # THIS. (Though the details depend on order inserted into
1528
 
                    # weave, etc.)
1529
 
                    # LCA generates a plan:
1530
 
                    # [('unchanged', M),
1531
 
                    #  ('conflicted-b', b),
1532
 
                    #  ('unchanged', a),
1533
 
                    #  ('conflicted-a', b),
1534
 
                    #  ('unchanged', N)]
1535
 
                    # If you mark 'conflicted-*' as part of BASE, then a 3-way
1536
 
                    # merge tool will cleanly generate "MaN" (as BASE vs THIS
1537
 
                    # removes one 'b', and BASE vs OTHER removes the other)
1538
 
                    # If you include neither, 3-way creates a clean "MbabN" as
1539
 
                    # THIS adds one 'b', and OTHER does too.
1540
 
                    # It seems that having the line 2 times is better than
1541
 
                    # having it omitted. (Easier to manually delete than notice
1542
 
                    # it needs to be added.)
1543
 
                    raise AssertionError('Unknown state: %s' % (state,))
1544
 
        return base_lines
1545
 
 
1546
657
 
1547
658
class WeaveMerge(PlanWeaveMerge):
1548
659
    """Weave merge that takes a VersionedFile and two versions as its input."""
1549
660
 
1550
 
    def __init__(self, versionedfile, ver_a, ver_b,
 
661
    def __init__(self, versionedfile, ver_a, ver_b, 
1551
662
        a_marker=PlanWeaveMerge.A_MARKER, b_marker=PlanWeaveMerge.B_MARKER):
1552
663
        plan = versionedfile.plan_merge(ver_a, ver_b)
1553
664
        PlanWeaveMerge.__init__(self, plan, a_marker, b_marker)
1554
665
 
1555
666
 
1556
 
class VirtualVersionedFiles(VersionedFiles):
1557
 
    """Dummy implementation for VersionedFiles that uses other functions for
1558
 
    obtaining fulltexts and parent maps.
1559
 
 
1560
 
    This is always on the bottom of the stack and uses string keys
1561
 
    (rather than tuples) internally.
1562
 
    """
1563
 
 
1564
 
    def __init__(self, get_parent_map, get_lines):
1565
 
        """Create a VirtualVersionedFiles.
1566
 
 
1567
 
        :param get_parent_map: Same signature as Repository.get_parent_map.
1568
 
        :param get_lines: Should return lines for specified key or None if
1569
 
                          not available.
1570
 
        """
1571
 
        super(VirtualVersionedFiles, self).__init__()
1572
 
        self._get_parent_map = get_parent_map
1573
 
        self._get_lines = get_lines
1574
 
 
1575
 
    def check(self, progressbar=None):
1576
 
        """See VersionedFiles.check.
1577
 
 
1578
 
        :note: Always returns True for VirtualVersionedFiles.
1579
 
        """
1580
 
        return True
1581
 
 
1582
 
    def add_mpdiffs(self, records):
1583
 
        """See VersionedFiles.mpdiffs.
1584
 
 
1585
 
        :note: Not implemented for VirtualVersionedFiles.
1586
 
        """
1587
 
        raise NotImplementedError(self.add_mpdiffs)
1588
 
 
1589
 
    def get_parent_map(self, keys):
1590
 
        """See VersionedFiles.get_parent_map."""
1591
 
        return dict([((k,), tuple([(p,) for p in v]))
1592
 
            for k,v in self._get_parent_map([k for (k,) in keys]).iteritems()])
1593
 
 
1594
 
    def get_sha1s(self, keys):
1595
 
        """See VersionedFiles.get_sha1s."""
1596
 
        ret = {}
1597
 
        for (k,) in keys:
1598
 
            lines = self._get_lines(k)
1599
 
            if lines is not None:
1600
 
                if not isinstance(lines, list):
1601
 
                    raise AssertionError
1602
 
                ret[(k,)] = osutils.sha_strings(lines)
1603
 
        return ret
1604
 
 
1605
 
    def get_record_stream(self, keys, ordering, include_delta_closure):
1606
 
        """See VersionedFiles.get_record_stream."""
1607
 
        for (k,) in list(keys):
1608
 
            lines = self._get_lines(k)
1609
 
            if lines is not None:
1610
 
                if not isinstance(lines, list):
1611
 
                    raise AssertionError
1612
 
                yield ChunkedContentFactory((k,), None,
1613
 
                        sha1=osutils.sha_strings(lines),
1614
 
                        chunks=lines)
1615
 
            else:
1616
 
                yield AbsentContentFactory((k,))
1617
 
 
1618
 
    def iter_lines_added_or_present_in_keys(self, keys, pb=None):
1619
 
        """See VersionedFile.iter_lines_added_or_present_in_versions()."""
1620
 
        for i, (key,) in enumerate(keys):
1621
 
            if pb is not None:
1622
 
                pb.update("Finding changed lines", i, len(keys))
1623
 
            for l in self._get_lines(key):
1624
 
                yield (l, key)
1625
 
 
1626
 
 
1627
 
def network_bytes_to_kind_and_offset(network_bytes):
1628
 
    """Strip of a record kind from the front of network_bytes.
1629
 
 
1630
 
    :param network_bytes: The bytes of a record.
1631
 
    :return: A tuple (storage_kind, offset_of_remaining_bytes)
1632
 
    """
1633
 
    line_end = network_bytes.find('\n')
1634
 
    storage_kind = network_bytes[:line_end]
1635
 
    return storage_kind, line_end + 1
1636
 
 
1637
 
 
1638
 
class NetworkRecordStream(object):
1639
 
    """A record_stream which reconstitures a serialised stream."""
1640
 
 
1641
 
    def __init__(self, bytes_iterator):
1642
 
        """Create a NetworkRecordStream.
1643
 
 
1644
 
        :param bytes_iterator: An iterator of bytes. Each item in this
1645
 
            iterator should have been obtained from a record_streams'
1646
 
            record.get_bytes_as(record.storage_kind) call.
1647
 
        """
1648
 
        self._bytes_iterator = bytes_iterator
1649
 
        self._kind_factory = {
1650
 
            'fulltext': fulltext_network_to_record,
1651
 
            'groupcompress-block': groupcompress.network_block_to_records,
1652
 
            'knit-ft-gz': knit.knit_network_to_record,
1653
 
            'knit-delta-gz': knit.knit_network_to_record,
1654
 
            'knit-annotated-ft-gz': knit.knit_network_to_record,
1655
 
            'knit-annotated-delta-gz': knit.knit_network_to_record,
1656
 
            'knit-delta-closure': knit.knit_delta_closure_to_records,
1657
 
            }
1658
 
 
1659
 
    def read(self):
1660
 
        """Read the stream.
1661
 
 
1662
 
        :return: An iterator as per VersionedFiles.get_record_stream().
1663
 
        """
1664
 
        for bytes in self._bytes_iterator:
1665
 
            storage_kind, line_end = network_bytes_to_kind_and_offset(bytes)
1666
 
            for record in self._kind_factory[storage_kind](
1667
 
                storage_kind, bytes, line_end):
1668
 
                yield record
1669
 
 
1670
 
 
1671
 
def fulltext_network_to_record(kind, bytes, line_end):
1672
 
    """Convert a network fulltext record to record."""
1673
 
    meta_len, = struct.unpack('!L', bytes[line_end:line_end+4])
1674
 
    record_meta = bytes[line_end+4:line_end+4+meta_len]
1675
 
    key, parents = bencode.bdecode_as_tuple(record_meta)
1676
 
    if parents == 'nil':
1677
 
        parents = None
1678
 
    fulltext = bytes[line_end+4+meta_len:]
1679
 
    return [FulltextContentFactory(key, parents, None, fulltext)]
1680
 
 
1681
 
 
1682
 
def _length_prefix(bytes):
1683
 
    return struct.pack('!L', len(bytes))
1684
 
 
1685
 
 
1686
 
def record_to_fulltext_bytes(record):
1687
 
    if record.parents is None:
1688
 
        parents = 'nil'
1689
 
    else:
1690
 
        parents = record.parents
1691
 
    record_meta = bencode.bencode((record.key, parents))
1692
 
    record_content = record.get_bytes_as('fulltext')
1693
 
    return "fulltext\n%s%s%s" % (
1694
 
        _length_prefix(record_meta), record_meta, record_content)
1695
 
 
1696
 
 
1697
 
def sort_groupcompress(parent_map):
1698
 
    """Sort and group the keys in parent_map into groupcompress order.
1699
 
 
1700
 
    groupcompress is defined (currently) as reverse-topological order, grouped
1701
 
    by the key prefix.
1702
 
 
1703
 
    :return: A sorted-list of keys
1704
 
    """
1705
 
    # gc-optimal ordering is approximately reverse topological,
1706
 
    # properly grouped by file-id.
1707
 
    per_prefix_map = {}
1708
 
    for item in parent_map.iteritems():
1709
 
        key = item[0]
1710
 
        if isinstance(key, str) or len(key) == 1:
1711
 
            prefix = ''
 
667
class InterVersionedFile(InterObject):
 
668
    """This class represents operations taking place between two VersionedFiles.
 
669
 
 
670
    Its instances have methods like join, and contain
 
671
    references to the source and target versionedfiles these operations can be 
 
672
    carried out on.
 
673
 
 
674
    Often we will provide convenience methods on 'versionedfile' which carry out
 
675
    operations with another versionedfile - they will always forward to
 
676
    InterVersionedFile.get(other).method_name(parameters).
 
677
    """
 
678
 
 
679
    _optimisers = []
 
680
    """The available optimised InterVersionedFile types."""
 
681
 
 
682
    def join(self, pb=None, msg=None, version_ids=None, ignore_missing=False):
 
683
        """Integrate versions from self.source into self.target.
 
684
 
 
685
        If version_ids is None all versions from source should be
 
686
        incorporated into this versioned file.
 
687
 
 
688
        Must raise RevisionNotPresent if any of the specified versions
 
689
        are not present in the other file's history unless ignore_missing is 
 
690
        supplied in which case they are silently skipped.
 
691
        """
 
692
        # the default join: 
 
693
        # - if the target is empty, just add all the versions from 
 
694
        #   source to target, otherwise:
 
695
        # - make a temporary versioned file of type target
 
696
        # - insert the source content into it one at a time
 
697
        # - join them
 
698
        if not self.target.versions():
 
699
            target = self.target
1712
700
        else:
1713
 
            prefix = key[0]
 
701
            # Make a new target-format versioned file. 
 
702
            temp_source = self.target.create_empty("temp", MemoryTransport())
 
703
            target = temp_source
 
704
        version_ids = self._get_source_version_ids(version_ids, ignore_missing)
 
705
        graph = self.source.get_graph(version_ids)
 
706
        order = tsort.topo_sort(graph.items())
 
707
        pb = ui.ui_factory.nested_progress_bar()
 
708
        parent_texts = {}
1714
709
        try:
1715
 
            per_prefix_map[prefix].append(item)
1716
 
        except KeyError:
1717
 
            per_prefix_map[prefix] = [item]
1718
 
 
1719
 
    present_keys = []
1720
 
    for prefix in sorted(per_prefix_map):
1721
 
        present_keys.extend(reversed(tsort.topo_sort(per_prefix_map[prefix])))
1722
 
    return present_keys
 
710
            # TODO for incremental cross-format work:
 
711
            # make a versioned file with the following content:
 
712
            # all revisions we have been asked to join
 
713
            # all their ancestors that are *not* in target already.
 
714
            # the immediate parents of the above two sets, with 
 
715
            # empty parent lists - these versions are in target already
 
716
            # and the incorrect version data will be ignored.
 
717
            # TODO: for all ancestors that are present in target already,
 
718
            # check them for consistent data, this requires moving sha1 from
 
719
            # 
 
720
            # TODO: remove parent texts when they are not relevant any more for 
 
721
            # memory pressure reduction. RBC 20060313
 
722
            # pb.update('Converting versioned data', 0, len(order))
 
723
            total = len(order)
 
724
            for index, version in enumerate(order):
 
725
                pb.update('Converting versioned data', index, total)
 
726
                _, _, parent_text = target.add_lines(version,
 
727
                                               self.source.get_parents(version),
 
728
                                               self.source.get_lines(version),
 
729
                                               parent_texts=parent_texts)
 
730
                parent_texts[version] = parent_text
 
731
            
 
732
            # this should hit the native code path for target
 
733
            if target is not self.target:
 
734
                return self.target.join(temp_source,
 
735
                                        pb,
 
736
                                        msg,
 
737
                                        version_ids,
 
738
                                        ignore_missing)
 
739
            else:
 
740
                return total
 
741
        finally:
 
742
            pb.finished()
 
743
 
 
744
    def _get_source_version_ids(self, version_ids, ignore_missing):
 
745
        """Determine the version ids to be used from self.source.
 
746
 
 
747
        :param version_ids: The caller-supplied version ids to check. (None 
 
748
                            for all). If None is in version_ids, it is stripped.
 
749
        :param ignore_missing: if True, remove missing ids from the version 
 
750
                               list. If False, raise RevisionNotPresent on
 
751
                               a missing version id.
 
752
        :return: A set of version ids.
 
753
        """
 
754
        if version_ids is None:
 
755
            # None cannot be in source.versions
 
756
            return set(self.source.versions())
 
757
        else:
 
758
            if ignore_missing:
 
759
                return set(self.source.versions()).intersection(set(version_ids))
 
760
            else:
 
761
                new_version_ids = set()
 
762
                for version in version_ids:
 
763
                    if version is None:
 
764
                        continue
 
765
                    if not self.source.has_version(version):
 
766
                        raise errors.RevisionNotPresent(version, str(self.source))
 
767
                    else:
 
768
                        new_version_ids.add(version)
 
769
                return new_version_ids