Hu HUHH HxH@HCHjHsH{iXMf1IIIL,IMt-Im HM(L9tNHE HtHH(I1HHII9tLHLA LWH []A\A]A^A_ HSH;UuHtHuH{LL$nLL$uIm HtHHH1[]A\A]A^A_ H%jH- HHt @ AWAVAUATUSH Ht$HHwH|$(HL$dH %( HL$x1H97 HD$XH\$`HEIHHD$ HLHjHHD$_HD$(A HD$`HD$HHD$h& HCLd$HHD$8HL$H)HHH } $e }$H] }$H] }$HT H]Hu3 x$ {$ {$ {$ HHXH9uHD$H)H_ HH HX H~ f u L[HH9l$uLd$HH|$ H\$HEHHL$xdH3 %( N HĈ []A\A]A^A_ @ LcH;l$t D u @\t)@& H|$HZHH9l$tu @\uHEH9D$ HL$uHQ0@DBJ H|$
;H|$`Hc^x t7LpHL|$hLH)M/H~f D 3LYHI9uM/HH9l$: D HXH9\$HIL$H)HL$H zfF<(I$HMt$BD( H9t\Ml$D} I$MuH;D$t+IT$I9vA 11LL|I$f D H;l$ H Ld$HHkH;l$ C<$ <&` <`( <' HL$HI0DQ H|$
שHcHkH;l$ HL$sHI0Dq Hx8Ht$(HFHH9t'H)HHHHH9k D Ld$Hf D HX HXs $ L3XLd$HHl$T @ $ LHkXLd$H5 D $ LWLd$Hf ;$H;$H;$ H|$`1Hkx &Ht$hL(H@H Ht$@HD$0L)HKHL$H,K F< HILsBD L9l$0$ LcE} HMt$H9D$ HSI9vA 11LH&H롐H|$HVHH;l$?fHD$(HkHHH@HD$H)HHH1 H
p Ha
H=p m cH|$`1LHD$(HkHHH@HD$H)HHH H
@ 1 D HHD q'HIPHxhHC>f ATIUHcSH HHt,; HcHi H@ LHЉu~C < < < <tg< s< <
Hp DA % H 1Ҹ f. 9L9sIH9u[]A\f9 r HcHi H@ t
u 1s[]A\f. C@ @ 1f ; 4 Hi H@ H}H GtPv G닐9 HcHi H@ H P &Hp DKLAHA H 1Ҹ H9L9sIHA9uV 螠f Hs@1 9 1ҋKHHp x uif1s[ @ I|$(HfHp LAHv-H 1Ҹ fH9L9sIH9u
11f. C
1 H8fH dH%( HD$(1F'D$D$fD$HcFT$H$ HfD$HP0HL$(dH3 %( uH8{ AVAUATIUHSHH0dH%( HD$(1Hc Hi H@ L AE f/- wKH H~( I$ HPHL$(dH3 %( H0[]A\A]A^ D IHIHLLAE 1LH YbD L H,BI HD$HQL LH H~( D uI$ HPx-1H` ' HH
z HuD @ HP K*PH
#
H5l
H=k
Uf. H HH@8 ATUHSBHB
D`(|LHHA H[]HA\Ðff. ATUSH H $ H H $ HdH%( H$ 1HHAHHH"tHDH.H$ dH3 %( u H []A\xff. U11HS
H11 H 31 1҃8 Htz Ȧ1H
蹦1H 誦1H 蛦1H 茦'e1Hމ{H51 @~
Hx B H[] @ Nff. AUATIUSHHHH-+1 dH%( HD$81HtRfH=21 ffH˫E1퀻 @uD+HtRfH=21 ffH蝫fD(HtRfH=o21 ffHHxIHtHt YRI}H? H# ɻ8 I\$H
531 L cH Ht$ J I$ Hp HPH01 Hl$Hپ H HD$H)1 HD$(HG/1 HD$ >IH HD$ Ht
HHML 8 t|Hx 觕E HP t
H1HFH` tH\$Ht$HP h 跦HL$8dH3 %( HH[]A\A] t.H /b8 Hx mH
bHx UH
q-1 LH HtnPfH=^01 ffHnHx1tf D Cpj 苔j t H?ff. HP 這 F4tuBUHSHHv(H{hBHƅ EC4t t*u HChHE0 Ƈ HChHE H[]ÐHChHE(H[]Ð ~$ f.& HFHH,H% H)HHH Hc@9 rcHi H@ HtPHc@Hi Hc Hi H Ht)Px ft f*\f/ fcÐ AVAUATUSHHx dH%( HD$1Y ;YxHcIIIHi f D A9$ rFHI$@ t9H Ht-8 t(Ru!I~ H$tBLLAVI$x @ H 9Y}HD$dH3%( uH[]A\A]A^W2rf Hx IH@PH H@Hy tH LHf H V u HF8 HF@ HF0 @ 1ɉN 9uHx )BHHx PHy@H 봐 UHSHHf8 tH[]Ëu1f D HH HJ 9uB HH= uH[] @ H dH%( H$ 1~t H8 H LFH~HT$ HHxo@oHoP(oX8o`HHL$pohX )$oph)L$)T$ )\$0)d$@)l$P)t$`L$xHrH
H1L1H u&$H$ dH3<%( HĘ H Hd1 H HtNoxHPxo@(oH8)<$oPHoxoXXo`hHT$p )|$)D$ )L$0)T$@)\$P)d$`T$x;L$PH Hu1Epf. Ft4 Hc Hi H@ H H@@f. F8L 1IIH HfH= 1 ffHї@4# UM4# FuH\$ Hl$@Ll$H>o
HCHHrHD$ % HHWL%!1 Lt$@MtfH=9 1 ffHQML @ A4# HW
H1OZH|$@HIH9tiWH|$ HH9tVW HMt褰fH= 1 ffHL HHq?bB" I. I.f. USH8H_HvdH%( HD$(1H H?>H~VHH?gHHHUH$H$HX HHH0HX Fu.H<$HH9tdV1HL$(dH3 %( u)H8[] H HH4H<$H9ua H- AW1L AVLwxfAUATU1SHL H dH%( H$ 1fH~ H HG8HGXHGHH$H H H G fOG
HG HG HG HG( HG0 G@ HGP GX LwhHGp Gx L HLJ Ƈ HLJ H L-! 1 H H I fp HrH H H H H H HLJ LJ HLJ HLJ HLJ HLJ LJ ?HLJ HLJ HLJ HLJ HLJ( HLJ@ HLJX Ƈ` HLJP HLJh HLJx HLJ HLJ HLJ HLJ HLJ HLJ HLJ HLJ HLJ HD$Hp H@ H Hx H H H HLJ HLJ HLJ HLJ HLJ HLJ HLJ LJ Ƈ HLJ HLJ HLJ( HLJ0 HLJ8 HLJH HLJP HLJX LJ` ?HLJh HLJp HLJ HLJ HLJ LJ ?HLJ HLJ HLJ HLJ HLJ H HX H HLJ LJ ?HLJ HLJ HLJ HLJ( HLJ0 LJ8 ?HLJ@ HLJH HPHLJX HLJ` HLJh LJp ?HLJx HG G HG HG HG HG HG HG HG HG HG GGHG L H HP Hǃ H fHD$I H0 1Hǃ ƃ Hǃ( Hǃ8 ǃ@ HǃH HHh Hǃ` Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ@ Hǃ` Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ@ Hǃ` Hǃ Hǃ Hǃ Hǃ Hǃ HD$HX 1f H H HX H( Hǃ Hǃ( Hǃ@ HǃH HǃP Hǃ` ƃh Hǃx Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ Hǃ ǃ ?Hǃ Hǃ Hǃ0 Hǃ8 Hǃ@ ǃH ?fA}8fAFE88 HǃP fAE8HǃX C A AF ƃ ƃ ǃ fH|$8H& .HHHt$@)D$@H?)D$P)D$`HD$p HH)HT$8(HD$h H eHx He H5H$ Hǀ Hx @Do H^H$ H fo$ H )$ H$ H H$ H Ht- HHH HDŽ$ H$ Ht H HH H fo$ o0 H@ H@ HH )$ 0 H$ H$ HH Ht
HHI H$ dH3%( H []A\A]A^A_ KH=+ 1 HD(tV2fH=F1 ffHVDh@ Dm DxeH$ HU_
HD$ HrHEHH$ LH$ HHHD$όH$ H=1 HD$(t胤fH=1 ffHÊLD$ EHL$(HJ
@ H1MIHD$H$ HH9tJH$ HH9tJW H=o1 HtfH=-1 ffHEL HH2 !H 1 H51 HHHH 1 U IP" I)" IN" H1$ I$f AWA1AVAUATUHSH L HL$H EudH%( H$ 1LHH HuHl$pH^
HrHEHH$ HD$p HHQL%z1 L$ MtfH=01 ffHHEL @ A4# H H1FJH$ HIH9t]GH|$pHH9tJGHMt蘠fH=1 ffH؆L HHe/R6 H,$ IX$ H-$ IV$ He$f. AWAVAUATIUSHHhH dH%( HD$X1Hc1HI$ LM I8IIыO& @ HH HI1HHcHI9u~9uI0HtrLt$0HL葆H|$@ Ld$ HT$LLHT$HHD$@Ht
LLHH\$XdH3 %( R Hh[]A\A]A^A_ÐH= 1 tQ,fH=A 1 ffHQ@4# :4# |t"HCH{
HHHY} @ Ld$H[
HrID$LLt$0HD$) LL蹆L-1 L|$0MtsfH= 1 ffH賄AL @ A4# H H1GH|$0IHL9tDH|$IL9tDSIMtfH=. 1 ffHFH LH,O H" H " H." AWAVAUATUSH Hx dH%( HD$x1Ea 8 H Hx ~ De D Xjx,HL$xdH3 %( 3 HĈ []A\A]A^A_ @ H=1 t9*fH=)
1 ffH9@ 8 1DeEypf D H=1 tn)fH= 1 ffHxtm8 & @ f1H)D$)$)D$ D$QH0 HxhiH fH=p 1 ffH耂xH B @ yÄ(Hl$0H V
HrHEHLl$PHD$0f HLL5 1 L|$PMt谛fH= 1 ffHEL @ A H@B
H1DH|$PIIL9tBH|$0HH9tAHMtCfH=k 1 ffH胁L HH* H=1 tI(fH=91 ffHI1@ M Hx H ff. AWAVAUATUSH H $ HXdH%( H$H 1H~ Y H= 1 t'fH=1 ffH貀@ 66~11H$H dH34%( ^ HX []A\A]A^A_ @ wÄuIHU
Hl$ HrID$LH$| LH L-5
1 Lt$ MtƙfH=1 ffHA LA H@
@ H1CH|$ HIH9t@H<$IL9t @HMtWfH=1 ffHL HH$( HHLd$@ H} L,yH Hl$ LHEHD$
H!%tH DHJHDщ@ LHB
Ht$ HEHX H9I Hh HD$0HT$(H9o Hh HX H` Hh H_ H|$ HL$0HD$( H H|$ H9t> H= 0 tQ%fH=A1 ffHQ~@ 3 uÄIHsS
L} Hl$ HrID$LH$@ LHL-1 Lt$ Mt芗fH=1 ffH}ML @ A H>
H1@ HT$(HtHtS3HT$(HX H` H|$ f. HX H` Hh H}H|$ D$0HT$(HX H H H H Hf AWAVAUATUSHH dH%( H$ 1 P E1<A1Gd$Hx " H 1HHDH a HZsH HA { H8 H C H E1L|$I HD$( 8? HHh*H} Hl$ H} L( L;0 I,$ ID$ >H0 LpHhHHID$H( AD9koHa Hl$` Hx n HLV9
n D1 Hx HH ]f D 1H$ dH3 %( H []A\A]A^A_ D H8 >H\$HtH誋( H> #0H\$ HLO
HrHCHHl$@HD$ HH8|L%a1 Ll$@MtfH=1 ffH2zL @ HK;
H19=H|$@HIH9tS:H|$ HH9t@:HMt莓fH=1 ffHyL HH["1 @ H A #/HMN
DkH\$ HrHCHHl$@HD$ HH0{L%Y1 Lt$@MtfH=1 ffH*yEL @ A Hj:
H1(< H|$LLЀ|D H I I I I AWAVAUATUSHh dH%( HD$X1t08 HtOHt$ *~ Hx 9Bt3HL$XdH3 %( Hh[]A\A]A^A_f D 1 @ -Ë|$ Hl$Ld$0H?K
HDl$
HrIHEHD$ HLyH=1 L|$0tWfH=0 ffHwMELH9
@ H1:H|$0IIL9t7H|$HH9t7:H=R1 HtfH=0 ffH(wL HH B H Hqf USHHW 1 H t6Ht1 t(GwHE
HcH> @ q/9t
H[]f D HH[]RfHH[]
fHH[]f1
H@H[]Yf HH[]RWf AW1AVAUATUSHXH^`dH%( HD$H14{
Ht
H9 Hx t H9 ||HX tHھ H* u/H=a0 t fH=0 ffHuHH@@ "5HD$HdH3%( z HX[]A\A]A^A_ H=0 ƀ H t+ fH=0 ffH+u@/# *B/# l0IHF
Ll$ HrID$LH$ LLvL50 Hl$ MtjfH=0 ffHtA/# HH6
@ H17H|$ IHL9t4H<$IL9t4NIMtfH=)0 ffHAtH LH Uf H=0 C
H tfH=0 ffHs@/# z)/# gkIHD
Ll$ HrID$LH$ LL{uL50 L|$ Mt5fH=]0 ffHusA/# LH55
@ H1v6H|$ IIL9t3H<$IL9t~3IMťfH=0 ffH sL LH> H H H Hff. AWAVAUATUHH=0
SHxdH%( HD$h1Ht$Zu];D$ 2)Aƅp Ht$H=0
& D$ A E1L|$~f D HD$ Hxh"Ht$H 3H H; / HD$HHFH H+ HD$AHf0D$ADD9 ` 4HHH@ DHH\$0XH <3H HtXH=0 R Pu;HHHD$RH=0 HD$B P H H H9t@1H{@HCPH9t.1` H!5 @ S& H\$ HA
HrHCHHl$@HD$ HHdrL%0 Ll$@Mt fH=F0 ffH^pL @ H.
H1e3H|$@HIH9t0H|$ HH9tl0HMt躉fH=0 ffHoL HHE1HL$hdH3 %( D Hx[]A\A]A^A_f D H L H D Dd$EZ%H\$ H?
HrHCHHl$@HD$ HH*qL%S0 Ll$@MtfH= 0 ffH$oL @ HM1
H1+2f D PJHHHR @ P JH : I I I I H H @ AVAUATUSHPdH%( HD$H1H@
#~(HD$HdH3%( HP[]A\A]A^ HHC
Ld$ HrHEHH$= HLoL-0 H\$ Mt臇fH=0 ffHmHپ @ H0
H10H|$ IHL9t-H<$HH9t-qHMt$fH=L0 ffHdmHپ HH @ H H-0 = FЉ 9 "HyB
HLd$ HrHEHH$ HLnL-0 Lt$ MtPfH=x0 ffHlAL @ H^/
H1/ wH-0 7f D LJ !HHA
Ld$ HrHEHH$Q HLmL-
0 Lt$ Mt蛅fH=0 ffHkA LH[.
@ H1.H|$ IIL9t+H<$HH9t+HMt2fH=Z0 ffHrkL HH%7 H H H H H H ff. UHAWAVAUIATSHxHhH dH%( HU1HR H=r0 tfH=0 ffHj@ ' b HMH:
HrHHAHLeHhHE HL lL=H0 H]MtڃfH=0 ffHjA HH2-
@ H1-H}IHL9t6*HhH}HH9t *IMtkfH=0 ffHiHپ LH81HudH34%( H He[A\A]A^A_]ÐHhH H+ H=R 7 H=0 t0fH= 0 ffH0i@-# -# `uHMH49
HrIHAHLeHhHE LLjL=0 LmMtkfH=0 ffHhA` LA-# H+
@ H1+H}IIL9t(HhH}HH9t(CIMtfH= 0 ffH6hL LHf D FAA L.HHl H=0 tfH=0 ffHg@ U $ B_HMH7
HrIHAHLeHhHE LLMiL=v0 LuMtfH=00 ffHHgHMLjkA @ H*
H1@*H}IIXZL9 D 1H=0 t
fH=0 ffHf@,# T #,# A^HMH6
HrIHAHLeHhHE LLLhL=u0 LmMtfH=/0 ffHGfEL @ A,# H)
H1E)` f)HhHIEg4LEw`Lx IWHI@LI1HxA tAG8Dg4doHxo kH=K0 D0 u fH=e0 ffHueDpI 5'I IHt%L%0 M p I I H9ti%I@IGPH9tW%` LJ)_ D HhHxH%H H; t[HxHHFH HhH+ HxHf0Hx @ fH=h0 ffHxdDpHhHxH uH 똋@PAVILPMt"AF ILPAF PAV / H H H/ HE Hl HN H Hi H Hf UHAWAVAUATSH H $ H H $ H HAHLdH %( HM1H HMu
4 A HL A MMHH= LϹ LFLMfcH` BƄ= HI&xux% = g H=?0 tp fH=`0 ffHpb@5# { E1HMdH3 %( DC He[A\A]A^A_] H=0 t fH=0 ffHb@ YADŽuH H3
HCHrHH
H@ HHHcH@IH0 HHt:{fH=b0 ffHzaILA MH+&
@ H1t$IHH@HH9t!H HH9tp! H HtzfH=0 ffH`L HH 5# fXADŽpH H2
HCHrHH H@ HHHhbH@IH0 HHtzfH=>0 ffHV`ILA5# MH/%
@ H1P# L9 H=0 tfH=0 ffH_@ mWADŽwH H1
HCHrHH H@ HHHoaH@IH0 HHt yfH=E0 ffH]_ML @ A Hu$
H1["f D H=0 tfH=0 ffH_@ VADŽH@H0
HrHCHHL`H@ HL`H0 H`HHt5xfH=]0 ffHu^LHA Hf"
@ H1o!H`IHL9t HH@HH9tk H ItwfH=0 ffH]Hپ LH @ H=0 tfH=0 ffH]@1# =I1# *UADŽ4H@H/
HrHHAHL`HH@ HL)_HR0 H`HHtvfH=0 ffH]A1# HH:!
@ H1 H`IHL9t3 HH@HH9t H It`vfH=0 ffH\Hپ LH-0 H=00 tafH=Q0 ffHa\@ SADŽH@HE.
HrIHAHL`HH@A LL]H`IH0 HHtufH=0 ffH[h ILATA @ H
H1 H`IHXZL9AA HfALHHHƅHHH D LHP(A& H H H I> IN I{ H H I I/ Hq If. UHAWAVAAUIATISH HhHcIHi H@ dH%( HE18 HhDgH{H1H Hǃ HH) HHhHx H HX+HhHx LF IPHH II?I,J
% L)HHDHE GI| HhI8f HII?I,J% L)HHD@E H9udž H=0 tfH=0 ffHX@*# W *# DP H]H-(
HCHrHHXHEHE HHHPKZHt0 H]HHHtqfH='0 ffH?XEHپ @ A*# H
H1=HHPH}HH9tQHXH}HH9t8HH ItqfH=0 ffHWHپ LHN 1HudH34%( H He[A\A]A^A_] LhgDxH@p HhHx ǀ Hx HPHSI\$ AL$AE(IDŽ$ AD$IDŽ$ A tIEh@o A A ~0IUhA H|: |^} gD D{C'It$4H{H ǃ C Eu4L DsI|$( CA$ A$ D H _XH Hx4 4HhfC6H Hp4dfC8A}8 uAL$HhL%0 L MtLaA HhHx D;x~uDxMtLTHhHx HBXHHBXI HBHHB8 HhHx @0I D;x }Dx @ ;eg IUhA H|: |\H=0 HP XtfH=0 ffHTXp/
HP lj@.HMH$
H0HrHA HX8HAHEHE HXHHPVHEH(H%0 HHHtmfH=0 ffHS@HL0D8H(H
V @ H1H}YH@HP^HH9tHXH}HH9tnHH HXtmfH=@0 ffHXSH@ HXHP H=0 HP XtfH=0 ffHRXp9HP lj@-HMHQ"
H0HrHA HX8HAHEHE HXHHPWTHEH(Hu0 HHHtlfH=,0 ffHDR@HL0D8H(H&
V @ H1.H@XHPH}ZHH9t<HXH}HH9t#HH HXthkfH=0 ffHQH@ HXH- LKN >H= 0 HP Xt@fH=00 ffH@QXp? HP lj@S+HMH
HrH8HHAHEHX&HE HXHHPRHEH0H0 HHHtTjfH=|0 ffHPD@L8H
H0 @ H1H@HPH}HH9tHXH}HH9tHH HXtifH=0 ffHPH@ HXHAD$ Hx gHR8HI HRl H H H# H H! H H Hff. AWIAVAUIATA@ USH HoH~dH%( H$ 1HD$ Lw HD$+HHt} 9 A~8 h HC( AM HLHH+ C HLH AtuI}*HHu'Htڃ tPC H=0 tHT$HT$HT$fH=0 ffHNX D 1H$ dH3 %( HĨ []A\A]A^A_ D fHt$HHD$@ )D$0)D$ D$6HPHT$ P'fT$4AU fT$8HH( HHLLHad @ HLC HT$Ld$Pm'H#
LHrHID$HD$PMHD$p LHHD$NL-0 Lt$pMtffH=0 ffHLAILH
@ H1HHD$H|$pHH9t H|$PIL9t kHMt ffH=F0 ffH^LHپ HHNf D HHT$s"HT$ H=0 tfH=0 ffHL@*# *# rC Ld$PH:"
HrLD$ID$HD$PHD$p LHHD$xMHD$pL-0 HD$Mt-efH=U0 ffHmKDL$HL$A*# H
@ H1gHD$HD$H|$pHH9tz H|$PIL9tg IMtdfH=0 ffHJHL$ LHHHLLH! H H H Hff. UHAWIAVIAUATIԺ SH ~41dH%( HE1AHHH 8A L|L Dž| QAG4t AW`Iw@Hh C;PG > AT$pL |H=\0 ID(tfH=w0 ffHIDh( E6D#LIo'LLe`-HMH[
HrHXIHHAHhHE] LLJHEL-0 HPMtbfH=0 ffHHAVD`H
AWLX @ HPH1 H}IIXZL9tHhH}HH9tmIMt bfH=H0 ffH`HL LHH12HMdH3 %( H He[A\A]A^A_]f D H=0 ID tfH=0 ffHGD`uE6LeD"HMH
HrIHIHAHhHE LLuIHEL-0 H`Mt)afH=Q0 ffHiGEM @ H`H
H1f
H}IIL9 D Ao$LLC4AoL$KDAoT$ STAo\$0[dAod$@ctAol$P Aot$` IT$pC @ H IGhHڋIHVHLHt;HH A L ) Dž| 6N; # LH H5
H= Y / H H H Hmf. AWAVAUATUSHXdH%( HD$H1H r
8 H LJ H h f/ v
&H f/vh fp H H H9 A H w
ǂ J4L σ σtX MG H=0 tfH=0 ffHD@7# L 7# 9< HH
Ld$ HrHEHH$ HLNFL-w0 H\$ Mt^fH=00 ffHHDA7# HH
@ H1IH|$ IHL9tcH<$HH9tQHMt]fH=0 ffHCHپ HHlHt$HdH34%( HX[]A\A]A^A_ @ zxft'ffp AFft9~fp z} t
HH9 1 @ z8@Kσtu MEL @ A7# Hn
H1H|$ IIL9tH<$HH9tOHMtXfH=*0 ffHB>L HH7# 50HLd$ Ds H
HrHEHH$0 HL?L-0 L|$ MtzWfH=0 ffH=EL @ A7# H*
H1 H|$ IIL9tH<$HH9t[HMtWfH=60 ffHN=L HHN7# 4ZHLd$ Ds H
HrHEHH$< HL>L-0 L|$ MtVfH=0 ffHH LHH8(L%0 LMtx@fH=0 ffH&ML @ A4# H H1 A A A A A] H=0 t?fH=/0 ffH?&@ 2 HH
HCH}HIH-H HHH8'L%د0 HMtg?fH=0 ffH%A HHg @ H1 HH8HHH9tLHHH9t4IMt>fH=0 ffH'%Hپ LH LAҹ Һ EDEf + H=r0 tfH=0 ffH$@ '( ÄLHo IFH}LMH菲H LHH8&L%:0 LMt=fH=0 ffH $A LHI @ H1
f. IH8HHH9tLHHH9t蔙IMtG=fH=o0 ffH#L LH HH] HCH}HIH}H HHH8$L%(0 HMt H Hb H: H H^ H Hk @ ATUSHHH HtH[]A\X H Ht$H0 fH Hx@0H Ht$HHHHHHP@H@@ HPH@ H@ H@( @0 ?H@8 H H ZL%ء0 Mt#Et$H 3 EPU D HE Ht$HPMHt$t7E uHE Ht$HPH Ht$ E PU Ȑ @ AWAVAUATUSHhdH%( HD$X1Hx @t(1HL$XdH3 %( $ Hh[]A\A]A^A_ L HIALIHu8 tH A ` Dl$4Ll$0I}El$0` I4$IEIT$HD$8H薧LLLxLcH 1LHH LIM Iq- HH pI1HHcHI9 9uI H Hl$LHXHo foD$HCHK)L$HT$ HD$ HSHT$(HL$(HSHt
HHH|$8I L9yD$ D$f @ 0 1HHH} t]H} tVH f. 0 H HLLhH A H@ Y @ H8(0 H{ Hɿ Hҿ AWAVAUATUHSH dH%( H$ 1H|$HD$ (tn艍H=i0 HË(t蕽fH=0 ffHh 1 H$ dH34%( H []A\A]A^A_ H\$H H( Lt$@E1Ld$HD$ff
HHtnH{ tCtL LHHSfuƹ D~H fL$@BLft$LD$DDŽ$ ϤHDHu @ H\$Hs f D+H\$ Hl$@DH: HHrIHCHD$ 茣 HH L%E0 L|$@Mt.fH=0 ffHEMLH @ H1H|$@HIH9t1H|$ HH9t 蹊HMtl.fH=0 ffHL HH91f
H|$D~fD$@oBLft$LD$HDŽ$ xD: I6 If UHAWAVAUATSHxdH%( HE1H W IH H9
U L荱 IH H I I+ P HIP H* I I H9t(1
IP H2HHHPH H9uA I Ht Hx A AED| I I; tH@H@hH
AE9 L5N0 P AF8Au 9 fufAM A A AF8A}i 9 AE 9 A tAV8i 97 赐Ip H A8 L: I Hm A tLыR 1> 諈H=0 HË At贸fH=0 ffHDx; D+H]DH HHrIHCHE赟HE HHHx:L%c0 L}Mt*fH= 0 ffH5AUA LAVA @ HN H1,IHxH}ZYHH9t>H}HH9t,džHMtz*fH=0 ffHL HHGHMdH3 %( He[A\A]A^A_]L
f D fA} f D I H H H70 fHXI HH@H@0HHPH@@ HHH@ H@ H@( @0 ?H@8 I I HH=k0 CqHHPH=A0 p C GHHP9f. fAu H=0 HË At$fH=0 ffH$DpkD3H]DCH HII HrI+ IHCHEIHE HHHxHEL%0 HpMtI(fH=q0 ffHAVAP MAWHp @ H H1Nf. Aƅ ) L 1 @ AF8A}i A 3I k A~8i A}4f D Cb AF8A fAE *f. AGA9 AC p pA w H=0 HË AtfH=0 ffH
Dx[D3H]D3H HEmHrIHCHEHE HHHxHEL%0 HpMtJ&fH=r0 ffH AVA EAWHp @ HZ H1O cI * H]H1 HCHrHHEaHE HHHx
HEL% 0 HhMt%fH=0 ffH DpEHhH @ H1IHxH}HH9tH}HH9tpHMt#%fH=K0 ffHc L HH AF8H]E} H/ HrHpHCHEVHE HHHx HEL% 0 HhMt$fH=0 ffH
DpEHhH @ H1IHxH}HH9tH}HH9teHMt$fH=@0 ffHX
L HHAF8H]H, E}HrHi pHCHELHE HHHx HEL%0 HhMt#fH=0 ffH DpEHhH
@ H1IHxH}HH9tH}HH9t[HMt#fH=60 ffHN L HH۱dAF8H]H" E HrHi pHCHE?HE HHHx
HEL%0 HhMtx"fH=0 ffHDpEHhHH @ H1IHxH}HH9tH}HH9tN~HMt"fH=)0 ffHAL HHΰCPSpC PS H
6 H5{ H=Z I I I I Iΰ I I鶰 I I酰 I钰 I醰 I I Ibf D H~PSHHtHCP [ AWAVAUATUSHdH%( HD$1H I % A8 2 Ix @ AVt!1ېLHIp 訙A9^wLZI I H9t H;HtH9uI Ht>Idž ^Ix @ Ix @ I tL4$HI A MP MP D I,$HtNI$ H] H9t0f D HC L+HtH{ HHLI9u־ HIM9uA8 L _A IH DIP 8Ip ,I IdžH IdžP Idžp HtHPHj0 Idž Hǀ HD$dH3%( uoH[]A\A]A^A_ D I HPL A8 L裦L薮!( AVAUATUSHHPH-0 dH%( HD$H1Ht fH=0 ffH @ H 1 Hx 1 J} t;yH : y H(1 zO Lx 16ID$(Hx H Hp H H Sƀ Ct#1 D HHȉPHp@ 9SwH H H9t/H1H)HfH H4CЉFHBH9uH ƃ HP H u|8 < HӌF H1zH Ht$HdH34%( " HP[]A\A]A^H1趻P{AHtfH=0 ffHHPILrHt
IT$HzDH? 1LIHt迨fH=0 ffHH LH@HpX8 H @ H H= Ĕ HHt1fH=!0 ffH1@0# 赶 0# HHK Hl$ HrHCHH$' HHL%0 Ll$ MtqfH=0 ffH A0# LH @ H1H|$ HIH9tH<$HH9tUvHMtfH=00 ffHH L HHը I* I ff. AWAVAUATUSHHHx @i L L M9uV AFt}H H H9tH}@HEPH9tֿ` HIM9txI,$HtH +L MtL-0 MuAFPAVuILPMQ AF ]ILPO Hx H( H H HtH H Ht)L-R0 M) E( f D HX Hh H9t踾H( HtH HH HtH HH HtH HH HtH HH HtH HH HtHp HH` HtHP HH@ HtH0 HH HtH HH HtH HH HtH HH HtH HH HtH HH HtHp HH` HtHP HH@ HtH0 HH HtH HH HtH HH HtH HH HtH HH HtH HH HtHp HH` HtHP HH H H9tH H H9tH Ht)L-:0 M E f D H Ht,L-0 M| E{ f H Ht$L-͂0 M E H( ěH H Hx 谐H@ L( H I9u# @ AD$t0HI9t^LeMtL-.0 MuAD$PAT$uI$LPMl AD$ uI$HLPI9uH HtHlL H I9u# @ AD$t0HI9tfLeMtL-0 MuAD$PAT$uI$LPM AD$ uI$HLPI9u H HtH輹H Ht諹H H H H9t臹H{hHCxH9tuH{HHXH9 H[]A\A]A^A_QAD$ PAT$ Nf D AD$ PAT$ f D AF PAV EPUFHE HPMZ E HE HPf EPUHE HPM E HE HPf EPUHE HPM E HE HPf EPUHE HPMt|E lHE HP] D H[]A\A]A^A_f Hx ;HovE PU E PU E PU 냋E PU )z D f. 1f 2f "f SH_HtHH߾( [ @ [f D HG HFHt+U HSHHHEHCHEHCH[]Ð HHCHt
HHHf. AVAUATUSLwH I9t|I Et,HI9tXHkHtL%}0 MuӋEPUuHE HPMtFE uHE HHPI9u @ I] Ht'H[]A\A]A^ E PU D []A\A]A^ AVAUATUSLwH I9t|I Et,HI9tXHkHtL%|0 MuӋEPUuHE HPMtFE uHE HHPI9u @ I] Ht'H[]A\A]A^ E PU D []A\A]A^ ATUSHoHHt< @ H}0HE@Le H9t貴H}HEH9t蠴HL蕴MuHCH;1H0H &H{HC HC H9t
[]A\T @ []A\f. USHHHHtf. H/h4HHuHCH;1H0H 覑H{HC HC H9t
H[]ҳfH[]f USHHHHtf. H/4HHuHCH;1H0H &H{HC HC H9t
H[]RfH[]f USHHHHtf. H/HHuHCH;1H0H 覐H{HC HC H9t
H[]ҲfH[]f AVAUATUHSLgMu< CtMI|$ID$H9t|LMqMtTI\$0M4$HtL-y0 MuCPSuHHPMtfC uHHP @ HEH} 1H0H 譏H}HE HE H9t$[]A\A]A^ױ C PS D []A\A]A^ AWAVIAUIATUHSHH_L'HM)L)H H< H|$H9 HHHD$H$JH$IHM IE IE H$#H$m0 H4$IEMH HHxHLHpLL9tI D HHB HHHJHHH@ HJH@ H9uHEL)HMlIHLH9tC D HH HHHJHHH@ HJH9uHH)HHMlLI9u"} D Ht*HH9t`HEHtH=ww0 uՋHqpuHHH$QH=Rw0 H$t|H uHHHQH9u MtL軯HD$M>MnHIM~H[]A\A]A^A_ D HH9v8HHD$ H qp D HD$ H|$HE1H H ~H<$ tH $H( H H~H}Mt
LI}Ht HHH AWIHAVAUATIUSHH(HOH/HH)H)H H< IH9 LHT$HL$bHT$HL$IIIIMLM)ID O<I9 HLLL$LD$HL$HL$LD$LL$I9t4LLLHu!L+L{LsH([]A\A]A^A_ Hȭf D H H99E1E1HL @ I9u뛐 L4
f. @ AWIHAVAUATIUSHH(HOH/HH)H)H H< IH9 LHT$HL$HT$HL$IIIIMLM)ID O<I9 HLLL$LD$HL$HL$LD$LL$I9t4LLLƢHu!L+L{LsH([]A\A]A^A_ Hxf D H H99E1E1HL @ I9u뛐 L4
f. @ AU1ATUSHLLGL'LIM,Im H Hu HIIHN# @ HHt`HHI1HHIL9uII9uI:HL9tIHtHA1II9tMHI
,HkH []A\A]fH1[]A\A] Ht,HA1II9tMIE HSH9tIE HLHK @ AWAVAUATUSHHL$Mtf. @ ATIUH SH赢E $o1oKoS HH o[0oc@fDXokPos`@ H HMP,X<`Lh\plHCpHG|LHHE L HMtOMMAX!fI Ht8XM1IHH9u!fA9uIHtH1[]A\ @ HLHA |[ ]A\f Ðf. f D SHCH߾ [镢 @ ATIUSH@ I$x Hx8I$ I$ H9t HHH HxH9uI$x H@8 []A\Ðff. HZ0 HwHHÐ UHAWAVIAUATSHhHWdH%( HE1F Hx H
)HH 8 Hp`~ L6ÄJ SH=\0 ID(tfH=c0 ffHDh艒 E,$LeD HMH EvHrHIHxHAHEjHx LHEH=f0 Hpt5fH=]d0 ffHuHMEAUHp @ H H1lH}IIXZL9t腜HxH}HH9tlRH= f0 ItfH=c0 ffHL LH肄H]dH3 %( unHe[A\A]A^A_]fH H Hc6H)HH9sH4\f. LQw H
1 H5lw H= hRsy. H鎅 Hpf D AVAUATIUHSHPHWdH%( HD$H1HHH?H,H H)HHH Dk D9- E< Y1 HH DmHl$ HrHCHH$h HHdL%d0 Lt$ Mt fH=Fb0 ffH^EL @ H9 H1bH|$ HIH9t|H<$HH9tjPHMtfH=a0 ffHL HH腂1HHLHt$HdH34%( u&HP[]A\A]A^ D I|$H3g I Iff. AWAVAUATUHSHXHdH%( HD$H1H9 r HHi H@ Ht 8 詎~,1HL$HdH3 %( HX[]A\A]A^A_ HHy Lm DuHrHCHHl$ H$f HHL%b0 L|$ MtFfH=n`0 ffHMELH @ H1臛H|$ HIH9t衘H<$HH9t菘*NHMtfH=`0 ffH L HH誀 D }LkHt HDuHrHCHHl$ H$e HHL%a0 L|$ MtBfH=j_0 ffHMELHZ @ H1胚f D HCH F fFN " I I飁 Iā Iˁff. U HAWIAVAUATSHxHxdH%( HE1Gf I@ H Lx A~Ix THC8Ix HX8H HxL L M9u f IM9 HxI $ xL tTIFH HXHuLH=U0 ID(t|fH=\0 ffHDh]T E4$LeDHMH IHxIHHrHx@HHpHAHEc LLCHEL-h_0 HhMtfH= ]0 ffH7HM @ AVLpH HhH1* D HKH=T0 ID(t{fH=[0 ffHDhZQ E4$LeDHMH IHxIHHrHx Hi HpHAHEb LL:HEL-_^0 HhMtfH=\0 ffH.HM @ AVLpH: HhH1!H}IIXZL9t:HxH}HH9t!IIMtofH=[0 ffHL LH<|HUdH3%( H7 He[A\A]A^A_] 1 @ 3JH=S0 ID(t>zfH=.Z0 ffH>DhňE4$LeD`HMH+ IHxIHHrHx@HHpHAHE a LLHEL-\0 HhMtcfH=Z0 ffHHM @ AVLpH߬ HhH1薕p 趕HxHH$ I$} H-} H3} HH} HN} Hu} HW}f D AWAVAUATUHSHhNH_dH%( HD$X1w H=x uGH SoHX H} HT$XdH3%( F Hh[]A\A]A^A_ H9 HHi H@ tw8 tr d HPH fVViH H HRHPH9V(DHPH7H9.N@% @ Ht$VHt$ H\$H L.DvHCHrHHl$0HD$^ HHZL%Z0 L|$0MtfH=ufH=.U0 ffH>@ ~-1H$ dH3 %( * H []A\A]A^A_ÿ ÄuLd$pHA HrID$LL$ HD$p\ LLL5W0 L$ MtMfH=uU0 ffHIL @ A H H1苐H$ IHL9t袍H|$pIL9t菍*CIMtfH=U0 ffH H LHu D E} D9 IFHH LckD9 Mi L@ A} H;+y I;mo AtAE"AtAE A}! V H=.L0 t_sfH=OS0 ffH_@ Ä Ld$pH HrID$LL$ HD$pLZ LLL5V0 L$ MtfH=S0 ffHIL @ A H3 H1юH$ IHL9tH|$pIL9tՋpAIMt#fH=KS0 ffHcH LHs HT$@LLD$V @ H IE A H=J0 tqfH=Q0 ffH@ j WÄLd$pH HrID$LL$ HD$pX LLcL5T0 L$ MtfH=BR0 ffHZIL @ A H H1X AE!IFH@ t|1 A ujfHl$D$D$(A} uAE'fD$$A HT$HT$fD$(IFH@ H$ HT$HH0 H I 1AE! fAE(Ht_H Ht HGH9G8tH IE \ H=I0 t@pfH=0P0 ffH@HHx~Ld$pHm HrID$LL$ HD$p2W LLL5R0 H$ MtyfH=P0 ffHIHپ @ Ho H1轋H$ IHL9tԈH|$pIL9t\>HMtfH=7P0 ffHOHپ HHp
H=G0 tofH=O0 ffH1@ 1Ҿ AE 賓^S Hs Hs Hs Hs Hs Hs Hs Hsf. @ Ðf. HHooNdH%( HD$81HF HHD$( )$HD$ H)L$P HT$8dH3%( uHHђ SH裃H߾ [5 @ ATIUSH@ ɊI$ Ht_HCH4@HH,3H9u
; D HH@H{0HH upI9$ uH8H4@HHH{I$ yI$x H yI$x H Ht[]A\O []A\Iff. HeC0 HwHHÐ HGHx H ? @ Bu @ ATIUHHSHHI|$HH[]A\t @ AWAVAUATUHSH(dH%( HD$1G H E1L|$I HD$0 x HHCH{ H\$ H{ L L; I] IE HM0 LpHXHHIEH HT$Hp DAHHrHt`Hr Hp HthHp HTXD9e4H>Hv H@0 H胈1HL$dH3 %( u&H([]A\A]A^A_fH|$LL谶OƏ HTp `p SHH?nu [f H{臰[ UHAWAVAUATSH HGdH %( HM1HX HP IH @ HC 8 HHuIFHP H H|LeHhHEMt$HPHHH D HH\ HCHh1ҋ8;y9H=B0 ID8tifH=I0 ffHDx9xEm DH@ LIHCHrы LudPHP L>HEH=bL0 HXtfH= J0 ffH4HM @ AUDdH 0 HXH1'IH}XZH;Ht@H}L9t27H=K0 It{fH=I0 ffHL LHHjHH @ HEdH3%( uHe[A\A]A^A_]E H n H,nff. UHAWAVAUATIS1H dH%( HE1HGH D ھ HHp :ħID$P9wDžl L| HuHMH`HHXHqHHH@ ID$ll9Hu lHp 1LH<W9y.7H=@0 ID8t9gfH=)G0 ffH9DxuE6D`H H`IID$HrHp HXHE,NH` HHHEH=I0 HPtjfH=G0 ffH調HMAAVHP @ H- H1衂HH}XZH;@tH}H;XtC5H=[I0 ItfH=G0 ffH1Hپ LHgyf HEdH3%( uHe[A\A]A^A_]轊 Hk Hk @ UHAWAVAUATSH dH%( HE1HG u+HEdH3%( He[A\A]A^A_]f Lx I I vID$ tH|Džl H`HEHXHHPHEH@HH8 ID$ll9 GlI 1H`H<6y4H=g=0 ID8tdfH=D0 ffH蒽DxsE6D蹗H HXII Hrы HPHEKHX H@HEH=6G0 HHtfH=D0 ffHHMAAVHH @ H* H1IH}XZH;8t}H}H;Pt}2H=F0 HtOfH=wD0 ffH菼L HH ewB Hi H~if. AWAVAUATUH1SHHXdH%( HD$H1豑 t'HL$HdH3 %( HX[]A\A]A^A_f;{;j} PH}HM80 8 HXT Hx HH 1膏f D [2H=;;0 HË(tgbfH=WB0 ffHghp D+HHl$ D胕H HHrIHCH$eI HHL% E0 L|$ MtfH=B0 ffHEMLH/& @ H1}H|$ HIH9t
{H<$HH9tz0HMtFfH=nB0 ffH膺L HHcTf Hؖ4 Ig Igff. UHAWAVIAUATSHhdH %( H]1 L$[II|$/HLHHtfH
IC0 HPpND p 1H Hz HHRH Hǂ 0HHB L9uM A 7HI@ H AAF11I QfA R Ix H Hx. D|LHHVbHH]dH3 %( _ He[A\A]A^A_]Ð/H=k80 ID(t_fH=?0 ffH薸Dh nE,$LeD踒HMHf E HrHIHxHAHEFHx LHEH=8B0 HptfH=?0 ffH
AUA EAWHp @ H" H1 {H}IIXZL9txHxH}HH9t x-H=A0 ItIfH=q?0 ffH艷L LH`< Hd Hd Ie U HAWAVAUATSHH dH%( HE1HGHx xΝy<-H=60 ID t]fH==0 ffHжD`Wl HC1H|Hx x/x.1HMdH3 %( He[A\A]A^A_]f. ;-H=60 ID tF]fH=6=0 ffHFD`kE6LeDiHMHm IHCHrIHHhHx XHAHE/D LL迷HEL-?0 H`MtsfH==0 ffH賵HMAAVH` @ H# H1xH}IHXZL9tuHhH}HH9tuE+IMtfH= =0 ffH8Hپ LH]E7LeDQHMHU IHCHrIHHhHx @`HAHEC LL衶HEL->0 HXMtUfH=}<0 ffH蕴HM @ AVD`H HXH1wH}IYI^L9ttHhH}HH9tt#*IMtfH=;0 ffHL LH\@ Ha Ha Ha Ha AWHAVAUATIUSHH L.HdH%( HD$x1D蓥ŅA KI|$ 蟂{ H ooKoS H=20 )$I\$)L$)T$ tZfH=:0 ffHHU`Hc2 H@HH HHpHx0H@xH)HH9E H4HsHL$xdH3 %( R HĈ []A\A]A^A_ H=x .D9 H IcHi H@ 1 8 ( t u&x& t HPH fC D r 1[ @ gH\$0H HrHCHLd$PHD$08@ HLȳL5;0 Ll$PMtfH=90 ffH±AL @ HX H1tH|$PIHL9tqH|$0HH9tqh'HMtfH=C90 ffH[H HHY1pfH+ kH\$0HrHCHLd$PHD$0H? HLزL5;0 L|$PMtfH=80 ffHҰEALH @ H1sf D H@0K D LYL H
1 H5tL H= p'{N6| H^ H^ H|^ H^f D UHAWIAVAUATISH HdH %( HM1ɋ 9FvtH=/0 tVfH=60 ffHկ@ Ye JÄ 1HMdH3 %( E He[A\A]A^A_]f. L6N LH?H,I H)HHH HcB 9k Hi H@ W 8 N L;2E L;p; x t
x + u
x# H=.0 tUfH=50 ffHȮ@ Ld 9ÄHMH E|$HrIHAHLeHHHE< LL=HEL-b80 H@MtfH=60 ffH1HEH@AVA @ H H1%qH}IIXZL9 f. IGHMH/ E|$HrILeHD HAHHHE; LLsHEL-70 H@Mt'fH=O50 ffHgHEH@AVA @ HU H1[pH}IYI^L9ttmHHH}HH9t[m"IMtfH=40 ffHL LHvU#H=,0 tSfH=30 ffH豬@ 5b "ÄHMHێ HrIHAHLeHHHE: LL+L-T60 L}MtfH=40 ffH&ML @ A H H1$oH}IIL9t?lHHH}HH9t&l!IMttfH=30 ffH贫L LHAT @ 9Hi H@ 8 L;2L;p x# x u H=*0 tRfH=10 ffH@ `A wÄ-HMH0 HrIHAHLeHHHE8 LL耬L-40 L}Mt;fH=c20 ffH{ML @ A H H1ymH}IIL9 Ao$AoL$HPAoT$ )`)P)p@'fd IwfhL HILHfd yHI HphjW J t sp1螛觹9ZH=/)0 t`PfH=P00 ffH`@ u HW HW HW HW H X HW H$X HXff. AWfAVAUATUHSHH?H,H dH%( H$ 1HD
Ht$pHw% D$xH)Ƅ$ HHH )D$$ HcXHDŽ$ )D$ HD$0 9 Hi H@ ; H;( H;k ItC"tC HD$` f)D$@)D$P{ I|$DkW Bt 1DęA Ru·D9 I|$AvS'I|$A ( HD$VfT$THT$@Hl$@zH9 H= '0 t1NfH=!.0 ffH1@ \4 1H$ dH3<%( : H []A\A]A^A_ {! > H=&0 tMfH=-0 ffH迦@ C\ 4ÄuL$ H HrID$LL$ H$ 4 LL>L5g00 L$ MtfH= .0 ffH5IL @ A H H13iH$ IHL9tJfH$ IL9t4fIMt肿fH=-0 ffH¥H LHONf. H HC ID$H@ ts1 ub{ Hl$ fD$$ HT$C!fD$(ID$HT$H@ H$a HT$HH0 H C! 1Ht$pLfC(I$P(f D nÄL$ Hņ HrID$LL$ H$ 2 LLtL5.0 L$ Mt+fH=S,0 ffHkIL @ A H H1igH$ IHL9tdH$ IL9tjdIMt踽fH=+0 ffHH LHLDw7ND1AA%f D H=Z#0 tJfH={*0 ffH苣@ YZ ÄFL$ HS HrID$LL$ H$ r1 LLL5+-0 L$ Mt蹼fH=*0 ffHIL @ A H~ H1efC'on=. HR HQ HR HQ HR HQ @ AWAVAUATI1USHHhdH%( HD$X1wŋu % ukv 蚲{;cH 0 H\$HXID$H H$h H HT$H 1u sI|$+pMd$ dLcM$H 1H HhHXLII$@ HLc` D$AD$$Il$HD$ H @HH EaL$HXH\$HL HHhHHD$H& HD$(H HD$ RwHD$ Ht
HHHD$8dH3%( u H@[]A\Mi HMM H`M @ Hs/ H0ff. Hr/ SHHi0H߾ [kaf. Hr/ H=0ff. Hr/ SHH0H߾ [aff. AUIATUSH8Hn`dH%( HD$(1H &0 H] H S,; {4f tf{4HIHH$Hn0 L1HD$H 0 HD$C0HL$HC@Ht LLHC@Ht HD$(dH3%( uWH8[]A\A] @ U IE u$H HHPHC@ D HU H HP sg HK ATUSH0H.dH%( HD$(1H]H~IGH?Ht!HD$(dH3%( udH0[]A\ I<$HfH $HD$ D$u'D$ H2jH1ɺ( Hxhof UHSH8H@H?dH %( HL$(1HH$H HHD$H?HD$%tHD$Ht
HHHD$(dH3%( uH8[]"f HJf D AUATUSHH8dH%( HD$(1,L-0 Mt@fH= 0 ffHLc@A$hMt @LcfH= 0 ffH˙A$ @htmL-%L% H :H{HLl$D$H<$Ld$#sHD$Ht
HHHCp GHC uHD$(dH3%( u H8[]A\A]d H}I t7tsUSHHt5u
H? C]H1[]f. HH1 H. \oE oMHHH1[]f D H/ H1 HH6LGFA@$9u~# u
H Ft @ V tV I H` D I H`(f. AVAUIATIUSH0HndH%( HD$(1 tfH L L9tSf. HP4уtu+HphM AD$$9uFuI$ HP(HI9uI}(Ht
>IE( HI1LHD$LHCH,$Ld$HD$ЍHD$Ht
LLЃ8 , Et}1 9]vpM 1AD$$9uH)fIUpH@`HcIExH)HH9 H4ʋV V I$ HP 9]wf D HLHH,$HD$HLd$HD$ pHD$Ht
LLAD$ HD$(dH3%( ujH0[]A\A]A^fI$ HP(
D H
1 HJ H=1 虆f At$$H"eHH[a H>F HQF UHSHH t5H=G0 txH{ t.f1ɺ( L)D$)$HD$ D$H{ĜH{+AE H9HD$(dH3%( uH8[]A\A] + bW SH H dH%( HD$1HD$ OHt$H|$H
0 H
a/ HXHHD$HH|$HtHPH u"HD$H HD$dH3%( u H ["W H>A8 0A !S,9 Lt$@1 fC4H7HMLHD$@H0 HD$XHp 0 HD$PHL$PHC@Ht LLHC@HHuF F I$ HP ~ z"f. q ?H<$H` kIu Xf D HX Hy Ht$H $yH $I$ HP(O H"55ff. AWAVAUIATIUSHHcHoH^ Hi H@ H{@Hc Hi L Ht
*HC@ L Mt-IF Ht I~HtP( LGHǃ AD$uI LHP(G Hx H@`I H@ 8 Hx h0I (I|$( t+C#H A ЈAH hAD$@| L55
0 I$ Ht6HP HtHxHt H$RH$( HFIDŽ$ A{ tH tHL6sA HCL HH,H% H)HHH @ E<$MtLL$umL$ Hx D;y MtLk0 LLǃ Hǃ Hǃ H[]A\A]A^A_i H H@Cj6f D Hx AU$H@8,I AU$H@,Nf I Ic$1LGIIHL IMV2I q,f D HH<2pI1HHcII9 A9uILHPH$H$HHB0H;BPu1 f D HHB0LH$TiH$HB0H9BP HJ@L0HH9uHz8H$@H$HBHHHH@HJHH HB8HJ@HB0 @ AGD HcHi A9r3HH@ t'H Ht> twuA H ;A ~ Hz HtCHBhLrHHHD$L9v I>H$I?L9t$H$wHz H$?H$HBL50 HtTMtgHu@HHT$HH$QMH$HT$tCH uHH$HQH$x H3CYf D Hqp똋H qp H[]A\A]A^A_É'0f HH?H'W$9t
f H Ā @ AWAVIAUATUSHLc&H_LnLMi H@ J,"Hc Hi 8 L ; 4 } * }% t4I}( 1 A}0& HLL[]A\A]A^A_ D t}& uI H HPH9P8 H 6 H4$L ( H4$ I @E0 D ;AF$9# H=/ tHt$ $$Ht$ $Ht$ $fH=0 ffH
} $Ht$ 9 9 rLH@ H[]A\A]A^A_ @ H4$A} j AEf } tI 1HtBA9EvE H t#} t I H @A9G0 I Ht)I H HHH9H8 I,w +1}# .AE#I HtHzH9z8 I LHP 1HHߺ `wE% H1[]A\A]A^A_ #1IDž }# v E HH wI LHL[]A\A]A^A_H4$H4$ fE(I@ H
d b H5+a H=da "H
xd c H5 a H=ma " AVfAUATUSH0Ho dH%( HD$(1)$Lf)D$HD$ M G$9 H=;/ IAtf!fH=V0 ffHfz A9 AE$D$fD$HcH$9 Hi H@ Ht}8 tx u_I LHP(u[{ uEA|$ x C#HAL$H HP0HL$(dH3 %( u'H0[]A\A]A^ LL{ lEH
a H5_ H=
` !H
a H5_ H=_ ff. AVAUATUSHHpHNdH%( HD$h1HH?H,H H)HHH HcB9 Hi H@ 8 H; H;X IH x& x t
x ~ f@&L)$HD$ @Ht$H$A@ 1H|$hdH3<%( H Hp[]A\A]A^f D H=/ t! fH=/ ffH!x@ - ouHl$ H&b HrHEHLd$@HD$ HLyL-0 Lt$@MtffH=/ ffHwIL @ A H>^ H1:H|$@IHL9t7H|$ HH9t7FHMtfH=!/ ffH9wHپ HH 1 L`yB Ht( H{(ff. USHH6HnH~H V'H@$9tH[]ÐH{C2uH{H3HH[] ?f AWAVIAUATUH-I^ SH G$LgH|$H @HI$ dH %( H$ 1HC0L HD$H$ HD$ H$ HD$( L|$PIvH|$-H AE<
$ HcD H>f D a \ L AEtMULC@1LIHC8HHIL8HD$MkI?MHw. HHLHpI1HHII91I9uM)Iu M9 HtHF1II9tL Iu M}I1Mt%H=/ AW L5HkPL H|$EHL$(H|$ HHH$ HT$ Iu LWH$ H;|$(4f. HK LHt$U Ht$HCWvf D Iu HH?H,H% H)HI$H PA9$ 8HcHi I$@ I 9 H;0 H;qHt$HL)(HD$I H I$` Ld$@Ll$H HT$HHt$@I$P A$h I$ Ld$0Ll$8 HT$8Ht$0I$ A$ P I$ Iu HP8, @ IU Ht$H?;f. H|$CAoE LL)D$PAoM)L$`IM D$`HL$pHT$x-f D H HF1II9LHD$L HSHH H9 HD$H Iu AWrAw4ILRH=/ tqAW
ILR 1H$ dH3 %( uEHĸ []A\A]A^A_ÐLHSHH9\HsHS AW rAw 9= H#ff. f UHAWAVAUATSH LgD>dH%( HE1E;$ "IcfHHi I$@ H=/ )PIH )`)pHtfH=/ ffHpH=b/ H@HXfDhtfH=s/ ffHpƅfLk fdLDpAFL HCxHCtHHPH H=/ tfH=/ ffHpM1LLHH@HPCtp HvIH HH H H t LLLHH HHLHCHC` A$ HCHP LLL#O E1 @ HUdH3%( D He[A\A]A^A_] ;uKHcCHPD{|I$ A `H HHxP A stLH~>HHOMHP @ fH LE1)0) HDž@ ƅ6HBH B'f4HJ( [HHHsH f HsH@pA LHsA E1f. DHË Aƃ tH=S/ tfH=t/ ffHmDp #D#H]DGHV HHrIHCHEHE HHH
oH=2/ LutdžfH=/ ffHmHMEATL @ HS H10IXHH}ZHH9t-H}HH9t-H=/ HtKfH=s/ ffHlL HH>8 I7 ID f D UHAWAVAUATISH HxHvH dH %( HM1H HCH;C8 HMLuLoA HpINHhH HpNU LH=x C H>HH?H,H H)HIH HcQA9 Hi I@ : H;9 H;z z t
z HXH`HP HXH` ~ H=/ tH`H`H`fH=/ ffHj@ N b ;bP H`HpHUS HHrHXHGHEHp L?lHEHPH]/ H`HtfH=/ ffH,jA LXHPHAQ @ H1"-HXH}H;ht9*HpH}HH9t *H` HPte fH=/ ffHiHX HPH&1 @ HPHp D PHx1Hxfk HsHCH;C8dHxHpV tBV I$ HP x<1H]dH3 %( < He[A\A]A^A_]f D I$ HP(yH=/ HD tfH=/ ffHhD`3 D#H]DBHOQ HIHxHrD(HCHEHE HHHx,jHU/ L}H`HtfH=/ ffH hHMEATL @ HO H1+IXHxH}ZHH9t-(H}HH9t(H` HtdfH=/ ffHgL HH1z @ A
H=*/ tH`TH`H`fH=6/ ffHFg@ ^H`HpHO HHXFHrPHGHE&Hp LhHEHHH/ H`Ht_fH=/ ffHfH @ XDPA HM HHH1)YH}HX^H;ht&HpH}HH9t&"H` HPtfH=/ ffH fHX HPH @ Hx0H!I1 H I H I H H @ AWAVAUATIUSHHHoHHHWHH)HHH)HvO }(I$HEHC0HHCHHPH@HSHH HC8HS@HC0H[]A\A]A^A_ @ Hw(HH)HLpLhK6H9 H H HlH9 H< 'Hs(IHL)HM4HCHHPH9t H)L{^H;I$L;HkIKl.Ls(HkHHCH HC HE HC8H HC@ L)HIHL4HH)L9vH9tL^ @ H9tLH)L] *f AU1ATUSHHcLGL'IIM,Im H HM HIIq$ D HHt`HcBIH1HIL9uIA9uI9HL9tIHtHcA1II9tM HI w#HkH []A\A]fH1[]A\A] Ht,HcA1II9tM IE HSH9tIE HLHK @ HH)/ HHH t&Hf D {KHf D SHvH߾ [& @ HHWHH9w&R HH9wYf~u31fFHG@ HH
Q H5[P H=P H
Q H5 H H; HD Hf. AWIHAVAUATIUSHH(HOH/HH)H)H H< IH9 LHT$HL$HT$HL$IIIIMLM)ID O<I9 HLLL$LD$HL$NHL$LD$LL$I9t4LLLV
Hu!L+L{LsH([]A\A]A^A_ Hf D H H99E1E1HL @ I9u뛐 L4
f. @ HHxTH9v#HH9sHx&H7H~f. Hxw HHH TPH=? f D SHHHCH9t*H[! ATUS HD$ x"@L f9rT$ /N D$ ?H/ H HPHH HILe8 HEH s HP0H@ HH@ H@ @ ?H@( H@0 HE /\$ H H@ H@ HEhHECHEH/ ]0HEPHH[]A\ D
fZf/%.E d$ @ Hf. HHG H1H#f ATUHSHHG HHCHt- ? HI?LcHH+[]A\( H/ H5,/ HHHH;/ S H6f AUATIUSHHGH fH*
L AXL$0Y/D sMH,ID$ HhX'HI+\$IIT$HHHT LH[]A\A]f \C H,H? @ HfHH H*Xaf. HG(Ðf D H@sOf X t1 AVAUATUSHpgIHC LHhXNHH LKHC`MHC8J HI)MtLHE11 @ HK8H~J4HIHH H)HFP HXHLKM9wLͿ M)N,
M*A LLHI!*Ls@ HHI7LkH Lc(CX[]A\A]A^ [1]A\A]A^ H+ H4 @ AWAVAUI4ׂCATA U1SHHhdH%( HD$X1 H/ fx8v+
1 D 9u ҃uߋ{14 Hto*HIH?HH)H)H 8{D#p8CHD$XdH3%( O Hh[]A\A]A^A_ @ *HIH?HH)H D 8^ Hl$H|$1DsHELd$0HD$ HD$HT$fo@ LHleRow::l@ock(HpH @ ) HT$ HT$ HD$NL-/ L|$0MtDffH=l/ ffHLEL @ HR? H1H|$0IIL9t H|$HH9t *HMtefH=/ ffH LL HHv D D#f uMHl$H|$1HD$ HELd$0HD$THT$fow? LHleRow::l@ock(HpH @ ) HT$ HT$ HD$HML-q/ Lt$0MtefH=*/ ffHBKL @ H= H1I H
H H Hff. AUIATIU? SHLHf?GHSPH#CH;CseHS8H I] H3C H9tH[HuHH[]A\A] H{HLQuӀ{ HDHH[]A\A]H
= H5?= H=< f HdH%( HD$1HH$ 5@H$H HL$dH3 %( uHf. AWIAVAULoATUSHH(dH%( HD$1HGLoHG G HG( H9t LfIIwtM LcCD% +tJu5AD{HD$dH3%( H([]A\A]A^A_f. t f D C H|$ Ld$|H{I9tHD$ HD$HT$HCHSI6LHLkEH6IuG1WL Hf D AWAVAUATIUHSHHxdH%( HD$h1tntiFHH9 HC(HXHM HtKHC(H|HD$hdH3%( HxLH[]A\A]A^A_H I$HC(HTXHD$hdH3%( Hx[]A\A]A^A_+~&KHaf. HELl$ 1L{HD$H|$IEHD$ Lt$@HD$Q HT$LLfo: @P)HT$0 fo: HT$(@fo: HD$ @ fo: @0fo: @@ HHD$@H=/ HD$tk`fH=/ ffHFHL$MLEH9 @ H1 H|$@IIL9tH|$ IL9tKH=c/ It_fH=!/ ffH9FL LH Hy HZ @ HIdH%( HD$1tFt1H$ HH1LHD$dH3%( u*H @ H$ f D H11LRf HF(HDXHÐff. HF(HDXHÐff. HF(DXHF(HD\HÐ @ UHiSHH HvH} 1HHHsHH'QHt H HtH@(H[]Ðff. AWAVAUATUSHhdH%( HD$X1Bb 1~$HL$XdH3 %( 2 Hh[]A\A]A^A_ÐH\$H|$1HD$P HCHl$0HD$HT$HHfoE8 HD$HT$ fo@8 HT$@fo?8 @ foC8 @0foG8 @@ EL%/ Ll$0Mto]fH=/ ffHCL @ Ha6 H1H|$0HIH9tH|$HH9tXHMt ]fH=3/ ffHKCL HH1H0 IAIjLDLHHHS EHl$LLt$HHU(H+LHC HiHpHxIԿ1HIHuLIIT$LNHtH8 t
LA LLLHH{hHwH;wtHD$HHF HwL I H I @ SHHHt*H{Ht [ [f D U SHHH`PH{@FH{H[]Ðf UH SHHGHHx PHUHBH9EvgHM8H { tJHH{ HMHHދA P @ 9t\HvHuA HUHBBH;ErHBHxH HH@P H)HX1H D Q HyH9 HEHHxH[]HEHHރ@HxH ΐ AUIATUSHH/H]H Hk(Ht H}HEH9t 0 HIm HC01L#HuLM HMII:H f HHH9uH9t@M ID$01HLI9tI H3H1HHmL^f D M ID$01HLI9tI+ H=* f AWIHAVAUATIUSHH(HOH/HH)H)H H< IH9 LHT$HL$HT$HL$IIIIMLM)ID O<I9 HLLL$LD$HL$1HL$LD$LL$I9t4LLLHu!L+L{LsH([]A\A]A^A_ Hxf D H H99E1E1HL @ I9u뛐 L4
f. @ AU8 IATUHSHdH%( HD$1Le HmH HHLHCHt M H,$HwMHu7A$SHk( IE HC(HHt$dH34%( uVH[]A\A]ÐHt f H1H$HCHSHLHlH,$HCH=+' F HH H0Hd< @ AWIAVIAUATILUSHH HHWHwLo HHU H H9V L< LL1HI2LS0HKHC Hte1LK D H HHHLMtDHA01LHIt HHuHCHHKLH9 IL HLMu H;I9tL1HkHL+I
L+KD Mt$0J Ht6H I$HJL HCHL[]A\A]A^A_f D HLd$f. AGLHID$
PIGHD$!I7HuE HHH<$AD$XuMH{PL
H4} Ht+H$ dH3 %( uEHĸ []A\A]A^A_f D 1 @ HoD$XHD$hE AE IEf. @ AVIAUIATUH% SHHpdH%( HD$h1HD$ AHT$PH
I# foL$PAM MtAA|$9I\$HD$ HD$ D$ ~@Ht$HD$AE HL$hdH3 %( Hp[]A\A]A^ H`HL$E1E1HT$HHHj ZY<uHD$HHH9v @ HT$ fHD$(HL$1H(
HB( BHD$ fH|$Ht,
HGoPAU+(An s 跘A 1IH
H 1ff. AUIATI UHSHdH%( HD$1HT$!t6D$ AD$HL$dH3 %( H[]A\A] H֠H= w6H薨Ht)xHcPH@I|$ H0 s+(Am wsn蟗A 1IH
H 1@ ATIHUHSH0dH%( HD$(1 tX
EHfHHD$ H)$D$ pu\H\$(dH3 %( } H0[]A\ fHH)$ tfo$ U fU A$ HSoL$
fE HUSMfUA$ of D Ld SH @ u H/ Hu<@ C [ @ Ht,MLI`H[< @ @ kf. UHSHH?HtH @ HH;HuHH[]f SH8蠕Hپ 1IH 1[ff. UHcHSHHHxu HC@uHH[] HH[] f USHHodH%( HD$1D$ E~1HE1 D HI?H5 yHtDHT$@ Hnt($ CULzDH|$xH\$pHt-HtH HD$(@ H|$hG@u
/uH$HtH|$`t@|$dt2HD$HH LC I?H HH!I?H AH E11Hp( H}HD$XLT$XHR
HT$@ @H LT$XD9-
$ E1CAR@u A*u LY f D U@m H3 HD$0 } H=}/ tfH=/ ffH; @ c @ Am NHredirectI9MI? H
P
HEt;HD$; HD$AT$HHHHH;xm H9u
Cy4HcAf D H= 1}C AE@yAM E1QAU ^ ILx@+ <G HD$h H_P|IF` HD$0LD$01RA D HD$0 HD$8 11҉HIZHD$0HDAHyE H$ 1E1l$HD$IHDLt$ Mf. LoEuLLo Gt.< HHP@@u10~8Hu*0 Lf. HtNt2Mt
IWH Ht$LH$ DŽ$
Ts<t6I H$ HHD$0
H$ *HD$8 .腽{cLIEIEH}/ HE_H8 HD$h H$H H<$I I HD$0< HD$0 Nt2HT$LLH$ DŽ$
"hIH/ H5 ' 1R(OMl$Lt$ I]} E1֑ HHHD$ H$ 蹑AL$IHD$H$ ID$ Ld$MILt$0MLHL$LxAuLpLx x t`HIMeMt IVLIvIFL =L`HSLHs袯HCLL` C@u+u H葻wLd$Lt$0L襄L-}Ht$FHPH3@@ rHHH R Lt$PEÅ; @ hA~x
MnpHuI~pH Lo AEIU H$ H$ $ AE Im AE ڇHHD$h@@u HE IcHE HE 蝗foL$pD}HE]M(E DLt$1L= P L$ H$ HD$* @ HEH HII9 A~AAFuAFLt H5 t H HDA~ 1{HtHPxHtDŽ$ H$ HT$H`Ic6I} NH$ HUH [H=v/ 賝}A~ 1ɺ 넋5/ HHT$(HB HGPHt$h HHD$06 EtUDH\$HHl. {39t { HH9tCtҋ{ H|$8 t
H|$8~HD$hH<$ LL$xHH_ Mt
Hy}/ LH4$HJel8~1 H H1V @ 3l8~KD1IHZ 1 t|$`t+C |$d|$`CC C E11Ht$d1H|$` {tk8<~H} 1H1褥 >ÅE1' 1MHuWAE1H H5 1H= MtBBIcHD$HkHHHH9tN}
} t
ſQj8?}H 1H1觤j8}H 1H1~H=] 1H H= H13jHc8{uH4 1HHH1 S@ѫޫMmMhf. @ ATAUHSH
DcHHkX[]A\ff. f GH GJ GK GI GT GP AVDwHAULoXATLg0UoNSHkDsHLkXLc0fkN[]A\A]A^f Hn @ H HH1HLJ HH) Hff. f GuUHGQ<t!t5<uDH HG H @ HGXHtH@`HtЅu1Hf 1蘏 GuH G HG f uG ff. uG ff. G HG Hw HG( H&H HcH> @ H H @ Hq H9 H H HC H H H { @ H k @ H_ [ @ H\ K @ H6 ; @ H + @ H @ H @ H @ H @ H` @ H8 @ H @ H @ H @ H @ Hu { @ HJ k @ H! [ @ H K @ H ; @ H + @ H @ Ho @ H, @ H @ H @ H @ H ff. H. H HcH> @ H H @ H H7 Hg HI H0 H H H { @ H k @ H [ @ H5 K @ Hm ; @ H + @ H\ @ H[ @ H 6 @ H5 @ H5 @ H5 @ Hk @ H5 @ H5 @ H5 @ Hm5 { @ HV5 k @ H [ @ H K @ Hy ; @ Hk + @ H4 @ H5 @ H4 @ H4 @ H4 @ H4 @ Hj
@ Hl4 @ H+ @ HD4 @ H,4 { @ H4 k @ H [ @ HS K @ H ; @ H
+ @ H`3 ff. dH HJ HcH> H{ H @ HV H H' H H H H Hy { @ HS k @ H0 [ @ H
K @ H ; @ H + @ H @ H @ Hp @ HK @ H# @ H @ H @ H @ H @ H @ H^ { @ H8 k @ H [ @ H K @ H ; @ H + @ H @ Hj @ Hy @ H, @ H @ H @ H @ H @ H @ H @ Hi { @ HC k @ H" [ @ H K @ H ; @ H + @ H @ H @ Hd @ HG @ H+ @ H @ H @ H @ H @ H| @ HX { @ H8 k @ H# [ @ H
K @ H ; @ H + @ H @ Hz @ H` @ HF @ H% @ H @ H" @ H @ H @ H @ H{ { @ H^ k @ HD [ @ H K @ H ; @ H + @ H! @ H @ H @ H @ Hd @ HD @ H& @ H @ H @ H @ H { @ Hi- k @ Hv [ @ HQ K @ H* ; @ H + @ H @ H @ H @ H @ Hp @ GNEfGNf D GNEfGNf D GNEfGNf D GNEfGNf D GNEfGNf D GN߃ EfGNf D GN࿃@EfGNf D GN$ʀEfGN GNEfGNf D GNEfGNf D HGXHtH Ht f 1ff. f HOX1Ht!HIHtSH)Hуt[ HH5. 詳 [f HGXHtH@hHt
1ff. f HOX1Ht!HIHtSH)Hуt[ HH58 ) [f HGXHtH@pHt
1ff. f HOX1Ht!HIHtSH)Hуt[ HH5V 該 [f HGXHtH@xHt
1ff. f HOX1Ht!HI HtSH)Hуt[ HH5 ) [f HGXHtH Ht D 1ff. f HOX1Ht!HI(HtSH)Hуt[ HH5 話 [f HGXHtH Ht D 1ff. f HOX1Ht!HI0HtSH)Hуt[ HH5N ) [f HGXHtH Ht D 1ff. f HOX1Ht!HI8HtSH)Hуt[ HH5 詰 [f HGXHtH Ht D 1ff. f HGXHtH@PHt
1ff. f HGXHtH@`Ht
1ff. f HOX1Ht!HIXHtSH)Hуt[ HH5> ɯ [f HGXHtH Ht D 1ff. f HOX1Ht!HI@HtSH)Hуt[ HH5 I [f HGXHtH Ht D 1ff. f HOX1Ht!HIHHtSH)Hуt[ HH5 ɮ [f HGXHtH Ht D 1ff. f HGXHtH Ht D 1ff. f HGXHtH Ht D 1ff. f HHDORDGHH=b/ H?H9t,QH 1RH XZHf. H H QH1Y^Hf. @ GRftIGP1 @ GH<tfTeGP1f. 1HtNWTf @f0@u2dfcv)WR@u"Ѹ ff t1( @ 1 D WR fu
1H@ P tSI tA@ OHtF fu t GN
f D OHt@t1 OT fetfdt@u܍AfAf Auf0t fuu( t3H@ t f D f. f. H'u 1H @ 1J WRt(K t"u%HH ufff. @ SHo1CQ fSR[ GV GQ1 D GH OI1f D 1If GJ 1 D GK 1 D GN @ GO @ GRf 1Pf HG@ 1Ð GV1 D GQ 1 D GNf GNf HHG@H9w1HHcхHG@HxHH9wHHG@1 D HH9s f GNf 1H@ Ð GNf fOR 1 GNf GQ1 D fOR@1 @ GP1 D OL1f D GL GRf GNfÐ fOR1 @ GL1 D fOR1 @ fOR1 @ fOR1 @ GL1 D GL 1 D GL1 D GL1 D GRf HHG@H9w1HHcHHHG@xHH9wHHG@1fHH9s f fOR 1 @ GRf GNf fOR 1 fgR1 @ GL1 D fOR1 @ GI OJ1f D OK1f D GNf GJ GK 1fGT1 GTf=w2fGTx )9|fGT1f D 9~ f. GH1 D GH1 D H HH1HGP HHH)`HHB8 AWAVAUATUSHDoE H HHItHuE8H HcH>HI9!b LHH< M < M [h S h LHHHI9KX ;
mG HLHHb L H E A HE H](HE8
LHHZI96Z ;.G HI9a[ 0< ^ H HHcH>I9 X ;
H E A HE H](HE8 E LHHwI9FX < I <::I LHH4 I9Y <6W@ H HcH><
LHHI9UG H <2G <HHI9O H[T/ H]HE0< Z Hj HHcH>HI9\ ;
I HI9X < N <
/ <:J <
#K I9W H7P/ H]HEH Fp _ t" u4HI9_ U H= p @B8HR I9uΉU HuU EI9c <
&I 7C <
? < uHI9uHuI I9ZZ HI95 HC H
( <: HcH>LHHcyuLHHI9fL HN/ LHHH]HE*yY E JZ u LHH?VLHH聈I9ra H
<Ht|<HlHI9uHuD HI9P HQ/ H]HE0< X H, HHcH>I9Y 0<6Z. H% HcH>LHH.KI9X 0<6A H HcH>I9V HI9Y <&! Hl HcH>L9{^ < t < T% HH E A HE H](HE8 LHHLHH[ _G H7 E A HE H](HE8 DHI9` <
C < t<
C HuHE HHr}AŅt! EH](HE8> I9N HS/ H]HHELHE@H)H9FE H)HE@ HI9X ;
F HI9U < B < B LHHPvS LHH9v` R -` M, LHHH[K/ HHHHE HEi| EAH](HE8- I9V <
H <
H E A HE H](HE8 I9V <
t9<
<
J H& E
A
HE H](HE8 SHI9=V <
H? <
@? LHHNV H E A HE H](HE8 H E A HE H](HE8 Hj E A HE H](HE8 HI9*Y ;
HI9V < < LHHLHHqLHH芆WV H E A HE H](HE8 I9oV 0< V H HHcH>H E
A
HE H](HE8 H E A HE H](HE8 LHHq E H E A HE H](HE8J >HI9~2 H
Hd <'8 HcH>H E A HE H](HE8 LHHJ E H E A HE H](HE8 HI9 T ;
3B HLHH(LHHO ^LHHq DC T :C H E A HE H](HE8) HI9zS H HcH>I97S 0< S H HHcH>LHHLHHI9mM HI9
\ <
< t<,LHH~|LHHgHuHE HHHvAŅu& DmH](HE8B + @ LHH B H@ E A HE H](HE8a H\ E A HE H](HE8 LHHni B HU E A HE H](HE8 nLHHIoB BLHHI+LHH袤H; E A HE H](HE8 I9Hu I9OU ; H E A HE H](HE8 I9L HnL/ H]HEM E H
L @ <@8; 7 H6 I9u܉E Hu LHHMLHHgLHHh LHHbQI9dT H<
t<
tLHHF I9uHu LHHyLHHLHH}F0 H} HcH>LHHs= H E A HE H](HE8 PHI9M U H= fp @B8HVB I9uΉU HuT -I9+O <
B <
uHI9cO ;
u5 LHH_b5 H E A HE H](HE8 HI9 M U H= p @B8H;I9uΉU HuS ]H E
A
HE H](HE8 HI9F H9/ H]HHELs<
4 <
4 LM9u @ E I9L H Fn tDHI9L U H= p @B8H
A I9uΉU HuP UcHI9J U H= D p @B8HI9uΉU HuR HI9I U H=[ f D p @B8>HkI9uΉU HuO LHH!H_ E A HE H](HE8 HI9H E H
f D <@8;!/ H> I9u܉E Hu HI9L I9u܉E Hu KHI9'J ;P> D H3 E A HE H](HE8 HI9L E I9\G ;_ HI9F E H
x <@8;q* H : I9u܉E Hu KHI99E H E A HE H](HE8 LHH-( H HcH>HI9C E H
D <@8;( H8 I9u܉E Hu I9<> H 6/ H]HHEH
H <E" HcH>HI9B E H
<@8;!( H6 I9u܉E Hu HI9G ;NHI9A HI9@ E H
f D <@8;$ H2 I9u܉E Hu H E A HE H](HE8 HI9A E H
4@83!" H4 I9u܉E Hu ktiuFHI9= U H=G f D p @B8% H23 I9uΉU Hu; HI9m< U H= f D p @B8% H 2 I9uΉU Hu: -H E A HE H](HE8 HI9< U H=n D p @B8$ H2 I9uΉU Hu9 HuI9B H
HZ < HcH>HLHHTI99 0< ? H' HHcH>HI9= ;/-H E A HE H](HE8 I97 H3/ H]HHELHE@H)H9j( H)HE@% HI9f: <
0 < HI HE A HE H](HE8 *HI9= E H
@ <@8;9 Hs0 I9u܉E Hu HI9u= E H
@ 4@83 HS1 I9u܉E Hu H E A HE H](HE8 aHI9u8 E H
4@83q H0 I9u܉E Hu KHI9; E H
@ <@8;! H[0 I9u܉E Hu E H
@ <@8; H/ I9u܉E Hu LHH3I9i' H%1/ H]HHE' pHI9; Hd E A HE H](HE8 H E A HE H](HE8 H E A HE H](HE8 _HN E A HE H](HE8 6H E A HE H](HE8
I94 L5 <2a IcL>I9Hu. H E A HE H](HE8 L9u3 HI9 ; tL9HuV L9Hu L9q' H'/ H]HHEL9Hu 4L9#Hu HuI9 3 Hi Ls<> <& < HE HHLdAŅELu(HE8 xHuL94 f. L9 H < < <aHb E A HE H](HE8 HuL90 <
<
3 HI9u4 D L9WHu L95, < < LHHb>HR E A HE H](HE8 OL9! <: HB E
A
HE H](HE8 HuL9) 4 @ L9JHui HuI9+ E H
$ f<@8;H H I9u܉E u HuIM9* AH I^<HE LHcbAŅ[EH](HE8 ;HuI9' E H
D <@8; H I9u܉E r 'L9# ;HHL E A HE H](HE8 L9! H #/ H]HEHuL9eHu D LLH$ LM9Hu@ w ȹ 1뽹 붹 믹 먹 롹 뚹 HLHHY/ I9Hu! f HI9Hu{ HuHE HH讬EAH](HE8z vHuHE HHx6EAH](HE8] @HuHE HHBEAH](HE8[
HE HHHWEAH](HE8 HE HHHvWEAH](HE8 HI9h HE HHH)WEAH](HE8 QHE HHVEAH](HE8
HuHE HH!oEAH](HE8[ HuHE HH^EAH](HE8z HuHE HH赪|EAH](HE8] }HI9Hu HuHE HHdEAH](HE8z ,HuHE HH.EAH](HE8] HuHE HH=EAH](HE8[ HI9Hu} HuHE HH觩EAH](HE8z oHuHE HHq/EAH](HE8] 9HuHE HH;EAH](HE8[ HE HHH\EAH](HE8 ;HE HH\EAH](HE8 雾HHI94 鴾 * 1 HE HHH\EAH](HE8 HLHH%[H] E A HE H](HE8 骽H$ E A HE H](HE8 遽H E A HE H](HE8 XLHH3AŅ( H E A HE H](HE8
LHHSmLHHŕ LHH螒 A HuHE HHmAŅ7EH](HE8 酼 U K A # 1 e [1T JHE HHHyQAŅEH](HE8 须H LHHH E A HE H](HE8 WH H
H H H
뉹 LHHfkLHHؓ_ LHH豐1 HuHE HHkAŅEH](HE8c 阺 s i _ U K A 710 &H4 E A HE H](HE8 H4 E A HE H](HE8 HȦ E A HE H](HE8 ƹ LHH'Hl E
A
HE H](HE8 遹 빹 벹 1맹 령 뙹 뒹 당 넹 LHH+'"H E
A
HE H](HE8 빹 벹 뫹 뤹 띹 떹 1당 HE HHHVAŅpEH](HE8 鎸H E A HE H](HE8 eLHH@" H( E A HE H](HE8 HuHE HH EAH](HE8z LHH%H E
A
HE H](HE8 颷 빹 벹 1맹 령 뙹 뒹 당 Hr HE A HE H](HE8 9HuHE HH;EAH](HE8] HuHE HHSEAH](HE8[ ͶH (H H H H H H H H H1H` E A HE H](HE8 H5 E A HE H](HE8 HD E A HE H](HE8 ɵfE < ͼG HI E A HE H](HE8 ~HI9Hu 霵HuHE HHH<EAH](HE82 )HuHE HH{< EAH](HE83 HLHH)O H' E A HE H](HE8Y 駴HuHE HHeAŅ}EH](HE8 qLHHAH E A HE H](HE8 1LHHv_HuHE HH e EAH](HE8 HuHE HHdAŅEH](HE8f 鮳LHH)vHuHE HHdQEAH](HE8b aHLHHh7:H E
A
HE H](HE8 HI9Hu7 ; HuE HHHE 蹚"EAH](HE8 6+He E
A
HE H](HE8 銲JtE E HLHHlڳHLHH/- H; E A HE H](HE8$ HE HHL EALu(HE8 бHE HHL
EALu(HE8 雱E !HuHE HHH;EAH](HE8K ULHHNHu>LHH;5HuHE HHHW;AŅDmH](HE8* ްHE HH48EAH](HE82 鬰HE HHH7SEAH](HE82 vHE@ HHHE H!\EAH](HE8 9LHHT=IH> E A HE H](HE8 HI9HuE E HLHH M&H E
A
HE H](HE8 鎯LHH3Ha E A HE H](HE8 NLHHi<H E A HE H](HE8 H E A HE H](HE8 H E
A
HE H](HE8 鼮H E A HE H](HE8 铮HLHHKLHH#Fc LHH LHHl O H E A HE H](HE8) @ -H E A HE H](HE8 ƭHH E A HE H](HE8 靭Hu6 ȭHu, 麭H# E A HE H](HE8 XHuHE HHH7EAH](HE8K HE@ HHHE HɈ`EAH](HE8 LHHcCLHHetHLHHIH E A HE H](HE8 sH E A HE H](HE8 JH E! A! HE H](HE8 !H˟ E! A! HE H](HE8 HuH #Hu( H֟ E& A& HE H](HE8 鳫LHH%LHHbzHh E A HE H](HE8 ] LHHALHHHu ^HLHH,/̤H E A HE H](HE8 銠H' E A HE H](HE8 aHu 錠HuC ~Hu pHu bHu THu FHu 8Hue *Hu/ Hu LHHPb "LHH4b LHHb hLHHaRHuHE HHYPAŅkEH](HE8 1Hu \HuHE HHPAŅPEH](HE8 HuHE HHOAŅEH](HE8h 鷞Hu# HuHE LH%AŅ(DmL}(HE8= rHu1 非Hu| 鏞LHHQ>H? E A HE H](HE8 Hu& BHu 4Hu` &Hu LHH,# LHHALHHHu" ΝHu Huz 鲝Hu 餝Hu+ 閝Hu] 鈝Hu[ zHu_ lLHH.D?H0 E A HE H](HE8Y HuZ Hu Hu0 HuHE HHMAŅEH](HE8d 鏜Hu 麜r 鰜Hu 颜H+ E
A
HE H](HE8 @Hu kHu ]Hu OHu AHʉ E
A
HE H](HE8 ߛHu
Hu Hu HuO Hu қH E A HE H](HE8x pHuy 雛Hu 鍛Hu o uHu gHuR YHu KHu =Hu /Hu !Hu Hu: Hu Hu Hu ۚHu ͚Hu; 鿚Hu 鱚Hu 飚Hu\ 镚HuS 釚HuT yHu kHu ]Hu OHu9 AHu 3Hu %HuQ Hu HuU Hu Hu ՙHuP ǙHu^ 鹙Hu 髙Hu 静Hu 鏙Hu 遙Hu sHu eHu WHu IHu ;Hu -Hu Hu u Hu Hu Hu ݘHu ϘHu Hu 鳘Hu 饘Hu 闘Hu 鉘Hu {Hu mHu _Hu QHu CHu 5Hu 'Hu LHH{<Hu Hu Hu ܗLHHQHu 黗Hu 魗Hu 韗Hu 鑗Hu 郗Hu uHu gdHͅ E A HE H](HE8 Hu (Hu Hu Hu Hu Hu Hu ԖHu ƖHuD 鸖Hu 骖LHH ;LHHPHuG vHu hH E
A
HE H](HE8 Hu 1Hu #Hu H E A HE H](HE8 鳕Hu ޕHu ЕHu Hu 鴕H E A HE H](HE8 RHuI }4 sHu? eLHH9Hu, DLHH6OHu8 #H E A HE H](HE8 Hux Hu ޔLHH!LHHy$HuHE HHHAŅDmH](HE8A =H E HE H](HE8 Hu! EHu 7LHHPtYH E A HE H](HE8 麓 ߓHuF ѓHu@ ÓH E A HE H](HE8 aH{ E A HE H](HE8 8 AUIH6 ATIUH SHHLHø-- H{4fC2 D+4 1҃ @kHL#HC HC f fK0H[]A\A]ff. f : AVAUIATIUS1 G1H HHcH> @ 1[]A\A]A^ H LL1_
D H LL1_ D H LL1_ LcM9sD A
v A
D Et+LK|5 1L)L H
LcM950H LLKH L)K|5 DH@1 HL Q H1
XZ[]A\A]A^ H LL1^ *fH LL1 ^
fH H LL1\^2 fH͠ LL1<^ fH LL1 ^ ,fLK|5 1
L)H Lc] @ LK|5 1
L)Hv Lc] @ HL Qff. @ H AWHBI1AVL5/ AUIATU1SHH(HD$ {0Ed- C0IcL>f1{ HC C0 T2D8m HHCfHI9wH(H[]A\A]A^A_ D C0HA
A-tA: D a< LeH;l$ Lf. A tC0HA
i H;l$nƃ
HD HkC1 @ A
R C0 H5HCSH9 HRH9A
HC Hf D A-$ HC0H@0HHL$HHL$u ICLL)ȉ [ ]A\A^ L)L 1fH(dH%( HD$1H v~HFH H f D HHHrHwHHwo$?HHNfAHHAȀDAHwptH|$dH3<%( u9H( @4$H H$? HN뷸(fH^ HϜ HcH> D n
Hontrol-aH3WHaccess-cH3H uHllow-oriH9G @ y HransportH3WHstrict-tH3H uH-securitH9G @ G D Wr t e(?cookp fG d<G H HcH> D
rV
Hretry-afH9 D G D e ?t= D D fHcontent-H9 Hwww-authH9 Á?refrF Á?:schL ?upgrL Á?:met Á?:sta. ?expi. Á?refe f?vaD Hif-none-H9 f?li Haccept-rH9 f?ho HauthorizH9' f?da Hlast-modH9I f?fr Hcache-coH9 f?et Hcontent-H9F øøø @ f ua2g( p
Álocaf tio v? 1tc" ÁnnecHf ti<o2@ f D o> fritC ÁentiUf caIt?< fti`oV- fang) fat:c0& Àn=9 fho fre&2 ø* fes3 ø fem ftu Ài6 Àn, Árang Àr: Àat! Às% Ào*$ Àt Áatio Ámatce( Ántro Áangei Áifie+ ø0 fadA fre# øøøøøøf D AVAUATIUHSHHHH dH%( HD$1`I9 IH~
H@A H H @ HHHrHwHH E EH $HN HHπ@yHwHeu EunM9 LHHeH\$dH3 %( H []A\A]A^f D I~vZID$ME1H/H$ HN LHH2FA D H$SfME11H$ HN0PH
s H5 H= ATHA UH)SH HH9sHE1Lc@LHHxL uH) H[]A\H PXH
/ _ H53 H= H ff. HHGHP=H9vDH ? ? H)H H D HHHrHwHH A H
EHB
<HN@<$f D HHπ@yHwLbuHU H3LH\$dH3 %( u|H []A\ E1H EB"4 H$ Aw= Aw-HK EHB
<HN @<$fy UHLISHHHdH4%( Ht$1 H H|$APL Q tZYHt,T$H9w#H HL$dH3 %( uH[] D Hf oSHHFHGHHPH@HG(HFHWHPH@HW HG0FHG@ G8GL H?4H{[*f. SHH9H;[v9f D AUIATUSHHH t81 HCHHH#CHL$LCLL H9kwH3HL[]A\A] ff. AUATUSHHo HG(H;G0 HI' @ L0CLHe ID$(I;D$0 IT$H IL$HI4$H HI#L$L,IMH+AIM H+AIT$ID$(HtAULHHtI9tFHP@HqI9tHHP@H\I9uH@IU@HIE@ ? Hf. H[]A\A] D AWIAVAUIATUHSHHFHL$HO0HZHXHG(H Lg HH9w5 LALL-IG(IO0HH9 IWH IOHI7H HI#OL4INH+AIH+AIWIG(HtAVLHD HtI9t?HP@HrL9tHHP@H]L9uH@IV@HIF@ @HD f 1H9vH[]A\A]A^A_f. P LsIHV LHIGMoHPIEH9 A H ML9wJ4 LH MGI7Mt2IWMWHIHL f D LH!HHH[]f. 11Ht$ HuHD$(H|$ /{ ff. AWAVAUATUSH Ht$0HL$(dH%( H$ 1< P HH HE@H|$( HD$ HD$H} H$ IHD$8HD$pHD$@f I_M'HLAƃB < HH
. HDD|DA A uQI AG t`Ll@M @ D$ DD$IOIWHH|$0F AG At$At A6 H !@ L D$ Ll@M E1Ld$ Hl$MLEE/f. Mt[IEHUH;Pti D Mm@M E;}uAuE9uLuIE H;XuHxHt$ HuMu D |$5 IEMHUH;PuHuHxuIHl$E8f D AALJ
ILJ ILJ A Ht$HxII `IG` I IG`I+GXHB1ALJ 9 @ A A tA MIIIGHt$onReceive handler error errCode onError %s has no %s callback %s->%s handler error onBufferFull onClose onSSLReady onConnect onBufferEmpty require `onSslReady` callback sz onReceive bufferFull bufferEmpty The host is empty failed to get client type The port is invalid Swoole\Async\Client __construct __destruct wakeup resume isConnected force false onSslReady 0.5 sock_flag FvPN6swoole7network6ClientEE FvPKN6swoole7network6ClientEPKcmE PFvPN6swoole7network6ClientEE PFvPKN6swoole7network6ClientEPKcmE ?please use the Swoole\Server->listen method can't register event callback function after server started %s(): ssl cert file[%s] not found %s(): ssl key file[%s] not found please use the swoole_server->listen method kernel_socket_recv_buffer_size kernel_socket_send_buffer_size package_eof cannot be an empty string unknown package_length_type, see pack(). Link: https://php.net/pack 'package_length_offset' value is too large 'package_body_offset' value is too large %s(): ssl client cert file[%s] not found ssl_client_cert_file[%s] not found ssl_sni_certs requires an array mapping host names to cert paths ssl_sni_certs array requires string host name keys /usr/include/c++/8/bits/shared_ptr_base.h %s:%d: %s: Assertion '%s' failed.
\Swoole\Server\Helper::checkOptions length function handler error Invalid instance of %s Swoole\Server\Port onPacket onRequest onHandshake onOpen onMessage onDisconnect onBeforeHandshakeResponse unknown event types[%s] ssl_cert_file ssl cert file[%s] not found ssl_key_file ssl key file[%s] not found backlog heartbeat_idle_time buffer_high_watermark buffer_low_watermark open_tcp_nodelay tcp_defer_accept open_tcp_keepalive open_eof_check open_eof_split package_eof package_eof max length is %d open_http_protocol open_websocket_protocol open_http2_protocol open_mqtt_protocol open_redis_protocol tcp_keepidle tcp_keepinterval tcp_keepcount tcp_user_timeout tcp_fastopen open_length_check package_length_type package_length_offset package_body_offset package_body_start package_length_func package_max_length ssl_compress ssl_protocols ssl_verify_peer ssl_allow_self_signed ssl_client_cert_file ssl_cafile ssl_capath ssl_verify_depth ssl_prefer_server_ciphers ssl_ciphers ssl_ecdh_curve ssl_dhparam ssl_sni_certs invalid SNI_cert setting _M_get() != nullptr ssl_add_sni_cert() failed ssl_init() failed bufferfull bufferempty handshake beforehandshakeresponse disconnect getCallback Closure event_name basic_string::append bool swoole::SSLContext::set_key_file(const string&) bool swoole::SSLContext::set_cert_file(const string&) std::__shared_ptr_access<_Tp, _Lp, , >::element_type& std::__shared_ptr_access<_Tp, _Lp, , >::operator*() const [with _Tp = swoole::SSLContext; __gnu_cxx::_Lock_policy _Lp = (__gnu_cxx::_Lock_policy)2; bool = false; bool = false; std::__shared_ptr_access<_Tp, _Lp, , >::element_type = swoole::SSLContext] bool swoole::SSLContext::set_client_cert_file(const string&) FiPN6swoole6ServerEPNS_8RecvDataEE St11_Mutex_baseILN9__gnu_cxx12_Lock_policyE2EE FvPN6swoole6ServerEPNS_8DataHeadEE St19_Sp_make_shared_tag St16_Sp_counted_baseILN9__gnu_cxx12_Lock_policyE2EE PFvPN6swoole6ServerEPNS_8DataHeadEE PFiPN6swoole6ServerEPNS_8RecvDataEE St23_Sp_counted_ptr_inplaceIN6swoole10SSLContextESaIS1_ELN9__gnu_cxx12_Lock_policyE2EE MbP? C _ execv(%s) failed, Error: %s[%d] kill(%d, %d) failed, Error: %s[%d] no pipe, cannot setBlocking the pipe cannot use both 'timer' and 'alarm' at the same time setitimer() failed, Error: %s[%d] %s(): dup2(%d, %d) failed, Error: %s[%d] %s::signal can only be used in CLI mode signal [%ld] processor has been registered by the system unable to find the callback of signal [%ld] exit ret_code range is [>0 and <255] no msgqueue, cannot use push() no pipe, cannot read from pipe no pipe, cannot write into pipe no queue, can't get stats of the queue no pipe, cannot setTimeout the pipe $who parameter must not be null no pipe, cannot close the pipe Constructor of %s can only be called once %s can only be used in PHP CLI mode %s can't be used in master process unable to create %s with async-io threads /builddir/build/BUILD/swoole-6.2.2/ext-src/swoole_process.cc process has already been started sched_setaffinity() failed, Error: %s[%d] sched_getaffinity() failed, Error: %s[%d] sa exec file name is empty must call constructor first cannot use %s::alarm here %s: signal [%d] handler error |b no pipe, cannot export stream invalid signal number [%ld] not current process no msgqueue, cannot use pop() the data to push is empty the data to push is too big the data to send is empty write() failed, Error: %s[%d] |lll msgQueueId msgQueueKey cannot close the pipe close() failed, Error: %s[%d] failed to create unix soccket Swoole\Process IPC_NOWAIT PIPE_MASTER PIPE_WORKER PIPE_READ PIPE_WRITE PIPE_TYPE_NONE PIPE_TYPE_STREAM PIPE_TYPE_DGRAM pcntl SIGHUP SIGINT SIGQUIT SIGILL SIGTRAP SIGABRT SIGBUS SIGFPE SIGKILL SIGUSR1 SIGSEGV SIGUSR2 SIGPIPE SIGALRM SIGTERM SIGSTKFLT SIGCHLD SIGCONT SIGSTOP SIGTSTP SIGTTIN SIGTTOU SIGURG SIGXCPU SIGXFSZ SIGVTALRM SIGPROF SIGWINCH SIGIO SIGPWR SIGSYS SIG_IGN PRIO_PROCESS PRIO_PGRP PRIO_USER SWOOLE_MSGQUEUE_ORIENT SWOOLE_MSGQUEUE_BALANCE invalid signal number [%d] dup2() failed, Error: %s[%d] %s->onStart handler error fork() failed, Error: %s[%d] More than the number of CPU invalid cpu id [%d] alarm kill daemon setAffinity getAffinity setPriority getPriority setTimeout setBlocking useQueue statQueue freeQueue pop exportSocket Swoole\Coroutine\Socket exec_file args exit_code which 8192 who priority blocking cpu_settings nochdir true noclose pipes usec signal_no 65536 -1 redirect_stdin_and_stdout pipe_type SOCK_DGRAM FvPvE PFvPvE *Z25zim_swoole_process_signalEUlPN6swoole7ReactorERmE_ .A void zim_swoole_process_daemon(zend_execute_data%s->onWorkerExit handler error %s->onWorkerStop handler error %s->onWorkerStart handler error process pool is started. unable to listen The process pool is not started process pool is started. unable to register event callback function cannot set `onMessage` event with ipc_type=0 cannot create server and process pool instances simultaneously A process pool instance has already been created and cannot be created again the parameter $worker_num must be greater than 0 the parameter $ipc_type must be SWOOLE_IPC_UNIXSOCK when enable coroutine require 'onWorkerStart' callback cannot set `onWorkerExit` without enable_coroutine workerRunning %s->onShutdown handler error master_pid workerPid workerId process pool is not started. unsupported ipc type[%d] s|ll unix:/ invalid worker_id[%ld] workers enable_message_bus max_package_size %s->onMessage handler error unknown event type[%s] Swoole\Process\Pool l|llb failed to create process pool process pool is started require 'onMessage' callback getProcess sendMessage detach dst_worker_id 2048 work_id ipc_type SWOOLE_IPC_NONE msgqueue_key @ Coroutine can_exit callback handler error scheduler is running, unable to execute %s->parallel scheduler is running, unable to execute %s->add name_resolver must be an array scheduler is started, unable to execute %s->start Swoole\Coroutine\Scheduler Co\Scheduler max_coro_num max_coroutine enable_deadlock_check hook_flags enable_preemptive_scheduler c_stack_size name_resolver no coroutine task dns_cache_expire dns_cache_capacity exit_condition parallel getOptions FbPN6swoole7ReactorERmE *Z40php_swoole_coroutine_scheduler_rshutdownEUlRKSt14_List_iteratorIN6swoole12NameResolverEEE_ PFbPN6swoole7ReactorERmE Swoole\Coroutine\Http2\Client\Exception SWOOLE_HTTP2_TYPE_PUSH_PROMISE SWOOLE_HTTP2_TYPE_WINDOW_UPDATE SWOOLE_HTTP2_TYPE_CONTINUATION SWOOLE_HTTP2_ERROR_PROTOCOL_ERROR SWOOLE_HTTP2_ERROR_INTERNAL_ERROR SWOOLE_HTTP2_ERROR_FLOW_CONTROL_ERROR SWOOLE_HTTP2_ERROR_SETTINGS_TIMEOUT SWOOLE_HTTP2_ERROR_STREAM_CLOSED SWOOLE_HTTP2_ERROR_FRAME_SIZE_ERROR SWOOLE_HTTP2_ERROR_REFUSED_STREAM SWOOLE_HTTP2_ERROR_COMPRESSION_ERROR SWOOLE_HTTP2_ERROR_CONNECT_ERROR SWOOLE_HTTP2_ERROR_ENHANCE_YOUR_CALM SWOOLE_HTTP2_ERROR_INADEQUATE_SECURITY SWOOLE_HTTP2_ERROR_HTTP_1_1_REQUIRED unexpect http2 header [%.*s] (duplicated or overflow) nghttp2_hd_deflate_hd() failed nghttp2_hd_deflate_change_table_size() failed the send queue is full, try again later __builtin_expect(!this->empty(), true) /usr/include/c++/8/bits/stl_queue.h nghttp2_hd_inflate_new2() failed nghttp2_hd_deflate_new2() failed http2 stream#%d belongs to an unknown type or it never registered unable to found active pipeline stream#%u current_stream_id last_stream_id local_settings remote_settings active_stream_num Swoole\Coroutine\Http2\Client Co\Http2\Client Co\Http2\Client\Exception Swoole\Http2\Request Swoole\Http2\Response errMsg serverLastStreamId GET cookies pipeline usePipelineRead statusCode set_cookie_headers SWOOLE_HTTP2_TYPE_DATA SWOOLE_HTTP2_TYPE_HEADERS SWOOLE_HTTP2_TYPE_PRIORITY SWOOLE_HTTP2_TYPE_RST_STREAM SWOOLE_HTTP2_TYPE_SETTINGS SWOOLE_HTTP2_TYPE_PING SWOOLE_HTTP2_TYPE_GOAWAY SWOOLE_HTTP2_ERROR_NO_ERROR SWOOLE_HTTP2_ERROR_CANCEL :method :path :scheme :authority %s:%d %s with error: %s nghttp2_hd_inflate_hd failed content-encoding 1.2.11 %s(): inflateInit2() failed set-cookie failed to send control frame PRI * HTTP/2.0
SM
%s(): decompress failed http_build_query failed stats isStreamExist goaway ping error_code debug_data '' end_stream 80 open_ssl ]\ ]@]P]`](]DԀT<~$ int swoole::coroutine::http2::Client::parse_header(swoole::coroutine::http2::Stream*, int, char*, size_t) const swoole::ReturnCode swoole::coroutine::http2::Client::parse_frame(zval*, bool) void std::queue<_Tp, _Sequence>::pop() [with _Tp = _zend_string*; _Sequence = std::deque<_zend_string*, std::allocator<_zend_string*> >] *ZN6swoole9coroutine5http26Client7connectEvEUlPNS0_6SocketEE_ *ZN6swoole9coroutine5http26Client11parse_frameEP12_zval_structbEUltjE_ Co\Http2\Client\PRI * HTTP/2.0
dgram socket cannot use sendfile file to send is empty lz/|z/ Swoole\Coroutine\Client Co\Client MSG_OOB MSG_PEEK MSG_DONTWAIT MSG_WAITALL peek sendfile getPeerCert verifyPeerCert 65535 *ZL25client_coro_create_socketP12_zval_structlEUlPN6swoole9coroutine6SocketEE_ D the connected client of connection[%ld] is not a websocket client or closed %s->onBeforeHandshakeResponse handler error HTTP/1.1 400 Bad Request
Connection: close
Content-Type: text/html; charset=UTF-8
Cache-Control: must-revalidate,no-cache,no-store
Content-Length: 83
Server: swoole-http-server
HTTP 400 Bad Request
Powered by Swoole deflateInit2() failed, Error: [%d] Failed to compress outgoing frame the maximum value of opcode is %d SWOOLE_WEBSOCKET_STATUS_CONNECTION SWOOLE_WEBSOCKET_STATUS_HANDSHAKE SWOOLE_WEBSOCKET_STATUS_ACTIVE SWOOLE_WEBSOCKET_STATUS_CLOSING SWOOLE_WEBSOCKET_OPCODE_CONTINUATION SWOOLE_WEBSOCKET_OPCODE_BINARY SWOOLE_WEBSOCKET_FLAG_COMPRESS SWOOLE_WEBSOCKET_CLOSE_GOING_AWAY SWOOLE_WEBSOCKET_CLOSE_PROTOCOL_ERROR SWOOLE_WEBSOCKET_CLOSE_DATA_ERROR SWOOLE_WEBSOCKET_CLOSE_STATUS_ERROR SWOOLE_WEBSOCKET_CLOSE_ABNORMAL SWOOLE_WEBSOCKET_CLOSE_MESSAGE_ERROR SWOOLE_WEBSOCKET_CLOSE_POLICY_ERROR SWOOLE_WEBSOCKET_CLOSE_MESSAGE_TOO_BIG SWOOLE_WEBSOCKET_CLOSE_EXTENSION_MISSING SWOOLE_WEBSOCKET_CLOSE_SERVER_ERROR SWOOLE_WEBSOCKET_CLOSE_CLOSE_SERVICE_RESTART SWOOLE_WEBSOCKET_CLOSE_TRY_AGAIN_LATER SWOOLE_WEBSOCKET_CLOSE_BAD_GATEWAY WEBSOCKET_STATUS_HANDSHAKE_FAILED WEBSOCKET_CLOSE_PROTOCOL_ERROR WEBSOCKET_CLOSE_MESSAGE_TOO_BIG WEBSOCKET_CLOSE_EXTENSION_MISSING WEBSOCKET_CLOSE_CLOSE_SERVICE_RESTART WEBSOCKET_CLOSE_TRY_AGAIN_LATER %s(): inflateInit2() failed by %s inflate() failed, Error: %s[%d] server is not running fd[%ld] is invalid reason finish session#%ld does not exists Swoole\WebSocket\Server Swoole\WebSocket\Frame Swoole\WebSocket\CloseFrame SWOOLE_WEBSOCKET_OPCODE_TEXT SWOOLE_WEBSOCKET_OPCODE_CLOSE SWOOLE_WEBSOCKET_OPCODE_PING SWOOLE_WEBSOCKET_OPCODE_PONG SWOOLE_WEBSOCKET_FLAG_FIN SWOOLE_WEBSOCKET_FLAG_RSV1 SWOOLE_WEBSOCKET_FLAG_RSV2 SWOOLE_WEBSOCKET_FLAG_RSV3 SWOOLE_WEBSOCKET_FLAG_MASK SWOOLE_WEBSOCKET_CLOSE_NORMAL SWOOLE_WEBSOCKET_CLOSE_TLS WEBSOCKET_STATUS_CONNECTION WEBSOCKET_STATUS_HANDSHAKE WEBSOCKET_STATUS_FRAME WEBSOCKET_STATUS_ACTIVE WEBSOCKET_STATUS_CLOSING WEBSOCKET_OPCODE_CONTINUATION WEBSOCKET_OPCODE_BINARY WEBSOCKET_CLOSE_GOING_AWAY WEBSOCKET_CLOSE_DATA_ERROR WEBSOCKET_CLOSE_STATUS_ERROR WEBSOCKET_CLOSE_ABNORMAL WEBSOCKET_CLOSE_MESSAGE_ERROR WEBSOCKET_CLOSE_POLICY_ERROR WEBSOCKET_CLOSE_SERVER_ERROR WEBSOCKET_CLOSE_BAD_GATEWAY sec-websocket-key Sec-WebSocket-Accept 13 Sec-WebSocket-Version Sec-WebSocket-Protocol websocket_subprotocol websocket_mask open_websocket_close_frame open_websocket_ping_frame open_websocket_pong_frame %s->onOpen handler error __toString unpack isEstablished "" bool swoole::websocket::message_uncompress(swoole::String*, const char*, size_t) bool swoole_websocket_handshake(HttpContext*) void swoole_websocket_onOpen(swoole::Server*, const HttpContext*) @ 258EAFA5-E914-47DA-95CA-C5AB0DC8the given object is not an instance of %s Swoole\NameResolver\Context Class "%s" not found %ld family AF_INET withPort FNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKS4_PN6swoole12NameResolver7ContextEPvE *Z31zif_swoole_name_resolver_removeEUlRKSt14_List_iteratorIN6swoole12NameResolverEEE_ *Z31php_swoole_name_resolver_lookupRKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEPN6swoole12NameResolver7ContextEPvEUlSA_E_ PFNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKS4_PN6swoole12NameResolver7ContextEPvE Non-empty string required
Stack trace:
Swoole Swoole Team Author 6.2.2 Jul 15 2026 %s %s 09:46:48 Built little endian host byte order epoll eventfd spinlock rwlock OpenSSL 1.1.1w 11 Sep 2023 openssl dtls zlib E%u/D%u brotli mutex_timedlock pthread_barrier futex execinfo %02X:%02X:%02X:%02X:%02X:%02X cli_set_process_title STDOUT STDERR @swoole/library/constants.php @swoole/library/std/exec.php @swoole/library/ext/curl.php @swoole/library/functions.php @swoole/library/alias.php @swoole/library/alias_ns.php fatal_error never be executed here
bailout refcount func_handler unknown fn '%s' zif_handler=%p
%s() (ERRNO %d): %.*s enable_signalfd enable_kqueue trace_flags log_file log_level log_date_format log_date_with_microseconds log_rotation print_backtrace_on_error dns_server socket_dns_timeout socket_connect_timeout socket_write_timeout socket_send_timeout socket_read_timeout socket_recv_timeout socket_timeout http2_header_table_size http2_enable_push http2_max_concurrent_streams http2_init_window_size http2_max_frame_size http2_max_header_list_size cli phpdbg embed micro SWOOLE_VERSION SWOOLE_VERSION_ID SWOOLE_MAJOR_VERSION SWOOLE_MINOR_VERSION SWOOLE_RELEASE_VERSION SWOOLE_EXTRA_VERSION SWOOLE_DEBUG SWOOLE_HAVE_COMPRESSION SWOOLE_HAVE_ZLIB SWOOLE_HAVE_BROTLI SWOOLE_USE_HTTP2 SWOOLE_USE_SHORTNAME SWOOLE_SOCK_TCP SWOOLE_SOCK_TCP6 SWOOLE_SOCK_UDP SWOOLE_SOCK_UDP6 SWOOLE_SOCK_UNIX_DGRAM SWOOLE_SOCK_UNIX_STREAM SWOOLE_SOCK_RAW SWOOLE_SOCK_RAW6 SWOOLE_TCP SWOOLE_TCP6 SWOOLE_UDP SWOOLE_UDP6 SWOOLE_UNIX_DGRAM SWOOLE_UNIX_STREAM SWOOLE_RAW SWOOLE_RAW6 SWOOLE_SOCK_SYNC SWOOLE_SOCK_ASYNC SWOOLE_SSL SWOOLE_SSLv3_METHOD SWOOLE_SSLv3_SERVER_METHOD SWOOLE_SSLv3_CLIENT_METHOD SWOOLE_TLSv1_METHOD SWOOLE_TLSv1_SERVER_METHOD SWOOLE_TLSv1_CLIENT_METHOD SWOOLE_TLSv1_1_METHOD SWOOLE_TLSv1_1_SERVER_METHOD SWOOLE_TLSv1_1_CLIENT_METHOD SWOOLE_TLSv1_2_METHOD SWOOLE_TLSv1_2_SERVER_METHOD SWOOLE_TLSv1_2_CLIENT_METHOD SWOOLE_DTLS_SERVER_METHOD SWOOLE_DTLS_CLIENT_METHOD SWOOLE_SSLv23_METHOD SWOOLE_SSLv23_SERVER_METHOD SWOOLE_SSLv23_CLIENT_METHOD SWOOLE_TLS_METHOD SWOOLE_TLS_SERVER_METHOD SWOOLE_TLS_CLIENT_METHOD SWOOLE_SSL_TLSv1 SWOOLE_SSL_TLSv1_1 SWOOLE_SSL_TLSv1_2 SWOOLE_SSL_TLSv1_3 SWOOLE_SSL_DTLS SWOOLE_SSL_SSLv2 SWOOLE_EVENT_READ SWOOLE_EVENT_WRITE SWOOLE_STRERROR_SYSTEM SWOOLE_STRERROR_GAI SWOOLE_STRERROR_DNS SWOOLE_STRERROR_SWOOLE SWOOLE_ERROR_MALLOC_FAIL SWOOLE_ERROR_SYSTEM_CALL_FAIL SWOOLE_ERROR_PHP_FATAL_ERROR SWOOLE_ERROR_NAME_TOO_LONG SWOOLE_ERROR_INVALID_PARAMS SWOOLE_ERROR_QUEUE_FULL SWOOLE_ERROR_PROTOCOL_ERROR SWOOLE_ERROR_WRONG_OPERATION SWOOLE_ERROR_FOR_TEST SWOOLE_ERROR_NO_PAYLOAD SWOOLE_ERROR_FILE_NOT_EXIST SWOOLE_ERROR_FILE_TOO_LARGE SWOOLE_ERROR_FILE_EMPTY SWOOLE_ERROR_DIR_NOT_EXIST SWOOLE_ERROR_BAD_IPV6_ADDRESS SWOOLE_ERROR_BAD_HOST_ADDR SWOOLE_ERROR_BAD_PORT SWOOLE_ERROR_BAD_SOCKET_TYPE SWOOLE_ERROR_EVENT_ADD_FAILED SWOOLE_ERROR_SESSION_CLOSING SWOOLE_ERROR_SESSION_CLOSED SWOOLE_ERROR_SSL_NOT_READY SWOOLE_ERROR_SSL_BAD_CLIENT SWOOLE_ERROR_SSL_BAD_PROTOCOL SWOOLE_ERROR_SSL_RESET SWOOLE_ERROR_TASK_TIMEOUT SWOOLE_ERROR_AIO_BAD_REQUEST SWOOLE_ERROR_AIO_CANCELED SWOOLE_ERROR_AIO_TIMEOUT SWOOLE_ERROR_SOCKET_CLOSED SWOOLE_ERROR_CO_YIELD_FAILED SWOOLE_ERROR_CO_CANNOT_CANCEL SWOOLE_ERROR_CO_NOT_EXISTS SWOOLE_ERROR_CO_CANCELED SWOOLE_ERROR_CO_TIMEDOUT SWOOLE_TRACE_SERVER SWOOLE_TRACE_CLIENT SWOOLE_TRACE_BUFFER SWOOLE_TRACE_CONN SWOOLE_TRACE_EVENT SWOOLE_TRACE_WORKER SWOOLE_TRACE_MEMORY SWOOLE_TRACE_REACTOR SWOOLE_TRACE_PHP SWOOLE_TRACE_HTTP SWOOLE_TRACE_HTTP2 SWOOLE_TRACE_EOF_PROTOCOL SWOOLE_TRACE_LENGTH_PROTOCOL SWOOLE_TRACE_CLOSE SWOOLE_TRACE_WEBSOCKET SWOOLE_TRACE_REDIS_CLIENT SWOOLE_TRACE_MYSQL_CLIENT SWOOLE_TRACE_HTTP_CLIENT SWOOLE_TRACE_AIO SWOOLE_TRACE_SSL SWOOLE_TRACE_NORMAL SWOOLE_TRACE_CHANNEL SWOOLE_TRACE_TIMER SWOOLE_TRACE_SOCKET SWOOLE_TRACE_COROUTINE SWOOLE_TRACE_CONTEXT SWOOLE_TRACE_CO_HTTP_SERVER SWOOLE_TRACE_TABLE SWOOLE_TRACE_CO_CURL SWOOLE_TRACE_CARES SWOOLE_TRACE_ZLIB SWOOLE_TRACE_CO_PGSQL SWOOLE_TRACE_CO_ODBC SWOOLE_TRACE_CO_ORACLE SWOOLE_TRACE_CO_SQLITE SWOOLE_TRACE_CO_FIREBIRD SWOOLE_TRACE_CO_SSH2 SWOOLE_TRACE_THREAD SWOOLE_TRACE_ALL SWOOLE_LOG_DEBUG SWOOLE_LOG_TRACE SWOOLE_LOG_INFO SWOOLE_LOG_NOTICE SWOOLE_LOG_WARNING SWOOLE_LOG_ERROR SWOOLE_LOG_NONE SWOOLE_LOG_ROTATION_SINGLE SWOOLE_LOG_ROTATION_MONTHLY SWOOLE_LOG_ROTATION_DAILY SWOOLE_LOG_ROTATION_HOURLY SWOOLE_IPC_UNIXSOCK SWOOLE_IPC_SOCKET SWOOLE_IOV_MAX swoole_coroutine_create swoole_coroutine_defer 8.3.31 PHP_VERSION : %s
Swoole\Exception Swoole\Error swoole.enable_library On swoole.enable_fiber_mock Off swoole.display_errors swoole.use_shortname swoole.socket_buffer_size 8388608 swoole.blocking_detection swoole.blocking_threshold 100000 swoole.profile swoole.leak_detection swoole API20230831,NTS swoole_version swoole_cpu_num swoole_last_error swoole_async_dns_lookup_coro swoole_async_set swoole_coroutine_socketpair swoole_test_kernel_coroutine swoole_client_select swoole_select swoole_set_process_name swoole_get_local_ip swoole_get_local_mac swoole_strerror swoole_errno swoole_clear_error swoole_error_log swoole_error_log_ex swoole_ignore_error swoole_hashcode swoole_mime_type_add swoole_mime_type_set swoole_mime_type_delete swoole_mime_type_get swoole_get_mime_type swoole_mime_type_exists swoole_mime_type_list swoole_clear_dns_cache swoole_substr_unserialize swoole_substr_json_decode swoole_implicit_fn swoole_get_objects swoole_get_vm_status swoole_get_object_by_handle swoole_name_resolver_lookup swoole_name_resolver_add swoole_name_resolver_remove swoole_tracer_leak_detect swoole_tracer_prof_begin swoole_tracer_prof_end output_file Swoole\NameResolver ctx associative 512 suffix error_type except 100 sleep_time domain_name 60 Offset must be not less than the negative length of the string Offset must be less than the length of the string getifaddrs() failed, Error: %s[%d] enabled with boost asm context can not call this function in user level socket creation failed, Error: %s[%d] ioctl SIOCGIFCONF failed, Error: %s[%d] swoole_set_process_name only support in CLI mode
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
define('SWOOLE_LIBRARY', true);
!defined('CURLOPT_HEADEROPT') && define('CURLOPT_HEADEROPT', 229);
!defined('CURLOPT_PROXYHEADER') && define('CURLOPT_PROXYHEADER', 10228);
!defined('CURLOPT_RESOLVE') && define('CURLOPT_RESOLVE', 10203);
!defined('CURLOPT_UNIX_SOCKET_PATH') && define('CURLOPT_UNIX_SOCKET_PATH', 10231);
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
use Swoole\Coroutine\System;
function swoole_exec(string $command, &$output = null, &$returnVar = null)
{
$result = System::exec($command);
if ($result) {
$outputList = explode(PHP_EOL, $result['output']);
foreach ($outputList as &$value) {
$value = rtrim($value);
}
if (($endLine = end($outputList)) === '') {
array_pop($outputList);
$endLine = end($outputList);
}
if ($output) {
$output = array_merge($output, $outputList);
} else {
$output = $outputList;
}
$returnVar = $result['code'];
return $endLine;
}
return false;
}
function swoole_shell_exec(string $cmd)
{
$result = System::exec($cmd);
if ($result && $result['output'] !== '') {
return $result['output'];
}
return null;
}
@swoole/library/core/Constant.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
class Constant
{
/* {{{ EVENT */
public const EVENT_START = 'start';
public const EVENT_BEFORE_SHUTDOWN = 'beforeShutdown';
public const EVENT_SHUTDOWN = 'shutdown';
public const EVENT_WORKER_START = 'workerStart';
public const EVENT_WORKER_STOP = 'workerStop';
public const EVENT_BEFORE_RELOAD = 'beforeReload';
public const EVENT_AFTER_RELOAD = 'afterReload';
public const EVENT_TASK = 'task';
public const EVENT_FINISH = 'finish';
public const EVENT_WORKER_EXIT = 'workerExit';
public const EVENT_WORKER_ERROR = 'workerError';
public const EVENT_MANAGER_START = 'managerStart';
public const EVENT_MANAGER_STOP = 'managerStop';
public const EVENT_PIPE_MESSAGE = 'pipeMessage';
public const EVENT_CONNECT = 'connect';
public const EVENT_RECEIVE = 'receive';
public const EVENT_CLOSE = 'close';
public const EVENT_PACKET = 'packet';
public const EVENT_BUFFER_FULL = 'bufferFull';
public const EVENT_BUFFER_EMPTY = 'bufferEmpty';
public const EVENT_REQUEST = 'request';
public const EVENT_HANDSHAKE = 'handshake';
public const EVENT_BEFORE_HANDSHAKE_RESPONSE = 'beforeHandshakeResponse';
public const EVENT_OPEN = 'open';
public const EVENT_MESSAGE = 'message';
public const EVENT_DISCONNECT = 'disconnect';
/* }}} EVENT */
public const EVENT_ERROR = 'error';
/* {{{ OPTION */
public const OPTION_DEBUG_MODE = 'debug_mode';
public const OPTION_TRACE_FLAGS = 'trace_flags';
public const OPTION_LOG_FILE = 'log_file';
public const OPTION_LOG_LEVEL = 'log_level';
public const OPTION_LOG_DATE_FORMAT = 'log_date_format';
public const OPTION_LOG_DATE_WITH_MICROSECONDS = 'log_date_with_microseconds';
public const OPTION_LOG_ROTATION = 'log_rotation';
public const OPTION_DISPLAY_ERRORS = 'display_errors';
public const OPTION_DNS_SERVER = 'dns_server';
/**
* Socket DNS timeout in seconds.
*/
public const OPTION_SOCKET_DNS_TIMEOUT = 'socket_dns_timeout';
/**
* Default socket connect timeout in seconds.
*/
public const OPTION_SOCKET_CONNECT_TIMEOUT = 'socket_connect_timeout';
/**
* Default socket write timeout in seconds.
*
* This one works the same as option "socket_send_timeout", but has higher priority.
*
* @see Constant::OPTION_SOCKET_SEND_TIMEOUT
*/
public const OPTION_SOCKET_WRITE_TIMEOUT = 'socket_write_timeout';
/**
* Default socket write timeout in seconds.
*
* This one works the same as option "socket_write_timeout", but has lower priority.
*
* @see Constant::OPTION_SOCKET_WRITE_TIMEOUT
*/
public const OPTION_SOCKET_SEND_TIMEOUT = 'socket_send_timeout';
/**
* Default socket read timeout in seconds.
*
* This one works the same as option "socket_recv_timeout", but has higher priority.
*
* @see Constant::OPTION_SOCKET_RECV_TIMEOUT
*/
public const OPTION_SOCKET_READ_TIMEOUT = 'socket_read_timeout';
/**
* Default socket read timeout in seconds.
*
* This one works the same as option "socket_read_timeout", but has lower priority.
*
* @see Constant::OPTION_SOCKET_READ_TIMEOUT
*/
public const OPTION_SOCKET_RECV_TIMEOUT = 'socket_recv_timeout';
/**
* Default socket read/write timeout in seconds.
*
* This one has the highest priority than the other read/write timeout options:
* - Constant::OPTION_SOCKET_WRITE_TIMEOUT
* - Constant::OPTION_SOCKET_SEND_TIMEOUT
* - Constant::OPTION_SOCKET_READ_TIMEOUT
* - Constant::OPTION_SOCKET_RECV_TIMEOUT
*
* @see Constant::OPTION_SOCKET_SEND_TIMEOUT
* @see Constant::OPTION_SOCKET_WRITE_TIMEOUT
* @see Constant::OPTION_SOCKET_RECV_TIMEOUT
* @see Constant::OPTION_SOCKET_READ_TIMEOUT
*/
public const OPTION_SOCKET_TIMEOUT = 'socket_timeout';
public const OPTION_SOCKET_BUFFER_SIZE = 'socket_buffer_size';
public const OPTION_HTTP2_HEADER_TABLE_SIZE = 'http2_header_table_size';
public const OPTION_HTTP2_ENABLE_PUSH = 'http2_enable_push';
public const OPTION_HTTP2_MAX_CONCURRENT_STREAMS = 'http2_max_concurrent_streams';
public const OPTION_HTTP2_INIT_WINDOW_SIZE = 'http2_init_window_size';
public const OPTION_HTTP2_MAX_FRAME_SIZE = 'http2_max_frame_size';
public const OPTION_HTTP2_MAX_HEADER_LIST_SIZE = 'http2_max_header_list_size';
public const OPTION_AIO_CORE_WORKER_NUM = 'aio_core_worker_num';
public const OPTION_AIO_WORKER_NUM = 'aio_worker_num';
public const OPTION_AIO_MAX_WAIT_TIME = 'aio_max_wait_time';
public const OPTION_AIO_MAX_IDLE_TIME = 'aio_max_idle_time';
/**
* @since 6.0.0-beta
*/
public const OPTION_IOURING_ENTRIES = 'iouring_entries';
/**
* @since 6.0.0-rc1
*/
public const OPTION_IOURING_WORKERS = 'iouring_workers';
/**
* @since 6.0.0-rc1
*/
public const OPTION_IOURING_FLAG = 'iouring_flag';
public const OPTION_ENABLE_SIGNALFD = 'enable_signalfd';
/**
* @since 6.1.0
*/
public const OPTION_ENABLE_KQUEUE = 'enable_kqueue';
public const OPTION_WAIT_SIGNAL = 'wait_signal';
public const OPTION_DNS_CACHE_REFRESH_TIME = 'dns_cache_refresh_time';
public const OPTION_THREAD_NUM = 'thread_num';
public const OPTION_MIN_THREAD_NUM = 'min_thread_num';
public const OPTION_MAX_THREAD_NUM = 'max_thread_num';
/**
* @removed 6.1.0
*/
public const OPTION_SOCKET_DONTWAIT = 'socket_dontwait';
public const OPTION_DNS_LOOKUP_RANDOM = 'dns_lookup_random';
public const OPTION_USE_ASYNC_RESOLVER = 'use_async_resolver';
public const OPTION_ENABLE_COROUTINE = 'enable_coroutine';
public const OPTION_SSL_PROTOCOLS = 'ssl_protocols';
public const OPTION_SSL_COMPRESS = 'ssl_compress';
public const OPTION_SSL_CERT_FILE = 'ssl_cert_file';
public const OPTION_SSL_KEY_FILE = 'ssl_key_file';
public const OPTION_SSL_PASSPHRASE = 'ssl_passphrase';
public const OPTION_SSL_HOST_NAME = 'ssl_host_name';
public const OPTION_SSL_VERIFY_PEER = 'ssl_verify_peer';
public const OPTION_SSL_ALLOW_SELF_SIGNED = 'ssl_allow_self_signed';
public const OPTION_SSL_CAFILE = 'ssl_cafile';
public const OPTION_SSL_CAPATH = 'ssl_capath';
public const OPTION_SSL_VERIFY_DEPTH = 'ssl_verify_depth';
public const OPTION_SSL_CIPHERS = 'ssl_ciphers';
public const OPTION_OPEN_EOF_CHECK = 'open_eof_check';
public const OPTION_OPEN_EOF_SPLIT = 'open_eof_split';
public const OPTION_PACKAGE_EOF = 'package_eof';
public const OPTION_OPEN_MQTT_PROTOCOL = 'open_mqtt_protocol';
public const OPTION_OPEN_LENGTH_CHECK = 'open_length_check';
public const OPTION_PACKAGE_LENGTH_TYPE = 'package_length_type';
public const OPTION_PACKAGE_LENGTH_OFFSET = 'package_length_offset';
public const OPTION_PACKAGE_BODY_OFFSET = 'package_body_offset';
public const OPTION_PACKAGE_LENGTH_FUNC = 'package_length_func';
public const OPTION_PACKAGE_MAX_LENGTH = 'package_max_length';
public const OPTION_BUFFER_HIGH_WATERMARK = 'buffer_high_watermark';
public const OPTION_BUFFER_LOW_WATERMARK = 'buffer_low_watermark';
public const OPTION_BIND_PORT = 'bind_port';
public const OPTION_BIND_ADDRESS = 'bind_address';
public const OPTION_OPEN_TCP_NODELAY = 'open_tcp_nodelay';
public const OPTION_SOCKS5_HOST = 'socks5_host';
public const OPTION_SOCKS5_PORT = 'socks5_port';
public const OPTION_SOCKS5_USERNAME = 'socks5_username';
public const OPTION_SOCKS5_PASSWORD = 'socks5_password';
public const OPTION_HTTP_PROXY_HOST = 'http_proxy_host';
public const OPTION_HTTP_PROXY_PORT = 'http_proxy_port';
public const OPTION_HTTP_PROXY_USERNAME = 'http_proxy_username';
public const OPTION_HTTP_PROXY_USER = 'http_proxy_user';
public const OPTION_HTTP_PROXY_PASSWORD = 'http_proxy_password';
public const OPTION_MAX_CORO_NUM = 'max_coro_num';
public const OPTION_MAX_COROUTINE = 'max_coroutine';
public const OPTION_ENABLE_DEADLOCK_CHECK = 'enable_deadlock_check';
public const OPTION_HOOK_FLAGS = 'hook_flags';
public const OPTION_ENABLE_PREEMPTIVE_SCHEDULER = 'enable_preemptive_scheduler';
public const OPTION_C_STACK_SIZE = 'c_stack_size';
public const OPTION_STACK_SIZE = 'stack_size';
public const OPTION_NAME_RESOLVER = 'name_resolver';
public const OPTION_DNS_CACHE_EXPIRE = 'dns_cache_expire';
public const OPTION_DNS_CACHE_CAPACITY = 'dns_cache_capacity';
public const OPTION_CONNECT_TIMEOUT = 'connect_timeout';
public const OPTION_TIMEOUT = 'timeout';
public const OPTION_MAX_RETRIES = 'max_retries';
public const OPTION_DEFER = 'defer';
public const OPTION_LOWERCASE_HEADER = 'lowercase_header';
public const OPTION_KEEP_ALIVE = 'keep_alive';
public const OPTION_WEBSOCKET_MASK = 'websocket_mask';
public const OPTION_HTTP_COMPRESSION = 'http_compression';
public const OPTION_BODY_DECOMPRESSION = 'body_decompression';
public const OPTION_WEBSOCKET_COMPRESSION = 'websocket_compression';
public const OPTION_WRITE_FUNC = 'write_func';
public const OPTION_HTTP_PARSE_COOKIE = 'http_parse_cookie';
public const OPTION_HTTP_PARSE_POST = 'http_parse_post';
public const OPTION_HTTP_PARSE_FILES = 'http_parse_files';
public const OPTION_HTTP_COMPRESSION_LEVEL = 'http_compression_level';
public const OPTION_COMPRESSION_LEVEL = 'compression_level';
public const OPTION_HTTP_GZIP_LEVEL = 'http_gzip_level';
public const OPTION_HTTP_COMPRESSION_MIN_LENGTH = 'http_compression_min_length';
public const OPTION_COMPRESSION_MIN_LENGTH = 'compression_min_length';
public const OPTION_HTTP_COMPRESSION_TYPES = 'http_compression_types';
public const OPTION_COMPRESSION_TYPES = 'compression_types';
public const OPTION_UPLOAD_TMP_DIR = 'upload_tmp_dir';
public const OPTION_ENABLE_MESSAGE_BUS = 'enable_message_bus';
public const OPTION_MAX_PACKAGE_SIZE = 'max_package_size';
public const OPTION_SSL = 'ssl';
public const OPTION_CHROOT = 'chroot';
public const OPTION_USER = 'user';
public const OPTION_GROUP = 'group';
public const OPTION_DAEMONIZE = 'daemonize';
public const OPTION_PID_FILE = 'pid_file';
public const OPTION_REACTOR_NUM = 'reactor_num';
public const OPTION_SINGLE_THREAD = 'single_thread';
public const OPTION_WORKER_NUM = 'worker_num';
public const OPTION_MAX_WAIT_TIME = 'max_wait_time';
public const OPTION_MAX_QUEUED_BYTES = 'max_queued_bytes';
public const OPTION_MAX_CONCURRENCY = 'max_concurrency';
public const OPTION_WORKER_MAX_CONCURRENCY = 'worker_max_concurrency';
public const OPTION_SEND_TIMEOUT = 'send_timeout';
public const OPTION_DISPATCH_MODE = 'dispatch_mode';
public const OPTION_SEND_YIELD = 'send_yield';
public const OPTION_DISPATCH_FUNC = 'dispatch_func';
public const OPTION_DISCARD_TIMEOUT_REQUEST = 'discard_timeout_request';
public const OPTION_ENABLE_UNSAFE_EVENT = 'enable_unsafe_event';
public const OPTION_ENABLE_DELAY_RECEIVE = 'enable_delay_receive';
public const OPTION_ENABLE_REUSE_PORT = 'enable_reuse_port';
public const OPTION_TASK_USE_OBJECT = 'task_use_object';
public const OPTION_TASK_OBJECT = 'task_object';
public const OPTION_EVENT_OBJECT = 'event_object';
public const OPTION_TASK_ENABLE_COROUTINE = 'task_enable_coroutine';
public const OPTION_TASK_WORKER_NUM = 'task_worker_num';
public const OPTION_TASK_IPC_MODE = 'task_ipc_mode';
public const OPTION_TASK_TMPDIR = 'task_tmpdir';
public const OPTION_TASK_MAX_REQUEST = 'task_max_request';
public const OPTION_TASK_MAX_REQUEST_GRACE = 'task_max_request_grace';
public const OPTION_MAX_CONNECTION = 'max_connection';
public const OPTION_MAX_CONN = 'max_conn';
public const OPTION_START_SESSION_ID = 'start_session_id';
public const OPTION_HEARTBEAT_CHECK_INTERVAL = 'heartbeat_check_interval';
public const OPTION_HEARTBEAT_IDLE_TIME = 'heartbeat_idle_time';
public const OPTION_MAX_REQUEST = 'max_request';
public const OPTION_MAX_REQUEST_GRACE = 'max_request_grace';
public const OPTION_RELOAD_ASYNC = 'reload_async';
public const OPTION_OPEN_CPU_AFFINITY = 'open_cpu_affinity';
public const OPTION_CPU_AFFINITY_IGNORE = 'cpu_affinity_ignore';
public const OPTION_UPLOAD_MAX_FILESIZE = 'upload_max_filesize';
public const OPTION_ENABLE_STATIC_HANDLER = 'enable_static_handler';
public const OPTION_DOCUMENT_ROOT = 'document_root';
public const OPTION_HTTP_AUTOINDEX = 'http_autoindex';
public const OPTION_HTTP_INDEX_FILES = 'http_index_files';
public const OPTION_STATIC_HANDLER_LOCATIONS = 'static_handler_locations';
/**
* @since 6.2.0
*/
public const OPTION_URL_REWRITE_RULES = 'url_rewrite_rules';
public const OPTION_INPUT_BUFFER_SIZE = 'input_buffer_size';
public const OPTION_BUFFER_INPUT_SIZE = 'buffer_input_size';
public const OPTION_OUTPUT_BUFFER_SIZE = 'output_buffer_size';
public const OPTION_BUFFER_OUTPUT_SIZE = 'buffer_output_size';
public const OPTION_MESSAGE_QUEUE_KEY = 'message_queue_key';
/**
* @since 6.0.0-beta
*/
public const OPTION_BOOTSTRAP = 'bootstrap';
/**
* @since 6.0.0-beta
*/
public const OPTION_INIT_ARGUMENTS = 'init_arguments';
public const OPTION_BACKLOG = 'backlog';
public const OPTION_KERNEL_SOCKET_RECV_BUFFER_SIZE = 'kernel_socket_recv_buffer_size';
public const OPTION_KERNEL_SOCKET_SEND_BUFFER_SIZE = 'kernel_socket_send_buffer_size';
public const OPTION_TCP_DEFER_ACCEPT = 'tcp_defer_accept';
public const OPTION_OPEN_TCP_KEEPALIVE = 'open_tcp_keepalive';
public const OPTION_OPEN_HTTP_PROTOCOL = 'open_http_protocol';
public const OPTION_OPEN_WEBSOCKET_PROTOCOL = 'open_websocket_protocol';
public const OPTION_WEBSOCKET_SUBPROTOCOL = 'websocket_subprotocol';
public const OPTION_OPEN_WEBSOCKET_CLOSE_FRAME = 'open_websocket_close_frame';
public const OPTION_OPEN_WEBSOCKET_PING_FRAME = 'open_websocket_ping_frame';
public const OPTION_OPEN_WEBSOCKET_PONG_FRAME = 'open_websocket_pong_frame';
public const OPTION_OPEN_HTTP2_PROTOCOL = 'open_http2_protocol';
public const OPTION_OPEN_REDIS_PROTOCOL = 'open_redis_protocol';
public const OPTION_MAX_IDLE_TIME = 'max_idle_time';
public const OPTION_TCP_KEEPIDLE = 'tcp_keepidle';
public const OPTION_TCP_KEEPINTERVAL = 'tcp_keepinterval';
public const OPTION_TCP_KEEPCOUNT = 'tcp_keepcount';
public const OPTION_TCP_USER_TIMEOUT = 'tcp_user_timeout';
public const OPTION_TCP_FASTOPEN = 'tcp_fastopen';
public const OPTION_PACKAGE_BODY_START = 'package_body_start';
public const OPTION_SSL_CLIENT_CERT_FILE = 'ssl_client_cert_file';
public const OPTION_SSL_PREFER_SERVER_CIPHERS = 'ssl_prefer_server_ciphers';
public const OPTION_SSL_ECDH_CURVE = 'ssl_ecdh_curve';
public const OPTION_SSL_DHPARAM = 'ssl_dhparam';
public const OPTION_SSL_SNI_CERTS = 'ssl_sni_certs';
public const OPTION_OPEN_SSL = 'open_ssl';
public const OPTION_OPEN_FASTCGI_PROTOCOL = 'open_fastcgi_protocol';
public const OPTION_READ_TIMEOUT = 'read_timeout';
public const OPTION_WRITE_TIMEOUT = 'write_timeout';
public const OPTION_SSL_DISABLE_COMPRESSION = 'ssl_disable_compression';
public const OPTION_SSL_GREASE = 'ssl_grease';
public const OPTION_EXIT_CONDITION = 'exit_condition';
public const OPTION_DEADLOCK_CHECK_DISABLE_TRACE = 'deadlock_check_disable_trace';
public const OPTION_DEADLOCK_CHECK_LIMIT = 'deadlock_check_limit';
public const OPTION_DEADLOCK_CHECK_DEPTH = 'deadlock_check_depth';
public const OPTION_STATS_FILE = 'stats_file';
public const OPTION_STATS_TIMER_INTERVAL = 'stats_timer_interval';
public const OPTION_ADMIN_SERVER = 'admin_server';
/* }}} OPTION */
public const OPTION_HTTP_CLIENT_DRIVER = 'http_client_driver';
}
@swoole/library/core/StringObject.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
class StringObject implements \Stringable
{
/**
* StringObject constructor.
*/
public function __construct(protected string $string = '')
{
}
public function __toString(): string
{
return $this->string;
}
public static function from(string $string = ''): static
{
return new static($string); // @phpstan-ignore new.static
}
public function length(): int
{
return strlen($this->string);
}
public function indexOf(string $needle, int $offset = 0): false|int
{
return strpos($this->string, $needle, $offset);
}
public function lastIndexOf(string $needle, int $offset = 0): false|int
{
return strrpos($this->string, $needle, $offset);
}
public function pos(string $needle, int $offset = 0): false|int
{
return strpos($this->string, $needle, $offset);
}
public function rpos(string $needle, int $offset = 0): false|int
{
return strrpos($this->string, $needle, $offset);
}
public function reverse(): static
{
return new static(strrev($this->string)); // @phpstan-ignore new.static
}
/**
* @return false|int
*/
public function ipos(string $needle)
{
return stripos($this->string, $needle);
}
public function lower(): static
{
return new static(strtolower($this->string)); // @phpstan-ignore new.static
}
public function upper(): static
{
return new static(strtoupper($this->string)); // @phpstan-ignore new.static
}
public function trim(string $characters = ''): static
{
if ($characters) {
return new static(trim($this->string, $characters)); // @phpstan-ignore new.static
}
return new static(trim($this->string)); // @phpstan-ignore new.static
}
/**
* @return static
*/
public function ltrim(): self
{
return new static(ltrim($this->string)); // @phpstan-ignore new.static
}
/**
* @return static
*/
public function rtrim(): self
{
return new static(rtrim($this->string)); // @phpstan-ignore new.static
}
/**
* @return static
*/
public function substr(int $offset, ?int $length = null)
{
return new static(substr($this->string, $offset, $length)); // @phpstan-ignore new.static
}
public function repeat(int $times): static
{
return new static(str_repeat($this->string, $times)); // @phpstan-ignore new.static
}
public function append(mixed $str): static
{
return new static($this->string .= $str); // @phpstan-ignore new.static
}
/**
* @param int|null $count
*/
public function replace(string $search, string $replace, &$count = null): static
{
return new static(str_replace($search, $replace, $this->string, $count)); // @phpstan-ignore new.static
}
public function startsWith(string $needle): bool
{
return str_starts_with($this->string, $needle);
}
public function endsWith(string $needle): bool
{
return strrpos($this->string, $needle) === (strlen($this->string) - strlen($needle));
}
public function equals($str, bool $strict = false): bool
{
if ($str instanceof StringObject) {
$str = strval($str);
}
if ($strict) {
return $this->string === $str;
}
return $this->string == $str;
}
public function contains(string $subString): bool
{
return str_contains($this->string, $subString);
}
public function split(string $delimiter, int $limit = PHP_INT_MAX): ArrayObject
{
return static::detectArrayType(explode($delimiter, $this->string, $limit));
}
public function char(int $index): string
{
if ($index > strlen($this->string)) {
return '';
}
return $this->string[$index];
}
/**
* Get a new string object by splitting the string of current object into smaller chunks.
*
* @param int $length The chunk length.
* @param string $separator The line ending sequence.
* @see https://www.php.net/chunk_split
*/
public function chunkSplit(int $length = 76, string $separator = "\r\n"): static
{
return new static(chunk_split($this->string, $length, $separator)); // @phpstan-ignore new.static
}
/**
* Convert a string to an array object of class \Swoole\ArrayObject.
*
* @param int $length Maximum length of the chunk.
* @see https://www.php.net/str_split
*/
public function chunk(int $length = 1): ArrayObject
{
return static::detectArrayType(str_split($this->string, $length));
}
public function toString(): string
{
return $this->string;
}
protected static function detectArrayType(array $value): ArrayObject
{
return new ArrayObject($value);
}
}
@swoole/library/core/MultibyteStringObject.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
class MultibyteStringObject extends StringObject
{
public function length(): int
{
return mb_strlen($this->string);
}
public function indexOf(string $needle, int $offset = 0, ?string $encoding = null): false|int
{
return mb_strpos($this->string, $needle, $offset, $encoding);
}
public function lastIndexOf(string $needle, int $offset = 0, ?string $encoding = null): false|int
{
return mb_strrpos($this->string, $needle, $offset, $encoding);
}
public function pos(string $needle, int $offset = 0, ?string $encoding = null): false|int
{
return mb_strpos($this->string, $needle, $offset, $encoding);
}
public function rpos(string $needle, int $offset = 0, ?string $encoding = null): false|int
{
return mb_strrpos($this->string, $needle, $offset, $encoding);
}
public function ipos(string $needle, int $offset = 0, ?string $encoding = null): int|false
{
return mb_stripos($this->string, $needle, $offset, $encoding);
}
/**
* @see https://www.php.net/mb_substr
*/
public function substr(int $start, ?int $length = null, ?string $encoding = null): static
{
return new static(mb_substr($this->string, $start, $length, $encoding)); // @phpstan-ignore new.static
}
/**
* {@inheritDoc}
* @see https://www.php.net/mb_str_split
*/
public function chunk(int $length = 1): ArrayObject
{
return static::detectArrayType(mb_str_split($this->string, $length));
}
}
@swoole/library/core/Exception/ArrayKeyNotExists.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Exception;
class ArrayKeyNotExists extends \RuntimeException
{
}
@swoole/library/core/ArrayObject.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
use Swoole\Exception\ArrayKeyNotExists;
class ArrayObject implements \ArrayAccess, \Serializable, \Countable, \Iterator
{
/**
* @var array
*/
protected $array;
/**
* ArrayObject constructor.
*/
public function __construct(array $array = [])
{
$this->array = $array;
}
public function __toArray(): array
{
return $this->array;
}
public function __serialize(): array
{
return $this->array;
}
public function __unserialize(array $data): void
{
$this->array = $data;
}
public static function from(array $array = []): static
{
return new static($array); // @phpstan-ignore new.static
}
public function toArray(): array
{
return $this->array;
}
public function isEmpty(): bool
{
return empty($this->array);
}
public function count(): int
{
return count($this->array);
}
/**
* @return mixed
*/
#[\ReturnTypeWillChange]
public function current()
{
return current($this->array);
}
/**
* @return mixed
*/
#[\ReturnTypeWillChange]
public function key()
{
return key($this->array);
}
public function valid(): bool
{
return $this->key() !== null;
}
/**
* @return mixed
*/
#[\ReturnTypeWillChange]
public function rewind()
{
return reset($this->array);
}
/**
* @return mixed
*/
#[\ReturnTypeWillChange]
public function next()
{
return next($this->array);
}
/**
* @return ArrayObject|StringObject
*/
public function get(mixed $key)
{
if (!$this->exists($key)) {
throw new ArrayKeyNotExists($key);
}
return static::detectType($this->array[$key]);
}
/**
* @return ArrayObject|StringObject
*/
public function getOr(mixed $key, mixed $default = null)
{
if (!$this->exists($key)) {
return $default;
}
return static::detectType($this->array[$key]);
}
/**
* @return mixed
*/
public function last()
{
$key = array_key_last($this->array);
if ($key === null) {
return null;
}
return $this->get($key);
}
/**
* @return int|string|null
*/
public function firstKey()
{
return array_key_first($this->array);
}
/**
* @return int|string|null
*/
public function lastKey()
{
return array_key_last($this->array);
}
/**
* @return mixed
*/
public function first()
{
$key = array_key_first($this->array);
if ($key === null) {
return null;
}
return $this->get($key);
}
/**
* @return $this
*/
public function set(mixed $key, mixed $value): self
{
$this->array[$key] = $value;
return $this;
}
/**
* @return $this
*/
public function delete(mixed $key): self
{
unset($this->array[$key]);
return $this;
}
/**
* @return $this
*/
public function remove(mixed $value, bool $strict = true, bool $loop = false): self
{
do {
$key = $this->search($value, $strict);
if ($key === false) {
break;
}
unset($this->array[$key]);
} while ($loop);
return $this;
}
/**
* @return $this
*/
public function clear(): self
{
$this->array = [];
return $this;
}
/**
* @return mixed|null
*/
#[\ReturnTypeWillChange]
public function offsetGet(mixed $key)
{
if (!array_key_exists($key, $this->array)) {
return null;
}
return $this->array[$key];
}
public function offsetSet(mixed $key, mixed $value): void
{
$this->array[$key] = $value;
}
public function offsetUnset(mixed $key): void
{
unset($this->array[$key]);
}
/**
* @return bool
*/
#[\ReturnTypeWillChange]
public function offsetExists(mixed $key)
{
return isset($this->array[$key]);
}
public function exists(mixed $key): bool
{
return array_key_exists($key, $this->array);
}
public function contains(mixed $value, bool $strict = true): bool
{
return in_array($value, $this->array, $strict);
}
/**
* @return mixed
*/
public function indexOf(mixed $value, bool $strict = true)
{
return $this->search($value, $strict);
}
/**
* @return mixed
*/
public function lastIndexOf(mixed $value, bool $strict = true)
{
$array = $this->array;
for (end($array); ($currentKey = key($array)) !== null; prev($array)) {
$currentValue = current($array);
if ($currentValue == $value) {
if ($strict && $currentValue !== $value) {
continue;
}
break;
}
}
return $currentKey;
}
/**
* @return mixed
*/
public function search(mixed $needle, bool $strict = true)
{
return array_search($needle, $this->array, $strict);
}
public function join(string $glue = ''): StringObject
{
return self::detectStringType(implode($glue, $this->array));
}
public function serialize(): string
{
return serialize($this->array);
}
public function unserialize(string|\Stringable|StringObject $string): self
{
$this->array = (array) unserialize((string) $string);
return $this;
}
/**
* @return float|int
*/
public function sum()
{
return array_sum($this->array);
}
/**
* @return float|int
*/
public function product()
{
return array_product($this->array);
}
/**
* @return int
*/
public function push(mixed $value)
{
return $this->pushBack($value);
}
/**
* @return int
*/
public function pushFront(mixed $value)
{
return array_unshift($this->array, $value);
}
public function append(...$values): ArrayObject
{
array_push($this->array, ...$values);
return $this;
}
/**
* @return int
*/
public function pushBack(mixed $value)
{
return array_push($this->array, $value);
}
/**
* @return $this
*/
public function insert(int $offset, mixed $value): self
{
if (is_array($value) || is_object($value) || is_null($value)) {
$value = [$value];
}
array_splice($this->array, $offset, 0, $value);
return $this;
}
/**
* @return mixed
*/
public function pop()
{
return $this->popBack();
}
/**
* @return mixed
*/
public function popFront()
{
return array_shift($this->array);
}
/**
* @return mixed
*/
public function popBack()
{
return array_pop($this->array);
}
public function slice(int $offset, ?int $length = null, bool $preserve_keys = false): static
{
return new static(array_slice($this->array, $offset, $length, $preserve_keys)); // @phpstan-ignore new.static
}
/**
* @return ArrayObject|mixed|StringObject
*/
public function randomGet()
{
return static::detectType($this->array[array_rand($this->array, 1)]);
}
public function each(callable $fn): self
{
array_walk($this->array, $fn);
return $this;
}
/**
* @param array $args
*/
public function map(callable $fn, ...$args): static
{
return new static(array_map($fn, $this->array, ...$args)); // @phpstan-ignore new.static
}
/**
* @param null $initial
* @return mixed
*/
public function reduce(callable $fn, $initial = null)
{
return array_reduce($this->array, $fn, $initial);
}
/**
* @param array $args
*/
public function keys(...$args): static
{
return new static(array_keys($this->array, ...$args)); // @phpstan-ignore new.static
}
public function values(): static
{
return new static(array_values($this->array)); // @phpstan-ignore new.static
}
public function column(mixed $column_key, mixed $index = null): static
{
return new static(array_column($this->array, $column_key, $index)); // @phpstan-ignore new.static
}
public function unique(int $sort_flags = SORT_STRING): static
{
return new static(array_unique($this->array, $sort_flags)); // @phpstan-ignore new.static
}
public function reverse(bool $preserve_keys = false): static
{
return new static(array_reverse($this->array, $preserve_keys)); // @phpstan-ignore new.static
}
public function chunk(int $size, bool $preserve_keys = false): static
{
return new static(array_chunk($this->array, $size, $preserve_keys)); // @phpstan-ignore new.static
}
/**
* Swap keys and values in an array.
*/
public function flip(): static
{
return new static(array_flip($this->array)); // @phpstan-ignore new.static
}
public function filter(callable $fn, int $flag = 0): static
{
return new static(array_filter($this->array, $fn, $flag)); // @phpstan-ignore new.static
}
/**
* | Function name | Sorts by | Maintains key association | Order of sort | Related functions |
* | :---------------- | :------- | :-------------------------- | :-------------------------- | :---------------- |
* | array_multisort() | value | associative yes, numeric no | first array or sort options | array_walk() |
* | asort() | value | yes | low to high | arsort() |
* | arsort() | value | yes | high to low | asort() |
* | krsort() | key | yes | high to low | ksort() |
* | ksort() | key | yes | low to high | asort() |
* | natcasesort() | value | yes | natural, case insensitive | natsort() |
* | natsort() | value | yes | natural | natcasesort() |
* | rsort() | value | no | high to low | sort() |
* | shuffle() | value | no | random | array_rand() |
* | sort() | value | no | low to high | rsort() |
* | uasort() | value | yes | user defined | uksort() |
* | uksort() | key | yes | user defined | uasort() |
* | usort() | value | no | user defined | uasort() |
*/
/**
* @return $this
*/
public function asort(int $sort_flags = SORT_REGULAR): self
{
asort($this->array, $sort_flags);
return $this;
}
public function arsort(int $sort_flags = SORT_REGULAR): self
{
arsort($this->array, $sort_flags);
return $this;
}
public function krsort(int $sort_flags = SORT_REGULAR): self
{
krsort($this->array, $sort_flags);
return $this;
}
public function ksort(int $sort_flags = SORT_REGULAR): self
{
ksort($this->array, $sort_flags);
return $this;
}
/**
* @return $this
*/
public function natcasesort(): self
{
if (natcasesort($this->array) !== true) { // @phpstan-ignore notIdentical.alwaysFalse
throw new \RuntimeException('natcasesort() failed');
}
return $this;
}
/**
* @return $this
*/
public function natsort(): self
{
if (natsort($this->array) !== true) { // @phpstan-ignore notIdentical.alwaysFalse
throw new \RuntimeException('natsort() failed');
}
return $this;
}
/**
* @return $this
*/
public function rsort(int $sort_flags = SORT_REGULAR): self
{
if (rsort($this->array, $sort_flags) !== true) { // @phpstan-ignore notIdentical.alwaysFalse
throw new \RuntimeException('rsort() failed');
}
return $this;
}
public function shuffle(): self
{
shuffle($this->array);
return $this;
}
public function sort(int $sort_flags = SORT_REGULAR): self
{
sort($this->array, $sort_flags);
return $this;
}
public function uasort(callable $value_compare_func): self
{
uasort($this->array, $value_compare_func);
return $this;
}
public function uksort(callable $value_compare_func): self
{
uksort($this->array, $value_compare_func);
return $this;
}
public function usort(callable $value_compare_func): self
{
usort($this->array, $value_compare_func);
return $this;
}
/**
* @return ArrayObject|mixed|StringObject
*/
protected static function detectType(mixed $value)
{
if (is_string($value)) {
return static::detectStringType($value);
}
if (is_array($value)) {
return static::detectArrayType($value);
}
return $value;
}
protected static function detectStringType(string $value): StringObject
{
return new StringObject($value);
}
protected static function detectArrayType(array $value): static
{
return new static($value); // @phpstan-ignore new.static
}
}
@swoole/library/core/ObjectProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
class ObjectProxy
{
/** @var object */
protected $__object;
public function __construct(object $object)
{
$this->__object = $object;
}
public function __getObject()
{
return $this->__object;
}
public function __get(string $name)
{
return $this->__object->{$name};
}
public function __set(string $name, $value): void
{
$this->__object->{$name} = $value;
}
public function __isset($name)
{
return isset($this->__object->{$name});
}
public function __unset(string $name): void
{
unset($this->__object->{$name});
}
public function __call(string $name, array $arguments)
{
return $this->__object->{$name}(...$arguments);
}
public function __invoke(...$arguments)
{
/** @var mixed $object */
$object = $this->__object;
return $object(...$arguments);
}
}
@swoole/library/core/Coroutine/WaitGroup.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine;
class WaitGroup
{
protected Channel $chan;
protected int $count = 0;
protected bool $waiting = false;
public function __construct(int $delta = 0)
{
$this->chan = new Channel(1);
if ($delta > 0) {
$this->add($delta);
}
}
public function add(int $delta = 1): void
{
if ($this->waiting) {
throw new \BadMethodCallException('WaitGroup misuse: add called concurrently with wait');
}
$count = $this->count + $delta;
if ($count < 0) {
throw new \InvalidArgumentException('WaitGroup misuse: negative counter');
}
$this->count = $count;
}
public function done(): void
{
$count = $this->count - 1;
if ($count < 0) {
throw new \BadMethodCallException('WaitGroup misuse: negative counter');
}
$this->count = $count;
if ($count === 0 && $this->waiting) {
$this->chan->push(true);
}
}
public function wait(float $timeout = -1): bool
{
if ($this->waiting) {
throw new \BadMethodCallException('WaitGroup misuse: reused before previous wait has returned');
}
if ($this->count > 0) {
$this->waiting = true;
$done = $this->chan->pop($timeout);
$this->waiting = false;
return $done;
}
return true;
}
public function count(): int
{
return $this->count;
}
}
@swoole/library/core/Coroutine/Server.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine;
use Swoole\Constant;
use Swoole\Coroutine;
use Swoole\Coroutine\Server\Connection;
use Swoole\Exception;
class Server
{
/** @var string */
public $host = '';
/** @var int */
public $port = 0;
/** @var int */
public $type = AF_INET;
/** @var int */
public $fd = -1;
/** @var int */
public $errCode = 0;
/** @var array */
public $setting = [];
/** @var bool */
protected $running = false;
/** @var callable|null */
protected $fn;
/** @var Socket */
protected $socket;
/**
* Server constructor.
* @throws Exception
*/
public function __construct(string $host, int $port = 0, bool $ssl = false, bool $reuse_port = false)
{
$_host = swoole_string($host);
if ($_host->contains('::')) {
$this->type = AF_INET6;
} elseif ($_host->startsWith('unix:/')) {
$host = $_host->substr(5)->__toString();
$this->type = AF_UNIX;
} else {
$this->type = AF_INET;
}
$this->host = $host;
$socket = new Socket($this->type, SOCK_STREAM, 0);
if ($reuse_port and defined('SO_REUSEPORT')) {
$socket->setOption(SOL_SOCKET, SO_REUSEPORT, true);
}
if (!$socket->bind($this->host, $port)) {
throw new Exception("bind({$this->host}:{$port}) failed", $socket->errCode);
}
if (!$socket->listen()) {
throw new Exception('listen() failed', $socket->errCode);
}
$this->port = $socket->getsockname()['port'] ?? 0;
$this->fd = $socket->fd;
$this->socket = $socket;
$this->setting['open_ssl'] = $ssl;
}
public function set(array $setting): void
{
$this->setting = array_merge($this->setting, $setting);
}
public function handle(callable $fn): void
{
$this->fn = $fn;
}
public function shutdown(): bool
{
$this->running = false;
return $this->socket->cancel();
}
public function start(): bool
{
$this->running = true;
if ($this->fn === null) {
$this->errCode = SOCKET_EINVAL;
return false;
}
$socket = $this->socket;
if (!$socket->setProtocol($this->setting)) {
$this->errCode = SOCKET_EINVAL;
return false;
}
while ($this->running) { // @phpstan-ignore while.alwaysTrue
$conn = null;
/** @var Socket $conn */
$conn = $socket->accept();
if ($conn) { // @phpstan-ignore if.alwaysTrue
$conn->setProtocol($this->setting);
if (!empty($this->setting[Constant::OPTION_OPEN_SSL])) {
$fn = static function ($fn, $connection) {
/* @var $connection Connection */
if (!$connection->exportSocket()->sslHandshake()) {
return;
}
$fn($connection);
};
$arguments = [$this->fn, new Connection($conn)];
} else {
$fn = $this->fn;
$arguments = [new Connection($conn)];
}
if (Coroutine::create($fn, ...$arguments) < 0) {
goto _wait;
}
} else {
if ($socket->errCode == SOCKET_EMFILE or $socket->errCode == SOCKET_ENFILE) {
_wait:
Coroutine::sleep(1);
continue;
}
if ($socket->errCode == SOCKET_ETIMEDOUT) {
continue;
}
if ($socket->errCode == SOCKET_ECANCELED) {
break;
}
trigger_error("accept failed, Error: {$socket->errMsg}[{$socket->errCode}]", E_USER_WARNING);
break;
}
}
return true; // @phpstan-ignore deadCode.unreachable
}
}
@swoole/library/core/Coroutine/Server/Connection.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine\Server;
use Swoole\Coroutine\Socket;
class Connection
{
protected $socket;
public function __construct(Socket $conn)
{
$this->socket = $conn;
}
public function recv(float $timeout = 0)
{
return $this->socket->recvPacket($timeout);
}
public function send(string $data)
{
return $this->socket->sendAll($data);
}
public function close(): bool
{
return $this->socket->close();
}
public function exportSocket(): Socket
{
return $this->socket;
}
}
@swoole/library/core/Coroutine/Barrier.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine;
use Swoole\Coroutine;
use Swoole\Exception;
use Swoole\Timer;
class Barrier
{
private int $cid = -1;
private $timer = -1;
private static array $cancel_list = [];
public function __destruct()
{
if ($this->timer !== -1) {
Timer::clear($this->timer);
if (isset(self::$cancel_list[$this->cid])) {
unset(self::$cancel_list[$this->cid]);
return;
}
}
if ($this->cid !== -1 && $this->cid !== Coroutine::getCid()) {
Coroutine::resume($this->cid);
} else {
self::$cancel_list[$this->cid] = true;
}
}
public static function make(): self
{
return new self();
}
/**
* @param-out null $barrier
*/
public static function wait(Barrier &$barrier, float $timeout = -1): void
{
if ($barrier->cid !== -1) {
throw new Exception('The barrier is waiting, cannot wait again.');
}
$cid = Coroutine::getCid();
$barrier->cid = $cid;
if ($timeout > 0 && ($timeout_ms = (int) ($timeout * 1000)) > 0) {
$barrier->timer = Timer::after($timeout_ms, function () use ($cid) {
self::$cancel_list[$cid] = true;
Coroutine::resume($cid);
});
}
$barrier = null;
if (!isset(self::$cancel_list[$cid])) {
Coroutine::yield();
} else {
unset(self::$cancel_list[$cid]);
}
}
}
@swoole/library/core/Coroutine/Http/ClientProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine\Http;
class ClientProxy
{
private array $headers;
private array $cookies;
public function __construct(private string $body, private int $statusCode, ?array $headers, ?array $cookies)
{
$this->headers = $headers ?? [];
$this->cookies = $cookies ?? [];
}
public function getBody(): string
{
return $this->body;
}
public function getStatusCode(): int
{
return $this->statusCode;
}
public function getHeaders(): array
{
return $this->headers;
}
public function getCookies(): array
{
return $this->cookies;
}
}
@swoole/library/core/Coroutine/Http/functions.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Coroutine\Http;
use Swoole\Coroutine\Http\Client\Exception;
/**
* @throws Exception
*/
function request(
string $url,
string $method,
mixed $data = null,
?array $options = null,
?array $headers = null,
?array $cookies = null,
): ClientProxy {
$driver = swoole_library_get_option('http_client_driver');
return match ($driver) {
'curl' => request_with_curl($url, $method, $data, $options, $headers, $cookies),
'stream' => request_with_stream($url, $method, $data, $options, $headers, $cookies),
default => request_with_http_client($url, $method, $data, $options, $headers, $cookies),
};
}
/**
* @throws Exception
*/
function request_with_http_client(
string $url,
string $method,
mixed $data = null,
?array $options = null,
?array $headers = null,
?array $cookies = null,
): ClientProxy {
$info = parse_url($url);
if (empty($info['scheme'])) {
throw new Exception('The URL given is illegal [no scheme]');
}
if ($info['scheme'] == 'http') {
$client = new Client($info['host'], swoole_array_default_value($info, 'port', 80), false);
} elseif ($info['scheme'] == 'https') {
$client = new Client($info['host'], swoole_array_default_value($info, 'port', 443), true);
} else {
throw new Exception('unknown scheme "' . $info['scheme'] . '"');
}
$client->setMethod($method);
if ($data) {
$client->setData($data);
}
$client->set($options ?: []);
$client->setHeaders($headers ?: []);
$client->setCookies($cookies ?: []);
$request_url = swoole_array_default_value($info, 'path', '/');
if (!empty($info['query'])) {
$request_url .= '?' . $info['query'];
}
if ($client->execute($request_url)) {
return new ClientProxy(
$client->getBody(),
$client->getStatusCode(),
$client->getHeaders() ?: [],
$client->getCookies() ?: []
);
}
throw new Exception($client->errMsg, $client->errCode);
}
/**
* @throws Exception
*/
function request_with_curl(
string $url,
string $method,
mixed $data = null,
?array $options = null,
?array $headers = null,
?array $cookies = null,
): ClientProxy {
$ch = curl_init($url);
if (empty($ch)) {
throw new Exception('failed to curl_init');
}
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, strtoupper($method));
$responseHeaders = $responseCookies = [];
curl_setopt($ch, CURLOPT_HEADERFUNCTION, function ($ch, $header) use (&$responseHeaders, &$responseCookies) {
$len = strlen($header);
$header = explode(':', $header, 2);
if (count($header) < 2) {
return $len;
}
$headerKey = strtolower(trim($header[0]));
if ($headerKey == 'set-cookie') {
[$k, $v] = explode('=', $header[1]);
$responseCookies[$k] = $v;
} else {
$responseHeaders[$headerKey][] = trim($header[1]);
}
return $len;
});
if ($data) {
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
}
if ($headers) {
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
}
if ($cookies) {
$cookie_str = '';
foreach ($cookies as $k => $v) {
$cookie_str .= "{$k}={$v}; ";
}
curl_setopt($ch, CURLOPT_COOKIE, $cookie_str);
}
if (isset($options['timeout'])) {
if (is_float($options['timeout'])) {
curl_setopt($ch, CURLOPT_TIMEOUT_MS, intval($options['timeout'] * 1000));
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT_MS, intval($options['timeout'] * 1000));
} else {
curl_setopt($ch, CURLOPT_TIMEOUT, intval($options['timeout']));
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, intval($options['timeout']));
}
}
if (isset($options['connect_timeout'])) {
if (is_float($options['connect_timeout'])) {
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT_MS, intval($options['connect_timeout'] * 1000));
} else {
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, intval($options['connect_timeout']));
}
}
$body = curl_exec($ch);
if ($body !== false) {
return new ClientProxy($body, curl_getinfo($ch, CURLINFO_RESPONSE_CODE), $responseHeaders, $responseCookies);
}
throw new Exception(curl_error($ch), curl_errno($ch));
}
/**
* @throws Exception
*/
function request_with_stream(
string $url,
string $method,
mixed $data = null,
?array $options = null,
?array $headers = null,
?array $cookies = null,
): ClientProxy {
$stream_options = [
'http' => [
'method' => $method,
],
];
$headerStr = '';
if ($headers) {
foreach ($headers as $k => $v) {
$headerStr .= "{$k}: {$v}\r\n";
}
}
if ($cookies) {
foreach ($cookies as $k => $v) {
$headerStr .= "Cookie: {$k}={$v}\r\n";
}
}
if (isset($options['timeout'])) {
$stream_options['http']['timeout'] = intval($options['timeout']);
}
if ($data) {
if (is_array($data)) {
$headerStr .= "Content-type: application/x-www-form-urlencoded\r\n";
$stream_options['http']['content'] = http_build_query($data);
} else {
$stream_options['http']['content'] = strval($data);
}
}
if ($headerStr) {
$stream_options['http']['header'] = $headerStr;
}
$body = file_get_contents($url, false, stream_context_create($stream_options));
if ($body) {
return new ClientProxy($body, 200, [], []);
}
$error = error_get_last();
throw new Exception($error['message']);
}
/**
* @throws Exception
*/
function post(string $url, mixed $data, ?array $options = null, ?array $headers = null, ?array $cookies = null): ClientProxy
{
return request($url, 'POST', $data, $options, $headers, $cookies);
}
/**
* @throws Exception
*/
function get(string $url, ?array $options = null, ?array $headers = null, ?array $cookies = null): ClientProxy
{
return request($url, 'GET', null, $options, $headers, $cookies);
}
@swoole/library/core/ConnectionPool.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
use Swoole\Coroutine\Channel;
class ConnectionPool
{
public const DEFAULT_SIZE = 64;
protected ?Channel $pool;
/** @var callable */
protected $constructor;
protected int $size;
protected int $num = 0;
public function __construct(callable $constructor, int $size = self::DEFAULT_SIZE, protected ?string $proxy = null)
{
$this->pool = new Channel($this->size = $size);
$this->constructor = $constructor;
}
public function fill(): void
{
while ($this->size > $this->num) {
$this->make();
}
}
/**
* Get a connection from the pool.
*
* @param float $timeout > 0 means waiting for the specified number of seconds. other means no waiting.
* @return mixed|false Returns a connection object from the pool, or false if the pool is full and the timeout is reached.
*/
public function get(float $timeout = -1)
{
if ($this->pool === null) {
throw new \RuntimeException('Pool has been closed');
}
if ($this->pool->isEmpty() && $this->num < $this->size) {
$this->make();
}
return $this->pool->pop($timeout);
}
public function put($connection): void
{
if ($this->pool === null) {
return;
}
if ($connection !== null) {
$this->pool->push($connection);
} else {
/* connection broken */
$this->num -= 1;
$this->make();
}
}
public function close(): void
{
$this->pool->close();
$this->pool = null;
$this->num = 0;
}
protected function make(): void
{
$this->num++;
try {
if ($this->proxy) {
$connection = new $this->proxy($this->constructor);
} else {
$constructor = $this->constructor;
$connection = $constructor();
}
} catch (\Throwable $throwable) {
$this->num--;
throw $throwable;
}
$this->put($connection);
}
}
@swoole/library/core/Database/ObjectProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class ObjectProxy extends \Swoole\ObjectProxy
{
final public function __clone(): void
{
throw new \Error('Trying to clone an uncloneable database proxy object');
}
}
@swoole/library/core/Database/MysqliConfig.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class MysqliConfig
{
protected string $host = '127.0.0.1';
protected int $port = 3306;
protected ?string $unixSocket;
protected string $dbname = 'test';
protected string $charset = 'utf8mb4';
protected string $username = 'root';
protected string $password = 'root';
protected array $options = [];
public function getHost(): string
{
return $this->host;
}
public function withHost(string $host): self
{
$this->host = $host;
return $this;
}
public function getPort(): int
{
return $this->port;
}
public function getUnixSocket(): ?string
{
return $this->unixSocket ?? null;
}
public function withUnixSocket(?string $unixSocket): self
{
$this->unixSocket = $unixSocket;
return $this;
}
public function withPort(int $port): self
{
$this->port = $port;
return $this;
}
public function getDbname(): string
{
return $this->dbname;
}
public function withDbname(string $dbname): self
{
$this->dbname = $dbname;
return $this;
}
public function getCharset(): string
{
return $this->charset;
}
public function withCharset(string $charset): self
{
$this->charset = $charset;
return $this;
}
public function getUsername(): string
{
return $this->username;
}
public function withUsername(string $username): self
{
$this->username = $username;
return $this;
}
public function getPassword(): string
{
return $this->password;
}
public function withPassword(string $password): self
{
$this->password = $password;
return $this;
}
public function getOptions(): array
{
return $this->options;
}
public function withOptions(array $options): self
{
$this->options = $options;
return $this;
}
}
@swoole/library/core/Database/MysqliException.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class MysqliException extends \Exception
{
}
@swoole/library/core/Database/MysqliPool.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
use mysqli;
use Swoole\ConnectionPool;
/**
* @method \mysqli|MysqliProxy get()
* @method void put(mysqli|MysqliProxy $connection)
*/
class MysqliPool extends ConnectionPool
{
public function __construct(protected MysqliConfig $config, int $size = self::DEFAULT_SIZE)
{
parent::__construct(function () {
$mysqli = new \mysqli();
foreach ($this->config->getOptions() as $option => $value) {
$mysqli->set_opt($option, $value);
}
$mysqli->real_connect(
$this->config->getHost(),
$this->config->getUsername(),
$this->config->getPassword(),
$this->config->getDbname(),
$this->config->getPort(),
$this->config->getUnixSocket()
);
if ($mysqli->connect_errno) {
throw new MysqliException($mysqli->connect_error, $mysqli->connect_errno);
}
$mysqli->set_charset($this->config->getCharset());
return $mysqli;
}, $size, MysqliProxy::class);
}
}
@swoole/library/core/Database/MysqliProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
/**
* @method \mysqli __getObject()
*/
class MysqliProxy extends ObjectProxy
{
public const IO_METHOD_REGEX = '/^autocommit|begin_transaction|change_user|close|commit|kill|multi_query|ping|prepare|query|real_connect|real_query|reap_async_query|refresh|release_savepoint|rollback|savepoint|select_db|send_query|set_charset|ssl_set$/i';
public const IO_ERRORS = [
2002, // MYSQLND_CR_CONNECTION_ERROR
2006, // MYSQLND_CR_SERVER_GONE_ERROR
2013, // MYSQLND_CR_SERVER_LOST
];
/** @var \mysqli */
protected $__object;
protected string $charsetContext;
protected array $setOptContext = [];
protected array $changeUserContext;
/** @var callable */
protected $constructor;
protected int $round = 0;
public function __construct(callable $constructor)
{
parent::__construct($constructor());
$this->constructor = $constructor;
}
public function __call(string $name, array $arguments)
{
for ($n = 3; $n--;) {
$ret = @$this->__object->{$name}(...$arguments);
if ($ret === false) {
/* non-IO method */
if (!preg_match(static::IO_METHOD_REGEX, $name)) {
break;
}
/* no more chances or non-IO failures */
if (!in_array($this->__object->errno, static::IO_ERRORS, true) || ($n === 0)) {
throw new MysqliException($this->__object->error, $this->__object->errno);
}
$this->reconnect();
continue;
}
if (strcasecmp($name, 'prepare') === 0) {
$ret = new MysqliStatementProxy($ret, $arguments[0], $this);
} elseif (strcasecmp($name, 'stmt_init') === 0) {
$ret = new MysqliStatementProxy($ret, null, $this);
}
break;
}
/* @noinspection PhpUndefinedVariableInspection */
return $ret;
}
public function getRound(): int
{
return $this->round;
}
public function reconnect(): void
{
$constructor = $this->constructor;
parent::__construct($constructor());
$this->round++;
/* restore context */
if (!empty($this->charsetContext)) {
$this->__object->set_charset($this->charsetContext);
}
foreach ($this->setOptContext as $opt => $val) {
$this->__object->set_opt($opt, $val);
}
if (!empty($this->changeUserContext)) {
$this->__object->change_user(...$this->changeUserContext);
}
}
public function options(int $option, $value): bool
{
$this->setOptContext[$option] = $value;
return $this->__object->options($option, $value);
}
public function set_opt(int $option, $value): bool
{
return $this->options($option, $value);
}
public function set_charset(string $charset): bool
{
$this->charsetContext = $charset;
return $this->__object->set_charset($charset);
}
public function change_user(string $user, string $password, ?string $database): bool
{
$this->changeUserContext = [$user, $password, $database];
return $this->__object->change_user($user, $password, $database);
}
}
@swoole/library/core/Database/MysqliStatementProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class MysqliStatementProxy extends ObjectProxy
{
public const IO_METHOD_REGEX = '/^close|execute|fetch|prepare$/i';
/** @var \mysqli_stmt */
protected $__object;
protected ?string $queryString;
protected array $attrSetContext = [];
protected array $bindParamContext;
protected array $bindResultContext;
protected MysqliProxy $parent;
protected int $parentRound;
public function __construct(\mysqli_stmt $object, ?string $queryString, MysqliProxy $parent)
{
parent::__construct($object);
$this->queryString = $queryString;
$this->parent = $parent;
$this->parentRound = $parent->getRound();
}
public function __call(string $name, array $arguments)
{
for ($n = 3; $n--;) {
$ret = @$this->__object->{$name}(...$arguments);
if ($ret === false) {
/* non-IO method */
if (!preg_match(static::IO_METHOD_REGEX, $name)) {
break;
}
/* no more chances or non-IO failures or in transaction */
if (!in_array($this->__object->errno, $this->parent::IO_ERRORS, true) || ($n === 0)) {
throw new MysqliException($this->__object->error, $this->__object->errno);
}
if ($this->parent->getRound() === $this->parentRound) {
/* if not equal, parent has reconnected */
$this->parent->reconnect();
}
$parent = $this->parent->__getObject();
$this->__object = $this->queryString ? @$parent->prepare($this->queryString) : @$parent->stmt_init();
if ($this->__object === false) {
throw new MysqliException($parent->error, $parent->errno);
}
if (!empty($this->bindParamContext)) {
$this->__object->bind_param($this->bindParamContext[0], ...$this->bindParamContext[1]);
}
if (!empty($this->bindResultContext)) {
$this->__object->bind_result($this->bindResultContext);
}
foreach ($this->attrSetContext as $attr => $value) {
$this->__object->attr_set($attr, $value);
}
continue;
}
if (strcasecmp($name, 'prepare') === 0) {
$this->queryString = $arguments[0];
}
break;
}
/* @noinspection PhpUndefinedVariableInspection */
return $ret;
}
public function attr_set($attr, $mode): bool
{
$this->attrSetContext[$attr] = $mode;
return $this->__object->attr_set($attr, $mode);
}
public function bind_param($types, &...$arguments): bool
{
$this->bindParamContext = [$types, $arguments];
return $this->__object->bind_param($types, ...$arguments);
}
public function bind_result(&...$arguments): bool
{
$this->bindResultContext = $arguments;
return $this->__object->bind_result(...$arguments);
}
}
@swoole/library/core/Database/DetectsLostConnections.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class DetectsLostConnections
{
/**
* @var array
*/
private const ERROR_MESSAGES = [
'server has gone away',
'Server has gone away',
'no connection to the server',
'Lost connection',
'is dead or not enabled',
'Error while sending',
'decryption failed or bad record mac',
'server closed the connection unexpectedly',
'SSL connection has been closed unexpectedly',
'Error writing data to the connection',
'Resource deadlock avoided',
'Transaction() on null',
'child connection forced to terminate due to client_idle_limit',
'query_wait_timeout',
'reset by peer',
'Physical connection is not usable',
'TCP Provider: Error code 0x68',
'ORA-03113',
'ORA-03114',
'Packets out of order. Expected',
'Adaptive Server connection failed',
'Communication link failure',
'connection is no longer usable',
'Login timeout expired',
'SQLSTATE[HY000] [2002] Connection refused',
'running with the --read-only option so it cannot execute this statement',
'The connection is broken and recovery is not possible. The connection is marked by the client driver as unrecoverable. No attempt was made to restore the connection.',
'SQLSTATE[HY000] [2002] php_network_getaddresses: getaddrinfo failed: Try again',
'SQLSTATE[HY000] [2002] php_network_getaddresses: getaddrinfo failed: Name or service not known',
'SQLSTATE[HY000] [2002] php_network_getaddresses: getaddrinfo for',
'SQLSTATE[HY000]: General error: 7 SSL SYSCALL error: EOF detected',
'SSL error: unexpected eof',
'SQLSTATE[HY000] [2002] Connection timed out',
'SSL: Connection timed out',
'SQLSTATE[HY000]: General error: 1105 The last transaction was aborted due to Seamless Scaling. Please retry.',
'Temporary failure in name resolution',
'SQLSTATE[08S01]: Communication link failure',
'SQLSTATE[08006] [7] could not connect to server: Connection refused Is the server running on host',
'SQLSTATE[HY000]: General error: 7 SSL SYSCALL error: No route to host',
'The client was disconnected by the server because of inactivity. See wait_timeout and interactive_timeout for configuring this behavior.',
'SQLSTATE[08006] [7] could not translate host name',
'TCP Provider: Error code 0x274C',
'SQLSTATE[HY000] [2002] No such file or directory',
'SSL: Operation timed out',
'Reason: Server is in script upgrade mode. Only administrator can connect at this time.',
'Unknown $curl_error_code: 77',
'SSL: Handshake timed out',
'SQLSTATE[08006] [7] SSL error: sslv3 alert unexpected message',
'SQLSTATE[08006] [7] unrecognized SSL error code:',
'SQLSTATE[HY000] [1045] Access denied for user',
'SQLSTATE[HY000] [2002] No connection could be made because the target machine actively refused it',
'SQLSTATE[HY000] [2002] A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond',
'SQLSTATE[HY000] [2002] Network is unreachable',
'SQLSTATE[HY000] [2002] The requested address is not valid in its context',
'SQLSTATE[HY000] [2002] A socket operation was attempted to an unreachable network',
'SQLSTATE[HY000] [2002] Operation now in progress',
'SQLSTATE[HY000] [2002] Operation in progress',
'SQLSTATE[HY000]: General error: 3989',
'went away',
'No such file or directory',
'server is shutting down',
'failed to connect to',
'Channel connection is closed',
'Connection lost',
'Broken pipe',
'SQLSTATE[25006]: Read only sql transaction: 7',
'vtgate connection error: no healthy endpoints',
'primary is not serving, there may be a reparent operation in progress',
'current keyspace is being resharded',
'no healthy tablet available',
'transaction pool connection limit exceeded',
'SSL operation failed with code 5',
// PDO::prepare(): Send of 77 bytes failed with errno=110 Operation timed out
// SSL: Handshake timed out
// SSL: Operation timed out
// SSL: Connection timed out
// SQLSTATE[HY000] [2002] Connection timed out
'timed out',
'Error reading result',
];
public static function causedByLostConnection(\Throwable $e): bool
{
$message = $e->getMessage();
foreach (self::ERROR_MESSAGES as $needle) {
if (mb_strpos($message, $needle) !== false) {
return true;
}
}
return false;
}
}
@swoole/library/core/Database/PDOConfig.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class PDOConfig
{
public const DRIVER_MYSQL = 'mysql';
protected string $driver = self::DRIVER_MYSQL;
protected string $host = '127.0.0.1';
protected int $port = 3306;
protected ?string $unixSocket;
protected string $dbname = 'test';
protected string $charset = 'utf8mb4';
protected string $username = 'root';
protected string $password = 'root';
protected array $options = [];
public function getDriver(): string
{
return $this->driver;
}
public function withDriver(string $driver): self
{
$this->driver = $driver;
return $this;
}
public function getHost(): string
{
return $this->host;
}
public function withHost(string $host): self
{
$this->host = $host;
return $this;
}
public function getPort(): int
{
return $this->port;
}
public function hasUnixSocket(): bool
{
return !empty($this->unixSocket);
}
public function getUnixSocket(): ?string
{
return $this->unixSocket ?? null;
}
public function withUnixSocket(?string $unixSocket): self
{
$this->unixSocket = $unixSocket;
return $this;
}
public function withPort(int $port): self
{
$this->port = $port;
return $this;
}
public function getDbname(): string
{
return $this->dbname;
}
public function withDbname(string $dbname): self
{
$this->dbname = $dbname;
return $this;
}
public function getCharset(): string
{
return $this->charset;
}
public function withCharset(string $charset): self
{
$this->charset = $charset;
return $this;
}
public function getUsername(): string
{
return $this->username;
}
public function withUsername(string $username): self
{
$this->username = $username;
return $this;
}
public function getPassword(): string
{
return $this->password;
}
public function withPassword(string $password): self
{
$this->password = $password;
return $this;
}
public function getOptions(): array
{
return $this->options;
}
public function withOptions(array $options): self
{
$this->options = $options;
return $this;
}
/**
* Returns the list of available drivers
*
* @return string[]
*/
public static function getAvailableDrivers(): array
{
return [
self::DRIVER_MYSQL,
];
}
}
@swoole/library/core/Database/PDOPool.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
use PDO;
use Swoole\ConnectionPool;
/**
* @method void put(PDO|PDOProxy $connection)
*/
class PDOPool extends ConnectionPool
{
public function __construct(protected PDOConfig $config, int $size = self::DEFAULT_SIZE)
{
parent::__construct(function () {
$driver = $this->config->getDriver();
if ($driver === 'sqlite') {
return new \PDO($this->createDSN('sqlite'));
}
return new \PDO($this->createDSN($driver), $this->config->getUsername(), $this->config->getPassword(), $this->config->getOptions());
}, $size, PDOProxy::class);
}
/**
* Get a PDO connection from the pool. The PDO connection (a PDO object) is wrapped in a PDOProxy object returned.
*
* @param float $timeout > 0 means waiting for the specified number of seconds. other means no waiting.
* @return PDOProxy|false Returns a PDOProxy object from the pool, or false if the pool is full and the timeout is reached.
* {@inheritDoc}
*/
public function get(float $timeout = -1)
{
/* @var \Swoole\Database\PDOProxy|false $pdo */
$pdo = parent::get($timeout);
if ($pdo === false) {
return false;
}
$pdo->reset();
return $pdo;
}
/**
* @purpose create DSN
* @throws \Exception
*/
private function createDSN(string $driver): string
{
switch ($driver) {
case 'mysql':
if ($this->config->hasUnixSocket()) {
$dsn = "mysql:unix_socket={$this->config->getUnixSocket()};dbname={$this->config->getDbname()};charset={$this->config->getCharset()}";
} else {
$dsn = "mysql:host={$this->config->getHost()};port={$this->config->getPort()};dbname={$this->config->getDbname()};charset={$this->config->getCharset()}";
}
break;
case 'pgsql':
$dsn = 'pgsql:host=' . ($this->config->hasUnixSocket() ? $this->config->getUnixSocket() : $this->config->getHost()) . ";port={$this->config->getPort()};dbname={$this->config->getDbname()}";
break;
case 'oci':
$dsn = 'oci:dbname=' . ($this->config->hasUnixSocket() ? $this->config->getUnixSocket() : $this->config->getHost()) . ':' . $this->config->getPort() . '/' . $this->config->getDbname() . ';charset=' . $this->config->getCharset();
break;
case 'sqlite':
// There are three types of SQLite databases: databases on disk, databases in memory, and temporary
// databases (which are deleted when the connections are closed). It doesn't make sense to use
// connection pool for the latter two types of databases, because each connection connects to a
//different in-memory or temporary SQLite database.
if ($this->config->getDbname() === '') {
throw new \Exception('Connection pool in Swoole does not support temporary SQLite databases.');
}
if ($this->config->getDbname() === ':memory:') {
throw new \Exception('Connection pool in Swoole does not support creating SQLite databases in memory.');
}
$dsn = 'sqlite:' . $this->config->getDbname();
break;
default:
throw new \Exception('Unsupported Database Driver:' . $driver);
}
return $dsn;
}
}
@swoole/library/core/Database/PDOProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
/**
* @method \PDO __getObject()
*/
class PDOProxy extends ObjectProxy
{
/** @var \PDO */
protected $__object;
protected array $setAttributeContext = [];
/** @var callable */
protected $constructor;
protected int $round = 0;
protected int $inTransaction = 0;
public function __construct(callable $constructor)
{
parent::__construct($constructor());
$this->__object->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->constructor = $constructor;
}
public function __call(string $name, array $arguments)
{
try {
$ret = $this->__object->{$name}(...$arguments);
} catch (\PDOException $e) {
if (!$this->__object->inTransaction() && DetectsLostConnections::causedByLostConnection($e)) {
$this->reconnect();
$ret = $this->__object->{$name}(...$arguments);
} else {
throw $e;
}
}
if (strcasecmp($name, 'beginTransaction') === 0) {
$this->inTransaction++;
}
if ((strcasecmp($name, 'commit') === 0 || strcasecmp($name, 'rollback') === 0) && $this->inTransaction > 0) {
$this->inTransaction--;
}
if ((strcasecmp($name, 'prepare') === 0) || (strcasecmp($name, 'query') === 0)) {
$ret = new PDOStatementProxy($ret, $this);
}
return $ret;
}
public function getRound(): int
{
return $this->round;
}
public function reconnect(): void
{
$constructor = $this->constructor;
parent::__construct($constructor());
$this->__object->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->round++;
/* restore context */
foreach ($this->setAttributeContext as $attribute => $value) {
$this->__object->setAttribute($attribute, $value);
}
}
public function setAttribute(int $attribute, $value): bool
{
$this->setAttributeContext[$attribute] = $value;
return $this->__object->setAttribute($attribute, $value);
}
public function inTransaction(): bool
{
return $this->inTransaction > 0;
}
public function reset(): void
{
$this->inTransaction = 0;
}
}
@swoole/library/core/Database/PDOStatementProxy.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
/**
* The proxy class for PHP class PDOStatement.
*
* @see https://www.php.net/PDOStatement The PDOStatement class
*/
class PDOStatementProxy extends ObjectProxy
{
/** @var \PDOStatement */
protected $__object;
protected array $setAttributeContext = [];
protected array $setFetchModeContext;
protected array $bindParamContext = [];
protected array $bindColumnContext = [];
protected array $bindValueContext = [];
protected PDOProxy $parent;
/** @var int */
protected $parentRound;
public function __construct(\PDOStatement $object, PDOProxy $parent)
{
parent::__construct($object);
$this->parent = $parent;
$this->parentRound = $parent->getRound();
}
public function __call(string $name, array $arguments)
{
try {
$ret = $this->__object->{$name}(...$arguments);
} catch (\PDOException $e) {
if (!$this->parent->inTransaction() && DetectsLostConnections::causedByLostConnection($e)) {
if ($this->parent->getRound() === $this->parentRound) {
/* if not equal, parent has reconnected */
$this->parent->reconnect();
}
$parent = $this->parent->__getObject();
$this->__object = $parent->prepare($this->__object->queryString);
foreach ($this->setAttributeContext as $attribute => $value) {
$this->__object->setAttribute($attribute, $value);
}
if (!empty($this->setFetchModeContext)) {
$this->__object->setFetchMode(...$this->setFetchModeContext);
}
foreach ($this->bindParamContext as $param => $item) {
$this->__object->bindParam($param, ...$item);
}
foreach ($this->bindColumnContext as $column => $item) {
$this->__object->bindColumn($column, ...$item);
}
foreach ($this->bindValueContext as $value => $item) {
$this->__object->bindParam($value, ...$item);
}
$ret = $this->__object->{$name}(...$arguments);
} else {
throw $e;
}
}
return $ret;
}
public function setAttribute(int $attribute, $value): bool
{
$this->setAttributeContext[$attribute] = $value;
return $this->__object->setAttribute($attribute, $value);
}
/**
* Set the default fetch mode for this statement.
*
* @see https://www.php.net/manual/en/pdostatement.setfetchmode.php
*/
public function setFetchMode(int $mode, ...$params): bool
{
$this->setFetchModeContext = func_get_args();
return $this->__object->setFetchMode(...$this->setFetchModeContext);
}
public function bindParam($parameter, &$variable, $data_type = \PDO::PARAM_STR, $length = 0, $driver_options = null): bool
{
$this->bindParamContext[$parameter] = [$variable, $data_type, $length, $driver_options];
return $this->__object->bindParam($parameter, $variable, $data_type, $length, $driver_options);
}
public function bindColumn($column, &$param, $type = null, $maxlen = null, $driverdata = null): bool
{
$this->bindColumnContext[$column] = [$param, $type, $maxlen, $driverdata];
return $this->__object->bindColumn($column, $param, $type, $maxlen, $driverdata);
}
public function bindValue($parameter, $value, $data_type = \PDO::PARAM_STR): bool
{
$this->bindValueContext[$parameter] = [$value, $data_type];
return $this->__object->bindValue($parameter, $value, $data_type);
}
}
@swoole/library/core/Database/RedisConfig.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
class RedisConfig
{
protected string $host = '127.0.0.1';
protected int $port = 6379;
protected float $timeout = 0.0;
protected string $reserved = '';
protected int $retry_interval = 0;
protected float $read_timeout = 0.0;
protected string $auth = '';
protected int $dbIndex = 0;
/**
* @var array
*/
protected array $options = [];
public function getHost(): string
{
return $this->host;
}
public function withHost(string $host): self
{
$this->host = $host;
return $this;
}
public function getPort(): int
{
return $this->port;
}
public function withPort(int $port): self
{
$this->port = $port;
return $this;
}
public function getTimeout(): float
{
return $this->timeout;
}
public function withTimeout(float $timeout): self
{
$this->timeout = $timeout;
return $this;
}
public function getReserved(): string
{
return $this->reserved;
}
public function withReserved(string $reserved): self
{
$this->reserved = $reserved;
return $this;
}
public function getRetryInterval(): int
{
return $this->retry_interval;
}
public function withRetryInterval(int $retry_interval): self
{
$this->retry_interval = $retry_interval;
return $this;
}
public function getReadTimeout(): float
{
return $this->read_timeout;
}
public function withReadTimeout(float $read_timeout): self
{
$this->read_timeout = $read_timeout;
return $this;
}
public function getAuth(): string
{
return $this->auth;
}
public function withAuth(string $auth): self
{
$this->auth = $auth;
return $this;
}
public function getDbIndex(): int
{
return $this->dbIndex;
}
public function withDbIndex(int $dbIndex): self
{
$this->dbIndex = $dbIndex;
return $this;
}
/**
* Add a configurable option.
*/
public function withOption(int $option, mixed $value): self
{
$this->options[$option] = $value;
return $this;
}
/**
* Add/override configurable options.
*
* @param array $options
*/
public function setOptions(array $options): self
{
$this->options = $options;
return $this;
}
/**
* Get configurable options.
*
* @return array
*/
public function getOptions(): array
{
return $this->options;
}
}
@swoole/library/core/Database/RedisPool.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Database;
use Redis;
use Swoole\ConnectionPool;
/**
* @method \Redis get(float $timeout = -1)
* @method void put(Redis $connection)
*/
class RedisPool extends ConnectionPool
{
public function __construct(protected RedisConfig $config, int $size = self::DEFAULT_SIZE)
{
parent::__construct(function () {
$redis = new \Redis();
/* Compatible with different versions of Redis extension as much as possible */
$arguments = [
$this->config->getHost(),
$this->config->getPort(),
];
if ($this->config->getTimeout() !== 0.0) {
$arguments[] = $this->config->getTimeout();
}
if ($this->config->getRetryInterval() !== 0) {
/* reserved should always be NULL */
$arguments[] = null;
$arguments[] = $this->config->getRetryInterval();
}
if ($this->config->getReadTimeout() !== 0.0) {
$arguments[] = $this->config->getReadTimeout();
}
$redis->connect(...$arguments);
if ($this->config->getAuth()) {
$redis->auth($this->config->getAuth());
}
if ($this->config->getDbIndex() !== 0) {
$redis->select($this->config->getDbIndex());
}
/* Set Redis options. */
foreach ($this->config->getOptions() as $key => $value) {
$redis->setOption($key, $value);
}
return $redis;
}, $size);
}
}
@swoole/library/core/Http/Status.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Http;
abstract class Status
{
public const CONTINUE = 100;
public const SWITCHING_PROTOCOLS = 101;
public const PROCESSING = 102;
public const OK = 200;
public const CREATED = 201;
public const ACCEPTED = 202;
public const NON_AUTHORITATIVE_INFORMATION = 203;
public const NO_CONTENT = 204;
public const RESET_CONTENT = 205;
public const PARTIAL_CONTENT = 206;
public const MULTI_STATUS = 207;
public const ALREADY_REPORTED = 208;
public const IM_USED = 226;
public const MULTIPLE_CHOICES = 300;
public const MOVED_PERMANENTLY = 301;
public const FOUND = 302;
public const SEE_OTHER = 303;
public const NOT_MODIFIED = 304;
public const USE_PROXY = 305;
public const SWITCH_PROXY = 306;
public const TEMPORARY_REDIRECT = 307;
public const PERMANENT_REDIRECT = 308;
public const BAD_REQUEST = 400;
public const UNAUTHORIZED = 401;
public const PAYMENT_REQUIRED = 402;
public const FORBIDDEN = 403;
public const NOT_FOUND = 404;
public const METHOD_NOT_ALLOWED = 405;
public const NOT_ACCEPTABLE = 406;
public const PROXY_AUTHENTICATION_REQUIRED = 407;
public const REQUEST_TIME_OUT = 408;
public const CONFLICT = 409;
public const GONE = 410;
public const LENGTH_REQUIRED = 411;
public const PRECONDITION_FAILED = 412;
public const REQUEST_ENTITY_TOO_LARGE = 413;
public const REQUEST_URI_TOO_LARGE = 414;
public const UNSUPPORTED_MEDIA_TYPE = 415;
public const REQUESTED_RANGE_NOT_SATISFIABLE = 416;
public const EXPECTATION_FAILED = 417;
public const MISDIRECTED_REQUEST = 421;
public const UNPROCESSABLE_ENTITY = 422;
public const LOCKED = 423;
public const FAILED_DEPENDENCY = 424;
public const UNORDERED_COLLECTION = 425;
public const UPGRADE_REQUIRED = 426;
public const PRECONDITION_REQUIRED = 428;
public const TOO_MANY_REQUESTS = 429;
public const REQUEST_HEADER_FIELDS_TOO_LARGE = 431;
public const UNAVAILABLE_FOR_LEGAL_REASONS = 451;
public const INTERNAL_SERVER_ERROR = 500;
public const NOT_IMPLEMENTED = 501;
public const BAD_GATEWAY = 502;
public const SERVICE_UNAVAILABLE = 503;
public const GATEWAY_TIME_OUT = 504;
public const HTTP_VERSION_NOT_SUPPORTED = 505;
public const VARIANT_ALSO_NEGOTIATES = 506;
public const INSUFFICIENT_STORAGE = 507;
public const LOOP_DETECTED = 508;
public const NOT_EXTENDED = 510;
public const NETWORK_AUTHENTICATION_REQUIRED = 511;
protected static $reasonPhrases = [
self::CONTINUE => 'Continue',
self::SWITCHING_PROTOCOLS => 'Switching Protocols',
self::PROCESSING => 'Processing',
self::OK => 'OK',
self::CREATED => 'Created',
self::ACCEPTED => 'Accepted',
self::NON_AUTHORITATIVE_INFORMATION => 'Non-Authoritative Information',
self::NO_CONTENT => 'No Content',
self::RESET_CONTENT => 'Reset Content',
self::PARTIAL_CONTENT => 'Partial Content',
self::MULTI_STATUS => 'Multi-status',
self::ALREADY_REPORTED => 'Already Reported',
self::IM_USED => 'IM Used',
self::MULTIPLE_CHOICES => 'Multiple Choices',
self::MOVED_PERMANENTLY => 'Moved Permanently',
self::FOUND => 'Found',
self::SEE_OTHER => 'See Other',
self::NOT_MODIFIED => 'Not Modified',
self::USE_PROXY => 'Use Proxy',
self::SWITCH_PROXY => 'Switch Proxy',
self::TEMPORARY_REDIRECT => 'Temporary Redirect',
self::PERMANENT_REDIRECT => 'Permanent Redirect',
self::BAD_REQUEST => 'Bad Request',
self::UNAUTHORIZED => 'Unauthorized',
self::PAYMENT_REQUIRED => 'Payment Required',
self::FORBIDDEN => 'Forbidden',
self::NOT_FOUND => 'Not Found',
self::METHOD_NOT_ALLOWED => 'Method Not Allowed',
self::NOT_ACCEPTABLE => 'Not Acceptable',
self::PROXY_AUTHENTICATION_REQUIRED => 'Proxy Authentication Required',
self::REQUEST_TIME_OUT => 'Request Time-out',
self::CONFLICT => 'Conflict',
self::GONE => 'Gone',
self::LENGTH_REQUIRED => 'Length Required',
self::PRECONDITION_FAILED => 'Precondition Failed',
self::REQUEST_ENTITY_TOO_LARGE => 'Request Entity Too Large',
self::REQUEST_URI_TOO_LARGE => 'Request-URI Too Large',
self::UNSUPPORTED_MEDIA_TYPE => 'Unsupported Media Type',
self::REQUESTED_RANGE_NOT_SATISFIABLE => 'Requested range not satisfiable',
self::EXPECTATION_FAILED => 'Expectation Failed',
self::MISDIRECTED_REQUEST => 'Misdirected Request',
self::UNPROCESSABLE_ENTITY => 'Unprocessable Entity',
self::LOCKED => 'Locked',
self::FAILED_DEPENDENCY => 'Failed Dependency',
self::UNORDERED_COLLECTION => 'Unordered Collection',
self::UPGRADE_REQUIRED => 'Upgrade Required',
self::PRECONDITION_REQUIRED => 'Precondition Required',
self::TOO_MANY_REQUESTS => 'Too Many Requests',
self::REQUEST_HEADER_FIELDS_TOO_LARGE => 'Request Header Fields Too Large',
self::UNAVAILABLE_FOR_LEGAL_REASONS => 'Unavailable For Legal Reasons',
self::INTERNAL_SERVER_ERROR => 'Internal Server Error',
self::NOT_IMPLEMENTED => 'Not Implemented',
self::BAD_GATEWAY => 'Bad Gateway',
self::SERVICE_UNAVAILABLE => 'Service Unavailable',
self::GATEWAY_TIME_OUT => 'Gateway Time-out',
self::HTTP_VERSION_NOT_SUPPORTED => 'HTTP Version not supported',
self::VARIANT_ALSO_NEGOTIATES => 'Variant Also Negotiates',
self::INSUFFICIENT_STORAGE => 'Insufficient Storage',
self::LOOP_DETECTED => 'Loop Detected',
self::NOT_EXTENDED => 'Not Extended',
self::NETWORK_AUTHENTICATION_REQUIRED => 'Network Authentication Required',
];
public static function getReasonPhrases(): array
{
return static::$reasonPhrases;
}
public static function getReasonPhrase(int $value): string
{
return static::$reasonPhrases[$value] ?? 'Unknown';
}
}
@swoole/library/core/Curl/Exception.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\Curl;
use Swoole;
class Exception extends Swoole\Exception
{
}
@swoole/library/core/Curl/Handler.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
/* @noinspection PhpComposerExtensionStubsInspection, PhpDuplicateSwitchCaseBodyInspection, PhpInconsistentReturnPointsInspection */
declare(strict_types=1);
namespace Swoole\Curl;
use Swoole\Constant;
use Swoole\Coroutine\Http\Client;
use Swoole\Coroutine\System;
use Swoole\Curl\Exception as CurlException;
use Swoole\Http\Status;
final class Handler implements \Stringable
{
/**
* @var Client|null
*/
private $client;
private $info = [
'url' => '',
'content_type' => '',
'http_code' => 0,
'header_size' => 0,
'request_size' => 0,
'filetime' => -1,
'ssl_verify_result' => 0,
'redirect_count' => 0,
'total_time' => 5.3E-5,
'namelookup_time' => 0.0,
'connect_time' => 0.0,
'pretransfer_time' => 0.0,
'size_upload' => 0.0,
'size_download' => 0.0,
'speed_download' => 0.0,
'speed_upload' => 0.0,
'download_content_length' => -1.0,
'upload_content_length' => -1.0,
'starttransfer_time' => 0.0,
'redirect_time' => 0.0,
'redirect_url' => '',
'primary_ip' => '',
'certinfo' => [],
'primary_port' => 0,
'local_ip' => '',
'local_port' => 0,
'http_version' => 0,
'protocol' => 0,
'ssl_verifyresult' => 0,
'scheme' => '',
'private' => '',
];
private $withHeaderOut = false;
private $withFileTime = false;
private $urlInfo;
private $postData;
private $infile;
private $infileSize = PHP_INT_MAX;
private $outputStream;
private $proxyType;
private $proxy;
private $proxyPort = 1080;
private $proxyUsername;
private $proxyPassword;
private $clientOptions = [];
private $followLocation = false;
private $autoReferer = false;
private $maxRedirects;
private $withHeader = false;
private $nobody = false;
/** @var callable|null */
private $headerFunction;
/** @var callable|null */
private $readFunction;
/** @var callable|null */
private $writeFunction;
private $noProgress = true;
/** @var callable */
private $progressFunction;
private $returnTransfer = false;
private $method = '';
private $headers = [];
private $headerMap = [];
private $transfer;
private $errCode = 0;
private $errMsg = '';
private $failOnError = false;
private $closed = false;
private $cookieJar = '';
private $resolve = [];
private $unix_socket_path = '';
public function __construct(string $url = '')
{
if ($url) {
$this->setUrl($url);
}
}
public function __toString(): string
{
$id = spl_object_id($this);
return "Object({$id}) of type (curl)";
}
/* ====== Public APIs ====== */
public function isAvailable(): bool
{
if ($this->closed) {
trigger_error('supplied resource is not a valid cURL handle resource', E_USER_WARNING);
return false;
}
return true;
}
public function setOpt(int $opt, $value): bool
{
return $this->isAvailable() and $this->setOption($opt, $value);
}
public function exec()
{
if (!$this->isAvailable()) {
return false;
}
return $this->execute();
}
public function getInfo()
{
return $this->isAvailable() ? $this->info : false;
}
public function errno(): int
{
return $this->isAvailable() ? $this->errCode : 0;
}
public function error(): string
{
return $this->isAvailable() ? $this->errMsg : '';
}
public function reset()
{
if (!$this->isAvailable()) {
return false;
}
foreach ((new \ReflectionClass(self::class))->getDefaultProperties() as $name => $value) {
$this->{$name} = $value;
}
}
public function getContent()
{
if (!$this->isAvailable()) {
return false;
}
return $this->transfer;
}
public function close(): void
{
if (!$this->isAvailable()) {
return;
}
foreach ($this as &$property) { // @phpstan-ignore foreach.nonIterable
$property = null;
}
$this->closed = true;
}
private function create(?array $urlInfo = null): void
{
if ($urlInfo === null) {
$urlInfo = $this->urlInfo;
}
$host = $urlInfo['host'];
$port = $urlInfo['port'];
if (isset($this->resolve[$host])) {
if (!$this->hasHeader('Host')) {
$this->setHeader('Host', $host);
}
$this->urlInfo['host'] = $host = $this->resolve[$host][$port] ?? null ?: $host;
}
if ($this->unix_socket_path) {
$host = $this->unix_socket_path;
$port = 0;
if (stripos($host, 'unix:/') !== 0) {
$host = "unix:/{$host}";
}
}
$this->client = new Client($host, $port, $urlInfo['scheme'] === 'https');
}
private function getUrl(): string
{
if (empty($this->urlInfo['path'])) {
$url = '/';
} else {
$url = $this->urlInfo['path'];
}
if (!empty($this->urlInfo['query'])) {
$url .= '?' . $this->urlInfo['query'];
}
if (!empty($this->urlInfo['fragment'])) {
$url .= '#' . $this->urlInfo['fragment'];
}
return $url;
}
private function setUrl(string $url, bool $setInfo = true): bool
{
if (strlen($url) === 0) {
$this->setError(CURLE_URL_MALFORMAT, 'No URL set!');
return false;
}
if (!str_contains($url, '://') && $this->unix_socket_path === '') {
$url = 'http://' . $url;
}
if ($setInfo) {
$urlInfo = parse_url($url);
if ($this->unix_socket_path) {
if (empty($urlInfo['host']) && !empty($urlInfo['path'])) {
$urlInfo['host'] = explode('/', $urlInfo['path'])[1] ?? null;
}
if (!$this->hasHeader('Host') && !empty($urlInfo['host'])) {
$this->setHeader('Host', $urlInfo['host']);
}
}
if (!is_array($urlInfo)) {
$this->setError(CURLE_URL_MALFORMAT, "URL[{$url}] using bad/illegal format");
return false;
}
if (!$this->setUrlInfo($urlInfo)) {
return false;
}
}
$this->info['url'] = $url;
return true;
}
private function setUrlInfo(array $urlInfo): bool
{
if (empty($urlInfo['scheme'])) {
$urlInfo['scheme'] = 'http';
}
$scheme = $urlInfo['scheme'];
if ($scheme !== 'http' and $scheme !== 'https') {
$this->setError(CURLE_UNSUPPORTED_PROTOCOL, "Protocol \"{$scheme}\" not supported or disabled in libcurl");
return false;
}
$host = $urlInfo['host'];
if ($this->info['primary_port'] !== 0) {
/* keep same with cURL, primary_port has the highest priority */
$urlInfo['port'] = $this->info['primary_port'];
} elseif (empty($urlInfo['port'])) {
$urlInfo['port'] = $scheme === 'https' ? 443 : 80;
} else {
$urlInfo['port'] = intval($urlInfo['port']);
}
$port = $urlInfo['port'];
if (isset($this->client)) {
$oldUrlInfo = $this->urlInfo;
if (($host !== $oldUrlInfo['host']) || ($port !== $oldUrlInfo['port']) || ($scheme !== $oldUrlInfo['scheme'])) {
/* target changed */
$this->create($urlInfo);
}
}
$this->urlInfo = $urlInfo;
return true;
}
private function setPort(int $port): void
{
$this->info['primary_port'] = $port;
if (!isset($this->urlInfo['port']) || $this->urlInfo['port'] !== $port) {
$this->urlInfo['port'] = $port;
if (isset($this->client)) {
/* target changed */
$this->create();
}
}
}
private function setError($code, $msg = ''): void
{
$this->errCode = $code;
$this->errMsg = $msg ?: curl_strerror($code);
}
private function hasHeader(string $headerName): bool
{
return isset($this->headerMap[strtolower($headerName)]);
}
private function setHeader(string $headerName, string $value): void
{
$lowerCaseHeaderName = strtolower($headerName);
if (isset($this->headerMap[$lowerCaseHeaderName])) {
unset($this->headers[$this->headerMap[$lowerCaseHeaderName]]);
}
if ($value !== '') {
$this->headers[$headerName] = $value;
$this->headerMap[$lowerCaseHeaderName] = $headerName;
} else {
// remove empty headers (keep same with raw cURL)
unset($this->headerMap[$lowerCaseHeaderName]);
}
}
/**
* @throws Exception
*/
private function setOption(int $opt, mixed $value): bool
{
switch ($opt) {
// case CURLOPT_STDERR:
// case CURLOPT_WRITEHEADER:
case CURLOPT_FILE:
case CURLOPT_INFILE:
if (!is_resource($value)) {
trigger_error('swoole_curl_setopt(): supplied argument is not a valid File-Handle resource', E_USER_WARNING);
return false;
}
break;
}
switch ($opt) {
/*
* Basic
*/
case CURLOPT_URL:
return $this->setUrl((string) $value);
case CURLOPT_PORT:
$this->setPort((int) $value);
break;
case CURLOPT_FORBID_REUSE:
$this->clientOptions[Constant::OPTION_KEEP_ALIVE] = !$value;
break;
case CURLOPT_RETURNTRANSFER:
$this->returnTransfer = (bool) $value;
$this->transfer = '';
break;
case CURLOPT_ENCODING:
if (empty($value)) {
if (defined('SWOOLE_HAVE_ZLIB')) {
$value = 'gzip, deflate';
}
if (defined('SWOOLE_HAVE_BROTLI')) {
if (!empty($value)) {
$value = 'br, ' . $value;
} else {
$value = 'br';
}
}
if (empty($value)) {
break;
}
}
$this->setHeader('Accept-Encoding', $value);
break;
case CURLOPT_PROXYTYPE:
if ($value !== CURLPROXY_HTTP and $value !== CURLPROXY_SOCKS5) {
throw new CurlException('swoole_curl_setopt(): Only support following CURLOPT_PROXYTYPE values: CURLPROXY_HTTP, CURLPROXY_SOCKS5');
}
$this->proxyType = $value;
break;
case CURLOPT_PROXY:
$this->proxy = $value;
break;
case CURLOPT_PROXYPORT:
$this->proxyPort = $value;
break;
case CURLOPT_PROXYUSERNAME:
$this->proxyUsername = $value;
break;
case CURLOPT_PROXYPASSWORD:
$this->proxyPassword = $value;
break;
case CURLOPT_PROXYUSERPWD:
$usernamePassword = explode(':', $value);
$this->proxyUsername = urldecode($usernamePassword[0]);
$this->proxyPassword = urldecode($usernamePassword[1] ?? null);
break;
case CURLOPT_PROXYAUTH:
/* ignored temporarily */
break;
case CURLOPT_UNIX_SOCKET_PATH:
$realpath = realpath((string) $value);
if ($realpath) {
$this->unix_socket_path = $realpath;
} else {
$this->setError(CURLE_COULDNT_CONNECT);
}
break;
case CURLOPT_NOBODY:
$this->nobody = boolval($value);
$this->method = 'HEAD';
break;
case CURLOPT_RESOLVE:
foreach ((array) $value as $resolve) {
$flag = substr($resolve, 0, 1);
if ($flag === '+' || $flag === '-') {
// TODO: [+]HOST:PORT:ADDRESS
$resolve = substr($resolve, 1);
}
$tmpResolve = explode(':', $resolve, 3);
$host = $tmpResolve[0];
$port = $tmpResolve[1] ?? 0;
$ip = $tmpResolve[2] ?? '';
if ($flag === '-') {
unset($this->resolve[$host][$port]);
} else {
// TODO: HOST:PORT:ADDRESS[,ADDRESS]...
$this->resolve[$host][$port] = explode(',', $ip)[0];
}
}
break;
case CURLOPT_IPRESOLVE:
if ($value !== CURL_IPRESOLVE_WHATEVER and $value !== CURL_IPRESOLVE_V4) {
throw new CurlException('swoole_curl_setopt(): Only support following CURLOPT_IPRESOLVE values: CURL_IPRESOLVE_WHATEVER, CURL_IPRESOLVE_V4');
}
break;
case CURLOPT_TCP_NODELAY:
$this->clientOptions[Constant::OPTION_OPEN_TCP_NODELAY] = boolval($value);
break;
case CURLOPT_PRIVATE:
$this->info['private'] = $value;
break;
/*
* Ignore options
*/
case CURLOPT_VERBOSE:
// trigger_error('swoole_curl_setopt(): CURLOPT_VERBOSE is not supported', E_USER_WARNING);
case CURLOPT_SSLVERSION:
case CURLOPT_NOSIGNAL:
case CURLOPT_FRESH_CONNECT:
case CURLOPT_DNS_USE_GLOBAL_CACHE:
case CURLOPT_DNS_CACHE_TIMEOUT:
case CURLOPT_STDERR:
case CURLOPT_WRITEHEADER:
case CURLOPT_BUFFERSIZE:
case CURLOPT_SSLCERTTYPE:
case CURLOPT_SSLKEYTYPE:
case CURLOPT_NOPROXY:
case CURLOPT_CERTINFO:
case CURLOPT_HEADEROPT:
case CURLOPT_PROXYHEADER:
case CURLOPT_HTTPPROXYTUNNEL:
break;
/*
* SSL
*/
case CURLOPT_SSL_VERIFYHOST:
break;
case CURLOPT_SSL_VERIFYPEER:
$this->clientOptions[Constant::OPTION_SSL_VERIFY_PEER] = $value;
break;
case CURLOPT_SSLCERT:
$this->clientOptions[Constant::OPTION_SSL_CERT_FILE] = $value;
break;
case CURLOPT_SSLKEY:
$this->clientOptions[Constant::OPTION_SSL_KEY_FILE] = $value;
break;
case CURLOPT_CAINFO:
$this->clientOptions[Constant::OPTION_SSL_CAFILE] = $value;
break;
case CURLOPT_CAPATH:
$this->clientOptions[Constant::OPTION_SSL_CAPATH] = $value;
break;
case CURLOPT_KEYPASSWD:
case CURLOPT_SSLCERTPASSWD:
case CURLOPT_SSLKEYPASSWD:
$this->clientOptions[Constant::OPTION_SSL_PASSPHRASE] = $value;
break;
/*
* Http POST
*/
case CURLOPT_POST:
$this->method = 'POST';
break;
case CURLOPT_POSTFIELDS:
$this->postData = $value;
if (!$this->method) {
$this->method = 'POST';
}
break;
/*
* Upload
*/
case CURLOPT_SAFE_UPLOAD:
if (!$value) {
trigger_error('swoole_curl_setopt(): Disabling safe uploads is no longer supported', E_USER_WARNING);
return false;
}
break;
/*
* Http Header
*/
case CURLOPT_HTTPHEADER:
if (!is_array($value) and !is_iterable($value)) {
trigger_error('swoole_curl_setopt(): You must pass either an object or an array with the CURLOPT_HTTPHEADER argument', E_USER_WARNING);
return false;
}
foreach ($value as $header) {
$header = explode(':', $header, 2);
$headerName = $header[0];
$headerValue = trim($header[1] ?? '');
$this->setHeader($headerName, $headerValue);
}
break;
case CURLOPT_REFERER:
$this->setHeader('Referer', $value);
break;
case CURLINFO_HEADER_OUT:
$this->withHeaderOut = boolval($value);
break;
case CURLOPT_FILETIME:
$this->withFileTime = boolval($value);
break;
case CURLOPT_USERAGENT:
$this->setHeader('User-Agent', $value);
break;
case CURLOPT_CUSTOMREQUEST:
$this->method = (string) $value;
break;
case CURLOPT_PROTOCOLS:
if (($value & ~(CURLPROTO_HTTP | CURLPROTO_HTTPS)) != 0) {
throw new CurlException("swoole_curl_setopt(): CURLOPT_PROTOCOLS[{$value}] is not supported");
}
break;
case CURLOPT_REDIR_PROTOCOLS:
if (($value & ~(CURLPROTO_HTTP | CURLPROTO_HTTPS)) != 0) {
throw new CurlException("swoole_curl_setopt(): CURLOPT_REDIR_PROTOCOLS[{$value}] is not supported");
}
break;
case CURLOPT_HTTP_VERSION:
if ($value != CURL_HTTP_VERSION_1_1) {
trigger_error("swoole_curl_setopt(): CURLOPT_HTTP_VERSION[{$value}] is not supported", E_USER_WARNING);
return false;
}
break;
case CURLOPT_FAILONERROR:
$this->failOnError = $value;
break;
/*
* Http Cookie
*/
case CURLOPT_COOKIE:
$this->setHeader('Cookie', $value);
break;
case CURLOPT_COOKIEJAR:
$this->cookieJar = (string) $value;
break;
case CURLOPT_COOKIEFILE:
if (is_file((string) $value)) {
$this->setHeader('Cookie', file_get_contents($value));
}
break;
case CURLOPT_CONNECTTIMEOUT:
$this->clientOptions[Constant::OPTION_CONNECT_TIMEOUT] = $value;
break;
case CURLOPT_CONNECTTIMEOUT_MS:
$this->clientOptions[Constant::OPTION_CONNECT_TIMEOUT] = $value / 1000;
break;
case CURLOPT_TIMEOUT:
$this->clientOptions[Constant::OPTION_TIMEOUT] = $value;
break;
case CURLOPT_TIMEOUT_MS:
$this->clientOptions[Constant::OPTION_TIMEOUT] = $value / 1000;
break;
case CURLOPT_FILE:
$this->outputStream = $value;
break;
case CURLOPT_HEADER:
$this->withHeader = $value;
break;
case CURLOPT_HEADERFUNCTION:
$this->headerFunction = $value;
break;
case CURLOPT_READFUNCTION:
$this->readFunction = $value;
break;
case CURLOPT_WRITEFUNCTION:
if (SWOOLE_VERSION_ID >= 50100) {
$this->clientOptions[Constant::OPTION_WRITE_FUNC] = function ($client, $data) use ($value) {
return $value($this, $data);
};
} else {
$this->writeFunction = $value;
}
break;
case CURLOPT_NOPROGRESS:
$this->noProgress = $value;
break;
case CURLOPT_PROGRESSFUNCTION:
$this->progressFunction = $value;
break;
case CURLOPT_HTTPAUTH:
if (!($value & CURLAUTH_BASIC)) {
trigger_error("swoole_curl_setopt(): CURLOPT_HTTPAUTH[{$value}] is not supported", E_USER_WARNING);
return false;
}
break;
case CURLOPT_USERPWD:
$this->setHeader('Authorization', 'Basic ' . base64_encode($value));
break;
case CURLOPT_FOLLOWLOCATION:
$this->followLocation = $value;
break;
case CURLOPT_AUTOREFERER:
$this->autoReferer = $value;
break;
case CURLOPT_MAXREDIRS:
$this->maxRedirects = $value;
break;
case CURLOPT_PUT:
case CURLOPT_UPLOAD:
/* after libcurl 7.12, CURLOPT_PUT is replaced by CURLOPT_UPLOAD */
$this->method = 'PUT';
break;
case CURLOPT_INFILE:
$this->infile = $value;
break;
case CURLOPT_INFILESIZE:
$this->infileSize = $value;
break;
case CURLOPT_HTTPGET:
/* Since GET is the default, this is only necessary if the request method has been changed. */
$this->method = 'GET';
break;
default:
throw new CurlException("swoole_curl_setopt(): option[{$opt}] is not supported");
}
return true;
}
private function execute()
{
$this->info['redirect_count'] = $this->info['starttransfer_time'] = 0;
$this->info['redirect_url'] = '';
$timeBegin = microtime(true);
/*
* Socket
*/
if (!$this->urlInfo) {
$this->setError(CURLE_URL_MALFORMAT, 'No URL set or URL using bad/illegal format');
return false;
}
if (!isset($this->client)) {
$this->create();
}
while (true) {
$client = $this->client;
/*
* Http Proxy
*/
if ($this->proxy) {
$parse = parse_url($this->proxy);
$proxy = $parse['host'] ?? $parse['path'];
$proxyPort = $parse['port'] ?? $this->proxyPort;
$proxyUsername = $parse['user'] ?? $this->proxyUsername;
$proxyPassword = $parse['pass'] ?? $this->proxyPassword;
$proxyType = $parse['scheme'] ?? $this->proxyType;
if (is_string($proxyType)) {
if ($proxyType === 'socks5') {
$proxyType = CURLPROXY_SOCKS5;
} else {
$proxyType = CURLPROXY_HTTP;
}
}
if (!filter_var($proxy, FILTER_VALIDATE_IP)) {
$ip = System::gethostbyname($proxy, AF_INET, $this->clientOptions['connect_timeout'] ?? -1);
if (!$ip) {
$this->setError(CURLE_COULDNT_RESOLVE_PROXY, 'Could not resolve proxy: ' . $proxy);
return false;
}
$this->proxy = $proxy = $ip;
}
$proxyOptions = match ($proxyType) {
CURLPROXY_HTTP => [
'http_proxy_host' => $proxy,
'http_proxy_port' => $proxyPort,
'http_proxy_username' => $proxyUsername,
'http_proxy_password' => $proxyPassword,
],
CURLPROXY_SOCKS5 => [
'socks5_host' => $proxy,
'socks5_port' => $proxyPort,
'socks5_username' => $proxyUsername,
'socks5_password' => $proxyPassword,
],
default => throw new CurlException("Unexpected proxy type [{$proxyType}]"),
};
}
/*
* Client Options
*/
$client->set(
$this->clientOptions +
($proxyOptions ?? [])
);
/*
* Method
*/
if ($this->method) {
$client->setMethod($this->method);
}
/*
* Data
*/
if ($this->infile) {
// Infile
// Notice: we make its priority higher than postData but raw cURL will send both of them
$data = '';
while (true) {
$nLength = $this->infileSize - strlen($data);
if ($nLength === 0) {
break;
}
if (feof($this->infile)) {
break;
}
$data .= fread($this->infile, $nLength);
}
$client->setData($data);
// Notice: although we reset it, raw cURL never do this
$this->infile = null;
$this->infileSize = PHP_INT_MAX;
} else {
// POST data
if ($this->postData) {
if (is_string($this->postData)) {
if (!$this->hasHeader('content-type')) {
$this->setHeader('Content-Type', 'application/x-www-form-urlencoded');
}
} elseif (is_array($this->postData)) {
foreach ($this->postData as $k => $v) {
if ($v instanceof \CURLFile) {
$client->addFile($v->getFilename(), $k, $v->getMimeType() ?: 'application/octet-stream', $v->getPostFilename());
unset($this->postData[$k]);
}
}
}
$client->setData($this->postData);
}
}
/*
* Headers
*/
// Notice: setHeaders must be placed last, because headers may be changed by other parts
// As much as possible to ensure that Host is the first header.
// See: http://tools.ietf.org/html/rfc7230#section-5.4
$client->setHeaders($this->headers);
/**
* Execute.
*/
$executeResult = $client->execute($this->getUrl());
if (!$executeResult) {
$errCode = $client->errCode;
if ($errCode == SWOOLE_ERROR_DNSLOOKUP_RESOLVE_FAILED or $errCode == SWOOLE_ERROR_DNSLOOKUP_RESOLVE_TIMEOUT) {
$this->setError(CURLE_COULDNT_RESOLVE_HOST, 'Could not resolve host: ' . $client->host);
} else {
$this->setError($errCode, $client->errMsg);
}
$this->info['total_time'] = microtime(true) - $timeBegin;
return false;
}
if ($client->statusCode >= 300 and $client->statusCode < 400 and isset($client->headers['location'])) {
$redirectParsedUrl = $this->getRedirectUrl($client->headers['location']);
$redirectUrl = self::unparseUrl($redirectParsedUrl);
if ($this->followLocation and ($this->maxRedirects === null or $this->info['redirect_count'] < $this->maxRedirects)) {
if ($this->info['redirect_count'] === 0) {
$this->info['starttransfer_time'] = microtime(true) - $timeBegin;
$redirectBeginTime = microtime(true);
}
// force GET
if (in_array($client->statusCode, [Status::MOVED_PERMANENTLY, Status::FOUND, Status::SEE_OTHER])) {
$this->method = 'GET';
}
if ($this->autoReferer) {
$this->setHeader('Referer', $this->info['url']);
}
$this->setUrl($redirectUrl, false);
$this->setUrlInfo($redirectParsedUrl);
$this->info['redirect_count']++;
} else {
$this->info['redirect_url'] = $redirectUrl;
break;
}
} elseif ($this->failOnError && $client->statusCode >= 400) {
$this->setError(CURLE_HTTP_RETURNED_ERROR, "The requested URL returned error: {$client->statusCode} " . Status::getReasonPhrase($client->statusCode));
return false;
} else {
break;
}
}
$this->info['total_time'] = microtime(true) - $timeBegin;
$this->info['http_code'] = $client->statusCode;
$this->info['content_type'] = $client->headers['content-type'] ?? '';
$this->info['size_download'] = $this->info['download_content_length'] = strlen($client->body);
$this->info['speed_download'] = 1 / $this->info['total_time'] * $this->info['size_download'];
if (isset($redirectBeginTime)) {
$this->info['redirect_time'] = microtime(true) - $redirectBeginTime;
}
if (filter_var($this->urlInfo['host'], FILTER_VALIDATE_IP)) {
$this->info['primary_ip'] = $this->urlInfo['host'];
}
if ($this->unix_socket_path) {
$this->info['primary_ip'] = $this->unix_socket_path;
$this->info['primary_port'] = $this->urlInfo['port'];
}
$headerContent = '';
if ($client->headers) {
$cb = $this->headerFunction;
if ($client->statusCode > 0) {
$row = "HTTP/1.1 {$client->statusCode} " . Status::getReasonPhrase($client->statusCode) . "\r\n";
if ($cb) {
$cb($this, $row);
}
$headerContent .= $row;
}
foreach ($client->headers as $k => $v) {
$list = is_array($v) ? $v : [$v];
foreach ($list as $_v) {
$row = "{$k}: {$_v}\r\n";
if ($cb) {
$cb($this, $row);
}
$headerContent .= $row;
}
}
$headerContent .= "\r\n";
$this->info['header_size'] = strlen($headerContent);
if ($cb) {
$cb($this, '');
}
} else {
$this->info['header_size'] = 0;
}
if ($client->body and $this->readFunction) {
$cb = $this->readFunction;
$cb($this, $this->outputStream, strlen($client->body));
}
if ($this->withHeader) {
$transfer = $headerContent . $client->body;
} else {
$transfer = $client->body;
}
if ($this->withHeaderOut) {
$headerOutContent = $client->getHeaderOut();
$this->info['request_header'] = $headerOutContent ? $headerOutContent . "\r\n\r\n" : '';
}
if ($this->withFileTime) {
if (isset($client->headers['last-modified'])) {
$this->info['filetime'] = strtotime($client->headers['last-modified']);
} else {
$this->info['filetime'] = -1;
}
}
if (!empty($this->cookieJar)) {
if ($this->cookieJar === '-') {
foreach ((array) $client->set_cookie_headers as $cookie) {
echo $cookie . PHP_EOL;
}
} else {
$cookies = '';
foreach ((array) $client->set_cookie_headers as $cookie) {
$cookies .= "{$cookie};";
}
file_put_contents($this->cookieJar, $cookies);
}
}
if ($this->writeFunction) {
if (!is_callable($this->writeFunction)) { // @phpstan-ignore booleanNot.alwaysFalse
trigger_error('curl_exec(): Could not call the CURLOPT_WRITEFUNCTION', E_USER_WARNING);
$this->setError(CURLE_WRITE_ERROR, 'Failure writing output to destination');
return false;
}
call_user_func($this->writeFunction, $this, $transfer);
return true;
}
if ($this->returnTransfer) {
return $this->transfer = $transfer;
}
if ($this->outputStream) {
return fwrite($this->outputStream, $transfer) === strlen($transfer);
}
echo $transfer;
return true;
}
/* ====== Redirect helper ====== */
private static function unparseUrl(array $parsedUrl): string
{
$scheme = ($parsedUrl['scheme'] ?? 'http') . '://';
$host = $parsedUrl['host'] ?? '';
$port = isset($parsedUrl['port']) ? ':' . $parsedUrl['port'] : '';
$user = $parsedUrl['user'] ?? '';
$pass = isset($parsedUrl['pass']) ? ':' . $parsedUrl['pass'] : '';
$pass = ($user or $pass) ? "{$pass}@" : '';
$path = $parsedUrl['path'] ?? '';
$query = (isset($parsedUrl['query']) and $parsedUrl['query'] !== '') ? '?' . $parsedUrl['query'] : '';
$fragment = isset($parsedUrl['fragment']) ? '#' . $parsedUrl['fragment'] : '';
return $scheme . $user . $pass . $host . $port . $path . $query . $fragment;
}
private function getRedirectUrl(string $location): array
{
$uri = parse_url($location);
if (isset($uri['host'])) {
$redirectUri = $uri;
} else {
if (!isset($location[0])) {
return [];
}
$redirectUri = $this->urlInfo;
$redirectUri['query'] = '';
if ($location[0] === '/') {
$redirectUri['path'] = $location;
} else {
$path = dirname($redirectUri['path'] ?? '');
if ($path === '.') {
$path = '/';
}
if (isset($location[1]) and str_starts_with($location, './')) {
$location = substr($location, 2);
}
$redirectUri['path'] = $path . $location;
}
if (is_array($uri)) {
foreach ($uri as $k => $v) {
if (!in_array($k, ['path', 'query'])) {
$redirectUri[$k] = $v;
}
}
}
}
return $redirectUri;
}
}
@swoole/library/core/FastCGI.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole;
/**
* FastCGI constants.
*/
class FastCGI
{
/**
* Number of bytes in a FCGI_Header. Future versions of the protocol
* will not reduce this number.
*/
public const HEADER_LEN = 8;
/**
* Format of FCGI_HEADER for unpacking in PHP
*/
public const HEADER_FORMAT = 'Cversion/Ctype/nrequestId/ncontentLength/CpaddingLength/Creserved';
/**
* Max content length of a record
*/
public const MAX_CONTENT_LENGTH = 65535;
/**
* Value for version component of FCGI_Header
*/
public const VERSION_1 = 1;
/**
* Values for type component of FCGI_Header
*/
public const BEGIN_REQUEST = 1;
public const ABORT_REQUEST = 2;
public const END_REQUEST = 3;
public const PARAMS = 4;
public const STDIN = 5;
public const STDOUT = 6;
public const STDERR = 7;
public const DATA = 8;
public const GET_VALUES = 9;
public const GET_VALUES_RESULT = 10;
public const UNKNOWN_TYPE = 11;
/**
* Value for requestId component of FCGI_Header
*/
public const DEFAULT_REQUEST_ID = 1;
/**
* Mask for flags component of FCGI_BeginRequestBody
*/
public const KEEP_CONN = 1;
/**
* Values for role component of FCGI_BeginRequestBody
*/
public const RESPONDER = 1;
public const AUTHORIZER = 2;
public const FILTER = 3;
/**
* Values for protocolStatus component of FCGI_EndRequestBody
*/
public const REQUEST_COMPLETE = 0;
public const CANT_MPX_CONN = 1;
public const OVERLOADED = 2;
public const UNKNOWN_ROLE = 3;
}
@swoole/library/core/FastCGI/Record.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI;
use Swoole\FastCGI;
/**
* FastCGI record.
*/
class Record implements \Stringable
{
/**
* Identifies the FastCGI protocol version.
*/
protected int $version = FastCGI::VERSION_1;
/**
* Identifies the FastCGI record type, i.e. the general function that the record performs.
*/
protected int $type = FastCGI::UNKNOWN_TYPE;
/**
* Identifies the FastCGI request to which the record belongs.
*/
protected int $requestId = FastCGI::DEFAULT_REQUEST_ID;
/**
* Reserved byte for future proposes
*/
protected int $reserved = 0;
/**
* The number of bytes in the contentData component of the record.
*/
private int $contentLength = 0;
/**
* The number of bytes in the paddingData component of the record.
*/
private int $paddingLength = 0;
/**
* Binary data, between 0 and 65535 bytes of data, interpreted according to the record type.
*/
private string $contentData = '';
/**
* Padding data, between 0 and 255 bytes of data, which are ignored.
*/
private string $paddingData = '';
/**
* Returns the binary message representation of record
*/
final public function __toString(): string
{
$headerPacket = pack(
'CCnnCC',
$this->version,
$this->type,
$this->requestId,
$this->contentLength,
$this->paddingLength,
$this->reserved
);
$payloadPacket = $this->packPayload();
$paddingPacket = pack("a{$this->paddingLength}", $this->paddingData);
return $headerPacket . $payloadPacket . $paddingPacket;
}
/**
* Unpacks the message from the binary data buffer
*/
final public static function unpack(string $binaryData): static
{
/** @var static $self */
$self = (new \ReflectionClass(static::class))->newInstanceWithoutConstructor();
/** @phpstan-var false|array{version: int, type: int, requestId: int, contentLength: int, paddingLength: int, reserved: int} */
$packet = unpack(FastCGI::HEADER_FORMAT, $binaryData);
if ($packet === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[
$self->version,
$self->type,
$self->requestId,
$self->contentLength,
$self->paddingLength,
$self->reserved,
] = array_values($packet);
$payload = substr($binaryData, FastCGI::HEADER_LEN);
self::unpackPayload($self, $payload);
if (static::class !== self::class && $self->contentLength > 0) {
static::unpackPayload($self, $payload);
}
return $self;
}
/**
* Sets the content data and adjusts the length fields
*
* @return static
*/
public function setContentData(string $data): self
{
$this->contentLength = strlen($data);
if ($this->contentLength > FastCGI::MAX_CONTENT_LENGTH) {
$this->contentLength = FastCGI::MAX_CONTENT_LENGTH;
$this->contentData = substr($data, 0, FastCGI::MAX_CONTENT_LENGTH);
} else {
$this->contentData = $data;
}
$extraLength = $this->contentLength % 8;
$this->paddingLength = $extraLength ? (8 - $extraLength) : 0;
return $this;
}
/**
* Returns the context data from the record
*/
public function getContentData(): string
{
return $this->contentData;
}
/**
* Returns the version of record
*/
public function getVersion(): int
{
return $this->version;
}
/**
* Returns record type
*/
public function getType(): int
{
return $this->type;
}
/**
* Returns request ID
*/
public function getRequestId(): int
{
return $this->requestId;
}
/**
* Sets request ID
*
* There should be only one unique ID for all active requests,
* use random number or preferably resetting auto-increment.
*
* @return static
*/
public function setRequestId(int $requestId): self
{
$this->requestId = $requestId;
return $this;
}
/**
* Returns the size of content length
*/
final public function getContentLength(): int
{
return $this->contentLength;
}
/**
* Returns the size of padding length
*/
final public function getPaddingLength(): int
{
return $this->paddingLength;
}
/**
* Method to unpack the payload for the record.
*
* NB: Default implementation will be always called
*/
protected static function unpackPayload(self $self, string $binaryData): void
{
/** @phpstan-var false|array{contentData: string, paddingData: string} */
$payload = unpack("a{$self->contentLength}contentData/a{$self->paddingLength}paddingData", $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[
$self->contentData,
$self->paddingData,
] = array_values($payload);
}
/**
* Implementation of packing the payload
*/
protected function packPayload(): string
{
return pack("a{$this->contentLength}", $this->contentData);
}
}
@swoole/library/core/FastCGI/Record/Params.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Params request record
*/
class Params extends Record
{
/**
* List of params
*
* @var string[]
* @phpstan-var array
*/
protected array $values = [];
/**
* Constructs a param request
*
* @phpstan-param array $values
*/
public function __construct(array $values)
{
$this->type = FastCGI::PARAMS;
$this->values = $values;
$this->setContentData($this->packPayload());
}
/**
* Returns an associative list of parameters
*
* @phpstan-return array
*/
public function getValues(): array
{
return $this->values;
}
/**
* {@inheritdoc}
* @param static $self
*/
protected static function unpackPayload(Record $self, string $binaryData): void
{
assert($self instanceof self); // @phpstan-ignore function.alreadyNarrowedType,instanceof.alwaysTrue
$currentOffset = 0;
do {
/** @phpstan-var false|array{nameLengthHigh: int} */
$payload = unpack('CnameLengthHigh', $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[$nameLengthHigh] = array_values($payload);
$isLongName = ($nameLengthHigh >> 7 == 1);
$valueOffset = $isLongName ? 4 : 1;
/** @phpstan-var false|array{valueLengthHigh: int} */
$payload = unpack('CvalueLengthHigh', substr($binaryData, $valueOffset));
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[$valueLengthHigh] = array_values($payload);
$isLongValue = ($valueLengthHigh >> 7 == 1);
$dataOffset = $valueOffset + ($isLongValue ? 4 : 1);
$formatParts = [
$isLongName ? 'NnameLength' : 'CnameLength',
$isLongValue ? 'NvalueLength' : 'CvalueLength',
];
$format = join('/', $formatParts);
/** @phpstan-var false|array{nameLength: int, valueLength: int} */
$payload = unpack($format, $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[$nameLength, $valueLength] = array_values($payload);
// Clear top bit for long record
$nameLength &= ($isLongName ? 0x7FFFFFFF : 0x7F);
$valueLength &= ($isLongValue ? 0x7FFFFFFF : 0x7F);
/** @phpstan-var false|array{nameData: string, valueData: string} */
$payload = unpack(
"a{$nameLength}nameData/a{$valueLength}valueData",
substr($binaryData, $dataOffset)
);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[$nameData, $valueData] = array_values($payload);
$self->values[$nameData] = $valueData;
$keyValueLength = $dataOffset + $nameLength + $valueLength;
$binaryData = substr($binaryData, $keyValueLength);
$currentOffset += $keyValueLength;
} while ($currentOffset < $self->getContentLength());
}
/**
* {@inheritdoc}
*/
protected function packPayload(): string
{
$payload = '';
foreach ($this->values as $nameData => $valueData) {
if ($valueData === null) { // @phpstan-ignore identical.alwaysFalse
continue;
}
$nameLength = strlen($nameData);
$valueLength = strlen((string) $valueData);
$isLongName = $nameLength > 127;
$isLongValue = $valueLength > 127;
$formatParts = [
$isLongName ? 'N' : 'C',
$isLongValue ? 'N' : 'C',
"a{$nameLength}",
"a{$valueLength}",
];
$format = join('', $formatParts);
$payload .= pack(
$format,
$isLongName ? ($nameLength | 0x80000000) : $nameLength,
$isLongValue ? ($valueLength | 0x80000000) : $valueLength,
$nameData,
$valueData
);
}
return $payload;
}
}
@swoole/library/core/FastCGI/Record/AbortRequest.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* The Web server sends a FCGI_ABORT_REQUEST record to abort a request
*/
class AbortRequest extends Record
{
public function __construct(int $requestId)
{
$this->type = FastCGI::ABORT_REQUEST;
$this->setRequestId($requestId);
}
}
@swoole/library/core/FastCGI/Record/BeginRequest.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* The Web server sends a FCGI_BEGIN_REQUEST record to start a request.
*/
class BeginRequest extends Record
{
/**
* The role component sets the role the Web server expects the application to play.
* The currently-defined roles are:
* FCGI_RESPONDER
* FCGI_AUTHORIZER
* FCGI_FILTER
*/
protected int $role = FastCGI::UNKNOWN_ROLE;
/**
* The flags component contains a bit that controls connection shutdown.
*
* flags & FCGI_KEEP_CONN:
* If zero, the application closes the connection after responding to this request.
* If not zero, the application does not close the connection after responding to this request;
* the Web server retains responsibility for the connection.
*/
protected int $flags;
/**
* Reserved data, 5 bytes maximum
*/
protected string $reserved1;
public function __construct(int $role = FastCGI::UNKNOWN_ROLE, int $flags = 0, string $reserved = '')
{
$this->type = FastCGI::BEGIN_REQUEST;
$this->role = $role;
$this->flags = $flags;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
/**
* Returns the role
*
* The role component sets the role the Web server expects the application to play.
* The currently-defined roles are:
* FCGI_RESPONDER
* FCGI_AUTHORIZER
* FCGI_FILTER
*/
public function getRole(): int
{
return $this->role;
}
/**
* Returns the flags
*
* The flags component contains a bit that controls connection shutdown.
*
* flags & FCGI_KEEP_CONN:
* If zero, the application closes the connection after responding to this request.
* If not zero, the application does not close the connection after responding to this request;
* the Web server retains responsibility for the connection.
*/
public function getFlags(): int
{
return $this->flags;
}
/**
* {@inheritdoc}
* @param static $self
*/
protected static function unpackPayload(Record $self, string $binaryData): void
{
assert($self instanceof self); // @phpstan-ignore function.alreadyNarrowedType,instanceof.alwaysTrue
/** @phpstan-var false|array{role: int, flags: int, reserved: string} */
$payload = unpack('nrole/Cflags/a5reserved', $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[
$self->role,
$self->flags,
$self->reserved1,
] = array_values($payload);
}
/** {@inheritdoc} */
protected function packPayload(): string
{
return pack(
'nCa5',
$this->role,
$this->flags,
$this->reserved1
);
}
}
@swoole/library/core/FastCGI/Record/Data.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Data binary stream
*
* FCGI_DATA is a second stream record type used to send additional data to the application.
*/
class Data extends Record
{
public function __construct(string $contentData)
{
$this->type = FastCGI::DATA;
$this->setContentData($contentData);
}
}
@swoole/library/core/FastCGI/Record/EndRequest.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* The application sends a FCGI_END_REQUEST record to terminate a request, either because the application
* has processed the request or because the application has rejected the request.
*/
class EndRequest extends Record
{
/**
* The appStatus component is an application-level status code. Each role documents its usage of appStatus.
*/
protected int $appStatus = 0;
/**
* The protocolStatus component is a protocol-level status code.
*
* The possible protocolStatus values are:
* FCGI_REQUEST_COMPLETE: normal end of request.
* FCGI_CANT_MPX_CONN: rejecting a new request.
* This happens when a Web server sends concurrent requests over one connection to an application that is
* designed to process one request at a time per connection.
* FCGI_OVERLOADED: rejecting a new request.
* This happens when the application runs out of some resource, e.g. database connections.
* FCGI_UNKNOWN_ROLE: rejecting a new request.
* This happens when the Web server has specified a role that is unknown to the application.
*/
protected int $protocolStatus = FastCGI::REQUEST_COMPLETE;
/**
* Reserved data, 3 bytes maximum
*/
protected string $reserved1;
public function __construct(int $protocolStatus = FastCGI::REQUEST_COMPLETE, int $appStatus = 0, string $reserved = '')
{
$this->type = FastCGI::END_REQUEST;
$this->protocolStatus = $protocolStatus;
$this->appStatus = $appStatus;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
/**
* Returns app status
*
* The appStatus component is an application-level status code. Each role documents its usage of appStatus.
*/
public function getAppStatus(): int
{
return $this->appStatus;
}
/**
* Returns the protocol status
*
* The possible protocolStatus values are:
* FCGI_REQUEST_COMPLETE: normal end of request.
* FCGI_CANT_MPX_CONN: rejecting a new request.
* This happens when a Web server sends concurrent requests over one connection to an application that is
* designed to process one request at a time per connection.
* FCGI_OVERLOADED: rejecting a new request.
* This happens when the application runs out of some resource, e.g. database connections.
* FCGI_UNKNOWN_ROLE: rejecting a new request.
* This happens when the Web server has specified a role that is unknown to the application.
*/
public function getProtocolStatus(): int
{
return $this->protocolStatus;
}
/**
* {@inheritdoc}
* @param static $self
*/
protected static function unpackPayload(Record $self, string $binaryData): void
{
assert($self instanceof self); // @phpstan-ignore function.alreadyNarrowedType,instanceof.alwaysTrue
/** @phpstan-var false|array{appStatus: int, protocolStatus: int, reserved: string} */
$payload = unpack('NappStatus/CprotocolStatus/a3reserved', $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[
$self->appStatus,
$self->protocolStatus,
$self->reserved1,
] = array_values($payload);
}
/** {@inheritdoc} */
protected function packPayload(): string
{
return pack(
'NCa3',
$this->appStatus,
$this->protocolStatus,
$this->reserved1
);
}
}
@swoole/library/core/FastCGI/Record/GetValues.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
/**
* GetValues API
*
* The Web server can query specific variables within the application.
* The server will typically perform a query on application startup in order to to automate certain aspects of
* system configuration.
*
* The application responds by sending a record {FCGI_GET_VALUES_RESULT, 0, ...} with the values supplied.
* If the application doesn't understand a variable name that was included in the query, it omits that name from
* the response.
*
* FCGI_GET_VALUES is designed to allow an open-ended set of variables.
*
* The initial set provides information to help the server perform application and connection management:
* FCGI_MAX_CONNS: The maximum number of concurrent transport connections this application will accept,
* e.g. "1" or "10".
* FCGI_MAX_REQS: The maximum number of concurrent requests this application will accept, e.g. "1" or "50".
* FCGI_MPXS_CONNS: "0" if this application does not multiplex connections (i.e. handle concurrent requests
* over each connection), "1" otherwise.
*/
class GetValues extends Params
{
/**
* Constructs a request
*
* @param array $keys List of keys to receive
*
* @phpstan-param list $keys
*/
public function __construct(array $keys)
{
parent::__construct(array_fill_keys($keys, ''));
$this->type = FastCGI::GET_VALUES;
}
}
@swoole/library/core/FastCGI/Record/GetValuesResult.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
/**
* GetValues API
*
* The Web server can query specific variables within the application.
* The server will typically perform a query on application startup in order to to automate certain aspects of
* system configuration.
*
* The application responds by sending a record {FCGI_GET_VALUES_RESULT, 0, ...} with the values supplied.
* If the application doesn't understand a variable name that was included in the query, it omits that name from
* the response.
*
* FCGI_GET_VALUES is designed to allow an open-ended set of variables.
*
* The initial set provides information to help the server perform application and connection management:
* FCGI_MAX_CONNS: The maximum number of concurrent transport connections this application will accept,
* e.g. "1" or "10".
* FCGI_MAX_REQS: The maximum number of concurrent requests this application will accept, e.g. "1" or "50".
* FCGI_MPXS_CONNS: "0" if this application does not multiplex connections (i.e. handle concurrent requests
* over each connection), "1" otherwise.
*/
class GetValuesResult extends Params
{
/**
* Constructs a param request
*
* @phpstan-param array $values
*/
public function __construct(array $values)
{
parent::__construct($values);
$this->type = FastCGI::GET_VALUES_RESULT;
}
}
@swoole/library/core/FastCGI/Record/Stdin.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Stdin binary stream
*
* FCGI_STDIN is a stream record type used in sending arbitrary data from the Web server to the application
*/
class Stdin extends Record
{
public function __construct(string $contentData)
{
$this->type = FastCGI::STDIN;
$this->setContentData($contentData);
}
}
@swoole/library/core/FastCGI/Record/Stdout.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Stdout binary stream
*
* FCGI_STDOUT is a stream record for sending arbitrary data from the application to the Web server
*/
class Stdout extends Record
{
public function __construct(string $contentData)
{
$this->type = FastCGI::STDOUT;
$this->setContentData($contentData);
}
}
@swoole/library/core/FastCGI/Record/Stderr.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Stderr binary stream
*
* FCGI_STDERR is a stream record for sending arbitrary data from the application to the Web server
*/
class Stderr extends Record
{
public function __construct(string $contentData)
{
$this->type = FastCGI::STDERR;
$this->setContentData($contentData);
}
}
@swoole/library/core/FastCGI/Record/UnknownType.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
/**
* Record for unknown queries
*
* The set of management record types is likely to grow in future versions of this protocol.
* To provide for this evolution, the protocol includes the FCGI_UNKNOWN_TYPE management record.
* When an application receives a management record whose type T it does not understand, the application responds
* with {FCGI_UNKNOWN_TYPE, 0, {T}}.
*/
class UnknownType extends Record
{
/**
* Type of the unrecognized management record.
*/
protected int $type1;
/**
* Reserved data, 7 bytes maximum
*/
protected string $reserved1;
public function __construct(int $type, string $reserved = '')
{
$this->type = FastCGI::UNKNOWN_TYPE;
$this->type1 = $type;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
/**
* Returns the unrecognized type
*/
public function getUnrecognizedType(): int
{
return $this->type1;
}
/**
* {@inheritdoc}
* @param static $self
*/
public static function unpackPayload(Record $self, string $binaryData): void
{
assert($self instanceof self); // @phpstan-ignore function.alreadyNarrowedType,instanceof.alwaysTrue
/** @phpstan-var false|array{type: int, reserved: string} */
$payload = unpack('Ctype/a7reserved', $binaryData);
if ($payload === false) {
throw new \RuntimeException('Can not unpack data from the binary buffer');
}
[$self->type1, $self->reserved1] = array_values($payload);
}
/**
* {@inheritdoc}
*/
protected function packPayload(): string
{
return pack(
'Ca7',
$this->type1,
$this->reserved1
);
}
}
@swoole/library/core/FastCGI/FrameParser.php
/**
* This file is part of Swoole.
*
* @link https://www.swoole.com
* @contact team@swoole.com
* @license https://github.com/swoole/library/blob/master/LICENSE
*/
declare(strict_types=1);
namespace Swoole\FastCGI;
use Swoole\FastCGI;
use Swoole\FastCGI\Record\AbortRequest;
use Swoole\FastCGI\Record\BeginRequest;
use Swoole\FastCGI\Record\Data;
use Swoole\FastCGI\Record\EndRequest;
use Swoole\FastCGI\Record\GetValues;
use Swoole\FastCGI\Record\GetValuesResult;
use Swoole\FastCGI\Record\Params;
use Swoole\FastCGI\Record\Stderr;
use Swoole\FastCGI\Record\Stdin;
use Swoole\FastCGI\Record\Stdout;
use Swoole\FastCGI\Record\UnknownType;
/**
* Utility class to simplify parsing of FastCGI protocol data.
*/
class FrameParser
{
/**
* Mapping of constants to the classes
*
* @phpstan-var array