untested graph_1

mp0/.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

mp0/.idea/inspectionProfiles/profiles_settings.xml

+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>
\ No newline at end of file

mp0/.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.6" project-jdk-type="Python SDK" />
+</project>
\ No newline at end of file

mp0/.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/mp0.iml" filepath="$PROJECT_DIR$/.idea/mp0.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

mp0/.idea/mp0.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+  <component name="PyDocumentationSettings">
+    <option name="format" value="PLAIN" />
+    <option name="myDocStringFormat" value="Plain" />
+  </component>
+</module>
\ No newline at end of file

mp0/.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/.." vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

mp0/graph_generator.py

+from matplotlib import lines
+
+
+def collect_data():
+    fp =open("logs.log","r+")
+    lines = fp.readlines()
+    count  = 0
+
+    for line in lines:
+        print(line)
+
 if __name__ == '__main__':
-    pass
+    # pass
+    collect_data

mp0/logger.py

+from mailbox import _mboxMMDF
 import socket
 import threading
 import json
@@ -6,6 +7,7 @@ import sys
 import logging
 import time
 from constants import INITIAL_MSG_LENGTH, REQUEST_DISCONNECT_MSG, ENCODING_FORMAT
+import matplotlib.pyplot as plt 
 
 logger = logging.getLogger()
 logger.setLevel(logging.INFO)
@@ -15,6 +17,10 @@ file_handler.setLevel(logging.INFO)
 file_handler.setFormatter(formatter)
 logger.addHandler(file_handler)
 
+# graph
+timestamp_and_receiveAmount_list =[]
+
+
 
 PORT = ''
 SERVER = socket.gethostbyname(socket.gethostname())
@@ -35,26 +41,120 @@ def recv_from_client(conn):
                 event = msg_dict.get('event', '')
                 is_first_msg = msg_dict.get('is_first_msg', '')
 
-                if event == REQUEST_DISCONNECT_MSG:
-                    print(f"{timestamp} - {name} disconnected")
-                    logger.info(f"{timestamp} - {name} disconnected")
-                    break
-
-                if is_first_msg:
-                    print(f"{timestamp} - {name} connected")
-                    logger.info(f"{timestamp} - {name} connected")
-                else:
-                    print(f"{timestamp} {name} {event}")
-                    logger.info(f"{timestamp} {str(time.time())} {name} {event} {str(initial_msg_length + msg_length)}")
+                # recode the timestamp of reveive
+                timestamp_reveive = time.time()
+                # the message_size(byte)
+                message_size_byte = initial_msg_length + msg_length
+                # output log
+                logger.info(f"{timestamp} {str(timestamp_reveive)} {name} {event} {str(message_size_byte)}")
+                #put server receiving timestamp; delivering timestamp;
+                timestamp_and_receiveAmount_list.add([timestamp_reveive,timestamp,message_size_byte])
+                
+                # if event == REQUEST_DISCONNECT_MSG:
+                #     print(f"{timestamp} - {name} disconnected")
+                #     logger.info(f"{timestamp} - {name} disconnected")
+                #     message_size_byte = -1
+                #     break
+
+                # if is_first_msg:
+                #     print(f"{timestamp} - {name} connected")
+                #     logger.info(f"{timestamp} - {name} connected")
+                #     message_size_byte = 0
+                # else:
+                #     print(f"{timestamp} {name} {event}")
+                    # logger.info(f"{timestamp} {str(time.time())} {name} {event} {str(initial_msg_length + msg_length)}")
         conn.close()
     except Exception as e:
         print(f"[ERROR] thread error:{e.__class__.__name__}.{e}.{traceback.format_exc()}")
 
 
+# draw the bandwith
+def graph_bandwith():
+    last = int(timestamp_and_receiveAmount_list[-1][0])
+    start = int(timestamp_and_receiveAmount_list[0][0])
+
+    num = (last-start)/60+1
+
+    bandwidth = [0 for i in range(num)] 
+    moment = [0 for i in range(num)] 
+
+    # fill in moment the x axis and initialize bandwidth as 0
+    for i in range(0,len(moment)):
+        moment[i] = i
+        bandwidth[i] = 0
+
+    for j in range(0,len(timestamp_and_receiveAmount_list)):
+        temp = (int(timestamp_and_receiveAmount_list[j][0]) - start)/60
+        bandwidth[temp] += timestamp_and_receiveAmount_list[j][2]
+    
+    # Kbps
+    bandwidth = (bandwidth*(8.0))/1024.0
+
+    # draw
+    plt.figure()
+    plt.title("Bandwidth(Kbps)")
+    plt.plot(moment,bandwidth,labal='bandwidth',color='b',marker='o',markerfacecolor='blue',markersize=10)
+    plt.xlabel('seconds')
+    plt.ylabel('Kbps')
+    for a,b in zip(moment,bandwidth):
+        plt.text(a,b,b,ha='center',va='bottom',fontsiz=8)
+
+    plt.legend()
+    plt.show()
+
+def graph_delay():
+    last = int(timestamp_and_receiveAmount_list[-1][0])
+    start = int(timestamp_and_receiveAmount_list[0][0])
+
+    num = (last-start)/60+1
+    
+    moment = [0 for i in range(num)] 
+    delays = [[] for i in range(num)]
+    minimum = [0 for i in range(num)] 
+    maximum = [0 for i in range(num)]
+    median = [0 for i in range(num)]
+    ninetieth_per = [0 for i in range(num)]
+
+
+    for i in range(0,len(moment)):
+        moment[i] = i
+    
+    for j in range(0,len(timestamp_and_receiveAmount_list)):
+        temp = (int(timestamp_and_receiveAmount_list[j][0]) - start)/60
+        delay = timestamp_and_receiveAmount_list[j][1]-timestamp_and_receiveAmount_list[j][2]
+        delays[temp].append(delay)
+    
+    for m in range(len(delays)):
+        delays[m].sort()
+        minimum[m] = delays[m][0]
+        maximum[m] = delays[m][-1]
+        median[m] = delays[m][len(delays[m])/2]
+        ninetieth_per[m] = delays[m][0.9*(len(delays[m])+1)]
+    
+     # draw
+    plt.figure()
+    plt.title("minimum delay, maximum delay, median delay, 90th percentile delay per second")
+    plt.plot(moment,minimum,labal='minimum',marker='o',markerfacecolor='blue',markersize=10)
+    plt.plot(moment,maximum,labal='maximum',marker='s',markerfacecolor='red',markersize=10)
+    plt.plot(moment,median,labal='median',marker='^',markerfacecolor='green',markersize=10)
+    plt.plot(moment,ninetieth_per,labal='90th percentile',marker='*',markerfacecolor='brown',markersize=10)
+    
+    for y in zip(minimum,maximum,median,ninetieth_per):
+        for x1,y1 in zip(moment,y):
+            plt.text(x1, y1 + 1, str(y1), ha='center', va='bottom', fontsize=5, rotation=0)
+
+    plt.legend(loc='best')
+    plt.show()
+
+
 def start():
     server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server.bind(ADDR)
     server.listen()
+    # get the start time of the sever as the origin 
+    timestart = time.time()
+    timestamp_and_receiveAmount_list.add([timestart,timestart,0])
+
     print(f"[LISTENING] Server is listening on {ADDR}")  # DEBUG
     while True:
         conn, addr = server.accept()