~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tests/test_smart_transport.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2007-04-13 15:37:58 UTC
  • mfrom: (2413.2.1 rename-SmartTransport)
  • Revision ID: pqm@pqm.ubuntu.com-20070413153758-6rwva0hs3h07wmpl
(Andrew Bennetts) Rename Smart.*Transport classes to RemoteTransport, RemoteTCPTransport, etc.

Show diffs side-by-side

added added

removed removed

Lines of Context:
534
534
 
535
535
    def test_probe_transport(self):
536
536
        t = self.get_transport()
537
 
        self.assertIsInstance(t, remote.SmartTransport)
 
537
        self.assertIsInstance(t, remote.RemoteTransport)
538
538
 
539
539
    def test_get_medium_from_transport(self):
540
540
        """Remote transport has a medium always, which it can return."""
793
793
        smart_server = server.SmartTCPServer(backing_transport=FlakyTransport())
794
794
        smart_server.start_background_thread()
795
795
        try:
796
 
            transport = remote.SmartTCPTransport(smart_server.get_url())
 
796
            transport = remote.RemoteTCPTransport(smart_server.get_url())
797
797
            try:
798
798
                transport.get('something')
799
799
            except errors.TransportError, e:
824
824
            self.backing_transport = get_transport("readonly+" + self.backing_transport.abspath('.'))
825
825
        self.server = server.SmartTCPServer(self.backing_transport)
826
826
        self.server.start_background_thread()
827
 
        self.transport = remote.SmartTCPTransport(self.server.get_url())
 
827
        self.transport = remote.RemoteTCPTransport(self.server.get_url())
828
828
        self.addCleanup(self.tearDownServer)
829
829
 
830
830
    def tearDownServer(self):
842
842
        """It should be safe to teardown the server with no requests."""
843
843
        self.setUpServer()
844
844
        server = self.server
845
 
        transport = remote.SmartTCPTransport(self.server.get_url())
 
845
        transport = remote.RemoteTCPTransport(self.server.get_url())
846
846
        self.tearDownServer()
847
847
        self.assertRaises(errors.ConnectionError, transport.has, '.')
848
848
 
854
854
        self.tearDownServer()
855
855
        # if the listening socket has closed, we should get a BADFD error
856
856
        # when connecting, rather than a hang.
857
 
        transport = remote.SmartTCPTransport(server.get_url())
 
857
        transport = remote.RemoteTCPTransport(server.get_url())
858
858
        self.assertRaises(errors.ConnectionError, transport.has, '.')
859
859
 
860
860
 
1111
1111
 
1112
1112
    def test_registration(self):
1113
1113
        t = get_transport('bzr+ssh://example.com/path')
1114
 
        self.assertIsInstance(t, remote.SmartSSHTransport)
 
1114
        self.assertIsInstance(t, remote.RemoteSSHTransport)
1115
1115
        self.assertEqual('example.com', t._host)
1116
1116
 
1117
1117
 
1122
1122
        input = StringIO("ok\n3\nbardone\n")
1123
1123
        output = StringIO()
1124
1124
        client_medium = medium.SmartSimplePipesClientMedium(input, output)
1125
 
        transport = remote.SmartTransport(
 
1125
        transport = remote.RemoteTransport(
1126
1126
            'bzr://localhost/', medium=client_medium)
1127
1127
 
1128
1128
        # We want to make sure the client is used when the first remote
1142
1142
    def test__translate_error_readonly(self):
1143
1143
        """Sending a ReadOnlyError to _translate_error raises TransportNotPossible."""
1144
1144
        client_medium = medium.SmartClientMedium()
1145
 
        transport = remote.SmartTransport(
 
1145
        transport = remote.RemoteTransport(
1146
1146
            'bzr://localhost/', medium=client_medium)
1147
1147
        self.assertRaises(errors.TransportNotPossible,
1148
1148
            transport._translate_error, ("ReadOnlyError", ))
1544
1544
        http_transport = self.get_readonly_transport()
1545
1545
        medium = http_transport.get_smart_medium()
1546
1546
        #remote_transport = RemoteTransport('fake_url', medium)
1547
 
        remote_transport = remote.SmartTransport('/', medium=medium)
 
1547
        remote_transport = remote.RemoteTransport('/', medium=medium)
1548
1548
        self.assertEqual(
1549
1549
            [(0, "c")], list(remote_transport.readv("data-file", [(0,1)])))
1550
1550