Update server.py
This commit is contained in:
1 parent
2ec0be3a82
commit
a9b4edd040
1 file changed
+11
-7
+11
-7
@@ -20,17 +20,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')
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
|
|||||||
Reference in new issue
Block a user