summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2014-11-19 13:50:34 +0100
committerVictor Stinner <victor.stinner@gmail.com>2014-11-19 13:50:34 +0100
commit8e73bf4e8917fb7c4ff7b06382f0099171ae4a87 (patch)
treeb25eb3a676cf1a1e31661781e979982582ca2ae4
parent45636aa3e53528ab1d377c6df911d1245fbfdccd (diff)
downloadaioeventlet-8e73bf4e8917fb7c4ff7b06382f0099171ae4a87.tar.gz
add more manual tests
-rw-r--r--manual_tests/date_cb.py19
-rw-r--r--manual_tests/hello_coro.py14
-rw-r--r--manual_tests/later_stop_later.py29
-rw-r--r--manual_tests/soon_stop_soon.py33
-rw-r--r--manual_tests/test_thread.py16
5 files changed, 111 insertions, 0 deletions
diff --git a/manual_tests/date_cb.py b/manual_tests/date_cb.py
new file mode 100644
index 0000000..05cdbcb
--- /dev/null
+++ b/manual_tests/date_cb.py
@@ -0,0 +1,19 @@
+import aiogreen
+import datetime
+
+def display_date(end_time, loop):
+ print(datetime.datetime.now())
+ if (loop.time() + 1.0) < end_time:
+ loop.call_later(1, display_date, end_time, loop)
+ else:
+ loop.stop()
+
+loop = aiogreen.EventLoop()
+
+# Schedule the first call to display_date()
+end_time = loop.time() + 5.0
+loop.call_soon(display_date, end_time, loop)
+
+# Blocking call interrupted by loop.stop()
+loop.run_forever()
+loop.close()
diff --git a/manual_tests/hello_coro.py b/manual_tests/hello_coro.py
new file mode 100644
index 0000000..5cbe417
--- /dev/null
+++ b/manual_tests/hello_coro.py
@@ -0,0 +1,14 @@
+import logging; logging.basicConfig(level=logging.DEBUG)
+import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy())
+from trollius import From
+
+import trollius as asyncio
+
+def work():
+ print("Hello")
+ yield From(trollius.sleep(1))
+ print('World')
+
+loop = asyncio.get_event_loop()
+loop.run_until_complete(work())
+loop.close()
diff --git a/manual_tests/later_stop_later.py b/manual_tests/later_stop_later.py
new file mode 100644
index 0000000..6c6a1c8
--- /dev/null
+++ b/manual_tests/later_stop_later.py
@@ -0,0 +1,29 @@
+import logging; logging.basicConfig(level=logging.DEBUG)
+import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy())
+from trollius import From
+
+import trollius
+import eventlet
+import time
+
+def hello():
+ print("Hello")
+
+def world():
+ print('World')
+ loop.stop()
+
+loop = trollius.get_event_loop()
+loop.call_later(0.1, hello)
+loop.call_later(0.2, loop.stop)
+loop.call_later(0.3, world)
+print("run forever")
+loop.run_forever()
+
+print("sleep")
+eventlet.sleep(1.0)
+
+print("run forever")
+loop.run_forever()
+
+loop.close()
diff --git a/manual_tests/soon_stop_soon.py b/manual_tests/soon_stop_soon.py
new file mode 100644
index 0000000..cede9a1
--- /dev/null
+++ b/manual_tests/soon_stop_soon.py
@@ -0,0 +1,33 @@
+import logging; logging.basicConfig(level=logging.DEBUG)
+import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy())
+from trollius import From
+
+import trollius
+import time
+
+def hello():
+ print("Hello")
+
+def stop():
+ print("stop")
+ loop.stop()
+
+def world():
+ print('World')
+ print("stop")
+ loop.stop()
+
+loop = trollius.get_event_loop()
+loop.call_soon(hello)
+loop.call_soon(stop)
+loop.call_soon(world)
+print("run forever")
+loop.run_forever()
+
+print("sleep")
+time.sleep(1.0)
+
+print("run forever")
+loop.run_forever()
+
+loop.close()
diff --git a/manual_tests/test_thread.py b/manual_tests/test_thread.py
new file mode 100644
index 0000000..9aa38d5
--- /dev/null
+++ b/manual_tests/test_thread.py
@@ -0,0 +1,16 @@
+import logging; logging.basicConfig(level=logging.DEBUG)
+import aiogreen
+import time
+import trollius
+
+def work():
+ print("Hello")
+ print("loop", trollius.get_event_loop())
+ time.sleep(1)
+ print('World')
+
+trollius.set_event_loop_policy(aiogreen.EventLoopPolicy())
+loop = trollius.get_event_loop()
+loop.run_until_complete(loop.run_in_executor(None, work))
+loop.run_until_complete(loop.run_in_executor(None, work))
+loop.close()