/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/tests/per_pack_repository.py

  • Committer: Vincent Ladeuil
  • Date: 2010-02-09 21:45:58 UTC
  • mto: (5029.1.1 integration)
  • mto: This revision was merged to the branch mainline in revision 5030.
  • Revision ID: v.ladeuil+lp@free.fr-20100209214558-6xv1a8uq712y1uwc
-s bt.per_pack_repos passing

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/tests/per_pack_repository.py
45
45
from bzrlib.repofmt.groupcompress_repo import RepositoryFormat2a
46
46
from bzrlib.smart import (
47
47
    client,
48
 
    server,
49
48
    )
50
49
from bzrlib.tests import (
51
50
    TestCase,
54
53
    TestSkipped,
55
54
    )
56
55
from bzrlib.transport import (
57
 
    fakenfs,
58
 
    memory,
59
56
    get_transport,
60
57
    )
 
58
from bzrlib.tests import test_server
61
59
from bzrlib.tests.per_repository import TestCaseWithRepository
62
60
 
63
61
 
240
238
 
241
239
    def test_commit_write_group_returns_new_pack_names(self):
242
240
        # This test doesn't need real disk.
243
 
        self.vfs_transport_factory = tests.MemoryServer
 
241
        self.vfs_transport_factory = test_server.MemoryServer
244
242
        format = self.get_format()
245
243
        repo = self.make_repository('foo', format=format)
246
244
        repo.lock_write()
277
275
    def test_fail_obsolete_deletion(self):
278
276
        # failing to delete obsolete packs is not fatal
279
277
        format = self.get_format()
280
 
        server = fakenfs.FakeNFSServer()
 
278
        server = test_server.FakeNFSServer()
281
279
        self.start_server(server)
282
280
        transport = get_transport(server.get_url())
283
281
        bzrdir = self.get_format().initialize_on_transport(transport)
709
707
 
710
708
        Also requires that the exception is logged.
711
709
        """
712
 
        self.vfs_transport_factory = memory.MemoryServer
 
710
        self.vfs_transport_factory = test_server.MemoryServer
713
711
        repo = self.make_repository('repo', format=self.get_format())
714
712
        token = repo.lock_write()
715
713
        self.addCleanup(repo.unlock)
726
724
            repo.leave_lock_in_place()
727
725
 
728
726
    def test_abort_write_group_does_raise_when_not_suppressed(self):
729
 
        self.vfs_transport_factory = memory.MemoryServer
 
727
        self.vfs_transport_factory = test_server.MemoryServer
730
728
        repo = self.make_repository('repo', format=self.get_format())
731
729
        token = repo.lock_write()
732
730
        self.addCleanup(repo.unlock)
739
737
            repo.leave_lock_in_place()
740
738
 
741
739
    def test_suspend_write_group(self):
742
 
        self.vfs_transport_factory = memory.MemoryServer
 
740
        self.vfs_transport_factory = test_server.MemoryServer
743
741
        repo = self.make_repository('repo', format=self.get_format())
744
742
        token = repo.lock_write()
745
743
        self.addCleanup(repo.unlock)
759
757
        self.assertEqual(wg_tokens[0], md5.hexdigest())
760
758
 
761
759
    def test_resume_chk_bytes(self):
762
 
        self.vfs_transport_factory = memory.MemoryServer
 
760
        self.vfs_transport_factory = test_server.MemoryServer
763
761
        repo = self.make_repository('repo', format=self.get_format())
764
762
        if repo.chk_bytes is None:
765
763
            raise TestNotApplicable('no chk_bytes for this repository')
783
781
 
784
782
    def test_resume_write_group_then_abort(self):
785
783
        # Create a repo, start a write group, insert some data, suspend.
786
 
        self.vfs_transport_factory = memory.MemoryServer
 
784
        self.vfs_transport_factory = test_server.MemoryServer
787
785
        repo = self.make_repository('repo', format=self.get_format())
788
786
        token = repo.lock_write()
789
787
        self.addCleanup(repo.unlock)
804
802
            [], same_repo._pack_collection._pack_transport.list_dir(''))
805
803
 
806
804
    def test_commit_resumed_write_group(self):
807
 
        self.vfs_transport_factory = memory.MemoryServer
 
805
        self.vfs_transport_factory = test_server.MemoryServer
808
806
        repo = self.make_repository('repo', format=self.get_format())
809
807
        token = repo.lock_write()
810
808
        self.addCleanup(repo.unlock)
832
830
        self.assertEqual([expected_pack_name], pack_names)
833
831
 
834
832
    def test_resume_malformed_token(self):
835
 
        self.vfs_transport_factory = memory.MemoryServer
 
833
        self.vfs_transport_factory = test_server.MemoryServer
836
834
        # Make a repository with a suspended write group
837
835
        repo = self.make_repository('repo', format=self.get_format())
838
836
        token = repo.lock_write()
1068
1066
        super(TestSmartServerAutopack, self).setUp()
1069
1067
        # Create a smart server that publishes whatever the backing VFS server
1070
1068
        # does.
1071
 
        self.smart_server = server.SmartTCPServer_for_testing()
 
1069
        self.smart_server = test_server.SmartTCPServer_for_testing()
1072
1070
        self.start_server(self.smart_server, self.get_server())
1073
1071
        # Log all HPSS calls into self.hpss_calls.
1074
1072
        client._SmartClient.hooks.install_named_hook(