Update client.py
This commit is contained in:
1 parent
a9b4edd040
commit
ca1073beda
1 file changed
+11
-7
+11
-7
@@ -22,17 +22,21 @@ def send_message(sock, message):
|
|||||||
sock.sendall(header)
|
sock.sendall(header)
|
||||||
sock.sendall(e_data)
|
sock.sendall(e_data)
|
||||||
|
|
||||||
def receive_message(sock):
|
def receive_exact(sock, num_bytes):
|
||||||
header = sock.recv(10)
|
|
||||||
if not header:
|
|
||||||
return None
|
|
||||||
message_length = int(header.decode('utf-8'))
|
|
||||||
received_data = b""
|
received_data = b""
|
||||||
while len(received_data) < message_length:
|
while len(received_data) < num_bytes:
|
||||||
chunk = sock.recv(65536)
|
chunk = sock.recv(num_bytes - len(received_data))
|
||||||
if not chunk:
|
if not chunk:
|
||||||
break
|
break
|
||||||
received_data += chunk
|
received_data += chunk
|
||||||
|
return received_data
|
||||||
|
|
||||||
|
def receive_message(sock):
|
||||||
|
header = receive_exact(sock, 10)
|
||||||
|
if not header:
|
||||||
|
return None
|
||||||
|
message_length = int(header.decode('utf-8'))
|
||||||
|
received_data = receive_exact(sock, message_length)
|
||||||
return received_data.decode('utf-8')
|
return received_data.decode('utf-8')
|
||||||
|
|
||||||
def grep_all_ips(ips, cmd):
|
def grep_all_ips(ips, cmd):
|
||||||
|
|||||||
Reference in new issue
Block a user