diff --git a/sjrpc/core/rpcconnection.py b/sjrpc/core/rpcconnection.py index 57664a665dc9d19d102bfb0e5309d589dfba0807..de22c4bb8b55dbef8eaa91583d56635e515bf6a3 100644 --- a/sjrpc/core/rpcconnection.py +++ b/sjrpc/core/rpcconnection.py @@ -9,7 +9,6 @@ from __future__ import absolute_import import ssl import struct import socket -import select import logging from sjrpc.core.protocols.rpc import RpcProtocol @@ -55,9 +54,6 @@ class RpcConnection(object): MESSAGE_HEADER = '!HL' MESSAGE_HEADER_FALLBACK = '!L' SHORTCUTS_MAINRPC = ('call', 'async_call') - IOW_EVENTS = {'read': select.POLLIN | select.POLLPRI, - 'write': select.POLLOUT, 'hup': select.POLLHUP, - 'error': select.POLLERR | select.POLLNVAL} def __init__(self, sock, loop=None, enable_tcp_keepalive=False, *args, **kwargs): @@ -164,12 +160,6 @@ class RpcConnection(object): def __nonzero__(self): return self._connected - def _enable_fallback(self): - pass - - def _disable_fallback(self): - pass - def _send_capabilities(self): ''' Send capabilities to the peer, only work in fallback mode for