diff options
author | Aldo Cortesi <aldo@nullcube.com> | 2012-06-30 10:52:28 +1200 |
---|---|---|
committer | Aldo Cortesi <aldo@nullcube.com> | 2012-06-30 10:52:28 +1200 |
commit | 67669a2a578157782a621fa1ac5531bbb2db8029 (patch) | |
tree | 2bf645771508a71aaf9790ea9b894452408bc2be /netlib/tcp.py | |
parent | 7480f87cd721de6ca9d0cdb7c9437bdb58b16ba0 (diff) | |
download | mitmproxy-67669a2a578157782a621fa1ac5531bbb2db8029.tar.gz mitmproxy-67669a2a578157782a621fa1ac5531bbb2db8029.tar.bz2 mitmproxy-67669a2a578157782a621fa1ac5531bbb2db8029.zip |
Allow control of buffer size for TCPClient, improve error messages.
Diffstat (limited to 'netlib/tcp.py')
-rw-r--r-- | netlib/tcp.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/netlib/tcp.py b/netlib/tcp.py index b3fc2212..bb0a00b9 100644 --- a/netlib/tcp.py +++ b/netlib/tcp.py @@ -50,6 +50,8 @@ class FileLike: class TCPClient: + rbufsize = -1 + wbufsize = -1 def __init__(self, host, port): self.host, self.port = host, port self.connection, self.rfile, self.wfile = None, None, None @@ -78,7 +80,8 @@ class TCPClient: addr = socket.gethostbyname(self.host) connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM) connection.connect((addr, self.port)) - self.rfile, self.wfile = connection.makefile('rb'), connection.makefile('wb') + self.rfile = connection.makefile('rb', self.rbufsize) + self.wfile = connection.makefile('wb', self.wbufsize) except socket.error, err: raise NetLibError('Error connecting to "%s": %s' % (self.host, err)) self.connection = connection |