mirror of
https://github.com/gnh1201/caterpillar.git
synced 2025-09-06 09:51:06 +00:00
Update server.py
This commit is contained in:
parent
4985383556
commit
a7f0ffb03d
|
@ -218,9 +218,12 @@ def proxy_server(webserver, port, scheme, method, url, conn, addr, data):
|
||||||
|
|
||||||
# Wait to see if there is more data to transmit
|
# Wait to see if there is more data to transmit
|
||||||
def sendall(sock, data):
|
def sendall(sock, data):
|
||||||
|
# send first chuck
|
||||||
|
sock.send(data)
|
||||||
if len(data) < buffer_size:
|
if len(data) < buffer_size:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
# send following chunks
|
||||||
buffered = b''
|
buffered = b''
|
||||||
conn.settimeout(1)
|
conn.settimeout(1)
|
||||||
while True:
|
while True:
|
||||||
|
@ -231,6 +234,7 @@ def proxy_server(webserver, port, scheme, method, url, conn, addr, data):
|
||||||
buffered += chunk
|
buffered += chunk
|
||||||
if proxy_check_filtered(buffered, webserver, port, scheme, method, url):
|
if proxy_check_filtered(buffered, webserver, port, scheme, method, url):
|
||||||
raise Exception("Filtered request")
|
raise Exception("Filtered request")
|
||||||
|
sock.send(chunk)
|
||||||
if len(buffered) > buffer_size:
|
if len(buffered) > buffer_size:
|
||||||
buffered = buffered[:-buffer_size] # reduce memory usage
|
buffered = buffered[:-buffer_size] # reduce memory usage
|
||||||
except:
|
except:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user