Function readwrite

src/network/asyncore_pollchoose.py:182–200

(obj, flags)

        obj.handle_error()

def readwrite(obj, flags):
    try:
        if flags & select.POLLIN and can_receive():
            obj.handle_read_event()
        if flags & select.POLLOUT and can_send():
            obj.handle_write_event()
        if flags & select.POLLPRI:
            obj.handle_expt_event()
        if flags & (select.POLLHUP | select.POLLERR | select.POLLNVAL):
            obj.handle_close()
    except socket.error as e:
        if e.args[0] not in _DISCONNECTED:
            obj.handle_error()
        else:
            obj.handle_close()
    except _reraised_exceptions:
        raise
    except:
        obj.handle_error()

def select_poller(timeout=0.0, map=None):
    """A poller which uses select(), available on most platforms."""