lab/mininet-sample
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

msg: cope with aggregated requests

Browse Source
This commit is contained in:
Quentin De Coninck 2017-02-23 14:44:01 +01:00
parent 5270b53209
commit 3e9e39f774
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/msg_server.py
View File

@ -49,7 +49,7 @@ class HandleClientConnectionThread(threading.Thread):
buffer_data += data buffer_data += data
if len(buffer_data) == self.msg_size: if len(buffer_data) >= self.msg_size:
stop_time = datetime.datetime.now() stop_time = datetime.datetime.now()
if start_time: if start_time:
self.delays.append(stop_time - start_time) self.delays.append(stop_time - start_time)
@ -57,11 +57,7 @@ class HandleClientConnectionThread(threading.Thread):
response = string_generator(size=self.msg_size, chars=string.digits) response = string_generator(size=self.msg_size, chars=string.digits)
start_time = datetime.datetime.now() start_time = datetime.datetime.now()
self.connection.sendall(response.encode(ENCODING)) self.connection.sendall(response.encode(ENCODING))
buffer_data = "" buffer_data = buffer_data[self.msg_size:]
elif len(buffer_data) > self.msg_size:
print("Too much data; break")
break
finally: finally:
# Clean up the connection # Clean up the connection