[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [stem/master] Drop max_response_size argument from RelaySocket's recv
commit 58c788780bb54a114745a0ddf8fbe4666f20dd97
Author: Damian Johnson <atagar@xxxxxxxxxxxxxx>
Date: Mon Jan 1 12:08:46 2018 -0800
Drop max_response_size argument from RelaySocket's recv
Turns out endosome never actually used it. I'll need to ask Tim where the
constant came from.
---
stem/socket.py | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/stem/socket.py b/stem/socket.py
index 20fbf6d0..fe902f0a 100644
--- a/stem/socket.py
+++ b/stem/socket.py
@@ -387,12 +387,10 @@ class RelaySocket(BaseSocket):
self._send(message, lambda s, sf, msg: _write_to_socket(sf, msg))
- def recv(self, max_response_size = MAX_READ_BUFFER_LEN):
+ def recv(self):
"""
Receives a message from the relay.
- :param int max_response_size: maximum bytes to return
-
:returns: bytes for the message received
:raises:
@@ -400,10 +398,10 @@ class RelaySocket(BaseSocket):
* :class:`stem.SocketClosed` if the socket closes before we receive a complete message
"""
- # TODO: Not really sure what we'll want here. To start with just copying
- # endosome's behavior.
+ # TODO: Is MAX_READ_BUFFER_LEN defined in the spec? Not sure where it came
+ # from.
- return self._recv(lambda s, sf: s.recv(max_response_size))
+ return self._recv(lambda s, sf: s.recv(MAX_READ_BUFFER_LEN))
def is_localhost(self):
return self.address == '127.0.0.1'
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits