From 6039e30be1d20e42cda67a41a98feaaf9cc13ab4 Mon Sep 17 00:00:00 2001 From: pengxuanzheng Date: Thu, 24 Sep 2020 11:24:42 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9example=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- example/singleThread | Bin 17088 -> 0 bytes example/single_thread.cpp | 150 ---------------------------------- example/single_thread.cpp_old | 115 -------------------------- 3 files changed, 265 deletions(-) delete mode 100755 example/singleThread delete mode 100644 example/single_thread.cpp delete mode 100644 example/single_thread.cpp_old diff --git a/example/singleThread b/example/singleThread deleted file mode 100755 index bf3485771183bffcb134eb85fa83c5b31909febf..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 17088 zcmeHOeRN#Kb)UEEmEKzRO0t9{o3G`=)DF?=!?uv^7_V%vc>);}fAHbNJgs)0qz$WG zW%sT85gY^p;*BCI6AEfbQwnKIo05{AkO*=B5xbbANsmcLa8H_3H>qYTx40G^T=!UCjvVoFC*Q@kDejM6r7f-71Sl48*m+HqV$B}XX99hY*)rJRC($*-U)AC--MJ7oF}R}dKC zK>}zY>u(#b#*FE{BY-fOPk$#YVE^aCTCtMQ{YK}sd_s&;n&!_pqFUp;a7v-Grzw7_D!LmojU&6n=g2J zCgrRQZ%_pvj+*>r|>-J49Ck$B8X*k+`^A8neMZ9BG_Q7dKj#L~8v z+Oc(0Jeja|guCJvGtHj9WWr3_;goHf%)EBM+$Q-p#lz{el@{WKg?BZ!II@dcX*-$P z*U`AfLF^4DqH)WFnph%cGjmttRXjCig>B31%0zCn?7|Wq*F~7w4Ji_8B%x%#l`y-b zMcKDEnH^gOx(Ez}wy!k%xM-8GCYiP%+t&we+`c`jm~HhT6HXFV4OppI_rBk6l`4dE zGcOA?ZErB~-$%8Owxf|NucRKOnb5vmtS1sN(}Xn=JtFAcR5I3|iY4rB)*Xq%R@M!z zQHFTrHnYdF?O311!gdlxGD%QYSzkDoV5Suf+hHVhrPG2AQXQ;hPJm7&aP>1+qlVW3N&7oi#7#Ti-smTP8aXxC@%1`X)dPa{-~dGv2XG=EI1xI z^dP!(Hw*ChfU(Tdn3r^{k!q$d?&OTr=a&i*{;ZYn1<{}`7yJ&o(~{*5y84!oP=kZ+ z{NA=W=+5s=&_Q?FV>syQ+erF59CQ>c7jAaY=jW*S9y;h{4tlSHzR*GMchH?5g}n~C z{KRspK?hxZ8!6$SgYN8qjiFPzG3~Z{gpBFAE!HZv>lx|jULxH`obUwNAFq?WRu?o z*8^<@mLe|!-b?2B?HRPTKL7)F8MpET?h&znD#>0ZE6Eoo>sXMm|RN)%NUB zBbxzoVA{y;JYi(FP8!3Z6GrS9`{7sCAv$S{EN}syCQ`F?1kq_@#rKWuF++Q4_hGJY z=u`s~OhOS9>^x3V&sAVlXk?F0-uJ=GjFAmZ9}S)1WgHG2H;z&ab|08#nbL7sHS@X! zAqZ9goG?Z{K{>*p7oNeFl+gf)O`d#zW+odtGj!k#+b4w@q|k8aj4@_t-{)wy;!dzY z%>Fx}FZwar0pOAqb8Nq3y<< zr^Z;2WuLu$=6RIpseXVVj?A;?^FmBbz|f3w=;5xn{wJ)ZaDG5PP1g1(pF%9mJ1 zTCo;Z7{jQ`VI*XKP6}3l@1BYBKbg3DLfKk9m+LUNhE8i|c}^qCqoE_@e&c9p5P%sY z2L_=WB|u#xgW;`5vI{P6eVWqRveQp*#mhoD_K;;`ux-#72|Yq>nzT%w_}$Em^w8^m z=s5@-;CPA(%yp3L!(bW;ozjLwr`CmDx&1gajOH|a4T%sMh47d$eBcon^0<+G8E@32 z|9$R_@nQHe0t-Xq;YT`|(PT)Dhg?zT#x#FN_!7cT z(y69TBApM6lzcx==5~A?>F*-_Eh?i*H-_BqDNQheOg8)ozhm%?1;{q~D*o6N^3~qw z4*C2e^FqGmU-B5fhI>m4U&~PGR$nmgYiad0wEC8B^!YdXYQewJr*nVM+c^zAvumD| zo(tzZaLxngJaEnf=R9!E1Lr(&&I9K>aLxngJn;Y51OBq0Fit^fs+=y;bdm=JzaS$D ze=rY!BoC)GX$oqsv|LV_76@`~UuB`h)qctniK~6q^Ciyb!H6%F_)Bs>mFAfgRQi8^ zFhg5jY|IrTklXXE@CaP3Js)!kT&)#{qn%s)$mJf`U55?6Ms{M4GZ!m-H2%X3ijV@l6)RS%~nexpp6+5MjbwU3>j(SY19 zyH~;oCHyN1za!y`68>Dm-$?kDgeCKXT=ilJuaK}=!YvZsC?PRlvuV>>|8ndMukf!5 zv;{Vy%oald8NagSkljlp6kIm zZ=MHRRuJ%1fasbezAwc{(G$cpLQ!aIhJmhEDe(cKcy!l`lrT<6iT(|WYbAR~1HD-D z8lJ_ol=iTXd)~SlV*2xld*1HClj$#l&-312QdED3=u}m`2EQ?+*ykIMU!f4wA>kkrwa2kcgWjLGMkZ%fk`FdzxfQIMU&5C7Du=-0Y=A zP>)v|07Iu2apo!0ZU@rqJwY-HwJy;5y-P`3B}Z&;7v)o>^&@4kcRe9B+7=*#-tC0c zYCC}3<$a8hCE8ukGvs{@B+rG~{Xh1t_1YMaG4Dn~8aVQZw~dfS zjy&$|Af$;SPkL`6WTjRInQ`x>WZP=a zpF*NmO=VS$z5{Uz+E-gClb?c1t9}M@u0x%bv}>xc4z{S5_?BWLlXW5XXJtV=8GDjH zNyBrb;UrLPDV4`{=;jKlSZyh_HrJt!$~d-lwWY-7I%HIRODZ7yDO7j&Gwp&SJhitv zk?CXFg_M!&5Edm%bh5fc{|7wJGr*%Y(D4LXMW-P5X<@|Tc`$;$a9YEA+=zI^Cpo(? zsk6f5Y1BqwAY1%5gs!7}X#0u+U%CX;zIwg~x^5?za0btzQy-qct_1MV9_>FaomR8-Bx07{8Z$tZeaPdTViNr1RYt2DQ-tc-*-p!&j`h8D1SCF*IbB6PmekJm!e z+Nwxm!6mG%sve08uRsJ1x(XUTfiX#W0Gfp{WM8oMp^ZyOpu&^O!d1&yB~V?k5xOX# zZCE1Y627)7A^D(?tSUp97vZg{UNuYRJg3YoiN$AA@^sZeg|v>ct)=3?y}U3b@a}!6 zY8ShJDqQ=WZy}!i0_tFWC01nyEI28vzu=f(^r7yI-uir`|iY5qhEQu)IQ5?BYQ98^ah-b?R9Bms7 z#HD&FceUoatV*xf+pccZ*X!41p4hX;wY;i#z`b9;dF*?)H0td=jrw($H0ncNel&CP zr2Yl{%lh~BJf{EsWBQlf=Y1_RCD)eRt5@l->bK~-pS{I3AO1HZ zy>xuU9xxMWE5cG%nzoM2wj0bXZS5hxJtR*OiBmib@1U8E?YBsTB#1Q~9?726eOD$Hk1~GBCD}!-gW)tw#N?-8%vMcffbuDL|Yp3D=bGLw6i`aYBNG_R7yt`>4mS2%K87tSbk416U2&u!~w!rF@*%>Hn+Q2_XYu$2O=5@0nG?O|5IFe>(M zy7J23Gcd+j*I(CXXA;)>9xH((SrMS&RHS#kIH&2a>)|C7KA=*Q3k1eX%$o-}it0Xr z190Rz)h^(NOuzKpuEtff+a@_E(t$H#ylJ6e=zP$6RCD1Cidr|l;fxv~_DmzxB)NZ? zl}aUrHT}Hy3&&Js}ZkA|#{8X3CSRlQx4-E#;P6^nnVrU3fs-FcCN!tpvZfvWw z!#xt~Nn`^2#i)x#S%9$KaJrWTqWcoiCm_7SQ*fj$9ZM!=AtusNRy<4sGS-h5Kfq7u z1#GI{06%yaNG16T9I$%L?o_zXGJB(tRhW=4!>LqwpO8@T&qTlm?cu&y1X(Ac5RU-Q zMQFrPH5P~@`}(lw3|6Zv(*xmfq6a4qB^pa~CsjP$)s?aa6oyl~mWsn))NK|GZuHJA zuHc+>H+t$F1?g^__$b6bFE^ieDs!XTK30&w1Rv%?dP-TLd9oWrS~b6(t>4SkJbgBO zer`TLn?CovD5bmE0?bl^PF5awvxT|y^3FszD{#IP3~pLYDGxeXdEAY$e`i5@C3~_U zeNpZlyHlAPC#TiA%4~WyqmxVd!Hw0CLhAr-wwS4NhE5qboxb)L(o@Su3)1JF%O!p8 z+$xY$JJHo@Q9fO*66Mn`oK29Jn_X0dP7|Kl0pkyhFy5S*O~ptO1P!Y}`F^AIEf?y2 z)Uj?svH?k-$fLJPI+GI^;-zpCej3g>tMklc2Ze6@v;y@w0y^cJTlXVogg?bk!%1hg z-o}Y|jN@0RTt5Vz^r(?iZcbN(|JR^vtdi-KLB!66HxVu5AL1yK@B3VI(VX__;{~5< z|0SSn1=`zHoIbbR20?e8)8yIVk>vD+b0%zd5&naqS7H!O#|xd|0jZ}muYMl}-S1?S zaau=NRG=StR_dYCkQ6ZH<>AMiE)fSf0Xm&~&wsz(;PkWYM~S>sL{AwqD&(JKpcguC z|1r@0N~r_VIpjimwico9FG3$FLVp7ELg)Oy4SFGaUMiyJ7o3iEF6Y~7(*K5}(=k*E z7JoAKei1z_?!x8m;qZe*BSwzX~znW5`9)BOxyNEN5?T23!U`p%5x zMBtkC8#cDKn>TFPvOToJ+|jzRJp?VAZ@Ip8Yul!edK-gJ!^ACxU{Kv2peqBWiAyEQ zL^TEZUoM@9TOHyaLnNJ1w>;+F%P?uMsID|Pt~by{h}kC0x+rlr33nU#Brorti@0NP zmW>zUqugfUw=?F*i>oa~ZiT2@8ilUd>}s5QOC^8WChvWaztmNlKj2mjH}%8bcM_xugWQlGpGD_OZkmbq1ss zFBKs7%&-3}Qk?Q?ekXRLWMWR5#v~#r_<&?l`FF~3VW-@XzCSNRC8t!@V{%2~OK-(Dzy9LNSmH!msaYQJ8CEqFK)&1jk#VBE3aoBhA!3RA&&|vIf`3$i z+*8RZcm^p>c{RTn^$U^w`p&CP_Ab~+mny%S$3E~OdiU(O9Hg#4YVVg#D=mC{oQdL9esocOp9Fcf2+yhOP^)psZwK|LU_Y1xlo3UnpW Y1sO9S5vYGFls{`0>F?$x=9$C(2OP$d00000 diff --git a/example/single_thread.cpp b/example/single_thread.cpp deleted file mode 100644 index 71a4e6a4..00000000 --- a/example/single_thread.cpp +++ /dev/null @@ -1,150 +0,0 @@ -/************************************************************************* - > File Name: single_thread.cpp - > Author: pxz - > Created Time: Fri 11 Sep 2020 09:52:05 AM CST - ************************************************************************/ -extern "C" -{ -#include -#include -#include -#include -#include -} -#include"../src/hos_client.h" - -//#define test_times 10000 - -#define debuginfo (void) - -typedef struct userdata_s -{ - struct timespec *finished; -}userdata_t; - -static size_t calc_time(struct timespec start, struct timespec end) -{ - return (end.tv_sec * 1000 * 1000 * 1000 + end.tv_nsec - - (start.tv_sec * 1000 * 1000 * 1000 + start.tv_nsec)); -} - -int file_to_buffer(const char *file, char *buffer, size_t *len) -{ - FILE *fp = fopen(file, "r"); - int num = 0; - *len = 0; - if (fp == NULL) - { - debuginfo("fopen file failed:%s\n", file); - return -1; - } - do{ - num = fread(&buffer[*len], 1, 4096, fp); - if (num < 0) - { - return -1; - } - *len += num; - }while(num == 4096); - fclose(fp); - return 0; -} - -void callback(bool result, const char *error, void *userdata) -{ - userdata_t *data = (userdata_t *)userdata; - clock_gettime(CLOCK_MONOTONIC, data->finished); - return ; -} - -int main(int argc, char *argv[]) -{ - if (argc != 4) - { - debuginfo("usege: singThread [bucket name] [object name]\n"); - return -1; - } - struct timespec start, end, finished; - size_t time; - int i = 0; - char *bucket = argv[1]; - char *object = argv[2]; - int test_times = atoi(argv[3]); - //int test_times = 10000; - //char *buf = (char *)malloc(1024 * 1024 * 4); - char buf[1024 * 1024 * 4]; - size_t buf_size; - int mode = FILE_MODE; - size_t fd = 0; - userdata_t data = {&finished}; - - file_to_buffer(object, buf, &buf_size); - - debuginfo("hos_client_init start ...\n"); - hos_client_handle handle = hos_client_create("http://192.168.44.10:9098/hos/", "default", "default", 4); - if (handle == NULL) - { - debuginfo("error:hos_client_handle\n"); - return -1; - } - debuginfo("hos_client_init success ... \n"); - - debuginfo("hos_create_bucket start ... \n"); - if(hos_create_bucket(handle, bucket)) - { - debuginfo("hos_create_bucket failed ... \n"); - return -1; - } - debuginfo("hos_create_bucket success ... \n"); - - debuginfo("hos_verify_bucket start ... \n"); - if(!hos_verify_bucket(handle, bucket)) - { - debuginfo("hos_verify_bucket failed ... \n"); - return -1; - } - debuginfo("hos_verify_bucket success ... \n"); - -#if 0 - fd = hos_open_fd(handle, bucket, object, callback, (void *)&data, 0, mode); - debuginfo("hos_upload_file start ...\n"); - clock_gettime(CLOCK_MONOTONIC, &start); - for (i = 0; i < test_times; i++) - { - hos_write(fd, object, 0, 0); - } - clock_gettime(CLOCK_MONOTONIC, &end); - time = calc_time(start, end); - time /= test_times; - printf("hos_upload_file spent %llu ns\n", time); - debuginfo("hos_upload_file end ...\n"); -#else - - mode = BUFF_MODE; - fd = 0; - fd = hos_open_fd(handle, bucket, object, callback, (void *)&data, 0, mode); - debuginfo("hos_upload_buf start ...\n"); - clock_gettime(CLOCK_MONOTONIC, &start); - for (i = 0; i < test_times; i++) - { - hos_write(fd, buf, buf_size, 0); - } - clock_gettime(CLOCK_MONOTONIC, &end); - time = calc_time(start, end); - time /= test_times; - printf("hos_upload_buf spent %llu ns\n", time); - debuginfo("hos_upload_buf end ...\n"); - -#endif - debuginfo("hos_client_close start ...\n"); - if (hos_client_destory(handle) == 0) - { - time = calc_time(start, finished); - time /= test_times; - printf("hos upload finished spent %llu ns\n", time); - } - - debuginfo("hos_client_close end ...\n"); - - return 0; -} diff --git a/example/single_thread.cpp_old b/example/single_thread.cpp_old deleted file mode 100644 index c11f6dcd..00000000 --- a/example/single_thread.cpp_old +++ /dev/null @@ -1,115 +0,0 @@ -/************************************************************************* - > File Name: single_thread.cpp - > Author: pxz - > Created Time: Fri 11 Sep 2020 09:52:05 AM CST - ************************************************************************/ -extern "C" -{ -#include -#include -#include -#include -} -#include"../src/hos_client.h" - -#define MAX_TEST_TIMES 10 - -static size_t calc_time(struct timespec start, struct timespec end) -{ - return (end.tv_sec * 1000 * 1000 * 1000 + end.tv_nsec - - (start.tv_sec * 1000 * 1000 * 1000 + start.tv_nsec)); -} - -void callback(bool result, const char *error, void *userdata) -{ - //printf("result : %s\n", result ? "true":"false"); - if (result) - return ; - //printf("error: %s\n", error); - //printf("userdata:%s\n", (char *)userdata); - return ; -} - -int main(int argc, char *argv[]) -{ - if (argc != 3) - { - printf("usege: singThread [bucket name] [object name]\n"); - return -1; - } - struct timespec start, end; - size_t time; - int i = 0; - char *bucket = argv[1]; - char *object = argv[2]; - printf("hos_client_init start ...\n"); - hos_client_handle handle = hos_client_create("http://192.168.44.12:9098/hos/", "default", "default", 4); - if (handle == NULL) - { - printf("error:hos_client_handle\n"); - return -1; - } - printf("hos_client_init success ... \n"); - - printf("hos_create_bucket start ... \n"); - if(hos_create_bucket(handle, bucket)) - { - printf("hos_create_bucket failed ... \n"); - return -1; - } - printf("hos_create_bucket success ... \n"); - - printf("hos_verify_bucket start ... \n"); - if(!hos_verify_bucket(handle, bucket)) - { - printf("hos_verify_bucket failed ... \n"); - return -1; - } - printf("hos_verify_bucket success ... \n"); - - printf("hos_upload_file start ...\n"); -#if 1 - clock_gettime(CLOCK_MONOTONIC, &start); - for (i = 0; i < MAX_TEST_TIMES; i++) - { - hos_upload_file(handle, bucket, object, callback, (void *)"this is userdata", 0); - } - clock_gettime(CLOCK_MONOTONIC, &end); - time = calc_time(start, end); - time /= MAX_TEST_TIMES; - printf("hos_upload_file spent %llu ns\n", time); -#if 0 - for (i = 0; i < MAX_TEST_TIMES; i++) - { - hos_close_fd(i, 0); - } -#endif - printf("hos_upload_file end ...\n"); -#else - - const char *buf = "this is hos_upload_buf\n"; - size_t buf_len = strlen(buf); - printf("hos_upload_buf start ...\n"); - clock_gettime(CLOCK_MONOTONIC, &start); - for (i = 1; i <= MAX_TEST_TIMES; i++) - { - hos_upload_buf(handle, bucket, object, buf, buf_len, callback, (void *)"this is userdata", 0); - } - clock_gettime(CLOCK_MONOTONIC, &end); - time = calc_time(start, end); - time /= MAX_TEST_TIMES; - printf("hos_upload_buf spent %llu ns\n", time); - - for (i = 1; i <= MAX_TEST_TIMES; i++) - { - hos_close_fd(i, 0); - } - printf("hos_upload_buf end ...\n"); - -#endif - printf("hos_client_close start ...\n"); - hos_client_destory(handle); - printf("hos_client_close end ...\n"); - - return 0; -}