~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/remote.py

  • Committer: Aaron Bentley
  • Date: 2009-03-24 15:47:32 UTC
  • mto: This revision was merged to the branch mainline in revision 4241.
  • Revision ID: aaron@aaronbentley.com-20090324154732-bwkvi4dx3o90a7dq
Add output, emit minimal inventory delta.

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=False)
 
843
            if self._real_repository is not None:
 
844
                self._real_repository.lock_read()
 
845
        else:
 
846
            self._lock_count += 1
 
847
 
 
848
    def _remote_lock_write(self, token):
 
849
        path = self.bzrdir._path_for_remote_call(self._client)
 
850
        if token is None:
 
851
            token = ''
 
852
        err_context = {'token': token}
 
853
        response = self._call('Repository.lock_write', path, token,
 
854
                              **err_context)
 
855
        if response[0] == 'ok':
 
856
            ok, token = response
 
857
            return token
 
858
        else:
 
859
            raise errors.UnexpectedSmartServerResponse(response)
 
860
 
 
861
    def lock_write(self, token=None, _skip_rpc=False):
 
862
        if not self._lock_mode:
 
863
            if _skip_rpc:
 
864
                if self._lock_token is not None:
 
865
                    if token != self._lock_token:
 
866
                        raise errors.TokenMismatch(token, self._lock_token)
 
867
                self._lock_token = token
 
868
            else:
 
869
                self._lock_token = self._remote_lock_write(token)
 
870
            # if self._lock_token is None, then this is something like packs or
 
871
            # svn where we don't get to lock the repo, or a weave style repository
 
872
            # where we cannot lock it over the wire and attempts to do so will
 
873
            # fail.
 
874
            if self._real_repository is not None:
 
875
                self._real_repository.lock_write(token=self._lock_token)
 
876
            if token is not None:
 
877
                self._leave_lock = True
 
878
            else:
 
879
                self._leave_lock = False
 
880
            self._lock_mode = 'w'
 
881
            self._lock_count = 1
 
882
            self._unstacked_provider.enable_cache(cache_misses=False)
 
883
        elif self._lock_mode == 'r':
 
884
            raise errors.ReadOnlyError(self)
 
885
        else:
 
886
            self._lock_count += 1
 
887
        return self._lock_token or None
 
888
 
 
889
    def leave_lock_in_place(self):
 
890
        if not self._lock_token:
 
891
            raise NotImplementedError(self.leave_lock_in_place)
 
892
        self._leave_lock = True
 
893
 
 
894
    def dont_leave_lock_in_place(self):
 
895
        if not self._lock_token:
 
896
            raise NotImplementedError(self.dont_leave_lock_in_place)
 
897
        self._leave_lock = False
 
898
 
 
899
    def _set_real_repository(self, repository):
 
900
        """Set the _real_repository for this repository.
 
901
 
 
902
        :param repository: The repository to fallback to for non-hpss
 
903
            implemented operations.
 
904
        """
 
905
        if self._real_repository is not None:
 
906
            # Replacing an already set real repository.
 
907
            # We cannot do this [currently] if the repository is locked -
 
908
            # synchronised state might be lost.
 
909
            if self.is_locked():
 
910
                raise AssertionError('_real_repository is already set')
 
911
        if isinstance(repository, RemoteRepository):
 
912
            raise AssertionError()
 
913
        self._real_repository = repository
 
914
        # If the _real_repository has _fallback_repositories, clear them out,
 
915
        # because we want it to have the same set as this repository.  This is
 
916
        # reasonable to do because the fallbacks we clear here are from a
 
917
        # "real" branch, and we're about to replace them with the equivalents
 
918
        # from a RemoteBranch.
 
919
        self._real_repository._fallback_repositories = []
 
920
        for fb in self._fallback_repositories:
 
921
            self._real_repository.add_fallback_repository(fb)
 
922
        if self._lock_mode == 'w':
 
923
            # if we are already locked, the real repository must be able to
 
924
            # acquire the lock with our token.
 
925
            self._real_repository.lock_write(self._lock_token)
 
926
        elif self._lock_mode == 'r':
 
927
            self._real_repository.lock_read()
 
928
 
 
929
    def start_write_group(self):
 
930
        """Start a write group on the decorated repository.
 
931
 
 
932
        Smart methods peform operations in a single step so this api
 
933
        is not really applicable except as a compatibility thunk
 
934
        for older plugins that don't use e.g. the CommitBuilder
 
935
        facility.
 
936
        """
 
937
        self._ensure_real()
 
938
        return self._real_repository.start_write_group()
 
939
 
 
940
    def _unlock(self, token):
 
941
        path = self.bzrdir._path_for_remote_call(self._client)
 
942
        if not token:
 
943
            # with no token the remote repository is not persistently locked.
 
944
            return
 
945
        err_context = {'token': token}
 
946
        response = self._call('Repository.unlock', path, token,
 
947
                              **err_context)
 
948
        if response == ('ok',):
 
949
            return
 
950
        else:
 
951
            raise errors.UnexpectedSmartServerResponse(response)
 
952
 
 
953
    def unlock(self):
 
954
        if not self._lock_count:
 
955
            raise errors.LockNotHeld(self)
 
956
        self._lock_count -= 1
 
957
        if self._lock_count > 0:
 
958
            return
 
959
        self._unstacked_provider.disable_cache()
 
960
        old_mode = self._lock_mode
 
961
        self._lock_mode = None
 
962
        try:
 
963
            # The real repository is responsible at present for raising an
 
964
            # exception if it's in an unfinished write group.  However, it
 
965
            # normally will *not* actually remove the lock from disk - that's
 
966
            # done by the server on receiving the Repository.unlock call.
 
967
            # This is just to let the _real_repository stay up to date.
 
968
            if self._real_repository is not None:
 
969
                self._real_repository.unlock()
 
970
        finally:
 
971
            # The rpc-level lock should be released even if there was a
 
972
            # problem releasing the vfs-based lock.
 
973
            if old_mode == 'w':
 
974
                # Only write-locked repositories need to make a remote method
 
975
                # call to perfom the unlock.
 
976
                old_token = self._lock_token
 
977
                self._lock_token = None
 
978
                if not self._leave_lock:
 
979
                    self._unlock(old_token)
 
980
 
 
981
    def break_lock(self):
 
982
        # should hand off to the network
 
983
        self._ensure_real()
 
984
        return self._real_repository.break_lock()
 
985
 
 
986
    def _get_tarball(self, compression):
 
987
        """Return a TemporaryFile containing a repository tarball.
 
988
 
 
989
        Returns None if the server does not support sending tarballs.
 
990
        """
 
991
        import tempfile
 
992
        path = self.bzrdir._path_for_remote_call(self._client)
 
993
        try:
 
994
            response, protocol = self._call_expecting_body(
 
995
                'Repository.tarball', path, compression)
 
996
        except errors.UnknownSmartMethod:
 
997
            protocol.cancel_read_body()
 
998
            return None
 
999
        if response[0] == 'ok':
 
1000
            # Extract the tarball and return it
 
1001
            t = tempfile.NamedTemporaryFile()
 
1002
            # TODO: rpc layer should read directly into it...
 
1003
            t.write(protocol.read_body_bytes())
 
1004
            t.seek(0)
 
1005
            return t
 
1006
        raise errors.UnexpectedSmartServerResponse(response)
 
1007
 
 
1008
    def sprout(self, to_bzrdir, revision_id=None):
 
1009
        # TODO: Option to control what format is created?
 
1010
        self._ensure_real()
 
1011
        dest_repo = self._real_repository._format.initialize(to_bzrdir,
 
1012
                                                             shared=False)
 
1013
        dest_repo.fetch(self, revision_id=revision_id)
 
1014
        return dest_repo
 
1015
 
 
1016
    ### These methods are just thin shims to the VFS object for now.
 
1017
 
 
1018
    def revision_tree(self, revision_id):
 
1019
        self._ensure_real()
 
1020
        return self._real_repository.revision_tree(revision_id)
 
1021
 
 
1022
    def get_serializer_format(self):
 
1023
        self._ensure_real()
 
1024
        return self._real_repository.get_serializer_format()
 
1025
 
 
1026
    def get_commit_builder(self, branch, parents, config, timestamp=None,
 
1027
                           timezone=None, committer=None, revprops=None,
 
1028
                           revision_id=None):
 
1029
        # FIXME: It ought to be possible to call this without immediately
 
1030
        # triggering _ensure_real.  For now it's the easiest thing to do.
 
1031
        self._ensure_real()
 
1032
        real_repo = self._real_repository
 
1033
        builder = real_repo.get_commit_builder(branch, parents,
 
1034
                config, timestamp=timestamp, timezone=timezone,
 
1035
                committer=committer, revprops=revprops, revision_id=revision_id)
 
1036
        return builder
 
1037
 
 
1038
    def add_fallback_repository(self, repository):
 
1039
        """Add a repository to use for looking up data not held locally.
 
1040
 
 
1041
        :param repository: A repository.
 
1042
        """
 
1043
        if not self._format.supports_external_lookups:
 
1044
            raise errors.UnstackableRepositoryFormat(
 
1045
                self._format.network_name(), self.base)
 
1046
        # We need to accumulate additional repositories here, to pass them in
 
1047
        # on various RPC's.
 
1048
        #
 
1049
        self._fallback_repositories.append(repository)
 
1050
        # If self._real_repository was parameterised already (e.g. because a
 
1051
        # _real_branch had its get_stacked_on_url method called), then the
 
1052
        # repository to be added may already be in the _real_repositories list.
 
1053
        if self._real_repository is not None:
 
1054
            if repository not in self._real_repository._fallback_repositories:
 
1055
                self._real_repository.add_fallback_repository(repository)
 
1056
        else:
 
1057
            # They are also seen by the fallback repository.  If it doesn't
 
1058
            # exist yet they'll be added then.  This implicitly copies them.
 
1059
            self._ensure_real()
 
1060
 
 
1061
    def add_inventory(self, revid, inv, parents):
 
1062
        self._ensure_real()
 
1063
        return self._real_repository.add_inventory(revid, inv, parents)
 
1064
 
 
1065
    def add_inventory_by_delta(self, basis_revision_id, delta, new_revision_id,
 
1066
                               parents):
 
1067
        self._ensure_real()
 
1068
        return self._real_repository.add_inventory_by_delta(basis_revision_id,
 
1069
            delta, new_revision_id, parents)
 
1070
 
 
1071
    def add_revision(self, rev_id, rev, inv=None, config=None):
 
1072
        self._ensure_real()
 
1073
        return self._real_repository.add_revision(
 
1074
            rev_id, rev, inv=inv, config=config)
 
1075
 
 
1076
    @needs_read_lock
 
1077
    def get_inventory(self, revision_id):
 
1078
        self._ensure_real()
 
1079
        return self._real_repository.get_inventory(revision_id)
 
1080
 
 
1081
    def iter_inventories(self, revision_ids):
 
1082
        self._ensure_real()
 
1083
        return self._real_repository.iter_inventories(revision_ids)
 
1084
 
 
1085
    @needs_read_lock
 
1086
    def get_revision(self, revision_id):
 
1087
        self._ensure_real()
 
1088
        return self._real_repository.get_revision(revision_id)
 
1089
 
 
1090
    def get_transaction(self):
 
1091
        self._ensure_real()
 
1092
        return self._real_repository.get_transaction()
 
1093
 
 
1094
    @needs_read_lock
 
1095
    def clone(self, a_bzrdir, revision_id=None):
 
1096
        self._ensure_real()
 
1097
        return self._real_repository.clone(a_bzrdir, revision_id=revision_id)
 
1098
 
 
1099
    def make_working_trees(self):
 
1100
        """See Repository.make_working_trees"""
 
1101
        self._ensure_real()
 
1102
        return self._real_repository.make_working_trees()
 
1103
 
 
1104
    def refresh_data(self):
 
1105
        """Re-read any data needed to to synchronise with disk.
 
1106
 
 
1107
        This method is intended to be called after another repository instance
 
1108
        (such as one used by a smart server) has inserted data into the
 
1109
        repository. It may not be called during a write group, but may be
 
1110
        called at any other time.
 
1111
        """
 
1112
        if self.is_in_write_group():
 
1113
            raise errors.InternalBzrError(
 
1114
                "May not refresh_data while in a write group.")
 
1115
        if self._real_repository is not None:
 
1116
            self._real_repository.refresh_data()
 
1117
 
 
1118
    def revision_ids_to_search_result(self, result_set):
 
1119
        """Convert a set of revision ids to a graph SearchResult."""
 
1120
        result_parents = set()
 
1121
        for parents in self.get_graph().get_parent_map(
 
1122
            result_set).itervalues():
 
1123
            result_parents.update(parents)
 
1124
        included_keys = result_set.intersection(result_parents)
 
1125
        start_keys = result_set.difference(included_keys)
 
1126
        exclude_keys = result_parents.difference(result_set)
 
1127
        result = graph.SearchResult(start_keys, exclude_keys,
 
1128
            len(result_set), result_set)
 
1129
        return result
 
1130
 
 
1131
    @needs_read_lock
 
1132
    def search_missing_revision_ids(self, other, revision_id=None, find_ghosts=True):
 
1133
        """Return the revision ids that other has that this does not.
 
1134
 
 
1135
        These are returned in topological order.
 
1136
 
 
1137
        revision_id: only return revision ids included by revision_id.
 
1138
        """
 
1139
        return repository.InterRepository.get(
 
1140
            other, self).search_missing_revision_ids(revision_id, find_ghosts)
 
1141
 
 
1142
    def fetch(self, source, revision_id=None, pb=None, find_ghosts=False,
 
1143
            fetch_spec=None):
 
1144
        # No base implementation to use as RemoteRepository is not a subclass
 
1145
        # of Repository; so this is a copy of Repository.fetch().
 
1146
        if fetch_spec is not None and revision_id is not None:
 
1147
            raise AssertionError(
 
1148
                "fetch_spec and revision_id are mutually exclusive.")
 
1149
        if self.is_in_write_group():
 
1150
            raise errors.InternalBzrError(
 
1151
                "May not fetch while in a write group.")
 
1152
        # fast path same-url fetch operations
 
1153
        if self.has_same_location(source) and fetch_spec is None:
 
1154
            # check that last_revision is in 'from' and then return a
 
1155
            # no-operation.
 
1156
            if (revision_id is not None and
 
1157
                not revision.is_null(revision_id)):
 
1158
                self.get_revision(revision_id)
 
1159
            return 0, []
 
1160
        # if there is no specific appropriate InterRepository, this will get
 
1161
        # the InterRepository base class, which raises an
 
1162
        # IncompatibleRepositories when asked to fetch.
 
1163
        inter = repository.InterRepository.get(source, self)
 
1164
        return inter.fetch(revision_id=revision_id, pb=pb,
 
1165
            find_ghosts=find_ghosts, fetch_spec=fetch_spec)
 
1166
 
 
1167
    def create_bundle(self, target, base, fileobj, format=None):
 
1168
        self._ensure_real()
 
1169
        self._real_repository.create_bundle(target, base, fileobj, format)
 
1170
 
 
1171
    @needs_read_lock
 
1172
    def get_ancestry(self, revision_id, topo_sorted=True):
 
1173
        self._ensure_real()
 
1174
        return self._real_repository.get_ancestry(revision_id, topo_sorted)
 
1175
 
 
1176
    def fileids_altered_by_revision_ids(self, revision_ids):
 
1177
        self._ensure_real()
 
1178
        return self._real_repository.fileids_altered_by_revision_ids(revision_ids)
 
1179
 
 
1180
    def _get_versioned_file_checker(self, revisions, revision_versions_cache):
 
1181
        self._ensure_real()
 
1182
        return self._real_repository._get_versioned_file_checker(
 
1183
            revisions, revision_versions_cache)
 
1184
 
 
1185
    def iter_files_bytes(self, desired_files):
 
1186
        """See Repository.iter_file_bytes.
 
1187
        """
 
1188
        self._ensure_real()
 
1189
        return self._real_repository.iter_files_bytes(desired_files)
 
1190
 
 
1191
    def get_parent_map(self, revision_ids):
 
1192
        """See bzrlib.Graph.get_parent_map()."""
 
1193
        return self._make_parents_provider().get_parent_map(revision_ids)
 
1194
 
 
1195
    def _get_parent_map_rpc(self, keys):
 
1196
        """Helper for get_parent_map that performs the RPC."""
 
1197
        medium = self._client._medium
 
1198
        if medium._is_remote_before((1, 2)):
 
1199
            # We already found out that the server can't understand
 
1200
            # Repository.get_parent_map requests, so just fetch the whole
 
1201
            # graph.
 
1202
            #
 
1203
            # Note that this reads the whole graph, when only some keys are
 
1204
            # wanted.  On this old server there's no way (?) to get them all
 
1205
            # in one go, and the user probably will have seen a warning about
 
1206
            # the server being old anyhow.
 
1207
            rg = self._get_revision_graph(None)
 
1208
            # There is an api discrepency between get_parent_map and
 
1209
            # get_revision_graph. Specifically, a "key:()" pair in
 
1210
            # get_revision_graph just means a node has no parents. For
 
1211
            # "get_parent_map" it means the node is a ghost. So fix up the
 
1212
            # graph to correct this.
 
1213
            #   https://bugs.launchpad.net/bzr/+bug/214894
 
1214
            # There is one other "bug" which is that ghosts in
 
1215
            # get_revision_graph() are not returned at all. But we won't worry
 
1216
            # about that for now.
 
1217
            for node_id, parent_ids in rg.iteritems():
 
1218
                if parent_ids == ():
 
1219
                    rg[node_id] = (NULL_REVISION,)
 
1220
            rg[NULL_REVISION] = ()
 
1221
            return rg
 
1222
 
 
1223
        keys = set(keys)
 
1224
        if None in keys:
 
1225
            raise ValueError('get_parent_map(None) is not valid')
 
1226
        if NULL_REVISION in keys:
 
1227
            keys.discard(NULL_REVISION)
 
1228
            found_parents = {NULL_REVISION:()}
 
1229
            if not keys:
 
1230
                return found_parents
 
1231
        else:
 
1232
            found_parents = {}
 
1233
        # TODO(Needs analysis): We could assume that the keys being requested
 
1234
        # from get_parent_map are in a breadth first search, so typically they
 
1235
        # will all be depth N from some common parent, and we don't have to
 
1236
        # have the server iterate from the root parent, but rather from the
 
1237
        # keys we're searching; and just tell the server the keyspace we
 
1238
        # already have; but this may be more traffic again.
 
1239
 
 
1240
        # Transform self._parents_map into a search request recipe.
 
1241
        # TODO: Manage this incrementally to avoid covering the same path
 
1242
        # repeatedly. (The server will have to on each request, but the less
 
1243
        # work done the better).
 
1244
        parents_map = self._unstacked_provider.get_cached_map()
 
1245
        if parents_map is None:
 
1246
            # Repository is not locked, so there's no cache.
 
1247
            parents_map = {}
 
1248
        start_set = set(parents_map)
 
1249
        result_parents = set()
 
1250
        for parents in parents_map.itervalues():
 
1251
            result_parents.update(parents)
 
1252
        stop_keys = result_parents.difference(start_set)
 
1253
        included_keys = start_set.intersection(result_parents)
 
1254
        start_set.difference_update(included_keys)
 
1255
        recipe = ('manual', start_set, stop_keys, len(parents_map))
 
1256
        body = self._serialise_search_recipe(recipe)
 
1257
        path = self.bzrdir._path_for_remote_call(self._client)
 
1258
        for key in keys:
 
1259
            if type(key) is not str:
 
1260
                raise ValueError(
 
1261
                    "key %r not a plain string" % (key,))
 
1262
        verb = 'Repository.get_parent_map'
 
1263
        args = (path,) + tuple(keys)
 
1264
        try:
 
1265
            response = self._call_with_body_bytes_expecting_body(
 
1266
                verb, args, body)
 
1267
        except errors.UnknownSmartMethod:
 
1268
            # Server does not support this method, so get the whole graph.
 
1269
            # Worse, we have to force a disconnection, because the server now
 
1270
            # doesn't realise it has a body on the wire to consume, so the
 
1271
            # only way to recover is to abandon the connection.
 
1272
            warning(
 
1273
                'Server is too old for fast get_parent_map, reconnecting.  '
 
1274
                '(Upgrade the server to Bazaar 1.2 to avoid this)')
 
1275
            medium.disconnect()
 
1276
            # To avoid having to disconnect repeatedly, we keep track of the
 
1277
            # fact the server doesn't understand remote methods added in 1.2.
 
1278
            medium._remember_remote_is_before((1, 2))
 
1279
            # Recurse just once and we should use the fallback code.
 
1280
            return self._get_parent_map_rpc(keys)
 
1281
        response_tuple, response_handler = response
 
1282
        if response_tuple[0] not in ['ok']:
 
1283
            response_handler.cancel_read_body()
 
1284
            raise errors.UnexpectedSmartServerResponse(response_tuple)
 
1285
        if response_tuple[0] == 'ok':
 
1286
            coded = bz2.decompress(response_handler.read_body_bytes())
 
1287
            if coded == '':
 
1288
                # no revisions found
 
1289
                return {}
 
1290
            lines = coded.split('\n')
 
1291
            revision_graph = {}
 
1292
            for line in lines:
 
1293
                d = tuple(line.split())
 
1294
                if len(d) > 1:
 
1295
                    revision_graph[d[0]] = d[1:]
 
1296
                else:
 
1297
                    # No parents - so give the Graph result (NULL_REVISION,).
 
1298
                    revision_graph[d[0]] = (NULL_REVISION,)
 
1299
            return revision_graph
 
1300
 
 
1301
    @needs_read_lock
 
1302
    def get_signature_text(self, revision_id):
 
1303
        self._ensure_real()
 
1304
        return self._real_repository.get_signature_text(revision_id)
 
1305
 
 
1306
    @needs_read_lock
 
1307
    def get_inventory_xml(self, revision_id):
 
1308
        self._ensure_real()
 
1309
        return self._real_repository.get_inventory_xml(revision_id)
 
1310
 
 
1311
    def deserialise_inventory(self, revision_id, xml):
 
1312
        self._ensure_real()
 
1313
        return self._real_repository.deserialise_inventory(revision_id, xml)
 
1314
 
 
1315
    def reconcile(self, other=None, thorough=False):
 
1316
        self._ensure_real()
 
1317
        return self._real_repository.reconcile(other=other, thorough=thorough)
 
1318
 
 
1319
    def all_revision_ids(self):
 
1320
        self._ensure_real()
 
1321
        return self._real_repository.all_revision_ids()
 
1322
 
 
1323
    @needs_read_lock
 
1324
    def get_deltas_for_revisions(self, revisions, specific_fileids=None):
 
1325
        self._ensure_real()
 
1326
        return self._real_repository.get_deltas_for_revisions(revisions,
 
1327
            specific_fileids=specific_fileids)
 
1328
 
 
1329
    @needs_read_lock
 
1330
    def get_revision_delta(self, revision_id, specific_fileids=None):
 
1331
        self._ensure_real()
 
1332
        return self._real_repository.get_revision_delta(revision_id,
 
1333
            specific_fileids=specific_fileids)
 
1334
 
 
1335
    @needs_read_lock
 
1336
    def revision_trees(self, revision_ids):
 
1337
        self._ensure_real()
 
1338
        return self._real_repository.revision_trees(revision_ids)
 
1339
 
 
1340
    @needs_read_lock
 
1341
    def get_revision_reconcile(self, revision_id):
 
1342
        self._ensure_real()
 
1343
        return self._real_repository.get_revision_reconcile(revision_id)
 
1344
 
 
1345
    @needs_read_lock
 
1346
    def check(self, revision_ids=None):
 
1347
        self._ensure_real()
 
1348
        return self._real_repository.check(revision_ids=revision_ids)
 
1349
 
 
1350
    def copy_content_into(self, destination, revision_id=None):
 
1351
        self._ensure_real()
 
1352
        return self._real_repository.copy_content_into(
 
1353
            destination, revision_id=revision_id)
 
1354
 
 
1355
    def _copy_repository_tarball(self, to_bzrdir, revision_id=None):
 
1356
        # get a tarball of the remote repository, and copy from that into the
 
1357
        # destination
 
1358
        from bzrlib import osutils
 
1359
        import tarfile
 
1360
        # TODO: Maybe a progress bar while streaming the tarball?
 
1361
        note("Copying repository content as tarball...")
 
1362
        tar_file = self._get_tarball('bz2')
 
1363
        if tar_file is None:
 
1364
            return None
 
1365
        destination = to_bzrdir.create_repository()
 
1366
        try:
 
1367
            tar = tarfile.open('repository', fileobj=tar_file,
 
1368
                mode='r|bz2')
 
1369
            tmpdir = osutils.mkdtemp()
 
1370
            try:
 
1371
                _extract_tar(tar, tmpdir)
 
1372
                tmp_bzrdir = BzrDir.open(tmpdir)
 
1373
                tmp_repo = tmp_bzrdir.open_repository()
 
1374
                tmp_repo.copy_content_into(destination, revision_id)
 
1375
            finally:
 
1376
                osutils.rmtree(tmpdir)
 
1377
        finally:
 
1378
            tar_file.close()
 
1379
        return destination
 
1380
        # TODO: Suggestion from john: using external tar is much faster than
 
1381
        # python's tarfile library, but it may not work on windows.
 
1382
 
 
1383
    @property
 
1384
    def inventories(self):
 
1385
        """Decorate the real repository for now.
 
1386
 
 
1387
        In the long term a full blown network facility is needed to
 
1388
        avoid creating a real repository object locally.
 
1389
        """
 
1390
        self._ensure_real()
 
1391
        return self._real_repository.inventories
 
1392
 
 
1393
    @needs_write_lock
 
1394
    def pack(self):
 
1395
        """Compress the data within the repository.
 
1396
 
 
1397
        This is not currently implemented within the smart server.
 
1398
        """
 
1399
        self._ensure_real()
 
1400
        return self._real_repository.pack()
 
1401
 
 
1402
    @property
 
1403
    def revisions(self):
 
1404
        """Decorate the real repository for now.
 
1405
 
 
1406
        In the short term this should become a real object to intercept graph
 
1407
        lookups.
 
1408
 
 
1409
        In the long term a full blown network facility is needed.
 
1410
        """
 
1411
        self._ensure_real()
 
1412
        return self._real_repository.revisions
 
1413
 
 
1414
    def set_make_working_trees(self, new_value):
 
1415
        if new_value:
 
1416
            new_value_str = "True"
 
1417
        else:
 
1418
            new_value_str = "False"
 
1419
        path = self.bzrdir._path_for_remote_call(self._client)
 
1420
        try:
 
1421
            response = self._call(
 
1422
                'Repository.set_make_working_trees', path, new_value_str)
 
1423
        except errors.UnknownSmartMethod:
 
1424
            self._ensure_real()
 
1425
            self._real_repository.set_make_working_trees(new_value)
 
1426
        else:
 
1427
            if response[0] != 'ok':
 
1428
                raise errors.UnexpectedSmartServerResponse(response)
 
1429
 
 
1430
    @property
 
1431
    def signatures(self):
 
1432
        """Decorate the real repository for now.
 
1433
 
 
1434
        In the long term a full blown network facility is needed to avoid
 
1435
        creating a real repository object locally.
 
1436
        """
 
1437
        self._ensure_real()
 
1438
        return self._real_repository.signatures
 
1439
 
 
1440
    @needs_write_lock
 
1441
    def sign_revision(self, revision_id, gpg_strategy):
 
1442
        self._ensure_real()
 
1443
        return self._real_repository.sign_revision(revision_id, gpg_strategy)
 
1444
 
 
1445
    @property
 
1446
    def texts(self):
 
1447
        """Decorate the real repository for now.
 
1448
 
 
1449
        In the long term a full blown network facility is needed to avoid
 
1450
        creating a real repository object locally.
 
1451
        """
 
1452
        self._ensure_real()
 
1453
        return self._real_repository.texts
 
1454
 
 
1455
    @needs_read_lock
 
1456
    def get_revisions(self, revision_ids):
 
1457
        self._ensure_real()
 
1458
        return self._real_repository.get_revisions(revision_ids)
 
1459
 
 
1460
    def supports_rich_root(self):
 
1461
        return self._format.rich_root_data
 
1462
 
 
1463
    def iter_reverse_revision_history(self, revision_id):
 
1464
        self._ensure_real()
 
1465
        return self._real_repository.iter_reverse_revision_history(revision_id)
 
1466
 
 
1467
    @property
 
1468
    def _serializer(self):
 
1469
        return self._format._serializer
 
1470
 
 
1471
    def store_revision_signature(self, gpg_strategy, plaintext, revision_id):
 
1472
        self._ensure_real()
 
1473
        return self._real_repository.store_revision_signature(
 
1474
            gpg_strategy, plaintext, revision_id)
 
1475
 
 
1476
    def add_signature_text(self, revision_id, signature):
 
1477
        self._ensure_real()
 
1478
        return self._real_repository.add_signature_text(revision_id, signature)
 
1479
 
 
1480
    def has_signature_for_revision_id(self, revision_id):
 
1481
        self._ensure_real()
 
1482
        return self._real_repository.has_signature_for_revision_id(revision_id)
 
1483
 
 
1484
    def item_keys_introduced_by(self, revision_ids, _files_pb=None):
 
1485
        self._ensure_real()
 
1486
        return self._real_repository.item_keys_introduced_by(revision_ids,
 
1487
            _files_pb=_files_pb)
 
1488
 
 
1489
    def revision_graph_can_have_wrong_parents(self):
 
1490
        # The answer depends on the remote repo format.
 
1491
        self._ensure_real()
 
1492
        return self._real_repository.revision_graph_can_have_wrong_parents()
 
1493
 
 
1494
    def _find_inconsistent_revision_parents(self):
 
1495
        self._ensure_real()
 
1496
        return self._real_repository._find_inconsistent_revision_parents()
 
1497
 
 
1498
    def _check_for_inconsistent_revision_parents(self):
 
1499
        self._ensure_real()
 
1500
        return self._real_repository._check_for_inconsistent_revision_parents()
 
1501
 
 
1502
    def _make_parents_provider(self, other=None):
 
1503
        providers = [self._unstacked_provider]
 
1504
        if other is not None:
 
1505
            providers.insert(0, other)
 
1506
        providers.extend(r._make_parents_provider() for r in
 
1507
                         self._fallback_repositories)
 
1508
        return graph._StackedParentsProvider(providers)
 
1509
 
 
1510
    def _serialise_search_recipe(self, recipe):
 
1511
        """Serialise a graph search recipe.
 
1512
 
 
1513
        :param recipe: A search recipe (start, stop, count).
 
1514
        :return: Serialised bytes.
 
1515
        """
 
1516
        start_keys = ' '.join(recipe[1])
 
1517
        stop_keys = ' '.join(recipe[2])
 
1518
        count = str(recipe[3])
 
1519
        return '\n'.join((start_keys, stop_keys, count))
 
1520
 
 
1521
    def _serialise_search_result(self, search_result):
 
1522
        if isinstance(search_result, graph.PendingAncestryResult):
 
1523
            parts = ['ancestry-of']
 
1524
            parts.extend(search_result.heads)
 
1525
        else:
 
1526
            recipe = search_result.get_recipe()
 
1527
            parts = [recipe[0], self._serialise_search_recipe(recipe)]
 
1528
        return '\n'.join(parts)
 
1529
 
 
1530
    def autopack(self):
 
1531
        path = self.bzrdir._path_for_remote_call(self._client)
 
1532
        try:
 
1533
            response = self._call('PackRepository.autopack', path)
 
1534
        except errors.UnknownSmartMethod:
 
1535
            self._ensure_real()
 
1536
            self._real_repository._pack_collection.autopack()
 
1537
            return
 
1538
        self.refresh_data()
 
1539
        if response[0] != 'ok':
 
1540
            raise errors.UnexpectedSmartServerResponse(response)
 
1541
 
 
1542
 
 
1543
class RemoteStreamSink(repository.StreamSink):
 
1544
 
 
1545
    def _insert_real(self, stream, src_format, resume_tokens):
 
1546
        self.target_repo._ensure_real()
 
1547
        sink = self.target_repo._real_repository._get_sink()
 
1548
        result = sink.insert_stream(stream, src_format, resume_tokens)
 
1549
        if not result:
 
1550
            self.target_repo.autopack()
 
1551
        return result
 
1552
 
 
1553
    def insert_stream(self, stream, src_format, resume_tokens):
 
1554
        target = self.target_repo
 
1555
        if target._lock_token:
 
1556
            verb = 'Repository.insert_stream_locked'
 
1557
            extra_args = (target._lock_token or '',)
 
1558
            required_version = (1, 14)
 
1559
        else:
 
1560
            verb = 'Repository.insert_stream'
 
1561
            extra_args = ()
 
1562
            required_version = (1, 13)
 
1563
        client = target._client
 
1564
        medium = client._medium
 
1565
        if medium._is_remote_before(required_version):
 
1566
            # No possible way this can work.
 
1567
            return self._insert_real(stream, src_format, resume_tokens)
 
1568
        path = target.bzrdir._path_for_remote_call(client)
 
1569
        if not resume_tokens:
 
1570
            # XXX: Ugly but important for correctness, *will* be fixed during
 
1571
            # 1.13 cycle. Pushing a stream that is interrupted results in a
 
1572
            # fallback to the _real_repositories sink *with a partial stream*.
 
1573
            # Thats bad because we insert less data than bzr expected. To avoid
 
1574
            # this we do a trial push to make sure the verb is accessible, and
 
1575
            # do not fallback when actually pushing the stream. A cleanup patch
 
1576
            # is going to look at rewinding/restarting the stream/partial
 
1577
            # buffering etc.
 
1578
            byte_stream = smart_repo._stream_to_byte_stream([], src_format)
 
1579
            try:
 
1580
                response = client.call_with_body_stream(
 
1581
                    (verb, path, '') + extra_args, byte_stream)
 
1582
            except errors.UnknownSmartMethod:
 
1583
                medium._remember_remote_is_before(required_version)
 
1584
                return self._insert_real(stream, src_format, resume_tokens)
 
1585
        byte_stream = smart_repo._stream_to_byte_stream(
 
1586
            stream, src_format)
 
1587
        resume_tokens = ' '.join(resume_tokens)
 
1588
        response = client.call_with_body_stream(
 
1589
            (verb, path, resume_tokens) + extra_args, byte_stream)
 
1590
        if response[0][0] not in ('ok', 'missing-basis'):
 
1591
            raise errors.UnexpectedSmartServerResponse(response)
 
1592
        if response[0][0] == 'missing-basis':
 
1593
            tokens, missing_keys = bencode.bdecode_as_tuple(response[0][1])
 
1594
            resume_tokens = tokens
 
1595
            return resume_tokens, missing_keys
 
1596
        else:
 
1597
            self.target_repo.refresh_data()
 
1598
            return [], set()
 
1599
 
 
1600
 
 
1601
class RemoteStreamSource(repository.StreamSource):
 
1602
    """Stream data from a remote server."""
 
1603
 
 
1604
    def get_stream(self, search):
 
1605
        if (self.from_repository._fallback_repositories and
 
1606
            self.to_format._fetch_order == 'topological'):
 
1607
            return self._real_stream(self.from_repository, search)
 
1608
        return self.missing_parents_chain(search, [self.from_repository] +
 
1609
            self.from_repository._fallback_repositories)
 
1610
 
 
1611
    def _real_stream(self, repo, search):
 
1612
        """Get a stream for search from repo.
 
1613
        
 
1614
        This never called RemoteStreamSource.get_stream, and is a heler
 
1615
        for RemoteStreamSource._get_stream to allow getting a stream 
 
1616
        reliably whether fallback back because of old servers or trying
 
1617
        to stream from a non-RemoteRepository (which the stacked support
 
1618
        code will do).
 
1619
        """
 
1620
        source = repo._get_source(self.to_format)
 
1621
        if isinstance(source, RemoteStreamSource):
 
1622
            return repository.StreamSource.get_stream(source, search)
 
1623
        return source.get_stream(search)
 
1624
 
 
1625
    def _get_stream(self, repo, search):
 
1626
        """Core worker to get a stream from repo for search.
 
1627
 
 
1628
        This is used by both get_stream and the stacking support logic. It
 
1629
        deliberately gets a stream for repo which does not need to be
 
1630
        self.from_repository. In the event that repo is not Remote, or
 
1631
        cannot do a smart stream, a fallback is made to the generic
 
1632
        repository._get_stream() interface, via self._real_stream.
 
1633
 
 
1634
        In the event of stacking, streams from _get_stream will not
 
1635
        contain all the data for search - this is normal (see get_stream).
 
1636
 
 
1637
        :param repo: A repository.
 
1638
        :param search: A search.
 
1639
        """
 
1640
        # Fallbacks may be non-smart
 
1641
        if not isinstance(repo, RemoteRepository):
 
1642
            return self._real_stream(repo, search)
 
1643
        client = repo._client
 
1644
        medium = client._medium
 
1645
        if medium._is_remote_before((1, 13)):
 
1646
            # streaming was added in 1.13
 
1647
            return self._real_stream(repo, search)
 
1648
        path = repo.bzrdir._path_for_remote_call(client)
 
1649
        try:
 
1650
            search_bytes = repo._serialise_search_result(search)
 
1651
            response = repo._call_with_body_bytes_expecting_body(
 
1652
                'Repository.get_stream',
 
1653
                (path, self.to_format.network_name()), search_bytes)
 
1654
            response_tuple, response_handler = response
 
1655
        except errors.UnknownSmartMethod:
 
1656
            medium._remember_remote_is_before((1,13))
 
1657
            return self._real_stream(repo, search)
 
1658
        if response_tuple[0] != 'ok':
 
1659
            raise errors.UnexpectedSmartServerResponse(response_tuple)
 
1660
        byte_stream = response_handler.read_streamed_body()
 
1661
        src_format, stream = smart_repo._byte_stream_to_stream(byte_stream)
 
1662
        if src_format.network_name() != repo._format.network_name():
 
1663
            raise AssertionError(
 
1664
                "Mismatched RemoteRepository and stream src %r, %r" % (
 
1665
                src_format.network_name(), repo._format.network_name()))
 
1666
        return stream
 
1667
 
 
1668
    def missing_parents_chain(self, search, sources):
 
1669
        """Chain multiple streams together to handle stacking.
 
1670
 
 
1671
        :param search: The overall search to satisfy with streams.
 
1672
        :param sources: A list of Repository objects to query.
 
1673
        """
 
1674
        self.serialiser = self.to_format._serializer
 
1675
        self.seen_revs = set()
 
1676
        self.referenced_revs = set()
 
1677
        # If there are heads in the search, or the key count is > 0, we are not
 
1678
        # done.
 
1679
        while not search.is_empty() and len(sources) > 1:
 
1680
            source = sources.pop(0)
 
1681
            stream = self._get_stream(source, search)
 
1682
            for kind, substream in stream:
 
1683
                if kind != 'revisions':
 
1684
                    yield kind, substream
 
1685
                else:
 
1686
                    yield kind, self.missing_parents_rev_handler(substream)
 
1687
            search = search.refine(self.seen_revs, self.referenced_revs)
 
1688
            self.seen_revs = set()
 
1689
            self.referenced_revs = set()
 
1690
        if not search.is_empty():
 
1691
            for kind, stream in self._get_stream(sources[0], search):
 
1692
                yield kind, stream
 
1693
 
 
1694
    def missing_parents_rev_handler(self, substream):
 
1695
        for content in substream:
 
1696
            revision_bytes = content.get_bytes_as('fulltext')
 
1697
            revision = self.serialiser.read_revision_from_string(revision_bytes)
 
1698
            self.seen_revs.add(content.key[-1])
 
1699
            self.referenced_revs.update(revision.parent_ids)
 
1700
            yield content
 
1701
 
 
1702
 
 
1703
class RemoteBranchLockableFiles(LockableFiles):
 
1704
    """A 'LockableFiles' implementation that talks to a smart server.
 
1705
 
 
1706
    This is not a public interface class.
 
1707
    """
 
1708
 
 
1709
    def __init__(self, bzrdir, _client):
 
1710
        self.bzrdir = bzrdir
 
1711
        self._client = _client
 
1712
        self._need_find_modes = True
 
1713
        LockableFiles.__init__(
 
1714
            self, bzrdir.get_branch_transport(None),
 
1715
            'lock', lockdir.LockDir)
 
1716
 
 
1717
    def _find_modes(self):
 
1718
        # RemoteBranches don't let the client set the mode of control files.
 
1719
        self._dir_mode = None
 
1720
        self._file_mode = None
 
1721
 
 
1722
 
 
1723
class RemoteBranchFormat(branch.BranchFormat):
 
1724
 
 
1725
    def __init__(self, network_name=None):
 
1726
        super(RemoteBranchFormat, self).__init__()
 
1727
        self._matchingbzrdir = RemoteBzrDirFormat()
 
1728
        self._matchingbzrdir.set_branch_format(self)
 
1729
        self._custom_format = None
 
1730
        self._network_name = network_name
 
1731
 
 
1732
    def __eq__(self, other):
 
1733
        return (isinstance(other, RemoteBranchFormat) and
 
1734
            self.__dict__ == other.__dict__)
 
1735
 
 
1736
    def _ensure_real(self):
 
1737
        if self._custom_format is None:
 
1738
            self._custom_format = branch.network_format_registry.get(
 
1739
                self._network_name)
 
1740
 
 
1741
    def get_format_description(self):
 
1742
        return 'Remote BZR Branch'
 
1743
 
 
1744
    def network_name(self):
 
1745
        return self._network_name
 
1746
 
 
1747
    def open(self, a_bzrdir, ignore_fallbacks=False):
 
1748
        return a_bzrdir.open_branch(ignore_fallbacks=ignore_fallbacks)
 
1749
 
 
1750
    def _vfs_initialize(self, a_bzrdir):
 
1751
        # Initialisation when using a local bzrdir object, or a non-vfs init
 
1752
        # method is not available on the server.
 
1753
        # self._custom_format is always set - the start of initialize ensures
 
1754
        # that.
 
1755
        if isinstance(a_bzrdir, RemoteBzrDir):
 
1756
            a_bzrdir._ensure_real()
 
1757
            result = self._custom_format.initialize(a_bzrdir._real_bzrdir)
 
1758
        else:
 
1759
            # We assume the bzrdir is parameterised; it may not be.
 
1760
            result = self._custom_format.initialize(a_bzrdir)
 
1761
        if (isinstance(a_bzrdir, RemoteBzrDir) and
 
1762
            not isinstance(result, RemoteBranch)):
 
1763
            result = RemoteBranch(a_bzrdir, a_bzrdir.find_repository(), result)
 
1764
        return result
 
1765
 
 
1766
    def initialize(self, a_bzrdir):
 
1767
        # 1) get the network name to use.
 
1768
        if self._custom_format:
 
1769
            network_name = self._custom_format.network_name()
 
1770
        else:
 
1771
            # Select the current bzrlib default and ask for that.
 
1772
            reference_bzrdir_format = bzrdir.format_registry.get('default')()
 
1773
            reference_format = reference_bzrdir_format.get_branch_format()
 
1774
            self._custom_format = reference_format
 
1775
            network_name = reference_format.network_name()
 
1776
        # Being asked to create on a non RemoteBzrDir:
 
1777
        if not isinstance(a_bzrdir, RemoteBzrDir):
 
1778
            return self._vfs_initialize(a_bzrdir)
 
1779
        medium = a_bzrdir._client._medium
 
1780
        if medium._is_remote_before((1, 13)):
 
1781
            return self._vfs_initialize(a_bzrdir)
 
1782
        # Creating on a remote bzr dir.
 
1783
        # 2) try direct creation via RPC
 
1784
        path = a_bzrdir._path_for_remote_call(a_bzrdir._client)
 
1785
        verb = 'BzrDir.create_branch'
 
1786
        try:
 
1787
            response = a_bzrdir._call(verb, path, network_name)
 
1788
        except errors.UnknownSmartMethod:
 
1789
            # Fallback - use vfs methods
 
1790
            medium._remember_remote_is_before((1, 13))
 
1791
            return self._vfs_initialize(a_bzrdir)
 
1792
        if response[0] != 'ok':
 
1793
            raise errors.UnexpectedSmartServerResponse(response)
 
1794
        # Turn the response into a RemoteRepository object.
 
1795
        format = RemoteBranchFormat(network_name=response[1])
 
1796
        repo_format = response_tuple_to_repo_format(response[3:])
 
1797
        if response[2] == '':
 
1798
            repo_bzrdir = a_bzrdir
 
1799
        else:
 
1800
            repo_bzrdir = RemoteBzrDir(
 
1801
                a_bzrdir.root_transport.clone(response[2]), a_bzrdir._format,
 
1802
                a_bzrdir._client)
 
1803
        remote_repo = RemoteRepository(repo_bzrdir, repo_format)
 
1804
        remote_branch = RemoteBranch(a_bzrdir, remote_repo,
 
1805
            format=format, setup_stacking=False)
 
1806
        # XXX: We know this is a new branch, so it must have revno 0, revid
 
1807
        # NULL_REVISION. Creating the branch locked would make this be unable
 
1808
        # to be wrong; here its simply very unlikely to be wrong. RBC 20090225
 
1809
        remote_branch._last_revision_info_cache = 0, NULL_REVISION
 
1810
        return remote_branch
 
1811
 
 
1812
    def make_tags(self, branch):
 
1813
        self._ensure_real()
 
1814
        return self._custom_format.make_tags(branch)
 
1815
 
 
1816
    def supports_tags(self):
 
1817
        # Remote branches might support tags, but we won't know until we
 
1818
        # access the real remote branch.
 
1819
        self._ensure_real()
 
1820
        return self._custom_format.supports_tags()
 
1821
 
 
1822
    def supports_stacking(self):
 
1823
        self._ensure_real()
 
1824
        return self._custom_format.supports_stacking()
 
1825
 
 
1826
 
 
1827
class RemoteBranch(branch.Branch, _RpcHelper):
 
1828
    """Branch stored on a server accessed by HPSS RPC.
 
1829
 
 
1830
    At the moment most operations are mapped down to simple file operations.
 
1831
    """
 
1832
 
 
1833
    def __init__(self, remote_bzrdir, remote_repository, real_branch=None,
 
1834
        _client=None, format=None, setup_stacking=True):
 
1835
        """Create a RemoteBranch instance.
 
1836
 
 
1837
        :param real_branch: An optional local implementation of the branch
 
1838
            format, usually accessing the data via the VFS.
 
1839
        :param _client: Private parameter for testing.
 
1840
        :param format: A RemoteBranchFormat object, None to create one
 
1841
            automatically. If supplied it should have a network_name already
 
1842
            supplied.
 
1843
        :param setup_stacking: If True make an RPC call to determine the
 
1844
            stacked (or not) status of the branch. If False assume the branch
 
1845
            is not stacked.
 
1846
        """
 
1847
        # We intentionally don't call the parent class's __init__, because it
 
1848
        # will try to assign to self.tags, which is a property in this subclass.
 
1849
        # And the parent's __init__ doesn't do much anyway.
 
1850
        self._revision_id_to_revno_cache = None
 
1851
        self._partial_revision_id_to_revno_cache = {}
 
1852
        self._revision_history_cache = None
 
1853
        self._last_revision_info_cache = None
 
1854
        self._merge_sorted_revisions_cache = None
 
1855
        self.bzrdir = remote_bzrdir
 
1856
        if _client is not None:
 
1857
            self._client = _client
 
1858
        else:
 
1859
            self._client = remote_bzrdir._client
 
1860
        self.repository = remote_repository
 
1861
        if real_branch is not None:
 
1862
            self._real_branch = real_branch
 
1863
            # Give the remote repository the matching real repo.
 
1864
            real_repo = self._real_branch.repository
 
1865
            if isinstance(real_repo, RemoteRepository):
 
1866
                real_repo._ensure_real()
 
1867
                real_repo = real_repo._real_repository
 
1868
            self.repository._set_real_repository(real_repo)
 
1869
            # Give the branch the remote repository to let fast-pathing happen.
 
1870
            self._real_branch.repository = self.repository
 
1871
        else:
 
1872
            self._real_branch = None
 
1873
        # Fill out expected attributes of branch for bzrlib api users.
 
1874
        self.base = self.bzrdir.root_transport.base
 
1875
        self._control_files = None
 
1876
        self._lock_mode = None
 
1877
        self._lock_token = None
 
1878
        self._repo_lock_token = None
 
1879
        self._lock_count = 0
 
1880
        self._leave_lock = False
 
1881
        # Setup a format: note that we cannot call _ensure_real until all the
 
1882
        # attributes above are set: This code cannot be moved higher up in this
 
1883
        # function.
 
1884
        if format is None:
 
1885
            self._format = RemoteBranchFormat()
 
1886
            if real_branch is not None:
 
1887
                self._format._network_name = \
 
1888
                    self._real_branch._format.network_name()
 
1889
        else:
 
1890
            self._format = format
 
1891
        if not self._format._network_name:
 
1892
            # Did not get from open_branchV2 - old server.
 
1893
            self._ensure_real()
 
1894
            self._format._network_name = \
 
1895
                self._real_branch._format.network_name()
 
1896
        self.tags = self._format.make_tags(self)
 
1897
        # The base class init is not called, so we duplicate this:
 
1898
        hooks = branch.Branch.hooks['open']
 
1899
        for hook in hooks:
 
1900
            hook(self)
 
1901
        if setup_stacking:
 
1902
            self._setup_stacking()
 
1903
 
 
1904
    def _setup_stacking(self):
 
1905
        # configure stacking into the remote repository, by reading it from
 
1906
        # the vfs branch.
 
1907
        try:
 
1908
            fallback_url = self.get_stacked_on_url()
 
1909
        except (errors.NotStacked, errors.UnstackableBranchFormat,
 
1910
            errors.UnstackableRepositoryFormat), e:
 
1911
            return
 
1912
        # it's relative to this branch...
 
1913
        fallback_url = urlutils.join(self.base, fallback_url)
 
1914
        transports = [self.bzrdir.root_transport]
 
1915
        stacked_on = branch.Branch.open(fallback_url,
 
1916
                                        possible_transports=transports)
 
1917
        self.repository.add_fallback_repository(stacked_on.repository)
 
1918
 
 
1919
    def _get_real_transport(self):
 
1920
        # if we try vfs access, return the real branch's vfs transport
 
1921
        self._ensure_real()
 
1922
        return self._real_branch._transport
 
1923
 
 
1924
    _transport = property(_get_real_transport)
 
1925
 
 
1926
    def __str__(self):
 
1927
        return "%s(%s)" % (self.__class__.__name__, self.base)
 
1928
 
 
1929
    __repr__ = __str__
 
1930
 
 
1931
    def _ensure_real(self):
 
1932
        """Ensure that there is a _real_branch set.
 
1933
 
 
1934
        Used before calls to self._real_branch.
 
1935
        """
 
1936
        if self._real_branch is None:
 
1937
            if not vfs.vfs_enabled():
 
1938
                raise AssertionError('smart server vfs must be enabled '
 
1939
                    'to use vfs implementation')
 
1940
            self.bzrdir._ensure_real()
 
1941
            self._real_branch = self.bzrdir._real_bzrdir.open_branch()
 
1942
            if self.repository._real_repository is None:
 
1943
                # Give the remote repository the matching real repo.
 
1944
                real_repo = self._real_branch.repository
 
1945
                if isinstance(real_repo, RemoteRepository):
 
1946
                    real_repo._ensure_real()
 
1947
                    real_repo = real_repo._real_repository
 
1948
                self.repository._set_real_repository(real_repo)
 
1949
            # Give the real branch the remote repository to let fast-pathing
 
1950
            # happen.
 
1951
            self._real_branch.repository = self.repository
 
1952
            if self._lock_mode == 'r':
 
1953
                self._real_branch.lock_read()
 
1954
            elif self._lock_mode == 'w':
 
1955
                self._real_branch.lock_write(token=self._lock_token)
 
1956
 
 
1957
    def _translate_error(self, err, **context):
 
1958
        self.repository._translate_error(err, branch=self, **context)
 
1959
 
 
1960
    def _clear_cached_state(self):
 
1961
        super(RemoteBranch, self)._clear_cached_state()
 
1962
        if self._real_branch is not None:
 
1963
            self._real_branch._clear_cached_state()
 
1964
 
 
1965
    def _clear_cached_state_of_remote_branch_only(self):
 
1966
        """Like _clear_cached_state, but doesn't clear the cache of
 
1967
        self._real_branch.
 
1968
 
 
1969
        This is useful when falling back to calling a method of
 
1970
        self._real_branch that changes state.  In that case the underlying
 
1971
        branch changes, so we need to invalidate this RemoteBranch's cache of
 
1972
        it.  However, there's no need to invalidate the _real_branch's cache
 
1973
        too, in fact doing so might harm performance.
 
1974
        """
 
1975
        super(RemoteBranch, self)._clear_cached_state()
 
1976
 
 
1977
    @property
 
1978
    def control_files(self):
 
1979
        # Defer actually creating RemoteBranchLockableFiles until its needed,
 
1980
        # because it triggers an _ensure_real that we otherwise might not need.
 
1981
        if self._control_files is None:
 
1982
            self._control_files = RemoteBranchLockableFiles(
 
1983
                self.bzrdir, self._client)
 
1984
        return self._control_files
 
1985
 
 
1986
    def _get_checkout_format(self):
 
1987
        self._ensure_real()
 
1988
        return self._real_branch._get_checkout_format()
 
1989
 
 
1990
    def get_physical_lock_status(self):
 
1991
        """See Branch.get_physical_lock_status()."""
 
1992
        # should be an API call to the server, as branches must be lockable.
 
1993
        self._ensure_real()
 
1994
        return self._real_branch.get_physical_lock_status()
 
1995
 
 
1996
    def get_stacked_on_url(self):
 
1997
        """Get the URL this branch is stacked against.
 
1998
 
 
1999
        :raises NotStacked: If the branch is not stacked.
 
2000
        :raises UnstackableBranchFormat: If the branch does not support
 
2001
            stacking.
 
2002
        :raises UnstackableRepositoryFormat: If the repository does not support
 
2003
            stacking.
 
2004
        """
 
2005
        try:
 
2006
            # there may not be a repository yet, so we can't use
 
2007
            # self._translate_error, so we can't use self._call either.
 
2008
            response = self._client.call('Branch.get_stacked_on_url',
 
2009
                self._remote_path())
 
2010
        except errors.ErrorFromSmartServer, err:
 
2011
            # there may not be a repository yet, so we can't call through
 
2012
            # its _translate_error
 
2013
            _translate_error(err, branch=self)
 
2014
        except errors.UnknownSmartMethod, err:
 
2015
            self._ensure_real()
 
2016
            return self._real_branch.get_stacked_on_url()
 
2017
        if response[0] != 'ok':
 
2018
            raise errors.UnexpectedSmartServerResponse(response)
 
2019
        return response[1]
 
2020
 
 
2021
    def _vfs_get_tags_bytes(self):
 
2022
        self._ensure_real()
 
2023
        return self._real_branch._get_tags_bytes()
 
2024
 
 
2025
    def _get_tags_bytes(self):
 
2026
        medium = self._client._medium
 
2027
        if medium._is_remote_before((1, 13)):
 
2028
            return self._vfs_get_tags_bytes()
 
2029
        try:
 
2030
            response = self._call('Branch.get_tags_bytes', self._remote_path())
 
2031
        except errors.UnknownSmartMethod:
 
2032
            medium._remember_remote_is_before((1, 13))
 
2033
            return self._vfs_get_tags_bytes()
 
2034
        return response[0]
 
2035
 
 
2036
    def lock_read(self):
 
2037
        self.repository.lock_read()
 
2038
        if not self._lock_mode:
 
2039
            self._lock_mode = 'r'
 
2040
            self._lock_count = 1
 
2041
            if self._real_branch is not None:
 
2042
                self._real_branch.lock_read()
 
2043
        else:
 
2044
            self._lock_count += 1
 
2045
 
 
2046
    def _remote_lock_write(self, token):
 
2047
        if token is None:
 
2048
            branch_token = repo_token = ''
 
2049
        else:
 
2050
            branch_token = token
 
2051
            repo_token = self.repository.lock_write()
 
2052
            self.repository.unlock()
 
2053
        err_context = {'token': token}
 
2054
        response = self._call(
 
2055
            'Branch.lock_write', self._remote_path(), branch_token,
 
2056
            repo_token or '', **err_context)
 
2057
        if response[0] != 'ok':
 
2058
            raise errors.UnexpectedSmartServerResponse(response)
 
2059
        ok, branch_token, repo_token = response
 
2060
        return branch_token, repo_token
 
2061
 
 
2062
    def lock_write(self, token=None):
 
2063
        if not self._lock_mode:
 
2064
            # Lock the branch and repo in one remote call.
 
2065
            remote_tokens = self._remote_lock_write(token)
 
2066
            self._lock_token, self._repo_lock_token = remote_tokens
 
2067
            if not self._lock_token:
 
2068
                raise SmartProtocolError('Remote server did not return a token!')
 
2069
            # Tell the self.repository object that it is locked.
 
2070
            self.repository.lock_write(
 
2071
                self._repo_lock_token, _skip_rpc=True)
 
2072
 
 
2073
            if self._real_branch is not None:
 
2074
                self._real_branch.lock_write(token=self._lock_token)
 
2075
            if token is not None:
 
2076
                self._leave_lock = True
 
2077
            else:
 
2078
                self._leave_lock = False
 
2079
            self._lock_mode = 'w'
 
2080
            self._lock_count = 1
 
2081
        elif self._lock_mode == 'r':
 
2082
            raise errors.ReadOnlyTransaction
 
2083
        else:
 
2084
            if token is not None:
 
2085
                # A token was given to lock_write, and we're relocking, so
 
2086
                # check that the given token actually matches the one we
 
2087
                # already have.
 
2088
                if token != self._lock_token:
 
2089
                    raise errors.TokenMismatch(token, self._lock_token)
 
2090
            self._lock_count += 1
 
2091
            # Re-lock the repository too.
 
2092
            self.repository.lock_write(self._repo_lock_token)
 
2093
        return self._lock_token or None
 
2094
 
 
2095
    def _set_tags_bytes(self, bytes):
 
2096
        self._ensure_real()
 
2097
        return self._real_branch._set_tags_bytes(bytes)
 
2098
 
 
2099
    def _unlock(self, branch_token, repo_token):
 
2100
        err_context = {'token': str((branch_token, repo_token))}
 
2101
        response = self._call(
 
2102
            'Branch.unlock', self._remote_path(), branch_token,
 
2103
            repo_token or '', **err_context)
 
2104
        if response == ('ok',):
 
2105
            return
 
2106
        raise errors.UnexpectedSmartServerResponse(response)
 
2107
 
 
2108
    def unlock(self):
 
2109
        try:
 
2110
            self._lock_count -= 1
 
2111
            if not self._lock_count:
 
2112
                self._clear_cached_state()
 
2113
                mode = self._lock_mode
 
2114
                self._lock_mode = None
 
2115
                if self._real_branch is not None:
 
2116
                    if (not self._leave_lock and mode == 'w' and
 
2117
                        self._repo_lock_token):
 
2118
                        # If this RemoteBranch will remove the physical lock
 
2119
                        # for the repository, make sure the _real_branch
 
2120
                        # doesn't do it first.  (Because the _real_branch's
 
2121
                        # repository is set to be the RemoteRepository.)
 
2122
                        self._real_branch.repository.leave_lock_in_place()
 
2123
                    self._real_branch.unlock()
 
2124
                if mode != 'w':
 
2125
                    # Only write-locked branched need to make a remote method
 
2126
                    # call to perfom the unlock.
 
2127
                    return
 
2128
                if not self._lock_token:
 
2129
                    raise AssertionError('Locked, but no token!')
 
2130
                branch_token = self._lock_token
 
2131
                repo_token = self._repo_lock_token
 
2132
                self._lock_token = None
 
2133
                self._repo_lock_token = None
 
2134
                if not self._leave_lock:
 
2135
                    self._unlock(branch_token, repo_token)
 
2136
        finally:
 
2137
            self.repository.unlock()
 
2138
 
 
2139
    def break_lock(self):
 
2140
        self._ensure_real()
 
2141
        return self._real_branch.break_lock()
 
2142
 
 
2143
    def leave_lock_in_place(self):
 
2144
        if not self._lock_token:
 
2145
            raise NotImplementedError(self.leave_lock_in_place)
 
2146
        self._leave_lock = True
 
2147
 
 
2148
    def dont_leave_lock_in_place(self):
 
2149
        if not self._lock_token:
 
2150
            raise NotImplementedError(self.dont_leave_lock_in_place)
 
2151
        self._leave_lock = False
 
2152
 
 
2153
    def _last_revision_info(self):
 
2154
        response = self._call('Branch.last_revision_info', self._remote_path())
 
2155
        if response[0] != 'ok':
 
2156
            raise SmartProtocolError('unexpected response code %s' % (response,))
 
2157
        revno = int(response[1])
 
2158
        last_revision = response[2]
 
2159
        return (revno, last_revision)
 
2160
 
 
2161
    def _gen_revision_history(self):
 
2162
        """See Branch._gen_revision_history()."""
 
2163
        response_tuple, response_handler = self._call_expecting_body(
 
2164
            'Branch.revision_history', self._remote_path())
 
2165
        if response_tuple[0] != 'ok':
 
2166
            raise errors.UnexpectedSmartServerResponse(response_tuple)
 
2167
        result = response_handler.read_body_bytes().split('\x00')
 
2168
        if result == ['']:
 
2169
            return []
 
2170
        return result
 
2171
 
 
2172
    def _remote_path(self):
 
2173
        return self.bzrdir._path_for_remote_call(self._client)
 
2174
 
 
2175
    def _set_last_revision_descendant(self, revision_id, other_branch,
 
2176
            allow_diverged=False, allow_overwrite_descendant=False):
 
2177
        # This performs additional work to meet the hook contract; while its
 
2178
        # undesirable, we have to synthesise the revno to call the hook, and
 
2179
        # not calling the hook is worse as it means changes can't be prevented.
 
2180
        # Having calculated this though, we can't just call into
 
2181
        # set_last_revision_info as a simple call, because there is a set_rh
 
2182
        # hook that some folk may still be using.
 
2183
        old_revno, old_revid = self.last_revision_info()
 
2184
        history = self._lefthand_history(revision_id)
 
2185
        self._run_pre_change_branch_tip_hooks(len(history), revision_id)
 
2186
        err_context = {'other_branch': other_branch}
 
2187
        response = self._call('Branch.set_last_revision_ex',
 
2188
            self._remote_path(), self._lock_token, self._repo_lock_token,
 
2189
            revision_id, int(allow_diverged), int(allow_overwrite_descendant),
 
2190
            **err_context)
 
2191
        self._clear_cached_state()
 
2192
        if len(response) != 3 and response[0] != 'ok':
 
2193
            raise errors.UnexpectedSmartServerResponse(response)
 
2194
        new_revno, new_revision_id = response[1:]
 
2195
        self._last_revision_info_cache = new_revno, new_revision_id
 
2196
        self._run_post_change_branch_tip_hooks(old_revno, old_revid)
 
2197
        if self._real_branch is not None:
 
2198
            cache = new_revno, new_revision_id
 
2199
            self._real_branch._last_revision_info_cache = cache
 
2200
 
 
2201
    def _set_last_revision(self, revision_id):
 
2202
        old_revno, old_revid = self.last_revision_info()
 
2203
        # This performs additional work to meet the hook contract; while its
 
2204
        # undesirable, we have to synthesise the revno to call the hook, and
 
2205
        # not calling the hook is worse as it means changes can't be prevented.
 
2206
        # Having calculated this though, we can't just call into
 
2207
        # set_last_revision_info as a simple call, because there is a set_rh
 
2208
        # hook that some folk may still be using.
 
2209
        history = self._lefthand_history(revision_id)
 
2210
        self._run_pre_change_branch_tip_hooks(len(history), revision_id)
 
2211
        self._clear_cached_state()
 
2212
        response = self._call('Branch.set_last_revision',
 
2213
            self._remote_path(), self._lock_token, self._repo_lock_token,
 
2214
            revision_id)
 
2215
        if response != ('ok',):
 
2216
            raise errors.UnexpectedSmartServerResponse(response)
 
2217
        self._run_post_change_branch_tip_hooks(old_revno, old_revid)
 
2218
 
 
2219
    @needs_write_lock
 
2220
    def set_revision_history(self, rev_history):
 
2221
        # Send just the tip revision of the history; the server will generate
 
2222
        # the full history from that.  If the revision doesn't exist in this
 
2223
        # branch, NoSuchRevision will be raised.
 
2224
        if rev_history == []:
 
2225
            rev_id = 'null:'
 
2226
        else:
 
2227
            rev_id = rev_history[-1]
 
2228
        self._set_last_revision(rev_id)
 
2229
        for hook in branch.Branch.hooks['set_rh']:
 
2230
            hook(self, rev_history)
 
2231
        self._cache_revision_history(rev_history)
 
2232
 
 
2233
    def _get_parent_location(self):
 
2234
        medium = self._client._medium
 
2235
        if medium._is_remote_before((1, 13)):
 
2236
            return self._vfs_get_parent_location()
 
2237
        try:
 
2238
            response = self._call('Branch.get_parent', self._remote_path())
 
2239
        except errors.UnknownSmartMethod:
 
2240
            medium._remember_remote_is_before((1, 13))
 
2241
            return self._vfs_get_parent_location()
 
2242
        if len(response) != 1:
 
2243
            raise errors.UnexpectedSmartServerResponse(response)
 
2244
        parent_location = response[0]
 
2245
        if parent_location == '':
 
2246
            return None
 
2247
        return parent_location
 
2248
 
 
2249
    def _vfs_get_parent_location(self):
 
2250
        self._ensure_real()
 
2251
        return self._real_branch._get_parent_location()
 
2252
 
 
2253
    def set_parent(self, url):
 
2254
        self._ensure_real()
 
2255
        return self._real_branch.set_parent(url)
 
2256
 
 
2257
    def _set_parent_location(self, url):
 
2258
        # Used by tests, to poke bad urls into branch configurations
 
2259
        if url is None:
 
2260
            self.set_parent(url)
 
2261
        else:
 
2262
            self._ensure_real()
 
2263
            return self._real_branch._set_parent_location(url)
 
2264
 
 
2265
    def set_stacked_on_url(self, stacked_location):
 
2266
        """Set the URL this branch is stacked against.
 
2267
 
 
2268
        :raises UnstackableBranchFormat: If the branch does not support
 
2269
            stacking.
 
2270
        :raises UnstackableRepositoryFormat: If the repository does not support
 
2271
            stacking.
 
2272
        """
 
2273
        self._ensure_real()
 
2274
        return self._real_branch.set_stacked_on_url(stacked_location)
 
2275
 
 
2276
    @needs_write_lock
 
2277
    def pull(self, source, overwrite=False, stop_revision=None,
 
2278
             **kwargs):
 
2279
        self._clear_cached_state_of_remote_branch_only()
 
2280
        self._ensure_real()
 
2281
        return self._real_branch.pull(
 
2282
            source, overwrite=overwrite, stop_revision=stop_revision,
 
2283
            _override_hook_target=self, **kwargs)
 
2284
 
 
2285
    @needs_read_lock
 
2286
    def push(self, target, overwrite=False, stop_revision=None):
 
2287
        self._ensure_real()
 
2288
        return self._real_branch.push(
 
2289
            target, overwrite=overwrite, stop_revision=stop_revision,
 
2290
            _override_hook_source_branch=self)
 
2291
 
 
2292
    def is_locked(self):
 
2293
        return self._lock_count >= 1
 
2294
 
 
2295
    @needs_read_lock
 
2296
    def revision_id_to_revno(self, revision_id):
 
2297
        self._ensure_real()
 
2298
        return self._real_branch.revision_id_to_revno(revision_id)
 
2299
 
 
2300
    @needs_write_lock
 
2301
    def set_last_revision_info(self, revno, revision_id):
 
2302
        # XXX: These should be returned by the set_last_revision_info verb
 
2303
        old_revno, old_revid = self.last_revision_info()
 
2304
        self._run_pre_change_branch_tip_hooks(revno, revision_id)
 
2305
        revision_id = ensure_null(revision_id)
 
2306
        try:
 
2307
            response = self._call('Branch.set_last_revision_info',
 
2308
                self._remote_path(), self._lock_token, self._repo_lock_token,
 
2309
                str(revno), revision_id)
 
2310
        except errors.UnknownSmartMethod:
 
2311
            self._ensure_real()
 
2312
            self._clear_cached_state_of_remote_branch_only()
 
2313
            self._real_branch.set_last_revision_info(revno, revision_id)
 
2314
            self._last_revision_info_cache = revno, revision_id
 
2315
            return
 
2316
        if response == ('ok',):
 
2317
            self._clear_cached_state()
 
2318
            self._last_revision_info_cache = revno, revision_id
 
2319
            self._run_post_change_branch_tip_hooks(old_revno, old_revid)
 
2320
            # Update the _real_branch's cache too.
 
2321
            if self._real_branch is not None:
 
2322
                cache = self._last_revision_info_cache
 
2323
                self._real_branch._last_revision_info_cache = cache
 
2324
        else:
 
2325
            raise errors.UnexpectedSmartServerResponse(response)
 
2326
 
 
2327
    @needs_write_lock
 
2328
    def generate_revision_history(self, revision_id, last_rev=None,
 
2329
                                  other_branch=None):
 
2330
        medium = self._client._medium
 
2331
        if not medium._is_remote_before((1, 6)):
 
2332
            # Use a smart method for 1.6 and above servers
 
2333
            try:
 
2334
                self._set_last_revision_descendant(revision_id, other_branch,
 
2335
                    allow_diverged=True, allow_overwrite_descendant=True)
 
2336
                return
 
2337
            except errors.UnknownSmartMethod:
 
2338
                medium._remember_remote_is_before((1, 6))
 
2339
        self._clear_cached_state_of_remote_branch_only()
 
2340
        self.set_revision_history(self._lefthand_history(revision_id,
 
2341
            last_rev=last_rev,other_branch=other_branch))
 
2342
 
 
2343
    def set_push_location(self, location):
 
2344
        self._ensure_real()
 
2345
        return self._real_branch.set_push_location(location)
 
2346
 
 
2347
 
 
2348
def _extract_tar(tar, to_dir):
 
2349
    """Extract all the contents of a tarfile object.
 
2350
 
 
2351
    A replacement for extractall, which is not present in python2.4
 
2352
    """
 
2353
    for tarinfo in tar:
 
2354
        tar.extract(tarinfo, to_dir)
 
2355
 
 
2356
 
 
2357
def _translate_error(err, **context):
 
2358
    """Translate an ErrorFromSmartServer into a more useful error.
 
2359
 
 
2360
    Possible context keys:
 
2361
      - branch
 
2362
      - repository
 
2363
      - bzrdir
 
2364
      - token
 
2365
      - other_branch
 
2366
      - path
 
2367
 
 
2368
    If the error from the server doesn't match a known pattern, then
 
2369
    UnknownErrorFromSmartServer is raised.
 
2370
    """
 
2371
    def find(name):
 
2372
        try:
 
2373
            return context[name]
 
2374
        except KeyError, key_err:
 
2375
            mutter('Missing key %r in context %r', key_err.args[0], context)
 
2376
            raise err
 
2377
    def get_path():
 
2378
        """Get the path from the context if present, otherwise use first error
 
2379
        arg.
 
2380
        """
 
2381
        try:
 
2382
            return context['path']
 
2383
        except KeyError, key_err:
 
2384
            try:
 
2385
                return err.error_args[0]
 
2386
            except IndexError, idx_err:
 
2387
                mutter(
 
2388
                    'Missing key %r in context %r', key_err.args[0], context)
 
2389
                raise err
 
2390
 
 
2391
    if err.error_verb == 'NoSuchRevision':
 
2392
        raise NoSuchRevision(find('branch'), err.error_args[0])
 
2393
    elif err.error_verb == 'nosuchrevision':
 
2394
        raise NoSuchRevision(find('repository'), err.error_args[0])
 
2395
    elif err.error_tuple == ('nobranch',):
 
2396
        raise errors.NotBranchError(path=find('bzrdir').root_transport.base)
 
2397
    elif err.error_verb == 'norepository':
 
2398
        raise errors.NoRepositoryPresent(find('bzrdir'))
 
2399
    elif err.error_verb == 'LockContention':
 
2400
        raise errors.LockContention('(remote lock)')
 
2401
    elif err.error_verb == 'UnlockableTransport':
 
2402
        raise errors.UnlockableTransport(find('bzrdir').root_transport)
 
2403
    elif err.error_verb == 'LockFailed':
 
2404
        raise errors.LockFailed(err.error_args[0], err.error_args[1])
 
2405
    elif err.error_verb == 'TokenMismatch':
 
2406
        raise errors.TokenMismatch(find('token'), '(remote token)')
 
2407
    elif err.error_verb == 'Diverged':
 
2408
        raise errors.DivergedBranches(find('branch'), find('other_branch'))
 
2409
    elif err.error_verb == 'TipChangeRejected':
 
2410
        raise errors.TipChangeRejected(err.error_args[0].decode('utf8'))
 
2411
    elif err.error_verb == 'UnstackableBranchFormat':
 
2412
        raise errors.UnstackableBranchFormat(*err.error_args)
 
2413
    elif err.error_verb == 'UnstackableRepositoryFormat':
 
2414
        raise errors.UnstackableRepositoryFormat(*err.error_args)
 
2415
    elif err.error_verb == 'NotStacked':
 
2416
        raise errors.NotStacked(branch=find('branch'))
 
2417
    elif err.error_verb == 'PermissionDenied':
 
2418
        path = get_path()
 
2419
        if len(err.error_args) >= 2:
 
2420
            extra = err.error_args[1]
 
2421
        else:
 
2422
            extra = None
 
2423
        raise errors.PermissionDenied(path, extra=extra)
 
2424
    elif err.error_verb == 'ReadError':
 
2425
        path = get_path()
 
2426
        raise errors.ReadError(path)
 
2427
    elif err.error_verb == 'NoSuchFile':
 
2428
        path = get_path()
 
2429
        raise errors.NoSuchFile(path)
 
2430
    elif err.error_verb == 'FileExists':
 
2431
        raise errors.FileExists(err.error_args[0])
 
2432
    elif err.error_verb == 'DirectoryNotEmpty':
 
2433
        raise errors.DirectoryNotEmpty(err.error_args[0])
 
2434
    elif err.error_verb == 'ShortReadvError':
 
2435
        args = err.error_args
 
2436
        raise errors.ShortReadvError(
 
2437
            args[0], int(args[1]), int(args[2]), int(args[3]))
 
2438
    elif err.error_verb in ('UnicodeEncodeError', 'UnicodeDecodeError'):
 
2439
        encoding = str(err.error_args[0]) # encoding must always be a string
 
2440
        val = err.error_args[1]
 
2441
        start = int(err.error_args[2])
 
2442
        end = int(err.error_args[3])
 
2443
        reason = str(err.error_args[4]) # reason must always be a string
 
2444
        if val.startswith('u:'):
 
2445
            val = val[2:].decode('utf-8')
 
2446
        elif val.startswith('s:'):
 
2447
            val = val[2:].decode('base64')
 
2448
        if err.error_verb == 'UnicodeDecodeError':
 
2449
            raise UnicodeDecodeError(encoding, val, start, end, reason)
 
2450
        elif err.error_verb == 'UnicodeEncodeError':
 
2451
            raise UnicodeEncodeError(encoding, val, start, end, reason)
 
2452
    elif err.error_verb == 'ReadOnlyError':
 
2453
        raise errors.TransportNotPossible('readonly transport')
 
2454
    raise errors.UnknownErrorFromSmartServer(err)