From 94935818ceafae7e541eb2e33114d1ba3827d4f4 Mon Sep 17 00:00:00 2001 From: Jeff Tao Date: Tue, 31 Mar 2020 18:53:56 +0800 Subject: [PATCH] fix the remove queue bug --- src/util/src/.tqueue.c.swp | Bin 0 -> 20480 bytes src/util/src/tqueue.c | 2 +- 2 files changed, 1 insertion(+), 1 deletion(-) create mode 100644 src/util/src/.tqueue.c.swp diff --git a/src/util/src/.tqueue.c.swp b/src/util/src/.tqueue.c.swp new file mode 100644 index 0000000000000000000000000000000000000000..40a09d5f638ccd61507bd50661e64d34cccce61c GIT binary patch literal 20480 zcmeI2dyHIF8NhEv1QCP)iGres#p2F(ccRai9s#k10v#ER4@jO37RN~;sXeVhz}xyAc~5{2Y(P12on8$=bZbRM|Yc$_{g2) zx3hE4>pS21&g1*;nO}YGi};ZqzwM>)>vC%*eFH(s{FS+i}0b5SKIc=CLSPiwwa z4_ZrPB00ZU5Av0Tax;HXwNS6Ls#Krf;5IJ~yhgrM2nzY#UaMKC=S%L+{Oks|zEG{Z z`KDjYw}NU-{}Wu&a$D|jap}gg9GM0(4a6E~1?8bLj&RnFtXVA&PwG2S9dq>dI6eC> z(?F(yOaqw)G7V%J$TW~?Ak#pmf&Y6A1dW57x6{k#*`DsR-z(a_pKpI(XTPs#OFzi| z-eJF2+6uyY?Bnb!(?F(yOaqw)G7V%J$TW~?Ak#pmflLFL1~Ls~8u$-rpipw0BWZVs z1ORydANv2#^6-1`9SC3m9(%Fl{1&c(H^9ko65M};<9q=2!TaH@P=Rf*9?pbU!a?wd z!yV^txD{@J&%!%l4kqB$@Z^ge=PtMwE`^Jr3g^HG91Bk!<~ToxufrGNM%V{FoDbu$ z5?%tw!jms_oWH?W;W}tR2`+>=I0aq>eQ+W?eW>I72)+r|z}sLijKk~TWpF$k3V%Pu zaUOyn!kusjd!#@euJOlT^&)_b&1AYMSfj7YzoD3_$ zfq!8ie}a4AX80)V0NU!E0`-%aehyS?Ob(CKp!JfUc23{ic9< zm}?aL0#Zxm+=XdQBgZ!BNWc7=Gi7w1K`nq*$DrEjRZD7MKr29ZVlRUDZqV}UA{0N; zeQMQv^(vol%=(3*+utXxu3Onq)uw8+0%^@N>Z4_nn(J1U`pmzBp<3&$#i{b7Bw7{4 zqkT!!4RWdwc#GBIT%lB&E4x9lGPialQmy1*tfMLh)f#G1oprBTrF$e@j8cO_wHA*2 zs4=F*P)8{g*{j@I(`BH0m2OWk_Lr<8VKvh30a=YTX=}xy`F67zYZu0la{c}N#Y(|f z136KCP7SGM^{uW~PUOmIbtSE7Stho_r^fx+mQm79LCH?9X$tRmTaP!>5rKfrnpS)#H{Ey zX*oL{(k~HHhSpBnaAmU7C_RPK(>pN;3{bI9V|Mj-j*nWUm17Lsv@i0GOZGxI1~T)d zXf%zrmi0&)6)blqoB1K7>C$XCN~{F3sD|d8TwHagFhP{Dt5U5=VJUDxMxK};X5O2n zY|-24Zt}gwZOrs=7m#$je&m?Aw3?o``%`-&=ctlNpPEL}W$DGTCq!gG6E&~tZj%MM zW7UmD#ae|HL0UTG8G~k@ORQXNcBNF{`hMMG0A^=4ynb$CYQx64EmL#T z8)v4rPfu(Nty8xcTmPPA^-y)QN$FrNTxFfa{v!WQHQc&Ufpi(|?zM``gZ7TWfPpCM9?qyS|NROfJnjX7YaJ@bGv$rv6rWfgA!n9aI- z>$->RFeg>(#afH?wa?y5uJk3JF|nBBo% zir1=@RHd-f<$zdpt2^D2DyX8@*sZ)W^}Fhe?PlM~xFk58+u+o!iq&1}?dj&C_n?HHe)9^W#1-l*<_ z$6?al>DF~y)x}1wiUhj~zF(*ZT848rPEVXo{_)pOZl0VyPkFwyHk;_VoJmVnY^*xZ z5xvCOR99B7@7A@-aYD^_biS0#Bb^l#ZlK{bJ<$tNagxX zDpG5^^-piyP221`#XWcy@w#+pkb#SPkI?l}p1v%4rD}P%?b`(7=~ovj0cWk88d<&O zHEMQzYDR6~PW_;otQUvXnffyS>ts!poA$#+Z*k1Y4>;ogUyt8-JbtP8|Ka=l`|$UF z3O|88Fb$`{E8qlp0>A$rxCt(Y3*i(v93IEd|0~=HcfeQRL(qhCVJ#d5kK^nA7;c7l zKphsK4C_H+0VhEp91Taok#IZyzr+UK1sA{un1GkU6ZrZ+g)hU0p$uc7;Fa(czP-c( zehs(5C!hgmLk8@ZXkZ} zB*)R_me%6D>sx12a(4|`XwR>EquTRWUPMvamF%4j>q@$|EaAriYW(FO>^ za6%%*#G$o&E~6NJ?7ssI<6%*yZ6&Er6Xu>!4>v>zRrfF95=fG%Q2Qsk7G zPaP76?wB28>58r;;d)C&sfSS}tr1ck$)ejzmW?IX>1mm5&)X!%!R{Bwu)2QrsH&c6 zTGhj&XH;`kty)#Jx=cEdoo@#uguyByU(qTdKL&D*5gFxIP>2*NQa}!(?rP}D=(!(#y%g|Uj z{#xnL3V^F_f|6@O8(;RSU|te1!hAXwf}x?fz9_lNQjoC49xtY%(ssGf-DWjPyqaQI zmRc;xBJl%8&XzYZ1tYzbmt`SNm0xiObP*D5FXIUx%_AfG|G;eSuy5%WMmaS0zdo}~ zs4E<*aJz|*2FsqhdfxV)wz9r-dHJ{04DRndlH}~3YS%FB{||BmyGh>R;{S*D`+tXz ze>c1X8gLvO3&+4;@bUi)55a@*0DK#+g?;cocrPr#8{u5o4ky49`2F|5*WhNj3a*4p zVJqZ8VgrwfpAVmd>*4+2!wy&h|HRjS2JVBOz<1$0@NIY}yb&ZOFbJ#QXgC;tM-1Rm z_!)c?J_A?70u*5$W?>q(K@J@F4RL`-;8*Z{_#V6qY9O(L(_t-)fW#0Efv1QE`~&_D z_ri^E9b5|^fms-Y7r?>r7;%B$!*}6!_&mH9d^jK81gFAN+y!_PZiQRm8n_xRhxfo` za1O|wfqxO(c@};RkHD>P3)}#g!#r$;*TV7eH1`7@1-U=)X^?vZd!Ymq@ETYHt6%_L z3cuifz-{m?xEiM63^)P~f#-qTA9w)nho6Jk+n3=$J~9hrM+*i4z@7 z%`Vq|EQ-pdcQmtz+r`=L&*A)+H2dy*$y2VWH9qx4$K15^y$@&Mc_?u*iTA;-=O8U~ z=ON65u#=mdlr~SJO(xV)_>J;VVE8eaS=~G9GFckFyE96T_qxSpHAdPGo%_AN(%!Xn|9j5V^emN;kWuM=J4H7UPsi?;UE0@(UbE8-dSYhE zWtMQlnn5;ps-K#rz&f1hH{p8P9?1DKWj@+XPivu@Geeu&eoPA@RW7_QG_=ONhkq{3 zAY7-%OQlKf5pAQrWVEB*1j18{?Qdie<|>2;E9!{_+@CuXS)h5V-`29YOi}gWJALwW zQKNmQPoni=p1W82)ET>@dzS86*Vp+}V&CT5cllDQ%rpHepCA2EM?2yJ_?|;!ZExen zAMN3z8b>qI?6gbm#?Q2)DrLJylCbw`DfjA9RW!%2|X4@dTL$rj>Vz-=_Ou1*dr4+_l%z6C-w{zE?QB}P+gIC-Qk8$}bY+l{-(2 z{h(US3;X2VJsz5?dkLjWQ9WIkyRjtg@HvP#(TTRrd_Tb@YoMayZc(LZ+0o0lSr*!_ z>!AaCBd_bSp)Ydj^=6=fXp3ZTzhP&!XfnyNHy&QAle!}r>>979h6Jn+a9;GdsVLWl tm0WBn6K6BVmbxWtmZe@thlDvt@vnp}nBDonCSV*D>zH$~FVKC~{TrwbDt!O| literal 0 HcmV?d00001 diff --git a/src/util/src/tqueue.c b/src/util/src/tqueue.c index d667b2428f..bddf68932d 100644 --- a/src/util/src/tqueue.c +++ b/src/util/src/tqueue.c @@ -282,7 +282,7 @@ void taosRemoveFromQset(taos_qset p1, taos_queue p2) { pthread_mutex_lock(&queue->mutex); atomic_sub_fetch_32(&qset->numOfItems, queue->numOfItems); queue->qset = NULL; - pthread_mutex_lock(&queue->mutex); + pthread_mutex_unlock(&queue->mutex); } } -- GitLab