From 5bff1a9955eb6808a6a5092c3bdf894ec4d90588 Mon Sep 17 00:00:00 2001
From: HappyZ <zhuyanzi@gmail.com>
Date: Mon, 13 Feb 2017 18:03:41 -0800
Subject: [PATCH] add option for udp receiving multiple times

---
 .../server_recv_normaludp/main.c              | 111 ++++++++++--------
 .../server_m_recv_normaludp                   | Bin 12780 -> 12780 bytes
 .../server_recv_normaludp                     | Bin 13621 -> 13621 bytes
 3 files changed, 63 insertions(+), 48 deletions(-)

diff --git a/offloading_binaries/server_recv_normaludp/main.c b/offloading_binaries/server_recv_normaludp/main.c
index e07d61d..95e6caa 100644
--- a/offloading_binaries/server_recv_normaludp/main.c
+++ b/offloading_binaries/server_recv_normaludp/main.c
@@ -41,17 +41,21 @@ int main(int argc, char *argv[])
     socklen_t clilen;
     // for misc
     int ret;
+    unsigned char listenOnce = 0;
 
     signal(SIGPIPE, SIG_IGN);
     
     if (argc < 2)
     {
-        printf("Usage: %s <port> <[optional] filepath>\n", argv[0]);
+        printf("Usage: %s <port> <[optional] listenOnce ([0]/1)> <[optional] filepath>\n", argv[0]);
         exit(0);
     }
 
     port  = atoi(argv[1]);
 
+    if (argc > 2)
+        listenOnce = atoi(argv[2]);
+    
     // listen to socket
     listenfd = socket(AF_INET, SOCK_DGRAM, 0);
     // bind socket and listen
@@ -62,63 +66,74 @@ int main(int argc, char *argv[])
     bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
 
     // infinity loop to listen
-    printf("Waiting on port %d...\n", port);
-    // clear total_bytes_recv to 0
-    total_bytes_recv = 0;
 
-    // if instrument to write to a file
-    if (argc > 2)
-    {
-        fd = open(argv[2], O_WRONLY | O_CREAT | O_TRUNC);
-        if (fd == -1) {
-            fprintf(stderr, "! Unable to open file %s.\n", argv[2]);
-            close(listenfd);
-            exit(1);
-        }
-    }
-
-    // start timing
-    gettimeofday(&t_start, NULL);
-
-    // start receiving
     for (;;)
     {
-        clilen = sizeof(cliaddr);
+        printf("Waiting on port %d...\n", port);
 
-        // wait for one client and accept it once found
-        ret = recvfrom(listenfd, recvbuf, recvsize, 0, (struct sockaddr *)&cliaddr, &clilen);
-        printf("Accepted client at %s with %d len msg\n", inet_ntoa(cliaddr.sin_addr), ret);
+        // clear total_bytes_recv to 0
+        total_bytes_recv = 0;
 
-        if (ret <= 0)
+        // if instrument to write to a file
+        if (argc > 3)
         {
-            if (errno == 0)
-                break;
-            fprintf(stderr, "! Fail to recv: ret:%d, err:%d; quiting..\n", ret, errno);
-            exit(1);
+            fd = open(argv[3], O_WRONLY | O_CREAT | O_TRUNC);
+            if (fd == -1) {
+                fprintf(stderr, "! Unable to open file %s.\n", argv[3]);
+                close(listenfd);
+                if (listenOnce)
+                    break;
+                continue;
+            }
         }
 
-        // a "code" to indicate UDP is done
-        // printf("%d %d %d", (recvbuf[0] == '='), (recvbuf[1] == '?'), (recvbuf[0] == '!'));
-        if ((recvbuf[0] == '=') && (recvbuf[1] == '?') && (recvbuf[2] == '!'))
+        // start timing
+        gettimeofday(&t_start, NULL);
+
+        // start receiving
+        for (;;)
+        {
+            clilen = sizeof(cliaddr);
+
+            // wait for one client and accept it once found
+            ret = recvfrom(listenfd, recvbuf, recvsize, 0, (struct sockaddr *)&cliaddr, &clilen);
+            printf("Accepted client at %s with %d len msg\n", inet_ntoa(cliaddr.sin_addr), ret);
+
+            if (ret <= 0)
+            {
+                if (errno == 0)
+                    break;
+                fprintf(stderr, "! Fail to recv: ret:%d, err:%d; quiting..\n", ret, errno);
+                exit(1);
+            }
+
+            // a "code" to indicate UDP is done
+            // printf("%d %d %d", (recvbuf[0] == '='), (recvbuf[1] == '?'), (recvbuf[0] == '!'));
+            if ((recvbuf[0] == '=') && (recvbuf[1] == '?') && (recvbuf[2] == '!'))
+            {
+                if (argc > 3)
+                    close(fd);
+                break;
+            }
+
+            if (argc > 3)
+                write(fd, recvbuf, ret);
+
+            total_bytes_recv += ret;
+            // printf("total_bytes_recv %d\n", total_bytes_recv);
+
+        }
+        
+        // end timing
+        gettimeofday(&t_end, NULL);
+        elapsedTime = (t_end.tv_sec - t_start.tv_sec) + (t_end.tv_usec - t_start.tv_usec) / 1000000.0;
+        printf(
+            "recv(bytes):%d\nduration(s):%lf\nthroughput(bps):%lf\n",
+            total_bytes_recv, elapsedTime, total_bytes_recv * 8 / elapsedTime);
+
+        if (listenOnce)
             break;
-
-        if (argc > 2)
-            write(fd, recvbuf, ret);
-
-        total_bytes_recv += ret;
-        // printf("total_bytes_recv %d\n", total_bytes_recv);
-
     }
-    
-    if (argc > 2)
-        close(fd);
-
-    // end timing
-    gettimeofday(&t_end, NULL);
-    elapsedTime = (t_end.tv_sec - t_start.tv_sec) + (t_end.tv_usec - t_start.tv_usec) / 1000000.0;
-    printf(
-        "recv(bytes):%d\nduration(s):%lf\nthroughput(bps):%lf\n",
-        total_bytes_recv, elapsedTime, total_bytes_recv * 8 / elapsedTime);
 
     close(listenfd);
 
diff --git a/offloading_binaries/server_recv_normaludp/server_m_recv_normaludp b/offloading_binaries/server_recv_normaludp/server_m_recv_normaludp
index 14f4767af775e75ef8811c6d0b087eecf3bbac96..9b3bab84327b877b1c8a69fe4e424e7e8c63137c 100755
GIT binary patch
delta 1852
zcmZ8hU1%It6h1SvNt4~Q*<>TE*-bk&yXi(!bJLV|Q=-|XD8)@N(7r_>m@QUVYal7U
zC~KR55mHi|zKE0zQl*MYn(afuDp6FbScu?H^(iyMMVnTr5c*WJerI+j4m)tU_q*rk
ze&;)9_uj<4i3_uJH`|DAUVVG2uC#h|@15w<d0V-C%zl0Kn5|^<cAGe27fF-;c`~ZW
z=+lcblv`LMVLEXUk-R6dD~C)c<>3yIm)ps7l&I;vQ>onb<BK9D6*}&OiGJ|!CUHl?
zD9IbCMXBlwYbu$R7B#K65J*Te7f8U)Au(ekKx*)tg)KvP+$RgWiU%5q{_yWOrXdjX
z8s`<J#U$~Tqk<&qG1Hlbp(l`R)VNiDu*4duy6G&Xk62u*K#f8qq}F3vyjKP_TiXxH
z`nf93YIbJ;cMifP&RI$Zdg{aWh)`t)am)RAYq@{Sa$~cm)tNC}?8Y+2(z2#8v#q1V
zabNBqw)~Pt!KsJ90Ww9w?Esi(`xm7q7S>pnOf(_W)iT{4`Ejhj26=YY$kP;%XQOq|
zjZH#{BzP(`RdQO1+WjP~ryHOf^2dGr=*2&;(2V_!dj<iJin~%K<fGU-#F!*JN<`sH
zMC<QijflL>L<!o*;N$1kbQA=U3lJ%_g2!FaO2c*z3iwXrsGh|6t)>@%L%^&EnrSs5
z33rN+I2-8a^AwYtn`l1lNuMl8a7<QD$lqbhqGBc+!-PIyUx8dDOq*9h`vI`O?;BR2
zK;QogRL@lfIAIfle}%7tDf^apZ%T9GxO@_i1XUfv-4O1!2b6vace`;{!Z>fq@Apte
z50j|)D<p0KsVJ8JfbUZeA1318=b#kFaErc199J8M9rL-yzvWAn%KC{wYd(d~2|e++
z9D$=MCfwoLAi7KArlm}p)+mCH25f&DXTz}p2<%)Ji}JbxPl&BRhk6LT4bSf7Xzy+#
zmAB%Ep6SD=!~PSZ+e*0nFc5fOzh#XhnLpd{XhQxBpO?TbI9eF5^@HHgQ*Z`0o&Zi7
zUCrC8b6@;5+f6hGbst8E4nw?$l}hCz&LOPZ_(OVg_KCw68i|%8Z#1+PU!IyidHT82
z6DRe|n0TSLue<ze?A>sAe&-{qQYgQ#zoMwg=5otp14?}X36jmmXy>*1WHZrx49CmH
zXQ@L<!MKy!#eU&*yV5a_nW}z`l*WN^9J@k|)MK=C#dcrb@(5EuER4}sc!X&P`!(ZC
z*RGa9yjT4i2>;$xFh1zwSB&qvY~_^k(VoP<+zz4)Os&*F5rt?D0}?{bjN`zQNb!k>
z)4<6c#)CbZC9Z@&cKaCDMc^gRtz3gwYSMh~rXfms@xK8FX*j^AKr83j|Ea<MD)b^<
zfy1=t5W&Mi90$Gu`?zOM)nEb4`WLZt0RuJo8Q{6{FWr&4Zsz5GA@A@kc2FXCxt(#l
WW1Q`c8Oh$JM(zZ!RJpJBbM-%qs%ats

delta 1734
zcmZWpZ)h837=PZoOP3~Ty(~8fOXqGT%~GiAwVN&-m1S!f!#F6;4+HyQ+I{E;1!4Nh
z51DHar_Ktu?>S|IDMKb1B_Kjo5R?fO6pJY2F1)z9f(qg%UHm<lyY{RH$MgQ4|IhDv
z?=}}U7v62ess>T@<0}_qb?fw_8>!n@J+Xeqdui>AC(1Q1WzBjQNR{DvQCH=yYEx>J
z<qla+SGSUqr2#39Io&Me5IJ3;JKbx&-u*D{f|Zei&UO<-Ux&Iy=*Y6=`9f1F=JL}W
zg&bGa9rp?X2}$0JBw%OFTJktRh2QJ2jZjh|rmLVBnNGI>oe5o7;Iuuo>u8-vP+)Br
zW?gQzfEEi@PO9UM%d$74dg>8WHZS*aS@rS}oS%Wsy6lP)=rB)uRZEd0h+CPexhqr8
zx_)fgaq}g|$9^nhylUC8zu2{}&T%V8PP$v2p(m5j1E$r{+bMKz9BxY0TJG?4BYI9g
z23<&T7{@d!pfN}EW2j?h;t^)nb~pW4156m`Q_#hF_aUOa{|hi}d2@=3Ui;-HEqRWA
zMgwT7<WrfGV~_$A?}41LY92R7pu5QW;C`qkh5)hiASSztf&o!w4Bhvs&wA%DF<Do)
zb~6vG0W%BOpPNDwo;HKT<B=UcLm8Qd4*PYrut7AzG2>=VZa#oNrX;YE!Q~ocUyF0u
zzK$^Xp*qp8YG_!s<(<jxsr%>t)SNJd;0+|@sn=NsQ<kl>@`?Tp-eU47bjP8KMc92D
zx&zR0VI6fj-oJz4?gp?sF0`F^)-%8Y)BbZXjSf5RT!%le8@-;N#Qzk7{R`yan9t!~
zjjZJ}#)zE(BZ{@)-=*Ks$bG6fu9$P&3XJ85@t*x{A~Ve&&vmOQTY`L|1vt<^attk%
zXj}JZzJ^Wb<kBRrHtcs1Z7f3hUL^2$^BeamBn$7duIJ=;@Oc%z@wVTA<V|ye)LPB6
z-uU!hV~nViB5EgzPAEiw_j<iKobTd);o!a0ICNsZ^<45&yd{jc5_ZREwBCMrk0Pk`
zzWJh1+QY5%BhzAl5YryE=kj+3+QUSp435|Bj|#^G*&BuZ?3WnbEB2LeRr=2$jpD#K
z3n^%j#_e=5bD*;2k)Xq{FvdFJk)Y#{bM`C6{poe|)_>xJ|0t1tqsUe4FN>bg><<p+
zrhXbidRTT-oRZjEAx)%VM8;X*6k5I&;8EcAkp0)e2X&r=A9ni?>NxQ2zzu8q4_@7o
z<|{u9N(J#h07u*C0&AeB64?LPf&UToJXPWFa^R3e;V8}mpM(8;U@z>z7BKVw0wfPG
xy#t>DF0{TMOUA~yukg`=!;_F`iQwgL#@~+p+C;`4nMe)tCivA_lM|mP{{nA(H!}bL

diff --git a/offloading_binaries/server_recv_normaludp/server_recv_normaludp b/offloading_binaries/server_recv_normaludp/server_recv_normaludp
index 7bdb2ef63caa3845aaf894c41dfdc52236e7c23d..48a3f03d8fda28b703cf0379bc8793a744ec3788 100755
GIT binary patch
delta 1159
zcmY*ZZAepL6n@{$r7PF&W}-=&2HKYRg^7Lm*#}-i=!<@dv}i_!M3L){;f!^|xdz5t
zR6nBp)i+5~TZP-SmDZ2&NBxM1oDtk%L=d6n$9mp-H?0fzob#UZoO7OY?#ICKf#W^n
z`fwUiuJEM~K~s-eJuGT=mwsHewRhun!<#ckm!TyPx!`<!@U8!)@0un{ufL}wMD!ZU
zb-w2->ZtRT)E--ikpM-NpaDYuJRgg>hFamJPK)S~Y_LQR5#6suZ}qMuLj1g;d=#*t
zVihmM08nwRP>O;bl~dq#OBa!>7SnXBSpo@h(3fUZ=~5^><Fx`Bh#(j8Z$#Wu4{z?3
zLQnw#ZqYp|-$dldsN&NQmBQQ{2Zw?3C@qaoLI4i3`-XMSa==xuGC{vKF+n$yMx{<9
zp)gTdYCGDOSZ0D{pdM_{RULX->2n?_t|2aCj>iAsm`mp|<q|%gx59>2Vof6VEOI@{
zK%iEOL+6mP`ZirO2R)*zcq6ZL3uObG5Fd4BmYrK!<FqJkFC*fS-a#VLGK*?gxJ!L7
zpOCF`Y)8a3#3RJHQ_ki%B842f=sgsb4g8E}q<bJJG~+eA72$v9yb4s1zY_91tZl|Y
zX#(}CsvV^;BiyWY<inigW}YJ}u{@(k;%foF0_06qO>K!s*imCnf%^~N0B1&(wMWPK
zo8y)G;8`5GpN$wd(|v5t*lKwQ3V!e+^3UH(`_fG5qIJqc<!=XiEn}TRrf>rg@m%;0
zp`@w#g>fx=B&26gq~?+XqPK|a{f*YIWgo@id9CRBmLmU}VG*It+<NSETg!>vCl0sd
zTAE6mOUkUQ!SpMyZyF8JSwPi2(D~qg2igY8<Iv-**<7gc&#-QDF}1L#=Ji$wpquc0
zkouLv1<iKDGSQ{g7AB=8r@)762kutfT}+?WK>K`q(<+xUIlGS9eb$`XWIDo*<(KH~
zCXOY<&U*7JO()~0gwADAV3xl1yn;&oSo{w#<~vm2Ormxc*^og`LZ)j4(!)%J8FUOX
z-B(jMNok1X72T#b_8QXeJ5^jsS0{>d?)<usm79ry{9wZ+PQ5Y`yx&=*IKyWveV_Cf
DkrWR~

delta 1082
zcmY*YYe<t(7(Qon<;>4*uBAoRR-4z<nG7i^yBMAy1<~bKScW2MLK*H)L0io)8f##k
zg6dcO$_T<5UMk#-B9S6SWD@>KvHH~LLVvW<ujhPoT@HNj`=0muyw7&Jo4cDk;>LO_
z(N6uvw=s)5GjaK&`E5G7^wg`tvIkQ+Lro)vC-W}sue)1T<&Rv|tuPv!4TP|;^gSi=
zXvtQZ9;GOcNf62ho*}KYSyBk;6D^fvbE+ECEDx`gY==zqsv49psPpPW;f?AbVnQe`
zEz*Gq3(EsgQ8U~uIH){FkA^|brz44G`EUj0r^pIv%}l)mNF3)Q(i-1k#1h`%GZx<L
z*C(;`{8H6H*^eSLCV~DISh~|ESV*pg#R3Cn79!DYK!d3X_-nN}?Fa|@g;c#e{!2%N
zq1R$3C}d&JI*ekTWNjzLg=Dc1pdG~}CTLP9T4KW+@J9s>v0?Eq-jlJ#SA(RWd>N6D
z{5ny0{U@4S5iX`}b06pu(7F%_^ot1b?Ns)PJR%Qx4U?C|l<nf43Up&;4c$VIu;<#p
z>%Bl$0@Zqq_L+L*cj&iivo{;&m@q5763lU7I=s5+jY-z*Aq^+1i?eW86oq8L4-3A;
zI&Xf6%>^{7(LJevxn!l3$VA#|Oa~KP$kUiG2r8!etZ4%+;N|9)>UI#;r~Nq!wT=s1
z?#4yqfQ4$5dRD&Dm5-I%49dhT8lHLDNhmp3^Q57~w7Oj|%)gjzId;iT4zO^s(ED~3
zye}JNkLUC(@F`XC%yNgNjdxo<I?OYw>PN|OblL+gV^k-!9}C2xzw-XfB3<?@pUNzu
z=lODLUcoR@zu|``+cM1ObUUO)ETGp<=+hUc!iQ6ZuLWNxZ?aa?c;ue7B8|tbwOq;B
zN}Z8{Rh5hBS>EI-H99RKpAaX%>8eO`FWlS~-nwQPpK;lZf1jr#x5C)C@Ms$&M{<2B
z)XB#Rv#1-=rZ*Eew-ja3Mo3#^OVK!`wcJsBi`w}Rq%+c5QbCs|C*ZMa=MJdOBogW3
Vk4t?<Z729Y^RbewNUeJ~<u^{g*?|B6