1
# Copyright (C) 2006, 2007 Canonical Ltd
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.
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.
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
"""Tests for the smart wire/domain protocol.
19
This module contains tests for the domain-level smart requests and responses,
20
such as the 'Branch.lock_write' request. Many of these use specific disk
21
formats to exercise calls that only make sense for formats with specific
24
Tests for low-level protocol encoding are found in test_smart_transport.
28
from cStringIO import StringIO
39
from bzrlib.branch import Branch, BranchReferenceFormat
40
import bzrlib.smart.branch
41
import bzrlib.smart.bzrdir, bzrlib.smart.bzrdir as smart_dir
42
import bzrlib.smart.packrepository
43
import bzrlib.smart.repository
44
from bzrlib.smart.request import (
45
FailedSmartServerResponse,
48
SuccessfulSmartServerResponse,
50
from bzrlib.tests import (
53
from bzrlib.transport import chroot, get_transport
54
from bzrlib.util import bencode
57
def load_tests(standard_tests, module, loader):
58
"""Multiply tests version and protocol consistency."""
59
# FindRepository tests.
60
bzrdir_mod = bzrlib.smart.bzrdir
63
"_request_class":bzrdir_mod.SmartServerRequestFindRepositoryV1}),
64
("find_repositoryV2", {
65
"_request_class":bzrdir_mod.SmartServerRequestFindRepositoryV2}),
66
("find_repositoryV3", {
67
"_request_class":bzrdir_mod.SmartServerRequestFindRepositoryV3}),
69
to_adapt, result = split_suite_by_re(standard_tests,
70
"TestSmartServerRequestFindRepository")
71
v2_only, v1_and_2 = split_suite_by_re(to_adapt,
73
tests.multiply_tests(v1_and_2, scenarios, result)
74
# The first scenario is only applicable to v1 protocols, it is deleted
76
tests.multiply_tests(v2_only, scenarios[1:], result)
80
class TestCaseWithChrootedTransport(tests.TestCaseWithTransport):
83
tests.TestCaseWithTransport.setUp(self)
84
self._chroot_server = None
86
def get_transport(self, relpath=None):
87
if self._chroot_server is None:
88
backing_transport = tests.TestCaseWithTransport.get_transport(self)
89
self._chroot_server = chroot.ChrootServer(backing_transport)
90
self._chroot_server.setUp()
91
self.addCleanup(self._chroot_server.tearDown)
92
t = get_transport(self._chroot_server.get_url())
93
if relpath is not None:
98
class TestCaseWithSmartMedium(tests.TestCaseWithTransport):
101
super(TestCaseWithSmartMedium, self).setUp()
102
# We're allowed to set the transport class here, so that we don't use
103
# the default or a parameterized class, but rather use the
104
# TestCaseWithTransport infrastructure to set up a smart server and
106
self.transport_server = self.make_transport_server
108
def make_transport_server(self):
109
return smart.server.SmartTCPServer_for_testing('-' + self.id())
111
def get_smart_medium(self):
112
"""Get a smart medium to use in tests."""
113
return self.get_transport().get_smart_medium()
116
class TestSmartServerResponse(tests.TestCase):
118
def test__eq__(self):
119
self.assertEqual(SmartServerResponse(('ok', )),
120
SmartServerResponse(('ok', )))
121
self.assertEqual(SmartServerResponse(('ok', ), 'body'),
122
SmartServerResponse(('ok', ), 'body'))
123
self.assertNotEqual(SmartServerResponse(('ok', )),
124
SmartServerResponse(('notok', )))
125
self.assertNotEqual(SmartServerResponse(('ok', ), 'body'),
126
SmartServerResponse(('ok', )))
127
self.assertNotEqual(None,
128
SmartServerResponse(('ok', )))
130
def test__str__(self):
131
"""SmartServerResponses can be stringified."""
133
"<SuccessfulSmartServerResponse args=('args',) body='body'>",
134
str(SuccessfulSmartServerResponse(('args',), 'body')))
136
"<FailedSmartServerResponse args=('args',) body='body'>",
137
str(FailedSmartServerResponse(('args',), 'body')))
140
class TestSmartServerRequest(tests.TestCaseWithMemoryTransport):
142
def test_translate_client_path(self):
143
transport = self.get_transport()
144
request = SmartServerRequest(transport, 'foo/')
145
self.assertEqual('./', request.translate_client_path('foo/'))
147
errors.InvalidURLJoin, request.translate_client_path, 'foo/..')
149
errors.PathNotChild, request.translate_client_path, '/')
151
errors.PathNotChild, request.translate_client_path, 'bar/')
152
self.assertEqual('./baz', request.translate_client_path('foo/baz'))
154
def test_transport_from_client_path(self):
155
transport = self.get_transport()
156
request = SmartServerRequest(transport, 'foo/')
159
request.transport_from_client_path('foo/').base)
162
class TestSmartServerBzrDirRequestCloningMetaDir(
163
tests.TestCaseWithMemoryTransport):
164
"""Tests for BzrDir.cloning_metadir."""
166
def test_cloning_metadir(self):
167
"""When there is a bzrdir present, the call succeeds."""
168
backing = self.get_transport()
169
dir = self.make_bzrdir('.')
170
local_result = dir.cloning_metadir()
171
request_class = smart_dir.SmartServerBzrDirRequestCloningMetaDir
172
request = request_class(backing)
173
expected = SuccessfulSmartServerResponse(
174
(local_result.network_name(),
175
local_result.repository_format.network_name(),
176
('branch', local_result.get_branch_format().network_name())))
177
self.assertEqual(expected, request.execute('', 'False'))
179
def test_cloning_metadir_reference(self):
180
"""The request works when bzrdir contains a branch reference."""
181
backing = self.get_transport()
182
referenced_branch = self.make_branch('referenced')
183
dir = self.make_bzrdir('.')
184
local_result = dir.cloning_metadir()
185
reference = BranchReferenceFormat().initialize(dir, referenced_branch)
186
reference_url = BranchReferenceFormat().get_reference(dir)
187
# The server shouldn't try to follow the branch reference, so it's fine
188
# if the referenced branch isn't reachable.
189
backing.rename('referenced', 'moved')
190
request_class = smart_dir.SmartServerBzrDirRequestCloningMetaDir
191
request = request_class(backing)
192
expected = SuccessfulSmartServerResponse(
193
(local_result.network_name(),
194
local_result.repository_format.network_name(),
195
('ref', reference_url)))
196
self.assertEqual(expected, request.execute('', 'False'))
199
class TestSmartServerRequestCreateRepository(tests.TestCaseWithMemoryTransport):
200
"""Tests for BzrDir.create_repository."""
202
def test_makes_repository(self):
203
"""When there is a bzrdir present, the call succeeds."""
204
backing = self.get_transport()
205
self.make_bzrdir('.')
206
request_class = bzrlib.smart.bzrdir.SmartServerRequestCreateRepository
207
request = request_class(backing)
208
reference_bzrdir_format = bzrdir.format_registry.get('default')()
209
reference_format = reference_bzrdir_format.repository_format
210
network_name = reference_format.network_name()
211
expected = SuccessfulSmartServerResponse(
212
('ok', 'no', 'no', 'no', network_name))
213
self.assertEqual(expected, request.execute('', network_name, 'True'))
216
class TestSmartServerRequestFindRepository(tests.TestCaseWithMemoryTransport):
217
"""Tests for BzrDir.find_repository."""
219
def test_no_repository(self):
220
"""When there is no repository to be found, ('norepository', ) is returned."""
221
backing = self.get_transport()
222
request = self._request_class(backing)
223
self.make_bzrdir('.')
224
self.assertEqual(SmartServerResponse(('norepository', )),
227
def test_nonshared_repository(self):
228
# nonshared repositorys only allow 'find' to return a handle when the
229
# path the repository is being searched on is the same as that that
230
# the repository is at.
231
backing = self.get_transport()
232
request = self._request_class(backing)
233
result = self._make_repository_and_result()
234
self.assertEqual(result, request.execute(''))
235
self.make_bzrdir('subdir')
236
self.assertEqual(SmartServerResponse(('norepository', )),
237
request.execute('subdir'))
239
def _make_repository_and_result(self, shared=False, format=None):
240
"""Convenience function to setup a repository.
242
:result: The SmartServerResponse to expect when opening it.
244
repo = self.make_repository('.', shared=shared, format=format)
245
if repo.supports_rich_root():
249
if repo._format.supports_tree_reference:
253
if (smart.bzrdir.SmartServerRequestFindRepositoryV3 ==
254
self._request_class):
255
return SuccessfulSmartServerResponse(
256
('ok', '', rich_root, subtrees, 'no',
257
repo._format.network_name()))
258
elif (smart.bzrdir.SmartServerRequestFindRepositoryV2 ==
259
self._request_class):
260
# All tests so far are on formats, and for non-external
262
return SuccessfulSmartServerResponse(
263
('ok', '', rich_root, subtrees, 'no'))
265
return SuccessfulSmartServerResponse(('ok', '', rich_root, subtrees))
267
def test_shared_repository(self):
268
"""When there is a shared repository, we get 'ok', 'relpath-to-repo'."""
269
backing = self.get_transport()
270
request = self._request_class(backing)
271
result = self._make_repository_and_result(shared=True)
272
self.assertEqual(result, request.execute(''))
273
self.make_bzrdir('subdir')
274
result2 = SmartServerResponse(result.args[0:1] + ('..', ) + result.args[2:])
275
self.assertEqual(result2,
276
request.execute('subdir'))
277
self.make_bzrdir('subdir/deeper')
278
result3 = SmartServerResponse(result.args[0:1] + ('../..', ) + result.args[2:])
279
self.assertEqual(result3,
280
request.execute('subdir/deeper'))
282
def test_rich_root_and_subtree_encoding(self):
283
"""Test for the format attributes for rich root and subtree support."""
284
backing = self.get_transport()
285
request = self._request_class(backing)
286
result = self._make_repository_and_result(format='dirstate-with-subtree')
287
# check the test will be valid
288
self.assertEqual('yes', result.args[2])
289
self.assertEqual('yes', result.args[3])
290
self.assertEqual(result, request.execute(''))
292
def test_supports_external_lookups_no_v2(self):
293
"""Test for the supports_external_lookups attribute."""
294
backing = self.get_transport()
295
request = self._request_class(backing)
296
result = self._make_repository_and_result(format='dirstate-with-subtree')
297
# check the test will be valid
298
self.assertEqual('no', result.args[4])
299
self.assertEqual(result, request.execute(''))
302
class TestSmartServerRequestInitializeBzrDir(tests.TestCaseWithMemoryTransport):
304
def test_empty_dir(self):
305
"""Initializing an empty dir should succeed and do it."""
306
backing = self.get_transport()
307
request = smart.bzrdir.SmartServerRequestInitializeBzrDir(backing)
308
self.assertEqual(SmartServerResponse(('ok', )),
310
made_dir = bzrdir.BzrDir.open_from_transport(backing)
311
# no branch, tree or repository is expected with the current
313
self.assertRaises(errors.NoWorkingTree, made_dir.open_workingtree)
314
self.assertRaises(errors.NotBranchError, made_dir.open_branch)
315
self.assertRaises(errors.NoRepositoryPresent, made_dir.open_repository)
317
def test_missing_dir(self):
318
"""Initializing a missing directory should fail like the bzrdir api."""
319
backing = self.get_transport()
320
request = smart.bzrdir.SmartServerRequestInitializeBzrDir(backing)
321
self.assertRaises(errors.NoSuchFile,
322
request.execute, 'subdir')
324
def test_initialized_dir(self):
325
"""Initializing an extant bzrdir should fail like the bzrdir api."""
326
backing = self.get_transport()
327
request = smart.bzrdir.SmartServerRequestInitializeBzrDir(backing)
328
self.make_bzrdir('subdir')
329
self.assertRaises(errors.FileExists,
330
request.execute, 'subdir')
333
class TestSmartServerRequestOpenBranch(TestCaseWithChrootedTransport):
335
def test_no_branch(self):
336
"""When there is no branch, ('nobranch', ) is returned."""
337
backing = self.get_transport()
338
request = smart.bzrdir.SmartServerRequestOpenBranch(backing)
339
self.make_bzrdir('.')
340
self.assertEqual(SmartServerResponse(('nobranch', )),
343
def test_branch(self):
344
"""When there is a branch, 'ok' is returned."""
345
backing = self.get_transport()
346
request = smart.bzrdir.SmartServerRequestOpenBranch(backing)
347
self.make_branch('.')
348
self.assertEqual(SmartServerResponse(('ok', '')),
351
def test_branch_reference(self):
352
"""When there is a branch reference, the reference URL is returned."""
353
backing = self.get_transport()
354
request = smart.bzrdir.SmartServerRequestOpenBranch(backing)
355
branch = self.make_branch('branch')
356
checkout = branch.create_checkout('reference',lightweight=True)
357
reference_url = BranchReferenceFormat().get_reference(checkout.bzrdir)
358
self.assertFileEqual(reference_url, 'reference/.bzr/branch/location')
359
self.assertEqual(SmartServerResponse(('ok', reference_url)),
360
request.execute('reference'))
363
class TestSmartServerRequestOpenBranchV2(TestCaseWithChrootedTransport):
365
def test_no_branch(self):
366
"""When there is no branch, ('nobranch', ) is returned."""
367
backing = self.get_transport()
368
self.make_bzrdir('.')
369
request = smart.bzrdir.SmartServerRequestOpenBranchV2(backing)
370
self.assertEqual(SmartServerResponse(('nobranch', )),
373
def test_branch(self):
374
"""When there is a branch, 'ok' is returned."""
375
backing = self.get_transport()
376
expected = self.make_branch('.')._format.network_name()
377
request = smart.bzrdir.SmartServerRequestOpenBranchV2(backing)
378
self.assertEqual(SuccessfulSmartServerResponse(('branch', expected)),
381
def test_branch_reference(self):
382
"""When there is a branch reference, the reference URL is returned."""
383
backing = self.get_transport()
384
request = smart.bzrdir.SmartServerRequestOpenBranchV2(backing)
385
branch = self.make_branch('branch')
386
checkout = branch.create_checkout('reference',lightweight=True)
387
reference_url = BranchReferenceFormat().get_reference(checkout.bzrdir)
388
self.assertFileEqual(reference_url, 'reference/.bzr/branch/location')
389
self.assertEqual(SuccessfulSmartServerResponse(('ref', reference_url)),
390
request.execute('reference'))
393
class TestSmartServerRequestRevisionHistory(tests.TestCaseWithMemoryTransport):
395
def test_empty(self):
396
"""For an empty branch, the body is empty."""
397
backing = self.get_transport()
398
request = smart.branch.SmartServerRequestRevisionHistory(backing)
399
self.make_branch('.')
400
self.assertEqual(SmartServerResponse(('ok', ), ''),
403
def test_not_empty(self):
404
"""For a non-empty branch, the body is empty."""
405
backing = self.get_transport()
406
request = smart.branch.SmartServerRequestRevisionHistory(backing)
407
tree = self.make_branch_and_memory_tree('.')
410
r1 = tree.commit('1st commit')
411
r2 = tree.commit('2nd commit', rev_id=u'\xc8'.encode('utf-8'))
414
SmartServerResponse(('ok', ), ('\x00'.join([r1, r2]))),
418
class TestSmartServerBranchRequest(tests.TestCaseWithMemoryTransport):
420
def test_no_branch(self):
421
"""When there is a bzrdir and no branch, NotBranchError is raised."""
422
backing = self.get_transport()
423
request = smart.branch.SmartServerBranchRequest(backing)
424
self.make_bzrdir('.')
425
self.assertRaises(errors.NotBranchError,
428
def test_branch_reference(self):
429
"""When there is a branch reference, NotBranchError is raised."""
430
backing = self.get_transport()
431
request = smart.branch.SmartServerBranchRequest(backing)
432
branch = self.make_branch('branch')
433
checkout = branch.create_checkout('reference',lightweight=True)
434
self.assertRaises(errors.NotBranchError,
435
request.execute, 'checkout')
438
class TestSmartServerBranchRequestLastRevisionInfo(tests.TestCaseWithMemoryTransport):
440
def test_empty(self):
441
"""For an empty branch, the result is ('ok', '0', 'null:')."""
442
backing = self.get_transport()
443
request = smart.branch.SmartServerBranchRequestLastRevisionInfo(backing)
444
self.make_branch('.')
445
self.assertEqual(SmartServerResponse(('ok', '0', 'null:')),
448
def test_not_empty(self):
449
"""For a non-empty branch, the result is ('ok', 'revno', 'revid')."""
450
backing = self.get_transport()
451
request = smart.branch.SmartServerBranchRequestLastRevisionInfo(backing)
452
tree = self.make_branch_and_memory_tree('.')
455
rev_id_utf8 = u'\xc8'.encode('utf-8')
456
r1 = tree.commit('1st commit')
457
r2 = tree.commit('2nd commit', rev_id=rev_id_utf8)
460
SmartServerResponse(('ok', '2', rev_id_utf8)),
464
class TestSmartServerBranchRequestGetConfigFile(tests.TestCaseWithMemoryTransport):
466
def test_default(self):
467
"""With no file, we get empty content."""
468
backing = self.get_transport()
469
request = smart.branch.SmartServerBranchGetConfigFile(backing)
470
branch = self.make_branch('.')
471
# there should be no file by default
473
self.assertEqual(SmartServerResponse(('ok', ), content),
476
def test_with_content(self):
477
# SmartServerBranchGetConfigFile should return the content from
478
# branch.control_files.get('branch.conf') for now - in the future it may
479
# perform more complex processing.
480
backing = self.get_transport()
481
request = smart.branch.SmartServerBranchGetConfigFile(backing)
482
branch = self.make_branch('.')
483
branch._transport.put_bytes('branch.conf', 'foo bar baz')
484
self.assertEqual(SmartServerResponse(('ok', ), 'foo bar baz'),
488
class SetLastRevisionTestBase(tests.TestCaseWithMemoryTransport):
489
"""Base test case for verbs that implement set_last_revision."""
492
tests.TestCaseWithMemoryTransport.setUp(self)
493
backing_transport = self.get_transport()
494
self.request = self.request_class(backing_transport)
495
self.tree = self.make_branch_and_memory_tree('.')
497
def lock_branch(self):
499
branch_token = b.lock_write()
500
repo_token = b.repository.lock_write()
501
b.repository.unlock()
502
return branch_token, repo_token
504
def unlock_branch(self):
505
self.tree.branch.unlock()
507
def set_last_revision(self, revision_id, revno):
508
branch_token, repo_token = self.lock_branch()
509
response = self._set_last_revision(
510
revision_id, revno, branch_token, repo_token)
514
def assertRequestSucceeds(self, revision_id, revno):
515
response = self.set_last_revision(revision_id, revno)
516
self.assertEqual(SuccessfulSmartServerResponse(('ok',)), response)
519
class TestSetLastRevisionVerbMixin(object):
520
"""Mixin test case for verbs that implement set_last_revision."""
522
def test_set_null_to_null(self):
523
"""An empty branch can have its last revision set to 'null:'."""
524
self.assertRequestSucceeds('null:', 0)
526
def test_NoSuchRevision(self):
527
"""If the revision_id is not present, the verb returns NoSuchRevision.
529
revision_id = 'non-existent revision'
531
FailedSmartServerResponse(('NoSuchRevision', revision_id)),
532
self.set_last_revision(revision_id, 1))
534
def make_tree_with_two_commits(self):
535
self.tree.lock_write()
537
rev_id_utf8 = u'\xc8'.encode('utf-8')
538
r1 = self.tree.commit('1st commit', rev_id=rev_id_utf8)
539
r2 = self.tree.commit('2nd commit', rev_id='rev-2')
542
def test_branch_last_revision_info_is_updated(self):
543
"""A branch's tip can be set to a revision that is present in its
546
# Make a branch with an empty revision history, but two revisions in
548
self.make_tree_with_two_commits()
549
rev_id_utf8 = u'\xc8'.encode('utf-8')
550
self.tree.branch.set_revision_history([])
552
(0, 'null:'), self.tree.branch.last_revision_info())
553
# We can update the branch to a revision that is present in the
555
self.assertRequestSucceeds(rev_id_utf8, 1)
557
(1, rev_id_utf8), self.tree.branch.last_revision_info())
559
def test_branch_last_revision_info_rewind(self):
560
"""A branch's tip can be set to a revision that is an ancestor of the
563
self.make_tree_with_two_commits()
564
rev_id_utf8 = u'\xc8'.encode('utf-8')
566
(2, 'rev-2'), self.tree.branch.last_revision_info())
567
self.assertRequestSucceeds(rev_id_utf8, 1)
569
(1, rev_id_utf8), self.tree.branch.last_revision_info())
571
def test_TipChangeRejected(self):
572
"""If a pre_change_branch_tip hook raises TipChangeRejected, the verb
573
returns TipChangeRejected.
575
rejection_message = u'rejection message\N{INTERROBANG}'
576
def hook_that_rejects(params):
577
raise errors.TipChangeRejected(rejection_message)
578
Branch.hooks.install_named_hook(
579
'pre_change_branch_tip', hook_that_rejects, None)
581
FailedSmartServerResponse(
582
('TipChangeRejected', rejection_message.encode('utf-8'))),
583
self.set_last_revision('null:', 0))
586
class TestSmartServerBranchRequestSetLastRevision(
587
SetLastRevisionTestBase, TestSetLastRevisionVerbMixin):
588
"""Tests for Branch.set_last_revision verb."""
590
request_class = smart.branch.SmartServerBranchRequestSetLastRevision
592
def _set_last_revision(self, revision_id, revno, branch_token, repo_token):
593
return self.request.execute(
594
'', branch_token, repo_token, revision_id)
597
class TestSmartServerBranchRequestSetLastRevisionInfo(
598
SetLastRevisionTestBase, TestSetLastRevisionVerbMixin):
599
"""Tests for Branch.set_last_revision_info verb."""
601
request_class = smart.branch.SmartServerBranchRequestSetLastRevisionInfo
603
def _set_last_revision(self, revision_id, revno, branch_token, repo_token):
604
return self.request.execute(
605
'', branch_token, repo_token, revno, revision_id)
607
def test_NoSuchRevision(self):
608
"""Branch.set_last_revision_info does not have to return
609
NoSuchRevision if the revision_id is absent.
611
raise tests.TestNotApplicable()
614
class TestSmartServerBranchRequestSetLastRevisionEx(
615
SetLastRevisionTestBase, TestSetLastRevisionVerbMixin):
616
"""Tests for Branch.set_last_revision_ex verb."""
618
request_class = smart.branch.SmartServerBranchRequestSetLastRevisionEx
620
def _set_last_revision(self, revision_id, revno, branch_token, repo_token):
621
return self.request.execute(
622
'', branch_token, repo_token, revision_id, 0, 0)
624
def assertRequestSucceeds(self, revision_id, revno):
625
response = self.set_last_revision(revision_id, revno)
627
SuccessfulSmartServerResponse(('ok', revno, revision_id)),
630
def test_branch_last_revision_info_rewind(self):
631
"""A branch's tip can be set to a revision that is an ancestor of the
632
current tip, but only if allow_overwrite_descendant is passed.
634
self.make_tree_with_two_commits()
635
rev_id_utf8 = u'\xc8'.encode('utf-8')
637
(2, 'rev-2'), self.tree.branch.last_revision_info())
638
# If allow_overwrite_descendant flag is 0, then trying to set the tip
639
# to an older revision ID has no effect.
640
branch_token, repo_token = self.lock_branch()
641
response = self.request.execute(
642
'', branch_token, repo_token, rev_id_utf8, 0, 0)
644
SuccessfulSmartServerResponse(('ok', 2, 'rev-2')),
647
(2, 'rev-2'), self.tree.branch.last_revision_info())
649
# If allow_overwrite_descendant flag is 1, then setting the tip to an
651
response = self.request.execute(
652
'', branch_token, repo_token, rev_id_utf8, 0, 1)
654
SuccessfulSmartServerResponse(('ok', 1, rev_id_utf8)),
658
(1, rev_id_utf8), self.tree.branch.last_revision_info())
660
def make_branch_with_divergent_history(self):
661
"""Make a branch with divergent history in its repo.
663
The branch's tip will be 'child-2', and the repo will also contain
664
'child-1', which diverges from a common base revision.
666
self.tree.lock_write()
668
r1 = self.tree.commit('1st commit')
669
revno_1, revid_1 = self.tree.branch.last_revision_info()
670
r2 = self.tree.commit('2nd commit', rev_id='child-1')
671
# Undo the second commit
672
self.tree.branch.set_last_revision_info(revno_1, revid_1)
673
self.tree.set_parent_ids([revid_1])
674
# Make a new second commit, child-2. child-2 has diverged from
676
new_r2 = self.tree.commit('2nd commit', rev_id='child-2')
679
def test_not_allow_diverged(self):
680
"""If allow_diverged is not passed, then setting a divergent history
681
returns a Diverged error.
683
self.make_branch_with_divergent_history()
685
FailedSmartServerResponse(('Diverged',)),
686
self.set_last_revision('child-1', 2))
687
# The branch tip was not changed.
688
self.assertEqual('child-2', self.tree.branch.last_revision())
690
def test_allow_diverged(self):
691
"""If allow_diverged is passed, then setting a divergent history
694
self.make_branch_with_divergent_history()
695
branch_token, repo_token = self.lock_branch()
696
response = self.request.execute(
697
'', branch_token, repo_token, 'child-1', 1, 0)
699
SuccessfulSmartServerResponse(('ok', 2, 'child-1')),
702
# The branch tip was changed.
703
self.assertEqual('child-1', self.tree.branch.last_revision())
706
class TestSmartServerBranchRequestGetParent(tests.TestCaseWithMemoryTransport):
708
def test_get_parent_none(self):
709
base_branch = self.make_branch('base')
710
request = smart.branch.SmartServerBranchGetParent(self.get_transport())
711
response = request.execute('base')
713
SuccessfulSmartServerResponse(('',)), response)
715
def test_get_parent_something(self):
716
base_branch = self.make_branch('base')
717
base_branch.set_parent(self.get_url('foo'))
718
request = smart.branch.SmartServerBranchGetParent(self.get_transport())
719
response = request.execute('base')
721
SuccessfulSmartServerResponse(("../foo",)),
725
class TestSmartServerBranchRequestGetTagsBytes(tests.TestCaseWithMemoryTransport):
726
# Only called when the branch format and tags match [yay factory
727
# methods] so only need to test straight forward cases.
729
def test_get_bytes(self):
730
base_branch = self.make_branch('base')
731
request = smart.branch.SmartServerBranchGetTagsBytes(
732
self.get_transport())
733
response = request.execute('base')
735
SuccessfulSmartServerResponse(('',)), response)
738
class TestSmartServerBranchRequestGetStackedOnURL(tests.TestCaseWithMemoryTransport):
740
def test_get_stacked_on_url(self):
741
base_branch = self.make_branch('base', format='1.6')
742
stacked_branch = self.make_branch('stacked', format='1.6')
743
# typically should be relative
744
stacked_branch.set_stacked_on_url('../base')
745
request = smart.branch.SmartServerBranchRequestGetStackedOnURL(
746
self.get_transport())
747
response = request.execute('stacked')
749
SmartServerResponse(('ok', '../base')),
753
class TestSmartServerBranchRequestLockWrite(tests.TestCaseWithMemoryTransport):
756
tests.TestCaseWithMemoryTransport.setUp(self)
758
def test_lock_write_on_unlocked_branch(self):
759
backing = self.get_transport()
760
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
761
branch = self.make_branch('.', format='knit')
762
repository = branch.repository
763
response = request.execute('')
764
branch_nonce = branch.control_files._lock.peek().get('nonce')
765
repository_nonce = repository.control_files._lock.peek().get('nonce')
767
SmartServerResponse(('ok', branch_nonce, repository_nonce)),
769
# The branch (and associated repository) is now locked. Verify that
770
# with a new branch object.
771
new_branch = repository.bzrdir.open_branch()
772
self.assertRaises(errors.LockContention, new_branch.lock_write)
774
def test_lock_write_on_locked_branch(self):
775
backing = self.get_transport()
776
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
777
branch = self.make_branch('.')
779
branch.leave_lock_in_place()
781
response = request.execute('')
783
SmartServerResponse(('LockContention',)), response)
785
def test_lock_write_with_tokens_on_locked_branch(self):
786
backing = self.get_transport()
787
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
788
branch = self.make_branch('.', format='knit')
789
branch_token = branch.lock_write()
790
repo_token = branch.repository.lock_write()
791
branch.repository.unlock()
792
branch.leave_lock_in_place()
793
branch.repository.leave_lock_in_place()
795
response = request.execute('',
796
branch_token, repo_token)
798
SmartServerResponse(('ok', branch_token, repo_token)), response)
800
def test_lock_write_with_mismatched_tokens_on_locked_branch(self):
801
backing = self.get_transport()
802
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
803
branch = self.make_branch('.', format='knit')
804
branch_token = branch.lock_write()
805
repo_token = branch.repository.lock_write()
806
branch.repository.unlock()
807
branch.leave_lock_in_place()
808
branch.repository.leave_lock_in_place()
810
response = request.execute('',
811
branch_token+'xxx', repo_token)
813
SmartServerResponse(('TokenMismatch',)), response)
815
def test_lock_write_on_locked_repo(self):
816
backing = self.get_transport()
817
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
818
branch = self.make_branch('.', format='knit')
819
branch.repository.lock_write()
820
branch.repository.leave_lock_in_place()
821
branch.repository.unlock()
822
response = request.execute('')
824
SmartServerResponse(('LockContention',)), response)
826
def test_lock_write_on_readonly_transport(self):
827
backing = self.get_readonly_transport()
828
request = smart.branch.SmartServerBranchRequestLockWrite(backing)
829
branch = self.make_branch('.')
830
root = self.get_transport().clone('/')
831
path = urlutils.relative_url(root.base, self.get_transport().base)
832
response = request.execute(path)
833
error_name, lock_str, why_str = response.args
834
self.assertFalse(response.is_successful())
835
self.assertEqual('LockFailed', error_name)
838
class TestSmartServerBranchRequestUnlock(tests.TestCaseWithMemoryTransport):
841
tests.TestCaseWithMemoryTransport.setUp(self)
843
def test_unlock_on_locked_branch_and_repo(self):
844
backing = self.get_transport()
845
request = smart.branch.SmartServerBranchRequestUnlock(backing)
846
branch = self.make_branch('.', format='knit')
848
branch_token = branch.lock_write()
849
repo_token = branch.repository.lock_write()
850
branch.repository.unlock()
851
# Unlock the branch (and repo) object, leaving the physical locks
853
branch.leave_lock_in_place()
854
branch.repository.leave_lock_in_place()
856
response = request.execute('',
857
branch_token, repo_token)
859
SmartServerResponse(('ok',)), response)
860
# The branch is now unlocked. Verify that with a new branch
862
new_branch = branch.bzrdir.open_branch()
863
new_branch.lock_write()
866
def test_unlock_on_unlocked_branch_unlocked_repo(self):
867
backing = self.get_transport()
868
request = smart.branch.SmartServerBranchRequestUnlock(backing)
869
branch = self.make_branch('.', format='knit')
870
response = request.execute(
871
'', 'branch token', 'repo token')
873
SmartServerResponse(('TokenMismatch',)), response)
875
def test_unlock_on_unlocked_branch_locked_repo(self):
876
backing = self.get_transport()
877
request = smart.branch.SmartServerBranchRequestUnlock(backing)
878
branch = self.make_branch('.', format='knit')
879
# Lock the repository.
880
repo_token = branch.repository.lock_write()
881
branch.repository.leave_lock_in_place()
882
branch.repository.unlock()
883
# Issue branch lock_write request on the unlocked branch (with locked
885
response = request.execute(
886
'', 'branch token', repo_token)
888
SmartServerResponse(('TokenMismatch',)), response)
891
class TestSmartServerRepositoryRequest(tests.TestCaseWithMemoryTransport):
893
def test_no_repository(self):
894
"""Raise NoRepositoryPresent when there is a bzrdir and no repo."""
895
# we test this using a shared repository above the named path,
896
# thus checking the right search logic is used - that is, that
897
# its the exact path being looked at and the server is not
899
backing = self.get_transport()
900
request = smart.repository.SmartServerRepositoryRequest(backing)
901
self.make_repository('.', shared=True)
902
self.make_bzrdir('subdir')
903
self.assertRaises(errors.NoRepositoryPresent,
904
request.execute, 'subdir')
907
class TestSmartServerRepositoryGetParentMap(tests.TestCaseWithMemoryTransport):
909
def test_trivial_bzipped(self):
910
# This tests that the wire encoding is actually bzipped
911
backing = self.get_transport()
912
request = smart.repository.SmartServerRepositoryGetParentMap(backing)
913
tree = self.make_branch_and_memory_tree('.')
915
self.assertEqual(None,
916
request.execute('', 'missing-id'))
917
# Note that it returns a body (of '' bzipped).
919
SuccessfulSmartServerResponse(('ok', ), bz2.compress('')),
920
request.do_body('\n\n0\n'))
923
class TestSmartServerRepositoryGetRevisionGraph(tests.TestCaseWithMemoryTransport):
925
def test_none_argument(self):
926
backing = self.get_transport()
927
request = smart.repository.SmartServerRepositoryGetRevisionGraph(backing)
928
tree = self.make_branch_and_memory_tree('.')
931
r1 = tree.commit('1st commit')
932
r2 = tree.commit('2nd commit', rev_id=u'\xc8'.encode('utf-8'))
935
# the lines of revision_id->revision_parent_list has no guaranteed
936
# order coming out of a dict, so sort both our test and response
937
lines = sorted([' '.join([r2, r1]), r1])
938
response = request.execute('', '')
939
response.body = '\n'.join(sorted(response.body.split('\n')))
942
SmartServerResponse(('ok', ), '\n'.join(lines)), response)
944
def test_specific_revision_argument(self):
945
backing = self.get_transport()
946
request = smart.repository.SmartServerRepositoryGetRevisionGraph(backing)
947
tree = self.make_branch_and_memory_tree('.')
950
rev_id_utf8 = u'\xc9'.encode('utf-8')
951
r1 = tree.commit('1st commit', rev_id=rev_id_utf8)
952
r2 = tree.commit('2nd commit', rev_id=u'\xc8'.encode('utf-8'))
955
self.assertEqual(SmartServerResponse(('ok', ), rev_id_utf8),
956
request.execute('', rev_id_utf8))
958
def test_no_such_revision(self):
959
backing = self.get_transport()
960
request = smart.repository.SmartServerRepositoryGetRevisionGraph(backing)
961
tree = self.make_branch_and_memory_tree('.')
964
r1 = tree.commit('1st commit')
967
# Note that it still returns body (of zero bytes).
969
SmartServerResponse(('nosuchrevision', 'missingrevision', ), ''),
970
request.execute('', 'missingrevision'))
973
class TestSmartServerRepositoryGetStream(tests.TestCaseWithMemoryTransport):
975
def make_two_commit_repo(self):
976
tree = self.make_branch_and_memory_tree('.')
979
r1 = tree.commit('1st commit')
980
r2 = tree.commit('2nd commit', rev_id=u'\xc8'.encode('utf-8'))
982
repo = tree.branch.repository
985
def test_ancestry_of(self):
986
"""The search argument may be a 'ancestry-of' some heads'."""
987
backing = self.get_transport()
988
request = smart.repository.SmartServerRepositoryGetStream(backing)
989
repo, r1, r2 = self.make_two_commit_repo()
990
fetch_spec = ['ancestry-of', r2]
991
lines = '\n'.join(fetch_spec)
992
request.execute('', repo._format.network_name())
993
response = request.do_body(lines)
994
self.assertEqual(('ok',), response.args)
995
stream_bytes = ''.join(response.body_stream)
996
self.assertStartsWith(stream_bytes, 'Bazaar pack format 1')
998
def test_search(self):
999
"""The search argument may be a 'search' of some explicit keys."""
1000
backing = self.get_transport()
1001
request = smart.repository.SmartServerRepositoryGetStream(backing)
1002
repo, r1, r2 = self.make_two_commit_repo()
1003
fetch_spec = ['search', '%s %s' % (r1, r2), 'null:', '2']
1004
lines = '\n'.join(fetch_spec)
1005
request.execute('', repo._format.network_name())
1006
response = request.do_body(lines)
1007
self.assertEqual(('ok',), response.args)
1008
stream_bytes = ''.join(response.body_stream)
1009
self.assertStartsWith(stream_bytes, 'Bazaar pack format 1')
1012
class TestSmartServerRequestHasRevision(tests.TestCaseWithMemoryTransport):
1014
def test_missing_revision(self):
1015
"""For a missing revision, ('no', ) is returned."""
1016
backing = self.get_transport()
1017
request = smart.repository.SmartServerRequestHasRevision(backing)
1018
self.make_repository('.')
1019
self.assertEqual(SmartServerResponse(('no', )),
1020
request.execute('', 'revid'))
1022
def test_present_revision(self):
1023
"""For a present revision, ('yes', ) is returned."""
1024
backing = self.get_transport()
1025
request = smart.repository.SmartServerRequestHasRevision(backing)
1026
tree = self.make_branch_and_memory_tree('.')
1029
rev_id_utf8 = u'\xc8abc'.encode('utf-8')
1030
r1 = tree.commit('a commit', rev_id=rev_id_utf8)
1032
self.assertTrue(tree.branch.repository.has_revision(rev_id_utf8))
1033
self.assertEqual(SmartServerResponse(('yes', )),
1034
request.execute('', rev_id_utf8))
1037
class TestSmartServerRepositoryGatherStats(tests.TestCaseWithMemoryTransport):
1039
def test_empty_revid(self):
1040
"""With an empty revid, we get only size an number and revisions"""
1041
backing = self.get_transport()
1042
request = smart.repository.SmartServerRepositoryGatherStats(backing)
1043
repository = self.make_repository('.')
1044
stats = repository.gather_stats()
1045
expected_body = 'revisions: 0\n'
1046
self.assertEqual(SmartServerResponse(('ok', ), expected_body),
1047
request.execute('', '', 'no'))
1049
def test_revid_with_committers(self):
1050
"""For a revid we get more infos."""
1051
backing = self.get_transport()
1052
rev_id_utf8 = u'\xc8abc'.encode('utf-8')
1053
request = smart.repository.SmartServerRepositoryGatherStats(backing)
1054
tree = self.make_branch_and_memory_tree('.')
1057
# Let's build a predictable result
1058
tree.commit('a commit', timestamp=123456.2, timezone=3600)
1059
tree.commit('a commit', timestamp=654321.4, timezone=0,
1063
stats = tree.branch.repository.gather_stats()
1064
expected_body = ('firstrev: 123456.200 3600\n'
1065
'latestrev: 654321.400 0\n'
1067
self.assertEqual(SmartServerResponse(('ok', ), expected_body),
1071
def test_not_empty_repository_with_committers(self):
1072
"""For a revid and requesting committers we get the whole thing."""
1073
backing = self.get_transport()
1074
rev_id_utf8 = u'\xc8abc'.encode('utf-8')
1075
request = smart.repository.SmartServerRepositoryGatherStats(backing)
1076
tree = self.make_branch_and_memory_tree('.')
1079
# Let's build a predictable result
1080
tree.commit('a commit', timestamp=123456.2, timezone=3600,
1082
tree.commit('a commit', timestamp=654321.4, timezone=0,
1083
committer='bar', rev_id=rev_id_utf8)
1085
stats = tree.branch.repository.gather_stats()
1087
expected_body = ('committers: 2\n'
1088
'firstrev: 123456.200 3600\n'
1089
'latestrev: 654321.400 0\n'
1091
self.assertEqual(SmartServerResponse(('ok', ), expected_body),
1093
rev_id_utf8, 'yes'))
1096
class TestSmartServerRepositoryIsShared(tests.TestCaseWithMemoryTransport):
1098
def test_is_shared(self):
1099
"""For a shared repository, ('yes', ) is returned."""
1100
backing = self.get_transport()
1101
request = smart.repository.SmartServerRepositoryIsShared(backing)
1102
self.make_repository('.', shared=True)
1103
self.assertEqual(SmartServerResponse(('yes', )),
1104
request.execute('', ))
1106
def test_is_not_shared(self):
1107
"""For a shared repository, ('no', ) is returned."""
1108
backing = self.get_transport()
1109
request = smart.repository.SmartServerRepositoryIsShared(backing)
1110
self.make_repository('.', shared=False)
1111
self.assertEqual(SmartServerResponse(('no', )),
1112
request.execute('', ))
1115
class TestSmartServerRepositoryLockWrite(tests.TestCaseWithMemoryTransport):
1117
def test_lock_write_on_unlocked_repo(self):
1118
backing = self.get_transport()
1119
request = smart.repository.SmartServerRepositoryLockWrite(backing)
1120
repository = self.make_repository('.', format='knit')
1121
response = request.execute('')
1122
nonce = repository.control_files._lock.peek().get('nonce')
1123
self.assertEqual(SmartServerResponse(('ok', nonce)), response)
1124
# The repository is now locked. Verify that with a new repository
1126
new_repo = repository.bzrdir.open_repository()
1127
self.assertRaises(errors.LockContention, new_repo.lock_write)
1129
def test_lock_write_on_locked_repo(self):
1130
backing = self.get_transport()
1131
request = smart.repository.SmartServerRepositoryLockWrite(backing)
1132
repository = self.make_repository('.', format='knit')
1133
repository.lock_write()
1134
repository.leave_lock_in_place()
1136
response = request.execute('')
1138
SmartServerResponse(('LockContention',)), response)
1140
def test_lock_write_on_readonly_transport(self):
1141
backing = self.get_readonly_transport()
1142
request = smart.repository.SmartServerRepositoryLockWrite(backing)
1143
repository = self.make_repository('.', format='knit')
1144
response = request.execute('')
1145
self.assertFalse(response.is_successful())
1146
self.assertEqual('LockFailed', response.args[0])
1149
class TestInsertStreamBase(tests.TestCaseWithMemoryTransport):
1151
def make_empty_byte_stream(self, repo):
1152
byte_stream = smart.repository._stream_to_byte_stream([], repo._format)
1153
return ''.join(byte_stream)
1156
class TestSmartServerRepositoryInsertStream(TestInsertStreamBase):
1158
def test_insert_stream_empty(self):
1159
backing = self.get_transport()
1160
request = smart.repository.SmartServerRepositoryInsertStream(backing)
1161
repository = self.make_repository('.')
1162
response = request.execute('', '')
1163
self.assertEqual(None, response)
1164
response = request.do_chunk(self.make_empty_byte_stream(repository))
1165
self.assertEqual(None, response)
1166
response = request.do_end()
1167
self.assertEqual(SmartServerResponse(('ok', )), response)
1170
class TestSmartServerRepositoryInsertStreamLocked(TestInsertStreamBase):
1172
def test_insert_stream_empty(self):
1173
backing = self.get_transport()
1174
request = smart.repository.SmartServerRepositoryInsertStreamLocked(
1176
repository = self.make_repository('.', format='knit')
1177
lock_token = repository.lock_write()
1178
response = request.execute('', '', lock_token)
1179
self.assertEqual(None, response)
1180
response = request.do_chunk(self.make_empty_byte_stream(repository))
1181
self.assertEqual(None, response)
1182
response = request.do_end()
1183
self.assertEqual(SmartServerResponse(('ok', )), response)
1186
def test_insert_stream_with_wrong_lock_token(self):
1187
backing = self.get_transport()
1188
request = smart.repository.SmartServerRepositoryInsertStreamLocked(
1190
repository = self.make_repository('.', format='knit')
1191
lock_token = repository.lock_write()
1193
errors.TokenMismatch, request.execute, '', '', 'wrong-token')
1197
class TestSmartServerRepositoryUnlock(tests.TestCaseWithMemoryTransport):
1200
tests.TestCaseWithMemoryTransport.setUp(self)
1202
def test_unlock_on_locked_repo(self):
1203
backing = self.get_transport()
1204
request = smart.repository.SmartServerRepositoryUnlock(backing)
1205
repository = self.make_repository('.', format='knit')
1206
token = repository.lock_write()
1207
repository.leave_lock_in_place()
1209
response = request.execute('', token)
1211
SmartServerResponse(('ok',)), response)
1212
# The repository is now unlocked. Verify that with a new repository
1214
new_repo = repository.bzrdir.open_repository()
1215
new_repo.lock_write()
1218
def test_unlock_on_unlocked_repo(self):
1219
backing = self.get_transport()
1220
request = smart.repository.SmartServerRepositoryUnlock(backing)
1221
repository = self.make_repository('.', format='knit')
1222
response = request.execute('', 'some token')
1224
SmartServerResponse(('TokenMismatch',)), response)
1227
class TestSmartServerIsReadonly(tests.TestCaseWithMemoryTransport):
1229
def test_is_readonly_no(self):
1230
backing = self.get_transport()
1231
request = smart.request.SmartServerIsReadonly(backing)
1232
response = request.execute()
1234
SmartServerResponse(('no',)), response)
1236
def test_is_readonly_yes(self):
1237
backing = self.get_readonly_transport()
1238
request = smart.request.SmartServerIsReadonly(backing)
1239
response = request.execute()
1241
SmartServerResponse(('yes',)), response)
1244
class TestSmartServerRepositorySetMakeWorkingTrees(tests.TestCaseWithMemoryTransport):
1246
def test_set_false(self):
1247
backing = self.get_transport()
1248
repo = self.make_repository('.', shared=True)
1249
repo.set_make_working_trees(True)
1250
request_class = smart.repository.SmartServerRepositorySetMakeWorkingTrees
1251
request = request_class(backing)
1252
self.assertEqual(SuccessfulSmartServerResponse(('ok',)),
1253
request.execute('', 'False'))
1254
repo = repo.bzrdir.open_repository()
1255
self.assertFalse(repo.make_working_trees())
1257
def test_set_true(self):
1258
backing = self.get_transport()
1259
repo = self.make_repository('.', shared=True)
1260
repo.set_make_working_trees(False)
1261
request_class = smart.repository.SmartServerRepositorySetMakeWorkingTrees
1262
request = request_class(backing)
1263
self.assertEqual(SuccessfulSmartServerResponse(('ok',)),
1264
request.execute('', 'True'))
1265
repo = repo.bzrdir.open_repository()
1266
self.assertTrue(repo.make_working_trees())
1269
class TestSmartServerPackRepositoryAutopack(tests.TestCaseWithTransport):
1271
def make_repo_needing_autopacking(self, path='.'):
1272
# Make a repo in need of autopacking.
1273
tree = self.make_branch_and_tree('.', format='pack-0.92')
1274
repo = tree.branch.repository
1275
# monkey-patch the pack collection to disable autopacking
1276
repo._pack_collection._max_pack_count = lambda count: count
1278
tree.commit('commit %s' % x)
1279
self.assertEqual(10, len(repo._pack_collection.names()))
1280
del repo._pack_collection._max_pack_count
1283
def test_autopack_needed(self):
1284
repo = self.make_repo_needing_autopacking()
1285
backing = self.get_transport()
1286
request = smart.packrepository.SmartServerPackRepositoryAutopack(
1288
response = request.execute('')
1289
self.assertEqual(SmartServerResponse(('ok',)), response)
1290
repo._pack_collection.reload_pack_names()
1291
self.assertEqual(1, len(repo._pack_collection.names()))
1293
def test_autopack_not_needed(self):
1294
tree = self.make_branch_and_tree('.', format='pack-0.92')
1295
repo = tree.branch.repository
1297
tree.commit('commit %s' % x)
1298
backing = self.get_transport()
1299
request = smart.packrepository.SmartServerPackRepositoryAutopack(
1301
response = request.execute('')
1302
self.assertEqual(SmartServerResponse(('ok',)), response)
1303
repo._pack_collection.reload_pack_names()
1304
self.assertEqual(9, len(repo._pack_collection.names()))
1306
def test_autopack_on_nonpack_format(self):
1307
"""A request to autopack a non-pack repo is a no-op."""
1308
repo = self.make_repository('.', format='knit')
1309
backing = self.get_transport()
1310
request = smart.packrepository.SmartServerPackRepositoryAutopack(
1312
response = request.execute('')
1313
self.assertEqual(SmartServerResponse(('ok',)), response)
1316
class TestHandlers(tests.TestCase):
1317
"""Tests for the request.request_handlers object."""
1319
def test_all_registrations_exist(self):
1320
"""All registered request_handlers can be found."""
1321
# If there's a typo in a register_lazy call, this loop will fail with
1322
# an AttributeError.
1323
for key, item in smart.request.request_handlers.iteritems():
1326
def test_registered_methods(self):
1327
"""Test that known methods are registered to the correct object."""
1329
smart.request.request_handlers.get('Branch.get_config_file'),
1330
smart.branch.SmartServerBranchGetConfigFile)
1332
smart.request.request_handlers.get('Branch.get_parent'),
1333
smart.branch.SmartServerBranchGetParent)
1335
smart.request.request_handlers.get('Branch.get_tags_bytes'),
1336
smart.branch.SmartServerBranchGetTagsBytes)
1338
smart.request.request_handlers.get('Branch.lock_write'),
1339
smart.branch.SmartServerBranchRequestLockWrite)
1341
smart.request.request_handlers.get('Branch.last_revision_info'),
1342
smart.branch.SmartServerBranchRequestLastRevisionInfo)
1344
smart.request.request_handlers.get('Branch.revision_history'),
1345
smart.branch.SmartServerRequestRevisionHistory)
1347
smart.request.request_handlers.get('Branch.set_last_revision'),
1348
smart.branch.SmartServerBranchRequestSetLastRevision)
1350
smart.request.request_handlers.get('Branch.set_last_revision_info'),
1351
smart.branch.SmartServerBranchRequestSetLastRevisionInfo)
1353
smart.request.request_handlers.get('Branch.unlock'),
1354
smart.branch.SmartServerBranchRequestUnlock)
1356
smart.request.request_handlers.get('BzrDir.find_repository'),
1357
smart.bzrdir.SmartServerRequestFindRepositoryV1)
1359
smart.request.request_handlers.get('BzrDir.find_repositoryV2'),
1360
smart.bzrdir.SmartServerRequestFindRepositoryV2)
1362
smart.request.request_handlers.get('BzrDirFormat.initialize'),
1363
smart.bzrdir.SmartServerRequestInitializeBzrDir)
1365
smart.request.request_handlers.get('BzrDir.cloning_metadir'),
1366
smart.bzrdir.SmartServerBzrDirRequestCloningMetaDir)
1368
smart.request.request_handlers.get('BzrDir.open_branch'),
1369
smart.bzrdir.SmartServerRequestOpenBranch)
1371
smart.request.request_handlers.get('BzrDir.open_branchV2'),
1372
smart.bzrdir.SmartServerRequestOpenBranchV2)
1374
smart.request.request_handlers.get('PackRepository.autopack'),
1375
smart.packrepository.SmartServerPackRepositoryAutopack)
1377
smart.request.request_handlers.get('Repository.gather_stats'),
1378
smart.repository.SmartServerRepositoryGatherStats)
1380
smart.request.request_handlers.get('Repository.get_parent_map'),
1381
smart.repository.SmartServerRepositoryGetParentMap)
1383
smart.request.request_handlers.get(
1384
'Repository.get_revision_graph'),
1385
smart.repository.SmartServerRepositoryGetRevisionGraph)
1387
smart.request.request_handlers.get('Repository.get_stream'),
1388
smart.repository.SmartServerRepositoryGetStream)
1390
smart.request.request_handlers.get('Repository.has_revision'),
1391
smart.repository.SmartServerRequestHasRevision)
1393
smart.request.request_handlers.get('Repository.insert_stream'),
1394
smart.repository.SmartServerRepositoryInsertStream)
1396
smart.request.request_handlers.get('Repository.insert_stream_locked'),
1397
smart.repository.SmartServerRepositoryInsertStreamLocked)
1399
smart.request.request_handlers.get('Repository.is_shared'),
1400
smart.repository.SmartServerRepositoryIsShared)
1402
smart.request.request_handlers.get('Repository.lock_write'),
1403
smart.repository.SmartServerRepositoryLockWrite)
1405
smart.request.request_handlers.get('Repository.tarball'),
1406
smart.repository.SmartServerRepositoryTarball)
1408
smart.request.request_handlers.get('Repository.unlock'),
1409
smart.repository.SmartServerRepositoryUnlock)
1411
smart.request.request_handlers.get('Transport.is_readonly'),
1412
smart.request.SmartServerIsReadonly)
added
removed
bzrlib/tests/test_smart.py
