Loading sjrpc/core/rpcconnection.py +3 −0 Original line number Diff line number Diff line Loading @@ -33,6 +33,9 @@ class RpcConnection(object): # Sock of this connection: self._sock = sock # Activate TCP keepalive on the connection: self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) # Inbound buffer containing currently readed message while it sending: self._inbound_buffer = BytesBuffer() Loading Loading
sjrpc/core/rpcconnection.py +3 −0 Original line number Diff line number Diff line Loading @@ -33,6 +33,9 @@ class RpcConnection(object): # Sock of this connection: self._sock = sock # Activate TCP keepalive on the connection: self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) # Inbound buffer containing currently readed message while it sending: self._inbound_buffer = BytesBuffer() Loading