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