/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

  • Committer: Vincent Ladeuil
  • Date: 2009-04-02 10:21:08 UTC
  • mto: (4237.1.1 trunk)
  • mto: This revision was merged to the branch mainline in revision 4240.
  • Revision ID: v.ladeuil+lp@free.fr-20090402102108-g0xrarrluckwgxvs
Stop-gap fix for Repository.get_revision_xml.

* bzrlib/repository.py:
(Repository.get_revision_xml): Revert previous change as it breaks
the test suite with LANG=en_US.UTF-8.

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