Rev 6149: Add some tests to make sure the timeout parameter gets propagated upwards correctly. in http://bazaar.launchpad.net/~jameinel/bzr/drop-idle-connections-824797

[John Arbash Meinel]

At http://bazaar.launchpad.net/~jameinel/bzr/drop-idle-connections-824797

------------------------------------------------------------
revno: 6149
revision-id: john at arbash-meinel.com-20110915095532-ayzf3aub59k9roh2
parent: john at arbash-meinel.com-20110915095023-wquhin2e0uh1nq1e
committer: John Arbash Meinel <john at arbash-meinel.com>
branch nick: drop-idle-connections-824797
timestamp: Thu 2011-09-15 11:55:32 +0200
message:
  Add some tests to make sure the timeout parameter gets propagated upwards correctly.
-------------- next part --------------
=== modified file 'bzrlib/tests/test_smart_transport.py'
--- a/bzrlib/tests/test_smart_transport.py	2011-09-15 09:50:23 +0000
+++ b/bzrlib/tests/test_smart_transport.py	2011-09-15 09:55:32 +0000
@@ -935,6 +935,28 @@
         server_protocol = self.build_protocol_socket('bzr request 2\n')
         self.assertProtocolTwo(server_protocol)
 
+    def test_socket_default_timeout(self):
+        server_sock, client_sock = self.portable_socket_pair()
+        server = medium.SmartServerSocketStreamMedium(server_sock, None)
+        self.assertEqual(server._DEFAULT_CLIENT_TIMEOUT,
+                         server._client_timeout)
+
+    def test_socket_set_timeout(self):
+        server_sock, client_sock = self.portable_socket_pair()
+        server = medium.SmartServerSocketStreamMedium(server_sock, None,
+            timeout=1.23)
+        self.assertEqual(1.23, server._client_timeout)
+
+    def test_pipe_default_timeout(self):
+        server = medium.SmartServerPipeStreamMedium(None, None, None)
+        self.assertEqual(server._DEFAULT_CLIENT_TIMEOUT,
+                         server._client_timeout)
+
+    def test_pipe_set_timeout(self):
+        server = medium.SmartServerPipeStreamMedium(None, None, None,
+            timeout=1.23)
+        self.assertEqual(1.23, server._client_timeout)
+
     def test_socket_wait_for_bytes_with_timeout_with_data(self):
         server_sock, client_sock = self.portable_socket_pair()
         self.addCleanup(server_sock.close)