From 6a9c114cf2b383ac4f7ce710c6c20880ec493445 Mon Sep 17 00:00:00 2001
From: xiaosuGW <xiaosuGW@localhost>
Date: Thu, 15 Jul 2021 16:18:18 -0500
Subject: [PATCH] upload test.sh and parse.py

---
 runtime/tests/parse.py | 57 ++++++++++++++++++++++++++++++++++++++++++
 runtime/tests/test.sh  |  2 ++
 2 files changed, 59 insertions(+)
 create mode 100644 runtime/tests/parse.py
 create mode 100755 runtime/tests/test.sh

diff --git a/runtime/tests/parse.py b/runtime/tests/parse.py
new file mode 100644
index 0000000..18b451a
--- /dev/null
+++ b/runtime/tests/parse.py
@@ -0,0 +1,57 @@
+import os
+import sys
+import numpy as np
+from collections import defaultdict
+#import matplotlib.pyplot as plt
+#cmd1='grep "outbound|80||%s" istio-log/%s | grep "8012::capacity::"|awk -F "::" \'{print $2 " " $4}\'' % (function, files[i])
+def def_value():
+	return 0
+
+def parse_file(file_dir):
+	running_time_dict = defaultdict(def_value)
+	queuing_times_dict = defaultdict(def_value)
+	runnable_times_dict = defaultdict(def_value)
+	blocked_times_dict = defaultdict(def_value)
+	initializing_times_dict = defaultdict(def_value)
+	
+	running_times = [] 
+	queuing_times = []
+	runnable_times = []
+	blocked_times = []
+	initializing_times = []
+	fo = open(file_dir, "r+")
+	next(fo)
+	for line in fo:
+		t = line.split(",")
+		id = t[0]
+		running_time_dict[id] += int(t[8])
+		queuing_times_dict[id] += int(t[5])
+		runnable_times_dict[id] += int(t[7])
+		blocked_times_dict[id] += int(t[9])
+		initializing_times_dict[id] += int(t[6])
+	for key,value in running_time_dict.items():	
+		running_times.append(value)
+	for key,value in queuing_times_dict.items():
+		queuing_times.append(value)
+	for key,value in runnable_times_dict.items():
+		runnable_times.append(value)
+	for key,value in blocked_times_dict.items():
+		blocked_times.append(value)
+	for key,value in initializing_times_dict.items():
+		initializing_times.append(value)
+	#return  np.median(running_times), np.median(queuing_times), np.median(runnable_times), np.median(blocked_times), np.median(initializing_times)
+	print(np.median(running_times), np.median(queuing_times), np.median(runnable_times), np.median(blocked_times), np.median(initializing_times))
+
+	#print(initializing_times)
+if __name__ == "__main__":
+    import json
+    argv = sys.argv[1:]
+    if len(argv) < 1:
+        print("usage ", sys.argv[0], " file dir")
+        sys.exit()
+
+    #m_running_t, m_queuing_t, m_runnable_t, m_blocked_t, m_initializing_t = parse_file(argv[0])
+    parse_file(argv[0])
+
+    #print(m_running_t, m_queuing_t, m_runnable_t, m_blocked_t, m_initializing_t) 
+
diff --git a/runtime/tests/test.sh b/runtime/tests/test.sh
new file mode 100755
index 0000000..c67a247
--- /dev/null
+++ b/runtime/tests/test.sh
@@ -0,0 +1,2 @@
+hey -c 50 -z 2m -disable-keepalive -m GET -d 5 "http://127.0.0.1:10000" > output.txt
+#hey -c 50 -n 100 -disable-keepalive -m GET -d 6 "http://127.0.0.1:10000" > output.txt