hH}5hH} G@t#H#hHD$dH3%( uJH[] @ /ug @ H\$} HYo}1Hy]p @ HH 1H=!rC. Hf D ATUSHdH%( HD$1G,H$ PpX HudHthuvHG`H$H{Pܶ. H5 ,Htx4$8EHD$dH3%( uTH[]A\ÐLgP M1NǐLg`H L,)v 1ɾ n UHSHw,dH%( HD$1D$ oX HuVHP. H5 0+Ht"HT$H{PHP虄HcD$E HE HD$dH3%( u#H[]fHP I1MAn AWAVAUATUSHH(w,dH%( HD$11oX HPS. H5 *HH ^6HM C HA@& H5~ HB}HcM HH5kz 'Ht$ }
w9E D$ IE1E1E1ʈU H5z HPL$ HH5? PD HH51 mPL HH5" vL HH5 _L HH5 HHD$dH3%( H([]A\A]A^A_ D D$I AAuI1҉~RD$ Mc11E1E1<A I @ HP I1҉vKIE1D$ kff. AWAVAUATUSH Dg,Ht$ dH%( H$ 1AD$D$PD$TmGXH< HGPE1HD$X{h HC`HD$0A < H H$ H HHD$8AI
H HD$( <t At <t<
f)D$`Ma AE l1ҿ Hc;M}EmHD$IMM9Y
E1H\$@HD$ DMj D L}L;H;E HD$HcLH 6sHuD@@u m u H n D I M9 AFtDc< I.E@uE AoLEMkL}LD$LQ;LD$L9K Hl$E@JE A caI M9{f D HD$LcH\$@J HD$HD$XH L%`. A|$t*H=i\. tzIfH=a. ffH誒Hx iu HY. H8 HD$(HtUH f)D$pD` E > HD$>HD$HD$HD$`HD$HD$hLt$0 Av j>MfHD$AFHLHD$I9# H$ H\$H1HD$(HD$THD$0f. AD$n I|$ Mt$iLcHL$MKH D3<
S < + < I} HH 1IHe H@H H} HF]. H
H1I9 H;F= H HH I9` H;FF IOHu
fApt H 11Of. AG@ A/ AL; k> LJHH AHD$McH|$ J t HL$A@uD${ HD$X H|$ HD$ @ H$ dH3%(
HĨ []A\A]A^A_ HD$ HD$X@@ ApipeuH$ 1Ҿ WAŅ D$ C 1 DA$ Ds CAG@ AW I L9d$u H\$H6mAŅ
E -.{x
Iv H{pH H_l H赓L#C f5IHD$X@@u ID$ HcID$ HA$@foL$`Al$ID$El$AL$(! ELt$1L= L, H$ HD$* ID$H( HII9 A~踟AFuAFLt H5 t Hۏ HDA~ 1*HtHPxHtDŽ$ H$ HT$H`Ic6H;H$ IT$H* [ D AsockMfA et@ I} H IHI} H5 AdHtE11Hp( I~HD$@;L\$@H HT$( @HbL\$@D9u $ E1CAS@uA+u L= hAV@FA.< L: gAG@(f A/L f D {jI} H5϶ i HtDHT$( Hat($ CLH|$hH\$`Ht,ZHtH ZHD$ @ H|$XG@u
/uYHD$HtHL|$Pt |$TtHD$H^HYQ D HredirectI9O9I} ~H2 P
Hυt;HD$9 HD$UHHH HH;x H9ucM~CyDIcAYf D L[ H= 1EC` AG@/A/%E1LX @ XHD$( I$Lh@ H=S. t@fH=9Y. ffHA<$ @0 afL[`IGHU. yy|$P[ C |$T}|$PC }C C D W<n HD$X LoPnHC` HD$(LD$(10? HD$( HD$8 <t6H H$ HHD$(L H$ ,HD$8 0B11DHI"HD$(H HLxHM4M9 H$ 1HD$HHHf. AGtGIw< IHP@@: 8DGD H1 8uHzVf. I M9uHHL}HA|$ [4 LIHD$HD$xA4ImIHD$HD$pAEHHH9 Ll$(H\$@LI @ } tjLmL} II\$Mt IUHIuJIEH =HXIWHIw~JIGHHX AG@uA/u LU H I9uLl$(H\$@L)LJHH\Ht
HVH Ht$LH$ DŽ$
@IGH
UxHD$X HD$H H|$FqHHH~ RP H HD$( Ht$0E111H|$P$=8'H 1H1 EIf <Z HD$( vHt$F H\HT$LH$ DŽ$
fHV. ' H5s 1R0 LbA~ 1ɺ gx5T. LthHL$ HA }LHt$>Ht$HPH@@ytQEH\$HHl-f D {39trP {bHH9tCtҋ{ JH|$8 t
H|$8tHD$XH|$ LL$hHH Mt
HPT. LHt$H`C{8D%1 H H1\C fK8%KD1IHr 1&C HGPHt$X HHD$(=uy aAŅ1A NHpH {AE1rH=L. E[:;[H舔H= H1Gb-8#H5 1H1B9YE1H H5 1H= M ,tWHc8 H 1HHH1AS@ua+u\HtO]A HcHD$HkIHIL9t2A|$A|$ t֓aPA78 #Hl 1H1AH= 10A/Z'Z f t f tf. f. AWIAVAUATIUSHhoHu/6uHFHHt
Ѕ
1Hh[]A\A]A^A_f D I)t.+uAHT$E1Ƀ
HD$( 6 @ IHD$ f.
HT$(E1HD$ Po* L|$HD$8 HD$0 AD$M4ED$D$ AD$D$M9$ LL$ LL- HL$@L<$MME @ f-wA u
AA @ wk6W IcD L>f D A'IIGHt LT$PLT$HT$HLT$P.
H)
ML<$HAD$Hh[L)]A\A]A^A_
V
V H|$ t+IB0Ht"Ht$HLT$HLH)LT$H HD$ f. D$ H ( I9ELL$ MHL$@ML<$ Av IRHHtLT$HL҅I& ALT$HH<
EIB@MLL$ LMHL$@L<$H)Ht)HL$HHLLT$@D$D$LL$ LT$@HL$HMt;IB(Ht2LHL$@LLLT$ L)D$D$LT$ HL$@
H|$Ht;IB0Ht2LHL$ HH)LT$LD$D$LT$HL$
H|$(Ht;IB Ht2LHL$ HH)LT$LD$D$LT$HL$ G
H|$0Ht;IBHt2LHL$ HH)LT$LD$D$LT$HL$
Ht$8Ht8IBHt/LHL$ LLT$H)D$D$LT$HL$ H|$Ht1IBHt(LHL$HH)D$LD$HL$ D$ Al$ED$AD$D$AD$Hb
z Ѓ |$
t$ f : A@+ H\$HD$ D$ fHf 0
L$ & H=b Hc4H>f.
H HSH\$ D$ HH\$ H @ AwH%- HH tUt$80tL Y |$T |$ u S9 Ru 8 AG D$HM D H :f. Ѓ a< H > B< KAGDBfAGf=0H H f. B< AGDBfAGf=H Hh[]A\A]A^A_ L|$HD$8 HD$0 HD$( u7HT$0E1HD$( HD$ 1<HH|$8IBHD$ HT$8E1HT$HD$0 HD$( HD$ IB8I AG HZ LT$HLLT$H8 wAA IBHH} LT$HLLT$H A HE1. ~#y ?H
l
Ht$Ht&IBHt HLT$LH)LT$AG H' HD$ /:#
_ Hm <0 RHfH 0fAGAGDBfAGf=H ~%#1 ?H\$( H
HL$Ht)IBHt HLT$HLH)LT$AG H' HD$ (:n .s 0 YH HH _ /'H\$8 HB< B< / : H|$ IBH Ht$HLT$HLH)ЅH LT$HHD$ BfIB@Ht#LT$PLHLL\$HIwLT$PL\$HL)JTIw_ IBHHT$HHt<$XLL\$PL\$PLT$XHT$H ALۃ<
HL$Ht)IBHt HLT$HLH)LT$H|$(Ht)IB Ht HLT$HH)LLT$AG H' HD$ HD$( #t ?GH O ~d#m ?!H|$8 IBH Ht$8HLT$HLH)ЅH LT$HHD$8
H|$Ht)IBHt HLT$HH)LLT$Ht$8Ht&IBHt HLT$LH)LT$mAG H' HD$ HD$8 c ~#T ?H
Ht$Ht&IBHt HLT$LH)LT$HL$0Ht)IBHt HLT$HLH)LT$AG H' HD$ HD$0 D$ փ Q H
HcH>AHA IBHHA HE1<
LIB0H+ 1LT$HHLЅHD$ , LT$HHD$ D$ K;t H1 /H( !D$ ) HHt$Ht&IBHt HLT$LH)LT$8HL$(Ht)IB Ht HLT$HLH)LT$AG H( HD$ HD$( {H|$0 IBH Ht$0HLT$HLH)ЅH LT$HHD$0 )H HL$Ht)IBHt HLT$HLH)LT$JAG H( HD$ H|$Ht)IBHt HLT$HH)LLT$AG H( HD$ wHnH|$8 IBH Ht$8HLT$HLH)ЅH LT$HHD$8 H|$Ht)IBHt HLT$HH)LLT$KHt$0Ht&IBHt HLT$LH)LT$AG H( HD$ HD$0 HL$Ht)IBHt HLT$HLH)LT$H|$8Ht)IBHt HLT$HH)LLT$AG H( HD$ HD$8 H|$ IB(H Ht$ HLT$HLH)Ѕ/H* LT$HHD$ H HH\$ H\$8HH|$ IBHk Ht$HLT$HLH)ЅH LT$HHD$ 0H "H Ht$Ht&IBHt HLT$LH)LT$FH|$( C IB H Ht$(HLT$HLH)ЅH LT$HHD$ HD$( D$ ) wH|$Ht)IBHt HLT$HH)LLT$H|$0 / IBH
Ht$0HLT$HLH)ЅpH LT$HHD$ HD$0 H|$ l IBH Ht$HLT$HLH)ЅH LT$HHD$ Ht$Ht&IBHt HLT$LH)LT$H|$8 IBH Ht$8HLT$HLH)ЅH LT$HHD$ HD$8 H|$ '
IBH Ht$HLT$HLH)Ѕ8H LT$HHD$ HD$ H DD$ D$ D$D$H/ H
u @84 D$ [D$D$H
H& @84? D$ 'D$D$H HF% @84# D$
B< .IGHH40HHpIGAG D$ AG D$ AG D$ pAG D$ VAG D$ HE15 H\$+ HD$ D$ HSH\$D$ H @ 1[]A\A]A^ H! LL1$N
D H LL1N D H LL1M LcM9sD A
v A
D Et+LK|5 1L)L HgLcM95'H LLKH L)K|5 DH@1 HL Q H1XZ[]A\A]A^ H3 LL1 M *fH LL1 L
fH H LL1L2 fH LL1L fH LL1|L ,fLK|5 1
L)H LcQL @ LK|5 1
L)H Lc)L @ HL Qff. @ H AWHBI1AVL5G 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 HЃP _ C0
LMA
teHH;l$ L @ LMA
uLH)Ht5HH@Ht)LL$HIt
HLL$ HC0 Lf D HC0
H@ HhHЃoR f A
Z C0H=f HCD8d2 HH@H H5tq HЃt3uFHSHHH@HHs2HЃHEfD HkC1HH([]A\A]A^A_ 1A-| A
! HHHSuHH@HlLLL$It
HH)HL$HL$LL$ 7uf D C0H HC0H@HHIt
HL$HH)HL$O @ HH H"LIt
HL$HH)HL$ Lf D C0 HHC w HC0H@(HW SHHHCH9;C0
2f D HC0H HC0D HHkC1Bƃ
HD HkC1 ƃ -HD HkC11L HD HkC1D HHkC1ƃ
HD HkC1ƃ
HD HkC1sLk D U@ SH HH0. PHt<1҅ HPHS Ht"HR
w HsHcKHR8HH[]H
. H5 H= Ff D H. S@ H PHt1HS Ht"HR
w HsHcKHR8H[H
H59 H=r ff. f UH@ SH HH . PHt5HS HhHt"HR
w HsHcKHR8HH[]H
H5 H= <ff. H USHHwC HHŁ` uP t)H8Ht H{0 t=HHE Lc0Ht"H@ wG Hsf D LH`HZ HL B D$H<$DpHD$IcHHHT$PIH HT$H\SЃ<H H= HcH>fKLIH Hc H H' 0 @ H?B k H n Hi HHHFH H wBDD$ HHC Dt$L1L,$,KJ K: DAA vI fHK
A$/c IT$A$L2LHHHLH A$/3 IT$HA $H42/) HA$HHH`HOJf. H5ͺ HU, @ FD D F F
HD$ Dt$H$D$H<$ t<|$Gt%H<$HH,Lw D H} H(L9uHD$H<$P H(HD$1P H\$hdH3 %( D$ Hx[]A\A]A^A_f IT$HBID$ D ID$HPIT$H0IT$HBID$ @ H= HtyAD$= MuM)AD$HI
LT$PL LLM}@HT$ HBD4P Hf A$Ah+ Al D$ IEIMuHHtDBuIHHcl$D|$ #'H$IAHD$ H ! Hc H H' HKY8m4 1 @ H?B H H DHHDaHH H wCf D DAIcH 1HH
Hu E,VЃ< IcL>f D VIcH H} WЃ< H5 HcH>f GAHQ%IcEe
AEH
H9,$D;d$J HcD$H|$ HD$P HD$(H @ G VB Gr Gb V D HV DAf D DAf D Dp @ LAcAEK5FF ߍF
AEAYAY AY
AFH9unH\$L3H[]A\A]A^A_AFAFIFȻ |Ld 랃H
" i H5V H= 1g ' AWAVAUATUSH(H LcII / Ic7 I N I' / IKY8m4 ,I?B I I ILICH I w\$H- AH|$H* FMIHl$H$E1HDl$HKY8m4t$ M f KHU H{HHS HtHtH)HH)HD H[] D uDtU S t܉tft u-Hs 8H[]@U S ttH
H5k H=A ff. @ H= . H USHHH H H-&- H U H U H U H U H U H U H HtH HtHH Ht H H{HHHHH)H HHHE H[]fff. @ S LJ [f UHo SHHG H@s# tDC t<1fD1 @ H{HC HD HH) (1HH HtHH Ht
Hǃ H?H sH ' H fH H H tntIH H߽*H Ht t ubH[]f H H H:$f D H HH L ]f H0HPH1H[] C D HU H߽)Jff. t N1f D f H ~Hff. @ H H ff. f U H SHH- PHV HH. H$H 舽H ǃ H H Eu t
t
Hu@H H!HE0HuHH HE8H ukHuHu[E ~ E HEHt9 t0 t'H0HPH/fH{ H'HH[]fGH53 @ H1HH[] @ HMU(HHu LEf @ HUHuHp!Mff. HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$("HT$XdH3%( uHha HxfHL$H$dH%( HD$h1)D$0HH|$0H|$)D$)D$ )D$@)D$Pt$8HD$w"HL$hdH3 %( uHx ff. f HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(D$ "HT$XdH3%( uHhy f HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(HT$D$ !HL$XdH3 %( uHh @ HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(HT$D$ !HL$XdH3 %( uHh @ HhHdH%( HD$X1H|$ HL$HD$ HD$H HH)LHH$ HT$ Ht$XdH34%( uHhff. HxIHT$H|$ HL$H4$HH)LdH%( HD$h1HD$ HD$X HHH|$LD$(D$ HD$ HT$hdH3%( uHx HhfdH%( HD$X1D$H H|$HD$D$(D$8HD$H H$ HT$XdH3%( uHhf HhdH%( HD$X1H|$ HL$HD$ HD$H HH)LHH$ T$' Ht$XdH34%( uHhff. f ATUSL$ H H $ L9uHodH%( H$@ 1uqHIH @ LPxYu'H$@ dH3 %( uIH@ []A\f D H HcL螽tH Hߋ0HP" D @ ATUSDgE H HHQЃ<w1H5r HcH> D
N H HtUfHtqH r< H
8 HcH> OH9tHH1yHH H!f AD[]A\fQHtHHPHx`H Oʃ H5 HcH> HQf. Qf. Qz 1Hz E D[]A\ 1@ D 1z D 1fz @ R1 @ HO O D O o1ff. SHHH t1H[H H߉D$ 1HQ2 D$ ff. UHSHHHH)tH3HtH Ht> t 1H[]fH D AUATIUSHH(dH%( HD$1Hl$D$ HD$ HntaH|$Ht/M I<$1HT$dH3%( u|H([]A\A] D tLl$ D$ u2LH
u뱐HHtH|$HuH2u K1t ff. @ SHH LHt H 1[HH [Ð Hs4H @ UHSHdH%( HD$1H 4ÃtgtIH4$HHc 4H<$H- u P HL$dH3 %( uCH[] P Ho H HH H f H HT$0HL$8LD$@LL$Ht7)D$P)L$`)T$p)$ )$ )$ )$ )$ dH%( HD$1H$ H$ HD$HD$ D$0 HD$HL$dH3 %( uH Kff. UHSHdH%( HD$1H[ÃtHH4$HHc2H<$Åu#&HL$dH3 %( u.H[] D H Hx U1SHHdH%( HD$1u tHH$uH,$HL$dH3 %( HuH[]Mff. f H HT$0HL$8LD$@LL$Ht7)D$P)L$`)T$p)$ )$ )$ )$ )$ dH%( HD$1H$ H$ HD$HD$ D$0 HD$HL$dH3 %( uH ff. U1SHHdH%( HD$1\
u tHHuH,$H|$dH3<%( HuH[] f. He- oHLLJoNLBHzHJ LJHv LHHr L@HxHH H- H- HH- HPH- HPH- HPH- HP f. @ AUIATUHSH dH%( H$ 1H貭 HD 1HMtm MHLW | HcH)HDHھ HH$ dH3%( u HĘ []A\A] D H Ht u SH.ǃ [Ð UH1SH *HHtHtJHH[]f D 賬 tu1HH[] t1Ҿ HHM HH뙐 USHHH VЃ< H
И HcH> V 1 HHxHHH[]f D HVfVf. Vf. 軫 tuHH[] D t1Ҿ HHt1X D AVA AUA ATIUSH dH%( HD$1Hl$D$ H A H ߾ Dl$ DVUUUA H A ߾ D)DЉT$ v xRA H ߾ D$ P x,E1HL$dH3 %( Du[H[]A\A]A^f [A8 LHA48 LHmf D SHA H dH%( HD$1HL$D$ t1HT$dH3%( u'H [H5 H߉D$ HD$ f SHH H ?tKV jt/~ Pw 1[f D t[ @ 1[f D [ ATUHSH dH%( HD$1D$ Ԩ HL$LD$ IċD$ xtHD$u+\$uHT$dH3%( uAH []A\Éf D A$1H}H5_ HD$ hD$ ff. AT IUSHH0dH%( HD$(1 fL$$D$ 8sukH|$ D HD$ tftBHt$ HuuT$ u
H HL$(dH3 %( uMH0[]A\ E n 1HHH5 H߉D$ }HD$ f. SffHH*H*ƾ H ^^Xf(L$d%L$t! f( E%t1H[H5 Hf H H9tPUHSHHHto 1H[] Ha- H Huϸ 1ff. fAWIAVAUMATIUSHH( dH%( H$ 1 LJ H D$ HD$@ H9t#L5- AV HAVI$ Hl M LLO I$ H HBH=@B H2HS㥛 H9 H I$ HS㥛 HHi HHH?HH)¸H 2HHFHD$(M L9tL5- AV LAVI$ A 1L$ Hl$@LLs: fHLI$ HT$P)D$PH HT$)D$`)D$pHD$TJ H\$@H HD$HD|$ E1HD$HD$f D 8suAtHHtf {f D HL%- D Hc H 1H߉D$ D$ 0f. Ht H -tA<> GLWHπw0LcH A AJDIA w0OMJHcLMIL)H* M9wOI0MHHHL9cIL9tYAIA< vŸJ 0t+-4qϸ@'0HJf D H 1f D t$H I9LHH1 D LMH1f D IA 10Lc ATAUHSHH Ht"H HtH@0Ht
Hǃ H iD#HHǃ Hǃ Hǃ ǃ s HKHHGs%uYtJU St?tft1 @ HU H{ HHSHtHtH)HH)HD []A\ÐU Sttff. HvJUHSH^H x
t(HHH)HH)Hھ
H"HHuHH[]1Hf. Lc E UASI SHcHI)HHLD
v H
H5݆ H= HsHRMcHLRLM9u HI9uH[]f D I9}%A I@AHH[]H
g H5[ H=Ӈ ff. @ AWAVAUATUSHHx L L dH%( H$h 1H ML)LfH L)Hc L Hō@HM4HLH M Ic^
Z ~5A$
t\
tWuLL @ JH
t;
t6H9uH Hi H
H] HcLLM D H! HlH$h dH3<%( Hx []A\A]A^A_f D E LcLl$ F LLLBD< H5ª Lz H H* H@H LLLxHT$HcL H Hg H@HZ Ht$L6f D H H H@ H Lf D H L uH H Lx1H5ϩ Ly Ht$L||$ t*KD= H9D$u f(Q fT
Q f.H H&f~5u1 D HHuA<$-tA<WЀ HPH9uH H L M HcLLAf. L f T$ A4$H=j L$ H H HtgH@(Ht^1L@T@o L gf Tf D ( 4f D H H<
Hk HH~ HHr HlHA HPH H߉D$ D$ / H ATUHSH HtH Ht H@0HtH Ht] ~kL% - 1f. H D HH H[] D HfHf. HHf. <hGDGD)H D GDGD)H D G+G D hHz H߽J1f.
f. A U9> M I I LL)HHH)PHcLI HH$HcHW HT$ A H8 I H~ H9# I H Lc#A uHHT$ HtHAHt
Ht$ HIM HD$ I H8 HCA LcA HHHH@ H@@ HHX HI HP(M I I I H,H)HHHH$HHD$H)LfHL$ HT$ H 5 I Nd"LI; QHc I HtLMt
HqHAH A M uI I Ht$l L%- HcHAT$HtaA I 9 f D A 9xHcҾ0 L,AT$Ic IE I HH< uH v L`S I HHHB HBBHI H@ HHP(1Adž I M I?Idž D$ D I H0 I Idž QЃ< H5 | HcH>f D H HA H HIHI Ht$O I H H@ H Hf Ht$v
D D
D q @ a Q D % D ! f D H2I H"H@0H @@
@ u @ D$("\a"Ld$(D$, H\$0MṀ 1Hߺ Lv 舮Hھ L{ A D H~
y:H w LL? @" @\ @
tKHALd$(H Lw DP@u DLw L1 ЭD$("\r"Ld$(D$, AA I AAHAD$Hyv Ll_D$("\t"Ld$(D$, Ld$(ALw CD$("\b"Ld$(D$, eD$("\n"Ld$(D$, NHv LH~u LH
x H5it H=v Hv L 1 AVAUIATUHSH H H : H9HۃH H9EAAH- Lt+LH HM A ~YA A HkHkCHtMtHLHѹ+ H[]A\A]A^Ð A uAub@k@kC @ HHz AAHc B D 1LHAVfkfkCf CPf kkC8 A 1 w Hw @@ w w1 Ht7G<~ H- ` fH&y HcH)H- ` D ff. @ SHSwH
u HHcH>HC[f. C[ C[ÈC[ fC[f G<w!Hu HcH> D HG @ G D G G 1 fGf D AWAVAUATUHSHWЃ< v8< < LHGHL)H9w4HH[]A\A]A^A_ < OGI)HHH9vLHl$H
w HcHH)HL$H6L H LFI A A I| D8 H - H HIWHH"H- H|$P DsAM A AI D{A@ wADkf D A
ALk I L9EAAL9HۃH L9EI| AAD8H:- HH|$PH HDcAH D DGHD)H9i0 D OGICH E1<>H
!s HcH> AAEL D D{Dk fD{fDkf 1f A A f. L{HjD}D}D}L}xf AWAVAUIATUSH_ރ@ HAr @HcH> _L{M@Ht MHcI)H H H H9 H{ A D8 HN- H HLLHRH+- LP DeA A A H]H]HH[]A\A]A^A_ H_ L{@ H{ME1 S _ _ A& ]؈Etf HY- HLPHH E<% v<# <.%f D < @ @Hs I1HcA E1 I)u H{ A ^ @ H{ E1I 1f H{
A @ H{ A @ f]fE\ E]؉E> I1E1 A @ @ WЃ<wyH
lo HcH> GHH1Hq HcH D HGHHf D HHfGHHf D GHH륹 ff. @ WHH
cq HcH)ff. WЃ<# H
n HHcH> G W)9 ƉwH H HG HWHcH)H9 HHwH H ] p HWH Hf. G W)9 @w@H Hf D Gx0W)9|.fwH H @ 9sH
p N H5p H=p Ff D HcH9 HcHHwHf D 9FH
o H H5o H=Gp f. 9lH
o T H5o H=rp 赢 D t 9rHWHH
@o A H5Do H=}o pH
!o Z H5%o H=~p Q AUATIUSHHo< HPl HcH> oI9 MHI)L賻HHtoIUH<(1,C<wUH
l HcH> D Hof@@f D of. oz DcHH[]A\A]f D fDcDcf. Lcf. ADc1"ff. @ AUIATUHSHDgD< HFk HcH> D DgH蔺HHtxHJ< LLZC<wWHk HcH> LgfDgf Dgf AEf D k D + HH[]A\A]f D C @ Hkf. fkf. @kE1&f UHHSHHxHHH[H]D @ VЃ<wXH
4j HcH> VHV D V Vס1 UHSHHWЃ</ H
i HcH> GH9 GHH) ˸HH HHH葪H @<~ Hxi HcH> H;_vRHH+w롐GH9v?GHH) GH9v'GHH)pHH)H9[ HaYHH[] HȈYH[]HYHH[]ffYHH[]fYHH[] HHf UHHSHHxHHH[H] @ IHHH?II1I) D ILLMLIIHHHI)L0AAI wHyHAA-LILA H)H9s D 1HH@wQH9r D IH D LHHILIIHHHI)A0EAH wLA H)H9w" DHDHQH9r D SHH dH%( HD$1HH9HHcHT$dH3%( uH [胻 AWAVAUIATIUSHH H|$HdH%( H$8 1赌H H L5- HAIHD$0H$MtiHl$Mt IM A Ao$HLID$HE HEA> trL5+- L;<$tLAV HHAIHu1H$8 dH3 %( ubHH []A\A]A^A_f D HD$0 H$ITf. H|$LL;<$tH- H$LR H$1 H HT$0HL$8LD$@LL$Ht7)D$P)L$`)T$p)$ )$ )$ )$ )$ dH%( HD$1H$ H$ HD$HD$ D$0 HD$yHL$dH3 %( uH {ff. AWIAVIAUATUSH HT$`HL$hLD$pLL$xdH%( HD$H1H$ D$ HD$ HD$PHD$(G[ H
d HcH>DgA> . < <B < IGI+GH AI^<% AvN,h H HH! H H!: H H' D$/ HT$(D$H*@s DmD<_ Hc HcH>DgDgDgAAEDm AG<M < <uIOI+Of D I9vLL IH IcLHLAWDЃ<w"H5 c HcH>Eof. AIf { f AG<6AGAW)HHF L {IH&1H\$HdH3 %( HĈ []A\A]A^A_fEomE odB*AGQMoHAGDm<AOAG)HcDmAExLmo <8AGAW)H[ D McAL$CAWЃ<, H=a HcH>f D HLAGÀ{ I D McLC HfAGLAIif HAGLAIJf. HAL IAW!HIGLAI
f. McAL$IC4AWЃ<a H5` HcH>f. AGA fAGAfAGA A̍ AWzf. IGAc AGA+G D$@uB /Y HT$(D$H2Hl$0HK$LcAG<] <g < IGI+G I9vLL萮IHIcLHLSAWЃ<w%H
_ HcH>$AGf D$$Is Mof. fEof E of. B *AO<u AGAW)H9f 1)f D$@i / HL$(D$H1Hl$0HT$Hv$LcAG< HT$ < <u IWI+WI9vLL@IHIcLHLAWЃ<H5z^ HcH> D B*AG D <uAWAG)Hcx /w{HT$(D$2f D HT$ HBHD$ D <PAOAG)Hc< @ AGAW)H D AGA+G HT$ HB2HD$ C / HL$(D$Hc1qf HL$ HAHD$ R D HT$ HBH*HD$ @sHH $葂H $IU D AWA+WS AWAG)Hc< @ HL$ HAHD$ d D AOA+O3辰HALIE1E1Au D AUATIUHSHHWЃ<w(H
\ HcH> @ HGHX IHs_ IL9 Au L{HuI9r#f. HL9v3L{HuI9wbL)HLd L9tHLHA$ E<w H[ HcH> ]HH[]A\A] I1f f]HH[]A\A]f D ]HH[]A\A] H]H[]A\A] @ H]HH[]A\A]f D H_H _H _HI1f. GHǃ@ LZ @IcHAHW H USHHy Hƿ HHHy H¿ HHH9 H9 H9 H)HZH,HtHHH HE A<wZH`Z HcH> Hg1f D AL A< A-YH1[] @ fYH1[] YH1[] @ HYH1[] AH1[] D HH9~ H1(f D H)HXf D USHo<wOHvY HcH> D o~/HAlUHHtf D HHHWH9uH[] o @@f D ofof. USHo<wOHX HcH> D o~/H!jUHHtf D HHHWH9uH[] o @@f D ofof. USHo^ڃ<$ H
QX HcH> ow!H
AX HcH> @ Hov1ۉH)[]f. @@f D of. of. 1f D ^HH9HF&}tH[] 1f D ^HH9HF1f D ^HH9HF 1f D H^HH9HF H9HHFf D w*H
PW HcH> 11N111Cff. AWAVAUATUSHH H- AΉL$ H|$( LD$0HT$t$<IHi AF)É\$8{ HcD$ E11E1A HD$(IcH|$|$ t\HT$(Ht${tUAD9t$8 EeA9|Hݙ- LHcHPH IcH|$|$ IuHD$ 8uDIcHcH|$)IHcHT$ 8HT$ HHtKDt$ EDD9t$8vt$ D$' LǺ HȆANL4$Il D$'
f D$'
f D$'f D$'f IFt I$DB t E @ Ht$MNjBt(Hl$H\$ HH| BuH- H|$P MtLճHD$ HD$ @ A~'LǺ InE1H5+ E1诅ANIIO E1A :f. IvI$HDru-I~H<$D$' @ E1E1 IvDrtLD$IA>$$LD$HLT$' AIH- HD$H|$S HD$ ff D D_HD߃@w+LiN @Ic IE EIM9uDXMtII D HtE
D:tBE1 D F8 tIL9uIM9uLXAEDXDXI AVIAUATIUSg~:Dm1L HI4H!9t LHHSL9u[]A\A]A^ AWIAVIAUATIUSH~ ICLL)ȉ [ ]A\A^ L)L 1fH(dH%( HD$1H v~HFH H f D HHHrHwHHwo$?HHNfAHHAȀDAHw0H|$dH3<%( u9H( @4$H H$? HN뷸袝fH^ HP HcH> D n Hontrol-aH3WHaccess-cH3H uHllow-oriH9G @ y HransportH3WHstrict-tH3H uH-securitH9GC @ G D Wr[ t* e(?cookX fG d<G HN HcH> D
r Hretry-afH9 D G D e ?t= D D fHcontent-H9 Hwww-authH9> Á?refr Á?:sch ?upgr Á?:met Á?:sta ?expi Á?refe{ f?va* Hif-none-H9 f?li Haccept-rH97 f?ho HauthorizH9a f?da Hlast-modH9 f?fr Hcache-coH9V f?eth Hcontent-H9 øøø @ 1tnx9 fho[ frey2 ø ø* ftu= fem fes3 Àim6 Áatio Àn?, Árang Ámatc( Ántro Àr: Àa! Àt* Às% Ào4$ Áange Áifie+ ø0 fre+# fadA øøøøøøf AVAUATIUHSHHHH dH%( HD$1\I9 IH~
H@A H H @ HHHrHwHH E EH $HN HHπ@yHwHu EunM9 LHHH\$dH3 %( H []A\A]A^f D I~vZID$ME1H/H$ HN LHH袲A D H$SfME11H$ HN0PH
C H5C H=R@ o SHH HH)A H9sHE1H{@pHxH) [ PXH
C Y H5C H=? HKoff. HHGHP=H9vDH ? ? H)H H D HHHrHwHH A H
XA EHB
<HN@<$f D HHπ@yHwLuHU H3LH\$dH3 %( u|H []A\ E1H@ EB"4 H$ Aw= Aw-H@ EHB
<HN @<$fyӋ UHLISHHHdH4%( Ht$1 H H|$APL Q ZYHt,T$H9w#H HL$dH3 %( uH[] D HBf oSHHFHGHHPH@HG(HFHWHPH@HW HG0FHG@ G8GL H?4{H{[*{f. SHHH;[vf D AUIATUSHHH t81 HCHHH#CHL$LrLL臀H9kwH3HL[]A\A]lff. AUATUSHHo HG(H;G0 HI' @ LLH%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 LحLL~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 LmIHV LHLIGMoHPIEH9 A H ML9wJ4 L(mH 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
p, HDD|DA A uQI AG t`Ll@M @ D$ DD$IOIWHH|$0V AG At$At A6 H !@ L D$ Ll@M E1Ld$ Hl$MLEE/f. Mt[IEHUH;Pti D Mm@M E;}uAuE9uLuIE H;XuHxHt$ HPuMu D |$5 IEMHUH;PuHuHxPuIHl$E8f D AALJ
ILJ ILJ A Ht$14 IwpHLL.Hx$II D$ t HAG<H|$XdH3<%( Hh[]A\A]A^A_ D I HMG`L)H9HGH/ IHuA 8f IwHHLLHxII `IG` I IG`I+GXHB1ALJ 9 @ A A tA MIIIGHt$::_SafeConv<_Yp> std::__shared_ptr<_Tp, _Lp>::reset(_Yp*) [with _Yp = swoole::SSLContext; _Tp = swoole::SSLContext; __gnu_cxx::_Lock_policy _Lp = (__gnu_cxx::_Lock_policy)2; std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> = void] St11_Mutex_baseILN9__gnu_cxx12_Lock_policyE2EE St16_Sp_counted_baseILN9__gnu_cxx12_Lock_policyE2EE St15_Sp_counted_ptrIPN6swoole10SSLContextELN9__gnu_cxx12_Lock_policyE2EE .A @@ Co\Socket\ExceptThe object of %s can not be created for security reasons Timer must be greater than or equal to 0.001 Unable to wait signal, async signal listener has been registered The signal [SIGCHLD] is registered, cannot execute swoole_coroutine_exec API must be called in the coroutine unknown protocol family, must be AF_INET or AF_INET6 bsize frsize blocks bfree bavail ffree favail fsid namemax Invalid signal [%ld] unknown fd type Unable to execute '%s' output only support file resources Swoole\Coroutine\System Co\System s|ld domain name is empty s|lllsd hostname is empty gethostbyname dnsLookup getaddrinfo statvfs readFile writeFile waitPid waitSignal waitEvent fread fwrite fgets -1 signo filename fileContent family socktype STREAM_IPPROTO_TCP service get_error_stream false domain_name 60 *Z33zim_swoole_coroutine_system_freadEUlvE_ *Z33zim_swoole_coroutine_system_fgetsEUlvE_ *Z34zim_swoole_coroutine_system_fwriteEUlvE_ MbP?you must call Redis constructor first you should not use setDefer after subscribe you should not use recv without defer or subscribe subscribe cannot be used with defer enabled Position must be either 'BEFORE' or 'AFTER' WEIGHTS and keys array should be the same size! Invalid AGGREGATE option provided! Weights must be numeric or '-inf','inf','+inf' Must pass either 3 or 5 arguments min and max arguments must start with '[' or '(' Invalid OFFSET for bitop command (must be between 0-2^32-1) errType zset hash reconnect compatibility_mode database punsubscribe pmessage psubscribe Swoole\Coroutine\Redis Co\Redis SWOOLE_REDIS_MODE_MULTI SWOOLE_REDIS_MODE_PIPELINE SWOOLE_REDIS_TYPE_NOT_FOUND SWOOLE_REDIS_TYPE_STRING SWOOLE_REDIS_TYPE_SET SWOOLE_REDIS_TYPE_LIST SWOOLE_REDIS_TYPE_ZSET SWOOLE_REDIS_TYPE_HASH SWOOLE_REDIS_ERR_IO SWOOLE_REDIS_ERR_OTHER SWOOLE_REDIS_ERR_EOF SWOOLE_REDIS_ERR_PROTOCOL SWOOLE_REDIS_ERR_OOM SWOOLE_REDIS_ERR_CLOSED SWOOLE_REDIS_ERR_NOAUTH SWOOLE_REDIS_ERR_ALLOC The host is empty unix:/ The port %ld is invalid cannot allocate redis context Can not found the connection connection is not available MOVED slz %ld PSETEX LSET RESTORE SDIFF SDIFFSTORE SUNION SUNIONSTORE SINTER SINTERSTORE RENAME RENAMENX RANDOMKEY UNWATCH BGSAVE LASTSAVE FLUSHDB FLUSHALL DBSIZE BGREWRITEAOF ROLE sls SETRANGE GETSET APPEND LPUSHX RPUSH RPUSHX SISMEMBER ZSCORE ZRANK ZREVRANK HGET HEXISTS PUBLISH sss ZREMRANGEBYSCORE ZCOUNT DECRBY GETBIT LINDEX PEXPIRE PEXPIREAT sll GETRANGE LTRIM LRANGE ZREMRANGEBYRANK %f SADD SREM ZREM PSUBSCRIBE PUNSUBSCRIBE sss|l XRANGE XREVRANGE XDEL XINFO GROUPS CONSUMERS sssls|a XAUTOCLAIM justid JUSTID sssla|a XCLAIM retrycount RETRYCOUNT force FORCE ssa XACK XPENDING consumer ssa|a XREADGROUP noack NOACK STREAMS XGROUP DELCONSUMER DESTROY CREATECONSUMER sss|b CREATE XTRIM minid MAXLEN ~ MINID limit XREAD XADD nomkstream NOMKSTREAM flush kill SCRIPT LOAD s|al EVALSHA EVAL ssz SMOVE BITOP BITCOUNT ssd HINCRBYFLOAT sz|l LREM sszz before LINSERT HINCRBY sa|a!s SUM ZUNIONSTORE %zu WEIGHTS -inf +inf AGGREGATE ZINTERSTORE sss|ll ZREVRANGEBYLEX ZRANGEBYLEX sss|a withscores ZREVRANGEBYSCORE WITHSCORES ZRANGEBYSCORE sll|b ZREVRANGE ZRANGE BZPOPMAX BZPOPMIN ZADD INCR sdz ZINCRBY HMGET PFMERGE PFCOUNT PFADD SRANDMEMBER BRPOPLPUSH BRPOP BLPOP MSETNX HSETNX HMSET HSET HDEL slb SETBIT sz|z PTTL ZCARD HLEN HKEYS HVALS HGETALL SMEMBERS DUMP DECR PERSIST LLEN SCARD SPOP STRLEN s|lb __destruct getAuth getDBNum getOptions setOptions getDefer setDefer setBit psetEx lSet mGet del hDel hSet hMSet hSetNx mSet mSetNx getKeys strLen blPop brPop bRPopLPush lSize lLen sSize scard sPop sMembers sGetMembers sRandMember persist pttl zCard zSize hLen hKeys hVals hGetAll debug restore dump renameKey rename renameNx rpoplpush randomKey pfadd pfcount pfmerge ping auth unwatch save bgSave lastSave flushDB flushAll dbSize bgrewriteaof role setRange setNx getSet lPushx lPush rPush rPushx sContains sismember zScore zRank zRevRank hGet hMGet hExists publish zIncrBy zAdd bzPopMin bzPopMax zDeleteRangeByScore zRemRangeByScore zCount zRange zRevRange zRangeByScore zRevRangeByScore zRangeByLex zRevRangeByLex zInter zinterstore zUnion zunionstore incrBy hIncrBy incr decrBy decr getBit lInsert lGet lIndex setTimeout pexpire pexpireAt getRange listTrim ltrim lGetRange lRange lRem lRemove zDeleteRangeByRank zRemRangeByRank incrByFloat hIncrByFloat bitCount bitOp sAdd sMove sDiff sDiffStore sUnion sUnionStore sInter sInterStore sRemove srem zDelete zRemove zRem pSubscribe pUnSubscribe multi eval evalSha xLen xAdd xRead xDel xRange xRevRange xTrim xGroupCreate xGroupSetId xGroupDestroy xGroupCreateConsumer xGroupDelConsumer xReadGroup xPending xAck xClaim xAutoClaim xInfoConsumers xInfoGroups xInfoStream group_name consumer_name min_idle_time options pairs weights aggregate other_members newkey other_keys timeout_or_key extra_args score channels dbindex cmd dst src channel patterns dstkey timestamp pivot pattern script_sha num_keys ret_key integer H_\]`]H_x]`^0_h\ `|____ `__ `_X________sqssssssŝׂ̂zddo Mb@Cexecv(%s) failed, Error: %s[%d] kill(%d, %d) failed, Error: %s[%d] sched_setaffinity() failed, Error: %s[%d] cannot use both 'timer' and 'alarm' at the same time setitimer() 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] %s(): dup2(%d, %d) failed, Error: %s[%d] you must call Process constructor first 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 setBlocking the pipe no pipe, cannot setTimeout the pipe $who parameter must not be null no pipe, cannot close the pipe %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 Illegal callback function of %s /builddir/build/BUILD/swoole-5.1.7/ext-src/swoole_process.cc process has already been started exec file name is empty More than the number of CPU invalid cpu id [%d] cannot use %s::alarm here %s: signal [%d] handler error invalid signal number [%ld] no pipe, cannot export stream not current process no msgqueue, cannot use pop() the data to push is empty the data to push is too big read() failed, Error: %s[%d] 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 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] alarm daemon setAffinity setPriority getPriority setBlocking useQueue statQueue freeQueue pop exportSocket exec_file exit_code which 8192 who priority blocking cpu_settings nochdir true noclose pipes [] signal_no redirect_stdin_and_stdout pipe_type FvPvE PFvPvE *Z25zim_swoole_process_signalEUlPN6swoole7ReactorERmE_ void zim_swoole_process_daemon(zend_execute_datamust call name_resolver_context constructor first the given object is not an instance of %s Swoole\NameResolver\Context Class "%s" not found basic_string::append 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 you must call Http Client constructor first %s must be of type callable, %s given websocket handshake failed, cannot push data Swoole\Coroutine\Http\Client\Exception SWOOLE_HTTP_CLIENT_ESTATUS_CONNECT_FAILED SWOOLE_HTTP_CLIENT_ESTATUS_REQUEST_TIMEOUT SWOOLE_HTTP_CLIENT_ESTATUS_SERVER_RESET SWOOLE_HTTP_CLIENT_ESTATUS_SEND_FAILED %s: __pos (which is %zu) > this->size() (which is %zu) %s() (ERRNO %d): Http header too large stat(%s) failed, Error: %s[%d] cannot send empty file[%s], Error: %s[%d] parameter $offset[%ld] exceeds the file size parameter $length[%ld] exceeds the file size, Error: %s[%d] %s(): inflateInit2() failed by %s %s(): HttpClient::decompress_response failed by %s %s(): BrotliDecoderCreateInstance() failed %s(): BrotliDecoderDecompressStream() failed, no memory is available %s(): BrotliDecoderDecompressStream() failed, %s %s(): HttpClient::decompress_response unknown compress method [%d] %s(): open(%s, O_CREAT | O_WRONLY) failed, Error: %s[%d] %s(): ftruncate(%s) failed, Error: %s[%d] %s(): fseek(%s, %jd) failed, Error: %s[%d] Socket#%d has already been bound to another coroutine#%ld, %s of the same socket in coroutine#%ld at the same time is not allowed Content-Type: multipart/form-data; boundary=%.*s
--%.*s
Content-Disposition: form-data; name="%.*s"
--%.*s
Content-Disposition: form-data; name="%.*s"; filename="%.*s"
Content-Type: %.*s
application/x-www-form-urlencoded permessage-deflate; client_no_context_takeover; server_no_context_takeover statusCode application/octet-stream upgrade sec-websocket-extensions permessage-deflate set-cookie set_cookie_headers content-encoding transfer-encoding chunked max_retries lowercase_header keep_alive websocket_mask http_compression body_decompression websocket_compression write_func Swoole\Coroutine\Http\Client Co\Http\Client Co\Http\Client\Exception basic_string::substr 1.2.11 reading reading or writing POST Host http:// %s%s:%u%s %s%s%s HTTP/1.1
%s:%u Content-Length Accept-Encoding Basic Proxy-Authorization keep-alive gzip, deflate, br ; Content-Length: %zu
--%.*s--
Content-Type http_build_query failed Upgrade 13 Sec-WebSocket-Version Sec-WebSocket-Key Sec-Websocket-Extensions setMethod setHeaders setBasicAuth setCookies setData addFile addData execute download getBody getHeaders getCookies getStatusCode getHeaderOut getPeerCert Swoole\WebSocket\Frame SWOOLE_WEBSOCKET_OPCODE_TEXT SWOOLE_WEBSOCKET_FLAG_FIN int http_parser_on_body(swoole_http_parser*, const char*, size_t) bool swoole::coroutine::http::Client::recv_response(double) std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> std::__shared_ptr<_Tp, _Lp>::reset(_Yp*) [with _Yp = swoole::SSLContext; _Tp = swoole::SSLContext; __gnu_cxx::_Lock_policy _Lp = (__gnu_cxx::_Lock_policy)2; std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> = void] bool swoole::coroutine::http::Client::decompress_response(const char*, size_t) *ZN6swoole9coroutine4http6Client7connectEvEUlPNS0_6SocketEE_ D D D Co\Http\Client\E----SwooleBoundaabcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!"§$%&/()=[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 __builtin_expect(!this->empty(), true) /usr/include/c++/8/bits/stl_queue.h unexpect http2 header [%.*s] (duplicated or overflow) nghttp2_hd_deflate_hd() failed the send queue is full, try again later nghttp2_hd_inflate_new2() failed nghttp2_hd_deflate_new2() failed nghttp2_hd_deflate_change_table_size() 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 streamId serverLastStreamId 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 nghttp2_hd_inflate_hd failed %s with error: %s %s(): inflateInit2() failed :method :path :scheme :authority %s:%d failed to send control frame PRI * HTTP/2.0
SM
%s(): decompress failed stats isStreamExist goaway error_code debug_data '' end_stream 80 `QQ NLP8Q(R8S(R(SSS R int swoole::coroutine::http2::Client::parse_header(swoole::coroutine::http2::Stream*, int, char*, size_t) swoole::ReturnCode swoole::coroutine::http2::Client::parse_frame(zval*, bool) std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> std::__shared_ptr<_Tp, _Lp>::reset(_Yp*) [with _Yp = swoole::SSLContext; _Tp = swoole::SSLContext; __gnu_cxx::_Lock_policy _Lp = (__gnu_cxx::_Lock_policy)2; std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> = void] void std::queue<_Tp, _Sequence>::pop() [with _Tp = _zend_string*; _Sequence = std::deque<_zend_string*, std::allocator<_zend_string*> >] std::queue<_Tp, _Sequence>::reference std::queue<_Tp, _Sequence>::front() [with _Tp = _zend_string*; _Sequence = std::deque<_zend_string*, std::allocator<_zend_string*> >; std::queue<_Tp, _Sequence>::reference = _zend_string*&] *ZN6swoole9coroutine5http26Client7connectEvEUlPNS0_6SocketEE_ Co\Http2\Client\PRI * HTTP/2.0
please use the Swoole\Server->connections uid can not be greater than %u or less than %d swoole connection list max_find_count=%d failed to shutdown, kill(%d, SIGTERM) failed, Error: %s[%d] not supported with single process mode failed to send the reload signal, Error: %s[%d] please use %s->finish instead when task_enable_coroutine is enable can't sendfile[%s] to the connections in master process kill(%d, SIGTERM) failed, Error: %s[%d] onPipeMessage is null, can't use sendMessage SWOOLE_SERVER_COMMAND_REACTOR_THREAD SWOOLE_SERVER_COMMAND_EVENT_WORKER SWOOLE_SERVER_COMMAND_TASK_WORKER SWOOLE_DISPATCH_RESULT_DISCARD_PACKET SWOOLE_DISPATCH_RESULT_CLOSE_CONNECTION SWOOLE_DISPATCH_RESULT_USERFUNC_FALLBACK %s->onPipeMessage handler error %s->onBufferFull handler error server is running, can't add process the first parameter can't be empty object is not instanceof swoole_process server is running, can't add listener %s can only be used in CLI mode server is running. unable to create %s failed to listen server port[%s:%ld], Error: %s[%d] /usr/include/c++/8/bits/stl_vector.h %s->onBufferEmpty handler error server is running, can't add command only support worker/task_worker process {"data": "failed to call function", "code": -1} {"data": "wrong return type", "code": -2} \Swoole\Server\Helper::onManagerStop %s->onManagerStop handler error \Swoole\Server\Helper::onBeforeReload %s->onBeforeReload handler error \Swoole\Server\Helper::onAfterReload %s->onAfterReload handler error \Swoole\Server\Helper::onShutdown \Swoole\Server\Helper::onWorkerExit %s->onWorkerExit handler error \Swoole\Server\Helper::onBeforeShutdown %s->onBeforeShutdown handler error \Swoole\Server\Helper::onManagerStart %s->onManagerStart handler error \Swoole\Server\Helper::onStart \Swoole\Server\Helper::onWorkerStop %s->onWorkerStop handler error \Swoole\Server\Helper::onWorkerStart %s->onWorkerStart handler error \Swoole\Server\Helper::onWorkerError %s->onWorkerError handler error UDP listener has to be added before executing sendto UDP6 listener has to be added before executing sendto UnixDgram listener has to be added before executing sendto server is running, unable to execute %s->set 'send_yield' option can only be set when using dispatch_mode=2/4 cpu_affinity_ignore num must be less than cpu num (%d) Unable to create upload_tmp_dir[%s] The length of document_root must be less than %d %s(): The length of document_root must be less than %d %s(): document_root[%s] does not exist http_index_files must be array http_compression_types must be array static_handler_locations num must be array cannot use msgqueue when task_enable_coroutine is enable vector::_M_range_check: __n (which is %zu) >= this->size() (which is %zu) %s(): unserialize() failed, Error at offset %ld of %zd bytes %s() (ERRNO %d): task[%ld] has expired %s() (ERRNO %d): Fatal error: %s in %s on line %d %s() (ERRNO %d): worker process is terminated by exit()/die() failed to create the server. Error: %s server open verify peer require client_cert_file config server dispatch mode should be FDMOD(%d) or IPMOD(%d) if open_http2_protocol is true use %s class and open http related protocols may lead to some errors (inconsistent class type) \Swoole\Server\Helper::onBeforeStart server is running, unable to execute %s->start() server have been shutdown, unable to execute %s->start() eventLoop has already been created, unable to start %s failed to start server. Error: %s server is running, unable to register event callback function taskCo method can only be used in the worker process task method can't be executed without task worker Server->task() cannot use in the task-worker taskWaitMulti method can only be used in the worker process taskwait failed, Error: %s[%d] taskwait method can only be used in the worker process worker_id must be less than task_worker_num[%u] large task pack failed Invalid instance of %s server is not running manager_pid %s->onDispatch handler error invalid target worker-id[%ld] l|lb websocket_status ssl_client_cert server_fd socket_fd socket_type remote_ip reactor_id connect_time last_recv_time last_send_time last_dispatch_time close_errno recv_queued_bytes send_queued_bytes ls|ll data is empty can't sendwait can't send messages to self worker_id[%d] is invalid start_time connection_num abort_count accept_count close_count task_worker_num user_worker_num total_recv_bytes total_send_bytes pipe_packet_msg_id session_round min_fd max_fd worker_request_count worker_response_count worker_dispatch_count worker_concurrency task_queue_num task_queue_bytes task_idle_worker_num tasking_num coroutine_num coroutine_peek_num getClientInfo Swoole\Server Swoole\Server\Task Swoole\Server\Event Swoole\Server\Packet server_socket Swoole\Server\PipeMessage source_worker_id Swoole\Server\StatusInfo worker_pid Swoole\Server\TaskResult task_id task_worker_id Swoole\Connection\Iterator onStart onBeforeShutdown onShutdown onWorkerStart onWorkerStop onBeforeReload onAfterReload onWorkerExit onWorkerError onTask onFinish onManagerStart onManagerStop onPipeMessage stats_timer admin_server SWOOLE_BASE SWOOLE_PROCESS SWOOLE_IPC_UNSOCK SWOOLE_IPC_MSGQUEUE SWOOLE_IPC_PREEMPTIVE SWOOLE_SERVER_COMMAND_MASTER SWOOLE_SERVER_COMMAND_MANAGER SWOOLE_SERVER_COMMAND_WORKER SWOOLE_DISPATCH_ROUND SWOOLE_DISPATCH_FDMOD SWOOLE_DISPATCH_IDLE_WORKER SWOOLE_DISPATCH_IPMOD SWOOLE_DISPATCH_UIDMOD SWOOLE_DISPATCH_USERFUNC SWOOLE_DISPATCH_STREAM SWOOLE_DISPATCH_CO_CONN_LB SWOOLE_DISPATCH_CO_REQ_LB SWOOLE_DISPATCH_CONCURRENT_LB SWOOLE_TASK_TMPFILE SWOOLE_TASK_SERIALIZE SWOOLE_TASK_NONBLOCK SWOOLE_TASK_CALLBACK SWOOLE_TASK_WAITALL SWOOLE_TASK_COROUTINE SWOOLE_TASK_PEEK SWOOLE_TASK_NOREPLY SWOOLE_WORKER_BUSY SWOOLE_WORKER_IDLE SWOOLE_WORKER_EXIT %s->onReceive handler error %s->onConnect handler error Server::add_worker() failed invalid $mode parameters %d SYSTEMD failed to add systemd socket %s->onClose handler error %s: command handler error %s->onShutdown handler error chroot group daemonize pid_file reactor_num single_thread max_queued_bytes worker_max_concurrency dispatch_mode send_yield dispatch_func discard_timeout_request enable_unsafe_event enable_delay_receive enable_reuse_port task_use_object task_object event_object task_enable_coroutine task_ipc_mode task_tmpdir task_max_request task_max_request_grace max_connection max_conn start_session_id heartbeat_check_interval heartbeat_idle_time reload_async open_cpu_affinity cpu_affinity_ignore malloc() failed http_parse_cookie http_parse_post http_parse_files http_compression_level http_gzip_level http_compression_min_length upload_tmp_dir upload_max_filesize enable_static_handler document_root http_autoindex http_index_files http_compression_types static_handler_locations input_buffer_size buffer_input_size output_buffer_size buffer_output_size message_queue_key %s->onTask handler error task[%ld] is invalid require onFinish callback %s->onFinish handler error open_redis_protocol open_http_protocol require onMessage callback require onRequest callback open_http2_protocol open_websocket_protocol require onPacket callback require onReceive callback fd can not be null invalid fd[%ld] getcallback beforeshutdown workerstart workerstop beforereload afterreload workerexit workererror managerstart managerstop pipemessage too many concurrent tasks failed to pack task taskCo z|dl unpack rewind next current offsetExists offsetGet offsetSet offsetUnset addlistener getCallback protect sendfile confirm pause resume taskwait taskWaitMulti getLastError heartbeat getClientList getWorkerId getWorkerPid getWorkerStatus getManagerPid getMasterPid connection_list sendMessage addCommand addProcess ignoreError start_fd find_count process_id process_type ifCloseConnection only_reload_taskworker 0.5 taskWorkerIndex finishCallback is_protected conn_fd send_data serverSocket workerId accepted_process_types dst_worker_id Swoole\Server\Port sock_type Closure event_name '0.0.0.0' SWOOLE_SOCK_TCP int php_swoole_server_onFinish(swoole::Server*, swoole::EventData*) std::vector<_Tp, _Alloc>::reference std::vector<_Tp, _Alloc>::front() [with _Tp = swoole::ListenPort*; _Alloc = std::allocator; std::vector<_Tp, _Alloc>::reference = swoole::ListenPort*&] bool swoole::Server::set_document_root(const string&) bool php_swoole_server_task_unpack(zval*, swoole::EventData*) void php_swoole_server_rshutdown() *Z28zim_swoole_server_addCommandEUlPN6swoole6ServerERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEE_ *Z27zim_swoole_server_heartbeatEUlPN6swoole10ConnectionEE_ *Z25zim_swoole_server_commandEUlPN6swoole6ServerERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEE_ *Z22zim_swoole_server_stopEUlPvE_ @ FvPN6swoole6ServerEPNS_6WorkerEE FvPN6swoole6ServerEPNS_6WorkerERKNS_10ExitStatusEE FiPN6swoole6ServerEPNS_9EventDataEE FvPN6swoole6ServerEPNS_9EventDataEE FvPN6swoole6ServerEPNS_8DataHeadEE FiPN6swoole6ServerEPNS_8RecvDataEE FvPN6swoole6ServerEE PFvPN6swoole6ServerEPNS_8DataHeadEE PFiPN6swoole6ServerEPNS_8RecvDataEE PFvPN6swoole6ServerEE PFvPN6swoole6ServerEPNS_6WorkerEE PFvPN6swoole6ServerEPNS_6WorkerERKNS_10ExitStatusEE PFiPN6swoole6ServerEPNS_9EventDataEE PFvPN6swoole6ServerEPNS_9EventDataEE ? _ C ?reactor wait failed, Error: %s[%d] swoole_event->onError[1]: getsockopt[sock=%d] failed, Error: %s[%d] swoole_event->onError[1]: socket error. Error: %s [%d] %s::end callback handler error %s::defer callback handler error async-io must be used in PHP CLI mode Unable to use async-io in task processes, please set `task_enable_coroutine` to true Unable to use async-io in manager process Unable to create event-loop reactor Unable to call Event::wait() in coroutine Event::wait() in shutdown function is deprecated fd argument must be either valid PHP stream or valid PHP socket resource invalid file descriptor#%d passed invalid file descriptor passed %s: writable callback handler error, fd [%d] will be removed from reactor %s: readable callback handler error, fd [%d] will be removed from reactor socket[%d] is not found in the reactor reactor is not ready, cannot call swoole_event_set %s: unable to find readable callback of fd [%d] %s: unable to find writable callback of fd [%d] reactor is not ready, cannot call swoole_event_del SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE Swoole\Event isset dispatch cycle Swoole\Event::rshutdown fn data empty unknown type readable_callback writable_callback %s::set failed invalid socket fd [%d] already exist invalid events swoole_event_add failed read_callback write_callback @ swoole_event_addswoole_event_delswoole_event_setswoole_event_waiswoole_event_issswoole_event_disswoole_event_defswoole_event_cycswoole_event_wriswoole_event_exibig5 mysql_native_password caching_sha2_password %s(): Unknown auth plugin: %s big5_chinese_ci dec8 dec8_swedish_ci cp850 cp850_general_ci hp8 hp8_english_ci koi8r koi8r_general_ci latin1 latin1_swedish_ci latin1_german1_ci latin2 latin2_general_ci latin2_czech_cs swe7 swe7_swedish_ci ascii ascii_general_ci ujis ujis_japanese_ci sjis sjis_japanese_ci hebrew hebrew_general_ci tis620 tis620_thai_ci euckr euckr_korean_ci latin2_hungarian_ci latin2_croatian_ci koi8u koi8u_general_ci gb2312 gb2312_chinese_ci greek greek_general_ci cp1250 cp1250_general_ci gbk gbk_chinese_ci latin5 latin5_turkish_ci latin1_german2_ci latin1_danish_ci armscii8 armscii8_general_ci utf8 utf8_general_ci ucs2 ucs2_general_ci cp866 cp866_general_ci keybcs2 keybcs2_general_ci macce macce_general_ci macroman macroman_general_ci cp852 cp852_general_ci latin7 latin7_general_ci latin7_estonian_cs cp1256 cp1256_general_ci cp1257 cp1257_general_ci eucjpms eucjpms_japanese_ci cp1257_lithuanian_ci cp1250_czech_cs latin7_general_cs macce_bin cp1250_croatian_ci utf8mb4 utf8mb4_general_ci utf8mb4_bin latin1_bin latin1_general_ci latin1_general_cs cp1251 cp1251_general_ci cp1251_bulgarian_ci cp1251_ukrainian_ci cp1251_bin cp1251_general_cs macroman_bin utf16 utf16_general_ci utf16_bin utf16le utf16le_general_ci cp1257_bin utf32 utf32_general_ci utf32_bin utf16le_bin armscii8_bin ascii_bin cp1250_bin cp1256_bin cp866_bin dec8_bin greek_bin hebrew_bin hp8_bin keybcs2_bin koi8r_bin koi8u_bin latin2_bin latin5_bin latin7_bin cp850_bin cp852_bin swe7_bin utf8_bin big5_bin euckr_bin gb2312_bin gbk_bin sjis_bin tis620_bin ucs2_bin ujis_bin geostd8 geostd8_general_ci geostd8_bin latin1_spanish_ci cp932 cp932_japanese_ci cp932_bin eucjpms_bin cp1250_polish_ci ucs2_unicode_ci ucs2_icelandic_ci ucs2_latvian_ci ucs2_romanian_ci ucs2_slovenian_ci ucs2_polish_ci ucs2_estonian_ci ucs2_spanish_ci ucs2_swedish_ci ucs2_turkish_ci ucs2_czech_ci ucs2_danish_ci ucs2_lithuanian_ci ucs2_slovak_ci ucs2_spanish2_ci ucs2_roman_ci ucs2_persian_ci ucs2_esperanto_ci ucs2_hungarian_ci ucs2_sinhala_ci ucs2_german2_ci ucs2_croatian_ci ucs2_unicode_520_ci ucs2_vietnamese_ci utf32_unicode_ci utf32_icelandic_ci utf32_latvian_ci utf32_romanian_ci utf32_slovenian_ci utf32_polish_ci utf32_estonian_ci utf32_spanish_ci utf32_swedish_ci utf32_turkish_ci utf32_czech_ci utf32_danish_ci utf32_lithuanian_ci utf32_slovak_ci utf32_spanish2_ci utf32_roman_ci utf32_persian_ci utf32_esperanto_ci utf32_hungarian_ci utf32_sinhala_ci utf32_german2_ci utf32_croatian_ci utf32_unicode_520_ci utf32_vietnamese_ci utf8_unicode_ci utf8_icelandic_ci utf8_latvian_ci utf8_romanian_ci utf8_slovenian_ci utf8_polish_ci utf8_estonian_ci utf8_spanish_ci utf8_swedish_ci utf8_turkish_ci utf8_czech_ci utf8_danish_ci utf8_lithuanian_ci utf8_slovak_ci utf8_spanish2_ci utf8_roman_ci utf8_persian_ci utf8_esperanto_ci utf8_hungarian_ci utf8_sinhala_ci utf8_german2_ci utf8_croatian_ci utf8_unicode_520_ci utf8_vietnamese_ci utf8mb4_unicode_ci utf8mb4_icelandic_ci utf8mb4_latvian_ci utf8mb4_romanian_ci utf8mb4_slovenian_ci utf8mb4_polish_ci utf8mb4_estonian_ci utf8mb4_spanish_ci utf8mb4_swedish_ci utf8mb4_turkish_ci utf8mb4_czech_ci utf8mb4_danish_ci utf8mb4_lithuanian_ci utf8mb4_slovak_ci utf8mb4_spanish2_ci utf8mb4_roman_ci utf8mb4_persian_ci utf8mb4_esperanto_ci utf8mb4_hungarian_ci utf8mb4_sinhala_ci utf8mb4_german2_ci utf8mb4_croatian_ci utf8mb4_unicode_520_ci utf8mb4_vietnamese_ci gb18030 gb18030_chinese_ci gb18030_bin utf8_general_cs %s(): BIO_new_mem_buf publicKey error! %s(): [PEM_read_bio_RSA_PUBKEY ERROR]: %s %s(): [RSA_public_encrypt ERROR]: %s swoole::mysql::auth_signature_response_packet::auth_signature_response_packet(swoole::mysql::raw_data_packet*, const string&, const char*) uint32_t swoole::mysql::mysql_auth_encrypt_dispatch(char*, std::__cxx11::string, const char*, const char*) Timer must be greater than or equal to 1 exec_msec exec_count %s->onTimeout handler error add timer failed initialized Swoole\Timer Swoole\Timer\Iterator tick clear clearAll SWOOLE_TIMER_MIN_MS SWOOLE_TIMER_MIN_SEC SWOOLE_TIMER_MAX_MS SWOOLE_TIMER_MAX_SEC timer_id FvPN6swoole5TimerEPNS_9TimerNodeEE FvPN6swoole9TimerNodeEE PFvPN6swoole5TimerEPNS_9TimerNodeEE PFvPN6swoole9TimerNodeEE swoole_timer_setswoole_timer_aftswoole_timer_ticswoole_timer_infswoole_timer_lisswoole_timer_exiswoole_timer_staswoole_timer_cleobject_num resource_num get_all_sockets get_all_commands get_socket_info get_thread_info get_manager_info get_memory_info get_all_unix_sockets get_all_ports get_connections get_connection_info cannot use push_back() with workers session_list thread_global_memory socket_list socket_out_buffer php_memory reload_count reload_last_time event_num timer_num No event loop created fd_type out_buffer_size require parameter session_id connection not exists require parameter type require parameter fd ca_state retransmits probes backoff snd_wscale rcv_wscale rto ato snd_mss rcv_mss unacked sacked lost fackets last_data_sent last_ack_sent last_data_recv last_ack_recv pmtu rcv_ssthresh rttvar snd_ssthresh snd_cwnd advmss reordering rcv_rtt rcv_space total_retrans basic_string::_M_replace_aux x܂@PtXbasic_string::_M_replace unknown token '[', '{', or a literal end of input ',' ':' '}' ']' '{' '[' number literal string literal null literal false literal true literal syntax error while parsing - ; last read: ' unexpected ; expected 0 P`Ў0 @L ,size(), true) %lu at line , column parse_error parse error __pos <= size() \u%04x\u%04x %.2X invalid UTF-8 byte at index : 0x !empty() \ufffd � /usr/include/c++/8/bits/basic_string.h incomplete UTF-8 string; last byte: 0x vector::_M_insert_aux vector::reserve boolean number iterator out of range __position != end() cannot use erase() with iterator does not fit current value /usr/include/c++/8/bits/stl_tree.h cannot use operator[] with a string argument with 4type must be string, but is h{} {
": ,
": [
G |<$vector::_M_realloc_insert invalid string: ill-formed UTF-8 byte invalid number; expected digit after '-' invalid number; expected digit after '.' invalid number; expected '+', '-', or digit after exponent invalid number; expected digit after exponent sign invalid string: control character U+000A (LF) must be escaped to \u000A or \n invalid string: missing closing quote invalid string: '\u' must be followed by 4 hex digits invalid string: surrogate U+DC00..U+DFFF must be followed by U+DC00..U+DFFF invalid string: surrogate U+DC00..U+DFFF must follow U+D800..U+DBFF invalid string: forbidden character after backslash invalid string: control character U+0000 (NUL) must be escaped to \u0000 invalid string: control character U+0001 (SOH) must be escaped to \u0001 invalid string: control character U+0002 (STX) must be escaped to \u0002 invalid string: control character U+0003 (ETX) must be escaped to \u0003 invalid string: control character U+0004 (EOT) must be escaped to \u0004 invalid string: control character U+0005 (ENQ) must be escaped to \u0005 invalid string: control character U+0006 (ACK) must be escaped to \u0006 invalid string: control character U+0007 (BEL) must be escaped to \u0007 invalid string: control character U+0008 (BS) must be escaped to \u0008 or \b invalid string: control character U+0009 (HT) must be escaped to \u0009 or \t invalid string: control character U+000B (VT) must be escaped to \u000B invalid string: control character U+000C (FF) must be escaped to \u000C or \f invalid string: control character U+000D (CR) must be escaped to \u000D or \r invalid string: control character U+000E (SO) must be escaped to \u000E invalid string: control character U+000F (SI) must be escaped to \u000F invalid string: control character U+0010 (DLE) must be escaped to \u0010 invalid string: control character U+0011 (DC1) must be escaped to \u0011 invalid string: control character U+0012 (DC2) must be escaped to \u0012 invalid string: control character U+0013 (DC3) must be escaped to \u0013 invalid string: control character U+0014 (DC4) must be escaped to \u0014 invalid string: control character U+0015 (NAK) must be escaped to \u0015 invalid string: control character U+0016 (SYN) must be escaped to \u0016 invalid string: control character U+0017 (ETB) must be escaped to \u0017 invalid string: control character U+0018 (CAN) must be escaped to \u0018 invalid string: control character U+0019 (EM) must be escaped to \u0019 invalid string: control character U+001A (SUB) must be escaped to \u001A invalid string: control character U+001B (ESC) must be escaped to \u001B invalid string: control character U+001C (FS) must be escaped to \u001C invalid string: control character U+001D (GS) must be escaped to \u001D invalid string: control character U+001E (RS) must be escaped to \u001E invalid string: control character U+001F (US) must be escaped to \u001F )pX@(pXH0 pX@(xPPPPPPPPPPPPPPPPPPPPPPPPPPPPPP800000000000000{einvalid BOM; must be 0xEF 0xBB 0xBF if given invalid literal 9F&%/\<<Lcannot get value cannot create object from initializer list )))bV std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::const_reference std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::back() const [with _CharT = char; _Traits = std::char_traits; _Alloc = std::allocator; std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::const_reference = const char&] std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::const_reference std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::operator[](std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::size_type) const [with _CharT = char; _Traits = std::char_traits; _Alloc = std::allocator; std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::const_reference = const char&; std::__cxx11::basic_string<_CharT, _Traits, _Alloc>::size_type = long unsigned int] std::vector<_Tp, _Alloc>::reference std::vector<_Tp, _Alloc>::operator[](std::vector<_Tp, _Alloc>::size_type) [with _Tp = nlohmann::basic_json<>; _Alloc = std::allocator >; std::vector<_Tp, _Alloc>::reference = nlohmann::basic_json<>&; std::vector<_Tp, _Alloc>::size_type = long unsigned int] std::_Rb_tree<_Key, _Val, _KeyOfValue, _Compare, _Alloc>::iterator std::_Rb_tree<_Key, _Val, _KeyOfValue, _Compare, _Alloc>::erase(std::_Rb_tree<_Key, _Val, _KeyOfValue, _Compare, _Alloc>::iterator) [with _Key = std::__cxx11::basic_string; _Val = std::pair, nlohmann::basic_json<> >; _KeyOfValue = std::_Select1st, nlohmann::basic_json<> > >; _Compare = std::less >; _Alloc = std::allocator, nlohmann::basic_json<> > >; std::_Rb_tree<_Key, _Val, _KeyOfValue, _Compare, _Alloc>::iterator = std::_Rb_tree_iterator, nlohmann::basic_json<> > >] void std::vector<_Tp, _Alloc>::pop_back() [with _Tp = nlohmann::basic_json<>; _Alloc = std::allocator >] void std::vector<_Tp, _Alloc>::pop_back() [with _Tp = nlohmann::basic_json<>*; _Alloc = std::allocator*>] std::vector<_Tp, _Alloc>::reference std::vector<_Tp, _Alloc>::back() [with _Tp = nlohmann::basic_json<>*; _Alloc = std::allocator*>; std::vector<_Tp, _Alloc>::reference = nlohmann::basic_json<>*&] std::vector<_Tp, _Alloc>::reference std::vector<_Tp, _Alloc>::back() [with _Tp = nlohmann::basic_json<>; _Alloc = std::allocator >; std::vector<_Tp, _Alloc>::reference = nlohmann::basic_json<>&] void std::vector<_Tp, _Alloc>::pop_back() [with _Tp = char; _Alloc = std::allocator] *ZN6swooleL22handle_get_all_socketsEPNS_6ServerERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEUliPNS_7network6SocketEE_ *ZN6swooleL22handle_get_connectionsEPNS_6ServerERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEUlPNS_10ConnectionEE_ *ZL18object_store_countvEUlP12_zend_objectE_ *Z22zif_swoole_get_objectsEUlP12_zend_objectE_ thread::id of a non-executing thread failed to getsockopt(TCP_INFO) for socket L
@
4
(
X
X
X
object key object separator number overflow parsing ' Xx
l0+,/4//,T--$.l0l0l0l0l* FNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEPN6swoole6ServerERKS4_E St19_Sp_make_shared_tag N6swoole10MemoryPoolE N8nlohmann6detail9exceptionE N8nlohmann6detail11parse_errorE N8nlohmann6detail16invalid_iteratorE N8nlohmann6detail10type_errorE N8nlohmann6detail12out_of_rangeE N8nlohmann6detail11other_errorE N8nlohmann6detail22input_adapter_protocolE N8nlohmann6detail20input_buffer_adapterE N8nlohmann6detail23output_adapter_protocolIcEE N8nlohmann6detail21output_string_adapterIcNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEE PFNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEPN6swoole6ServerERKS4_E St23_Sp_counted_ptr_inplaceIN8nlohmann6detail21output_string_adapterIcNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEESaIS9_ELN9__gnu_cxx12_Lock_policyE2EE St23_Sp_counted_ptr_inplaceIN8nlohmann6detail20input_buffer_adapterESaIS2_ELN9__gnu_cxx12_Lock_policyE2EE
00010203040506070809101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 00010203040506070809101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 ƚpOܼw kAV< Ѝ,U1(\QFɦqaˋ#w"{mSx@I̮ Wζ]y<7VM6 OH8oꖐ$:%˅t ,φ4*
45<5*g8PD;?ȄkL'DŅT%Οk\b}$lۺd_
Xfl&ޓt
|J|l_b%S04`?U&NZ~)p$wt帟ߦ}t_ϛpDk11eU%{?;+*\.Ӓsi$$I cd~̈Po ̼,eXѳ @ bx x9? {Η8 $ p\{2~S , h髤8m 4 E"&'O < '1c D Ȍ8eް L eǃ T qB ] \ X,iM
d pd' l JwmB t k}{x \ | wyTw ś[[ =]S5Ȭ \* _F %94 \r ξTSܷ1 A"L x\ӛ f S!{Z :0 ܵ \S٨ ::_SafeConv<_Yp> std::__shared_ptr<_Tp, _Lp>::reset(_Yp*) [with _Yp = swoole::SSLContext; _Tp = swoole::SSLContext; __gnu_cxx::_Lock_policy _Lp = (__gnu_cxx::_Lock_policy)2; std::__shared_ptr<_Tp, _Lp>::_SafeConv<_Yp> = void] *ZN6swoole11MysqlClient7connectENSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEtbEUlPNS_9coroutine6SocketEE_ $@ Co\MySQL\StatemeCo\MySQL\Exceptiyou must call Channel constructor first %s() (ERRNO %d): channel is destroyed, %zu producers will be discarded %s() (ERRNO %d): channel is destroyed, %zu consumers will be discarded consumer_num producer_num Swoole\Coroutine\Channel Co\Channel Chan SWOOLE_CHANNEL_OK SWOOLE_CHANNEL_TIMEOUT SWOOLE_CHANNEL_CLOSED SWOOLE_CHANNEL_CANCELED isEmpty isFull std::queue<_Tp, _Sequence>::reference std::queue<_Tp, _Sequence>::front() [with _Tp = void*; _Sequence = std::deque >; std::queue<_Tp, _Sequence>::reference = void*&] swoole::coroutine::Channel::~Chayou must call Lock constructor first FileLock and SemLock is no longer supported, please use mutex lock only mutex supports lockwait wrong lock type Swoole\Lock SWOOLE_FILELOCK SWOOLE_MUTEX SWOOLE_SEM SWOOLE_RWLOCK SWOOLE_SPINLOCK trylock trylock_read destroy N6swoole4LockE @ please use the Swoole\Server->listen method can't register event callback function after server started please use the swoole_server->listen method kernel_socket_recv_buffer_size kernel_socket_send_buffer_size unknown package_length_type, see pack(). Link: http://php.net/pack 'package_length_offset' value is too large 'package_body_offset' value is too large 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 \Swoole\Server\Helper::checkOptions length function handler error onConnect onReceive onClose onPacket onBufferFull onBufferEmpty onRequest onHandshake onOpen onMessage onDisconnect onBeforeHandshakeResponse unknown event types[%s] buffer_high_watermark buffer_low_watermark tcp_defer_accept open_tcp_keepalive websocket_subprotocol open_websocket_close_frame open_websocket_ping_frame open_websocket_pong_frame tcp_keepidle tcp_keepinterval tcp_keepcount tcp_user_timeout tcp_fastopen package_body_start ssl_client_cert_file ssl_prefer_server_ciphers ssl_dhparam ssl_sni_certs invalid SNI_cert setting ssl_add_sni_cert() failed ssl_init() failed bufferfull bufferempty handshake beforehandshakeresponse disconnect the second parameter should be an array %s(): connection[%d] is closed command [%.8s...](length=%d) is too long %s->onRequest with command '%.*s' handler error _handler_%s l|z +%.*s
+%s
-%.*s
-%s
:%ld
require more parameters invalid string size *%d
$%d
%s
$%zu
Unknown type[%ld] Swoole\Redis\Server NIL STATUS MAP _handler_%.*s -ERR unknown command '%.*s'
setHandler getHandler int php_swoole_redis_server_onReceive(swoole::Server*, swoole::RecvData*) aio_core_worker_num aio_max_wait_time aio_max_idle_time enable_signalfd wait_signal dns_cache_refresh_time min_thread_num max_thread_num socket_dontwait dns_lookup_random use_async_resolver invalid domain name domain name empty eventLoop has already been created. unable to change settings getifaddrs() failed, Error: %s[%d] enabled with boost asm context can not call this function in user level new socket 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);
function swoole_exec(string $command, &$output = null, &$returnVar = null)
{
$result = Swoole\Coroutine::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 = Swoole\Coroutine::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';
public const OPTION_SOCKET_DNS_TIMEOUT = 'socket_dns_timeout';
public const OPTION_SOCKET_CONNECT_TIMEOUT = 'socket_connect_timeout';
public const OPTION_SOCKET_WRITE_TIMEOUT = 'socket_write_timeout';
public const OPTION_SOCKET_SEND_TIMEOUT = 'socket_send_timeout';
public const OPTION_SOCKET_READ_TIMEOUT = 'socket_read_timeout';
public const OPTION_SOCKET_RECV_TIMEOUT = 'socket_recv_timeout';
public const OPTION_SOCKET_BUFFER_SIZE = 'socket_buffer_size';
public const OPTION_SOCKET_TIMEOUT = 'socket_timeout';
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';
public const OPTION_ENABLE_SIGNALFD = 'enable_signalfd';
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';
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_HOST = 'host';
public const OPTION_PORT = 'port';
public const OPTION_SSL = 'ssl';
public const OPTION_USER = 'user';
public const OPTION_PASSWORD = 'password';
public const OPTION_DATABASE = 'database';
public const OPTION_CHARSET = 'charset';
public const OPTION_STRICT_TYPE = 'strict_type';
public const OPTION_FETCH_MODE = 'fetch_mode';
public const OPTION_ENABLE_MESSAGE_BUS = 'enable_message_bus';
public const OPTION_MAX_PACKAGE_SIZE = 'max_package_size';
public const OPTION_SERIALIZE = 'serialize';
public const OPTION_RECONNECT = 'reconnect';
public const OPTION_COMPATIBILITY_MODE = 'compatibility_mode';
public const OPTION_CHROOT = 'chroot';
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';
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';
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 array_key_exists($this->key(), $this->array);
}
/**
* @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) {
throw new \RuntimeException('natcasesort() failed');
}
return $this;
}
/**
* @return $this
*/
public function natsort(): self
{
if (natsort($this->array) !== true) {
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) {
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) {
/** @var Socket $conn */
$conn = null;
$conn = $socket->accept();
if ($conn) {
$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;
}
}
@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();
}
/**
* @throws Exception
*/
public static function wait(Barrier &$barrier, float $timeout = -1)
{
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',
'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',
'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',
'Reason: Server is in script upgrade mode. Only administrator can connect at this time.',
'Unknown $curl_error_code: 77',
'SQLSTATE[08006] [7] SSL error: sslv3 alert unexpected message',
'SQLSTATE[08006] [7] unrecognized SSL error code:',
'SQLSTATE[HY000] [2002] No connection could be made because the target machine actively refused it',
'Broken pipe',
// 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()
* @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;
use Swoole\Constant;
use Swoole\Coroutine\Http\Client;
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:
/*
* From PHP 5.1.3, this option has no effect: the raw output will always be returned when CURLOPT_RETURNTRANSFER is used.
*/
case CURLOPT_BINARYTRANSFER: /* TODO */
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:
$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 = Swoole\Coroutine::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) {
$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 ($this->cookieJar && $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