Loading sjrpc/core/rpcconnection.py +0 −10 Original line number Diff line number Diff line Loading @@ -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 Loading Loading @@ -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): Loading Loading @@ -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 Loading Loading
sjrpc/core/rpcconnection.py +0 −10 Original line number Diff line number Diff line Loading @@ -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 Loading Loading @@ -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): Loading Loading @@ -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 Loading