diff options
author | Victor Stinner <victor.stinner@gmail.com> | 2014-11-20 13:36:31 +0100 |
---|---|---|
committer | Victor Stinner <victor.stinner@gmail.com> | 2014-11-20 13:36:31 +0100 |
commit | d0136026a49547c4961995201214fd7450975dcc (patch) | |
tree | 6a887bdefce1d388460811432aa6f87e1358faf9 | |
parent | cfc066967813d2e6a93de14136500e32b0c5da0c (diff) | |
download | aioeventlet-d0136026a49547c4961995201214fd7450975dcc.tar.gz |
remove more dead code
-rw-r--r-- | README | 1 | ||||
-rw-r--r-- | aiogreen.py | 24 |
2 files changed, 3 insertions, 22 deletions
@@ -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 |