/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/remote.py

Return mapping in revision_id_bzr_to_foreign() as required by the interface.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006, 2007, 2008 Canonical Ltd
2
 
#
3
 
# This program is free software; you can redistribute it and/or modify
4
 
# it under the terms of the GNU General Public License as published by
5
 
# the Free Software Foundation; either version 2 of the License, or
6
 
# (at your option) any later version.
7
 
#
8
 
# This program is distributed in the hope that it will be useful,
9
 
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
 
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
 
# GNU General Public License for more details.
12
 
#
13
 
# You should have received a copy of the GNU General Public License
14
 
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
 
 
17
 
# TODO: At some point, handle upgrades by just passing the whole request
18
 
# across to run on the server.
19
 
 
20
 
import bz2
21
 
 
22
 
from bzrlib import (
23
 
    branch,
24
 
    bzrdir,
25
 
    config,
26
 
    debug,
27
 
    errors,
28
 
    graph,
29
 
    lockdir,
30
 
    pack,
31
 
    repository,
32
 
    revision,
33
 
    revision as _mod_revision,
34
 
    symbol_versioning,
35
 
    urlutils,
36
 
)
37
 
from bzrlib.branch import BranchReferenceFormat
38
 
from bzrlib.bzrdir import BzrDir, RemoteBzrDirFormat
39
 
from bzrlib.decorators import needs_read_lock, needs_write_lock
40
 
from bzrlib.errors import (
41
 
    NoSuchRevision,
42
 
    SmartProtocolError,
43
 
    )
44
 
from bzrlib.lockable_files import LockableFiles
45
 
from bzrlib.smart import client, vfs, repository as smart_repo
46
 
from bzrlib.revision import ensure_null, NULL_REVISION
47
 
from bzrlib.trace import mutter, note, warning
48
 
from bzrlib.util import bencode
49
 
 
50
 
 
51
 
class _RpcHelper(object):
52
 
    """Mixin class that helps with issuing RPCs."""
53
 
 
54
 
    def _call(self, method, *args, **err_context):
55
 
        try:
56
 
            return self._client.call(method, *args)
57
 
        except errors.ErrorFromSmartServer, err:
58
 
            self._translate_error(err, **err_context)
59
 
 
60
 
    def _call_expecting_body(self, method, *args, **err_context):
61
 
        try:
62
 
            return self._client.call_expecting_body(method, *args)
63
 
        except errors.ErrorFromSmartServer, err:
64
 
            self._translate_error(err, **err_context)
65
 
 
66
 
    def _call_with_body_bytes_expecting_body(self, method, args, body_bytes,
67
 
                                             **err_context):
68
 
        try:
69
 
            return self._client.call_with_body_bytes_expecting_body(
70
 
                method, args, body_bytes)
71
 
        except errors.ErrorFromSmartServer, err:
72
 
            self._translate_error(err, **err_context)
73
 
 
74
 
 
75
 
def response_tuple_to_repo_format(response):
76
 
    """Convert a response tuple describing a repository format to a format."""
77
 
    format = RemoteRepositoryFormat()
78
 
    format._rich_root_data = (response[0] == 'yes')
79
 
    format._supports_tree_reference = (response[1] == 'yes')
80
 
    format._supports_external_lookups = (response[2] == 'yes')
81
 
    format._network_name = response[3]
82
 
    return format
83
 
 
84
 
 
85
 
# Note: RemoteBzrDirFormat is in bzrdir.py
86
 
 
87
 
class RemoteBzrDir(BzrDir, _RpcHelper):
88
 
    """Control directory on a remote server, accessed via bzr:// or similar."""
89
 
 
90
 
    def __init__(self, transport, format, _client=None):
91
 
        """Construct a RemoteBzrDir.
92
 
 
93
 
        :param _client: Private parameter for testing. Disables probing and the
94
 
            use of a real bzrdir.
95
 
        """
96
 
        BzrDir.__init__(self, transport, format)
97
 
        # this object holds a delegated bzrdir that uses file-level operations
98
 
        # to talk to the other side
99
 
        self._real_bzrdir = None
100
 
        # 1-shot cache for the call pattern 'create_branch; open_branch' - see
101
 
        # create_branch for details.
102
 
        self._next_open_branch_result = None
103
 
 
104
 
        if _client is None:
105
 
            medium = transport.get_smart_medium()
106
 
            self._client = client._SmartClient(medium)
107
 
        else:
108
 
            self._client = _client
109
 
            return
110
 
 
111
 
        path = self._path_for_remote_call(self._client)
112
 
        response = self._call('BzrDir.open', path)
113
 
        if response not in [('yes',), ('no',)]:
114
 
            raise errors.UnexpectedSmartServerResponse(response)
115
 
        if response == ('no',):
116
 
            raise errors.NotBranchError(path=transport.base)
117
 
 
118
 
    def _ensure_real(self):
119
 
        """Ensure that there is a _real_bzrdir set.
120
 
 
121
 
        Used before calls to self._real_bzrdir.
122
 
        """
123
 
        if not self._real_bzrdir:
124
 
            self._real_bzrdir = BzrDir.open_from_transport(
125
 
                self.root_transport, _server_formats=False)
126
 
            self._format._network_name = \
127
 
                self._real_bzrdir._format.network_name()
128
 
 
129
 
    def _translate_error(self, err, **context):
130
 
        _translate_error(err, bzrdir=self, **context)
131
 
 
132
 
    def break_lock(self):
133
 
        # Prevent aliasing problems in the next_open_branch_result cache.
134
 
        # See create_branch for rationale.
135
 
        self._next_open_branch_result = None
136
 
        return BzrDir.break_lock(self)
137
 
 
138
 
    def _vfs_cloning_metadir(self, require_stacking=False):
139
 
        self._ensure_real()
140
 
        return self._real_bzrdir.cloning_metadir(
141
 
            require_stacking=require_stacking)
142
 
 
143
 
    def cloning_metadir(self, require_stacking=False):
144
 
        medium = self._client._medium
145
 
        if medium._is_remote_before((1, 13)):
146
 
            return self._vfs_cloning_metadir(require_stacking=require_stacking)
147
 
        verb = 'BzrDir.cloning_metadir'
148
 
        if require_stacking:
149
 
            stacking = 'True'
150
 
        else:
151
 
            stacking = 'False'
152
 
        path = self._path_for_remote_call(self._client)
153
 
        try:
154
 
            response = self._call(verb, path, stacking)
155
 
        except errors.UnknownSmartMethod:
156
 
            medium._remember_remote_is_before((1, 13))
157
 
            return self._vfs_cloning_metadir(require_stacking=require_stacking)
158
 
        except errors.UnknownErrorFromSmartServer, err:
159
 
            if err.error_tuple != ('BranchReference',):
160
 
                raise
161
 
            # We need to resolve the branch reference to determine the
162
 
            # cloning_metadir.  This causes unnecessary RPCs to open the
163
 
            # referenced branch (and bzrdir, etc) but only when the caller
164
 
            # didn't already resolve the branch reference.
165
 
            referenced_branch = self.open_branch()
166
 
            return referenced_branch.bzrdir.cloning_metadir()
167
 
        if len(response) != 3:
168
 
            raise errors.UnexpectedSmartServerResponse(response)
169
 
        control_name, repo_name, branch_info = response
170
 
        if len(branch_info) != 2:
171
 
            raise errors.UnexpectedSmartServerResponse(response)
172
 
        branch_ref, branch_name = branch_info
173
 
        format = bzrdir.network_format_registry.get(control_name)
174
 
        if repo_name:
175
 
            format.repository_format = repository.network_format_registry.get(
176
 
                repo_name)
177
 
        if branch_ref == 'ref':
178
 
            # XXX: we need possible_transports here to avoid reopening the
179
 
            # connection to the referenced location
180
 
            ref_bzrdir = BzrDir.open(branch_name)
181
 
            branch_format = ref_bzrdir.cloning_metadir().get_branch_format()
182
 
            format.set_branch_format(branch_format)
183
 
        elif branch_ref == 'branch':
184
 
            if branch_name:
185
 
                format.set_branch_format(
186
 
                    branch.network_format_registry.get(branch_name))
187
 
        else:
188
 
            raise errors.UnexpectedSmartServerResponse(response)
189
 
        return format
190
 
 
191
 
    def create_repository(self, shared=False):
192
 
        # as per meta1 formats - just delegate to the format object which may
193
 
        # be parameterised.
194
 
        result = self._format.repository_format.initialize(self, shared)
195
 
        if not isinstance(result, RemoteRepository):
196
 
            return self.open_repository()
197
 
        else:
198
 
            return result
199
 
 
200
 
    def destroy_repository(self):
201
 
        """See BzrDir.destroy_repository"""
202
 
        self._ensure_real()
203
 
        self._real_bzrdir.destroy_repository()
204
 
 
205
 
    def create_branch(self):
206
 
        # as per meta1 formats - just delegate to the format object which may
207
 
        # be parameterised.
208
 
        real_branch = self._format.get_branch_format().initialize(self)
209
 
        if not isinstance(real_branch, RemoteBranch):
210
 
            result = RemoteBranch(self, self.find_repository(), real_branch)
211
 
        else:
212
 
            result = real_branch
213
 
        # BzrDir.clone_on_transport() uses the result of create_branch but does
214
 
        # not return it to its callers; we save approximately 8% of our round
215
 
        # trips by handing the branch we created back to the first caller to
216
 
        # open_branch rather than probing anew. Long term we need a API in
217
 
        # bzrdir that doesn't discard result objects (like result_branch).
218
 
        # RBC 20090225
219
 
        self._next_open_branch_result = result
220
 
        return result
221
 
 
222
 
    def destroy_branch(self):
223
 
        """See BzrDir.destroy_branch"""
224
 
        self._ensure_real()
225
 
        self._real_bzrdir.destroy_branch()
226
 
        self._next_open_branch_result = None
227
 
 
228
 
    def create_workingtree(self, revision_id=None, from_branch=None):
229
 
        raise errors.NotLocalUrl(self.transport.base)
230
 
 
231
 
    def find_branch_format(self):
232
 
        """Find the branch 'format' for this bzrdir.
233
 
 
234
 
        This might be a synthetic object for e.g. RemoteBranch and SVN.
235
 
        """
236
 
        b = self.open_branch()
237
 
        return b._format
238
 
 
239
 
    def get_branch_reference(self):
240
 
        """See BzrDir.get_branch_reference()."""
241
 
        response = self._get_branch_reference()
242
 
        if response[0] == 'ref':
243
 
            return response[1]
244
 
        else:
245
 
            return None
246
 
 
247
 
    def _get_branch_reference(self):
248
 
        path = self._path_for_remote_call(self._client)
249
 
        medium = self._client._medium
250
 
        if not medium._is_remote_before((1, 13)):
251
 
            try:
252
 
                response = self._call('BzrDir.open_branchV2', path)
253
 
                if response[0] not in ('ref', 'branch'):
254
 
                    raise errors.UnexpectedSmartServerResponse(response)
255
 
                return response
256
 
            except errors.UnknownSmartMethod:
257
 
                medium._remember_remote_is_before((1, 13))
258
 
        response = self._call('BzrDir.open_branch', path)
259
 
        if response[0] != 'ok':
260
 
            raise errors.UnexpectedSmartServerResponse(response)
261
 
        if response[1] != '':
262
 
            return ('ref', response[1])
263
 
        else:
264
 
            return ('branch', '')
265
 
 
266
 
    def _get_tree_branch(self):
267
 
        """See BzrDir._get_tree_branch()."""
268
 
        return None, self.open_branch()
269
 
 
270
 
    def open_branch(self, _unsupported=False, ignore_fallbacks=False):
271
 
        if _unsupported:
272
 
            raise NotImplementedError('unsupported flag support not implemented yet.')
273
 
        if self._next_open_branch_result is not None:
274
 
            # See create_branch for details.
275
 
            result = self._next_open_branch_result
276
 
            self._next_open_branch_result = None
277
 
            return result
278
 
        response = self._get_branch_reference()
279
 
        if response[0] == 'ref':
280
 
            # a branch reference, use the existing BranchReference logic.
281
 
            format = BranchReferenceFormat()
282
 
            return format.open(self, _found=True, location=response[1],
283
 
                ignore_fallbacks=ignore_fallbacks)
284
 
        branch_format_name = response[1]
285
 
        if not branch_format_name:
286
 
            branch_format_name = None
287
 
        format = RemoteBranchFormat(network_name=branch_format_name)
288
 
        return RemoteBranch(self, self.find_repository(), format=format,
289
 
            setup_stacking=not ignore_fallbacks)
290
 
 
291
 
    def _open_repo_v1(self, path):
292
 
        verb = 'BzrDir.find_repository'
293
 
        response = self._call(verb, path)
294
 
        if response[0] != 'ok':
295
 
            raise errors.UnexpectedSmartServerResponse(response)
296
 
        # servers that only support the v1 method don't support external
297
 
        # references either.
298
 
        self._ensure_real()
299
 
        repo = self._real_bzrdir.open_repository()
300
 
        response = response + ('no', repo._format.network_name())
301
 
        return response, repo
302
 
 
303
 
    def _open_repo_v2(self, path):
304
 
        verb = 'BzrDir.find_repositoryV2'
305
 
        response = self._call(verb, path)
306
 
        if response[0] != 'ok':
307
 
            raise errors.UnexpectedSmartServerResponse(response)
308
 
        self._ensure_real()
309
 
        repo = self._real_bzrdir.open_repository()
310
 
        response = response + (repo._format.network_name(),)
311
 
        return response, repo
312
 
 
313
 
    def _open_repo_v3(self, path):
314
 
        verb = 'BzrDir.find_repositoryV3'
315
 
        medium = self._client._medium
316
 
        if medium._is_remote_before((1, 13)):
317
 
            raise errors.UnknownSmartMethod(verb)
318
 
        try:
319
 
            response = self._call(verb, path)
320
 
        except errors.UnknownSmartMethod:
321
 
            medium._remember_remote_is_before((1, 13))
322
 
            raise
323
 
        if response[0] != 'ok':
324
 
            raise errors.UnexpectedSmartServerResponse(response)
325
 
        return response, None
326
 
 
327
 
    def open_repository(self):
328
 
        path = self._path_for_remote_call(self._client)
329
 
        response = None
330
 
        for probe in [self._open_repo_v3, self._open_repo_v2,
331
 
            self._open_repo_v1]:
332
 
            try:
333
 
                response, real_repo = probe(path)
334
 
                break
335
 
            except errors.UnknownSmartMethod:
336
 
                pass
337
 
        if response is None:
338
 
            raise errors.UnknownSmartMethod('BzrDir.find_repository{3,2,}')
339
 
        if response[0] != 'ok':
340
 
            raise errors.UnexpectedSmartServerResponse(response)
341
 
        if len(response) != 6:
342
 
            raise SmartProtocolError('incorrect response length %s' % (response,))
343
 
        if response[1] == '':
344
 
            # repo is at this dir.
345
 
            format = response_tuple_to_repo_format(response[2:])
346
 
            # Used to support creating a real format instance when needed.
347
 
            format._creating_bzrdir = self
348
 
            remote_repo = RemoteRepository(self, format)
349
 
            format._creating_repo = remote_repo
350
 
            if real_repo is not None:
351
 
                remote_repo._set_real_repository(real_repo)
352
 
            return remote_repo
353
 
        else:
354
 
            raise errors.NoRepositoryPresent(self)
355
 
 
356
 
    def open_workingtree(self, recommend_upgrade=True):
357
 
        self._ensure_real()
358
 
        if self._real_bzrdir.has_workingtree():
359
 
            raise errors.NotLocalUrl(self.root_transport)
360
 
        else:
361
 
            raise errors.NoWorkingTree(self.root_transport.base)
362
 
 
363
 
    def _path_for_remote_call(self, client):
364
 
        """Return the path to be used for this bzrdir in a remote call."""
365
 
        return client.remote_path_from_transport(self.root_transport)
366
 
 
367
 
    def get_branch_transport(self, branch_format):
368
 
        self._ensure_real()
369
 
        return self._real_bzrdir.get_branch_transport(branch_format)
370
 
 
371
 
    def get_repository_transport(self, repository_format):
372
 
        self._ensure_real()
373
 
        return self._real_bzrdir.get_repository_transport(repository_format)
374
 
 
375
 
    def get_workingtree_transport(self, workingtree_format):
376
 
        self._ensure_real()
377
 
        return self._real_bzrdir.get_workingtree_transport(workingtree_format)
378
 
 
379
 
    def can_convert_format(self):
380
 
        """Upgrading of remote bzrdirs is not supported yet."""
381
 
        return False
382
 
 
383
 
    def needs_format_conversion(self, format=None):
384
 
        """Upgrading of remote bzrdirs is not supported yet."""
385
 
        if format is None:
386
 
            symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
387
 
                % 'needs_format_conversion(format=None)')
388
 
        return False
389
 
 
390
 
    def clone(self, url, revision_id=None, force_new_repo=False,
391
 
              preserve_stacking=False):
392
 
        self._ensure_real()
393
 
        return self._real_bzrdir.clone(url, revision_id=revision_id,
394
 
            force_new_repo=force_new_repo, preserve_stacking=preserve_stacking)
395
 
 
396
 
    def _get_config(self):
397
 
        return RemoteBzrDirConfig(self)
398
 
 
399
 
 
400
 
class RemoteRepositoryFormat(repository.RepositoryFormat):
401
 
    """Format for repositories accessed over a _SmartClient.
402
 
 
403
 
    Instances of this repository are represented by RemoteRepository
404
 
    instances.
405
 
 
406
 
    The RemoteRepositoryFormat is parameterized during construction
407
 
    to reflect the capabilities of the real, remote format. Specifically
408
 
    the attributes rich_root_data and supports_tree_reference are set
409
 
    on a per instance basis, and are not set (and should not be) at
410
 
    the class level.
411
 
 
412
 
    :ivar _custom_format: If set, a specific concrete repository format that
413
 
        will be used when initializing a repository with this
414
 
        RemoteRepositoryFormat.
415
 
    :ivar _creating_repo: If set, the repository object that this
416
 
        RemoteRepositoryFormat was created for: it can be called into
417
 
        to obtain data like the network name.
418
 
    """
419
 
 
420
 
    _matchingbzrdir = RemoteBzrDirFormat()
421
 
 
422
 
    def __init__(self):
423
 
        repository.RepositoryFormat.__init__(self)
424
 
        self._custom_format = None
425
 
        self._network_name = None
426
 
        self._creating_bzrdir = None
427
 
        self._supports_external_lookups = None
428
 
        self._supports_tree_reference = None
429
 
        self._rich_root_data = None
430
 
 
431
 
    @property
432
 
    def fast_deltas(self):
433
 
        self._ensure_real()
434
 
        return self._custom_format.fast_deltas
435
 
 
436
 
    @property
437
 
    def rich_root_data(self):
438
 
        if self._rich_root_data is None:
439
 
            self._ensure_real()
440
 
            self._rich_root_data = self._custom_format.rich_root_data
441
 
        return self._rich_root_data
442
 
 
443
 
    @property
444
 
    def supports_external_lookups(self):
445
 
        if self._supports_external_lookups is None:
446
 
            self._ensure_real()
447
 
            self._supports_external_lookups = \
448
 
                self._custom_format.supports_external_lookups
449
 
        return self._supports_external_lookups
450
 
 
451
 
    @property
452
 
    def supports_tree_reference(self):
453
 
        if self._supports_tree_reference is None:
454
 
            self._ensure_real()
455
 
            self._supports_tree_reference = \
456
 
                self._custom_format.supports_tree_reference
457
 
        return self._supports_tree_reference
458
 
 
459
 
    def _vfs_initialize(self, a_bzrdir, shared):
460
 
        """Helper for common code in initialize."""
461
 
        if self._custom_format:
462
 
            # Custom format requested
463
 
            result = self._custom_format.initialize(a_bzrdir, shared=shared)
464
 
        elif self._creating_bzrdir is not None:
465
 
            # Use the format that the repository we were created to back
466
 
            # has.
467
 
            prior_repo = self._creating_bzrdir.open_repository()
468
 
            prior_repo._ensure_real()
469
 
            result = prior_repo._real_repository._format.initialize(
470
 
                a_bzrdir, shared=shared)
471
 
        else:
472
 
            # assume that a_bzr is a RemoteBzrDir but the smart server didn't
473
 
            # support remote initialization.
474
 
            # We delegate to a real object at this point (as RemoteBzrDir
475
 
            # delegate to the repository format which would lead to infinite
476
 
            # recursion if we just called a_bzrdir.create_repository.
477
 
            a_bzrdir._ensure_real()
478
 
            result = a_bzrdir._real_bzrdir.create_repository(shared=shared)
479
 
        if not isinstance(result, RemoteRepository):
480
 
            return self.open(a_bzrdir)
481
 
        else:
482
 
            return result
483
 
 
484
 
    def initialize(self, a_bzrdir, shared=False):
485
 
        # Being asked to create on a non RemoteBzrDir:
486
 
        if not isinstance(a_bzrdir, RemoteBzrDir):
487
 
            return self._vfs_initialize(a_bzrdir, shared)
488
 
        medium = a_bzrdir._client._medium
489
 
        if medium._is_remote_before((1, 13)):
490
 
            return self._vfs_initialize(a_bzrdir, shared)
491
 
        # Creating on a remote bzr dir.
492
 
        # 1) get the network name to use.
493
 
        if self._custom_format:
494
 
            network_name = self._custom_format.network_name()
495
 
        elif self._network_name:
496
 
            network_name = self._network_name
497
 
        else:
498
 
            # Select the current bzrlib default and ask for that.
499
 
            reference_bzrdir_format = bzrdir.format_registry.get('default')()
500
 
            reference_format = reference_bzrdir_format.repository_format
501
 
            network_name = reference_format.network_name()
502
 
        # 2) try direct creation via RPC
503
 
        path = a_bzrdir._path_for_remote_call(a_bzrdir._client)
504
 
        verb = 'BzrDir.create_repository'
505
 
        if shared:
506
 
            shared_str = 'True'
507
 
        else:
508
 
            shared_str = 'False'
509
 
        try:
510
 
            response = a_bzrdir._call(verb, path, network_name, shared_str)
511
 
        except errors.UnknownSmartMethod:
512
 
            # Fallback - use vfs methods
513
 
            medium._remember_remote_is_before((1, 13))
514
 
            return self._vfs_initialize(a_bzrdir, shared)
515
 
        else:
516
 
            # Turn the response into a RemoteRepository object.
517
 
            format = response_tuple_to_repo_format(response[1:])
518
 
            # Used to support creating a real format instance when needed.
519
 
            format._creating_bzrdir = a_bzrdir
520
 
            remote_repo = RemoteRepository(a_bzrdir, format)
521
 
            format._creating_repo = remote_repo
522
 
            return remote_repo
523
 
 
524
 
    def open(self, a_bzrdir):
525
 
        if not isinstance(a_bzrdir, RemoteBzrDir):
526
 
            raise AssertionError('%r is not a RemoteBzrDir' % (a_bzrdir,))
527
 
        return a_bzrdir.open_repository()
528
 
 
529
 
    def _ensure_real(self):
530
 
        if self._custom_format is None:
531
 
            self._custom_format = repository.network_format_registry.get(
532
 
                self._network_name)
533
 
 
534
 
    @property
535
 
    def _fetch_order(self):
536
 
        self._ensure_real()
537
 
        return self._custom_format._fetch_order
538
 
 
539
 
    @property
540
 
    def _fetch_uses_deltas(self):
541
 
        self._ensure_real()
542
 
        return self._custom_format._fetch_uses_deltas
543
 
 
544
 
    @property
545
 
    def _fetch_reconcile(self):
546
 
        self._ensure_real()
547
 
        return self._custom_format._fetch_reconcile
548
 
 
549
 
    def get_format_description(self):
550
 
        return 'bzr remote repository'
551
 
 
552
 
    def __eq__(self, other):
553
 
        return self.__class__ is other.__class__
554
 
 
555
 
    def check_conversion_target(self, target_format):
556
 
        if self.rich_root_data and not target_format.rich_root_data:
557
 
            raise errors.BadConversionTarget(
558
 
                'Does not support rich root data.', target_format)
559
 
        if (self.supports_tree_reference and
560
 
            not getattr(target_format, 'supports_tree_reference', False)):
561
 
            raise errors.BadConversionTarget(
562
 
                'Does not support nested trees', target_format)
563
 
 
564
 
    def network_name(self):
565
 
        if self._network_name:
566
 
            return self._network_name
567
 
        self._creating_repo._ensure_real()
568
 
        return self._creating_repo._real_repository._format.network_name()
569
 
 
570
 
    @property
571
 
    def _serializer(self):
572
 
        self._ensure_real()
573
 
        return self._custom_format._serializer
574
 
 
575
 
 
576
 
class RemoteRepository(_RpcHelper):
577
 
    """Repository accessed over rpc.
578
 
 
579
 
    For the moment most operations are performed using local transport-backed
580
 
    Repository objects.
581
 
    """
582
 
 
583
 
    def __init__(self, remote_bzrdir, format, real_repository=None, _client=None):
584
 
        """Create a RemoteRepository instance.
585
 
 
586
 
        :param remote_bzrdir: The bzrdir hosting this repository.
587
 
        :param format: The RemoteFormat object to use.
588
 
        :param real_repository: If not None, a local implementation of the
589
 
            repository logic for the repository, usually accessing the data
590
 
            via the VFS.
591
 
        :param _client: Private testing parameter - override the smart client
592
 
            to be used by the repository.
593
 
        """
594
 
        if real_repository:
595
 
            self._real_repository = real_repository
596
 
        else:
597
 
            self._real_repository = None
598
 
        self.bzrdir = remote_bzrdir
599
 
        if _client is None:
600
 
            self._client = remote_bzrdir._client
601
 
        else:
602
 
            self._client = _client
603
 
        self._format = format
604
 
        self._lock_mode = None
605
 
        self._lock_token = None
606
 
        self._lock_count = 0
607
 
        self._leave_lock = False
608
 
        # Cache of revision parents; misses are cached during read locks, and
609
 
        # write locks when no _real_repository has been set.
610
 
        self._unstacked_provider = graph.CachingParentsProvider(
611
 
            get_parent_map=self._get_parent_map_rpc)
612
 
        self._unstacked_provider.disable_cache()
613
 
        # For tests:
614
 
        # These depend on the actual remote format, so force them off for
615
 
        # maximum compatibility. XXX: In future these should depend on the
616
 
        # remote repository instance, but this is irrelevant until we perform
617
 
        # reconcile via an RPC call.
618
 
        self._reconcile_does_inventory_gc = False
619
 
        self._reconcile_fixes_text_parents = False
620
 
        self._reconcile_backsup_inventory = False
621
 
        self.base = self.bzrdir.transport.base
622
 
        # Additional places to query for data.
623
 
        self._fallback_repositories = []
624
 
 
625
 
    def __str__(self):
626
 
        return "%s(%s)" % (self.__class__.__name__, self.base)
627
 
 
628
 
    __repr__ = __str__
629
 
 
630
 
    def abort_write_group(self, suppress_errors=False):
631
 
        """Complete a write group on the decorated repository.
632
 
 
633
 
        Smart methods perform operations in a single step so this API
634
 
        is not really applicable except as a compatibility thunk
635
 
        for older plugins that don't use e.g. the CommitBuilder
636
 
        facility.
637
 
 
638
 
        :param suppress_errors: see Repository.abort_write_group.
639
 
        """
640
 
        self._ensure_real()
641
 
        return self._real_repository.abort_write_group(
642
 
            suppress_errors=suppress_errors)
643
 
 
644
 
    @property
645
 
    def chk_bytes(self):
646
 
        """Decorate the real repository for now.
647
 
 
648
 
        In the long term a full blown network facility is needed to avoid
649
 
        creating a real repository object locally.
650
 
        """
651
 
        self._ensure_real()
652
 
        return self._real_repository.chk_bytes
653
 
 
654
 
    def commit_write_group(self):
655
 
        """Complete a write group on the decorated repository.
656
 
 
657
 
        Smart methods perform operations in a single step so this API
658
 
        is not really applicable except as a compatibility thunk
659
 
        for older plugins that don't use e.g. the CommitBuilder
660
 
        facility.
661
 
        """
662
 
        self._ensure_real()
663
 
        return self._real_repository.commit_write_group()
664
 
 
665
 
    def resume_write_group(self, tokens):
666
 
        self._ensure_real()
667
 
        return self._real_repository.resume_write_group(tokens)
668
 
 
669
 
    def suspend_write_group(self):
670
 
        self._ensure_real()
671
 
        return self._real_repository.suspend_write_group()
672
 
 
673
 
    def get_missing_parent_inventories(self):
674
 
        self._ensure_real()
675
 
        return self._real_repository.get_missing_parent_inventories()
676
 
 
677
 
    def _ensure_real(self):
678
 
        """Ensure that there is a _real_repository set.
679
 
 
680
 
        Used before calls to self._real_repository.
681
 
 
682
 
        Note that _ensure_real causes many roundtrips to the server which are
683
 
        not desirable, and prevents the use of smart one-roundtrip RPC's to
684
 
        perform complex operations (such as accessing parent data, streaming
685
 
        revisions etc). Adding calls to _ensure_real should only be done when
686
 
        bringing up new functionality, adding fallbacks for smart methods that
687
 
        require a fallback path, and never to replace an existing smart method
688
 
        invocation. If in doubt chat to the bzr network team.
689
 
        """
690
 
        if self._real_repository is None:
691
 
            self._unstacked_provider.missing_keys.clear()
692
 
            self.bzrdir._ensure_real()
693
 
            self._set_real_repository(
694
 
                self.bzrdir._real_bzrdir.open_repository())
695
 
 
696
 
    def _translate_error(self, err, **context):
697
 
        self.bzrdir._translate_error(err, repository=self, **context)
698
 
 
699
 
    def find_text_key_references(self):
700
 
        """Find the text key references within the repository.
701
 
 
702
 
        :return: a dictionary mapping (file_id, revision_id) tuples to altered file-ids to an iterable of
703
 
        revision_ids. Each altered file-ids has the exact revision_ids that
704
 
        altered it listed explicitly.
705
 
        :return: A dictionary mapping text keys ((fileid, revision_id) tuples)
706
 
            to whether they were referred to by the inventory of the
707
 
            revision_id that they contain. The inventory texts from all present
708
 
            revision ids are assessed to generate this report.
709
 
        """
710
 
        self._ensure_real()
711
 
        return self._real_repository.find_text_key_references()
712
 
 
713
 
    def _generate_text_key_index(self):
714
 
        """Generate a new text key index for the repository.
715
 
 
716
 
        This is an expensive function that will take considerable time to run.
717
 
 
718
 
        :return: A dict mapping (file_id, revision_id) tuples to a list of
719
 
            parents, also (file_id, revision_id) tuples.
720
 
        """
721
 
        self._ensure_real()
722
 
        return self._real_repository._generate_text_key_index()
723
 
 
724
 
    def _get_revision_graph(self, revision_id):
725
 
        """Private method for using with old (< 1.2) servers to fallback."""
726
 
        if revision_id is None:
727
 
            revision_id = ''
728
 
        elif revision.is_null(revision_id):
729
 
            return {}
730
 
 
731
 
        path = self.bzrdir._path_for_remote_call(self._client)
732
 
        response = self._call_expecting_body(
733
 
            'Repository.get_revision_graph', path, revision_id)
734
 
        response_tuple, response_handler = response
735
 
        if response_tuple[0] != 'ok':
736
 
            raise errors.UnexpectedSmartServerResponse(response_tuple)
737
 
        coded = response_handler.read_body_bytes()
738
 
        if coded == '':
739
 
            # no revisions in this repository!
740
 
            return {}
741
 
        lines = coded.split('\n')
742
 
        revision_graph = {}
743
 
        for line in lines:
744
 
            d = tuple(line.split())
745
 
            revision_graph[d[0]] = d[1:]
746
 
 
747
 
        return revision_graph
748
 
 
749
 
    def _get_sink(self):
750
 
        """See Repository._get_sink()."""
751
 
        return RemoteStreamSink(self)
752
 
 
753
 
    def _get_source(self, to_format):
754
 
        """Return a source for streaming from this repository."""
755
 
        return RemoteStreamSource(self, to_format)
756
 
 
757
 
    @needs_read_lock
758
 
    def has_revision(self, revision_id):
759
 
        """True if this repository has a copy of the revision."""
760
 
        # Copy of bzrlib.repository.Repository.has_revision
761
 
        return revision_id in self.has_revisions((revision_id,))
762
 
 
763
 
    @needs_read_lock
764
 
    def has_revisions(self, revision_ids):
765
 
        """Probe to find out the presence of multiple revisions.
766
 
 
767
 
        :param revision_ids: An iterable of revision_ids.
768
 
        :return: A set of the revision_ids that were present.
769
 
        """
770
 
        # Copy of bzrlib.repository.Repository.has_revisions
771
 
        parent_map = self.get_parent_map(revision_ids)
772
 
        result = set(parent_map)
773
 
        if _mod_revision.NULL_REVISION in revision_ids:
774
 
            result.add(_mod_revision.NULL_REVISION)
775
 
        return result
776
 
 
777
 
    def has_same_location(self, other):
778
 
        return (self.__class__ is other.__class__ and
779
 
                self.bzrdir.transport.base == other.bzrdir.transport.base)
780
 
 
781
 
    def get_graph(self, other_repository=None):
782
 
        """Return the graph for this repository format"""
783
 
        parents_provider = self._make_parents_provider(other_repository)
784
 
        return graph.Graph(parents_provider)
785
 
 
786
 
    def gather_stats(self, revid=None, committers=None):
787
 
        """See Repository.gather_stats()."""
788
 
        path = self.bzrdir._path_for_remote_call(self._client)
789
 
        # revid can be None to indicate no revisions, not just NULL_REVISION
790
 
        if revid is None or revision.is_null(revid):
791
 
            fmt_revid = ''
792
 
        else:
793
 
            fmt_revid = revid
794
 
        if committers is None or not committers:
795
 
            fmt_committers = 'no'
796
 
        else:
797
 
            fmt_committers = 'yes'
798
 
        response_tuple, response_handler = self._call_expecting_body(
799
 
            'Repository.gather_stats', path, fmt_revid, fmt_committers)
800
 
        if response_tuple[0] != 'ok':
801
 
            raise errors.UnexpectedSmartServerResponse(response_tuple)
802
 
 
803
 
        body = response_handler.read_body_bytes()
804
 
        result = {}
805
 
        for line in body.split('\n'):
806
 
            if not line:
807
 
                continue
808
 
            key, val_text = line.split(':')
809
 
            if key in ('revisions', 'size', 'committers'):
810
 
                result[key] = int(val_text)
811
 
            elif key in ('firstrev', 'latestrev'):
812
 
                values = val_text.split(' ')[1:]
813
 
                result[key] = (float(values[0]), long(values[1]))
814
 
 
815
 
        return result
816
 
 
817
 
    def find_branches(self, using=False):
818
 
        """See Repository.find_branches()."""
819
 
        # should be an API call to the server.
820
 
        self._ensure_real()
821
 
        return self._real_repository.find_branches(using=using)
822
 
 
823
 
    def get_physical_lock_status(self):
824
 
        """See Repository.get_physical_lock_status()."""
825
 
        # should be an API call to the server.
826
 
        self._ensure_real()
827
 
        return self._real_repository.get_physical_lock_status()
828
 
 
829
 
    def is_in_write_group(self):
830
 
        """Return True if there is an open write group.
831
 
 
832
 
        write groups are only applicable locally for the smart server..
833
 
        """
834
 
        if self._real_repository:
835
 
            return self._real_repository.is_in_write_group()
836
 
 
837
 
    def is_locked(self):
838
 
        return self._lock_count >= 1
839
 
 
840
 
    def is_shared(self):
841
 
        """See Repository.is_shared()."""
842
 
        path = self.bzrdir._path_for_remote_call(self._client)
843
 
        response = self._call('Repository.is_shared', path)
844
 
        if response[0] not in ('yes', 'no'):
845
 
            raise SmartProtocolError('unexpected response code %s' % (response,))
846
 
        return response[0] == 'yes'
847
 
 
848
 
    def is_write_locked(self):
849
 
        return self._lock_mode == 'w'
850
 
 
851
 
    def lock_read(self):
852
 
        # wrong eventually - want a local lock cache context
853
 
        if not self._lock_mode:
854
 
            self._lock_mode = 'r'
855
 
            self._lock_count = 1
856
 
            self._unstacked_provider.enable_cache(cache_misses=True)
857
 
            if self._real_repository is not None:
858
 
                self._real_repository.lock_read()
859
 
        else:
860
 
            self._lock_count += 1
861
 
        for repo in self._fallback_repositories:
862
 
            repo.lock_read()
863
 
 
864
 
    def _remote_lock_write(self, token):
865
 
        path = self.bzrdir._path_for_remote_call(self._client)
866
 
        if token is None:
867
 
            token = ''
868
 
        err_context = {'token': token}
869
 
        response = self._call('Repository.lock_write', path, token,
870
 
                              **err_context)
871
 
        if response[0] == 'ok':
872
 
            ok, token = response
873
 
            return token
874
 
        else:
875
 
            raise errors.UnexpectedSmartServerResponse(response)
876
 
 
877
 
    def lock_write(self, token=None, _skip_rpc=False):
878
 
        if not self._lock_mode:
879
 
            if _skip_rpc:
880
 
                if self._lock_token is not None:
881
 
                    if token != self._lock_token:
882
 
                        raise errors.TokenMismatch(token, self._lock_token)
883
 
                self._lock_token = token
884
 
            else:
885
 
                self._lock_token = self._remote_lock_write(token)
886
 
            # if self._lock_token is None, then this is something like packs or
887
 
            # svn where we don't get to lock the repo, or a weave style repository
888
 
            # where we cannot lock it over the wire and attempts to do so will
889
 
            # fail.
890
 
            if self._real_repository is not None:
891
 
                self._real_repository.lock_write(token=self._lock_token)
892
 
            if token is not None:
893
 
                self._leave_lock = True
894
 
            else:
895
 
                self._leave_lock = False
896
 
            self._lock_mode = 'w'
897
 
            self._lock_count = 1
898
 
            cache_misses = self._real_repository is None
899
 
            self._unstacked_provider.enable_cache(cache_misses=cache_misses)
900
 
        elif self._lock_mode == 'r':
901
 
            raise errors.ReadOnlyError(self)
902
 
        else:
903
 
            self._lock_count += 1
904
 
        for repo in self._fallback_repositories:
905
 
            # Writes don't affect fallback repos
906
 
            repo.lock_read()
907
 
        return self._lock_token or None
908
 
 
909
 
    def leave_lock_in_place(self):
910
 
        if not self._lock_token:
911
 
            raise NotImplementedError(self.leave_lock_in_place)
912
 
        self._leave_lock = True
913
 
 
914
 
    def dont_leave_lock_in_place(self):
915
 
        if not self._lock_token:
916
 
            raise NotImplementedError(self.dont_leave_lock_in_place)
917
 
        self._leave_lock = False
918
 
 
919
 
    def _set_real_repository(self, repository):
920
 
        """Set the _real_repository for this repository.
921
 
 
922
 
        :param repository: The repository to fallback to for non-hpss
923
 
            implemented operations.
924
 
        """
925
 
        if self._real_repository is not None:
926
 
            # Replacing an already set real repository.
927
 
            # We cannot do this [currently] if the repository is locked -
928
 
            # synchronised state might be lost.
929
 
            if self.is_locked():
930
 
                raise AssertionError('_real_repository is already set')
931
 
        if isinstance(repository, RemoteRepository):
932
 
            raise AssertionError()
933
 
        self._real_repository = repository
934
 
        # three code paths happen here:
935
 
        # 1) old servers, RemoteBranch.open() calls _ensure_real before setting
936
 
        # up stacking. In this case self._fallback_repositories is [], and the
937
 
        # real repo is already setup. Preserve the real repo and
938
 
        # RemoteRepository.add_fallback_repository will avoid adding
939
 
        # duplicates.
940
 
        # 2) new servers, RemoteBranch.open() sets up stacking, and when
941
 
        # ensure_real is triggered from a branch, the real repository to
942
 
        # set already has a matching list with separate instances, but
943
 
        # as they are also RemoteRepositories we don't worry about making the
944
 
        # lists be identical.
945
 
        # 3) new servers, RemoteRepository.ensure_real is triggered before
946
 
        # RemoteBranch.ensure real, in this case we get a repo with no fallbacks
947
 
        # and need to populate it.
948
 
        if (self._fallback_repositories and
949
 
            len(self._real_repository._fallback_repositories) !=
950
 
            len(self._fallback_repositories)):
951
 
            if len(self._real_repository._fallback_repositories):
952
 
                raise AssertionError(
953
 
                    "cannot cleanly remove existing _fallback_repositories")
954
 
        for fb in self._fallback_repositories:
955
 
            self._real_repository.add_fallback_repository(fb)
956
 
        if self._lock_mode == 'w':
957
 
            # if we are already locked, the real repository must be able to
958
 
            # acquire the lock with our token.
959
 
            self._real_repository.lock_write(self._lock_token)
960
 
        elif self._lock_mode == 'r':
961
 
            self._real_repository.lock_read()
962
 
 
963
 
    def start_write_group(self):
964
 
        """Start a write group on the decorated repository.
965
 
 
966
 
        Smart methods perform operations in a single step so this API
967
 
        is not really applicable except as a compatibility thunk
968
 
        for older plugins that don't use e.g. the CommitBuilder
969
 
        facility.
970
 
        """
971
 
        self._ensure_real()
972
 
        return self._real_repository.start_write_group()
973
 
 
974
 
    def _unlock(self, token):
975
 
        path = self.bzrdir._path_for_remote_call(self._client)
976
 
        if not token:
977
 
            # with no token the remote repository is not persistently locked.
978
 
            return
979
 
        err_context = {'token': token}
980
 
        response = self._call('Repository.unlock', path, token,
981
 
                              **err_context)
982
 
        if response == ('ok',):
983
 
            return
984
 
        else:
985
 
            raise errors.UnexpectedSmartServerResponse(response)
986
 
 
987
 
    def unlock(self):
988
 
        if not self._lock_count:
989
 
            raise errors.LockNotHeld(self)
990
 
        self._lock_count -= 1
991
 
        if self._lock_count > 0:
992
 
            return
993
 
        self._unstacked_provider.disable_cache()
994
 
        old_mode = self._lock_mode
995
 
        self._lock_mode = None
996
 
        try:
997
 
            # The real repository is responsible at present for raising an
998
 
            # exception if it's in an unfinished write group.  However, it
999
 
            # normally will *not* actually remove the lock from disk - that's
1000
 
            # done by the server on receiving the Repository.unlock call.
1001
 
            # This is just to let the _real_repository stay up to date.
1002
 
            if self._real_repository is not None:
1003
 
                self._real_repository.unlock()
1004
 
        finally:
1005
 
            # The rpc-level lock should be released even if there was a
1006
 
            # problem releasing the vfs-based lock.
1007
 
            if old_mode == 'w':
1008
 
                # Only write-locked repositories need to make a remote method
1009
 
                # call to perform the unlock.
1010
 
                old_token = self._lock_token
1011
 
                self._lock_token = None
1012
 
                if not self._leave_lock:
1013
 
                    self._unlock(old_token)
1014
 
 
1015
 
    def break_lock(self):
1016
 
        # should hand off to the network
1017
 
        self._ensure_real()
1018
 
        return self._real_repository.break_lock()
1019
 
 
1020
 
    def _get_tarball(self, compression):
1021
 
        """Return a TemporaryFile containing a repository tarball.
1022
 
 
1023
 
        Returns None if the server does not support sending tarballs.
1024
 
        """
1025
 
        import tempfile
1026
 
        path = self.bzrdir._path_for_remote_call(self._client)
1027
 
        try:
1028
 
            response, protocol = self._call_expecting_body(
1029
 
                'Repository.tarball', path, compression)
1030
 
        except errors.UnknownSmartMethod:
1031
 
            protocol.cancel_read_body()
1032
 
            return None
1033
 
        if response[0] == 'ok':
1034
 
            # Extract the tarball and return it
1035
 
            t = tempfile.NamedTemporaryFile()
1036
 
            # TODO: rpc layer should read directly into it...
1037
 
            t.write(protocol.read_body_bytes())
1038
 
            t.seek(0)
1039
 
            return t
1040
 
        raise errors.UnexpectedSmartServerResponse(response)
1041
 
 
1042
 
    def sprout(self, to_bzrdir, revision_id=None):
1043
 
        # TODO: Option to control what format is created?
1044
 
        self._ensure_real()
1045
 
        dest_repo = self._real_repository._format.initialize(to_bzrdir,
1046
 
                                                             shared=False)
1047
 
        dest_repo.fetch(self, revision_id=revision_id)
1048
 
        return dest_repo
1049
 
 
1050
 
    ### These methods are just thin shims to the VFS object for now.
1051
 
 
1052
 
    def revision_tree(self, revision_id):
1053
 
        self._ensure_real()
1054
 
        return self._real_repository.revision_tree(revision_id)
1055
 
 
1056
 
    def get_serializer_format(self):
1057
 
        self._ensure_real()
1058
 
        return self._real_repository.get_serializer_format()
1059
 
 
1060
 
    def get_commit_builder(self, branch, parents, config, timestamp=None,
1061
 
                           timezone=None, committer=None, revprops=None,
1062
 
                           revision_id=None):
1063
 
        # FIXME: It ought to be possible to call this without immediately
1064
 
        # triggering _ensure_real.  For now it's the easiest thing to do.
1065
 
        self._ensure_real()
1066
 
        real_repo = self._real_repository
1067
 
        builder = real_repo.get_commit_builder(branch, parents,
1068
 
                config, timestamp=timestamp, timezone=timezone,
1069
 
                committer=committer, revprops=revprops, revision_id=revision_id)
1070
 
        return builder
1071
 
 
1072
 
    def add_fallback_repository(self, repository):
1073
 
        """Add a repository to use for looking up data not held locally.
1074
 
 
1075
 
        :param repository: A repository.
1076
 
        """
1077
 
        if not self._format.supports_external_lookups:
1078
 
            raise errors.UnstackableRepositoryFormat(
1079
 
                self._format.network_name(), self.base)
1080
 
        # We need to accumulate additional repositories here, to pass them in
1081
 
        # on various RPC's.
1082
 
        #
1083
 
        self._fallback_repositories.append(repository)
1084
 
        # If self._real_repository was parameterised already (e.g. because a
1085
 
        # _real_branch had its get_stacked_on_url method called), then the
1086
 
        # repository to be added may already be in the _real_repositories list.
1087
 
        if self._real_repository is not None:
1088
 
            fallback_locations = [repo.bzrdir.root_transport.base for repo in
1089
 
                self._real_repository._fallback_repositories]
1090
 
            if repository.bzrdir.root_transport.base not in fallback_locations:
1091
 
                self._real_repository.add_fallback_repository(repository)
1092
 
 
1093
 
    def add_inventory(self, revid, inv, parents):
1094
 
        self._ensure_real()
1095
 
        return self._real_repository.add_inventory(revid, inv, parents)
1096
 
 
1097
 
    def add_inventory_by_delta(self, basis_revision_id, delta, new_revision_id,
1098
 
                               parents):
1099
 
        self._ensure_real()
1100
 
        return self._real_repository.add_inventory_by_delta(basis_revision_id,
1101
 
            delta, new_revision_id, parents)
1102
 
 
1103
 
    def add_revision(self, rev_id, rev, inv=None, config=None):
1104
 
        self._ensure_real()
1105
 
        return self._real_repository.add_revision(
1106
 
            rev_id, rev, inv=inv, config=config)
1107
 
 
1108
 
    @needs_read_lock
1109
 
    def get_inventory(self, revision_id):
1110
 
        self._ensure_real()
1111
 
        return self._real_repository.get_inventory(revision_id)
1112
 
 
1113
 
    def iter_inventories(self, revision_ids):
1114
 
        self._ensure_real()
1115
 
        return self._real_repository.iter_inventories(revision_ids)
1116
 
 
1117
 
    @needs_read_lock
1118
 
    def get_revision(self, revision_id):
1119
 
        self._ensure_real()
1120
 
        return self._real_repository.get_revision(revision_id)
1121
 
 
1122
 
    def get_transaction(self):
1123
 
        self._ensure_real()
1124
 
        return self._real_repository.get_transaction()
1125
 
 
1126
 
    @needs_read_lock
1127
 
    def clone(self, a_bzrdir, revision_id=None):
1128
 
        self._ensure_real()
1129
 
        return self._real_repository.clone(a_bzrdir, revision_id=revision_id)
1130
 
 
1131
 
    def make_working_trees(self):
1132
 
        """See Repository.make_working_trees"""
1133
 
        self._ensure_real()
1134
 
        return self._real_repository.make_working_trees()
1135
 
 
1136
 
    def refresh_data(self):
1137
 
        """Re-read any data needed to to synchronise with disk.
1138
 
 
1139
 
        This method is intended to be called after another repository instance
1140
 
        (such as one used by a smart server) has inserted data into the
1141
 
        repository. It may not be called during a write group, but may be
1142
 
        called at any other time.
1143
 
        """
1144
 
        if self.is_in_write_group():
1145
 
            raise errors.InternalBzrError(
1146
 
                "May not refresh_data while in a write group.")
1147
 
        if self._real_repository is not None:
1148
 
            self._real_repository.refresh_data()
1149
 
 
1150
 
    def revision_ids_to_search_result(self, result_set):
1151
 
        """Convert a set of revision ids to a graph SearchResult."""
1152
 
        result_parents = set()
1153
 
        for parents in self.get_graph().get_parent_map(
1154
 
            result_set).itervalues():
1155
 
            result_parents.update(parents)
1156
 
        included_keys = result_set.intersection(result_parents)
1157
 
        start_keys = result_set.difference(included_keys)
1158
 
        exclude_keys = result_parents.difference(result_set)
1159
 
        result = graph.SearchResult(start_keys, exclude_keys,
1160
 
            len(result_set), result_set)
1161
 
        return result
1162
 
 
1163
 
    @needs_read_lock
1164
 
    def search_missing_revision_ids(self, other, revision_id=None, find_ghosts=True):
1165
 
        """Return the revision ids that other has that this does not.
1166
 
 
1167
 
        These are returned in topological order.
1168
 
 
1169
 
        revision_id: only return revision ids included by revision_id.
1170
 
        """
1171
 
        return repository.InterRepository.get(
1172
 
            other, self).search_missing_revision_ids(revision_id, find_ghosts)
1173
 
 
1174
 
    def fetch(self, source, revision_id=None, pb=None, find_ghosts=False,
1175
 
            fetch_spec=None):
1176
 
        # No base implementation to use as RemoteRepository is not a subclass
1177
 
        # of Repository; so this is a copy of Repository.fetch().
1178
 
        if fetch_spec is not None and revision_id is not None:
1179
 
            raise AssertionError(
1180
 
                "fetch_spec and revision_id are mutually exclusive.")
1181
 
        if self.is_in_write_group():
1182
 
            raise errors.InternalBzrError(
1183
 
                "May not fetch while in a write group.")
1184
 
        # fast path same-url fetch operations
1185
 
        if self.has_same_location(source) and fetch_spec is None:
1186
 
            # check that last_revision is in 'from' and then return a
1187
 
            # no-operation.
1188
 
            if (revision_id is not None and
1189
 
                not revision.is_null(revision_id)):
1190
 
                self.get_revision(revision_id)
1191
 
            return 0, []
1192
 
        # if there is no specific appropriate InterRepository, this will get
1193
 
        # the InterRepository base class, which raises an
1194
 
        # IncompatibleRepositories when asked to fetch.
1195
 
        inter = repository.InterRepository.get(source, self)
1196
 
        return inter.fetch(revision_id=revision_id, pb=pb,
1197
 
            find_ghosts=find_ghosts, fetch_spec=fetch_spec)
1198
 
 
1199
 
    def create_bundle(self, target, base, fileobj, format=None):
1200
 
        self._ensure_real()
1201
 
        self._real_repository.create_bundle(target, base, fileobj, format)
1202
 
 
1203
 
    @needs_read_lock
1204
 
    def get_ancestry(self, revision_id, topo_sorted=True):
1205
 
        self._ensure_real()
1206
 
        return self._real_repository.get_ancestry(revision_id, topo_sorted)
1207
 
 
1208
 
    def fileids_altered_by_revision_ids(self, revision_ids):
1209
 
        self._ensure_real()
1210
 
        return self._real_repository.fileids_altered_by_revision_ids(revision_ids)
1211
 
 
1212
 
    def _get_versioned_file_checker(self, revisions, revision_versions_cache):
1213
 
        self._ensure_real()
1214
 
        return self._real_repository._get_versioned_file_checker(
1215
 
            revisions, revision_versions_cache)
1216
 
 
1217
 
    def iter_files_bytes(self, desired_files):
1218
 
        """See Repository.iter_file_bytes.
1219
 
        """
1220
 
        self._ensure_real()
1221
 
        return self._real_repository.iter_files_bytes(desired_files)
1222
 
 
1223
 
    def get_parent_map(self, revision_ids):
1224
 
        """See bzrlib.Graph.get_parent_map()."""
1225
 
        return self._make_parents_provider().get_parent_map(revision_ids)
1226
 
 
1227
 
    def _get_parent_map_rpc(self, keys):
1228
 
        """Helper for get_parent_map that performs the RPC."""
1229
 
        medium = self._client._medium
1230
 
        if medium._is_remote_before((1, 2)):
1231
 
            # We already found out that the server can't understand
1232
 
            # Repository.get_parent_map requests, so just fetch the whole
1233
 
            # graph.
1234
 
            #
1235
 
            # Note that this reads the whole graph, when only some keys are
1236
 
            # wanted.  On this old server there's no way (?) to get them all
1237
 
            # in one go, and the user probably will have seen a warning about
1238
 
            # the server being old anyhow.
1239
 
            rg = self._get_revision_graph(None)
1240
 
            # There is an API discrepancy between get_parent_map and
1241
 
            # get_revision_graph. Specifically, a "key:()" pair in
1242
 
            # get_revision_graph just means a node has no parents. For
1243
 
            # "get_parent_map" it means the node is a ghost. So fix up the
1244
 
            # graph to correct this.
1245
 
            #   https://bugs.launchpad.net/bzr/+bug/214894
1246
 
            # There is one other "bug" which is that ghosts in
1247
 
            # get_revision_graph() are not returned at all. But we won't worry
1248
 
            # about that for now.
1249
 
            for node_id, parent_ids in rg.iteritems():
1250
 
                if parent_ids == ():
1251
 
                    rg[node_id] = (NULL_REVISION,)
1252
 
            rg[NULL_REVISION] = ()
1253
 
            return rg
1254
 
 
1255
 
        keys = set(keys)
1256
 
        if None in keys:
1257
 
            raise ValueError('get_parent_map(None) is not valid')
1258
 
        if NULL_REVISION in keys:
1259
 
            keys.discard(NULL_REVISION)
1260
 
            found_parents = {NULL_REVISION:()}
1261
 
            if not keys:
1262
 
                return found_parents
1263
 
        else:
1264
 
            found_parents = {}
1265
 
        # TODO(Needs analysis): We could assume that the keys being requested
1266
 
        # from get_parent_map are in a breadth first search, so typically they
1267
 
        # will all be depth N from some common parent, and we don't have to
1268
 
        # have the server iterate from the root parent, but rather from the
1269
 
        # keys we're searching; and just tell the server the keyspace we
1270
 
        # already have; but this may be more traffic again.
1271
 
 
1272
 
        # Transform self._parents_map into a search request recipe.
1273
 
        # TODO: Manage this incrementally to avoid covering the same path
1274
 
        # repeatedly. (The server will have to on each request, but the less
1275
 
        # work done the better).
1276
 
        #
1277
 
        # Negative caching notes:
1278
 
        # new server sends missing when a request including the revid
1279
 
        # 'include-missing:' is present in the request.
1280
 
        # missing keys are serialised as missing:X, and we then call
1281
 
        # provider.note_missing(X) for-all X
1282
 
        parents_map = self._unstacked_provider.get_cached_map()
1283
 
        if parents_map is None:
1284
 
            # Repository is not locked, so there's no cache.
1285
 
            parents_map = {}
1286
 
        # start_set is all the keys in the cache
1287
 
        start_set = set(parents_map)
1288
 
        # result set is all the references to keys in the cache
1289
 
        result_parents = set()
1290
 
        for parents in parents_map.itervalues():
1291
 
            result_parents.update(parents)
1292
 
        stop_keys = result_parents.difference(start_set)
1293
 
        # We don't need to send ghosts back to the server as a position to
1294
 
        # stop either.
1295
 
        stop_keys.difference_update(self._unstacked_provider.missing_keys)
1296
 
        key_count = len(parents_map)
1297
 
        if (NULL_REVISION in result_parents
1298
 
            and NULL_REVISION in self._unstacked_provider.missing_keys):
1299
 
            # If we pruned NULL_REVISION from the stop_keys because it's also
1300
 
            # in our cache of "missing" keys we need to increment our key count
1301
 
            # by 1, because the reconsitituted SearchResult on the server will
1302
 
            # still consider NULL_REVISION to be an included key.
1303
 
            key_count += 1
1304
 
        included_keys = start_set.intersection(result_parents)
1305
 
        start_set.difference_update(included_keys)
1306
 
        recipe = ('manual', start_set, stop_keys, key_count)
1307
 
        body = self._serialise_search_recipe(recipe)
1308
 
        path = self.bzrdir._path_for_remote_call(self._client)
1309
 
        for key in keys:
1310
 
            if type(key) is not str:
1311
 
                raise ValueError(
1312
 
                    "key %r not a plain string" % (key,))
1313
 
        verb = 'Repository.get_parent_map'
1314
 
        args = (path, 'include-missing:') + tuple(keys)
1315
 
        try:
1316
 
            response = self._call_with_body_bytes_expecting_body(
1317
 
                verb, args, body)
1318
 
        except errors.UnknownSmartMethod:
1319
 
            # Server does not support this method, so get the whole graph.
1320
 
            # Worse, we have to force a disconnection, because the server now
1321
 
            # doesn't realise it has a body on the wire to consume, so the
1322
 
            # only way to recover is to abandon the connection.
1323
 
            warning(
1324
 
                'Server is too old for fast get_parent_map, reconnecting.  '
1325
 
                '(Upgrade the server to Bazaar 1.2 to avoid this)')
1326
 
            medium.disconnect()
1327
 
            # To avoid having to disconnect repeatedly, we keep track of the
1328
 
            # fact the server doesn't understand remote methods added in 1.2.
1329
 
            medium._remember_remote_is_before((1, 2))
1330
 
            # Recurse just once and we should use the fallback code.
1331
 
            return self._get_parent_map_rpc(keys)
1332
 
        response_tuple, response_handler = response
1333
 
        if response_tuple[0] not in ['ok']:
1334
 
            response_handler.cancel_read_body()
1335
 
            raise errors.UnexpectedSmartServerResponse(response_tuple)
1336
 
        if response_tuple[0] == 'ok':
1337
 
            coded = bz2.decompress(response_handler.read_body_bytes())
1338
 
            if coded == '':
1339
 
                # no revisions found
1340
 
                return {}
1341
 
            lines = coded.split('\n')
1342
 
            revision_graph = {}
1343
 
            for line in lines:
1344
 
                d = tuple(line.split())
1345
 
                if len(d) > 1:
1346
 
                    revision_graph[d[0]] = d[1:]
1347
 
                else:
1348
 
                    # No parents:
1349
 
                    if d[0].startswith('missing:'):
1350
 
                        revid = d[0][8:]
1351
 
                        self._unstacked_provider.note_missing_key(revid)
1352
 
                    else:
1353
 
                        # no parents - so give the Graph result
1354
 
                        # (NULL_REVISION,).
1355
 
                        revision_graph[d[0]] = (NULL_REVISION,)
1356
 
            return revision_graph
1357
 
 
1358
 
    @needs_read_lock
1359
 
    def get_signature_text(self, revision_id):
1360
 
        self._ensure_real()
1361
 
        return self._real_repository.get_signature_text(revision_id)
1362
 
 
1363
 
    @needs_read_lock
1364
 
    def get_inventory_xml(self, revision_id):
1365
 
        self._ensure_real()
1366
 
        return self._real_repository.get_inventory_xml(revision_id)
1367
 
 
1368
 
    def deserialise_inventory(self, revision_id, xml):
1369
 
        self._ensure_real()
1370
 
        return self._real_repository.deserialise_inventory(revision_id, xml)
1371
 
 
1372
 
    def reconcile(self, other=None, thorough=False):
1373
 
        self._ensure_real()
1374
 
        return self._real_repository.reconcile(other=other, thorough=thorough)
1375
 
 
1376
 
    def all_revision_ids(self):
1377
 
        self._ensure_real()
1378
 
        return self._real_repository.all_revision_ids()
1379
 
 
1380
 
    @needs_read_lock
1381
 
    def get_deltas_for_revisions(self, revisions, specific_fileids=None):
1382
 
        self._ensure_real()
1383
 
        return self._real_repository.get_deltas_for_revisions(revisions,
1384
 
            specific_fileids=specific_fileids)
1385
 
 
1386
 
    @needs_read_lock
1387
 
    def get_revision_delta(self, revision_id, specific_fileids=None):
1388
 
        self._ensure_real()
1389
 
        return self._real_repository.get_revision_delta(revision_id,
1390
 
            specific_fileids=specific_fileids)
1391
 
 
1392
 
    @needs_read_lock
1393
 
    def revision_trees(self, revision_ids):
1394
 
        self._ensure_real()
1395
 
        return self._real_repository.revision_trees(revision_ids)
1396
 
 
1397
 
    @needs_read_lock
1398
 
    def get_revision_reconcile(self, revision_id):
1399
 
        self._ensure_real()
1400
 
        return self._real_repository.get_revision_reconcile(revision_id)
1401
 
 
1402
 
    @needs_read_lock
1403
 
    def check(self, revision_ids=None):
1404
 
        self._ensure_real()
1405
 
        return self._real_repository.check(revision_ids=revision_ids)
1406
 
 
1407
 
    def copy_content_into(self, destination, revision_id=None):
1408
 
        self._ensure_real()
1409
 
        return self._real_repository.copy_content_into(
1410
 
            destination, revision_id=revision_id)
1411
 
 
1412
 
    def _copy_repository_tarball(self, to_bzrdir, revision_id=None):
1413
 
        # get a tarball of the remote repository, and copy from that into the
1414
 
        # destination
1415
 
        from bzrlib import osutils
1416
 
        import tarfile
1417
 
        # TODO: Maybe a progress bar while streaming the tarball?
1418
 
        note("Copying repository content as tarball...")
1419
 
        tar_file = self._get_tarball('bz2')
1420
 
        if tar_file is None:
1421
 
            return None
1422
 
        destination = to_bzrdir.create_repository()
1423
 
        try:
1424
 
            tar = tarfile.open('repository', fileobj=tar_file,
1425
 
                mode='r|bz2')
1426
 
            tmpdir = osutils.mkdtemp()
1427
 
            try:
1428
 
                _extract_tar(tar, tmpdir)
1429
 
                tmp_bzrdir = BzrDir.open(tmpdir)
1430
 
                tmp_repo = tmp_bzrdir.open_repository()
1431
 
                tmp_repo.copy_content_into(destination, revision_id)
1432
 
            finally:
1433
 
                osutils.rmtree(tmpdir)
1434
 
        finally:
1435
 
            tar_file.close()
1436
 
        return destination
1437
 
        # TODO: Suggestion from john: using external tar is much faster than
1438
 
        # python's tarfile library, but it may not work on windows.
1439
 
 
1440
 
    @property
1441
 
    def inventories(self):
1442
 
        """Decorate the real repository for now.
1443
 
 
1444
 
        In the long term a full blown network facility is needed to
1445
 
        avoid creating a real repository object locally.
1446
 
        """
1447
 
        self._ensure_real()
1448
 
        return self._real_repository.inventories
1449
 
 
1450
 
    @needs_write_lock
1451
 
    def pack(self):
1452
 
        """Compress the data within the repository.
1453
 
 
1454
 
        This is not currently implemented within the smart server.
1455
 
        """
1456
 
        self._ensure_real()
1457
 
        return self._real_repository.pack()
1458
 
 
1459
 
    @property
1460
 
    def revisions(self):
1461
 
        """Decorate the real repository for now.
1462
 
 
1463
 
        In the short term this should become a real object to intercept graph
1464
 
        lookups.
1465
 
 
1466
 
        In the long term a full blown network facility is needed.
1467
 
        """
1468
 
        self._ensure_real()
1469
 
        return self._real_repository.revisions
1470
 
 
1471
 
    def set_make_working_trees(self, new_value):
1472
 
        if new_value:
1473
 
            new_value_str = "True"
1474
 
        else:
1475
 
            new_value_str = "False"
1476
 
        path = self.bzrdir._path_for_remote_call(self._client)
1477
 
        try:
1478
 
            response = self._call(
1479
 
                'Repository.set_make_working_trees', path, new_value_str)
1480
 
        except errors.UnknownSmartMethod:
1481
 
            self._ensure_real()
1482
 
            self._real_repository.set_make_working_trees(new_value)
1483
 
        else:
1484
 
            if response[0] != 'ok':
1485
 
                raise errors.UnexpectedSmartServerResponse(response)
1486
 
 
1487
 
    @property
1488
 
    def signatures(self):
1489
 
        """Decorate the real repository for now.
1490
 
 
1491
 
        In the long term a full blown network facility is needed to avoid
1492
 
        creating a real repository object locally.
1493
 
        """
1494
 
        self._ensure_real()
1495
 
        return self._real_repository.signatures
1496
 
 
1497
 
    @needs_write_lock
1498
 
    def sign_revision(self, revision_id, gpg_strategy):
1499
 
        self._ensure_real()
1500
 
        return self._real_repository.sign_revision(revision_id, gpg_strategy)
1501
 
 
1502
 
    @property
1503
 
    def texts(self):
1504
 
        """Decorate the real repository for now.
1505
 
 
1506
 
        In the long term a full blown network facility is needed to avoid
1507
 
        creating a real repository object locally.
1508
 
        """
1509
 
        self._ensure_real()
1510
 
        return self._real_repository.texts
1511
 
 
1512
 
    @needs_read_lock
1513
 
    def get_revisions(self, revision_ids):
1514
 
        self._ensure_real()
1515
 
        return self._real_repository.get_revisions(revision_ids)
1516
 
 
1517
 
    def supports_rich_root(self):
1518
 
        return self._format.rich_root_data
1519
 
 
1520
 
    def iter_reverse_revision_history(self, revision_id):
1521
 
        self._ensure_real()
1522
 
        return self._real_repository.iter_reverse_revision_history(revision_id)
1523
 
 
1524
 
    @property
1525
 
    def _serializer(self):
1526
 
        return self._format._serializer
1527
 
 
1528
 
    def store_revision_signature(self, gpg_strategy, plaintext, revision_id):
1529
 
        self._ensure_real()
1530
 
        return self._real_repository.store_revision_signature(
1531
 
            gpg_strategy, plaintext, revision_id)
1532
 
 
1533
 
    def add_signature_text(self, revision_id, signature):
1534
 
        self._ensure_real()
1535
 
        return self._real_repository.add_signature_text(revision_id, signature)
1536
 
 
1537
 
    def has_signature_for_revision_id(self, revision_id):
1538
 
        self._ensure_real()
1539
 
        return self._real_repository.has_signature_for_revision_id(revision_id)
1540
 
 
1541
 
    def item_keys_introduced_by(self, revision_ids, _files_pb=None):
1542
 
        self._ensure_real()
1543
 
        return self._real_repository.item_keys_introduced_by(revision_ids,
1544
 
            _files_pb=_files_pb)
1545
 
 
1546
 
    def revision_graph_can_have_wrong_parents(self):
1547
 
        # The answer depends on the remote repo format.
1548
 
        self._ensure_real()
1549
 
        return self._real_repository.revision_graph_can_have_wrong_parents()
1550
 
 
1551
 
    def _find_inconsistent_revision_parents(self):
1552
 
        self._ensure_real()
1553
 
        return self._real_repository._find_inconsistent_revision_parents()
1554
 
 
1555
 
    def _check_for_inconsistent_revision_parents(self):
1556
 
        self._ensure_real()
1557
 
        return self._real_repository._check_for_inconsistent_revision_parents()
1558
 
 
1559
 
    def _make_parents_provider(self, other=None):
1560
 
        providers = [self._unstacked_provider]
1561
 
        if other is not None:
1562
 
            providers.insert(0, other)
1563
 
        providers.extend(r._make_parents_provider() for r in
1564
 
                         self._fallback_repositories)
1565
 
        return graph._StackedParentsProvider(providers)
1566
 
 
1567
 
    def _serialise_search_recipe(self, recipe):
1568
 
        """Serialise a graph search recipe.
1569
 
 
1570
 
        :param recipe: A search recipe (start, stop, count).
1571
 
        :return: Serialised bytes.
1572
 
        """
1573
 
        start_keys = ' '.join(recipe[1])
1574
 
        stop_keys = ' '.join(recipe[2])
1575
 
        count = str(recipe[3])
1576
 
        return '\n'.join((start_keys, stop_keys, count))
1577
 
 
1578
 
    def _serialise_search_result(self, search_result):
1579
 
        if isinstance(search_result, graph.PendingAncestryResult):
1580
 
            parts = ['ancestry-of']
1581
 
            parts.extend(search_result.heads)
1582
 
        else:
1583
 
            recipe = search_result.get_recipe()
1584
 
            parts = [recipe[0], self._serialise_search_recipe(recipe)]
1585
 
        return '\n'.join(parts)
1586
 
 
1587
 
    def autopack(self):
1588
 
        path = self.bzrdir._path_for_remote_call(self._client)
1589
 
        try:
1590
 
            response = self._call('PackRepository.autopack', path)
1591
 
        except errors.UnknownSmartMethod:
1592
 
            self._ensure_real()
1593
 
            self._real_repository._pack_collection.autopack()
1594
 
            return
1595
 
        self.refresh_data()
1596
 
        if response[0] != 'ok':
1597
 
            raise errors.UnexpectedSmartServerResponse(response)
1598
 
 
1599
 
 
1600
 
class RemoteStreamSink(repository.StreamSink):
1601
 
 
1602
 
    def _insert_real(self, stream, src_format, resume_tokens):
1603
 
        self.target_repo._ensure_real()
1604
 
        sink = self.target_repo._real_repository._get_sink()
1605
 
        result = sink.insert_stream(stream, src_format, resume_tokens)
1606
 
        if not result:
1607
 
            self.target_repo.autopack()
1608
 
        return result
1609
 
 
1610
 
    def insert_stream(self, stream, src_format, resume_tokens):
1611
 
        target = self.target_repo
1612
 
        target._unstacked_provider.missing_keys.clear()
1613
 
        if target._lock_token:
1614
 
            verb = 'Repository.insert_stream_locked'
1615
 
            extra_args = (target._lock_token or '',)
1616
 
            required_version = (1, 14)
1617
 
        else:
1618
 
            verb = 'Repository.insert_stream'
1619
 
            extra_args = ()
1620
 
            required_version = (1, 13)
1621
 
        client = target._client
1622
 
        medium = client._medium
1623
 
        if medium._is_remote_before(required_version):
1624
 
            # No possible way this can work.
1625
 
            return self._insert_real(stream, src_format, resume_tokens)
1626
 
        path = target.bzrdir._path_for_remote_call(client)
1627
 
        if not resume_tokens:
1628
 
            # XXX: Ugly but important for correctness, *will* be fixed during
1629
 
            # 1.13 cycle. Pushing a stream that is interrupted results in a
1630
 
            # fallback to the _real_repositories sink *with a partial stream*.
1631
 
            # Thats bad because we insert less data than bzr expected. To avoid
1632
 
            # this we do a trial push to make sure the verb is accessible, and
1633
 
            # do not fallback when actually pushing the stream. A cleanup patch
1634
 
            # is going to look at rewinding/restarting the stream/partial
1635
 
            # buffering etc.
1636
 
            byte_stream = smart_repo._stream_to_byte_stream([], src_format)
1637
 
            try:
1638
 
                response = client.call_with_body_stream(
1639
 
                    (verb, path, '') + extra_args, byte_stream)
1640
 
            except errors.UnknownSmartMethod:
1641
 
                medium._remember_remote_is_before(required_version)
1642
 
                return self._insert_real(stream, src_format, resume_tokens)
1643
 
        byte_stream = smart_repo._stream_to_byte_stream(
1644
 
            stream, src_format)
1645
 
        resume_tokens = ' '.join(resume_tokens)
1646
 
        response = client.call_with_body_stream(
1647
 
            (verb, path, resume_tokens) + extra_args, byte_stream)
1648
 
        if response[0][0] not in ('ok', 'missing-basis'):
1649
 
            raise errors.UnexpectedSmartServerResponse(response)
1650
 
        if response[0][0] == 'missing-basis':
1651
 
            tokens, missing_keys = bencode.bdecode_as_tuple(response[0][1])
1652
 
            resume_tokens = tokens
1653
 
            return resume_tokens, set(missing_keys)
1654
 
        else:
1655
 
            self.target_repo.refresh_data()
1656
 
            return [], set()
1657
 
 
1658
 
 
1659
 
class RemoteStreamSource(repository.StreamSource):
1660
 
    """Stream data from a remote server."""
1661
 
 
1662
 
    def get_stream(self, search):
1663
 
        if (self.from_repository._fallback_repositories and
1664
 
            self.to_format._fetch_order == 'topological'):
1665
 
            return self._real_stream(self.from_repository, search)
1666
 
        return self.missing_parents_chain(search, [self.from_repository] +
1667
 
            self.from_repository._fallback_repositories)
1668
 
 
1669
 
    def _real_stream(self, repo, search):
1670
 
        """Get a stream for search from repo.
1671
 
        
1672
 
        This never called RemoteStreamSource.get_stream, and is a heler
1673
 
        for RemoteStreamSource._get_stream to allow getting a stream 
1674
 
        reliably whether fallback back because of old servers or trying
1675
 
        to stream from a non-RemoteRepository (which the stacked support
1676
 
        code will do).
1677
 
        """
1678
 
        source = repo._get_source(self.to_format)
1679
 
        if isinstance(source, RemoteStreamSource):
1680
 
            return repository.StreamSource.get_stream(source, search)
1681
 
        return source.get_stream(search)
1682
 
 
1683
 
    def _get_stream(self, repo, search):
1684
 
        """Core worker to get a stream from repo for search.
1685
 
 
1686
 
        This is used by both get_stream and the stacking support logic. It
1687
 
        deliberately gets a stream for repo which does not need to be
1688
 
        self.from_repository. In the event that repo is not Remote, or
1689
 
        cannot do a smart stream, a fallback is made to the generic
1690
 
        repository._get_stream() interface, via self._real_stream.
1691
 
 
1692
 
        In the event of stacking, streams from _get_stream will not
1693
 
        contain all the data for search - this is normal (see get_stream).
1694
 
 
1695
 
        :param repo: A repository.
1696
 
        :param search: A search.
1697
 
        """
1698
 
        # Fallbacks may be non-smart
1699
 
        if not isinstance(repo, RemoteRepository):
1700
 
            return self._real_stream(repo, search)
1701
 
        client = repo._client
1702
 
        medium = client._medium
1703
 
        if medium._is_remote_before((1, 13)):
1704
 
            # streaming was added in 1.13
1705
 
            return self._real_stream(repo, search)
1706
 
        path = repo.bzrdir._path_for_remote_call(client)
1707
 
        try:
1708
 
            search_bytes = repo._serialise_search_result(search)
1709
 
            response = repo._call_with_body_bytes_expecting_body(
1710
 
                'Repository.get_stream',
1711
 
                (path, self.to_format.network_name()), search_bytes)
1712
 
            response_tuple, response_handler = response
1713
 
        except errors.UnknownSmartMethod:
1714
 
            medium._remember_remote_is_before((1,13))
1715
 
            return self._real_stream(repo, search)
1716
 
        if response_tuple[0] != 'ok':
1717
 
            raise errors.UnexpectedSmartServerResponse(response_tuple)
1718
 
        byte_stream = response_handler.read_streamed_body()
1719
 
        src_format, stream = smart_repo._byte_stream_to_stream(byte_stream)
1720
 
        if src_format.network_name() != repo._format.network_name():
1721
 
            raise AssertionError(
1722
 
                "Mismatched RemoteRepository and stream src %r, %r" % (
1723
 
                src_format.network_name(), repo._format.network_name()))
1724
 
        return stream
1725
 
 
1726
 
    def missing_parents_chain(self, search, sources):
1727
 
        """Chain multiple streams together to handle stacking.
1728
 
 
1729
 
        :param search: The overall search to satisfy with streams.
1730
 
        :param sources: A list of Repository objects to query.
1731
 
        """
1732
 
        self.serialiser = self.to_format._serializer
1733
 
        self.seen_revs = set()
1734
 
        self.referenced_revs = set()
1735
 
        # If there are heads in the search, or the key count is > 0, we are not
1736
 
        # done.
1737
 
        while not search.is_empty() and len(sources) > 1:
1738
 
            source = sources.pop(0)
1739
 
            stream = self._get_stream(source, search)
1740
 
            for kind, substream in stream:
1741
 
                if kind != 'revisions':
1742
 
                    yield kind, substream
1743
 
                else:
1744
 
                    yield kind, self.missing_parents_rev_handler(substream)
1745
 
            search = search.refine(self.seen_revs, self.referenced_revs)
1746
 
            self.seen_revs = set()
1747
 
            self.referenced_revs = set()
1748
 
        if not search.is_empty():
1749
 
            for kind, stream in self._get_stream(sources[0], search):
1750
 
                yield kind, stream
1751
 
 
1752
 
    def missing_parents_rev_handler(self, substream):
1753
 
        for content in substream:
1754
 
            revision_bytes = content.get_bytes_as('fulltext')
1755
 
            revision = self.serialiser.read_revision_from_string(revision_bytes)
1756
 
            self.seen_revs.add(content.key[-1])
1757
 
            self.referenced_revs.update(revision.parent_ids)
1758
 
            yield content
1759
 
 
1760
 
 
1761
 
class RemoteBranchLockableFiles(LockableFiles):
1762
 
    """A 'LockableFiles' implementation that talks to a smart server.
1763
 
 
1764
 
    This is not a public interface class.
1765
 
    """
1766
 
 
1767
 
    def __init__(self, bzrdir, _client):
1768
 
        self.bzrdir = bzrdir
1769
 
        self._client = _client
1770
 
        self._need_find_modes = True
1771
 
        LockableFiles.__init__(
1772
 
            self, bzrdir.get_branch_transport(None),
1773
 
            'lock', lockdir.LockDir)
1774
 
 
1775
 
    def _find_modes(self):
1776
 
        # RemoteBranches don't let the client set the mode of control files.
1777
 
        self._dir_mode = None
1778
 
        self._file_mode = None
1779
 
 
1780
 
 
1781
 
class RemoteBranchFormat(branch.BranchFormat):
1782
 
 
1783
 
    def __init__(self, network_name=None):
1784
 
        super(RemoteBranchFormat, self).__init__()
1785
 
        self._matchingbzrdir = RemoteBzrDirFormat()
1786
 
        self._matchingbzrdir.set_branch_format(self)
1787
 
        self._custom_format = None
1788
 
        self._network_name = network_name
1789
 
 
1790
 
    def __eq__(self, other):
1791
 
        return (isinstance(other, RemoteBranchFormat) and
1792
 
            self.__dict__ == other.__dict__)
1793
 
 
1794
 
    def _ensure_real(self):
1795
 
        if self._custom_format is None:
1796
 
            self._custom_format = branch.network_format_registry.get(
1797
 
                self._network_name)
1798
 
 
1799
 
    def get_format_description(self):
1800
 
        return 'Remote BZR Branch'
1801
 
 
1802
 
    def network_name(self):
1803
 
        return self._network_name
1804
 
 
1805
 
    def open(self, a_bzrdir, ignore_fallbacks=False):
1806
 
        return a_bzrdir.open_branch(ignore_fallbacks=ignore_fallbacks)
1807
 
 
1808
 
    def _vfs_initialize(self, a_bzrdir):
1809
 
        # Initialisation when using a local bzrdir object, or a non-vfs init
1810
 
        # method is not available on the server.
1811
 
        # self._custom_format is always set - the start of initialize ensures
1812
 
        # that.
1813
 
        if isinstance(a_bzrdir, RemoteBzrDir):
1814
 
            a_bzrdir._ensure_real()
1815
 
            result = self._custom_format.initialize(a_bzrdir._real_bzrdir)
1816
 
        else:
1817
 
            # We assume the bzrdir is parameterised; it may not be.
1818
 
            result = self._custom_format.initialize(a_bzrdir)
1819
 
        if (isinstance(a_bzrdir, RemoteBzrDir) and
1820
 
            not isinstance(result, RemoteBranch)):
1821
 
            result = RemoteBranch(a_bzrdir, a_bzrdir.find_repository(), result)
1822
 
        return result
1823
 
 
1824
 
    def initialize(self, a_bzrdir):
1825
 
        # 1) get the network name to use.
1826
 
        if self._custom_format:
1827
 
            network_name = self._custom_format.network_name()
1828
 
        else:
1829
 
            # Select the current bzrlib default and ask for that.
1830
 
            reference_bzrdir_format = bzrdir.format_registry.get('default')()
1831
 
            reference_format = reference_bzrdir_format.get_branch_format()
1832
 
            self._custom_format = reference_format
1833
 
            network_name = reference_format.network_name()
1834
 
        # Being asked to create on a non RemoteBzrDir:
1835
 
        if not isinstance(a_bzrdir, RemoteBzrDir):
1836
 
            return self._vfs_initialize(a_bzrdir)
1837
 
        medium = a_bzrdir._client._medium
1838
 
        if medium._is_remote_before((1, 13)):
1839
 
            return self._vfs_initialize(a_bzrdir)
1840
 
        # Creating on a remote bzr dir.
1841
 
        # 2) try direct creation via RPC
1842
 
        path = a_bzrdir._path_for_remote_call(a_bzrdir._client)
1843
 
        verb = 'BzrDir.create_branch'
1844
 
        try:
1845
 
            response = a_bzrdir._call(verb, path, network_name)
1846
 
        except errors.UnknownSmartMethod:
1847
 
            # Fallback - use vfs methods
1848
 
            medium._remember_remote_is_before((1, 13))
1849
 
            return self._vfs_initialize(a_bzrdir)
1850
 
        if response[0] != 'ok':
1851
 
            raise errors.UnexpectedSmartServerResponse(response)
1852
 
        # Turn the response into a RemoteRepository object.
1853
 
        format = RemoteBranchFormat(network_name=response[1])
1854
 
        repo_format = response_tuple_to_repo_format(response[3:])
1855
 
        if response[2] == '':
1856
 
            repo_bzrdir = a_bzrdir
1857
 
        else:
1858
 
            repo_bzrdir = RemoteBzrDir(
1859
 
                a_bzrdir.root_transport.clone(response[2]), a_bzrdir._format,
1860
 
                a_bzrdir._client)
1861
 
        remote_repo = RemoteRepository(repo_bzrdir, repo_format)
1862
 
        remote_branch = RemoteBranch(a_bzrdir, remote_repo,
1863
 
            format=format, setup_stacking=False)
1864
 
        # XXX: We know this is a new branch, so it must have revno 0, revid
1865
 
        # NULL_REVISION. Creating the branch locked would make this be unable
1866
 
        # to be wrong; here its simply very unlikely to be wrong. RBC 20090225
1867
 
        remote_branch._last_revision_info_cache = 0, NULL_REVISION
1868
 
        return remote_branch
1869
 
 
1870
 
    def make_tags(self, branch):
1871
 
        self._ensure_real()
1872
 
        return self._custom_format.make_tags(branch)
1873
 
 
1874
 
    def supports_tags(self):
1875
 
        # Remote branches might support tags, but we won't know until we
1876
 
        # access the real remote branch.
1877
 
        self._ensure_real()
1878
 
        return self._custom_format.supports_tags()
1879
 
 
1880
 
    def supports_stacking(self):
1881
 
        self._ensure_real()
1882
 
        return self._custom_format.supports_stacking()
1883
 
 
1884
 
 
1885
 
class RemoteBranch(branch.Branch, _RpcHelper):
1886
 
    """Branch stored on a server accessed by HPSS RPC.
1887
 
 
1888
 
    At the moment most operations are mapped down to simple file operations.
1889
 
    """
1890
 
 
1891
 
    def __init__(self, remote_bzrdir, remote_repository, real_branch=None,
1892
 
        _client=None, format=None, setup_stacking=True):
1893
 
        """Create a RemoteBranch instance.
1894
 
 
1895
 
        :param real_branch: An optional local implementation of the branch
1896
 
            format, usually accessing the data via the VFS.
1897
 
        :param _client: Private parameter for testing.
1898
 
        :param format: A RemoteBranchFormat object, None to create one
1899
 
            automatically. If supplied it should have a network_name already
1900
 
            supplied.
1901
 
        :param setup_stacking: If True make an RPC call to determine the
1902
 
            stacked (or not) status of the branch. If False assume the branch
1903
 
            is not stacked.
1904
 
        """
1905
 
        # We intentionally don't call the parent class's __init__, because it
1906
 
        # will try to assign to self.tags, which is a property in this subclass.
1907
 
        # And the parent's __init__ doesn't do much anyway.
1908
 
        self._revision_id_to_revno_cache = None
1909
 
        self._partial_revision_id_to_revno_cache = {}
1910
 
        self._revision_history_cache = None
1911
 
        self._last_revision_info_cache = None
1912
 
        self._merge_sorted_revisions_cache = None
1913
 
        self.bzrdir = remote_bzrdir
1914
 
        if _client is not None:
1915
 
            self._client = _client
1916
 
        else:
1917
 
            self._client = remote_bzrdir._client
1918
 
        self.repository = remote_repository
1919
 
        if real_branch is not None:
1920
 
            self._real_branch = real_branch
1921
 
            # Give the remote repository the matching real repo.
1922
 
            real_repo = self._real_branch.repository
1923
 
            if isinstance(real_repo, RemoteRepository):
1924
 
                real_repo._ensure_real()
1925
 
                real_repo = real_repo._real_repository
1926
 
            self.repository._set_real_repository(real_repo)
1927
 
            # Give the branch the remote repository to let fast-pathing happen.
1928
 
            self._real_branch.repository = self.repository
1929
 
        else:
1930
 
            self._real_branch = None
1931
 
        # Fill out expected attributes of branch for bzrlib API users.
1932
 
        self.base = self.bzrdir.root_transport.base
1933
 
        self._control_files = None
1934
 
        self._lock_mode = None
1935
 
        self._lock_token = None
1936
 
        self._repo_lock_token = None
1937
 
        self._lock_count = 0
1938
 
        self._leave_lock = False
1939
 
        # Setup a format: note that we cannot call _ensure_real until all the
1940
 
        # attributes above are set: This code cannot be moved higher up in this
1941
 
        # function.
1942
 
        if format is None:
1943
 
            self._format = RemoteBranchFormat()
1944
 
            if real_branch is not None:
1945
 
                self._format._network_name = \
1946
 
                    self._real_branch._format.network_name()
1947
 
        else:
1948
 
            self._format = format
1949
 
        if not self._format._network_name:
1950
 
            # Did not get from open_branchV2 - old server.
1951
 
            self._ensure_real()
1952
 
            self._format._network_name = \
1953
 
                self._real_branch._format.network_name()
1954
 
        self.tags = self._format.make_tags(self)
1955
 
        # The base class init is not called, so we duplicate this:
1956
 
        hooks = branch.Branch.hooks['open']
1957
 
        for hook in hooks:
1958
 
            hook(self)
1959
 
        if setup_stacking:
1960
 
            self._setup_stacking()
1961
 
 
1962
 
    def _setup_stacking(self):
1963
 
        # configure stacking into the remote repository, by reading it from
1964
 
        # the vfs branch.
1965
 
        try:
1966
 
            fallback_url = self.get_stacked_on_url()
1967
 
        except (errors.NotStacked, errors.UnstackableBranchFormat,
1968
 
            errors.UnstackableRepositoryFormat), e:
1969
 
            return
1970
 
        self._activate_fallback_location(fallback_url, None)
1971
 
 
1972
 
    def _get_config(self):
1973
 
        return RemoteBranchConfig(self)
1974
 
 
1975
 
    def _get_real_transport(self):
1976
 
        # if we try vfs access, return the real branch's vfs transport
1977
 
        self._ensure_real()
1978
 
        return self._real_branch._transport
1979
 
 
1980
 
    _transport = property(_get_real_transport)
1981
 
 
1982
 
    def __str__(self):
1983
 
        return "%s(%s)" % (self.__class__.__name__, self.base)
1984
 
 
1985
 
    __repr__ = __str__
1986
 
 
1987
 
    def _ensure_real(self):
1988
 
        """Ensure that there is a _real_branch set.
1989
 
 
1990
 
        Used before calls to self._real_branch.
1991
 
        """
1992
 
        if self._real_branch is None:
1993
 
            if not vfs.vfs_enabled():
1994
 
                raise AssertionError('smart server vfs must be enabled '
1995
 
                    'to use vfs implementation')
1996
 
            self.bzrdir._ensure_real()
1997
 
            self._real_branch = self.bzrdir._real_bzrdir.open_branch()
1998
 
            if self.repository._real_repository is None:
1999
 
                # Give the remote repository the matching real repo.
2000
 
                real_repo = self._real_branch.repository
2001
 
                if isinstance(real_repo, RemoteRepository):
2002
 
                    real_repo._ensure_real()
2003
 
                    real_repo = real_repo._real_repository
2004
 
                self.repository._set_real_repository(real_repo)
2005
 
            # Give the real branch the remote repository to let fast-pathing
2006
 
            # happen.
2007
 
            self._real_branch.repository = self.repository
2008
 
            if self._lock_mode == 'r':
2009
 
                self._real_branch.lock_read()
2010
 
            elif self._lock_mode == 'w':
2011
 
                self._real_branch.lock_write(token=self._lock_token)
2012
 
 
2013
 
    def _translate_error(self, err, **context):
2014
 
        self.repository._translate_error(err, branch=self, **context)
2015
 
 
2016
 
    def _clear_cached_state(self):
2017
 
        super(RemoteBranch, self)._clear_cached_state()
2018
 
        if self._real_branch is not None:
2019
 
            self._real_branch._clear_cached_state()
2020
 
 
2021
 
    def _clear_cached_state_of_remote_branch_only(self):
2022
 
        """Like _clear_cached_state, but doesn't clear the cache of
2023
 
        self._real_branch.
2024
 
 
2025
 
        This is useful when falling back to calling a method of
2026
 
        self._real_branch that changes state.  In that case the underlying
2027
 
        branch changes, so we need to invalidate this RemoteBranch's cache of
2028
 
        it.  However, there's no need to invalidate the _real_branch's cache
2029
 
        too, in fact doing so might harm performance.
2030
 
        """
2031
 
        super(RemoteBranch, self)._clear_cached_state()
2032
 
 
2033
 
    @property
2034
 
    def control_files(self):
2035
 
        # Defer actually creating RemoteBranchLockableFiles until its needed,
2036
 
        # because it triggers an _ensure_real that we otherwise might not need.
2037
 
        if self._control_files is None:
2038
 
            self._control_files = RemoteBranchLockableFiles(
2039
 
                self.bzrdir, self._client)
2040
 
        return self._control_files
2041
 
 
2042
 
    def _get_checkout_format(self):
2043
 
        self._ensure_real()
2044
 
        return self._real_branch._get_checkout_format()
2045
 
 
2046
 
    def get_physical_lock_status(self):
2047
 
        """See Branch.get_physical_lock_status()."""
2048
 
        # should be an API call to the server, as branches must be lockable.
2049
 
        self._ensure_real()
2050
 
        return self._real_branch.get_physical_lock_status()
2051
 
 
2052
 
    def get_stacked_on_url(self):
2053
 
        """Get the URL this branch is stacked against.
2054
 
 
2055
 
        :raises NotStacked: If the branch is not stacked.
2056
 
        :raises UnstackableBranchFormat: If the branch does not support
2057
 
            stacking.
2058
 
        :raises UnstackableRepositoryFormat: If the repository does not support
2059
 
            stacking.
2060
 
        """
2061
 
        try:
2062
 
            # there may not be a repository yet, so we can't use
2063
 
            # self._translate_error, so we can't use self._call either.
2064
 
            response = self._client.call('Branch.get_stacked_on_url',
2065
 
                self._remote_path())
2066
 
        except errors.ErrorFromSmartServer, err:
2067
 
            # there may not be a repository yet, so we can't call through
2068
 
            # its _translate_error
2069
 
            _translate_error(err, branch=self)
2070
 
        except errors.UnknownSmartMethod, err:
2071
 
            self._ensure_real()
2072
 
            return self._real_branch.get_stacked_on_url()
2073
 
        if response[0] != 'ok':
2074
 
            raise errors.UnexpectedSmartServerResponse(response)
2075
 
        return response[1]
2076
 
 
2077
 
    def _vfs_get_tags_bytes(self):
2078
 
        self._ensure_real()
2079
 
        return self._real_branch._get_tags_bytes()
2080
 
 
2081
 
    def _get_tags_bytes(self):
2082
 
        medium = self._client._medium
2083
 
        if medium._is_remote_before((1, 13)):
2084
 
            return self._vfs_get_tags_bytes()
2085
 
        try:
2086
 
            response = self._call('Branch.get_tags_bytes', self._remote_path())
2087
 
        except errors.UnknownSmartMethod:
2088
 
            medium._remember_remote_is_before((1, 13))
2089
 
            return self._vfs_get_tags_bytes()
2090
 
        return response[0]
2091
 
 
2092
 
    def lock_read(self):
2093
 
        self.repository.lock_read()
2094
 
        if not self._lock_mode:
2095
 
            self._lock_mode = 'r'
2096
 
            self._lock_count = 1
2097
 
            if self._real_branch is not None:
2098
 
                self._real_branch.lock_read()
2099
 
        else:
2100
 
            self._lock_count += 1
2101
 
 
2102
 
    def _remote_lock_write(self, token):
2103
 
        if token is None:
2104
 
            branch_token = repo_token = ''
2105
 
        else:
2106
 
            branch_token = token
2107
 
            repo_token = self.repository.lock_write()
2108
 
            self.repository.unlock()
2109
 
        err_context = {'token': token}
2110
 
        response = self._call(
2111
 
            'Branch.lock_write', self._remote_path(), branch_token,
2112
 
            repo_token or '', **err_context)
2113
 
        if response[0] != 'ok':
2114
 
            raise errors.UnexpectedSmartServerResponse(response)
2115
 
        ok, branch_token, repo_token = response
2116
 
        return branch_token, repo_token
2117
 
 
2118
 
    def lock_write(self, token=None):
2119
 
        if not self._lock_mode:
2120
 
            # Lock the branch and repo in one remote call.
2121
 
            remote_tokens = self._remote_lock_write(token)
2122
 
            self._lock_token, self._repo_lock_token = remote_tokens
2123
 
            if not self._lock_token:
2124
 
                raise SmartProtocolError('Remote server did not return a token!')
2125
 
            # Tell the self.repository object that it is locked.
2126
 
            self.repository.lock_write(
2127
 
                self._repo_lock_token, _skip_rpc=True)
2128
 
 
2129
 
            if self._real_branch is not None:
2130
 
                self._real_branch.lock_write(token=self._lock_token)
2131
 
            if token is not None:
2132
 
                self._leave_lock = True
2133
 
            else:
2134
 
                self._leave_lock = False
2135
 
            self._lock_mode = 'w'
2136
 
            self._lock_count = 1
2137
 
        elif self._lock_mode == 'r':
2138
 
            raise errors.ReadOnlyTransaction
2139
 
        else:
2140
 
            if token is not None:
2141
 
                # A token was given to lock_write, and we're relocking, so
2142
 
                # check that the given token actually matches the one we
2143
 
                # already have.
2144
 
                if token != self._lock_token:
2145
 
                    raise errors.TokenMismatch(token, self._lock_token)
2146
 
            self._lock_count += 1
2147
 
            # Re-lock the repository too.
2148
 
            self.repository.lock_write(self._repo_lock_token)
2149
 
        return self._lock_token or None
2150
 
 
2151
 
    def _set_tags_bytes(self, bytes):
2152
 
        self._ensure_real()
2153
 
        return self._real_branch._set_tags_bytes(bytes)
2154
 
 
2155
 
    def _unlock(self, branch_token, repo_token):
2156
 
        err_context = {'token': str((branch_token, repo_token))}
2157
 
        response = self._call(
2158
 
            'Branch.unlock', self._remote_path(), branch_token,
2159
 
            repo_token or '', **err_context)
2160
 
        if response == ('ok',):
2161
 
            return
2162
 
        raise errors.UnexpectedSmartServerResponse(response)
2163
 
 
2164
 
    def unlock(self):
2165
 
        try:
2166
 
            self._lock_count -= 1
2167
 
            if not self._lock_count:
2168
 
                self._clear_cached_state()
2169
 
                mode = self._lock_mode
2170
 
                self._lock_mode = None
2171
 
                if self._real_branch is not None:
2172
 
                    if (not self._leave_lock and mode == 'w' and
2173
 
                        self._repo_lock_token):
2174
 
                        # If this RemoteBranch will remove the physical lock
2175
 
                        # for the repository, make sure the _real_branch
2176
 
                        # doesn't do it first.  (Because the _real_branch's
2177
 
                        # repository is set to be the RemoteRepository.)
2178
 
                        self._real_branch.repository.leave_lock_in_place()
2179
 
                    self._real_branch.unlock()
2180
 
                if mode != 'w':
2181
 
                    # Only write-locked branched need to make a remote method
2182
 
                    # call to perform the unlock.
2183
 
                    return
2184
 
                if not self._lock_token:
2185
 
                    raise AssertionError('Locked, but no token!')
2186
 
                branch_token = self._lock_token
2187
 
                repo_token = self._repo_lock_token
2188
 
                self._lock_token = None
2189
 
                self._repo_lock_token = None
2190
 
                if not self._leave_lock:
2191
 
                    self._unlock(branch_token, repo_token)
2192
 
        finally:
2193
 
            self.repository.unlock()
2194
 
 
2195
 
    def break_lock(self):
2196
 
        self._ensure_real()
2197
 
        return self._real_branch.break_lock()
2198
 
 
2199
 
    def leave_lock_in_place(self):
2200
 
        if not self._lock_token:
2201
 
            raise NotImplementedError(self.leave_lock_in_place)
2202
 
        self._leave_lock = True
2203
 
 
2204
 
    def dont_leave_lock_in_place(self):
2205
 
        if not self._lock_token:
2206
 
            raise NotImplementedError(self.dont_leave_lock_in_place)
2207
 
        self._leave_lock = False
2208
 
 
2209
 
    def _last_revision_info(self):
2210
 
        response = self._call('Branch.last_revision_info', self._remote_path())
2211
 
        if response[0] != 'ok':
2212
 
            raise SmartProtocolError('unexpected response code %s' % (response,))
2213
 
        revno = int(response[1])
2214
 
        last_revision = response[2]
2215
 
        return (revno, last_revision)
2216
 
 
2217
 
    def _gen_revision_history(self):
2218
 
        """See Branch._gen_revision_history()."""
2219
 
        response_tuple, response_handler = self._call_expecting_body(
2220
 
            'Branch.revision_history', self._remote_path())
2221
 
        if response_tuple[0] != 'ok':
2222
 
            raise errors.UnexpectedSmartServerResponse(response_tuple)
2223
 
        result = response_handler.read_body_bytes().split('\x00')
2224
 
        if result == ['']:
2225
 
            return []
2226
 
        return result
2227
 
 
2228
 
    def _remote_path(self):
2229
 
        return self.bzrdir._path_for_remote_call(self._client)
2230
 
 
2231
 
    def _set_last_revision_descendant(self, revision_id, other_branch,
2232
 
            allow_diverged=False, allow_overwrite_descendant=False):
2233
 
        # This performs additional work to meet the hook contract; while its
2234
 
        # undesirable, we have to synthesise the revno to call the hook, and
2235
 
        # not calling the hook is worse as it means changes can't be prevented.
2236
 
        # Having calculated this though, we can't just call into
2237
 
        # set_last_revision_info as a simple call, because there is a set_rh
2238
 
        # hook that some folk may still be using.
2239
 
        old_revno, old_revid = self.last_revision_info()
2240
 
        history = self._lefthand_history(revision_id)
2241
 
        self._run_pre_change_branch_tip_hooks(len(history), revision_id)
2242
 
        err_context = {'other_branch': other_branch}
2243
 
        response = self._call('Branch.set_last_revision_ex',
2244
 
            self._remote_path(), self._lock_token, self._repo_lock_token,
2245
 
            revision_id, int(allow_diverged), int(allow_overwrite_descendant),
2246
 
            **err_context)
2247
 
        self._clear_cached_state()
2248
 
        if len(response) != 3 and response[0] != 'ok':
2249
 
            raise errors.UnexpectedSmartServerResponse(response)
2250
 
        new_revno, new_revision_id = response[1:]
2251
 
        self._last_revision_info_cache = new_revno, new_revision_id
2252
 
        self._run_post_change_branch_tip_hooks(old_revno, old_revid)
2253
 
        if self._real_branch is not None:
2254
 
            cache = new_revno, new_revision_id
2255
 
            self._real_branch._last_revision_info_cache = cache
2256
 
 
2257
 
    def _set_last_revision(self, revision_id):
2258
 
        old_revno, old_revid = self.last_revision_info()
2259
 
        # This performs additional work to meet the hook contract; while its
2260
 
        # undesirable, we have to synthesise the revno to call the hook, and
2261
 
        # not calling the hook is worse as it means changes can't be prevented.
2262
 
        # Having calculated this though, we can't just call into
2263
 
        # set_last_revision_info as a simple call, because there is a set_rh
2264
 
        # hook that some folk may still be using.
2265
 
        history = self._lefthand_history(revision_id)
2266
 
        self._run_pre_change_branch_tip_hooks(len(history), revision_id)
2267
 
        self._clear_cached_state()
2268
 
        response = self._call('Branch.set_last_revision',
2269
 
            self._remote_path(), self._lock_token, self._repo_lock_token,
2270
 
            revision_id)
2271
 
        if response != ('ok',):
2272
 
            raise errors.UnexpectedSmartServerResponse(response)
2273
 
        self._run_post_change_branch_tip_hooks(old_revno, old_revid)
2274
 
 
2275
 
    @needs_write_lock
2276
 
    def set_revision_history(self, rev_history):
2277
 
        # Send just the tip revision of the history; the server will generate
2278
 
        # the full history from that.  If the revision doesn't exist in this
2279
 
        # branch, NoSuchRevision will be raised.
2280
 
        if rev_history == []:
2281
 
            rev_id = 'null:'
2282
 
        else:
2283
 
            rev_id = rev_history[-1]
2284
 
        self._set_last_revision(rev_id)
2285
 
        for hook in branch.Branch.hooks['set_rh']:
2286
 
            hook(self, rev_history)
2287
 
        self._cache_revision_history(rev_history)
2288
 
 
2289
 
    def _get_parent_location(self):
2290
 
        medium = self._client._medium
2291
 
        if medium._is_remote_before((1, 13)):
2292
 
            return self._vfs_get_parent_location()
2293
 
        try:
2294
 
            response = self._call('Branch.get_parent', self._remote_path())
2295
 
        except errors.UnknownSmartMethod:
2296
 
            medium._remember_remote_is_before((1, 13))
2297
 
            return self._vfs_get_parent_location()
2298
 
        if len(response) != 1:
2299
 
            raise errors.UnexpectedSmartServerResponse(response)
2300
 
        parent_location = response[0]
2301
 
        if parent_location == '':
2302
 
            return None
2303
 
        return parent_location
2304
 
 
2305
 
    def _vfs_get_parent_location(self):
2306
 
        self._ensure_real()
2307
 
        return self._real_branch._get_parent_location()
2308
 
 
2309
 
    def _set_parent_location(self, url):
2310
 
        medium = self._client._medium
2311
 
        if medium._is_remote_before((1, 15)):
2312
 
            return self._vfs_set_parent_location(url)
2313
 
        try:
2314
 
            call_url = url or ''
2315
 
            if type(call_url) is not str:
2316
 
                raise AssertionError('url must be a str or None (%s)' % url)
2317
 
            response = self._call('Branch.set_parent_location',
2318
 
                self._remote_path(), self._lock_token, self._repo_lock_token,
2319
 
                call_url)
2320
 
        except errors.UnknownSmartMethod:
2321
 
            medium._remember_remote_is_before((1, 15))
2322
 
            return self._vfs_set_parent_location(url)
2323
 
        if response != ():
2324
 
            raise errors.UnexpectedSmartServerResponse(response)
2325
 
 
2326
 
    def _vfs_set_parent_location(self, url):
2327
 
        self._ensure_real()
2328
 
        return self._real_branch._set_parent_location(url)
2329
 
 
2330
 
    @needs_write_lock
2331
 
    def pull(self, source, overwrite=False, stop_revision=None,
2332
 
             **kwargs):
2333
 
        self._clear_cached_state_of_remote_branch_only()
2334
 
        self._ensure_real()
2335
 
        return self._real_branch.pull(
2336
 
            source, overwrite=overwrite, stop_revision=stop_revision,
2337
 
            _override_hook_target=self, **kwargs)
2338
 
 
2339
 
    @needs_read_lock
2340
 
    def push(self, target, overwrite=False, stop_revision=None):
2341
 
        self._ensure_real()
2342
 
        return self._real_branch.push(
2343
 
            target, overwrite=overwrite, stop_revision=stop_revision,
2344
 
            _override_hook_source_branch=self)
2345
 
 
2346
 
    def is_locked(self):
2347
 
        return self._lock_count >= 1
2348
 
 
2349
 
    @needs_read_lock
2350
 
    def revision_id_to_revno(self, revision_id):
2351
 
        self._ensure_real()
2352
 
        return self._real_branch.revision_id_to_revno(revision_id)
2353
 
 
2354
 
    @needs_write_lock
2355
 
    def set_last_revision_info(self, revno, revision_id):
2356
 
        # XXX: These should be returned by the set_last_revision_info verb
2357
 
        old_revno, old_revid = self.last_revision_info()
2358
 
        self._run_pre_change_branch_tip_hooks(revno, revision_id)
2359
 
        revision_id = ensure_null(revision_id)
2360
 
        try:
2361
 
            response = self._call('Branch.set_last_revision_info',
2362
 
                self._remote_path(), self._lock_token, self._repo_lock_token,
2363
 
                str(revno), revision_id)
2364
 
        except errors.UnknownSmartMethod:
2365
 
            self._ensure_real()
2366
 
            self._clear_cached_state_of_remote_branch_only()
2367
 
            self._real_branch.set_last_revision_info(revno, revision_id)
2368
 
            self._last_revision_info_cache = revno, revision_id
2369
 
            return
2370
 
        if response == ('ok',):
2371
 
            self._clear_cached_state()
2372
 
            self._last_revision_info_cache = revno, revision_id
2373
 
            self._run_post_change_branch_tip_hooks(old_revno, old_revid)
2374
 
            # Update the _real_branch's cache too.
2375
 
            if self._real_branch is not None:
2376
 
                cache = self._last_revision_info_cache
2377
 
                self._real_branch._last_revision_info_cache = cache
2378
 
        else:
2379
 
            raise errors.UnexpectedSmartServerResponse(response)
2380
 
 
2381
 
    @needs_write_lock
2382
 
    def generate_revision_history(self, revision_id, last_rev=None,
2383
 
                                  other_branch=None):
2384
 
        medium = self._client._medium
2385
 
        if not medium._is_remote_before((1, 6)):
2386
 
            # Use a smart method for 1.6 and above servers
2387
 
            try:
2388
 
                self._set_last_revision_descendant(revision_id, other_branch,
2389
 
                    allow_diverged=True, allow_overwrite_descendant=True)
2390
 
                return
2391
 
            except errors.UnknownSmartMethod:
2392
 
                medium._remember_remote_is_before((1, 6))
2393
 
        self._clear_cached_state_of_remote_branch_only()
2394
 
        self.set_revision_history(self._lefthand_history(revision_id,
2395
 
            last_rev=last_rev,other_branch=other_branch))
2396
 
 
2397
 
    def set_push_location(self, location):
2398
 
        self._ensure_real()
2399
 
        return self._real_branch.set_push_location(location)
2400
 
 
2401
 
 
2402
 
class RemoteConfig(object):
2403
 
    """A Config that reads and writes from smart verbs.
2404
 
 
2405
 
    It is a low-level object that considers config data to be name/value pairs
2406
 
    that may be associated with a section. Assigning meaning to the these
2407
 
    values is done at higher levels like bzrlib.config.TreeConfig.
2408
 
    """
2409
 
 
2410
 
    def get_option(self, name, section=None, default=None):
2411
 
        """Return the value associated with a named option.
2412
 
 
2413
 
        :param name: The name of the value
2414
 
        :param section: The section the option is in (if any)
2415
 
        :param default: The value to return if the value is not set
2416
 
        :return: The value or default value
2417
 
        """
2418
 
        try:
2419
 
            configobj = self._get_configobj()
2420
 
            if section is None:
2421
 
                section_obj = configobj
2422
 
            else:
2423
 
                try:
2424
 
                    section_obj = configobj[section]
2425
 
                except KeyError:
2426
 
                    return default
2427
 
            return section_obj.get(name, default)
2428
 
        except errors.UnknownSmartMethod:
2429
 
            return self._vfs_get_option(name, section, default)
2430
 
 
2431
 
    def _response_to_configobj(self, response):
2432
 
        if len(response[0]) and response[0][0] != 'ok':
2433
 
            raise errors.UnexpectedSmartServerResponse(response)
2434
 
        lines = response[1].read_body_bytes().splitlines()
2435
 
        return config.ConfigObj(lines, encoding='utf-8')
2436
 
 
2437
 
 
2438
 
class RemoteBranchConfig(RemoteConfig):
2439
 
    """A RemoteConfig for Branches."""
2440
 
 
2441
 
    def __init__(self, branch):
2442
 
        self._branch = branch
2443
 
 
2444
 
    def _get_configobj(self):
2445
 
        path = self._branch._remote_path()
2446
 
        response = self._branch._client.call_expecting_body(
2447
 
            'Branch.get_config_file', path)
2448
 
        return self._response_to_configobj(response)
2449
 
 
2450
 
    def set_option(self, value, name, section=None):
2451
 
        """Set the value associated with a named option.
2452
 
 
2453
 
        :param value: The value to set
2454
 
        :param name: The name of the value to set
2455
 
        :param section: The section the option is in (if any)
2456
 
        """
2457
 
        medium = self._branch._client._medium
2458
 
        if medium._is_remote_before((1, 14)):
2459
 
            return self._vfs_set_option(value, name, section)
2460
 
        try:
2461
 
            path = self._branch._remote_path()
2462
 
            response = self._branch._client.call('Branch.set_config_option',
2463
 
                path, self._branch._lock_token, self._branch._repo_lock_token,
2464
 
                value.encode('utf8'), name, section or '')
2465
 
        except errors.UnknownSmartMethod:
2466
 
            medium._remember_remote_is_before((1, 14))
2467
 
            return self._vfs_set_option(value, name, section)
2468
 
        if response != ():
2469
 
            raise errors.UnexpectedSmartServerResponse(response)
2470
 
 
2471
 
    def _real_object(self):
2472
 
        self._branch._ensure_real()
2473
 
        return self._branch._real_branch
2474
 
 
2475
 
    def _vfs_set_option(self, value, name, section=None):
2476
 
        return self._real_object()._get_config().set_option(
2477
 
            value, name, section)
2478
 
 
2479
 
 
2480
 
class RemoteBzrDirConfig(RemoteConfig):
2481
 
    """A RemoteConfig for BzrDirs."""
2482
 
 
2483
 
    def __init__(self, bzrdir):
2484
 
        self._bzrdir = bzrdir
2485
 
 
2486
 
    def _get_configobj(self):
2487
 
        medium = self._bzrdir._client._medium
2488
 
        verb = 'BzrDir.get_config_file'
2489
 
        if medium._is_remote_before((1, 15)):
2490
 
            raise errors.UnknownSmartMethod(verb)
2491
 
        path = self._bzrdir._path_for_remote_call(self._bzrdir._client)
2492
 
        response = self._bzrdir._call_expecting_body(
2493
 
            verb, path)
2494
 
        return self._response_to_configobj(response)
2495
 
 
2496
 
    def _vfs_get_option(self, name, section, default):
2497
 
        return self._real_object()._get_config().get_option(
2498
 
            name, section, default)
2499
 
 
2500
 
    def set_option(self, value, name, section=None):
2501
 
        """Set the value associated with a named option.
2502
 
 
2503
 
        :param value: The value to set
2504
 
        :param name: The name of the value to set
2505
 
        :param section: The section the option is in (if any)
2506
 
        """
2507
 
        return self._real_object()._get_config().set_option(
2508
 
            value, name, section)
2509
 
 
2510
 
    def _real_object(self):
2511
 
        self._bzrdir._ensure_real()
2512
 
        return self._bzrdir._real_bzrdir
2513
 
 
2514
 
 
2515
 
 
2516
 
def _extract_tar(tar, to_dir):
2517
 
    """Extract all the contents of a tarfile object.
2518
 
 
2519
 
    A replacement for extractall, which is not present in python2.4
2520
 
    """
2521
 
    for tarinfo in tar:
2522
 
        tar.extract(tarinfo, to_dir)
2523
 
 
2524
 
 
2525
 
def _translate_error(err, **context):
2526
 
    """Translate an ErrorFromSmartServer into a more useful error.
2527
 
 
2528
 
    Possible context keys:
2529
 
      - branch
2530
 
      - repository
2531
 
      - bzrdir
2532
 
      - token
2533
 
      - other_branch
2534
 
      - path
2535
 
 
2536
 
    If the error from the server doesn't match a known pattern, then
2537
 
    UnknownErrorFromSmartServer is raised.
2538
 
    """
2539
 
    def find(name):
2540
 
        try:
2541
 
            return context[name]
2542
 
        except KeyError, key_err:
2543
 
            mutter('Missing key %r in context %r', key_err.args[0], context)
2544
 
            raise err
2545
 
    def get_path():
2546
 
        """Get the path from the context if present, otherwise use first error
2547
 
        arg.
2548
 
        """
2549
 
        try:
2550
 
            return context['path']
2551
 
        except KeyError, key_err:
2552
 
            try:
2553
 
                return err.error_args[0]
2554
 
            except IndexError, idx_err:
2555
 
                mutter(
2556
 
                    'Missing key %r in context %r', key_err.args[0], context)
2557
 
                raise err
2558
 
 
2559
 
    if err.error_verb == 'NoSuchRevision':
2560
 
        raise NoSuchRevision(find('branch'), err.error_args[0])
2561
 
    elif err.error_verb == 'nosuchrevision':
2562
 
        raise NoSuchRevision(find('repository'), err.error_args[0])
2563
 
    elif err.error_tuple == ('nobranch',):
2564
 
        raise errors.NotBranchError(path=find('bzrdir').root_transport.base)
2565
 
    elif err.error_verb == 'norepository':
2566
 
        raise errors.NoRepositoryPresent(find('bzrdir'))
2567
 
    elif err.error_verb == 'LockContention':
2568
 
        raise errors.LockContention('(remote lock)')
2569
 
    elif err.error_verb == 'UnlockableTransport':
2570
 
        raise errors.UnlockableTransport(find('bzrdir').root_transport)
2571
 
    elif err.error_verb == 'LockFailed':
2572
 
        raise errors.LockFailed(err.error_args[0], err.error_args[1])
2573
 
    elif err.error_verb == 'TokenMismatch':
2574
 
        raise errors.TokenMismatch(find('token'), '(remote token)')
2575
 
    elif err.error_verb == 'Diverged':
2576
 
        raise errors.DivergedBranches(find('branch'), find('other_branch'))
2577
 
    elif err.error_verb == 'TipChangeRejected':
2578
 
        raise errors.TipChangeRejected(err.error_args[0].decode('utf8'))
2579
 
    elif err.error_verb == 'UnstackableBranchFormat':
2580
 
        raise errors.UnstackableBranchFormat(*err.error_args)
2581
 
    elif err.error_verb == 'UnstackableRepositoryFormat':
2582
 
        raise errors.UnstackableRepositoryFormat(*err.error_args)
2583
 
    elif err.error_verb == 'NotStacked':
2584
 
        raise errors.NotStacked(branch=find('branch'))
2585
 
    elif err.error_verb == 'PermissionDenied':
2586
 
        path = get_path()
2587
 
        if len(err.error_args) >= 2:
2588
 
            extra = err.error_args[1]
2589
 
        else:
2590
 
            extra = None
2591
 
        raise errors.PermissionDenied(path, extra=extra)
2592
 
    elif err.error_verb == 'ReadError':
2593
 
        path = get_path()
2594
 
        raise errors.ReadError(path)
2595
 
    elif err.error_verb == 'NoSuchFile':
2596
 
        path = get_path()
2597
 
        raise errors.NoSuchFile(path)
2598
 
    elif err.error_verb == 'FileExists':
2599
 
        raise errors.FileExists(err.error_args[0])
2600
 
    elif err.error_verb == 'DirectoryNotEmpty':
2601
 
        raise errors.DirectoryNotEmpty(err.error_args[0])
2602
 
    elif err.error_verb == 'ShortReadvError':
2603
 
        args = err.error_args
2604
 
        raise errors.ShortReadvError(
2605
 
            args[0], int(args[1]), int(args[2]), int(args[3]))
2606
 
    elif err.error_verb in ('UnicodeEncodeError', 'UnicodeDecodeError'):
2607
 
        encoding = str(err.error_args[0]) # encoding must always be a string
2608
 
        val = err.error_args[1]
2609
 
        start = int(err.error_args[2])
2610
 
        end = int(err.error_args[3])
2611
 
        reason = str(err.error_args[4]) # reason must always be a string
2612
 
        if val.startswith('u:'):
2613
 
            val = val[2:].decode('utf-8')
2614
 
        elif val.startswith('s:'):
2615
 
            val = val[2:].decode('base64')
2616
 
        if err.error_verb == 'UnicodeDecodeError':
2617
 
            raise UnicodeDecodeError(encoding, val, start, end, reason)
2618
 
        elif err.error_verb == 'UnicodeEncodeError':
2619
 
            raise UnicodeEncodeError(encoding, val, start, end, reason)
2620
 
    elif err.error_verb == 'ReadOnlyError':
2621
 
        raise errors.TransportNotPossible('readonly transport')
2622
 
    raise errors.UnknownErrorFromSmartServer(err)