Implement testAsync for python tests

git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@665485 13f79535-47bb-0310-9956-ffa450edef68

diff --git a/test/py/TestClient.py b/test/py/TestClient.py
index ab2cba8..d7b65b7 100755 (executable)
--- a/test/py/TestClient.py
+++ b/test/py/TestClient.py
@@ -86,6 +86,13 @@ class AbstractTest(unittest.TestCase):
       self.assertEqual(x.errorCode, 1001)
       self.assertEqual(x.message, 'Xception')
 
+  def testAsync(self):
+    start = time.time()
+    self.client.testAsync(2)
+    end = time.time()
+    self.assertTrue(end - start < 0.2,
+                    "async sleep took %f sec" % (end - start))
+
 class NormalBinaryTest(AbstractTest):
   protocol_factory = TBinaryProtocol.TBinaryProtocolFactory()
 

diff --git a/test/py/TestServer.py b/test/py/TestServer.py
index 94a81c0..4c6cb8a 100755 (executable)
--- a/test/py/TestServer.py
+++ b/test/py/TestServer.py
@@ -1,6 +1,6 @@
 #!/usr/bin/env python
 
-import sys, glob
+import sys, glob, time
 sys.path.insert(0, './gen-py')
 sys.path.insert(0, glob.glob('../../lib/py/build/lib.*')[0])
 
@@ -52,6 +52,11 @@ class TestHandler:
       x.message = str
       raise x
 
+  def testAsync(self, seconds):
+    print 'testAsync(%d) => sleeping...' % seconds
+    time.sleep(seconds)
+    print 'done sleeping'
+
 handler = TestHandler()
 processor = ThriftTest.Processor(handler)
 transport = TSocket.TServerSocket(9090)