91
# Note that RemoteBzrDirProber lives in bzrlib.bzrdir so bzrlib.remote
92
# does not have to be imported unless a remote format is involved.
94
class RemoteBzrDirFormat(_mod_bzrdir.BzrDirMetaFormat1):
95
"""Format representing bzrdirs accessed via a smart server"""
97
supports_workingtrees = False
100
_mod_bzrdir.BzrDirMetaFormat1.__init__(self)
101
# XXX: It's a bit ugly that the network name is here, because we'd
102
# like to believe that format objects are stateless or at least
103
# immutable, However, we do at least avoid mutating the name after
104
# it's returned. See <https://bugs.launchpad.net/bzr/+bug/504102>
105
self._network_name = None
108
return "%s(_network_name=%r)" % (self.__class__.__name__,
111
def get_format_description(self):
112
if self._network_name:
113
real_format = controldir.network_format_registry.get(self._network_name)
114
return 'Remote: ' + real_format.get_format_description()
115
return 'bzr remote bzrdir'
117
def get_format_string(self):
118
raise NotImplementedError(self.get_format_string)
120
def network_name(self):
121
if self._network_name:
122
return self._network_name
124
raise AssertionError("No network name set.")
126
def initialize_on_transport(self, transport):
128
# hand off the request to the smart server
129
client_medium = transport.get_smart_medium()
130
except errors.NoSmartMedium:
131
# TODO: lookup the local format from a server hint.
132
local_dir_format = _mod_bzrdir.BzrDirMetaFormat1()
133
return local_dir_format.initialize_on_transport(transport)
134
client = _SmartClient(client_medium)
135
path = client.remote_path_from_transport(transport)
137
response = client.call('BzrDirFormat.initialize', path)
138
except errors.ErrorFromSmartServer, err:
139
_translate_error(err, path=path)
140
if response[0] != 'ok':
141
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
142
format = RemoteBzrDirFormat()
143
self._supply_sub_formats_to(format)
144
return RemoteBzrDir(transport, format)
146
def parse_NoneTrueFalse(self, arg):
153
raise AssertionError("invalid arg %r" % arg)
155
def _serialize_NoneTrueFalse(self, arg):
162
def _serialize_NoneString(self, arg):
165
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
166
create_prefix=False, force_new_repo=False, stacked_on=None,
167
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
170
# hand off the request to the smart server
171
client_medium = transport.get_smart_medium()
172
except errors.NoSmartMedium:
175
# Decline to open it if the server doesn't support our required
176
# version (3) so that the VFS-based transport will do it.
177
if client_medium.should_probe():
179
server_version = client_medium.protocol_version()
180
if server_version != '2':
184
except errors.SmartProtocolError:
185
# Apparently there's no usable smart server there, even though
186
# the medium supports the smart protocol.
191
client = _SmartClient(client_medium)
192
path = client.remote_path_from_transport(transport)
193
if client_medium._is_remote_before((1, 16)):
196
# TODO: lookup the local format from a server hint.
197
local_dir_format = _mod_bzrdir.BzrDirMetaFormat1()
198
self._supply_sub_formats_to(local_dir_format)
199
return local_dir_format.initialize_on_transport_ex(transport,
200
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
201
force_new_repo=force_new_repo, stacked_on=stacked_on,
202
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
203
make_working_trees=make_working_trees, shared_repo=shared_repo,
205
return self._initialize_on_transport_ex_rpc(client, path, transport,
206
use_existing_dir, create_prefix, force_new_repo, stacked_on,
207
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
209
def _initialize_on_transport_ex_rpc(self, client, path, transport,
210
use_existing_dir, create_prefix, force_new_repo, stacked_on,
211
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
213
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
214
args.append(self._serialize_NoneTrueFalse(create_prefix))
215
args.append(self._serialize_NoneTrueFalse(force_new_repo))
216
args.append(self._serialize_NoneString(stacked_on))
217
# stack_on_pwd is often/usually our transport
220
stack_on_pwd = transport.relpath(stack_on_pwd)
223
except errors.PathNotChild:
225
args.append(self._serialize_NoneString(stack_on_pwd))
226
args.append(self._serialize_NoneString(repo_format_name))
227
args.append(self._serialize_NoneTrueFalse(make_working_trees))
228
args.append(self._serialize_NoneTrueFalse(shared_repo))
229
request_network_name = self._network_name or \
230
_mod_bzrdir.BzrDirFormat.get_default_format().network_name()
232
response = client.call('BzrDirFormat.initialize_ex_1.16',
233
request_network_name, path, *args)
234
except errors.UnknownSmartMethod:
235
client._medium._remember_remote_is_before((1,16))
236
local_dir_format = _mod_bzrdir.BzrDirMetaFormat1()
237
self._supply_sub_formats_to(local_dir_format)
238
return local_dir_format.initialize_on_transport_ex(transport,
239
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
240
force_new_repo=force_new_repo, stacked_on=stacked_on,
241
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
242
make_working_trees=make_working_trees, shared_repo=shared_repo,
244
except errors.ErrorFromSmartServer, err:
245
_translate_error(err, path=path)
246
repo_path = response[0]
247
bzrdir_name = response[6]
248
require_stacking = response[7]
249
require_stacking = self.parse_NoneTrueFalse(require_stacking)
250
format = RemoteBzrDirFormat()
251
format._network_name = bzrdir_name
252
self._supply_sub_formats_to(format)
253
bzrdir = RemoteBzrDir(transport, format, _client=client)
255
repo_format = response_tuple_to_repo_format(response[1:])
259
repo_bzrdir_format = RemoteBzrDirFormat()
260
repo_bzrdir_format._network_name = response[5]
261
repo_bzr = RemoteBzrDir(transport.clone(repo_path),
265
final_stack = response[8] or None
266
final_stack_pwd = response[9] or None
268
final_stack_pwd = urlutils.join(
269
transport.base, final_stack_pwd)
270
remote_repo = RemoteRepository(repo_bzr, repo_format)
271
if len(response) > 10:
272
# Updated server verb that locks remotely.
273
repo_lock_token = response[10] or None
274
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
276
remote_repo.dont_leave_lock_in_place()
278
remote_repo.lock_write()
279
policy = _mod_bzrdir.UseExistingRepository(remote_repo, final_stack,
280
final_stack_pwd, require_stacking)
281
policy.acquire_repository()
285
bzrdir._format.set_branch_format(self.get_branch_format())
287
# The repo has already been created, but we need to make sure that
288
# we'll make a stackable branch.
289
bzrdir._format.require_stacking(_skip_repo=True)
290
return remote_repo, bzrdir, require_stacking, policy
292
def _open(self, transport):
293
return RemoteBzrDir(transport, self)
295
def __eq__(self, other):
296
if not isinstance(other, RemoteBzrDirFormat):
298
return self.get_format_description() == other.get_format_description()
300
def __return_repository_format(self):
301
# Always return a RemoteRepositoryFormat object, but if a specific bzr
302
# repository format has been asked for, tell the RemoteRepositoryFormat
303
# that it should use that for init() etc.
304
result = RemoteRepositoryFormat()
305
custom_format = getattr(self, '_repository_format', None)
307
if isinstance(custom_format, RemoteRepositoryFormat):
310
# We will use the custom format to create repositories over the
311
# wire; expose its details like rich_root_data for code to
313
result._custom_format = custom_format
316
def get_branch_format(self):
317
result = _mod_bzrdir.BzrDirMetaFormat1.get_branch_format(self)
318
if not isinstance(result, RemoteBranchFormat):
319
new_result = RemoteBranchFormat()
320
new_result._custom_format = result
322
self.set_branch_format(new_result)
326
repository_format = property(__return_repository_format,
327
_mod_bzrdir.BzrDirMetaFormat1._set_repository_format) #.im_func)
330
class RemoteBzrDir(_mod_bzrdir.BzrDir, _RpcHelper):
83
# Note: RemoteBzrDirFormat is in bzrdir.py
85
class RemoteBzrDir(BzrDir, _RpcHelper):
331
86
"""Control directory on a remote server, accessed via bzr:// or similar."""
333
def __init__(self, transport, format, _client=None, _force_probe=False):
88
def __init__(self, transport, format, _client=None):
334
89
"""Construct a RemoteBzrDir.
336
91
:param _client: Private parameter for testing. Disables probing and the
337
92
use of a real bzrdir.
339
_mod_bzrdir.BzrDir.__init__(self, transport, format)
94
BzrDir.__init__(self, transport, format)
340
95
# this object holds a delegated bzrdir that uses file-level operations
341
96
# to talk to the other side
342
97
self._real_bzrdir = None
343
self._has_working_tree = None
344
98
# 1-shot cache for the call pattern 'create_branch; open_branch' - see
345
99
# create_branch for details.
346
100
self._next_open_branch_result = None
537
245
def _get_branch_reference(self):
538
246
path = self._path_for_remote_call(self._client)
539
247
medium = self._client._medium
541
('BzrDir.open_branchV3', (2, 1)),
542
('BzrDir.open_branchV2', (1, 13)),
543
('BzrDir.open_branch', None),
545
for verb, required_version in candidate_calls:
546
if required_version and medium._is_remote_before(required_version):
248
if not medium._is_remote_before((1, 13)):
549
response = self._call(verb, path)
250
response = self._call('BzrDir.open_branchV2', path)
251
if response[0] not in ('ref', 'branch'):
252
raise errors.UnexpectedSmartServerResponse(response)
550
254
except errors.UnknownSmartMethod:
551
if required_version is None:
553
medium._remember_remote_is_before(required_version)
556
if verb == 'BzrDir.open_branch':
557
if response[0] != 'ok':
558
raise errors.UnexpectedSmartServerResponse(response)
559
if response[1] != '':
560
return ('ref', response[1])
562
return ('branch', '')
563
if response[0] not in ('ref', 'branch'):
255
medium._remember_remote_is_before((1, 13))
256
response = self._call('BzrDir.open_branch', path)
257
if response[0] != 'ok':
564
258
raise errors.UnexpectedSmartServerResponse(response)
259
if response[1] != '':
260
return ('ref', response[1])
262
return ('branch', '')
567
def _get_tree_branch(self, name=None):
264
def _get_tree_branch(self):
568
265
"""See BzrDir._get_tree_branch()."""
569
return None, self.open_branch(name=name)
266
return None, self.open_branch()
571
def open_branch(self, name=None, unsupported=False,
572
ignore_fallbacks=False):
268
def open_branch(self, _unsupported=False, ignore_fallbacks=False):
574
270
raise NotImplementedError('unsupported flag support not implemented yet.')
575
271
if self._next_open_branch_result is not None:
576
272
# See create_branch for details.
1510
1128
# state, so always add a lock here. If a caller passes us a locked
1511
1129
# repository, they are responsible for unlocking it later.
1512
1130
repository.lock_read()
1513
self._check_fallback_repository(repository)
1514
1131
self._fallback_repositories.append(repository)
1515
1132
# If self._real_repository was parameterised already (e.g. because a
1516
1133
# _real_branch had its get_stacked_on_url method called), then the
1517
1134
# repository to be added may already be in the _real_repositories list.
1518
1135
if self._real_repository is not None:
1519
fallback_locations = [repo.user_url for repo in
1136
fallback_locations = [repo.bzrdir.root_transport.base for repo in
1520
1137
self._real_repository._fallback_repositories]
1521
if repository.user_url not in fallback_locations:
1138
if repository.bzrdir.root_transport.base not in fallback_locations:
1522
1139
self._real_repository.add_fallback_repository(repository)
1524
def _check_fallback_repository(self, repository):
1525
"""Check that this repository can fallback to repository safely.
1527
Raise an error if not.
1529
:param repository: A repository to fallback to.
1531
return _mod_repository.InterRepository._assert_same_model(
1534
1141
def add_inventory(self, revid, inv, parents):
1535
1142
self._ensure_real()
1536
1143
return self._real_repository.add_inventory(revid, inv, parents)
1538
1145
def add_inventory_by_delta(self, basis_revision_id, delta, new_revision_id,
1539
parents, basis_inv=None, propagate_caches=False):
1540
1147
self._ensure_real()
1541
1148
return self._real_repository.add_inventory_by_delta(basis_revision_id,
1542
delta, new_revision_id, parents, basis_inv=basis_inv,
1543
propagate_caches=propagate_caches)
1149
delta, new_revision_id, parents)
1545
1151
def add_revision(self, rev_id, rev, inv=None, config=None):
1546
1152
self._ensure_real()
2059
1658
def insert_stream(self, stream, src_format, resume_tokens):
2060
1659
target = self.target_repo
2061
1660
target._unstacked_provider.missing_keys.clear()
2062
candidate_calls = [('Repository.insert_stream_1.19', (1, 19))]
2063
1661
if target._lock_token:
2064
candidate_calls.append(('Repository.insert_stream_locked', (1, 14)))
2065
lock_args = (target._lock_token or '',)
1662
verb = 'Repository.insert_stream_locked'
1663
extra_args = (target._lock_token or '',)
1664
required_version = (1, 14)
2067
candidate_calls.append(('Repository.insert_stream', (1, 13)))
1666
verb = 'Repository.insert_stream'
1668
required_version = (1, 13)
2069
1669
client = target._client
2070
1670
medium = client._medium
1671
if medium._is_remote_before(required_version):
1672
# No possible way this can work.
1673
return self._insert_real(stream, src_format, resume_tokens)
2071
1674
path = target.bzrdir._path_for_remote_call(client)
2072
# Probe for the verb to use with an empty stream before sending the
2073
# real stream to it. We do this both to avoid the risk of sending a
2074
# large request that is then rejected, and because we don't want to
2075
# implement a way to buffer, rewind, or restart the stream.
2077
for verb, required_version in candidate_calls:
2078
if medium._is_remote_before(required_version):
2081
# We've already done the probing (and set _is_remote_before) on
2082
# a previous insert.
1675
if not resume_tokens:
1676
# XXX: Ugly but important for correctness, *will* be fixed during
1677
# 1.13 cycle. Pushing a stream that is interrupted results in a
1678
# fallback to the _real_repositories sink *with a partial stream*.
1679
# Thats bad because we insert less data than bzr expected. To avoid
1680
# this we do a trial push to make sure the verb is accessible, and
1681
# do not fallback when actually pushing the stream. A cleanup patch
1682
# is going to look at rewinding/restarting the stream/partial
2085
1684
byte_stream = smart_repo._stream_to_byte_stream([], src_format)
2087
1686
response = client.call_with_body_stream(
2088
(verb, path, '') + lock_args, byte_stream)
1687
(verb, path, '') + extra_args, byte_stream)
2089
1688
except errors.UnknownSmartMethod:
2090
1689
medium._remember_remote_is_before(required_version)
2096
return self._insert_real(stream, src_format, resume_tokens)
2097
self._last_inv_record = None
2098
self._last_substream = None
2099
if required_version < (1, 19):
2100
# Remote side doesn't support inventory deltas. Wrap the stream to
2101
# make sure we don't send any. If the stream contains inventory
2102
# deltas we'll interrupt the smart insert_stream request and
2104
stream = self._stop_stream_if_inventory_delta(stream)
1690
return self._insert_real(stream, src_format, resume_tokens)
2105
1691
byte_stream = smart_repo._stream_to_byte_stream(
2106
1692
stream, src_format)
2107
1693
resume_tokens = ' '.join(resume_tokens)
2108
1694
response = client.call_with_body_stream(
2109
(verb, path, resume_tokens) + lock_args, byte_stream)
1695
(verb, path, resume_tokens) + extra_args, byte_stream)
2110
1696
if response[0][0] not in ('ok', 'missing-basis'):
2111
1697
raise errors.UnexpectedSmartServerResponse(response)
2112
if self._last_substream is not None:
2113
# The stream included an inventory-delta record, but the remote
2114
# side isn't new enough to support them. So we need to send the
2115
# rest of the stream via VFS.
2116
self.target_repo.refresh_data()
2117
return self._resume_stream_with_vfs(response, src_format)
2118
1698
if response[0][0] == 'missing-basis':
2119
1699
tokens, missing_keys = bencode.bdecode_as_tuple(response[0][1])
2120
1700
resume_tokens = tokens
2123
1703
self.target_repo.refresh_data()
2124
1704
return [], set()
2126
def _resume_stream_with_vfs(self, response, src_format):
2127
"""Resume sending a stream via VFS, first resending the record and
2128
substream that couldn't be sent via an insert_stream verb.
2130
if response[0][0] == 'missing-basis':
2131
tokens, missing_keys = bencode.bdecode_as_tuple(response[0][1])
2132
# Ignore missing_keys, we haven't finished inserting yet
2135
def resume_substream():
2136
# Yield the substream that was interrupted.
2137
for record in self._last_substream:
2139
self._last_substream = None
2140
def resume_stream():
2141
# Finish sending the interrupted substream
2142
yield ('inventory-deltas', resume_substream())
2143
# Then simply continue sending the rest of the stream.
2144
for substream_kind, substream in self._last_stream:
2145
yield substream_kind, substream
2146
return self._insert_real(resume_stream(), src_format, tokens)
2148
def _stop_stream_if_inventory_delta(self, stream):
2149
"""Normally this just lets the original stream pass-through unchanged.
2151
However if any 'inventory-deltas' substream occurs it will stop
2152
streaming, and store the interrupted substream and stream in
2153
self._last_substream and self._last_stream so that the stream can be
2154
resumed by _resume_stream_with_vfs.
2157
stream_iter = iter(stream)
2158
for substream_kind, substream in stream_iter:
2159
if substream_kind == 'inventory-deltas':
2160
self._last_substream = substream
2161
self._last_stream = stream_iter
2164
yield substream_kind, substream
2167
class RemoteStreamSource(vf_repository.StreamSource):
1707
class RemoteStreamSource(repository.StreamSource):
2168
1708
"""Stream data from a remote server."""
2170
1710
def get_stream(self, search):
2171
1711
if (self.from_repository._fallback_repositories and
2172
1712
self.to_format._fetch_order == 'topological'):
2173
1713
return self._real_stream(self.from_repository, search)
2176
repos = [self.from_repository]
2182
repos.extend(repo._fallback_repositories)
2183
sources.append(repo)
2184
return self.missing_parents_chain(search, sources)
2186
def get_stream_for_missing_keys(self, missing_keys):
2187
self.from_repository._ensure_real()
2188
real_repo = self.from_repository._real_repository
2189
real_source = real_repo._get_source(self.to_format)
2190
return real_source.get_stream_for_missing_keys(missing_keys)
1714
return self.missing_parents_chain(search, [self.from_repository] +
1715
self.from_repository._fallback_repositories)
2192
1717
def _real_stream(self, repo, search):
2193
1718
"""Get a stream for search from repo.
2224
1748
return self._real_stream(repo, search)
2225
1749
client = repo._client
2226
1750
medium = client._medium
1751
if medium._is_remote_before((1, 13)):
1752
# streaming was added in 1.13
1753
return self._real_stream(repo, search)
2227
1754
path = repo.bzrdir._path_for_remote_call(client)
2228
search_bytes = repo._serialise_search_result(search)
2229
args = (path, self.to_format.network_name())
2231
('Repository.get_stream_1.19', (1, 19)),
2232
('Repository.get_stream', (1, 13))]
2235
for verb, version in candidate_verbs:
2236
if medium._is_remote_before(version):
2239
response = repo._call_with_body_bytes_expecting_body(
2240
verb, args, search_bytes)
2241
except errors.UnknownSmartMethod:
2242
medium._remember_remote_is_before(version)
2243
except errors.UnknownErrorFromSmartServer, e:
2244
if isinstance(search, graph.EverythingResult):
2245
error_verb = e.error_from_smart_server.error_verb
2246
if error_verb == 'BadSearch':
2247
# Pre-2.4 servers don't support this sort of search.
2248
# XXX: perhaps falling back to VFS on BadSearch is a
2249
# good idea in general? It might provide a little bit
2250
# of protection against client-side bugs.
2251
medium._remember_remote_is_before((2, 4))
2255
response_tuple, response_handler = response
1756
search_bytes = repo._serialise_search_result(search)
1757
response = repo._call_with_body_bytes_expecting_body(
1758
'Repository.get_stream',
1759
(path, self.to_format.network_name()), search_bytes)
1760
response_tuple, response_handler = response
1761
except errors.UnknownSmartMethod:
1762
medium._remember_remote_is_before((1,13))
2259
1763
return self._real_stream(repo, search)
2260
1764
if response_tuple[0] != 'ok':
2261
1765
raise errors.UnexpectedSmartServerResponse(response_tuple)
2262
1766
byte_stream = response_handler.read_streamed_body()
2263
src_format, stream = smart_repo._byte_stream_to_stream(byte_stream,
2264
self._record_counter)
1767
src_format, stream = smart_repo._byte_stream_to_stream(byte_stream)
2265
1768
if src_format.network_name() != repo._format.network_name():
2266
1769
raise AssertionError(
2267
1770
"Mismatched RemoteRepository and stream src %r, %r" % (
2343
1845
self._network_name)
2345
1847
def get_format_description(self):
2347
return 'Remote: ' + self._custom_format.get_format_description()
1848
return 'Remote BZR Branch'
2349
1850
def network_name(self):
2350
1851
return self._network_name
2352
def open(self, a_bzrdir, name=None, ignore_fallbacks=False):
2353
return a_bzrdir.open_branch(name=name,
2354
ignore_fallbacks=ignore_fallbacks)
1853
def open(self, a_bzrdir, ignore_fallbacks=False):
1854
return a_bzrdir.open_branch(ignore_fallbacks=ignore_fallbacks)
2356
def _vfs_initialize(self, a_bzrdir, name):
1856
def _vfs_initialize(self, a_bzrdir):
2357
1857
# Initialisation when using a local bzrdir object, or a non-vfs init
2358
1858
# method is not available on the server.
2359
1859
# self._custom_format is always set - the start of initialize ensures
2361
1861
if isinstance(a_bzrdir, RemoteBzrDir):
2362
1862
a_bzrdir._ensure_real()
2363
result = self._custom_format.initialize(a_bzrdir._real_bzrdir,
1863
result = self._custom_format.initialize(a_bzrdir._real_bzrdir)
2366
1865
# We assume the bzrdir is parameterised; it may not be.
2367
result = self._custom_format.initialize(a_bzrdir, name)
1866
result = self._custom_format.initialize(a_bzrdir)
2368
1867
if (isinstance(a_bzrdir, RemoteBzrDir) and
2369
1868
not isinstance(result, RemoteBranch)):
2370
result = RemoteBranch(a_bzrdir, a_bzrdir.find_repository(), result,
1869
result = RemoteBranch(a_bzrdir, a_bzrdir.find_repository(), result)
2374
def initialize(self, a_bzrdir, name=None, repository=None):
1872
def initialize(self, a_bzrdir):
2375
1873
# 1) get the network name to use.
2376
1874
if self._custom_format:
2377
1875
network_name = self._custom_format.network_name()
2379
1877
# Select the current bzrlib default and ask for that.
2380
reference_bzrdir_format = _mod_bzrdir.format_registry.get('default')()
1878
reference_bzrdir_format = bzrdir.format_registry.get('default')()
2381
1879
reference_format = reference_bzrdir_format.get_branch_format()
2382
1880
self._custom_format = reference_format
2383
1881
network_name = reference_format.network_name()
2384
1882
# Being asked to create on a non RemoteBzrDir:
2385
1883
if not isinstance(a_bzrdir, RemoteBzrDir):
2386
return self._vfs_initialize(a_bzrdir, name=name)
1884
return self._vfs_initialize(a_bzrdir)
2387
1885
medium = a_bzrdir._client._medium
2388
1886
if medium._is_remote_before((1, 13)):
2389
return self._vfs_initialize(a_bzrdir, name=name)
1887
return self._vfs_initialize(a_bzrdir)
2390
1888
# Creating on a remote bzr dir.
2391
1889
# 2) try direct creation via RPC
2392
1890
path = a_bzrdir._path_for_remote_call(a_bzrdir._client)
2393
if name is not None:
2394
# XXX JRV20100304: Support creating colocated branches
2395
raise errors.NoColocatedBranchSupport(self)
2396
1891
verb = 'BzrDir.create_branch'
2398
1893
response = a_bzrdir._call(verb, path, network_name)
2399
1894
except errors.UnknownSmartMethod:
2400
1895
# Fallback - use vfs methods
2401
1896
medium._remember_remote_is_before((1, 13))
2402
return self._vfs_initialize(a_bzrdir, name=name)
1897
return self._vfs_initialize(a_bzrdir)
2403
1898
if response[0] != 'ok':
2404
1899
raise errors.UnexpectedSmartServerResponse(response)
2405
1900
# Turn the response into a RemoteRepository object.
2406
1901
format = RemoteBranchFormat(network_name=response[1])
2407
1902
repo_format = response_tuple_to_repo_format(response[3:])
2408
repo_path = response[2]
2409
if repository is not None:
2410
remote_repo_url = urlutils.join(a_bzrdir.user_url, repo_path)
2411
url_diff = urlutils.relative_url(repository.user_url,
2414
raise AssertionError(
2415
'repository.user_url %r does not match URL from server '
2416
'response (%r + %r)'
2417
% (repository.user_url, a_bzrdir.user_url, repo_path))
2418
remote_repo = repository
1903
if response[2] == '':
1904
repo_bzrdir = a_bzrdir
2421
repo_bzrdir = a_bzrdir
2423
repo_bzrdir = RemoteBzrDir(
2424
a_bzrdir.root_transport.clone(repo_path), a_bzrdir._format,
2426
remote_repo = RemoteRepository(repo_bzrdir, repo_format)
1906
repo_bzrdir = RemoteBzrDir(
1907
a_bzrdir.root_transport.clone(response[2]), a_bzrdir._format,
1909
remote_repo = RemoteRepository(repo_bzrdir, repo_format)
2427
1910
remote_branch = RemoteBranch(a_bzrdir, remote_repo,
2428
format=format, setup_stacking=False, name=name)
1911
format=format, setup_stacking=False)
2429
1912
# XXX: We know this is a new branch, so it must have revno 0, revid
2430
1913
# NULL_REVISION. Creating the branch locked would make this be unable
2431
1914
# to be wrong; here its simply very unlikely to be wrong. RBC 20090225
2689
2146
return self._vfs_get_tags_bytes()
2690
2147
return response[0]
2692
def _vfs_set_tags_bytes(self, bytes):
2694
return self._real_branch._set_tags_bytes(bytes)
2696
def _set_tags_bytes(self, bytes):
2697
if self.is_locked():
2698
self._tags_bytes = bytes
2699
medium = self._client._medium
2700
if medium._is_remote_before((1, 18)):
2701
self._vfs_set_tags_bytes(bytes)
2705
self._remote_path(), self._lock_token, self._repo_lock_token)
2706
response = self._call_with_body_bytes(
2707
'Branch.set_tags_bytes', args, bytes)
2708
except errors.UnknownSmartMethod:
2709
medium._remember_remote_is_before((1, 18))
2710
self._vfs_set_tags_bytes(bytes)
2712
2149
def lock_read(self):
2713
"""Lock the branch for read operations.
2715
:return: A bzrlib.lock.LogicalLockResult.
2717
2150
self.repository.lock_read()
2718
2151
if not self._lock_mode:
2719
self._note_lock('r')
2720
2152
self._lock_mode = 'r'
2721
2153
self._lock_count = 1
2722
2154
if self._real_branch is not None:
2723
2155
self._real_branch.lock_read()
2725
2157
self._lock_count += 1
2726
return lock.LogicalLockResult(self.unlock)
2728
2159
def _remote_lock_write(self, token):
2729
2160
if token is None:
2730
2161
branch_token = repo_token = ''
2732
2163
branch_token = token
2733
repo_token = self.repository.lock_write().repository_token
2164
repo_token = self.repository.lock_write()
2734
2165
self.repository.unlock()
2735
2166
err_context = {'token': token}
2737
response = self._call(
2738
'Branch.lock_write', self._remote_path(), branch_token,
2739
repo_token or '', **err_context)
2740
except errors.LockContention, e:
2741
# The LockContention from the server doesn't have any
2742
# information about the lock_url. We re-raise LockContention
2743
# with valid lock_url.
2744
raise errors.LockContention('(remote lock)',
2745
self.repository.base.split('.bzr/')[0])
2167
response = self._call(
2168
'Branch.lock_write', self._remote_path(), branch_token,
2169
repo_token or '', **err_context)
2746
2170
if response[0] != 'ok':
2747
2171
raise errors.UnexpectedSmartServerResponse(response)
2748
2172
ok, branch_token, repo_token = response
3153
2534
medium = self._branch._client._medium
3154
2535
if medium._is_remote_before((1, 14)):
3155
2536
return self._vfs_set_option(value, name, section)
3156
if isinstance(value, dict):
3157
if medium._is_remote_before((2, 2)):
3158
return self._vfs_set_option(value, name, section)
3159
return self._set_config_option_dict(value, name, section)
3161
return self._set_config_option(value, name, section)
3163
def _set_config_option(self, value, name, section):
3165
2538
path = self._branch._remote_path()
3166
2539
response = self._branch._client.call('Branch.set_config_option',
3167
2540
path, self._branch._lock_token, self._branch._repo_lock_token,
3168
2541
value.encode('utf8'), name, section or '')
3169
2542
except errors.UnknownSmartMethod:
3170
medium = self._branch._client._medium
3171
2543
medium._remember_remote_is_before((1, 14))
3172
2544
return self._vfs_set_option(value, name, section)
3173
2545
if response != ():
3174
2546
raise errors.UnexpectedSmartServerResponse(response)
3176
def _serialize_option_dict(self, option_dict):
3178
for key, value in option_dict.items():
3179
if isinstance(key, unicode):
3180
key = key.encode('utf8')
3181
if isinstance(value, unicode):
3182
value = value.encode('utf8')
3183
utf8_dict[key] = value
3184
return bencode.bencode(utf8_dict)
3186
def _set_config_option_dict(self, value, name, section):
3188
path = self._branch._remote_path()
3189
serialised_dict = self._serialize_option_dict(value)
3190
response = self._branch._client.call(
3191
'Branch.set_config_option_dict',
3192
path, self._branch._lock_token, self._branch._repo_lock_token,
3193
serialised_dict, name, section or '')
3194
except errors.UnknownSmartMethod:
3195
medium = self._branch._client._medium
3196
medium._remember_remote_is_before((2, 2))
3197
return self._vfs_set_option(value, name, section)
3199
raise errors.UnexpectedSmartServerResponse(response)
3201
2548
def _real_object(self):
3202
2549
self._branch._ensure_real()
3203
2550
return self._branch._real_branch