~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/versionedfile.py

doc

Show diffs side-by-side

added added

removed removed

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