summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2014-11-20 13:36:31 +0100
committerVictor Stinner <victor.stinner@gmail.com>2014-11-20 13:36:31 +0100
commitd0136026a49547c4961995201214fd7450975dcc (patch)
tree6a887bdefce1d388460811432aa6f87e1358faf9
parentcfc066967813d2e6a93de14136500e32b0c5da0c (diff)
downloadaioeventlet-d0136026a49547c4961995201214fd7450975dcc.tar.gz
remove more dead code
-rw-r--r--README1
-rw-r--r--aiogreen.py24
2 files changed, 3 insertions, 22 deletions
diff --git a/README b/README
index 3ed21a3..8811e53 100644
--- a/README
+++ b/README
@@ -111,6 +111,7 @@ Tests of aiogreen 0.1:
To do (Not supported)
=====================
+* add_reader() does only support one callback per file descriptor currently.
* run an event loop in a thread different than the main thread
* sockets: create_server, sock_recv
* pipes: connect_read_pipe
diff --git a/aiogreen.py b/aiogreen.py
index 52f64c8..adf3bc3 100644
--- a/aiogreen.py
+++ b/aiogreen.py
@@ -1,17 +1,10 @@
-import sys
import errno
-import eventlet.greenio
-import eventlet.semaphore
import eventlet.hubs.hub
import functools
-import heapq
+import sys
socket = eventlet.patcher.original('socket')
threading = eventlet.patcher.original('threading')
-try:
- # Python 2
- import Queue as queue
-except ImportError:
- import queue
+
try:
import asyncio
from asyncio import base_events
@@ -19,8 +12,6 @@ try:
from asyncio import selectors
from asyncio.log import logger
- _FUTURE_CLASSES = (asyncio.Future,)
-
if sys.platform == 'win32':
from asyncio.windows_utils import socketpair
else:
@@ -32,13 +23,6 @@ except ImportError:
from trollius import selectors
from trollius.log import logger
- if hasattr(asyncio.tasks, '_FUTURE_CLASSES'):
- # Trollius 1.0.0
- _FUTURE_CLASSES = asyncio.tasks._FUTURE_CLASSES
- else:
- # Trollius >= 1.0.1
- _FUTURE_CLASSES = asyncio.futures._FUTURE_CLASSES
-
if sys.platform == 'win32':
from trollius.windows_utils import socketpair
else:
@@ -73,10 +57,6 @@ _BLOCKING_IO_ERRNOS = set((
))
-def _is_main_thread():
- return isinstance(threading.current_thread(), threading._MainThread)
-
-
class SocketTransport(selector_events._SelectorSocketTransport):
def __repr__(self):
# override repr because _SelectorSocketTransport depends on