/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to bzrlib/versionedfile.py

  • Committer: Robert Collins
  • Date: 2010-05-06 11:08:10 UTC
  • mto: This revision was merged to the branch mainline in revision 5223.
  • Revision ID: robertc@robertcollins.net-20100506110810-h3j07fh5gmw54s25
Cleaner matcher matching revised unlocking protocol.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006 Canonical Ltd
 
1
# Copyright (C) 2006-2010 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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
18
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 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
 
22
28
from bzrlib.lazy_import import lazy_import
23
29
lazy_import(globals(), """
 
30
import urllib
24
31
 
25
32
from bzrlib import (
 
33
    annotate,
26
34
    errors,
 
35
    graph as _mod_graph,
 
36
    groupcompress,
 
37
    index,
 
38
    knit,
27
39
    osutils,
28
40
    multiparent,
29
41
    tsort,
30
42
    revision,
31
43
    ui,
32
44
    )
 
45
from bzrlib.graph import DictParentsProvider, Graph, StackedParentsProvider
33
46
from bzrlib.transport.memory import MemoryTransport
34
47
""")
35
 
 
36
 
from cStringIO import StringIO
37
 
 
38
 
from bzrlib.inter import InterObject
 
48
from bzrlib.registry import Registry
 
49
from bzrlib.symbol_versioning import *
39
50
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
40
207
 
41
208
 
42
209
class VersionedFile(object):
43
210
    """Versioned text file storage.
44
 
    
 
211
 
45
212
    A versioned file manages versions of line-based text files,
46
213
    keeping track of the originating version for each line.
47
214
 
53
220
    Texts are identified by a version-id string.
54
221
    """
55
222
 
56
 
    def __init__(self, access_mode):
57
 
        self.finished = False
58
 
        self._access_mode = access_mode
59
 
 
60
223
    @staticmethod
61
224
    def check_not_reserved_id(version_id):
62
225
        revision.check_not_reserved_id(version_id)
65
228
        """Copy this versioned file to name on transport."""
66
229
        raise NotImplementedError(self.copy_to)
67
230
 
68
 
    def versions(self):
69
 
        """Return a unsorted list of versions."""
70
 
        raise NotImplementedError(self.versions)
 
231
    def get_record_stream(self, versions, ordering, include_delta_closure):
 
232
        """Get a stream of records for versions.
71
233
 
72
 
    def has_ghost(self, version_id):
73
 
        """Returns whether version is present as a ghost."""
74
 
        raise NotImplementedError(self.has_ghost)
 
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)
75
247
 
76
248
    def has_version(self, version_id):
77
249
        """Returns whether version is present."""
78
250
        raise NotImplementedError(self.has_version)
79
251
 
 
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
 
80
261
    def add_lines(self, version_id, parents, lines, parent_texts=None,
81
262
        left_matching_blocks=None, nostore_sha=None, random_id=False,
82
263
        check_content=True):
96
277
            the data back accurately. (Checking the lines have been split
97
278
            correctly is expensive and extremely unlikely to catch bugs so it
98
279
            is not done at runtime unless check_content is True.)
99
 
        :param parent_texts: An optional dictionary containing the opaque 
 
280
        :param parent_texts: An optional dictionary containing the opaque
100
281
            representations of some or all of the parents of version_id to
101
282
            allow delta optimisations.  VERY IMPORTANT: the texts must be those
102
283
            returned by add_lines or data corruption can be caused.
128
309
 
129
310
    def add_lines_with_ghosts(self, version_id, parents, lines,
130
311
        parent_texts=None, nostore_sha=None, random_id=False,
131
 
        check_content=True):
 
312
        check_content=True, left_matching_blocks=None):
132
313
        """Add lines to the versioned file, allowing ghosts to be present.
133
 
        
 
314
 
134
315
        This takes the same parameters as add_lines and returns the same.
135
316
        """
136
317
        self._check_write_ok()
137
318
        return self._add_lines_with_ghosts(version_id, parents, lines,
138
 
            parent_texts, nostore_sha, random_id, check_content)
 
319
            parent_texts, nostore_sha, random_id, check_content, left_matching_blocks)
139
320
 
140
321
    def _add_lines_with_ghosts(self, version_id, parents, lines, parent_texts,
141
 
        nostore_sha, random_id, check_content):
 
322
        nostore_sha, random_id, check_content, left_matching_blocks):
142
323
        """Helper to do class specific add_lines_with_ghosts."""
143
324
        raise NotImplementedError(self.add_lines_with_ghosts)
144
325
 
158
339
            if '\n' in line[:-1]:
159
340
                raise errors.BzrBadParameterContainsNewline("lines")
160
341
 
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
 
 
206
342
    def get_format_signature(self):
207
343
        """Get a text description of the data encoding in this file.
208
 
        
 
344
 
209
345
        :since: 0.90
210
346
        """
211
347
        raise NotImplementedError(self.get_format_signature)
213
349
    def make_mpdiffs(self, version_ids):
214
350
        """Create multiparent diffs for specified versions."""
215
351
        knit_versions = set()
 
352
        knit_versions.update(version_ids)
 
353
        parent_map = self.get_parent_map(version_ids)
216
354
        for version_id in version_ids:
217
 
            knit_versions.add(version_id)
218
 
            knit_versions.update(self.get_parents(version_id))
 
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())
219
361
        lines = dict(zip(knit_versions,
220
362
            self._get_lf_split_line_list(knit_versions)))
221
363
        diffs = []
222
364
        for version_id in version_ids:
223
365
            target = lines[version_id]
224
 
            parents = [lines[p] for p in self.get_parents(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)
225
375
            if len(parents) > 0:
226
376
                left_parent_blocks = self._extract_blocks(version_id,
227
377
                                                          parents[0], target)
251
401
        for version, parent_ids, expected_sha1, mpdiff in records:
252
402
            needed_parents.update(p for p in parent_ids
253
403
                                  if not mpvf.has_version(p))
254
 
        for parent_id, lines in zip(needed_parents,
255
 
                                 self._get_lf_split_line_list(needed_parents)):
 
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)):
256
407
            mpvf.add_version(lines, parent_id, [])
257
408
        for (version, parent_ids, expected_sha1, mpdiff), lines in\
258
409
            zip(records, mpvf.get_line_list(versions)):
261
412
                    mpvf.get_diff(parent_ids[0]).num_lines()))
262
413
            else:
263
414
                left_matching_blocks = None
264
 
            _, _, version_text = self.add_lines(version, parent_ids, lines,
265
 
                vf_parents, left_matching_blocks=left_matching_blocks)
 
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)
266
425
            vf_parents[version] = version_text
267
 
        for (version, parent_ids, expected_sha1, mpdiff), sha1 in\
268
 
             zip(records, self.get_sha1s(versions)):
269
 
            if expected_sha1 != sha1:
 
426
        sha1s = self.get_sha1s(versions)
 
427
        for version, parent_ids, expected_sha1, mpdiff in records:
 
428
            if expected_sha1 != sha1s[version]:
270
429
                raise errors.VersionedFileInvalidChecksum(version)
271
430
 
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
 
    
291
431
    def get_text(self, version_id):
292
432
        """Return version contents as a text string.
293
433
 
328
468
        if isinstance(version_ids, basestring):
329
469
            version_ids = [version_ids]
330
470
        raise NotImplementedError(self.get_ancestry)
331
 
        
 
471
 
332
472
    def get_ancestry_with_ghosts(self, version_ids):
333
473
        """Return a list of all ancestors of given version(s). This
334
474
        will not include the null revision.
335
475
 
336
476
        Must raise RevisionNotPresent if any of the given versions are
337
477
        not present in file history.
338
 
        
 
478
 
339
479
        Ghosts that are known about will be included in ancestry list,
340
480
        but are not explicitly marked.
341
481
        """
342
482
        raise NotImplementedError(self.get_ancestry_with_ghosts)
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)
 
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)
381
491
 
382
492
    def get_parents_with_ghosts(self, version_id):
383
493
        """Return version names for parents of version_id.
388
498
        Ghosts that are known about will be included in the parent list,
389
499
        but are not explicitly marked.
390
500
        """
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)
 
501
        try:
 
502
            return list(self.get_parent_map([version_id])[version_id])
 
503
        except KeyError:
 
504
            raise errors.RevisionNotPresent(version_id, self)
401
505
 
402
506
    def annotate(self, version_id):
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.
 
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.
415
511
        """
416
 
        self._check_write_ok()
417
 
        return InterVersionedFile.get(other, self).join(
418
 
            pb,
419
 
            msg,
420
 
            version_ids,
421
 
            ignore_missing)
 
512
        raise NotImplementedError(self.annotate)
422
513
 
423
514
    def iter_lines_added_or_present_in_versions(self, version_ids=None,
424
515
                                                pb=None):
442
533
        """
443
534
        raise NotImplementedError(self.iter_lines_added_or_present_in_versions)
444
535
 
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
 
 
468
536
    def plan_merge(self, ver_a, ver_b):
469
537
        """Return pseudo-annotation indicating how the two versions merge.
470
538
 
481
549
        unchanged   Alive in both a and b (possibly created in both)
482
550
        new-a       Created in a
483
551
        new-b       Created in b
484
 
        ghost-a     Killed in a, unborn in b    
 
552
        ghost-a     Killed in a, unborn in b
485
553
        ghost-b     Killed in b, unborn in a
486
554
        irrelevant  Not in either revision
487
555
        """
488
556
        raise NotImplementedError(VersionedFile.plan_merge)
489
 
        
 
557
 
490
558
    def weave_merge(self, plan, a_marker=TextMerge.A_MARKER,
491
559
                    b_marker=TextMerge.B_MARKER):
492
560
        return PlanWeaveMerge(plan, a_marker, b_marker).merge_lines()[0]
493
561
 
494
562
 
495
 
class _PlanMergeVersionedFile(object):
 
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):
496
1315
    """A VersionedFile for uncommitted and committed texts.
497
1316
 
498
1317
    It is intended to allow merges to be planned with working tree texts.
499
 
    It implements only the small part of the VersionedFile interface used by
 
1318
    It implements only the small part of the VersionedFiles interface used by
500
1319
    PlanMerge.  It falls back to multiple versionedfiles for data not stored in
501
1320
    _PlanMergeVersionedFile itself.
 
1321
 
 
1322
    :ivar: fallback_versionedfiles a list of VersionedFiles objects that can be
 
1323
        queried for missing texts.
502
1324
    """
503
1325
 
504
 
    def __init__(self, file_id, fallback_versionedfiles=None):
505
 
        """Constuctor
 
1326
    def __init__(self, file_id):
 
1327
        """Create a _PlanMergeVersionedFile.
506
1328
 
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.
 
1329
        :param file_id: Used with _PlanMerge code which is not yet fully
 
1330
            tuple-keyspace aware.
511
1331
        """
512
1332
        self._file_id = file_id
513
 
        if fallback_versionedfiles is None:
514
 
            self.fallback_versionedfiles = []
515
 
        else:
516
 
            self.fallback_versionedfiles = fallback_versionedfiles
 
1333
        # fallback locations
 
1334
        self.fallback_versionedfiles = []
 
1335
        # Parents for locally held keys.
517
1336
        self._parents = {}
 
1337
        # line data for locally held keys.
518
1338
        self._lines = {}
 
1339
        # key lookup providers
 
1340
        self._providers = [DictParentsProvider(self._parents)]
519
1341
 
520
1342
    def plan_merge(self, ver_a, ver_b, base=None):
521
1343
        """See VersionedFile.plan_merge"""
522
1344
        from bzrlib.merge import _PlanMerge
523
1345
        if base is None:
524
 
            return _PlanMerge(ver_a, ver_b, self).plan_merge()
525
 
        old_plan = list(_PlanMerge(ver_a, base, self).plan_merge())
526
 
        new_plan = list(_PlanMerge(ver_a, ver_b, self).plan_merge())
 
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())
527
1349
        return _PlanMerge._subtract_plans(old_plan, new_plan)
528
1350
 
529
1351
    def plan_lca_merge(self, ver_a, ver_b, base=None):
530
1352
        from bzrlib.merge import _PlanLCAMerge
531
 
        graph = self._get_graph()
532
 
        new_plan = _PlanLCAMerge(ver_a, ver_b, self, graph).plan_merge()
 
1353
        graph = Graph(self)
 
1354
        new_plan = _PlanLCAMerge(ver_a, ver_b, self, (self._file_id,), graph).plan_merge()
533
1355
        if base is None:
534
1356
            return new_plan
535
 
        old_plan = _PlanLCAMerge(ver_a, base, self, graph).plan_merge()
 
1357
        old_plan = _PlanLCAMerge(ver_a, base, self, (self._file_id,), graph).plan_merge()
536
1358
        return _PlanLCAMerge._subtract_plans(list(old_plan), list(new_plan))
537
1359
 
538
 
    def add_lines(self, version_id, parents, lines):
539
 
        """See VersionedFile.add_lines
 
1360
    def add_lines(self, key, parents, lines):
 
1361
        """See VersionedFiles.add_lines
540
1362
 
541
 
        Lines are added locally, not fallback versionedfiles.  Also, ghosts are
542
 
        permitted.  Only reserved ids are permitted.
 
1363
        Lines are added locally, not to fallback versionedfiles.  Also, ghosts
 
1364
        are permitted.  Only reserved ids are permitted.
543
1365
        """
544
 
        if not revision.is_reserved_id(version_id):
 
1366
        if type(key) is not tuple:
 
1367
            raise TypeError(key)
 
1368
        if not revision.is_reserved_id(key[-1]):
545
1369
            raise ValueError('Only reserved ids may be used')
546
1370
        if parents is None:
547
1371
            raise ValueError('Parents may not be None')
548
1372
        if lines is None:
549
1373
            raise ValueError('Lines may not be None')
550
 
        self._parents[version_id] = parents
551
 
        self._lines[version_id] = lines
 
1374
        self._parents[key] = tuple(parents)
 
1375
        self._lines[key] = lines
552
1376
 
553
 
    def get_lines(self, version_id):
554
 
        """See VersionedFile.get_ancestry"""
555
 
        lines = self._lines.get(version_id)
556
 
        if lines is not None:
557
 
            return lines
 
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)
558
1385
        for versionedfile in self.fallback_versionedfiles:
559
 
            try:
560
 
                return versionedfile.get_lines(version_id)
561
 
            except errors.RevisionNotPresent:
562
 
                continue
563
 
        else:
564
 
            raise errors.RevisionNotPresent(version_id, self._file_id)
565
 
 
566
 
    def get_ancestry(self, version_id, topo_sorted=False):
567
 
        """See VersionedFile.get_ancestry.
568
 
 
569
 
        Note that this implementation assumes that if a VersionedFile can
570
 
        answer get_ancestry at all, it can give an authoritative answer.  In
571
 
        fact, ghosts can invalidate this assumption.  But it's good enough
572
 
        99% of the time, and far cheaper/simpler.
573
 
 
574
 
        Also note that the results of this version are never topologically
575
 
        sorted, and are a set.
576
 
        """
577
 
        if topo_sorted:
578
 
            raise ValueError('This implementation does not provide sorting')
579
 
        parents = self._parents.get(version_id)
580
 
        if parents is None:
581
 
            for vf in self.fallback_versionedfiles:
582
 
                try:
583
 
                    return vf.get_ancestry(version_id, topo_sorted=False)
584
 
                except errors.RevisionNotPresent:
 
1386
            for record in versionedfile.get_record_stream(
 
1387
                pending, 'unordered', True):
 
1388
                if record.storage_kind == 'absent':
585
1389
                    continue
586
 
            else:
587
 
                raise errors.RevisionNotPresent(version_id, self._file_id)
588
 
        ancestry = set([version_id])
589
 
        for parent in parents:
590
 
            ancestry.update(self.get_ancestry(parent, topo_sorted=False))
591
 
        return ancestry
592
 
 
593
 
    def get_parents(self, version_id):
594
 
        """See VersionedFile.get_parents"""
595
 
        parents = self._parents.get(version_id)
596
 
        if parents is not None:
597
 
            return parents
598
 
        for versionedfile in self.fallback_versionedfiles:
599
 
            try:
600
 
                return versionedfile.get_parents(version_id)
601
 
            except errors.RevisionNotPresent:
602
 
                continue
603
 
        else:
604
 
            raise errors.RevisionNotPresent(version_id, self._file_id)
605
 
 
606
 
    def _get_graph(self):
607
 
        from bzrlib.graph import (
608
 
            DictParentsProvider,
609
 
            Graph,
610
 
            _StackedParentsProvider,
611
 
            )
612
 
        from bzrlib.repofmt.knitrepo import _KnitParentsProvider
613
 
        parent_providers = [DictParentsProvider(self._parents)]
614
 
        for vf in self.fallback_versionedfiles:
615
 
            parent_providers.append(_KnitParentsProvider(vf))
616
 
        return Graph(_StackedParentsProvider(parent_providers))
 
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)
 
1398
 
 
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
617
1416
 
618
1417
 
619
1418
class PlanWeaveMerge(TextMerge):
620
1419
    """Weave merge that takes a plan as its input.
621
 
    
 
1420
 
622
1421
    This exists so that VersionedFile.plan_merge is implementable.
623
1422
    Most callers will want to use WeaveMerge instead.
624
1423
    """
626
1425
    def __init__(self, plan, a_marker=TextMerge.A_MARKER,
627
1426
                 b_marker=TextMerge.B_MARKER):
628
1427
        TextMerge.__init__(self, a_marker, b_marker)
629
 
        self.plan = plan
 
1428
        self.plan = list(plan)
630
1429
 
631
1430
    def _merge_struct(self):
632
1431
        lines_a = []
645
1444
                yield(lines_a,)
646
1445
            else:
647
1446
                yield (lines_a, lines_b)
648
 
       
 
1447
 
649
1448
        # We previously considered either 'unchanged' or 'killed-both' lines
650
1449
        # to be possible places to resynchronize.  However, assuming agreement
651
1450
        # on killed-both lines may be too aggressive. -- mbp 20060324
657
1456
                lines_a = []
658
1457
                lines_b = []
659
1458
                ch_a = ch_b = False
660
 
                
 
1459
 
661
1460
            if state == 'unchanged':
662
1461
                if line:
663
1462
                    yield ([line],)
679
1478
            elif state == 'conflicted-b':
680
1479
                ch_b = ch_a = True
681
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
682
1485
            else:
683
 
                assert state in ('irrelevant', 'ghost-a', 'ghost-b', 
684
 
                                 'killed-base', 'killed-both'), state
 
1486
                if state not in ('irrelevant', 'ghost-a', 'ghost-b',
 
1487
                        'killed-base'):
 
1488
                    raise AssertionError(state)
685
1489
        for struct in outstanding_struct():
686
1490
            yield struct
687
1491
 
 
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
 
688
1546
 
689
1547
class WeaveMerge(PlanWeaveMerge):
690
1548
    """Weave merge that takes a VersionedFile and two versions as its input."""
691
1549
 
692
 
    def __init__(self, versionedfile, ver_a, ver_b, 
 
1550
    def __init__(self, versionedfile, ver_a, ver_b,
693
1551
        a_marker=PlanWeaveMerge.A_MARKER, b_marker=PlanWeaveMerge.B_MARKER):
694
1552
        plan = versionedfile.plan_merge(ver_a, ver_b)
695
1553
        PlanWeaveMerge.__init__(self, plan, a_marker, b_marker)
696
1554
 
697
1555
 
698
 
class InterVersionedFile(InterObject):
699
 
    """This class represents operations taking place between two VersionedFiles.
700
 
 
701
 
    Its instances have methods like join, and contain
702
 
    references to the source and target versionedfiles these operations can be 
703
 
    carried out on.
704
 
 
705
 
    Often we will provide convenience methods on 'versionedfile' which carry out
706
 
    operations with another versionedfile - they will always forward to
707
 
    InterVersionedFile.get(other).method_name(parameters).
708
 
    """
709
 
 
710
 
    _optimisers = []
711
 
    """The available optimised InterVersionedFile types."""
712
 
 
713
 
    def join(self, pb=None, msg=None, version_ids=None, ignore_missing=False):
714
 
        """Integrate versions from self.source into self.target.
715
 
 
716
 
        If version_ids is None all versions from source should be
717
 
        incorporated into this versioned file.
718
 
 
719
 
        Must raise RevisionNotPresent if any of the specified versions
720
 
        are not present in the other file's history unless ignore_missing is 
721
 
        supplied in which case they are silently skipped.
722
 
        """
723
 
        # the default join: 
724
 
        # - if the target is empty, just add all the versions from 
725
 
        #   source to target, otherwise:
726
 
        # - make a temporary versioned file of type target
727
 
        # - insert the source content into it one at a time
728
 
        # - join them
729
 
        if not self.target.versions():
730
 
            target = self.target
 
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 = ''
731
1712
        else:
732
 
            # Make a new target-format versioned file. 
733
 
            temp_source = self.target.create_empty("temp", MemoryTransport())
734
 
            target = temp_source
735
 
        version_ids = self._get_source_version_ids(version_ids, ignore_missing)
736
 
        graph = self.source.get_graph(version_ids)
737
 
        order = tsort.topo_sort(graph.items())
738
 
        pb = ui.ui_factory.nested_progress_bar()
739
 
        parent_texts = {}
 
1713
            prefix = key[0]
740
1714
        try:
741
 
            # TODO for incremental cross-format work:
742
 
            # make a versioned file with the following content:
743
 
            # all revisions we have been asked to join
744
 
            # all their ancestors that are *not* in target already.
745
 
            # the immediate parents of the above two sets, with 
746
 
            # empty parent lists - these versions are in target already
747
 
            # and the incorrect version data will be ignored.
748
 
            # TODO: for all ancestors that are present in target already,
749
 
            # check them for consistent data, this requires moving sha1 from
750
 
            # 
751
 
            # TODO: remove parent texts when they are not relevant any more for 
752
 
            # memory pressure reduction. RBC 20060313
753
 
            # pb.update('Converting versioned data', 0, len(order))
754
 
            total = len(order)
755
 
            for index, version in enumerate(order):
756
 
                pb.update('Converting versioned data', index, total)
757
 
                _, _, parent_text = target.add_lines(version,
758
 
                                               self.source.get_parents(version),
759
 
                                               self.source.get_lines(version),
760
 
                                               parent_texts=parent_texts)
761
 
                parent_texts[version] = parent_text
762
 
            
763
 
            # this should hit the native code path for target
764
 
            if target is not self.target:
765
 
                return self.target.join(temp_source,
766
 
                                        pb,
767
 
                                        msg,
768
 
                                        version_ids,
769
 
                                        ignore_missing)
770
 
            else:
771
 
                return total
772
 
        finally:
773
 
            pb.finished()
774
 
 
775
 
    def _get_source_version_ids(self, version_ids, ignore_missing):
776
 
        """Determine the version ids to be used from self.source.
777
 
 
778
 
        :param version_ids: The caller-supplied version ids to check. (None 
779
 
                            for all). If None is in version_ids, it is stripped.
780
 
        :param ignore_missing: if True, remove missing ids from the version 
781
 
                               list. If False, raise RevisionNotPresent on
782
 
                               a missing version id.
783
 
        :return: A set of version ids.
784
 
        """
785
 
        if version_ids is None:
786
 
            # None cannot be in source.versions
787
 
            return set(self.source.versions())
788
 
        else:
789
 
            if ignore_missing:
790
 
                return set(self.source.versions()).intersection(set(version_ids))
791
 
            else:
792
 
                new_version_ids = set()
793
 
                for version in version_ids:
794
 
                    if version is None:
795
 
                        continue
796
 
                    if not self.source.has_version(version):
797
 
                        raise errors.RevisionNotPresent(version, str(self.source))
798
 
                    else:
799
 
                        new_version_ids.add(version)
800
 
                return new_version_ids
 
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