Make sure Channel is actually iterable in py3. Pointed out by pylint. cleanup queue.

cleanup threadpool.
various small cleanups.
cleanup _fileobjectposix.

.landscape.yml

@@ -27,6 +27,8 @@ ignore-paths:
   - gevent/_tblib.py
   # likewise
   - greentest/six.py
+  # sadly, this one is complicated
+  - setup.py
   - greentest/getaddrinfo_module.py
 ignore-patterns:
   # disabled code
@@ -55,3 +57,5 @@ pyflakes:
     - F401
     # F811: redefined function; same story
     - F811
+    # F403: wildcard import; same story
+    - F403

.pylintrc

@@ -58,7 +58,9 @@ generated-members=exc_clear
 # List of classes names for which member attributes should not be checked
 # (useful for classes with attributes dynamically set). This supports can work
 # with qualified names.
-ignored-classes=SSLContext, SSLSocket, greenlet
+# greenlet, Greenlet, parent, dead: all attempts to fix issues in greenlet.py
+# only seen on the service, e.g., self.parent.loop: class parent has no loop
+ignored-classes=SSLContext, SSLSocket, greenlet, Greenlet, parent, dead
 
 # List of module names for which member attributes should not be checked
 # (useful for modules/projects where namespaces are manipulated during runtime

changelog.rst

@@ -14,6 +14,8 @@
 - Remove module ``gevent.coros`` which was replaced by ``gevent.lock``
   and has been deprecated since 1.0b2.
 - The ``ref`` parameter to :func:`gevent.os.fork_and_watch` was being ignored.
+- Python 3: :class:`gevent.queue.Channel` is now correctly iterable, instead of
+  raising a :exc:`TypeError`.
 
 1.1.0 (Mar 5, 2016)
 ===================

gevent/__init__.py

@@ -44,7 +44,7 @@ __all__ = ['get_hub',
 import sys
 if sys.platform == 'win32':
     # trigger WSAStartup call
-    import socket  # pylint:disable=unused-import
+    import socket  # pylint:disable=unused-import,useless-suppression
     del socket
 
 from gevent.hub import get_hub, iwait, wait, PYPY

gevent/_fileobjectposix.py

@@ -24,6 +24,9 @@ class GreenFileDescriptorIO(RawIOBase):
     # the type's tp_dealloc slot; prior to Python 3, the object doesn't
     # appear to have a __del__ method, even though it functionally does)
 
+    _read_event = None
+    _write_event = None
+
     def __init__(self, fileno, mode='r', closefd=True):
         RawIOBase.__init__(self)
         self._closed = False
@@ -33,15 +36,14 @@ class GreenFileDescriptorIO(RawIOBase):
         self._readable = 'r' in mode
         self._writable = 'w' in mode
         self.hub = get_hub()
-        io = self.hub.loop.io
+
+        io_watcher = self.hub.loop.io
         if self._readable:
-            self._read_event = io(fileno, 1)
-        else:
-            self._read_event = None
+            self._read_event = io_watcher(fileno, 1)
+
         if self._writable:
-            self._write_event = io(fileno, 2)
-        else:
-            self._write_event = None
+            self._write_event = io_watcher(fileno, 2)
+
         self._seekable = None
 
     def readable(self):
@@ -231,10 +233,12 @@ class FileObjectPosix(object):
             bufsize = 1
 
         if mode == 'r':
-            self.io = BufferedReader(self.fileio, bufsize)
+            IOFamily = BufferedReader
         else:
             assert mode == 'w'
-            self.io = BufferedWriter(self.fileio, bufsize)
+            IOFamily = BufferedWriter
+
+        self.io = IOFamily(self.fileio, bufsize)
         #else: # QQQ: not used, not reachable
         #
         #    self.io = BufferedRandom(self.fileio, bufsize)

gevent/_semaphore.py

@@ -99,7 +99,7 @@ class Semaphore(object):
                         return
                     try:
                         link(self) # Must use Cython >= 0.23.4 on PyPy else this leaks memory
-                    except:
+                    except: # pylint:disable=bare-except
                         getcurrent().handle_error((link, self), *sys.exc_info())
                     if self._dirty:
                         # We mutated self._links so we need to start over

gevent/_ssl3.py

@@ -298,7 +298,7 @@ class SSLSocket(socket):
         # 3.5+
         def selected_alpn_protocol(self):
             self._checkClosed()
-            if not self._sslobj or not _ssl.HAS_ALPN:
+            if not self._sslobj or not _ssl.HAS_ALPN: # pylint:disable=no-member
                 return None
             else:
                 return self._sslobj.selected_alpn_protocol()

gevent/_sslgte279.py

@@ -376,7 +376,7 @@ class SSLSocket(socket):
         # 2.7.10+
         def selected_alpn_protocol(self):
             self._checkClosed()
-            if not self._sslobj or not _ssl.HAS_ALPN:
+            if not self._sslobj or not _ssl.HAS_ALPN: # pylint:disable=no-member
                 return None
             else:
                 return self._sslobj.selected_alpn_protocol()

gevent/monkey.py

@@ -407,12 +407,12 @@ def patch_socket(dns=True, aggressive=True):
     # However, because gevent.socket.socket.connect is a Python function, the exception raised by it causes
     # _socket object to be referenced by the frame, thus causing the next invocation of bind(source_address) to fail.
     if dns:
-        items = socket.__implements__
+        items = socket.__implements__ # pylint:disable=no-member
     else:
-        items = set(socket.__implements__) - set(socket.__dns__)
+        items = set(socket.__implements__) - set(socket.__dns__) # pylint:disable=no-member
     patch_module('socket', items=items)
     if aggressive:
-        if 'ssl' not in socket.__implements__:
+        if 'ssl' not in socket.__implements__: # pylint:disable=no-member
             remove_item(socket, 'ssl')
 
 
@@ -423,7 +423,7 @@ def patch_dns():
     by that method if requested.
     """
     from gevent import socket
-    patch_module('socket', items=socket.__dns__)
+    patch_module('socket', items=socket.__dns__) # pylint:disable=no-member
 
 
 def patch_ssl():

gevent/queue.py

@@ -105,6 +105,8 @@ class Queue(object):
         return type(self)(self.maxsize, self.queue)
 
     def _init(self, maxsize, items=None):
+        # FIXME: Why is maxsize unused or even passed?
+        # pylint:disable=unused-argument
         if items:
             self.queue = collections.deque(items)
         else:
@@ -321,7 +323,7 @@ class Queue(object):
                 try:
                     putter = self.putters.popleft()
                     self._put(putter.item)
-                except:
+                except: # pylint:disable=bare-except
                     putter.throw(*sys.exc_info())
                 else:
                     putter.switch(putter)
@@ -378,9 +380,11 @@ class PriorityQueue(Queue):
             self.queue = []
 
     def _put(self, item, heappush=heapq.heappush):
+        # pylint:disable=arguments-differ
         heappush(self.queue, item)
 
     def _get(self, heappop=heapq.heappop):
+        # pylint:disable=arguments-differ
         return heappop(self.queue)
 
 
@@ -593,3 +597,5 @@ class Channel(object):
         if result is StopIteration:
             raise result
         return result
+
+    __next__ = next # py3

gevent/threadpool.py

@@ -189,6 +189,7 @@ class ThreadPool(GroupMappingMixin):
                 self._size -= 1
 
     def _worker(self):
+        # pylint:disable=too-many-branches
         need_decrease = True
         try:
             while True:
@@ -205,7 +206,7 @@ class ThreadPool(GroupMappingMixin):
                     func, args, kwargs, thread_result = task
                     try:
                         value = func(*args, **kwargs)
-                    except:
+                    except: # pylint:disable=bare-except
                         exc_info = getattr(sys, 'exc_info', None)
                         if exc_info is None:
                             return
@@ -219,7 +220,7 @@ class ThreadPool(GroupMappingMixin):
                         del func, args, kwargs, thread_result, task
                 finally:
                     if sys is None:
-                        return
+                        return # pylint:disable=lost-exception
                     task_queue.task_done()
         finally:
             if need_decrease:
@@ -230,6 +231,7 @@ class ThreadPool(GroupMappingMixin):
         .. deprecated:: 1.1a2
            Identical to :meth:`apply`; the ``expected_errors`` argument is ignored.
         """
+        # pylint:disable=unused-argument
         # Deprecated but never documented. In the past, before
         # self.apply() allowed all errors to be raised to the caller,
         # expected_errors allowed a caller to specify a set of errors

gevent/timeout.py

@@ -29,6 +29,7 @@ class _FakeTimer(object):
     active = False
 
     def start(self, *args, **kwargs):
+        # pylint:disable=unused-argument
         raise AssertionError("non-expiring timer cannot be started")
 
     def stop(self):

gevent/wsgi.py

@@ -9,7 +9,7 @@ pipelining, and not supporting SSL.
    Use :mod:`gevent.pywsgi`
 """
 
-from gevent.pywsgi import *
+from gevent.pywsgi import * # pylint:disable=wildcard-import
 import gevent.pywsgi as _pywsgi
 __all__ = _pywsgi.__all__
 del _pywsgi

greentest/patched_tests_setup.py

@@ -49,8 +49,7 @@ test_patched_threading.*
 def make_re(tests):
     tests = [x.strip().replace(r'\.', r'\\.').replace('*', '.*?')
              for x in tests.split('\n') if x.strip()]
-    tests = re.compile('^%s$' % '|'.join(tests))
-    return tests
+    return re.compile('^%s$' % '|'.join(tests))
 
 
 no_switch_tests = make_re(no_switch_tests)
@@ -68,6 +67,9 @@ def get_switch_expected(fullname):
     >>> get_switch_expected("test_patched_httplib.BasicTest.test_bad_status_repr")
     False
     """
+    # certain pylint versions mistype the globals as
+    # str, not re.
+    # pylint:disable=no-member
     if ignore_switch_tests.match(fullname) is not None:
         return None
     if no_switch_tests.match(fullname) is not None:

greentest/test__queue.py

@@ -254,6 +254,12 @@ class TestChannel(TestCase):
         channel.task_done()
         assert channel.unfinished_tasks == 0, channel.unfinished_tasks
 
+    def test_iterable(self):
+        channel = queue.Channel()
+        gevent.spawn(channel.put, StopIteration)
+        r = list(channel)
+        self.assertEqual(r, [])
+
 
 class TestNoWait(TestCase):
 

setup.cfg

@@ -5,7 +5,8 @@
 # N813: camelCase imported as lowercase; socketcommon
 # N806: variable in function should be lowercase; but sometimes we want constant-looking names, especially for closures
 # N812: lowercase imported as non-lowercase; from greenlet import greenlet as RawGreenlet
-ignore=E702,E265,E402,E731,E266,E261,W503,E129,N801,N802,N803,N813,N806,N812
+# N805: first arg should be self; fails on metaclasses and classmethods; pylint does a better job
+ignore=E702,E265,E402,E731,E266,E261,W503,E129,N801,N802,N803,N813,N806,N812,N805
 max_line_length=160
 exclude=.runtimes,.eggs,.tox,.git,build,2.6,2.7,2.7pypy,3.3,3.5,test_support.py,test_queue.py,patched_tests_setup.py,test_threading_2.py,lock_tests.py,_sslgte279.py,3.4