From dce9e500682e4b545264e0382b0f5d9648447484 Mon Sep 17 00:00:00 2001 From: victoryang00 Date: Sat, 6 Apr 2024 17:47:14 -0700 Subject: [PATCH] pushh restore --- artifact/common_util.py | 231 +++++++++++++++++++--------- artifact/result/burst/burst.pdf | Bin 0 -> 13323 bytes artifact/usecase_burst_computing.py | 135 ++++++++-------- artifact/usecase_energy_outrage.py | 6 +- bench/nas | 2 +- lib/wasm-micro-runtime | 2 +- 6 files changed, 234 insertions(+), 142 deletions(-) create mode 100644 artifact/result/burst/burst.pdf diff --git a/artifact/common_util.py b/artifact/common_util.py index a7270c1..43470e4 100644 --- a/artifact/common_util.py +++ b/artifact/common_util.py @@ -7,10 +7,10 @@ from collections import defaultdict import csv -pwd_mac = "/Users/victoryang00/Documents/project/MVVM-bench/" +pwd_mac = "/mnt/MVVM" pwd = "/mnt/MVVM" slowtier = "giga-root" -burst = "mac" +burst = "giga-root" energy = "bana" @@ -215,7 +215,7 @@ def plot_whole(results, file_name): def get_avg_99percent(data): - group_size = 1000 + group_size = 10 num_groups = len(data) // group_size grouped_data = np.reshape(data[: num_groups * group_size], (num_groups, group_size)) avg_values = np.mean(grouped_data, axis=1) @@ -730,13 +730,13 @@ def run_checkpoint_restore_outrage( exec_with_log(f"ssh -t {slowtier} rm {pwd}/build/*.out") # Execute run_restore with the same arguments (or modify as needed) exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {energy} ./MVVM_restore -t ./bench/{aot_file} {extra2}' >> MVVM_restore.1.out &" + f"script -f -q /dev/null -c 'ssh -t {energy} \" cd /mnt/osdi23/MVVM/build && ./MVVM_restore -t ./bench/{aot_file} {extra2}\"' >> MVVM_restore.1.out &" ) exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {slowtier} ./MVVM_restore -t ./bench/{aot_file} {extra3}' >> MVVM_restore.2.out &" + f"script -f -q /dev/null -c 'ssh -t {slowtier} \"cd /mnt/MVVM/build && ./MVVM_restore -t ./bench/{aot_file} {extra3}\"' >> MVVM_restore.2.out &" ) exec_with_log( - f"script -f -q /dev/null -c './MVVM_restore -t ./bench/{aot_file} {extra4}' >> MVVM_restore.3.out &" + f"script -f -q /dev/null -c '\./MVVM_restore -t ./bench/{aot_file} {extra4}' >> MVVM_restore.3.out &" ) exec_with_log(f"sleep {time}") exec_with_log( @@ -744,7 +744,28 @@ def run_checkpoint_restore_outrage( ) exec_with_log(f"sleep {time1}") exec_with_log(f"ssh -t {energy} pkill -SIGINT MVVM_restore") + + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {energy} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {energy} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {energy} pkill -SIGINT MVVM_restore") + exec_with_log(f"sleep {time2}") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") + exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") + exec_with_log("sleep 14") exec_with_log(f"ssh -t {slowtier} pkill -SIGINT MVVM_restore") exec_with_log(f"sleep 100") @@ -779,73 +800,139 @@ def run_checkpoint_restore_burst( extra8: str = "", extra9: str = "", ): - # Execute run_checkpoint and capture its result res = [] - exec_with_log("rm ./*.out") - exec_with_log("pkill MVVM_checkpoint") - exec_with_log("pkill MVVM_restore") - exec_with_log(f"ssh -t {burst} pkill MVVM_checkpoint") - exec_with_log(f"ssh -t {burst} pkill MVVM_restore") - exec_with_log(f"ssh -t {burst} rm {pwd_mac}/build/*.out") - # Execute run_restore with the same arguments (or modify as needed) - exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {burst} ./MVVM_restore -t ./bench/{aot_file1} {extra2}' >> MVVM_restore.0.out &" - ) - exec_with_log( - f"ssh -t {burst} {pwd_mac}/artifact/run_with_energy_monitoring_mac.sh MVVM_restore 0 {aot_file} &" - ) - - exec_with_log( - f"script -f -q /dev/null -c './MVVM_restore -t ./bench/{aot_file1} {extra3}' >> MVVM_restore.1.out &" - ) - exec_with_log( - f"../artifact/run_with_energy_monitoring.sh MVVM_restore 1 {aot_file} &" - ) - exec_with_log( - f"script -f -q /dev/null -c './MVVM_restore -t ./bench/{aot_file} {extra7}' >> MVVM_restore.4.out &" - ) - exec_with_log( - f"../artifact/run_with_energy_monitoring.sh MVVM_restore 4 {aot_file1} &" - ) - exec_with_log("sleep 10") - exec_with_log( - f"./MVVM_checkpoint -t ./bench/{aot_file1} {' '.join(['-a ' + str(x) for x in arg1])} -e {env} {extra1} > MVVM_checkpoint.0.out &" - ) - exec_with_log( - f"../artifact/run_with_energy_monitoring.sh MVVM_checkpoint 0 {aot_file} &" - ) - - exec_with_log("sleep 10") - exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {burst} ./MVVM_checkpoint -t ./bench/{aot_file} {' '.join(['-a ' + str(x) for x in arg])} -e {env} {extra6}' > MVVM_checkpoint.1.out &" - ) - # exec_with_log(f"ssh -t mac ../artifact/run_with_energy_monitoring_mac.sh MVVM_checkpoint 1 {aot_file} &") - exec_with_log(f"pkill -SIGINT MVVM_checkpoint") - - exec_with_log("sleep 100") - - exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") - exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_checkpoint") - exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {burst} ./MVVM_restore -t ./bench/{aot_file1} {extra4}' >> MVVM_restore.2.out &" - ) - exec_with_log( - f"script -f -q /dev/null -c 'ssh -t {burst} ./MVVM_restore -t ./bench/{aot_file} {extra8}' >> MVVM_restore.5.out &" - ) - exec_with_log("sleep 100") - exec_with_log(f"pkill -SIGINT MVVM_restore") - exec_with_log( - f"script -f -q /dev/null -c './MVVM_restore -t ./bench/{aot_file} {extra9}' >> MVVM_restore.6.out &" - ) - exec_with_log( - f"script -f -q /dev/null -c './MVVM_restore -t ./bench/{aot_file1} {extra5}' >> MVVM_restore.3.out &" - ) - # Return a combined result or just the checkpoint result as needed - - exec_with_log("sleep 100") - exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") - exec_with_log(f"sleep 1000") - exec_with_log(f"scp {burst}:{pwd_mac}/build/*.*.out ./") + # exec_with_log("rm ./*.out") + # exec_with_log("sudo pkill -9 MVVM_checkpoint") + # exec_with_log("sudo pkill -9 MVVM_restore") + # exec_with_log(f"ssh -t {burst} pkill -9 MVVM_checkpoint") + # exec_with_log(f"ssh -t {burst} pkill -9 MVVM_restore") + # exec_with_log(f"ssh -t {burst} \"cd /mnt/MVVM/build && rm {pwd_mac}/build/*.out\"") + # # Execute run_checkpoint and capture its result + # exec_with_log( + # f"script -f -q /dev/null -c 'ssh -t {burst} \"cd /mnt/MVVM/build && ./MVVM_restore -t ./bench/{aot_file1} {extra2}\"' >> MVVM_restore.0.out &" + # ) + # # exec_with_log( + # # f"ssh -t {burst} {pwd_mac}/artifact/run_with_energy_monitoring_mac.sh MVVM_restore 0 {aot_file} &" + # # ) + + # exec_with_log( + # f"script -f -q /dev/null -c ' SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file1} {extra3}' >> MVVM_restore.1.out &" + # ) + # # exec_with_log( + # # f"sudo ../artifact/run_with_energy_monitoring.sh MVVM_restore 1 {aot_file} &" + # # ) + # exec_with_log( + # f"script -f -q /dev/null -c ' SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file} {extra7}' >> MVVM_restore.4.out &" + # ) + # # exec_with_log( + # # f"sudo ../artifact/run_with_energy_monitoring.sh MVVM_restore 4 {aot_file1} &" + # # ) + # exec_with_log("sleep 100") + + # exec_with_log( + # f"./MVVM_checkpoint -t ./bench/{aot_file1} {' '.join(['-a ' + str(x) for x in arg1])} -e {env} {extra1} > MVVM_checkpoint.0.out &" + # ) + # # exec_with_log( + # # f"sudo ../artifact/run_with_energy_monitoring.sh MVVM_checkpoint 0 {aot_file} &" + # # ) + + # exec_with_log("sleep 1000") + + # exec_with_log( + # f"script -f -q /dev/null -c 'ssh -t {burst} \"cd /mnt/MVVM/build && SPDLOG_LEVEL=debug ./MVVM_checkpoint -t ./bench/{aot_file} {' '.join(['-a ' + str(x) for x in arg])} -e {env} {extra6}\"' > MVVM_checkpoint.1.out &" + # ) + # # exec_with_log( + # # f"ssh -t {burst} {pwd_mac}/artifact/run_with_energy_monitoring_mac.sh MVVM_checkpoint 1 {aot_file1} &" + # # ) + # exec_with_log("sleep 20") + # # exec_with_log(f"ssh -t mac ../artifact/run_with_energy_monitoring_mac.sh MVVM_checkpoint 1 {aot_file} &") + # exec_with_log(f"pkill -SIGINT MVVM_checkpoint") + # exec_with_log("sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_checkpoint") + # exec_with_log("sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_checkpoint") + # exec_with_log("sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_checkpoint") + + # exec_with_log("sleep 100") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_checkpoint") # pkill 0 and checkpoint 1 + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_checkpoint") # pkill 0 and checkpoint 1 + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_checkpoint") # pkill 0 and checkpoint 1 + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_checkpoint") # pkill 0 and checkpoint 1 + # exec_with_log("sleep 15") + # # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + + + # # exec_with_log("sleep 100") + # # exec_with_log(f"pkill -SIGINT MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"pkill -SIGINT MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"pkill -SIGINT MVVM_restore") + # # exec_with_log("sleep 15") + # # exec_with_log(f"pkill -SIGINT MVVM_restore") + # exec_with_log( + # f"script -f -q /dev/null -c 'ssh -t {burst} \"cd /mnt/MVVM/build && SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file1} {extra4}\"' >> MVVM_restore.2.out &" + # ) + # # exec_with_log( + # # f"ssh -t {burst} {pwd_mac}/artifact/run_with_energy_monitoring_mac.sh MVVM_restore 2 {aot_file} &" + # # ) + # exec_with_log( + # f"script -f -q /dev/null -c 'ssh -t {burst} \"cd /mnt/MVVM/build && SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file} {extra8}\"' >> MVVM_restore.5.out &" + # ) + # # exec_with_log( + # # f"ssh -t {burst} {pwd_mac}/artifact/run_with_energy_monitoring_mac.sh MVVM_restore 5 {aot_file1} &" + # # ) + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT -f MVVM_restore") + + # exec_with_log("sleep 150") + # exec_with_log(f"pkill -SIGINT MVVM_restore") + # exec_with_log(f"sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_restore") + # exec_with_log(f"sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_restore") + # exec_with_log(f"sleep 15") + # exec_with_log(f"pkill -SIGINT MVVM_restore") + # exec_with_log(f"sleep 15") + # exec_with_log( + # f"script -f -q /dev/null -c ' SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file} {extra9}' >> MVVM_restore.6.out &" + # ) + # # exec_with_log( + # # f"sudo ../artifact/run_with_energy_monitoring.sh MVVM_restore 6 {aot_file1} &" + # # ) + # exec_with_log( + # f"script -f -q /dev/null -c 'SPDLOG_LEVEL=debug ./MVVM_restore -t ./bench/{aot_file1} {extra5}' >> MVVM_restore.3.out &" + # ) + # # exec_with_log( + # # f"sudo ../artifact/run_with_energy_monitoring.sh MVVM_restore 3 {aot_file} &" + # # ) + # # Return a combined result or just the checkpoint result as needed + + # exec_with_log("sleep 50") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") + # exec_with_log("sleep 15") + # exec_with_log(f"ssh -t {burst} pkill -SIGINT MVVM_restore") + # exec_with_log(f"sleep 1000") + # exec_with_log(f"scp {burst}:{pwd_mac}/build/*.*.out ./") cmd = f"cat ./MVVM_checkpoint.0.out ./MVVM_checkpoint.1.out ./MVVM_restore.0.out ./MVVM_restore.1.out ./MVVM_restore.2.out ./MVVM_restore.3.out ./MVVM_restore.4.out ./MVVM_restore.5.out ./MVVM_restore.6.out" cmd = cmd.split() result = subprocess.run(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE) diff --git a/artifact/result/burst/burst.pdf b/artifact/result/burst/burst.pdf new file mode 100644 index 0000000000000000000000000000000000000000..a9d55755b459d05b1bdb4ce4256cbc5a8b0753f6 GIT binary patch literal 13323 zcmb_@2RM~q{5T=GMs{R$B{ST8xmNa;nVHOM&+C$C*rRCJ3L!)xD-z1cs;mZIqmZ3d zGD_6%eXrKH{Qlpb-}Aqo^PKaZ_l(baKjWMa0euxUafAdKB2Y98y?q~ofWo0(cCHXv zSt!i-ls6s)_()1jT-POYpKc!V{sEz_u!C z04VqXA{3_S0f3+jUl!FxIp zouPj4Q!PqJt%x2&drHFtRN*@=%=p?gA) zx9ZNN&2tA0sy>ToJL8j4_DWMW=G;SSN*{r@^*8UMPI1nr9#mkIlDhZo!_v~1&3B87 zZ7Hy-hjsFDM;->PPpS;v`55#tZ^3l)%q!=hn1|~(!%tp6nwMWc_Ok8M`3v)GOV8fF z9l7}&c5`}UjNiI+aZ-~NUM**Ex7%m{)AspN+h=3{$MnIlBd@z&l`pOFW;PuDXUjE+ zi{Ogad!~J4NQxhyVmrCAOMN47gZ``DP(`>^;(NWCcn6Vk{A=wl^D1CB*z5GnuW?wd zp=;JhJ)At`j%~8M{yMkvd`;!q^M&g}*A5&#cgA;v{=uOkREBlk=gP4U-47mqUR@aZ z8nCtYA;sys{OK>_Pu8~1Rhiy2y*aiSBef*wyBO&InK@|K=kb~TCXCo74}>!^p`DMUxVvPPcb@Ug^G~zcWZt}K0-xUOk^m;4?$-OjlBCnO*r}J5$!%WB zr93_DLy__iJ@u`{t5W^>aY-ZEgC*sB#R6ro2WL8;(+^mCtS0QezF2kr z`sq)fX16NnAy+DmZgqAEKodTErtUUg8|?Hil)3quOX)E2cK#Z*o%DQFr7z!ZPMv0_ z(R_SyZK7d$*6vUF_`pX_%@Nk;;zN^6L%3dsDUH?AGaPRK*v)|8b)VIg=>$(C}38Ql_W( zeJ1&L6Wz5VBM%-9Dc~u~IgQsoM^zuF{@UU3&?80b{QK4oz2e%{?2)CabMDux>$XbA zzC=kQz0RGkDSoqP=n%}*sHMrU(5pyxG4z%AsrqoA8|+JU6ueN1`Kzn)(YXgyv_t%k zvQLC)R-`*%sPBhP1W)DOou+Vf@d#*ek3o!GRN;XaRUM+3lFKtboj@U9FJC|S<)KuK zW9F24&@uFN+tQBFMOm{r#yE>_FVSK?=lw9w_T9k=SFjnX&E-!>eukD zQXwI5532ndgBg?Xh>YSX%GklPPY>TBDU<}L~osaJgaZ?^=y^-DKVr&($W4SQQa z?%eGU#%Nw`oSLW^;A6;LDL)aCopfG^!7y9%I^0ZZQkKVO(P11JSpxZ*wLu|)@=0ZN zIG1&Nu+B=u**f-(Sd+S}19zEawqd|NYDsjM%+_#LFKY1a^FYrA;g`k-^UeDI4R?5TSZ;OuZX{)(S)$=Lx zO45Mh#QB~gvsniwH4BAiz5U@EaH_ciwO-mjSKrE};=$$!WWPzV*mFdS!fsYMx$L|( z>2(1KmIZIZ{57|}XFPc(AC6zG-yl;`$i*5QdTR5=Ve*Bvu3Pvx6`iXnKb6lLbh> zg@qhPejiO(U|jj>1mn{zuh~}jVM0%h?P7nZr&4fAk8GHEw(hcyvJ1!gtGS~*?>;MB zDD%v4=VY_<79ZYtOr%J*$T&$k-${NLB3V2uXLAKD!%&yWgg9XwyGpCgncn;Me6^g5 zaZtl(3%6yP1+Do-Lbr0$o1>-J)hzzwsl46^1Jbl=&&}dibkq~=#M>p3gx$JTOZnwf zEf{HtN(^S+g(%)vnhiE?3O?_=_Y23@Jqe6SM3@jEqHVeUYT^&3e06(9$oYHCQ*Kka z(y_@=3CMOS`Hx3De_Tx=Xz1gw#--clN^A+!+H5V%($v8)7JZoFo=JC;VR2^a_eqY|Oz_0T-eq>FlB1 z%He9s9d~P^mGLOmfU4U;PCB9VVvdCUPr_-cnavq3xvucn%w6?oyvJizw|cvn-m|bP zQAC%)4CWAh{aSHt4vQ+qHPw(Zbw2KkwCMs4@O{&wn&z%zYRicltv0M-*|A~H2l4Lm zY^fq{1@t8%tPF!kaVGpUp#qKy!8s8=lx#K37aC&@o$6F`Hl6P;5KD6?@Q&|jE6fG#PNCkHG+}()8T|UD12=334|L|-k#rO8PyhU8zhK%SXDLPbnvC8> z7wXBE_o$0rsIp%QQJOp;uYOyYM?Q)&e3+fS(&mB9(sQxbYh+>dqrR2(d__E-m_Q`n zT71`$o{yJgeAMaG_6OwbL-S<_ubd%%j*iSOe%EMSVWiQLw8A=Tz062Qp{DfNHPY^e z;_g&^!;(Pb@@h8aUZ+_`b8&W*N?4JIXy=rt{6BvA1&z;YW$3Y^d`;9v-pWGuT{Glr zlSwyTPrYX2E{0a!^Vv5|p>}%?rIoN1qSQ5*d-7CuBz7#Yz9LHq9oGV#+z&5tzSR)> zXrA2ufZ4M^fo}<@pb4ybt!F%I+GUx8P$;%ohxQ&`qvPmM4EoNA5G7YFFOf zYL3B$vS)*j_uJEolwTB}P#e5;DcJqe-M#ld7@yZz=QE>cKOSE6C>$3(pJ3YW2AAq% z)0|y%2x`j5@RvN-dDX$X_lsp|S(}7!+E^?%6MJC0Gt}Hv=vp;q(JrX^BQglHUMiCs z3RZ;1s#YPH+FnMQJ2j7ZInL(YsdK;3Sfn0d@chG@e7EUtj=hf_92;wyBM-AU9UwAl z6UQE6AVH#0Yw?JcWjP5W4gXnqcpU=Zsdh3Z0i3D@D>RbA>9wYdrtx}s{E z(*Z~HpBKFr6}YD5mr5&jSn2I?#OUB93GQq9O>_*Qu0G`U@f@Wz9^G$CZYWWo_vf4) z+ahmMrw%u9Toqo8T+YGM14jCZ?zha)&a61=FskOdZi@ z-DkCsPW!kx*%xGj*I+oq}`@7q?Je zx|l_7ueR1f-mJnUjzWcboo`oyT#OVYgT%;<+6BViA6w&$bu^jU6OJ|B#cR!BMM%zO z{7Bqmx+J%Uf4PcF-P->t`FLLjy}|oDofiZ>mku{&t~}+FU3BEJ2I0t&Ax_8#Mm-}P zC6y3%Xr?nn@ls*7#yZo*^CnW1*Ry9h3tPiZ%!CEA?c=`yRh?PjYjD4@<`BWaQE((v z@w)DQxG$|ELcp3r?R@(!BR<|<9kZdq6VzfaYfWccoH&%PL>*7&BxD)dQI}>9H3vt? z#&KV}<cqPh zy7q!SDHCi}t>$-2+(NLLnKM*~6)j3JjT7cKB@&}raJ=%F85Pq*QXR6@0)z(7*DbcI z3KZ;gl+<&l$c^hH;!Bnu+mz0wi;SMdjYekH%d#R^!`}9u3^kdr#q`MCY1xEIKcp`6 z!aaK*l(tHHan%%OdgOlNbpOcg>HA-0c#3Mao@ClLZnifE)k$ydd;4696q0?5C%y$| zq~HS#NKgng;(NqKidw)g#huLIShrxd+%)U6b$Ym>cn4Mkj=y zn|FOB++&*fo?yc*$#qwTB z1TgdqW?HT>9jWWd;(dXUpphh+-oT5X?QeZP_bg~L7CGvwW94pmJLrJy36*0rGt}xa z2kle#O^++m%xX0`TSOb+O@r$x-hj%M#Qmnj%X<1xi5;3w|%+b z-QA3{^s(R*Kw5Emr9)ZK8)V+?31vmGm=)db2v&U za=CEq=(;}Z^P1**I>uFZRb>(1D=*(#H+RvxCA+f+Xl+pO-gqUb&0sPxRB&{uSazUi z{eVS3@xY(7M}i^uZ-RTouvRIa`G~ z)WZ~_PKQXmGcHh^RTA>>g3^1>H*;Z4(A&y}(5}F}(Zu=hPio^;d^TS@zi4XTLU z>9fRqIch=N=O#$FFBg8^L_;X%*1?N!Q5QurMT4#fu!}9UV=aZ^=~M7J)ZUK-L>vhhR0sjefDxwHY^ma zi$S!)&pf_dGpTLG>=V&ZeWJutHvhDQrA6AQ=-LZ$0`gVEDT{nnRz!(1DIWD@T4aW( zN@TIiHztQvEIl+OqSWeXzM8qlmRfLq%`8psOBsFH*ORp=UMo~MA*)lRc*DDa&~sJp40rab+%|1m=Zj*{k1d_r=n8SP#~ z_yIAwk5~A7CAYZF<_y%D2gY{{d`+D`Xk_rwut362$ts$wJDcg9T(%ptd0G8?oY;*t z-v`tOBJNS5vdQhwXd-J0rjqzrj?(#YGg#y{-E*^Req+%q8#nCvS*;94RG+`3viS07!I}3P z&L$}~5xv^0W&zd_@~MSs{)_QSfn&Nd2cPmna*;CPhwlbGdg~doapZ~NyRDA(k34tw zc5WU|-+_YQvE^?R#G(KDqfm`&WNLu!q5NvBNCSZk>Io)9t$mGSM4q;pW>^fTqOCfm zc7Q5L@C2I~wU+&`{w0O_F@kuu;h#_7q=Pr6*uJSH-n%Y5o9gOlLpf>XWr z8SAw6pZR5XfD$}B{S8VK`Y-IXD)8;9AodJBH1ZD77)!bQq4E}Jcr35!yzCsMv2hQ0 zVwCUjxU@!q|4@IT-kF2SMfsa(!l8rtA2n&H{F5%VxoH>0&0i^Cy*~JUylh1+e}K(m zb+I?EGsmFwaXYS^F*}p(etFOfhJkm1$2IORC3f<0Kl!R3B8GoOfCwmB_MDt&8rjQJ z5_&k)w$x1`Yyppa@pU7L{rJ+Eb-Ol+VD_Tv2aOD51vgnLsoFUQ7qKGFWXJAb&}_P~ z9O&tv<9_4V>?dwA6a$>l5G`QI^Pu-NS@IdH8P&M+TZa`4%oR4a$%i^^dKQ3AJ#)H4C#&l%yz*su$_}bh)?fLLW zJ8%a)%l?f!lF0v-Ar!J&AFf}DCTEUh2RszV-6Rj?L19ddlEgj@x<`-6E9inN1=2&K zoq|)L9*iwec9pWU7)}+Qbn+`tMztu&1cul3XcH)*dsNmlL-~U@Cu9?}@Q9kPSo$sp ztba~>nZq|j^$2=s@an`6B#ZlR#oBDj$<=ryKc)EJxX(nah%L-TM;BzC^&)84YTcI`_uKSjRW?xT-AnmL5jt`#pbtj9q0 zgpAZ%7N7&~sD3}KOJJ@b&5%2 zfU*4w9|upUf5!2zZ~8vffAxu!>AuTZ!oBq7WNM#(o3&j$n=ko=VUdDqHwlY=PU+VP zsJ4mx&yigGkRbWPbc0|$zjhYw10}4~x zzPu1ez>x^3I2wzBA|wF?hCrfF;0?wPLl5~+pMD&Ph8w}Lm}BjeNJ;Fj3POVzzb`+O z_Rs|zMF-TqXJl+2Ag6bLbqB9l3iTIU{}DpiP@WZBlQ&3gdi{`|QNZ(_&?~v)JTz${ zo~UN!-I;V^kybt-E6H%$+~UF8o{YJrP+V>Lsf6iqZuNLD$Awo5SrN*&2ulIV}@eM z(6Y>LhJ1nX*deP5I{UKX``&W4l$e%4wy9OPeN4Ri^<&y|-* zQ#SI(&3U$?8!+F5f+S8nLwk|YtE26YL)lXIy&#Nq-zz3$v+!0OZqAWui6&g*bosco zlq+dvJsbdkxdZ!l@NWJFJruSQ(5rAXoH|}DQX%>IpI!HHAgi=X_ITnu-LO0Hhz$x4?q?SSY`o(1YJ93XK+Z9)r_Zpas6m4*69 zJs~?wydO~iwJJVARgJ-B1u+>JqjlOGT79GMQFYu?g@~~`x1UCIYYeqZM?blI;a?|FGY6+P{!pl*c?oZNeO?L|1AZ@h(b(3Y*umTkhU)Q|60P=HZx zbK#+X#xH!8Z}AnU6hE!j6Kp+k{m#YFPx0(7>!}{kO9D%EWNzh_a=YvKo)EOQaH^5! z?WXQnEBS}Xuyz+~L=CFTcTD)XiCQJQKUTx_xVzWIEiPY+BV*-QsuDyP2xRA(RFz za%O2Twu3LaS7xLOytS@}nC_`&<*EzQBnxx>NX?svg6dBzwAR`o4Jkqo{p0K6vnPfi z7;`SSE^|bvI5&Gm&OGhONP>1=50CEA8S<9LEt*+YnxC@LQngg#Q|8W;DXl~{#LLR7 zBRYcTu`wPwRD#pIc>+%#u}YV=?W%LU`tsO}O%rdFNUSMsMFFq-vL#DWE>H0|=K%cm z6S$FG_E;&^izz#N=;Gu!=1x=ef4Lz9^dA6->ycVk;_8QNgj@p3{JGfYgzwod~ z8Zo$;Rk;LB#xq4>xWmf7dK}-K2J~OC80Sfepqtx*oPh>=4lNBpHLh$vq%Ry`rSKsd zCdybC`#*__Fupra{8X7V$SgT=5+Cu1rsFpAf?=daL7fTT%cV5roob8|WxHWs(?srs zPepds|4Oib$e;!tE=bJZ z;J^w>7{M|#$fY{07$Oj#ifg$~Tp9V;Q~q$3W9{5pA|&P>Sc*E{d;KIrd1z_SqC zx&w1|aIuhoV+q9#Gzk=nduqE6uY^0^9I;P195wN^f6rs;-Sig}h!$_MVy{EROzS4E z+;(mrK_Nm%sG`mu?)Na8P%wsS+UsMo{oe(eXzDEcq@!x%$pT0PbBhM`A7)ugB5YFtYRtl z8MqWJD`+%qdG1~HEl(H;(4OvMe?A`6*|FSYY}0bB-%|nm^36zH^!Vr4JJZvjHYu!a zETjLVAt1|t1Vxg6ar%Y2i#7zD2`m|NzM~o>UvTQjF*4rS0pd96&1rsB#LSG0Q_yir zpD#6%Tf*MRH;Y_BwKd;n|E(k2PDavY=A|7#+QENABK`s_dj(-PbXK3`v%{us)H5BH^ewb zhc&vS-Xp&%ORn7CTVSBPkGJPVo{@0rFs1zYYR|o|?C*x8RPjy6K<$J%#S}XWRaw|Q zx`lEv4^Ld+dY!WHs@*8BHJKx1H@S%vcmGWPyCgY1!CoR8^2Ke;6Al^{)q}F1F6O^v znX^DYLo&Z;Wh!!|sFT@(A0;DW@p-b#;ks60#l$18vXzS6rW;?#ud5p;|4AQ!6hB$E z9R-mx&0tElzW8q~T>}FZlfx=_S6dT5BU?{j&?XUliOSBl1Yj~u$M#zriNOF75RlHL zg7>v2xOfx22vEegl(Zia6}Sfwxg53i020TPeqVZf{(r<<;1;^JM1l(`qf7!02YC$q z{b*T1U?6b%K%yIvNJdI~gTPchfxIv<4en?9-S;jCOvS~~5f3D>fmv&oP!w>m;OlK` z4hO01`O? z6)?aBsH7k;cPPvQiU7z70~Q3Z0!@-XaLEMZxxq|b9Ei?9-*$T7&-_6W@xLEZ{ABJg z>>;u1f8hndW_MdBUw|5a#T7+gdoT$QhXgJRz#YH`aU=>Lld`S1#x}xm2+Ztz6G$-x zk{?~{6+NBY@t_ z;v1x-6sce&aikh23BU{VV-ZLI!R>v~z`hvZR0V|t=b@n(pq2uN1=gg31jk`XL;!1W ze-hI`0s=4qgoS{6Vt_d$qI?GqtV!|%?t}&(;2?=WutC(o8Ym>bfZJ^s2nIlrG!vxn z&jtYC_7X?{WAF_K6#)5nG5F4|?=`?O$ag?UP@yFeAlfAGK{@yrs31-xVFCmSob_WB z5GXhtLVEXY0UQlM4*p$8v#Ta16jh09H^2b|^S0fG40_00!pQ@?9pr*C0^Fw*iCxl1Vw(cV=hpD^`t&`D3WAZK)sCowi~Gb0sTi>;HTLj9gzXM{bD^x$4X$= zwgmx*OIniv$oX~)P`jiZA>S+pfG%kSXhZmHp+g1v=(*TG3G!x&|Drgwh0NLE$>gW4kk1rGvzuM0qiRUn7MPN~wJwRk|VVENF ze;o!GxNpOL0pS-faP(*AuhE$rLj0#!BJSbh=?CP{Zxi6>gkKN1wr${cvOP@O z#Q`+-fG~sPAZ4Qa0XB<-z_%O^!2JC5j+B9Ha?qs_27C{1cQ2y5iyhP-B_SyR7lS$z ziQc}_Fqp@WR}x+XClLq?@If5>?1AL;UuStcI701g?cIP~zO4X^BrWga<*5QD@(Zg- zBjLbVF&d6VNFs44tT7_zM1h-~mU0`sLq!fW!1B%y1N-Gygpf4wyKAwczi^dI$s-{B-}-2kZf4 z>ipg(iTM-eKi7k!k-!DjZ*$QY;NIZ3J`5cD$2bfM(C5F8`x9R{28aD)92W2wf1is* zf+`C9{lFLC25@ood!HnztbQ9O1sKfV`XqPQLlOn5v478%L}UJ(ixlN>UUgo$5=pB@juUCU89@g@OnOsOqUf{s%IF7)t;E literal 0 HcmV?d00001 diff --git a/artifact/usecase_burst_computing.py b/artifact/usecase_burst_computing.py index ef262ed..47babe5 100644 --- a/artifact/usecase_burst_computing.py +++ b/artifact/usecase_burst_computing.py @@ -7,7 +7,7 @@ from collections import defaultdict import subprocess -ip = ["128.114.53.32", "128.114.59.134"] +ip = ["192.168.0.24", "192.168.0.23"] port = 12347 port2 = 12346 new_port = 1235 @@ -27,7 +27,7 @@ [ "./ORBvoc.txt", "./TUM3.yaml", - "./", + "./rgbd_dataset_freiburg3_long_office_household_validation", "./associations/fr3_office_val.txt", ], ] @@ -263,8 +263,10 @@ def plot_time(reu, aot_energy, aot_ps, aot1_energy, aot1_ps): # print("exec_time ",exec_time[-1]) if line.__contains__("ttrack"): to_append = float(line.split(" ")[-1].replace("\\r", "")) + # print(exec_time) + # print("exec_time ",exec_time[-1]) if to_append > 0: - exec_time[state].append(to_append + 1) + exec_time[state].append(to_append) if line.__contains__("Snapshot "): # print("line ", line) time.append( @@ -277,11 +279,11 @@ def plot_time(reu, aot_energy, aot_ps, aot1_energy, aot1_ps): time.append(parse_time(line.split(" ")[1].replace("]", ""))) print("time ", time) state += 1 - except: + except : print(line) # print(exec_time) # print(exec_time1) - # # print(time) + # print(time) # record time fig, ax = plt.subplots() base = time[0] - sum(exec_time[0]) @@ -299,7 +301,9 @@ def plot_time(reu, aot_energy, aot_ps, aot1_energy, aot1_ps): time_spots.pop(to_pop) if idx != len(exec_time) - 1: time_spots.append(time[idx + 1] - sum(exec_time[idx + 1]) - base) - + print(len(time)) + print(len(exec_time1)) + print(len(exec_time)) time_spots1 = [time[5] - sum(exec_time1[0]) - base] for idx, i in enumerate(exec_time1): @@ -310,8 +314,9 @@ def plot_time(reu, aot_energy, aot_ps, aot1_energy, aot1_ps): # Append the new time spot to the sequence time_spots1.append(new_time_spot) time_spots1.pop(to_pop) - if idx != len(exec_time1) - 1: - time_spots1.append(time[idx + 6] - sum(exec_time1[idx + 1]) - base) + print(idx, len(exec_time1) - 1, len(time) - 1, len(time_spots1) - 1) + if idx != len(exec_time1) -1: + time_spots1.append(time[idx + 6] - sum(exec_time1[idx+1]) - base) avg_extended, percentile99_extended = get_avg_99percent(sum_aot) avg_exec_time1, percentile_99_exec_time1 = get_avg_99percent(sum_aot1) ax.plot(time_spots, avg_extended, "blue") @@ -445,64 +450,64 @@ def plot_time(reu, aot_energy, aot_ps, aot1_energy, aot1_ps): reu = "" with open("burst.txt", "r") as f: reu = f.read() - with open("MVVM_checkpoint.ps.1.out") as f: - checkpoint1 = f.read() - with open("MVVM_checkpoint.ps.out") as f: - checkpoint = f.read() - with open("MVVM_restore.ps.6.out") as f: - restore6 = f.read() - with open("MVVM_restore.ps.5.out") as f: - restore5 = f.read() - with open("MVVM_restore.ps.4.out") as f: - restore4 = f.read() - with open("MVVM_restore.ps.3.out") as f: - restore3 = f.read() - with open("MVVM_restore.ps.2.out") as f: - restore2 = f.read() - with open("MVVM_restore.ps.1.out") as f: - restore1 = f.read() - with open("MVVM_restore.ps.out") as f: - restore = f.read() - - with open("MVVM_checkpoint.energy.1.out") as f: - checkpoint_energy1 = f.read() - with open("MVVM_checkpoint.energy.out") as f: - checkpoint_energy = f.read() - with open("MVVM_restore.energy.6.out") as f: - restore_energy6 = f.read() - with open("MVVM_restore.energy.5.out") as f: - restore_energy5 = f.read() - with open("MVVM_restore.energy.4.out") as f: - restore_energy4 = f.read() - with open("MVVM_restore.energy.3.out") as f: - restore_energy3 = f.read() - with open("MVVM_restore.energy.2.out") as f: - restore_energy2 = f.read() - with open("MVVM_restore.energy.1.out") as f: - restore_energy1 = f.read() - with open("MVVM_restore.energy.out") as f: - restore_energy = f.read() + # with open("MVVM_checkpoint.ps.1.out") as f: + # checkpoint1 = f.read() + # with open("MVVM_checkpoint.ps.out") as f: + # checkpoint = f.read() + # with open("MVVM_restore.ps.6.out") as f: + # restore6 = f.read() + # with open("MVVM_restore.ps.5.out") as f: + # restore5 = f.read() + # with open("MVVM_restore.ps.4.out") as f: + # restore4 = f.read() + # with open("MVVM_restore.ps.3.out") as f: + # restore3 = f.read() + # with open("MVVM_restore.ps.2.out") as f: + # restore2 = f.read() + # with open("MVVM_restore.ps.1.out") as f: + # restore1 = f.read() + # with open("MVVM_restore.ps.out") as f: + # restore = f.read() + + # with open("MVVM_checkpoint.energy.1.out") as f: + # checkpoint_energy1 = f.read() + # with open("MVVM_checkpoint.energy.out") as f: + # checkpoint_energy = f.read() + # with open("MVVM_restore.energy.6.out") as f: + # restore_energy6 = f.read() + # with open("MVVM_restore.energy.5.out") as f: + # restore_energy5 = f.read() + # with open("MVVM_restore.energy.4.out") as f: + # restore_energy4 = f.read() + # with open("MVVM_restore.energy.3.out") as f: + # restore_energy3 = f.read() + # with open("MVVM_restore.energy.2.out") as f: + # restore_energy2 = f.read() + # with open("MVVM_restore.energy.1.out") as f: + # restore_energy1 = f.read() + # with open("MVVM_restore.energy.out") as f: + # restore_energy = f.read() plot_time( reu, - # None, - # None, - # None, - # None, - [ - checkpoint_energy, - restore_energy, - restore_energy1, - restore_energy3, - restore_energy2, - ], - [checkpoint1, restore3, restore4, restore5, restore6], - [ - checkpoint_energy1, - restore_energy3, - restore_energy4, - restore_energy5, - restore_energy6, - ], - [checkpoint1, restore3, restore4, restore5, restore6], + None, + None, + None, + None, + # [ + # checkpoint_energy, + # restore_energy, + # restore_energy1, + # restore_energy3, + # restore_energy2, + # ], + # [checkpoint1, restore3, restore4, restore5, restore6], + # [ + # checkpoint_energy1, + # restore_energy3, + # restore_energy4, + # restore_energy5, + # restore_energy6, + # ], + # [checkpoint1, restore3, restore4, restore5, restore6], ) \ No newline at end of file diff --git a/artifact/usecase_energy_outrage.py b/artifact/usecase_energy_outrage.py index 1240473..211fdde 100644 --- a/artifact/usecase_energy_outrage.py +++ b/artifact/usecase_energy_outrage.py @@ -102,7 +102,7 @@ def predict_outages(state, start_date, end_date): print(predictions) # Convert the CSV data to a DataFrame - df = pd.read_csv(pd.compat.StringIO(data)) + df = pd.read_csv(data) # Convert the 'run_start_time' column to datetime format df['run_start_time'] = pd.to_datetime(df['run_start_time']) @@ -196,8 +196,8 @@ def read_from_csv(filename): # write_to_csv("outrage_computing.csv") time,time1,time2 = get_cloud_result("eaglei_outages_2020.csv") - # plot(results) - reu = get_eneragy_outrage(time,time1,time2) + print(time,time1,time2) + reu = get_eneragy_outrage(10,30,40) with open("outrage.txt", "w") as f: f.write(str(reu)) reu = "" diff --git a/bench/nas b/bench/nas index fae7521..fa64f5b 160000 --- a/bench/nas +++ b/bench/nas @@ -1 +1 @@ -Subproject commit fae7521ab4b5ffcf5ff29d101aa4e7b813c1e46f +Subproject commit fa64f5bdc12a1b19374b9a6c5b2443b9f5b9a175 diff --git a/lib/wasm-micro-runtime b/lib/wasm-micro-runtime index caa27c2..4629d19 160000 --- a/lib/wasm-micro-runtime +++ b/lib/wasm-micro-runtime @@ -1 +1 @@ -Subproject commit caa27c2a34bc3f890a9a76c4d07f5697619636d0 +Subproject commit 4629d1964b6008fb7c3396b43c6c509f4e5c3e7b