11"oHD$H 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 @ AwH7, 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
y @84 D$ [D$D$H
H @84? D$ 'D$D$H H @84# D$
B< .IGHH40HHpIGAG D$ AG D$ AG D$ pAG D$ VAG D$ HE15 H\$+ HD$ D$ HSH\$D$ H @ 1[]A\A]A^ LL
1H w[]A\A]A^ @ H LL1w LcM9sD A
^ A
, Et+LK|5 1L)L H?7LcM9M.TH LLKH L)K|5 DH@ HL Q H16XZ[]A\A]A^ H/ LL1v *f. H LL1 vfH H LL1|v2 fH LL1\v fLK|5 1
L)H Lc1v @ LK|5 1
L)H Lc v @ HL Qff. @ H, AWHBAVIAUIATL%R UHS1H(HD$HD$ HD$ }0E| E0IcL>fHE E0H@(HtHЃt)l A-# A
E0HI9wH(H[]A\A]A^A_f. HE E0 H@ HtHЃtɅ H\$HCHD$A
U H9\$ H\$ E0H\$A
] A- A: D a< L{H9\$ L@A 1E0H\$A
L{H9\$uHE H@HtHL$LHH)It
Ѓ 4 L D A-| HE E0H@0HHЃ f D A
< HE E0H@HtHЃuHC f D HED8|2! H9\$ UHHEH9,HU E0LRMHHHHD$H)It A҃N A
H9\$P E0
HHE f D A
B E0Hf A
" E0
Hf HEUH9a HRH9u6A
HE 1} HE E0 T2D8
HHHEHE E0 H@HHL$HHH)It
Ѓnu(L{H9\$ D D H]E1HH([]A\A]A^A_ L{H9\$@HE H H0H|$LH)It= HЃnLf D H9\$% HCH\$E0 H/E0 o E0H 1A
HHHU E0H HE H@H5HL$HT$HH)It
Ѓ
fHE H HBH|$ H(1[]A\A]A^A_HPH;T$sHU LRM HD$HT$HH)It A҃ xHEH|$vHE H@HHL$HT$HH)It
Ѓ )f. HE E0H HHL$HHH)It
Ѓ*ƅ
HD H]E11ƅ
HD H]E1ƅ -HD H]E1D HH]E1k HD H]E1Jƅ
HD H]E1(D HH]E1
HD$HD$H+EHHE H@HHL$HT$HH)It
ЃtHD$ U@ SH HH, PHt<1҅ HPHS Ht"HR
w HsHcKHR8HH[]H
n H5 H=+ /f D H
, S@ H PHt1HS Ht"HR
w HsHcKHR8H[H
H5q H= }/ff. f UH@ SH HHw, 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=S HcH>fKLIH Hc H H' 0 @ H?B k H n Hi HHHFH H wBDD$ GHHC Dt$L1L,$,KJ K: DAA vI fHK
A$/c IT$A$L2LHHHLH@) A$/3 IT$HA $H42/) HA$HHH`H(Jf. H5
H|, @ FD D F F
HD$ Dt$H$D$H<$ t<|$Gt%H<$HH,Lw D H} HcRL9uHD$H<$P HJRHD$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}hHT$ HBD4P Hf A$Ah+ Al D$ IEIMuHHtDBuIHHcl$D|$ PH$IAHD$ H ! Hc H H' HKY8m4 1 @ H?B H H DHHDaHH H wCf D DAIcH 1HH
J Hu E,VЃ< IcL>f D VIcH".H} WЃ< H56 HcH>f GAHOIcEe
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Ȼ |L$G랃H
b h H5 H=X 1g F 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-vHs 8H[]
U S ttH
G H5 H= ff. @ H=, H USHH H AH GH-~x, 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[f UHo SHHG H s# tDC t<1fD1 @ H{HC HD HH) (1HH HtHH Ht
Hǃ H H 3@H F3H H H H tntIH H߽SH Ht t ubH[]f H H HMf D H HH L #f H0HPHZH[] C D H H߽RJff. t Yf D f H Hff. @ H H ff. f U H SHH*u, PHV HH,, H1H H ǃ H H Eu t
t
Hu@H HHE0HuHH HE8H ukHuH1u[E ~ E HEHt9 t0 t'H0HPHXfH HPHH[]fGH53 @ H` 1HH[] @ HMU(HHu LEi!f @ HUHuHJMff. HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(+LHT$XdH3%( uHh, HxfHL$H$dH%( HD$h1)D$0HH|$0H|$)D$)D$ )D$@)D$Pt$8HD$KHL$hdH3 %( uHx-,ff. f HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(D$ CKHT$XdH3%( uHh+f HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(HT$D$ JHL$XdH3 %( uHhD+ @ HhfdH%( HD$X1)D$ H|$ H)$)D$)D$0)D$@t$(HT$D$ ^JHL$XdH3 %( uHh* @ HhHdH%( HD$X1H|$ HL$HD$ HD$H HH)LHH$ HT$IHt$XdH34%( uHh[*ff. HxIHT$H|$ HL$H4$HH)LdH%( HD$h1HD$ HD$X HHH|$LD$(D$ HD$QIHT$hdH3%( uHx) HhfdH%( HD$X1D$H H|$HD$D$(D$8HD$H H$HHT$XdH3%( uHhR)f HhdH%( HD$X1H|$ HL$HD$ HD$H HH)LHH$ T$gHHt$XdH34%( uHh(ff. f ATUSL$ H H $ L9uHodH%( H$@ 1uqHIH @ LPxYu'H$@ dH3 %( uIH@ []A\f D H HcLtH Hߋ0HPK D ( @ ATUSDgE H HHQЃ<w1H5 HcH> D s7 +H HtUfHtqH r< H
x HcH> OH9tHHYyH HJf 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 h#t1H[H H߉D$ 1HQID$ ff. UHSHHHHQtH3HtH 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-Eu뱐HHtH|$HuHYu 1t_$ff. @ SHH Ht H 1[HHT xG[Ð H[H @ UHSHdH%( HD$1HK[ÃtgtIH4$HHc`[H<$Hj, u P HL$dH3 %( uCH[] P H HFH HFB#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. UHSHdH%( HD$1H ÃtHH4$HHcYH<$Åu#1HL$dH3 %( u.H[] D 1H7 HXE! U1SHHdH%( HD$1 -u tHHuH,$HL$dH3 %( HuH[]!ff. f H HT$0HL$8LD$@LL$Ht7)D$P)L$`)T$p)$ )$ )$ )$ )$ dH%( HD$1H$ H$ HD$HD$ D$0 HD$h HL$dH3 %( uH ff. U1SHHdH%( HD$1 7u tHHuH,$H|$dH3<%( HuH[]] f. Hf, oHLLJoNLBHzHJ LJHv LHHr L@HxHH Hmf, Hl, HH i, HPH!n, HPH&o, HPHk, HP f. @ AUIATUHSH dH%( H$ 1HR HD 1HMtm MHL HcH)HD&Hھ HBH$ dH3%( u HĘ []A\A] D H Ht u SHUǃ [Ð UH1SH 6RHHtHtJHH[]f D S tu1HH[] t1Ҿ HAH HHA뙐 USHHH VЃ< H
HcH> V 1`FHHxHHH[]f D HVfVf. Vf. [ tuHH[] D t1Ҿ HH@t1X D AVA AUA ATIUSH dH%( HD$1Hl$D$ H I A H ߾ Dl$H DVUUUA H A ߾ D)DЉT$ HxRA H ߾ D$ Hx,E1HL$dH3 %( Du[H[]A\A]A^f A8 LHn?A8} LHM?f D SHA H dH%( HD$1HL$D$ Gt1HT$dH3%( u'H [H5ۡ H߉D$ HT D$ Yf SHH H /tK jt/~ Pw 1[f D t[ @ 1[f D [ ATUHSH dH%( HD$1D$ t HL$LD$ IċD$ tHD$u+\$uHT$dH3%( uAH []A\Éf D A$1H}H5 HD$ hD$ ff. AT IUSHH0dH%( HD$(1 fL$$D$ 8sukH|$ D HD$ tftBHt$ H uT$ u
HaHHL$(dH3 %( uMH0[]A\ E n 1HH7H5ɟ H߉D$ }HD$ f. SffHH*H*ƾ H ^^Xf(L$LL$t! f( Lt1H[H5) Hf H H9tPUHSHHHto 1H[] H^, H Huϸ 1ff. fAWIAVAUMATIUSHH( dH%( H$ 1 LJ H D$ HD$@ H9t#L5 ^, AV HAVI$ Hl M LL(O I$ H HBH=@B H2HS㥛 H9 H I$ HS㥛 HHi HHH?HH)¸H 2HHFHD$(M L9tL5N], AV LAVI$ A 1L$ Hl$@LLK fHLI$ HT$P)D$PH HT$)D$`)D$pHD$TJ H\$@H HD$HD|$ E1HD$HD$f D 8suAtHHtf {f D HL%U, D H H21H߉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 ) D#HHǃ Hǃ Hǃ ǃ 3 HKHHGs%uYtJU St?tft1 @ HU H{ HHSHtHtH)HH)HD []A\ÐU Sttff. HvJUHSH^H x
t(HHH)HH)Hھ
Hb HHuHH[]1Hf. Lc E UASI SHcHI)HHLD
v H
) H5 H=V AHsHRMcHLRLM9u HI9uH[]f D I9}%A I@AHH[]H
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 Ha HlH$h dH3<%( Hx []A\A]A^A_f D E LcLl$ F LLL1BD< H5 L 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( fT
f.HH H&f~5u1 D HHuA<$-tA<WЀ HPH9uH H L M HcLLAf. L f T$ A4$H= L$ H H HtgH@(Ht^1L@T@o L gf Tf D h 4f D H H<
H HH HH HlH HPH( H߉D$ D$ /Q H ATUHSH HtH Ht H@0HtH Ht] ~kL%tL, 1f. H D HH H[] D HfHf. HHf. <hGDGD)H D GDGD)H D G+G D hH 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% E, HcHAT$HtaA I 9 f D A 9xHcҾ0 L,AT$Ic IE I HH< uH_ L`S I HHHB HBBHI H@ HHP(1Adž I M I?Idž D$ D I H5/0 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ߺ L= Hھ L{ A D H~
y:HI LL? @" @\ @
tK!HALd$(H L DP@u DL L1 D$("\r"Ld$(D$, AA I AAHAD$H Ll_D$("\t"Ld$(D$, Ld$(ALA CD$("\b"Ld$(D$, eD$("\n"Ld$(D$, NH2 LH LH
ń H5 H= Hʂ L_1 AVAUIATUHSH H H : H9HۃH H9EAAHl?, Lt+LH HM A ~YA A HkHkCHtMtHLH+ H[]A\A]A^Ð A uAub@k@kC @ HH AAHc B D 1LHAVfkfkCf CPf kkC8 A 1 w Hw @@ w w 1 Ht7G<~ Hm=, ` fHV HcH)HP=, ` D ff. @ SHSwH
$ HHcH>HC[f. C[ C[ÈC[ fC[f G<w!H HcH> D HG @ G D G G 1 fGf D AWAVAUATUHSHWЃ< v8< < LHGHL)H9w4HH[]A\A]A^A_ < OGI)HHH9vLHl$H
ʃ HcHH)HL$H6L H LFI A A I| D8 Hw;, H HIWHHbHS;, 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
Q HcH> AAEL D D{Dk fD{fDkf 1f A A f. L{HjD}D}D}L}xf AWAVAUIATUSH_ރ@ Hq~ @HcH> _L{M@H MHcI)H H H H9 H{ A D8 H8, H HLLHH8, LP DeA A A H]H]HH[]A\A]A^A_ H_ L{@ H{ME1 S _ _ A& ]؈Etf H7, HLPHH E<% v<# <.%f D < @ @HG I1HcA E1 I)u H{ A ^ @ H{ E1I 1f H{
A @ H{ A @ f]fE\ E]؉E> I1E1 A @ @ WЃ<wyH
{ HcH> GHH1H
~ HcH D HGHHf D HHfGHHf D GHH륹 ff. @ WHH
} HcH)ff. WЃ<# H
z 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
F| N H5J| H=| f D HcH9 HcHHwHf D 9FH
{ H H5{ H=w| f. 9lH
{ T H5{ H=| e D t 9rHWHH
p{ A H5t{ H={ H
Q{ Z H5U{ H=| AUATIUSHHo< Hx HcH> oI9 MHI)LcHHtoIUH<(1C<wUH:x HcH> D Hof@@f D of. oz DcHH[]A\A]f D fDcDcf. Lcf. ADc1"ff. @ AUIATUHSHDgD< Hvw HcH> D DgHDHHtxHJ< LLC<wWH@w HcH> LgfDgf Dgf AEf D k D + HH[]A\A]f D C @ Hkf. fkf. @kE1&f UHHSHH8HHH[H] @ VЃ<wXH
dv HcH> VHV D V Vw1 UHSHHWЃ</ H
u HcH> GH9 GHH) {HH HHHH @<~ Hu HcH> H;_vRHH+w롐GH9v?GHH) GH9v'GHH)pHH)H9[ HaYHH[] HȈYH[]HYHH[]ffYHH[]fYHH[] HHf UHHSHH8HHH[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$1HHyHHc~HT$dH3%( uH [ AWAVAUIATIUSHH H|$HdH%( H$8 1uH H L5,, HAIHD$0H$MtiHl$Mt IM A Ao$HLID$HE HEHA> trL5,, L;<$tLAV HHAIHu1H$8 dH3 %( ubHH []A\A]A^A_f D HD$0 H$ITf. H|$Lc L;<$tH+, H$LR H$q H HT$0HL$8LD$@LL$Ht7)D$P)L$`)T$p)$ )$ )$ )$ )$ dH%( HD$1H$ H$ HD$HD$ D$0 HD$HL$dH3 %( uH ff. AWIAVIAUATUSH HT$`HL$hLD$pLL$xdH%( HD$H1H$ D$ HD$ HD$PHD$(G[ H
p HcH>DgA> . < <B < IGI+GH AI^<% AvN,h H HH! H H!: H H' D$/ HT$(D$H*@s DmD<_ Ho HcH>DgDgDgAAEDm AG<M < <uIOI+Of D I9vLLIH IcLHL#AWDЃ<w"H5;o 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=m HcH>f D HLAGÀ{ I D McLC HfAGLAIif HAGLAIJf. HAL IAW!HIGLAI
f. McAL$IC4AWЃ<a H5m HcH>f. AGA fAGAfAGA A̍ AWzf. IGAc AGA+G D$@uB /Y HT$(D$H2Hl$0H+$LcAG<] <g < IGI+G I9vLL@IHIcLHLAWЃ<w%H
k HcH>$AGf D$$Is Mof. fEof E of. B *AO<u AGAW)H9f 1)f D$@i / HL$(D$H1Hl$0HT$H$LcAG< HT$ < <u IWI+WI9vLLIHIcLHLCAWЃ<H5j 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 $QH $IU D AWA+WS AWAG)Hc< @ HL$ HAHD$ d D AOA+O3HALIE1E1Au D AUATIUHSHHWЃ<w(H
h HcH> @ HGHX IHs_ IL9 Au LFHuI9r#f. HL9v3L HuI9wbL)HLd L9tHLHA$ E<w Hh 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ǃ@ Lg @IcHAHW H USHHy Hƿ HHHy H¿ HHH9 H9 H9 H)HZH,HtHHHHE A<wZHf HcH> Hg1f D AL A< A-YH1[] @ fYH1[] YH1[] @ HYH1[] AH1[] D HH9~ H1(f D H)HXf D USHo<wOHe HcH> D o~/HAUHHtf D HHHWH9uH[] o @@f D ofof. USHo<wOHe HcH> D o~/HaUHHtf D HHHWH9uH[] o @@f D ofof. USHo^ڃ<$ H
d HcH> ow!H
qd 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
c HcH> 11N111Cff. AWAVAUATUSHH H, AΉL$ H|$( LD$0HT$t$<IHi AF)É\$8{ HcD$ E11E1A HD$(IcH|$|$ t\HT$(Ht$BtUAD9t$8 EeA9|H5, LHcHPH IcH|$|$ IuHD$ 8uDIcHcH|$)IHcHT$ HT$ HHtKDt$ EDD9t$8vt$ D$' LǺ HhANL4$Il D$'
f D$'
f D$'f D$'f IFt I$DB t E @ Ht$MNjBt(Hl$H\$ HH| BuHr, H|$P MtLHD$ HD$ @ A~'LǺ InE1H5b# E1OANIIO E1A :f. IvI$HDru-I~H<$D$' @ E1E1 IvDrtLD$I#A>$$LD$HLT$' 蕲AIHJ, HD$H|$S HD$ f D D_HD߃@w+LZ @Ic IE EIM9uDXMtII D HtE
D:tBE1 D F8 tIL9uIM9uLXAEDXDXI AVIAUATIUS7~:Dm1L HI4H9t LHrHSL9u[]A\A]A^ AWIAVIAUATIUSH~ ICLL)ȉ [ ]A\A^ L)L 1fH(dH%( HD$1H v~HFH H f D HHHrHwHHwo$?HHNfAHHAȀDAHw` H|$dH3<%( u9H( @4$H H$? HN뷸fH^ H?] HcH> D n Hontrol-aH3WHaccess-cH3H uHllow-oriH9G @ y HransportH3WHstrict-tH3H uH-securitH9GC @ G D Wr[ t* e(?cookX fG d<G H*[ 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$1I9 IH~
H@A H H @ HHHrHwHH E EH $HN HHπ@yHwH7u EunM9 LHHH\$dH3 %( H []A\A]A^f D I~vZID$ME1H/H$ HN LHHA D H$SfME11H$ HN0P2H
3P H5wP H=L c SHH HH)A H9sHE1H{@՝HxH) [ PXH
P Y H5P H=,L Hff. HHGHP=H9vDH ? ? H)H H D HHHrHwHH A H
M EHB
<HN@<$f D HHπ@yHwLuHU H3LH\$dH3 %( u|H []A\ E1HaM EB"4 H$ Aw= Aw-H+M EHB
<HN @<$fy UHLISHHHdH4%( Ht$1 H H|$APL Q ZYHt,T$H9w#H HL$dH3 %( uH[] D H肶f oSHHFHGHHPH@HG(HFHWHPH@HW HG0FHG@ G8GL H?4H{[*f. SHH/H;[&f D AUIATUSHHH t81 HCHHH#CHL$LRLL藬H9kwH3HL[]A\A]|ff. AUATUSHHo HG(H;G0 HI' @ LLH5ID$(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 LLLIG(IO0HH9 IWH IOHI7H HI#OL4INH+AIH+AIWIG(HtAVLHD HtI9t?HP@HrL9tHHP@H]L9uH@IV@HIF@ @HD f 1H9vH[]A\A]A^A_f. P LIHV LH}IGMoHPIEH9 A H ML9wJ4 L踚H MGI7Mt2IWMWHIHL f D LH!HHH[]f. 11Ht$ HuHD$(H|$ Z{ ff. AWAVAUATUSH Ht$0HL$(dH%( H$ 1< P HH HE@H|$( HD$ HD$H} H$ IHD$8HD$pHD$@f I_M'HLAƃB < HH
`l+ 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$ H~uMu D |$5 IEMHUH;PuHuHxGuIHl$E8f D AALJ
ILJ ILJ A Ht$string = $string;
}
public function __toString(): string
{
return $this->string;
}
public function length(): int
{
return strlen($this->string);
}
public function indexOf(string $needle, int $offset = 0)
{
return strpos($this->string, ...func_get_args());
}
public function lastIndexOf(string $needle, int $offset = 0)
{
return strrpos($this->string, ...func_get_args());
}
public function pos(string $needle, int $offset = 0)
{
return strpos($this->string, ...func_get_args());
}
public function rpos(string $needle, int $offset = 0)
{
return strrpos($this->string, ...func_get_args());
}
public function ipos(string $needle)
{
return stripos($this->string, $needle);
}
public function lower(): self
{
return new static(strtolower($this->string));
}
public function upper(): self
{
return new static(strtoupper($this->string));
}
public function trim($characters = ''): self
{
if ($characters) {
return new static(trim($this->string, $characters));
}
return new static(trim($this->string));
}
public function ltrim(): self
{
return new static(ltrim($this->string));
}
public function rtrim(): self
{
return new static(rtrim($this->string));
}
public function substr(int $offset, ?int $length = null)
{
return new static(substr($this->string, ...func_get_args()));
}
public function repeat(int $times): self
{
return new static(str_repeat($this->string, $times));
}
public function append($str): self
{
return new static($this->string .= $str);
}
public function replace(string $search, string $replace, &$count = null): self
{
return new static(str_replace($search, $replace, $this->string, $count));
}
public function startsWith(string $needle): bool
{
return strpos($this->string, $needle) === 0;
}
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 strpos($this->string, $subString) !== false;
}
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];
}
public function chunkSplit(int $chunkLength = 76, string $chunkEnd = ''): self
{
return new static(chunk_split($this->string, ...func_get_args()));
}
public function chunk(int $splitLength = 1): ArrayObject
{
return static::detectArrayType(str_split($this->string, ...func_get_args()));
}
public function toString(): string
{
return $this->string;
}
protected static function detectArrayType(array $value): ArrayObject
{
return new ArrayObject($value);
}
}
@swoole-src/library/core/MultibyteStringObject.php
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)
{
return mb_strpos($this->string, ...func_get_args());
}
public function lastIndexOf(string $needle, int $offset = 0, ?string $encoding = null)
{
return mb_strrpos($this->string, ...func_get_args());
}
public function pos(string $needle, int $offset = 0, ?string $encoding = null)
{
return mb_strpos($this->string, ...func_get_args());
}
public function rpos(string $needle, int $offset = 0, ?string $encoding = null)
{
return mb_strrpos($this->string, ...func_get_args());
}
public function ipos(string $needle, ?string $encoding = null)
{
return mb_stripos($this->string, ...func_get_args());
}
public function substr(int $offset, ?int $length = null, ?string $encoding = null)
{
return new static(mb_substr($this->string, ...func_get_args()));
}
public function chunk(int $splitLength = 1, ?int $limit = null): ArrayObject
{
return static::detectArrayType(mb_split($this->string, ...func_get_args()));
}
}
@swoole-src/library/core/Exception/ArrayKeyNotExists.php
declare(strict_types=1);
namespace Swoole\Exception;
class ArrayKeyNotExists extends \RuntimeException
{
}
@swoole-src/library/core/ArrayObject.php
declare(strict_types=1);
namespace Swoole;
use ArrayAccess;
use Countable;
use Iterator;
use RuntimeException;
use Serializable;
use Swoole\Exception\ArrayKeyNotExists;
class ArrayObject implements ArrayAccess, Serializable, Countable, Iterator
{
protected $array;
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 function toArray(): array
{
return $this->array;
}
public function isEmpty(): bool
{
return empty($this->array);
}
public function count(): int
{
return count($this->array);
}
#[\ReturnTypeWillChange]
public function current()
{
return current($this->array);
}
#[\ReturnTypeWillChange]
public function key()
{
return key($this->array);
}
public function valid(): bool
{
return array_key_exists($this->key(), $this->array);
}
#[\ReturnTypeWillChange]
public function rewind()
{
return reset($this->array);
}
#[\ReturnTypeWillChange]
public function next()
{
return next($this->array);
}
public function get($key)
{
if (!$this->exists($key)) {
throw new ArrayKeyNotExists($key);
}
return static::detectType($this->array[$key]);
}
public function getOr($key, $default = null)
{
if (!$this->exists($key)) {
return $default;
}
return static::detectType($this->array[$key]);
}
public function last()
{
$key = array_key_last($this->array);
if ($key === null) {
return null;
}
return $this->get($key);
}
public function firstKey()
{
return array_key_first($this->array);
}
public function lastKey()
{
return array_key_last($this->array);
}
public function first()
{
$key = array_key_first($this->array);
if ($key === null) {
return null;
}
return $this->get($key);
}
public function set($key, $value): self
{
$this->array[$key] = $value;
return $this;
}
public function delete($key): self
{
unset($this->array[$key]);
return $this;
}
public function remove($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;
}
public function clear(): self
{
$this->array = [];
return $this;
}
#[\ReturnTypeWillChange]
public function offsetGet($key)
{
if (!array_key_exists($key, $this->array)) {
return null;
}
return $this->array[$key];
}
public function offsetSet($key, $value): void
{
$this->array[$key] = $value;
}
public function offsetUnset($key): void
{
unset($this->array[$key]);
}
#[\ReturnTypeWillChange]
public function offsetExists($key)
{
return isset($this->array[$key]);
}
public function exists($key): bool
{
return array_key_exists($key, $this->array);
}
public function contains($value, bool $strict = true): bool
{
return in_array($value, $this->array, $strict);
}
public function indexOf($value, bool $strict = true)
{
return $this->search($value, $strict);
}
public function lastIndexOf($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;
}
public function search($needle, bool $strict = true)
{
return array_search($needle, $this->array, $strict);
}
public function join(string $glue = ''): StringObject
{
return static::detectStringType(implode($glue, $this->array));
}
public function serialize(): StringObject
{
return static::detectStringType(serialize($this->array));
}
public function unserialize($string): self
{
$this->array = (array) unserialize((string) $string);
return $this;
}
public function sum()
{
return array_sum($this->array);
}
public function product()
{
return array_product($this->array);
}
public function push($value)
{
return $this->pushBack($value);
}
public function pushFront($value)
{
return array_unshift($this->array, $value);
}
public function append(...$values): ArrayObject
{
array_push($this->array, ...$values);
return $this;
}
public function pushBack($value)
{
return array_push($this->array, $value);
}
public function insert(int $offset, $value): self
{
if (is_array($value) || is_object($value) || is_null($value)) {
$value = [$value];
}
array_splice($this->array, $offset, 0, $value);
return $this;
}
public function pop()
{
return $this->popBack();
}
public function popFront()
{
return array_shift($this->array);
}
public function popBack()
{
return array_pop($this->array);
}
public function slice($offset, int $length = null, bool $preserve_keys = false): self
{
return new static(array_slice($this->array, ...func_get_args()));
}
public function randomGet()
{
return static::detectType($this->array[array_rand($this->array, 1)]);
}
public function each(callable $fn): self
{
if (array_walk($this->array, $fn) === false) {
throw new RuntimeException('array_walk() failed');
}
return $this;
}
public function map(callable $fn, ...$args): self
{
return new static(array_map($fn, $this->array, ...$args));
}
public function reduce(callable $fn, $initial = null)
{
return array_reduce($this->array, $fn, $initial);
}
public function keys(...$args): self
{
return new static(array_keys($this->array, ...$args));
}
public function values(): self
{
return new static(array_values($this->array));
}
public function column($column_key, $index = null): self
{
return new static(array_column($this->array, $column_key, $index));
}
public function unique(int $sort_flags = SORT_STRING): self
{
return new static(array_unique($this->array, $sort_flags));
}
public function reverse(bool $preserve_keys = false): self
{
return new static(array_reverse($this->array, $preserve_keys));
}
public function chunk(int $size, bool $preserve_keys = false): self
{
return new static(array_chunk($this->array, $size, $preserve_keys));
}
public function flip(): self
{
return new static(array_flip($this->array));
}
public function filter(callable $fn, int $flag = 0): self
{
return new static(array_filter($this->array, $fn, $flag));
}
public function asort(int $sort_flags = SORT_REGULAR): self
{
if (asort($this->array, $sort_flags) !== true) {
throw new RuntimeException('asort() failed');
}
return $this;
}
public function arsort(int $sort_flags = SORT_REGULAR): self
{
if (arsort($this->array, $sort_flags) !== true) {
throw new RuntimeException('arsort() failed');
}
return $this;
}
public function krsort(int $sort_flags = SORT_REGULAR): self
{
if (krsort($this->array, $sort_flags) !== true) {
throw new RuntimeException('krsort() failed');
}
return $this;
}
public function ksort(int $sort_flags = SORT_REGULAR): self
{
if (ksort($this->array, $sort_flags) !== true) {
throw new RuntimeException('ksort() failed');
}
return $this;
}
public function natcasesort(): self
{
if (natcasesort($this->array) !== true) {
throw new RuntimeException('natcasesort() failed');
}
return $this;
}
public function natsort(): self
{
if (natsort($this->array) !== true) {
throw new RuntimeException('natsort() failed');
}
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
{
if (shuffle($this->array) !== true) {
throw new RuntimeException('shuffle() failed');
}
return $this;
}
public function sort(int $sort_flags = SORT_REGULAR): self
{
if (sort($this->array, $sort_flags) !== true) {
throw new RuntimeException('sort() failed');
}
return $this;
}
public function uasort(callable $value_compare_func): self
{
if (uasort($this->array, $value_compare_func) !== true) {
throw new RuntimeException('uasort() failed');
}
return $this;
}
public function uksort(callable $value_compare_func): self
{
if (uksort($this->array, $value_compare_func) !== true) {
throw new RuntimeException('uksort() failed');
}
return $this;
}
public function usort(callable $value_compare_func): self
{
if (usort($this->array, $value_compare_func) !== true) {
throw new RuntimeException('usort() failed');
}
return $this;
}
protected static function detectType($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): self
{
return new static($value);
}
}
@swoole-src/library/core/ObjectProxy.php
declare(strict_types=1);
namespace Swoole;
use TypeError;
class ObjectProxy
{
protected $__object;
public function __construct($object)
{
if (!is_object($object)) {
throw new TypeError('Non-object given');
}
$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)
{
$object = $this->__object;
return $object(...$arguments);
}
}
@swoole-src/library/core/Coroutine/WaitGroup.php
declare(strict_types=1);
namespace Swoole\Coroutine;
use BadMethodCallException;
use InvalidArgumentException;
class WaitGroup
{
protected $chan;
protected $count = 0;
protected $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-src/library/core/Coroutine/Server.php
declare(strict_types=1);
namespace Swoole\Coroutine;
use Swoole\Coroutine;
use Swoole\Coroutine\Server\Connection;
use Swoole\Exception;
define('SWOOLE_COROUTINE_SOCKET_HAVE_SSL_HANDSHAKE', method_exists(Socket::class, 'sslHandshake'));
class Server
{
public $host = '';
public $port = 0;
public $type = AF_INET;
public $fd = -1;
public $errCode = 0;
public $setting = [];
protected $running = false;
protected $fn;
protected $socket;
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) {
$conn = null;
$conn = $socket->accept();
if ($conn) {
$conn->setProtocol($this->setting);
if (SWOOLE_COROUTINE_SOCKET_HAVE_SSL_HANDSHAKE && $this->setting['open_ssl'] ?? false) {
$fn = static function ($fn, $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-src/library/core/Coroutine/Server/Connection.php
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-src/library/core/Coroutine/Barrier.php
declare(strict_types=1);
namespace Swoole\Coroutine;
use Swoole\Coroutine;
use Swoole\Exception;
use Swoole\Timer;
class Barrier
{
private $cid = -1;
private $timer = -1;
private static $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()
{
return new static();
}
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-src/library/core/Coroutine/Http/ClientProxy.php
declare(strict_types=1);
namespace Swoole\Coroutine\Http;
class ClientProxy
{
private $body;
private $statusCode;
private $headers;
private $cookies;
public function __construct($body, $statusCode, $headers, $cookies)
{
$this->body = $body;
$this->statusCode = $statusCode;
$this->headers = $headers;
$this->cookies = $cookies;
}
public function getBody()
{
return $this->body;
}
public function getStatusCode()
{
return $this->statusCode;
}
public function getHeaders()
{
return $this->headers;
}
public function getCookies()
{
return $this->cookies;
}
}
@swoole-src/library/core/Coroutine/Http/functions.php
declare(strict_types=1);
namespace Swoole\Coroutine\Http;
use Swoole\Coroutine\Http\Client\Exception;
function request(
string $url,
string $method,
$data = null,
array $options = null,
array $headers = null,
array $cookies = null
): ClientProxy {
$driver = swoole_library_get_option('http_client_driver');
switch ($driver) {
case 'curl':
return request_with_curl($url, $method, $data, $options, $headers, $cookies);
case 'stream':
return request_with_stream($url, $method, $data, $options, $headers, $cookies);
case 'swoole':
default:
return request_with_http_client($url, $method, $data, $options, $headers, $cookies);
}
}
function request_with_http_client(
string $url,
string $method,
$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);
}
if (is_array($options)) {
$client->set($options);
}
if (is_array($headers)) {
$client->setHeaders($headers);
}
if (is_array($cookies)) {
$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);
}
function request_with_curl(
string $url,
string $method,
$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_HTTP_CODE), $responseHeaders, $responseCookies);
}
throw new Exception(curl_error($ch), curl_errno($ch));
}
function request_with_stream(
string $url,
string $method,
$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']);
}
function post(string $url, $data, array $options = null, array $headers = null, array $cookies = null): ClientProxy
{
return request($url, 'POST', $data, $options, $headers, $cookies);
}
function get(string $url, array $options = null, array $headers = null, array $cookies = null): ClientProxy
{
return request($url, 'GET', null, $options, $headers, $cookies);
}
@swoole-src/library/core/ConnectionPool.php
declare(strict_types=1);
namespace Swoole;
use RuntimeException;
use Swoole\Coroutine\Channel;
use Throwable;
class ConnectionPool
{
public const DEFAULT_SIZE = 64;
protected $pool;
protected $constructor;
protected $size;
protected $num;
protected $proxy;
public function __construct(callable $constructor, int $size = self::DEFAULT_SIZE, ?string $proxy = null)
{
$this->pool = new Channel($this->size = $size);
$this->constructor = $constructor;
$this->num = 0;
$this->proxy = $proxy;
}
public function fill(): void
{
while ($this->size > $this->num) {
$this->make();
}
}
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 {
$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-src/library/core/Database/ObjectProxy.php
declare(strict_types=1);
namespace Swoole\Database;
use Error;
class ObjectProxy extends \Swoole\ObjectProxy
{
public function __clone()
{
throw new Error('Trying to clone an uncloneable database proxy object');
}
}
@swoole-src/library/core/Database/MysqliConfig.php
declare(strict_types=1);
namespace Swoole\Database;
class MysqliConfig
{
protected $host = '127.0.0.1';
protected $port = 3306;
protected $unixSocket = '';
protected $dbname = 'test';
protected $charset = 'utf8mb4';
protected $username = 'root';
protected $password = 'root';
protected $options = [];
public function getHost(): string
{
return $this->host;
}
public function withHost($host): self
{
$this->host = $host;
return $this;
}
public function getPort(): int
{
return $this->port;
}
public function getUnixSocket(): string
{
return $this->unixSocket;
}
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-src/library/core/Database/MysqliException.php
declare(strict_types=1);
namespace Swoole\Database;
use Exception;
class MysqliException extends Exception
{
}
@swoole-src/library/core/Database/MysqliPool.php
declare(strict_types=1);
namespace Swoole\Database;
use mysqli;
use Swoole\ConnectionPool;
class MysqliPool extends ConnectionPool
{
protected $config;
public function __construct(MysqliConfig $config, int $size = self::DEFAULT_SIZE)
{
$this->config = $config;
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);
}
return $mysqli;
}, $size, MysqliProxy::class);
}
}
@swoole-src/library/core/Database/MysqliProxy.php
declare(strict_types=1);
namespace Swoole\Database;
use mysqli;
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,
2006,
2013,
];
protected $__object;
protected $charsetContext;
protected $setOptContext;
protected $changeUserContext;
protected $constructor;
protected $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) {
if (!preg_match(static::IO_METHOD_REGEX, $name)) {
break;
}
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;
}
return $ret;
}
public function getRound(): int
{
return $this->round;
}
public function reconnect(): void
{
$constructor = $this->constructor;
parent::__construct($constructor());
$this->round++;
if ($this->charsetContext) {
$this->__object->set_charset($this->charsetContext);
}
if ($this->setOptContext) {
foreach ($this->setOptContext as $opt => $val) {
$this->__object->set_opt($opt, $val);
}
}
if ($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-src/library/core/Database/MysqliStatementProxy.php
declare(strict_types=1);
namespace Swoole\Database;
use mysqli;
use mysqli_stmt;
class MysqliStatementProxy extends ObjectProxy
{
public const IO_METHOD_REGEX = '/^close|execute|fetch|prepare$/i';
protected $__object;
protected $queryString;
protected $attrSetContext;
protected $bindParamContext;
protected $bindResultContext;
protected $parent;
protected $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) {
if (!preg_match(static::IO_METHOD_REGEX, $name)) {
break;
}
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) {
$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 ($this->bindParamContext) {
$this->__object->bind_param($this->bindParamContext[0], ...$this->bindParamContext[1]);
}
if ($this->bindResultContext) {
$this->__object->bind_result($this->bindResultContext);
}
if ($this->attrSetContext) {
foreach ($this->attrSetContext as $attr => $value) {
$this->__object->attr_set($attr, $value);
}
}
continue;
}
if (strcasecmp($name, 'prepare') === 0) {
$this->queryString = $arguments[0];
}
break;
}
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-src/library/core/Database/PDOConfig.php
declare(strict_types=1);
namespace Swoole\Database;
class PDOConfig
{
public const DRIVER_MYSQL = 'mysql';
protected $driver = self::DRIVER_MYSQL;
protected $host = '127.0.0.1';
protected $port = 3306;
protected $unixSocket;
protected $dbname = 'test';
protected $charset = 'utf8mb4';
protected $username = 'root';
protected $password = 'root';
protected $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($host): self
{
$this->host = $host;
return $this;
}
public function getPort(): int
{
return $this->port;
}
public function hasUnixSocket(): bool
{
return isset($this->unixSocket);
}
public function getUnixSocket(): string
{
return $this->unixSocket;
}
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;
}
public static function getAvailableDrivers()
{
return [
self::DRIVER_MYSQL,
];
}
}
@swoole-src/library/core/Database/PDOPool.php
declare(strict_types=1);
namespace Swoole\Database;
use PDO;
use Swoole\ConnectionPool;
class PDOPool extends ConnectionPool
{
protected $size = 64;
protected $config;
public function __construct(PDOConfig $config, int $size = self::DEFAULT_SIZE)
{
$this->config = $config;
parent::__construct(function () {
return new PDO(
"{$this->config->getDriver()}:" .
(
$this->config->hasUnixSocket() ?
"unix_socket={$this->config->getUnixSocket()};" :
"host={$this->config->getHost()};" . "port={$this->config->getPort()};"
) .
"dbname={$this->config->getDbname()};" .
"charset={$this->config->getCharset()}",
$this->config->getUsername(),
$this->config->getPassword(),
$this->config->getOptions()
);
}, $size, PDOProxy::class);
}
}
@swoole-src/library/core/Database/PDOProxy.php
declare(strict_types=1);
namespace Swoole\Database;
use PDO;
use PDOException;
class PDOProxy extends ObjectProxy
{
public const IO_METHOD_REGEX = '/^query|prepare|exec|beginTransaction|commit|rollback$/i';
public const IO_ERRORS = [
2002,
2006,
2013,
];
protected $__object;
protected $setAttributeContext;
protected $constructor;
protected $round = 0;
public function __construct(callable $constructor)
{
parent::__construct($constructor());
$this->__object->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
$this->constructor = $constructor;
}
public function __call(string $name, array $arguments)
{
for ($n = 3; $n--;) {
$ret = @$this->__object->{$name}(...$arguments);
if ($ret === false) {
if (!preg_match(static::IO_METHOD_REGEX, $name)) {
break;
}
$errorInfo = $this->__object->errorInfo();
if (
!in_array($errorInfo[1], static::IO_ERRORS, true)
|| $n === 0
|| $this->__object->inTransaction()
) {
if (!empty($errorInfo) && $errorInfo[0] !== '00000') {
$exception = new PDOException($errorInfo[2], $errorInfo[1]);
$exception->errorInfo = $errorInfo;
throw $exception;
}
break;
}
$this->reconnect();
continue;
}
if ((strcasecmp($name, 'prepare') === 0) || (strcasecmp($name, 'query') === 0)) {
$ret = new PDOStatementProxy($ret, $this);
}
break;
}
return $ret;
}
public function getRound(): int
{
return $this->round;
}
public function reconnect(): void
{
$constructor = $this->constructor;
parent::__construct($constructor());
$this->round++;
if ($this->setAttributeContext) {
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->__object->inTransaction();
}
}
@swoole-src/library/core/Database/PDOStatementProxy.php
declare(strict_types=1);
namespace Swoole\Database;
use PDO;
use PDOException;
use PDOStatement;
class PDOStatementProxy extends ObjectProxy
{
protected $__object;
protected $setAttributeContext;
protected $setFetchModeContext;
protected $bindParamContext;
protected $bindColumnContext;
protected $bindValueContext;
protected $parent;
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)
{
for ($n = 3; $n--;) {
$ret = @$this->__object->{$name}(...$arguments);
if ($ret === false) {
if (strtolower($name) !== 'execute') {
break;
}
if (
!in_array($this->__object->errorInfo()[1], $this->parent::IO_ERRORS, true)
|| $n === 0
|| $this->parent->inTransaction()
) {
$errorInfo = $this->__object->errorInfo();
if (!empty($errorInfo) && $errorInfo[0] !== '00000') {
$exception = new PDOException($errorInfo[2], $errorInfo[1]);
$exception->errorInfo = $errorInfo;
throw $exception;
}
break;
}
if ($this->parent->getRound() === $this->parentRound) {
$this->parent->reconnect();
}
$parent = $this->parent->__getObject();
$this->__object = $parent->prepare($this->__object->queryString);
if ($this->__object === false) {
$errorInfo = $parent->errorInfo();
$exception = new PDOException($errorInfo[2], $errorInfo[1]);
$exception->errorInfo = $errorInfo;
throw $exception;
}
if ($this->setAttributeContext) {
foreach ($this->setAttributeContext as $attribute => $value) {
$this->__object->setAttribute($attribute, $value);
}
}
if ($this->setFetchModeContext) {
$this->__object->setFetchMode(...$this->setFetchModeContext);
}
if ($this->bindParamContext) {
foreach ($this->bindParamContext as $param => $item) {
$this->__object->bindParam($param, ...$item);
}
}
if ($this->bindColumnContext) {
foreach ($this->bindColumnContext as $column => $item) {
$this->__object->bindColumn($column, ...$item);
}
}
if ($this->bindValueContext) {
foreach ($this->bindValueContext as $value => $item) {
$this->__object->bindParam($value, ...$item);
}
}
continue;
}
break;
}
return $ret;
}
public function setAttribute(int $attribute, $value): bool
{
$this->setAttributeContext[$attribute] = $value;
return $this->__object->setAttribute($attribute, $value);
}
public function setFetchMode(int $mode, ...$args): 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-src/library/core/Database/RedisConfig.php
declare(strict_types=1);
namespace Swoole\Database;
class RedisConfig
{
protected $host = '127.0.0.1';
protected $port = 6379;
protected $timeout = 0.0;
protected $reserved = '';
protected $retry_interval = 0;
protected $read_timeout = 0.0;
protected $auth = '';
protected $dbIndex = 0;
public function getHost()
{
return $this->host;
}
public function withHost($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;
}
}
@swoole-src/library/core/Database/RedisPool.php
declare(strict_types=1);
namespace Swoole\Database;
use Redis;
use Swoole\ConnectionPool;
class RedisPool extends ConnectionPool
{
protected $config;
public function __construct(RedisConfig $config, int $size = self::DEFAULT_SIZE)
{
$this->config = $config;
parent::__construct(function () {
$redis = new Redis();
$arguments = [
$this->config->getHost(),
$this->config->getPort(),
];
if ($this->config->getTimeout() !== 0.0) {
$arguments[] = $this->config->getTimeout();
}
if ($this->config->getRetryInterval() !== 0) {
$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());
}
return $redis;
}, $size);
}
}
@swoole-src/library/core/Http/Status.php
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-src/library/core/Curl/Exception.php
declare(strict_types=1);
namespace Swoole\Curl;
use Swoole;
class Exception extends Swoole\Exception
{
}
@swoole-src/library/core/Curl/Handler.php
declare(strict_types=1);
namespace Swoole\Curl;
use CURLFile;
use ReflectionClass;
use Swoole;
use Swoole\Constant;
use Swoole\Coroutine\Http\Client;
use Swoole\Curl\Exception as CurlException;
use Swoole\Http\Status;
final class Handler
{
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;
private $headerFunction;
private $readFunction;
private $writeFunction;
private $noProgress = true;
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()
{
$id = spl_object_id($this);
return "Object({$id}) of type (curl)";
}
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()
{
return $this->isAvailable() ? $this->errCode : false;
}
public function error()
{
return $this->isAvailable() ? $this->errMsg : false;
}
public function reset()
{
if (!$this->isAvailable()) {
return false;
}
foreach ((new ReflectionClass(static::class))->getDefaultProperties() as $name => $value) {
$this->{$name} = $value;
}
}
public function getContent()
{
if (!$this->isAvailable()) {
return false;
}
return $this->transfer;
}
public function close()
{
if (!$this->isAvailable()) {
return false;
}
foreach ($this as &$property) {
$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 (strpos($url, '://') === false && $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) {
$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 ($this->client) {
$oldUrlInfo = $this->urlInfo;
if (($host !== $oldUrlInfo['host']) || ($port !== $oldUrlInfo['port']) || ($scheme !== $oldUrlInfo['scheme'])) {
$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 ($this->client) {
$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 {
unset($this->headerMap[$lowerCaseHeaderName]);
}
}
private function setOption(int $opt, $value): bool
{
switch ($opt) {
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) {
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 = $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 Swoole\Curl\Exception(
'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:
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 === '-') {
$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 {
$this->resolve[$host][$port] = explode(',', $ip)[0];
}
}
break;
case CURLOPT_IPRESOLVE:
if ($value !== CURL_IPRESOLVE_WHATEVER and $value !== CURL_IPRESOLVE_V4) {
throw new Swoole\Curl\Exception(
'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;
case CURLOPT_VERBOSE:
case CURLOPT_SSLVERSION:
case CURLOPT_NOSIGNAL:
case CURLOPT_FRESH_CONNECT:
case CURLOPT_BINARYTRANSFER:
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;
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;
case CURLOPT_POST:
$this->method = 'POST';
break;
case CURLOPT_POSTFIELDS:
$this->postData = $value;
if (!$this->method) {
$this->method = 'POST';
}
break;
case CURLOPT_SAFE_UPLOAD:
if (!$value) {
trigger_error('swoole_curl_setopt(): Disabling safe uploads is no longer supported', E_USER_WARNING);
return false;
}
break;
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;
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:
$this->method = 'PUT';
break;
case CURLOPT_INFILE:
$this->infile = $value;
break;
case CURLOPT_INFILESIZE:
$this->infileSize = $value;
break;
case CURLOPT_HTTPGET:
$this->method = 'GET';
break;
default:
throw new Swoole\Curl\Exception("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);
if (!$this->urlInfo) {
$this->setError(CURLE_URL_MALFORMAT, 'No URL set or URL using bad/illegal format');
return false;
}
if (!$this->client) {
$this->create();
}
while (true) {
$client = $this->client;
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;
}
switch ($proxyType) {
case CURLPROXY_HTTP:
$proxyOptions = [
'http_proxy_host' => $proxy,
'http_proxy_port' => $proxyPort,
'http_proxy_username' => $proxyUsername,
'http_proxy_password' => $proxyPassword,
];
break;
case CURLPROXY_SOCKS5:
$proxyOptions = [
'socks5_host' => $proxy,
'socks5_port' => $proxyPort,
'socks5_username' => $proxyUsername,
'socks5_password' => $proxyPassword,
];
break;
default:
throw new CurlException("Unexpected proxy type [{$proxyType}]");
}
}
$client->set(
$this->clientOptions +
($proxyOptions ?? [])
);
if ($this->method) {
$client->setMethod($this->method);
}
if ($this->infile) {
$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);
$this->infile = null;
$this->infileSize = PHP_INT_MAX;
} else {
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);
}
$client->setHeaders($this->headers);
$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 = static::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);
}
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)) {
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;
}
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 substr($location, 0, 2) === './') {
$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-src/library/core/FastCGI.php
declare(strict_types=1);
namespace Swoole;
class FastCGI
{
public const HEADER_LEN = 8;
public const HEADER_FORMAT = 'Cversion/Ctype/nrequestId/ncontentLength/CpaddingLength/Creserved';
public const MAX_CONTENT_LENGTH = 65535;
public const VERSION_1 = 1;
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;
public const DEFAULT_REQUEST_ID = 1;
public const KEEP_CONN = 1;
public const RESPONDER = 1;
public const AUTHORIZER = 2;
public const FILTER = 3;
public const REQUEST_COMPLETE = 0;
public const CANT_MPX_CONN = 1;
public const OVERLOADED = 2;
public const UNKNOWN_ROLE = 3;
}
@swoole-src/library/core/FastCGI/Record.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use Swoole\FastCGI;
class Record
{
protected $version = FastCGI::VERSION_1;
protected $type = FastCGI::UNKNOWN_TYPE;
protected $requestId = FastCGI::DEFAULT_REQUEST_ID;
protected $reserved = 0;
private $contentLength = 0;
private $paddingLength = 0;
private $contentData = '';
private $paddingData = '';
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;
}
final public static function unpack(string $data): self
{
$self = new static();
[
$self->version,
$self->type,
$self->requestId,
$self->contentLength,
$self->paddingLength,
$self->reserved
] = array_values(unpack(FastCGI::HEADER_FORMAT, $data));
$payload = substr($data, FastCGI::HEADER_LEN);
self::unpackPayload($self, $payload);
if (get_called_class() !== __CLASS__ && $self->contentLength > 0) {
static::unpackPayload($self, $payload);
}
return $self;
}
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;
}
public function getContentData(): string
{
return $this->contentData;
}
public function getVersion(): int
{
return $this->version;
}
public function getType(): int
{
return $this->type;
}
public function getRequestId(): int
{
return $this->requestId;
}
public function setRequestId(int $requestId): self
{
$this->requestId = $requestId;
return $this;
}
final public function getContentLength(): int
{
return $this->contentLength;
}
final public function getPaddingLength(): int
{
return $this->paddingLength;
}
protected static function unpackPayload($self, string $data): void
{
[
$self->contentData,
$self->paddingData
] = array_values(
unpack("a{$self->contentLength}contentData/a{$self->paddingLength}paddingData", $data)
);
}
protected function packPayload(): string
{
return pack("a{$this->contentLength}", $this->contentData);
}
}
@swoole-src/library/core/FastCGI/Record/Params.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class Params extends Record
{
protected $values = [];
public function __construct(array $values = [])
{
$this->type = FastCGI::PARAMS;
$this->values = $values;
$this->setContentData($this->packPayload());
}
public function getValues(): array
{
return $this->values;
}
protected static function unpackPayload($self, string $data): void
{
$currentOffset = 0;
do {
[$nameLengthHigh] = array_values(unpack('CnameLengthHigh', $data));
$isLongName = ($nameLengthHigh >> 7 == 1);
$valueOffset = $isLongName ? 4 : 1;
[$valueLengthHigh] = array_values(unpack('CvalueLengthHigh', substr($data, $valueOffset)));
$isLongValue = ($valueLengthHigh >> 7 == 1);
$dataOffset = $valueOffset + ($isLongValue ? 4 : 1);
$formatParts = [
$isLongName ? 'NnameLength' : 'CnameLength',
$isLongValue ? 'NvalueLength' : 'CvalueLength',
];
$format = join('/', $formatParts);
[$nameLength, $valueLength] = array_values(unpack($format, $data));
$nameLength &= ($isLongName ? 0x7FFFFFFF : 0x7F);
$valueLength &= ($isLongValue ? 0x7FFFFFFF : 0x7F);
[$nameData, $valueData] = array_values(
unpack(
"a{$nameLength}nameData/a{$valueLength}valueData",
substr($data, $dataOffset)
)
);
$self->values[$nameData] = $valueData;
$keyValueLength = $dataOffset + $nameLength + $valueLength;
$data = substr($data, $keyValueLength);
$currentOffset += $keyValueLength;
} while ($currentOffset < $self->getContentLength());
}
protected function packPayload(): string
{
$payload = '';
foreach ($this->values as $nameData => $valueData) {
if ($valueData === null) {
continue;
}
$nameLength = strlen($nameData);
$valueLength = strlen((string) $valueData);
$isLongName = $nameLength > 127;
$isLongValue = $valueLength > 127;
$formatParts = [
$isLongName ? 'N' : 'C',
$isLongValue ? 'N' : 'C',
"a{$nameLength}",
"a{$valueLength}",
];
$format = join('', $formatParts);
$payload .= pack(
$format,
$isLongName ? ($nameLength | 0x80000000) : $nameLength,
$isLongValue ? ($valueLength | 0x80000000) : $valueLength,
$nameData,
$valueData
);
}
return $payload;
}
}
@swoole-src/library/core/FastCGI/Record/AbortRequest.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class AbortRequest extends Record
{
public function __construct(int $requestId = 0)
{
$this->type = FastCGI::ABORT_REQUEST;
$this->setRequestId($requestId);
}
}
@swoole-src/library/core/FastCGI/Record/BeginRequest.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class BeginRequest extends Record
{
protected $role = FastCGI::UNKNOWN_ROLE;
protected $flags;
protected $reserved1;
public function __construct(int $role = FastCGI::UNKNOWN_ROLE, int $flags = 0, string $reserved = '')
{
$this->type = FastCGI::BEGIN_REQUEST;
$this->role = $role;
$this->flags = $flags;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
public function getRole(): int
{
return $this->role;
}
public function getFlags(): int
{
return $this->flags;
}
protected static function unpackPayload($self, string $data): void
{
[
$self->role,
$self->flags,
$self->reserved1
] = array_values(unpack('nrole/Cflags/a5reserved', $data));
}
protected function packPayload(): string
{
return pack(
'nCa5',
$this->role,
$this->flags,
$this->reserved1
);
}
}
@swoole-src/library/core/FastCGI/Record/Data.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class Data extends Record
{
public function __construct(string $contentData = '')
{
$this->type = FastCGI::DATA;
$this->setContentData($contentData);
}
}
@swoole-src/library/core/FastCGI/Record/EndRequest.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class EndRequest extends Record
{
protected $appStatus = 0;
protected $protocolStatus = FastCGI::REQUEST_COMPLETE;
protected $reserved1;
public function __construct(
int $protocolStatus = FastCGI::REQUEST_COMPLETE,
int $appStatus = 0,
string $reserved = ''
) {
$this->type = FastCGI::END_REQUEST;
$this->protocolStatus = $protocolStatus;
$this->appStatus = $appStatus;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
public function getAppStatus(): int
{
return $this->appStatus;
}
public function getProtocolStatus(): int
{
return $this->protocolStatus;
}
protected static function unpackPayload($self, string $data): void
{
[
$self->appStatus,
$self->protocolStatus,
$self->reserved1
] = array_values(unpack('NappStatus/CprotocolStatus/a3reserved', $data));
}
protected function packPayload(): string
{
return pack(
'NCa3',
$this->appStatus,
$this->protocolStatus,
$this->reserved1
);
}
}
@swoole-src/library/core/FastCGI/Record/GetValues.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
class GetValues extends Params
{
public function __construct(array $keys = [])
{
parent::__construct(array_fill_keys($keys, ''));
$this->type = FastCGI::GET_VALUES;
}
}
@swoole-src/library/core/FastCGI/Record/GetValuesResult.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
class GetValuesResult extends Params
{
public function __construct(array $values = [])
{
parent::__construct($values);
$this->type = FastCGI::GET_VALUES_RESULT;
}
}
@swoole-src/library/core/FastCGI/Record/Stdin.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class Stdin extends Record
{
public function __construct(string $contentData = '')
{
$this->type = FastCGI::STDIN;
$this->setContentData($contentData);
}
}
@swoole-src/library/core/FastCGI/Record/Stdout.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class Stdout extends Record
{
public function __construct(string $contentData = '')
{
$this->type = FastCGI::STDOUT;
$this->setContentData($contentData);
}
}
@swoole-src/library/core/FastCGI/Record/Stderr.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class Stderr extends Record
{
public function __construct(string $contentData = '')
{
$this->type = FastCGI::STDERR;
$this->setContentData($contentData);
}
}
@swoole-src/library/core/FastCGI/Record/UnknownType.php
declare(strict_types=1);
namespace Swoole\FastCGI\Record;
use Swoole\FastCGI;
use Swoole\FastCGI\Record;
class UnknownType extends Record
{
protected $type1;
protected $reserved1;
public function __construct(int $type = 0, string $reserved = '')
{
$this->type = FastCGI::UNKNOWN_TYPE;
$this->type1 = $type;
$this->reserved1 = $reserved;
$this->setContentData($this->packPayload());
}
public function getUnrecognizedType(): int
{
return $this->type1;
}
public static function unpackPayload($self, string $data): void
{
[$self->type1, $self->reserved1] = array_values(unpack('Ctype/a7reserved', $data));
}
protected function packPayload(): string
{
return pack(
'Ca7',
$this->type1,
$this->reserved1
);
}
}
@swoole-src/library/core/FastCGI/FrameParser.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use DomainException;
use RuntimeException;
use Swoole\FastCGI;
class FrameParser
{
protected static $classMapping = [
FastCGI::BEGIN_REQUEST => FastCGI\Record\BeginRequest::class,
FastCGI::ABORT_REQUEST => FastCGI\Record\AbortRequest::class,
FastCGI::END_REQUEST => FastCGI\Record\EndRequest::class,
FastCGI::PARAMS => FastCGI\Record\Params::class,
FastCGI::STDIN => FastCGI\Record\Stdin::class,
FastCGI::STDOUT => FastCGI\Record\Stdout::class,
FastCGI::STDERR => FastCGI\Record\Stderr::class,
FastCGI::DATA => FastCGI\Record\Data::class,
FastCGI::GET_VALUES => FastCGI\Record\GetValues::class,
FastCGI::GET_VALUES_RESULT => FastCGI\Record\GetValuesResult::class,
FastCGI::UNKNOWN_TYPE => FastCGI\Record\UnknownType::class,
];
public static function hasFrame(string $buffer): bool
{
$bufferLength = strlen($buffer);
if ($bufferLength < FastCGI::HEADER_LEN) {
return false;
}
$fastInfo = unpack(FastCGI::HEADER_FORMAT, $buffer);
if ($bufferLength < FastCGI::HEADER_LEN + $fastInfo['contentLength'] + $fastInfo['paddingLength']) {
return false;
}
return true;
}
public static function parseFrame(string &$buffer): Record
{
$bufferLength = strlen($buffer);
if ($bufferLength < FastCGI::HEADER_LEN) {
throw new RuntimeException('Not enough data in the buffer to parse');
}
$recordHeader = unpack(FastCGI::HEADER_FORMAT, $buffer);
$recordType = $recordHeader['type'];
if (!isset(self::$classMapping[$recordType])) {
throw new DomainException("Invalid FastCGI record type {$recordType} received");
}
$className = self::$classMapping[$recordType];
$record = $className::unpack($buffer);
$offset = FastCGI::HEADER_LEN + $record->getContentLength() + $record->getPaddingLength();
$buffer = substr($buffer, $offset);
return $record;
}
}
@swoole-src/library/core/FastCGI/Message.php
declare(strict_types=1);
namespace Swoole\FastCGI;
class Message
{
protected $params = [];
protected $body = '';
protected $error = '';
public function getParam(string $name): ?string
{
return $this->params[$name] ?? null;
}
public function withParam(string $name, string $value): self
{
$this->params[$name] = $value;
return $this;
}
public function withoutParam(string $name): self
{
unset($this->params[$name]);
return $this;
}
public function getParams(): array
{
return $this->params;
}
public function withParams(array $params): self
{
$this->params = $params;
return $this;
}
public function withAddedParams(array $params): self
{
$this->params = $params + $this->params;
return $this;
}
public function getBody(): string
{
return $this->body;
}
public function withBody($body): self
{
$this->body = (string) $body;
return $this;
}
public function getError(): string
{
return $this->error;
}
public function withError(string $error): self
{
$this->error = $error;
return $this;
}
}
@swoole-src/library/core/FastCGI/Request.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use Swoole\FastCGI;
use Swoole\FastCGI\Record\BeginRequest;
use Swoole\FastCGI\Record\Params;
use Swoole\FastCGI\Record\Stdin;
class Request extends Message
{
protected $keepConn = false;
public function __toString(): string
{
$body = $this->getBody();
$beginRequestFrame = new BeginRequest(FastCGI::RESPONDER, ($this->keepConn ? FastCGI::KEEP_CONN : 0));
$paramsFrame = new Params($this->getParams());
$paramsEofFrame = new Params();
if (empty($body)) {
$message = "{$beginRequestFrame}{$paramsFrame}{$paramsEofFrame}}";
} else {
$stdinList = [];
while (true) {
$stdinList[] = $stdin = new Stdin($body);
$stdinLength = $stdin->getContentLength();
if ($stdinLength === strlen($body)) {
break;
}
$body = substr($body, $stdinLength);
}
$stdinList[] = new Stdin();
$stdin = implode($stdinList);
$message = "{$beginRequestFrame}{$paramsFrame}{$paramsEofFrame}{$stdin}}";
}
return $message;
}
public function getKeepConn(): bool
{
return $this->keepConn;
}
public function withKeepConn(bool $keepConn): self
{
$this->keepConn = $keepConn;
return $this;
}
}
@swoole-src/library/core/FastCGI/Response.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use InvalidArgumentException;
use Swoole\FastCGI\Record\EndRequest;
use Swoole\FastCGI\Record\Stderr;
use Swoole\FastCGI\Record\Stdout;
class Response extends Message
{
public function __construct(array $records = [])
{
if (!static::verify($records)) {
throw new InvalidArgumentException('Bad records');
}
$body = '';
$error = '';
foreach ($records as $record) {
if ($record instanceof Stdout) {
if ($record->getContentLength() > 0) {
$body .= $record->getContentData();
}
} elseif ($record instanceof Stderr) {
if ($record->getContentLength() > 0) {
$error .= $record->getContentData();
}
}
}
$this->withBody($body)->withError($error);
}
public static function verify(array $records): bool
{
return !empty($records) && $records[count($records) - 1] instanceof EndRequest;
}
}
@swoole-src/library/core/FastCGI/HttpRequest.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use InvalidArgumentException;
class HttpRequest extends Request
{
protected $params = [
'REQUEST_SCHEME' => 'http',
'REQUEST_METHOD' => 'GET',
'DOCUMENT_ROOT' => '',
'SCRIPT_FILENAME' => '',
'SCRIPT_NAME' => '',
'DOCUMENT_URI' => '/',
'REQUEST_URI' => '/',
'QUERY_STRING' => '',
'CONTENT_TYPE' => 'text/plain',
'CONTENT_LENGTH' => '0',
'GATEWAY_INTERFACE' => 'CGI/1.1',
'SERVER_PROTOCOL' => 'HTTP/1.1',
'SERVER_SOFTWARE' => 'swoole/' . SWOOLE_VERSION,
'REMOTE_ADDR' => 'unknown',
'REMOTE_PORT' => '0',
'SERVER_ADDR' => 'unknown',
'SERVER_PORT' => '0',
'SERVER_NAME' => 'Swoole',
'REDIRECT_STATUS' => '200',
];
public function getScheme(): ?string
{
return $this->params['REQUEST_SCHEME'] ?? null;
}
public function withScheme(string $scheme): self
{
$this->params['REQUEST_SCHEME'] = $scheme;
return $this;
}
public function withoutScheme(): void
{
unset($this->params['REQUEST_SCHEME']);
}
public function getMethod(): ?string
{
return $this->params['REQUEST_METHOD'] ?? null;
}
public function withMethod(string $method): self
{
$this->params['REQUEST_METHOD'] = $method;
return $this;
}
public function withoutMethod(): void
{
unset($this->params['REQUEST_METHOD']);
}
public function getDocumentRoot(): ?string
{
return $this->params['DOCUMENT_ROOT'] ?? null;
}
public function withDocumentRoot(string $documentRoot): self
{
$this->params['DOCUMENT_ROOT'] = $documentRoot;
return $this;
}
public function withoutDocumentRoot(): void
{
unset($this->params['DOCUMENT_ROOT']);
}
public function getScriptFilename(): ?string
{
return $this->params['SCRIPT_FILENAME'] ?? null;
}
public function withScriptFilename(string $scriptFilename): self
{
$this->params['SCRIPT_FILENAME'] = $scriptFilename;
return $this;
}
public function withoutScriptFilename(): void
{
unset($this->params['SCRIPT_FILENAME']);
}
public function getScriptName(): ?string
{
return $this->params['SCRIPT_NAME'] ?? null;
}
public function withScriptName(string $scriptName): self
{
$this->params['SCRIPT_NAME'] = $scriptName;
return $this;
}
public function withoutScriptName(): void
{
unset($this->params['SCRIPT_NAME']);
}
public function withUri(string $uri): self
{
$info = parse_url($uri);
return $this->withRequestUri($uri)
->withDocumentUri($info['path'] ?? '')
->withQueryString($info['query'] ?? '');
}
public function getDocumentUri(): ?string
{
return $this->params['DOCUMENT_URI'] ?? null;
}
public function withDocumentUri(string $documentUri): self
{
$this->params['DOCUMENT_URI'] = $documentUri;
return $this;
}
public function withoutDocumentUri(): void
{
unset($this->params['DOCUMENT_URI']);
}
public function getRequestUri(): ?string
{
return $this->params['REQUEST_URI'] ?? null;
}
public function withRequestUri(string $requestUri): self
{
$this->params['REQUEST_URI'] = $requestUri;
return $this;
}
public function withoutRequestUri(): void
{
unset($this->params['REQUEST_URI']);
}
public function withQuery($query): self
{
if (is_array($query)) {
$query = http_build_query($query);
}
return $this->withQueryString($query);
}
public function getQueryString(): ?string
{
return $this->params['QUERY_STRING'] ?? null;
}
public function withQueryString(string $queryString): self
{
$this->params['QUERY_STRING'] = $queryString;
return $this;
}
public function withoutQueryString(): void
{
unset($this->params['QUERY_STRING']);
}
public function getContentType(): ?string
{
return $this->params['CONTENT_TYPE'] ?? null;
}
public function withContentType(string $contentType): self
{
$this->params['CONTENT_TYPE'] = $contentType;
return $this;
}
public function withoutContentType(): void
{
unset($this->params['CONTENT_TYPE']);
}
public function getContentLength(): ?int
{
return isset($this->params['CONTENT_LENGTH']) ? (int) $this->params['CONTENT_LENGTH'] : null;
}
public function withContentLength(int $contentLength): self
{
$this->params['CONTENT_LENGTH'] = (string) $contentLength;
return $this;
}
public function withoutContentLength(): void
{
unset($this->params['CONTENT_LENGTH']);
}
public function getGatewayInterface(): ?string
{
return $this->params['GATEWAY_INTERFACE'] ?? null;
}
public function withGatewayInterface(string $gatewayInterface): self
{
$this->params['GATEWAY_INTERFACE'] = $gatewayInterface;
return $this;
}
public function withoutGatewayInterface(): void
{
unset($this->params['GATEWAY_INTERFACE']);
}
public function getServerProtocol(): ?string
{
return $this->params['SERVER_PROTOCOL'] ?? null;
}
public function withServerProtocol(string $serverProtocol): self
{
$this->params['SERVER_PROTOCOL'] = $serverProtocol;
return $this;
}
public function withoutServerProtocol(): void
{
unset($this->params['SERVER_PROTOCOL']);
}
public function withProtocolVersion(string $protocolVersion): self
{
if (!is_numeric($protocolVersion)) {
throw new InvalidArgumentException('Protocol version must be numeric');
}
$this->params['SERVER_PROTOCOL'] = "HTTP/{$protocolVersion}";
return $this;
}
public function getServerSoftware(): ?string
{
return $this->params['SERVER_SOFTWARE'] ?? null;
}
public function withServerSoftware(string $serverSoftware): self
{
$this->params['SERVER_SOFTWARE'] = $serverSoftware;
return $this;
}
public function withoutServerSoftware(): void
{
unset($this->params['SERVER_SOFTWARE']);
}
public function getRemoteAddr(): ?string
{
return $this->params['REMOTE_ADDR'] ?? null;
}
public function withRemoteAddr(string $remoteAddr): self
{
$this->params['REMOTE_ADDR'] = $remoteAddr;
return $this;
}
public function withoutRemoteAddr(): void
{
unset($this->params['REMOTE_ADDR']);
}
public function getRemotePort(): ?int
{
return isset($this->params['REMOTE_PORT']) ? (int) $this->params['REMOTE_PORT'] : null;
}
public function withRemotePort(int $remotePort): self
{
$this->params['REMOTE_PORT'] = (string) $remotePort;
return $this;
}
public function withoutRemotePort(): void
{
unset($this->params['REMOTE_PORT']);
}
public function getServerAddr(): ?string
{
return $this->params['SERVER_ADDR'] ?? null;
}
public function withServerAddr(string $serverAddr): self
{
$this->params['SERVER_ADDR'] = $serverAddr;
return $this;
}
public function withoutServerAddr(): void
{
unset($this->params['SERVER_ADDR']);
}
public function getServerPort(): ?int
{
return isset($this->params['SERVER_PORT']) ? (int) $this->params['SERVER_PORT'] : null;
}
public function withServerPort(int $serverPort): self
{
$this->params['SERVER_PORT'] = (string) $serverPort;
return $this;
}
public function withoutServerPort(): void
{
unset($this->params['SERVER_PORT']);
}
public function getServerName(): ?string
{
return $this->params['SERVER_NAME'] ?? null;
}
public function withServerName(string $serverName): self
{
$this->params['SERVER_NAME'] = $serverName;
return $this;
}
public function withoutServerName(): void
{
unset($this->params['SERVER_NAME']);
}
public function getRedirectStatus(): ?string
{
return $this->params['REDIRECT_STATUS'] ?? null;
}
public function withRedirectStatus(string $redirectStatus): self
{
$this->params['REDIRECT_STATUS'] = $redirectStatus;
return $this;
}
public function withoutRedirectStatus(): void
{
unset($this->params['REDIRECT_STATUS']);
}
public function getHeader(string $name): ?string
{
return $this->params[static::convertHeaderNameToParamName($name)] ?? null;
}
public function withHeader(string $name, string $value): self
{
$this->params[static::convertHeaderNameToParamName($name)] = $value;
return $this;
}
public function withoutHeader(string $name): void
{
unset($this->params[static::convertHeaderNameToParamName($name)]);
}
public function getHeaders(): array
{
$headers = [];
foreach ($this->params as $name => $value) {
if (strpos($name, 'HTTP_') === 0) {
$headers[static::convertParamNameToHeaderName($name)] = $value;
}
}
return $headers;
}
public function withHeaders(array $headers): self
{
foreach ($headers as $name => $value) {
$this->withHeader($name, $value);
}
return $this;
}
public function withBody($body): Message
{
if (is_array($body)) {
$body = http_build_query($body);
$this->withContentType('application/x-www-form-urlencoded');
}
parent::withBody($body);
return $this->withContentLength(strlen($body));
}
protected static function convertHeaderNameToParamName(string $name)
{
return 'HTTP_' . str_replace('-', '_', strtoupper($name));
}
protected static function convertParamNameToHeaderName(string $name)
{
return ucwords(str_replace('_', '-', substr($name, strlen('HTTP_'))), '-');
}
}
@swoole-src/library/core/FastCGI/HttpResponse.php
declare(strict_types=1);
namespace Swoole\FastCGI;
use Swoole\Http\Status;
class HttpResponse extends Response
{
protected $statusCode;
protected $reasonPhrase;
protected $headers = [];
protected $headersMap = [];
protected $setCookieHeaderLines = [];
public function __construct(array $records = [])
{
parent::__construct($records);
$body = (string) $this->getBody();
if (strlen($body) === 0) {
return;
}
$array = explode("\r\n\r\n", $body, 2);
if (count($array) != 2) {
$this->withStatusCode(Status::BAD_GATEWAY)->withReasonPhrase('Invalid FastCGI Response')->withError($body);
return;
}
$headers = explode("\r\n", $array[0]);
$body = $array[1];
foreach ($headers as $header) {
$array = explode(':', $header, 2);
if (count($array) != 2) {
continue;
}
$name = trim($array[0]);
$value = trim($array[1]);
if (strcasecmp($name, 'Status') === 0) {
$array = explode(' ', $value, 2);
$statusCode = $array[0];
$reasonPhrase = $array[1] ?? null;
} elseif (strcasecmp($name, 'Set-Cookie') === 0) {
$this->withSetCookieHeaderLine($value);
} else {
$this->withHeader($name, $value);
}
}
$statusCode = (int) ($statusCode ?? Status::OK);
$reasonPhrase = (string) ($reasonPhrase ?? Status::getReasonPhrase($statusCode));
$this->withStatusCode($statusCode)->withReasonPhrase($reasonPhrase);
$this->withBody($body);
}
public function getStatusCode(): int
{
return $this->statusCode;
}
public function withStatusCode(int $statusCode): self
{
$this->statusCode = $statusCode;
return $this;
}
public function getReasonPhrase(): string
{
return $this->reasonPhrase;
}
public function withReasonPhrase(string $reasonPhrase): self
{
$this->reasonPhrase = $reasonPhrase;
return $this;
}
public function getHeader(string $name): ?string
{
$name = $this->headersMap[strtolower($name)] ?? null;
return $name ? $this->headers[$name] : null;
}
public function getHeaders(): array
{
return $this->headers;
}
public function withHeader(string $name, string $value): self
{
$this->headers[$name] = $value;
$this->headersMap[strtolower($name)] = $name;
return $this;
}
public function withHeaders(array $headers): self
{
foreach ($headers as $name => $value) {
$this->withHeader($name, $value);
}
return $this;
}
public function getSetCookieHeaderLines(): array
{
return $this->setCookieHeaderLines;
}
public function withSetCookieHeaderLine(string $value): self
{
$this->setCookieHeaderLines[] = $value;
return $this;
}
}
@swoole-src/library/core/Coroutine/FastCGI/Client.php
declare(strict_types=1);
namespace Swoole\Coroutine\FastCGI;
use InvalidArgumentException;
use Swoole\Coroutine\FastCGI\Client\Exception;
use Swoole\Coroutine\Socket;
use Swoole\FastCGI\FrameParser;
use Swoole\FastCGI\HttpRequest;
use Swoole\FastCGI\HttpResponse;
use Swoole\FastCGI\Record\EndRequest;
use Swoole\FastCGI\Request;
use Swoole\FastCGI\Response;
class Client
{
protected $af;
protected $host;
protected $port;
protected $ssl;
protected $socket;
public function __construct(string $host, int $port = 0, bool $ssl = false)
{
if (stripos($host, 'unix:/') === 0) {
$this->af = AF_UNIX;
$host = '/' . ltrim(substr($host, strlen('unix:/')), '/');
$port = 0;
} elseif (strpos($host, ':') !== false) {
$this->af = AF_INET6;
} else {
$this->af = AF_INET;
}
$this->host = $host;
$this->port = $port;
$this->ssl = $ssl;
}
public function execute(Request $request, float $timeout = -1): Response
{
if (!$this->socket) {
$this->socket = $socket = new Socket($this->af, SOCK_STREAM, IPPROTO_IP);
$socket->setProtocol([
'open_ssl' => $this->ssl,
'open_fastcgi_protocol' => true,
]);
if (!$socket->connect($this->host, $this->port, $timeout)) {
$this->ioException();
}
} else {
$socket = $this->socket;
}
$sendData = (string) $request;
if ($socket->sendAll($sendData) !== strlen($sendData)) {
$this->ioException();
}
$records = [];
while (true) {
if (SWOOLE_VERSION_ID < 40500) {
$recvData = '';
while (true) {
$tmp = $socket->recv(8192, $timeout);
if (!$tmp) {
if ($tmp === '') {
$this->ioException(SOCKET_ECONNRESET);
}
$this->ioException();
}
$recvData .= $tmp;
if (FrameParser::hasFrame($recvData)) {
break;
}
}
} else {
$recvData = $socket->recvPacket($timeout);
if (!$recvData) {
if ($recvData === '') {
$this->ioException(SOCKET_ECONNRESET);
}
$this->ioException();
}
if (!FrameParser::hasFrame($recvData)) {
$this->ioException(SOCKET_EPROTO);
}
}
do {
$records[] = $record = FrameParser::parseFrame($recvData);
} while (strlen($recvData) !== 0);
if ($record instanceof EndRequest) {
if (!$request->getKeepConn()) {
$this->socket->close();
$this->socket = null;
}
switch (true) {
case $request instanceof HttpRequest:
return new HttpResponse($records);
default:
return new Response($records);
}
}
}
exit(1);
}
public static function parseUrl(string $url): array
{
$url = parse_url($url);
$host = $url['host'] ?? '';
$port = $url['port'] ?? 0;
if (empty($host)) {
$host = $url['path'] ?? '';
if (empty($host)) {
throw new InvalidArgumentException('Invalid url');
}
$host = "unix:/{$host}";
}
return [$host, $port];
}
public static function call(string $url, string $path, $data = '', float $timeout = -1): string
{
$client = new Client(...static::parseUrl($url));
$pathInfo = parse_url($path);
$path = $pathInfo['path'] ?? '';
$root = dirname($path);
$scriptName = '/' . basename($path);
$documentUri = $scriptName;
$query = $pathInfo['query'] ?? '';
$requestUri = $query ? "{$documentUri}?{$query}" : $documentUri;
$request = new HttpRequest();
$request->withDocumentRoot($root)
->withScriptFilename($path)
->withScriptName($documentUri)
->withDocumentUri($documentUri)
->withRequestUri($requestUri)
->withQueryString($query)
->withBody($data)
->withMethod($request->getContentLength() === 0 ? 'GET' : 'POST');
$response = $client->execute($request, $timeout);
return $response->getBody();
}
protected function ioException(?int $errno = null): void
{
$socket = $this->socket;
if ($errno !== null) {
$socket->errCode = $errno;
$socket->errMsg = swoole_strerror($errno);
}
$socket->close();
$this->socket = null;
throw new Exception($socket->errMsg, $socket->errCode);
}
}
@swoole-src/library/core/Coroutine/FastCGI/Client/Exception.php
declare(strict_types=1);
namespace Swoole\Coroutine\FastCGI\Client;
class Exception extends \Swoole\Exception
{
}
@swoole-src/library/core/Coroutine/FastCGI/Proxy.php
declare(strict_types=1);
namespace Swoole\Coroutine\FastCGI;
use InvalidArgumentException;
use Swoole\FastCGI\HttpRequest;
use Swoole\FastCGI\HttpResponse;
use Swoole\Http;
class Proxy
{
protected $host;
protected $port;
protected $timeout = -1;
protected $documentRoot;
protected $https = false;
protected $index = 'index.php';
protected $params = [];
protected $staticFileFilter;
public function __construct(string $url, string $documentRoot = '/')
{
[$this->host, $this->port] = Client::parseUrl($url);
$this->documentRoot = $documentRoot;
$this->staticFileFilter = [$this, 'staticFileFiltrate'];
}
public function withTimeout(float $timeout): self
{
$this->timeout = $timeout;
return $this;
}
public function withHttps(bool $https): self
{
$this->https = $https;
return $this;
}
public function withIndex(string $index): self
{
$this->index = $index;
return $this;
}
public function getParam(string $name): ?string
{
return $this->params[$name] ?? null;
}
public function withParam(string $name, string $value): self
{
$this->params[$name] = $value;
return $this;
}
public function withoutParam(string $name): self
{
unset($this->params[$name]);
return $this;
}
public function getParams(): array
{
return $this->params;
}
public function withParams(array $params): self
{
$this->params = $params;
return $this;
}
public function withAddedParams(array $params): self
{
$this->params = $params + $this->params;
return $this;
}
public function withStaticFileFilter(?callable $filter): self
{
$this->staticFileFilter = $filter;
return $this;
}
public function translateRequest($userRequest): HttpRequest
{
$request = new HttpRequest();
if ($userRequest instanceof \Swoole\Http\Request) {
$server = $userRequest->server;
$headers = $userRequest->header;
$pathInfo = $userRequest->server['path_info'];
$pathInfo = '/' . (ltrim($pathInfo, '/'));
if (strlen($this->index) !== 0) {
$extension = pathinfo($pathInfo, PATHINFO_EXTENSION);
if (empty($extension)) {
$pathInfo = rtrim($pathInfo, '/') . '/' . $this->index;
}
}
$requestUri = $scriptName = $documentUri = $server['request_uri'];
$queryString = $server['query_string'] ?? '';
if (strlen($queryString) !== 0) {
$requestUri .= "?{$server['query_string']}";
}
$request
->withDocumentRoot($this->documentRoot)
->withScriptFilename($this->documentRoot . $pathInfo)
->withScriptName($scriptName)
->withDocumentUri($documentUri)
->withServerProtocol($server['server_protocol'])
->withServerAddr('127.0.0.1')
->withServerPort($server['server_port'])
->withRemoteAddr($server['remote_addr'])
->withRemotePort($server['remote_port'])
->withMethod($server['request_method'])
->withRequestUri($requestUri)
->withQueryString($queryString)
->withContentType($headers['content-type'] ?? '')
->withContentLength((int) ($headers['content-length'] ?? 0))
->withHeaders($headers)
->withBody($userRequest->rawContent())
->withAddedParams($this->params);
if ($this->https) {
$request->withParam('HTTPS', '1');
}
} else {
throw new InvalidArgumentException('Not supported on ' . get_class($userRequest));
}
return $request;
}
public function translateResponse(HttpResponse $response, $userResponse): void
{
if ($userResponse instanceof \Swoole\Http\Response) {
$userResponse->status($response->getStatusCode(), $response->getReasonPhrase());
$userResponse->header = $response->getHeaders();
$userResponse->cookie = $response->getSetCookieHeaderLines();
$userResponse->end($response->getBody());
} else {
throw new InvalidArgumentException('Not supported on ' . get_class($userResponse));
}
}
public function pass($userRequest, $userResponse): void
{
if (!($userRequest instanceof HttpRequest)) {
$request = $this->translateRequest($userRequest);
} else {
$request = $userRequest;
}
unset($userRequest);
if ($this->staticFileFilter) {
$filter = $this->staticFileFilter;
if ($filter($request, $userResponse)) {
return;
}
}
$client = new Client($this->host, $this->port);
$response = $client->execute($request, $this->timeout);
$this->translateResponse($response, $userResponse);
}
public function staticFileFiltrate(HttpRequest $request, $userResponse): bool
{
if ($userResponse instanceof \Swoole\Http\Response) {
$extension = pathinfo($request->getScriptFilename(), PATHINFO_EXTENSION);
if ($extension !== 'php') {
$realPath = realpath($request->getScriptFilename());
if (!$realPath || strpos($realPath, $this->documentRoot) !== 0 || !is_file($realPath)) {
$userResponse->status(Http\Status::NOT_FOUND);
} else {
$userResponse->sendfile($realPath);
}
return true;
}
return false;
}
throw new InvalidArgumentException('Not supported on ' . get_class($userResponse));
}
}
@swoole-src/library/core/Process/Manager.php
declare(strict_types=1);
namespace Swoole\Process;
use Swoole\Constant;
use function Swoole\Coroutine\run;
class Manager
{
protected $pool;
protected $ipcType = SWOOLE_IPC_NONE;
protected $msgQueueKey = 0;
protected $startFuncMap = [];
public function __construct(int $ipcType = SWOOLE_IPC_NONE, int $msgQueueKey = 0)
{
$this->setIPCType($ipcType)->setMsgQueueKey($msgQueueKey);
}
public function add(callable $func, bool $enableCoroutine = false): self
{
$this->addBatch(1, $func, $enableCoroutine);
return $this;
}
public function addBatch(int $workerNum, callable $func, bool $enableCoroutine = false): self
{
for ($i = 0; $i < $workerNum; $i++) {
$this->startFuncMap[] = [$func, $enableCoroutine];
}
return $this;
}
public function start(): void
{
$this->pool = new Pool(count($this->startFuncMap), $this->ipcType, $this->msgQueueKey, false);
$this->pool->on(Constant::EVENT_WORKER_START, function (Pool $pool, int $workerId) {
[$func, $enableCoroutine] = $this->startFuncMap[$workerId];
if ($enableCoroutine) {
run($func, $pool, $workerId);
} else {
$func($pool, $workerId);
}
});
$this->pool->start();
}
public function setIPCType(int $ipcType): self
{
$this->ipcType = $ipcType;
return $this;
}
public function getIPCType(): int
{
return $this->ipcType;
}
public function setMsgQueueKey(int $msgQueueKey): self
{
$this->msgQueueKey = $msgQueueKey;
return $this;
}
public function getMsgQueueKey(): int
{
return $this->msgQueueKey;
}
}
@swoole-src/library/core/Server/Admin.php
declare(strict_types=1);
namespace Swoole\Server;
use Reflection;
use ReflectionClass;
use ReflectionExtension;
use ReflectionFunction;
use ReflectionMethod;
use Swoole\Coroutine;
use Swoole\Http\Request;
use Swoole\Http\Response;
use Swoole\Server;
use Swoole\StringObject;
use Swoole\Timer;
class Admin
{
public const SIZE_OF_ZVAL = 16;
public const SIZE_OF_ZEND_STRING = 32;
public const SIZE_OF_ZEND_OBJECT = 56;
public const SIZE_OF_ZEND_ARRAY = 56;
private static $map = [
'reactor' => SWOOLE_SERVER_COMMAND_REACTOR_THREAD,
'reactor_thread' => SWOOLE_SERVER_COMMAND_REACTOR_THREAD,
'worker' => SWOOLE_SERVER_COMMAND_EVENT_WORKER,
'event_worker' => SWOOLE_SERVER_COMMAND_EVENT_WORKER,
'task' => SWOOLE_SERVER_COMMAND_TASK_WORKER,
'task_worker' => SWOOLE_SERVER_COMMAND_TASK_WORKER,
];
private static $allList = [
'all',
'all_reactor',
'all_reactor_thread',
'all_worker',
'all_event_worker',
'all_task',
'all_task_worker',
'specific',
];
private static $postMethodList = [
'server_reload',
'server_shutdown',
'close_session',
];
private static $accessToken = '';
public static function init(Server $server)
{
$accepted_process_types = SWOOLE_SERVER_COMMAND_MASTER |
SWOOLE_SERVER_COMMAND_MANAGER |
SWOOLE_SERVER_COMMAND_EVENT_WORKER |
SWOOLE_SERVER_COMMAND_TASK_WORKER;
$server->addCommand(
'server_reload',
$accepted_process_types,
function ($server, $msg) {
$server->reload();
return self::json('Operation succeeded');
}
);
$server->addCommand(
'server_shutdown',
$accepted_process_types,
function ($server, $msg) {
$server->shutdown();
}
);
$server->addCommand(
'coroutine_stats',
$accepted_process_types,
function ($server, $msg) {
return self::json(Coroutine::stats());
}
);
$server->addCommand(
'coroutine_list',
$accepted_process_types,
function ($server, $msg) {
return self::json(iterator_to_array(Coroutine::list()));
}
);
$server->addCommand(
'coroutine_bt',
$accepted_process_types,
function ($server, $msg) {
$json = json_decode($msg);
$cid = empty($json->cid) ? 0 : intval($json->cid);
$bt = Coroutine::getBackTrace($cid);
if ($bt === false) {
return self::json("Coroutine#{$cid} not exists", 4004);
}
return self::json($bt);
}
);
$server->addCommand(
'server_stats',
$accepted_process_types,
function ($server, $msg) {
return self::json($server->stats());
}
);
$server->addCommand(
'server_setting',
$accepted_process_types,
function (Server $server, $msg) {
$setting = $server->setting;
$setting['mode'] = $server->mode;
$setting['host'] = $server->host;
$setting['port'] = $server->port;
$setting['master_pid'] = $server->master_pid;
$setting['manager_pid'] = $server->manager_pid;
return self::json($setting);
}
);
$server->addCommand(
'get_client_info',
$accepted_process_types,
function (Server $server, $msg) {
$json = json_decode($msg, true);
if (empty($json['session_id'])) {
return self::json('require session_id', 4003);
}
return self::json($server->getClientInfo(intval($json['session_id'])));
}
);
$server->addCommand('close_session', $accepted_process_types, [__CLASS__, 'handlerCloseSession']);
$server->addCommand('get_version_info', $accepted_process_types, [__CLASS__, 'handlerGetVersionInfo']);
$server->addCommand('get_worker_info', $accepted_process_types, [__CLASS__, 'handlerGetWorkerInfo']);
$server->addCommand('get_timer_list', $accepted_process_types, [__CLASS__, 'handlerGetTimerList']);
$server->addCommand('get_coroutine_list', $accepted_process_types, [__CLASS__, 'handlerGetCoroutineList']);
$server->addCommand('get_objects', $accepted_process_types, [__CLASS__, 'handlerGetObjects']);
$server->addCommand('get_class_info', $accepted_process_types, [__CLASS__, 'handlerGetClassInfo']);
$server->addCommand('get_function_info', $accepted_process_types, [__CLASS__, 'handlerGetFunctionInfo']);
$server->addCommand('get_object_by_handle', $accepted_process_types, [__CLASS__, 'handlerGetObjectByHandle']);
$server->addCommand('get_server_cpu_usage', $accepted_process_types, [__CLASS__, 'handlerGetServerCpuUsage']);
$server->addCommand(
'get_server_memory_usage',
$accepted_process_types,
[__CLASS__, 'handlerGetServerMemoryUsage']
);
$server->addCommand(
'get_static_property_value',
$accepted_process_types,
[__CLASS__, 'handlerGetStaticPropertyValue']
);
$server->addCommand(
'get_defined_functions',
$accepted_process_types,
[__CLASS__, 'handlerGetDefinedFunctions']
);
$server->addCommand('get_declared_classes', $accepted_process_types, [__CLASS__, 'handlerGetDeclaredClasses']);
$server->addCommand(
'gc_status',
$accepted_process_types,
function ($server, $msg) {
$status = function_exists('gc_status') ? gc_status() : [];
return self::json($status);
}
);
if (extension_loaded('opcache')) {
$server->addCommand(
'opcache_status',
$accepted_process_types,
function ($server, $msg) {
return self::json(opcache_get_status(true));
}
);
}
$server->addCommand(
'getpid',
$accepted_process_types,
function ($server, $msg) {
return self::json(['pid' => posix_getpid()]);
}
);
$server->addCommand(
'memory_usage',
$accepted_process_types,
function ($server, $msg) {
return self::json([
'usage' => memory_get_usage(),
'real_usage' => memory_get_usage(true),
]);
}
);
$server->addCommand(
'get_included_files',
$accepted_process_types,
function ($server, $msg) {
return self::json(['files' => get_included_files()]);
}
);
$server->addCommand('get_resources', $accepted_process_types, [__CLASS__, 'handlerGetResources']);
$server->addCommand(
'get_defined_constants',
$accepted_process_types,
function ($server, $msg) {
$constants = get_defined_constants();
foreach ($constants as $k => $c) {
if (is_resource($c)) {
unset($constants[$k]);
}
}
unset($constants['NULL'], $constants['NAN'], $constants['INF']);
return self::json($constants);
}
);
$server->addCommand(
'get_loaded_extensions',
$accepted_process_types,
function ($server, $msg) {
$extensions = get_loaded_extensions();
$list = [];
foreach ($extensions as $key => $extension) {
$ext = new ReflectionExtension($extension);
$list[$key] = [
'id' => ++$key,
'name' => $extension,
'version' => $ext->getVersion() ?? '',
];
}
return self::json($list);
}
);
$server->addCommand(
'get_declared_interfaces',
$accepted_process_types,
function ($server, $msg) {
return self::json(get_declared_interfaces());
}
);
$server->addCommand(
'get_declared_traits',
$accepted_process_types,
function ($server, $msg) {
return self::json(get_declared_traits());
}
);
$server->addCommand(
'get_included_file_contents',
$accepted_process_types,
function (Server $server, $msg) {
$json = json_decode($msg, true);
if (empty($json['filename'])) {
return self::json('require filename', 4003);
}
if (!file_exists($json['filename'])) {
return self::json("{$json['filename']} not exist", 4004);
}
if (!in_array($json['filename'], get_included_files())) {
return self::json('no permission', 4003);
}
return self::json(file_get_contents($json['filename']));
}
);
$server->addCommand(
'get_globals',
$accepted_process_types,
function ($server, $msg) {
$globals = [];
foreach ($GLOBALS as $key => $item) {
if ($key === 'GLOBALS') {
continue;
}
$type = gettype($item);
$other = [];
if ($type === 'object') {
$other = [
'class_name' => get_class($item),
'object_id' => spl_object_id($item),
'object_hash' => spl_object_hash($item),
];
}
if ($type == 'resource' || $type == 'resource (closed)') {
$item = '';
}
$globals[] = [
'key' => $key,
'value' => $item,
'type' => $type,
'other' => $other,
];
}
return self::json($globals);
}
);
$server->addCommand(
'get_extension_info',
$accepted_process_types,
function (Server $server, $msg) {
$json = json_decode($msg, true);
if (empty($json['extension_name']) || !extension_loaded($json['extension_name'])) {
return self::json('require extension_name', 4004);
}
$ext = new ReflectionExtension($json['extension_name']);
ob_start();
$ext->info();
$info = ob_get_clean();
$constants = $ext->getConstants();
foreach ($constants as $k => $c) {
if (is_resource($c)) {
unset($constants[$k]);
}
}
unset($constants['NULL'], $constants['NAN'], $constants['INF']);
return self::json([
'classes' => $ext->getClassNames(),
'version' => $ext->getVersion(),
'constants' => $constants,
'ini_entries' => $ext->getINIEntries(),
'dependencies' => $ext->getDependencies(),
'functions' => array_keys($ext->getFunctions()),
'info' => trim($info),
]);
}
);
$server->addCommand(
'get_composer_packages',
$accepted_process_types,
function (Server $server, $msg) {
if (!class_exists(\Composer\InstalledVersions::class)) {
return self::json('require composer 2.0', 4003);
}
$list = [];
foreach (['getAllRawData', 'getRawData'] as $method) {
if (!method_exists(\Composer\InstalledVersions::class, $method)) {
continue;
}
$raw_data[] = \Composer\InstalledVersions::$method();
if ($method === 'getAllRawData') {
$raw_data = \Composer\InstalledVersions::$method();
array_shift($raw_data);
}
foreach ($raw_data as $key => $package) {
$key_name = $package['root']['name'];
if ($package['root']['name'] === '__root__' && isset($list['__root__'])) {
$key_name = "__root__{$key}";
}
$package['root']['install_path'] = !empty($package['root']['install_path']) ? realpath($package['root']['install_path']) : '';
$list[$key_name] = $package;
}
break;
}
return self::json($list);
}
);
}
public static function getAccessToken(): string
{
return self::$accessToken;
}
public static function start(Server $server)
{
$admin_server_uri = swoole_string($server->setting['admin_server']);
if ($admin_server_uri->startsWith('unix:/')) {
return swoole_error_log(SWOOLE_LOG_ERROR, "admin_server[{$server->setting['admin_server']}] is not supported");
}
if ($admin_server_uri->contains('@')) {
[$access_name, $access_secret] = $admin_server_uri->split('@', 2)->get(0)->split(':', 2)->toArray();
self::$accessToken = sha1($access_name . $access_secret);
[$host, $port] = $admin_server_uri->split('@', 2)->get(1)->split(':', 2)->toArray();
} else {
[$host, $port] = $admin_server_uri->split(':', 2)->toArray();
}
$admin_server = new Coroutine\Http\Server($host, intval($port));
$admin_server->handle('/api', function (Request $req, Response $resp) use ($server) {
$path_array = swoole_string($req->server['request_uri'])->trim('/')->split('/');
if ($path_array->count() < 2 or $path_array->count() > 3) {
$resp->status(403);
$resp->end(self::json('Bad API path', 4003));
return;
}
$resp->header('Server', 'swoole-admin-server');
$resp->header('Access-Control-Allow-Origin', '*');
$resp->header('Access-Control-Allow-Methods', 'GET, POST, OPTIONS');
$resp->header('Access-Control-Allow-Headers', 'X-ACCESS-TOKEN, X-ADMIN-SERVER-ACCESS-TOKEN');
$method = $req->getMethod();
if ($method === 'OPTIONS') {
return $resp->end();
}
$token = self::getAccessToken();
if (!empty($token)) {
$token_header = $req->header['x-admin-server-access-token'] ?? '';
if ($token_header !== $token) {
$resp->status(403);
$resp->end(self::json('Bad access token', 4003));
return;
}
}
$cmd = $path_array->get(1)->toString();
if (in_array($cmd, self::$postMethodList) && $method != 'POST') {
$resp->status(403);
$resp->end(self::json('Bad request method', 4003));
return;
}
if ($method == 'GET') {
$data = $req->get;
} else {
$data = $req->post;
}
if ($cmd === 'multi') {
$body = json_decode($req->getContent(), true);
if (empty($body) || !is_array($body) || $method != 'POST') {
goto _bad_process;
}
$result = self::handlerMulti($server, $body);
$resp->end(json_encode($result, JSON_INVALID_UTF8_IGNORE));
return;
}
if ($path_array->count() == 2) {
$process = swoole_string('master');
} else {
$process = $path_array->get(2);
}
if ($process->startsWith('master')) {
$process_type = SWOOLE_SERVER_COMMAND_MASTER;
$process_id = 0;
} elseif ($process->startsWith('manager')) {
$process_type = SWOOLE_SERVER_COMMAND_MANAGER;
$process_id = 0;
} elseif ($process->startsWith('all') || $process->equals('specific')) {
if (!in_array($process->toString(), self::$allList)) {
goto _bad_process;
}
$result = self::handlerGetAll($server, $process, $cmd, $data);
$resp->end(self::json($result));
return;
} else {
$array = $process->split('-');
if ($array->count() != 2) {
_bad_process:
$resp->status(403);
$resp->end(self::json('Bad process', 4003));
return;
}
if (!isset(self::$map[$array->get(0)->toString()])) {
goto _bad_process;
}
$process_type = self::$map[$array->get(0)->toString()];
$process_id = intval($array->get(1)->toString());
}
$result = $server->command($cmd, $process_id, intval($process_type), $data, false);
if (!$result) {
$resp->end(json_encode([
'code' => swoole_last_error(),
'data' => swoole_strerror(swoole_last_error()),
]));
} else {
$resp->end($result);
}
});
$admin_server->handle('/', function (Request $req, Response $resp) use ($server) {
$resp->status(404);
});
$server->admin_server = $admin_server;
$admin_server->start();
}
public static function handlerGetResources($server, $msg)
{
$resources = get_resources();
$list = [];
foreach ($resources as $r) {
$info = [
'id' => function_exists('get_resource_id') ? get_resource_id($r) : intval($r),
'type' => get_resource_type($r),
];
if ($info['type'] == 'stream') {
$info['info'] = stream_get_meta_data($r);
}
$list[] = $info;
}
return self::json($list);
}
public static function handlerGetWorkerInfo($server, $msg)
{
$info = [
'id' => $server->getWorkerId(),
'pid' => $server->getWorkerPid(),
'gc_status' => function_exists('gc_status') ? gc_status() : [],
'memory_usage' => memory_get_usage(),
'memory_real_usage' => memory_get_usage(true),
'process_status' => self::getProcessStatus(),
'coroutine_stats' => Coroutine::stats(),
'timer_stats' => Timer::stats(),
];
if (function_exists('swoole_get_vm_status')) {
$info['vm_status'] = swoole_get_vm_status();
}
return self::json($info);
}
public static function handlerCloseSession($server, $msg)
{
$json = json_decode($msg, true);
if (empty($json['session_id'])) {
return self::json('require session_id', 4003);
}
if ($server->close(intval($json['session_id']), !empty($json['force']))) {
return self::json([]);
}
return self::json(['error' => swoole_last_error()], 4004);
}
public static function handlerGetTimerList($server, $msg)
{
$list = [];
foreach (Timer::list() as $timer_id) {
$list[] = [
'id' => $timer_id,
'info' => Timer::info($timer_id),
];
}
return self::json($list);
}
public static function handlerGetCoroutineList($server, $msg)
{
$list = [];
foreach (Coroutine::list() as $cid) {
$list[] = [
'id' => $cid,
'elapsed' => Coroutine::getElapsed($cid),
'stack_usage' => Coroutine::getStackUsage($cid),
'backTrace' => Coroutine::getBackTrace($cid, DEBUG_BACKTRACE_IGNORE_ARGS, 1),
];
}
return self::json($list);
}
public static function handlerGetObjects($server, $msg)
{
if (!function_exists('swoole_get_objects')) {
return self::json(['require ext-swoole_plus'], 5000);
}
$list = [];
$objects = swoole_get_objects();
foreach ($objects as $o) {
$class_name = get_class($o);
$class = new ReflectionClass($class_name);
$filename = $class->getFileName();
$line = $class->getStartLine();
$list[] = [
'id' => spl_object_id($o),
'hash' => spl_object_hash($o),
'class' => $class_name,
'filename' => $filename ?: '',
'line' => $line ?: '',
'memory_size' => self::getObjectMemorySize($o),
];
}
return self::json($list);
}
public static function handlerGetClassInfo($server, $msg)
{
$json = json_decode($msg, true);
if (empty($json['class_name']) && empty($json['interface_name'])) {
return self::json(['error' => 'require class_name or interface_name'], 4004);
}
if (!empty($json['class_name'])) {
if (!class_exists($json['class_name'], false) && !interface_exists($json['class_name'], false)) {
return self::json("{$json['class_name']} not exists", 4003);
}
$name = $json['class_name'];
}
if (!empty($json['interface_name'])) {
if (!interface_exists($json['interface_name'], false)) {
return self::json("{$json['interface_name']} not exists", 4003);
}
$name = $json['interface_name'];
}
$class = new ReflectionClass($name);
$filename = $class->getFileName();
$getTmpConstants = function ($data) {
$tmp = [];
foreach ($data as $k => $v) {
$tmp[] = [
'name' => $k,
'value' => is_array($v) ? var_export($v, true) : $v,
'type' => is_array($v) ? 'detail' : 'default',
];
}
return $tmp;
};
$tmpConstants = $class->getConstants();
$constants = $tmpConstants ? $getTmpConstants($tmpConstants) : [];
$staticProperties = [];
$properties = [];
$tmpProperties = $class->getProperties();
$getTmpProperties = function ($class, $data) {
$static = [];
$noStatic = [];
$defaultProperties = $class->getDefaultProperties();
foreach ($data as $k => $v) {
$name = $v->getName();
$modifiers = Reflection::getModifierNames($v->getModifiers());
if ($v->isStatic()) {
$static[] = [
'name' => $name,
'value' => $defaultProperties[$name],
'modifiers' => implode(' ', $modifiers),
];
} else {
$noStatic[] = [
'name' => $name,
'value' => $defaultProperties[$name],
'modifiers' => implode(' ', $modifiers),
];
}
}
return ['static' => $static, 'no_static' => $noStatic];
};
if ($tmpProperties) {
$tmpProperties = $getTmpProperties($class, $tmpProperties);
$staticProperties = $tmpProperties['static'];
$properties = $tmpProperties['no_static'];
}
$staticMethods = [];
$methods = [];
$tmpStaticMethods = $class->getMethods();
$getTmpMethods = function ($data) {
$static = [];
$noStatic = [];
foreach ($data as $k => $v) {
$name = $v->getName();
$line = $v->getStartLine();
$modifiers = Reflection::getModifierNames($v->getModifiers());
if ($v->isStatic()) {
$static[] = [
'name' => $name,
'line' => $line ?: '',
'modifiers' => implode(' ', $modifiers),
];
} else {
$noStatic[] = [
'name' => $name,
'line' => $line ?: '',
'modifiers' => implode(' ', $modifiers),
];
}
}
return ['static' => $static, 'no_static' => $noStatic];
};
if ($tmpStaticMethods) {
$tmpStaticMethods = $getTmpMethods($tmpStaticMethods);
$staticMethods = $tmpStaticMethods['static'];
$methods = $tmpStaticMethods['no_static'];
}
$tmpParentClass = $class->getParentClass();
$parentClass = $tmpParentClass ? $tmpParentClass->getName() : '';
$tmpInterface = $class->getInterfaceNames();
$interface = $tmpInterface ?? [];
$data = [
'filename' => $filename,
'constants' => $constants,
'staticProperties' => $staticProperties,
'properties' => $properties,
'staticMethods' => $staticMethods,
'methods' => $methods,
'parentClass' => $parentClass,
'interface' => $interface,
];
return self::json($data);
}
public static function handlerGetFunctionInfo($server, $msg)
{
$json = json_decode($msg, true);
$className = $json['class_name'] ?? '';
$functionName = $json['function_name'] ?? '';
if (empty($json) || empty($functionName)) {
return self::json('require function_name', 4004);
}
$isStatic = false;
if (!empty($className)) {
if (!class_exists($className) && !interface_exists($className)) {
return self::json("{$className} not exists", 4004);
}
if (!method_exists($className, $functionName)) {
return self::json("{$className}->{$functionName} not exists", 4004);
}
$ref = new ReflectionMethod($className, $functionName);
$isStatic = $ref->isStatic();
} else {
if (!function_exists($functionName)) {
return self::json("{$functionName} not exists", 4004);
}
$ref = new ReflectionFunction($functionName);
}
$result = [
'filename' => $ref->getFileName(),
'line' => $ref->getStartLine() ?? '',
'num' => $ref->getNumberOfParameters(),
'user_defined' => $ref->isUserDefined(),
'extension' => $ref->getExtensionName(),
'is_static' => $isStatic,
];
$params = $ref->getParameters();
$list = [];
foreach ($params as $param) {
$type = $optional = $default = '';
$paramName = $param->getName();
if ($param->hasType()) {
$reflection = $param->getType();
if ($reflection instanceof \ReflectionUnionType) {
$unionType = [];
foreach ($reflection->getTypes() as $objType) {
$unionType[] = $objType->getName();
}
$type = implode('|', $unionType);
} else {
$type = $reflection->getName();
}
}
if ($param->isOptional() && !$param->isVariadic()) {
if (!$result['user_defined'] && PHP_VERSION_ID < 80000) {
continue;
}
$optional = '?';
if ($param->isDefaultValueAvailable()) {
$value = $param->getDefaultValue();
if (in_array($value, [true, false, null, ''])) {
if ($value === null) {
$value = 'null';
}
if ($value === true) {
$value = 'true';
}
if ($value === false) {
$value = 'false';
}
if ($value === '') {
$value = "''";
}
}
$default = " = {$value}";
}
}
$isPassedByReference = $param->isPassedByReference() ? '&' : '';
$isVariadic = $param->isVariadic() ? '...' : '';
$option = "{$optional}{$type} {$isPassedByReference}{$isVariadic}";
$param = "\${$paramName}{$default}";
$list[] = [
'optional' => $optional,
'type' => $type,
'is_passed_by_reference' => $isPassedByReference,
'is_variadic' => $isVariadic,
'name' => $paramName,
'default' => $default,
'full' => $option !== ' ' ? "{$option}{$param}" : $param,
];
}
$result['params'] = $list;
return self::json($result);
}
public static function handlerGetObjectByHandle($server, $msg)
{
if (!function_exists('swoole_get_object_by_handle')) {
return self::json(['require ext-swoole_plus'], 5000);
}
$json = json_decode($msg, true);
if (empty($json) || empty($json['object_id']) || empty($json['object_hash'])) {
return self::json(['error' => 'Params Error!'], 4004);
}
$object = swoole_get_object_by_handle((int) $json['object_id']);
if (!$object) {
return self::json(['error' => 'Object destroyed!'], 4004);
}
$object_hash = spl_object_hash($object);
if ($object_hash != $json['object_hash']) {
return self::json(['error' => 'Object destroyed!'], 4004);
}
return self::json(var_export($object, true));
}
public static function handlerGetVersionInfo($server, $msg)
{
$ip_arr = swoole_get_local_ip();
$host = [];
$local = [];
foreach ($ip_arr as $k => $ip) {
if (filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE)) {
$host[] = $ip;
} else {
$local[] = $ip;
}
}
$data = [
'os' => php_uname('s') . '-' . php_uname('r'),
'swoole' => swoole_version(),
'php' => phpversion(),
'ip' => $host ? $host[0] : $local[0],
];
return self::json($data);
}
public static function handlerGetDefinedFunctions($server, $msg)
{
$functions = get_defined_functions();
$arr = [];
if ($functions) {
$arr['internal'] = $functions['internal'];
foreach ($functions['user'] as $function_name) {
$function = new ReflectionFunction($function_name);
$filename = $function->getFileName();
$line = $function->getStartLine();
$arr['user'][] = [
'function' => $function_name,
'filename' => $filename,
'line' => $line,
];
}
}
return self::json($arr);
}
public static function handlerGetDeclaredClasses($server, $msg)
{
$classes = get_declared_classes();
$arr = [];
if ($classes) {
foreach ($classes as $classes_name) {
$function = new ReflectionClass($classes_name);
$filename = $function->getFileName();
$line = $function->getStartLine();
$arr[] = [
'class' => $classes_name,
'filename' => $filename ?: '',
'line' => $line ?: '',
];
}
}
return self::json($arr);
}
public static function handlerGetServerMemoryUsage($server, $msg)
{
$total = 0;
$result['master'] = $result['manager'] = 0;
if (self::haveMasterProcess($server)) {
$result['master'] = self::getProcessMemoryRealUsage($server->master_pid);
}
$total += $result['master'];
if (self::haveManagerProcess($server)) {
$result['manager'] = self::getProcessMemoryRealUsage($server->manager_pid);
}
$total += $result['manager'];
$n = $server->setting['worker_num'] + $server->setting['task_worker_num'];
for ($i = 0; $i < $n; $i++) {
$key = 'worker-' . $i;
$result[$key] = self::getProcessMemoryRealUsage($server->getWorkerPid($i));
$total += $result[$key];
}
$result['total'] = $total;
$result['memory_size'] = 0;
if (PHP_OS_FAMILY === 'Linux') {
preg_match('#MemTotal:\s+(\d+) kB#i', file_get_contents('/proc/meminfo'), $match);
$result['memory_size'] = $match[1] * 1024;
}
return self::json($result);
}
public static function handlerGetServerCpuUsage($server, $msg)
{
$total = 0;
$result['master'] = $result['manager'] = 0;
if (self::haveMasterProcess($server)) {
$result['master'] = self::getProcessCpuUsage($server->master_pid);
}
$total += $result['master'][1] ?? 0;
if (self::haveManagerProcess($server)) {
$result['manager'] = self::getProcessCpuUsage($server->manager_pid);
}
$total += $result['manager'][1] ?? 0;
$n = $server->setting['worker_num'] + $server->setting['task_worker_num'];
for ($i = 0; $i < $n; $i++) {
$key = 'worker-' . $i;
$result[$key] = self::getProcessCpuUsage($server->getWorkerPid($i))[1] ?? 0;
$total += $result[$key];
}
$result['total'] = $total;
$result['cpu_num'] = swoole_cpu_num();
return self::json($result);
}
public static function handlerGetStaticPropertyValue($server, $msg)
{
$json = json_decode($msg, true);
if (empty($json['class_name'])) {
return self::json(['error' => 'require class_name!'], 4004);
}
if (empty($json['property_name'])) {
return self::json(['error' => 'require property_name!'], 4004);
}
$className = $json['class_name'];
$propertyName = $json['property_name'];
if (!class_exists($className)) {
return self::json("class[{$className}] not exists", 4004);
}
$reflection = new ReflectionClass($className);
$value = $reflection->getStaticPropertyValue($propertyName, []);
$result = [
'value' => var_export($value, true),
];
return self::json($result);
}
private static function handlerMulti(Server $server, array $list)
{
$return_list = [];
foreach ($list as $key => $content) {
$path_array = swoole_string($content['path'])->trim('/')->split('/');
$cmd = $path_array->get(1)->toString();
if ($path_array->count() == 2) {
$process = swoole_string('master');
} else {
$process = $path_array->get(2);
}
$data = [];
$url_query = parse_url($process->toString(), PHP_URL_QUERY) ?? [];
if (!empty($url_query)) {
parse_str($url_query, $data);
}
$data = array_merge($data, $content['post'] ?? []);
if ($process->startsWith('master')) {
$process_type = SWOOLE_SERVER_COMMAND_MASTER;
$process_id = 0;
} elseif ($process->startsWith('manager')) {
$process_type = SWOOLE_SERVER_COMMAND_MANAGER;
$process_id = 0;
} elseif ($process->startsWith('all') || $process->startsWith('specific')) {
if (!in_array($process->toString(), self::$allList) && !$process->startsWith('specific')) {
$return_list[$key] = json_decode('{}');
continue;
}
$result = self::handlerGetAll($server, $process, $cmd, $data);
$return_list[$key] = ['code' => 0, 'data' => $result];
continue;
} else {
$array = $process->split('-');
if ($array->count() != 2 || !isset(self::$map[$array->get(0)->toString()])) {
$return_list[$key] = json_decode('{}');
continue;
}
$process_type = self::$map[$array->get(0)->toString()];
$process_id = intval($array->get(1)->toString());
}
$return_list[$key] = $server->command($cmd, $process_id, intval($process_type), $data, true);
}
return $return_list;
}
private static function handlerGetAll(Server $server, StringObject $process, $cmd, $data, bool $json_decode = true)
{
if ($process->equals('all')) {
$result = self::handlerGetMaster($cmd, $data, $server, $json_decode) +
self::handlerGetManager($cmd, $data, $server, $json_decode) +
self::handlerGetAllWorker($cmd, $data, $server, $json_decode) +
self::handlerGetAllTaskWorker($cmd, $data, $server, $json_decode);
} elseif ($process->startsWith('all_reactor')) {
$result = self::handlerGetAllReactor($cmd, $data, $server, $json_decode);
} elseif ($process->equals('all_worker') || $process->equals('all_event_worker')) {
$result = self::handlerGetAllWorker($cmd, $data, $server, $json_decode);
} elseif ($process->startsWith('all_task')) {
$result = self::handlerGetAllTaskWorker($cmd, $data, $server, $json_decode);
} else {
$result = [];
if (!empty($data['workers']) && is_array($data['workers'])) {
foreach ($data['workers'] as $name) {
$process = swoole_string($name);
if ($process->startsWith('master')) {
$result += self::handlerGetMaster($cmd, $data, $server, $json_decode);
} elseif ($process->startsWith('manager')) {
$result += self::handlerGetManager($cmd, $data, $server, $json_decode);
} else {
$array = $process->split('-');
if ($array->count() != 2 || !isset(self::$map[$array->get(0)->toString()])) {
$result[$name] = $json_decode ? json_decode('{}') : $json_decode;
} else {
$process_type = self::$map[$array->get(0)->toString()];
$process_id = intval($array->get(1)->toString());
$result[$name] = $server->command($cmd, $process_id, $process_type, $data, $json_decode);
}
}
}
}
}
return $result;
}
private static function handlerGetMaster($cmd, $data, Server $server, bool $json_decode = false)
{
$list['master'] = $server->command($cmd, 0, SWOOLE_SERVER_COMMAND_MASTER, $data, $json_decode);
return $list;
}
private static function handlerGetManager($cmd, $data, Server $server, bool $json_decode = false)
{
$list['manager'] = $server->command($cmd, 0, SWOOLE_SERVER_COMMAND_MANAGER, $data, $json_decode);
return $list;
}
private static function handlerGetAllReactor($cmd, $data, Server $server, bool $json_decode = false)
{
$list = [];
if ($server->mode === SWOOLE_BASE) {
return $list;
}
$process_type = SWOOLE_SERVER_COMMAND_REACTOR_THREAD;
if (empty($server->setting['reactor_num'])) {
$reactor_num = $server->setting['worker_num'];
} else {
$reactor_num = $server->setting['reactor_num'];
}
for ($process_id = 0; $process_id < $reactor_num; $process_id++) {
$list["reactor-{$process_id}"] = $server->command($cmd, $process_id, $process_type, $data, $json_decode);
}
return $list;
}
private static function handlerGetAllWorker($cmd, $data, Server $server, bool $json_decode = false)
{
$process_type = SWOOLE_SERVER_COMMAND_EVENT_WORKER;
$worker_num = $server->setting['worker_num'];
$list = [];
for ($process_id = 0; $process_id < $worker_num; $process_id++) {
$list["worker-{$process_id}"] = $server->command($cmd, $process_id, $process_type, $data, $json_decode);
}
return $list;
}
private static function handlerGetAllTaskWorker($cmd, $data, Server $server, bool $json_decode = false)
{
$process_type = SWOOLE_SERVER_COMMAND_TASK_WORKER;
$list = [];
if (empty($server->setting['task_worker_num'])) {
return $list;
}
$task_worker_num = $server->setting['task_worker_num'];
for ($process_id = 0; $process_id < $task_worker_num; $process_id++) {
$list["task_worker-{$process_id}"] = $server->command($cmd, $process_id, $process_type, $data, $json_decode);
}
return $list;
}
private static function getProcessCpuUsage($pid)
{
if (PHP_OS_FAMILY !== 'Linux' || !file_exists("/proc/{$pid}/stat")) {
return [0];
}
$statAll = file_get_contents('/proc/stat');
$statProc = file_get_contents("/proc/{$pid}/stat");
$dataAll = preg_split("/[ \t]+/", $statAll, 6);
assert($dataAll[0] === 'cpu', '/proc/stat malformed');
$dataProc = preg_split("/[ \t]+/", $statProc, 15);
if (isset($dataProc[13]) and isset($dataProc[14])) {
return [
(int) $dataAll[1] + (int) $dataAll[2] + (int) $dataAll[3] + (int) $dataAll[4],
(int) $dataProc[13] + (int) $dataProc[14],
];
}
return [(int) $dataAll[1] + (int) $dataAll[2] + (int) $dataAll[3] + (int) $dataAll[4]];
}
private static function getProcessMemoryRealUsage($pid = 'self')
{
$status = self::getProcessStatus($pid);
if (!is_array($status) || !isset($status['VmRSS'])) {
return 0;
}
return intval($status['VmRSS']) * 1024;
}
private static function getProcessStatus($pid = 'self')
{
$array = [];
if (PHP_OS_FAMILY !== 'Linux' || !file_exists("/proc/{$pid}/status")) {
return $array;
}
$status = swoole_string(trim(file_get_contents("/proc/{$pid}/status")));
$lines = $status->split("\n");
foreach ($lines as $l) {
if (empty($l)) {
continue;
}
[$k, $v] = swoole_string($l)->split(':');
$array[$k] = trim($v);
}
return $array;
}
private static function getArrayMemorySize(array $a): int
{
$size = self::SIZE_OF_ZVAL + self::SIZE_OF_ZEND_ARRAY;
foreach ($a as $k => $v) {
if (is_string($k)) {
$size += self::getStringMemorySize($k);
} else {
$size += self::SIZE_OF_ZVAL;
}
if (is_string($v)) {
$size += self::getStringMemorySize($v);
} elseif (is_array($v)) {
$size += self::getArrayMemorySize($v);
} else {
$size += self::SIZE_OF_ZVAL;
}
}
return $size;
}
private static function getStringMemorySize(string $s): int
{
return self::SIZE_OF_ZVAL + self::SIZE_OF_ZEND_STRING + strlen($s);
}
private static function getObjectMemorySize(object $o): int
{
$vars = get_object_vars($o);
$size = self::SIZE_OF_ZEND_OBJECT;
foreach ($vars as $v) {
if (is_array($v)) {
$size += self::getArrayMemorySize($v);
} elseif (is_string($v)) {
$size += self::getStringMemorySize($v);
} else {
$size += self::SIZE_OF_ZVAL;
}
}
return $size;
}
private static function haveMasterProcess(Server $server): bool
{
if ($server->mode === SWOOLE_BASE) {
return false;
}
return true;
}
private static function haveManagerProcess(Server $server): bool
{
if ($server->mode === SWOOLE_BASE && $server->getManagerPid() === 0) {
return false;
}
return true;
}
private static function json($data, $code = 0)
{
$result = json_encode(['code' => $code, 'data' => $data], JSON_INVALID_UTF8_IGNORE);
if (empty($result)) {
return json_encode([
'code' => 5010,
'data' => ['message' => json_last_error_msg(), 'code' => json_last_error()],
]);
}
return $result;
}
}
@swoole-src/library/core/Server/Helper.php
declare(strict_types=1);
namespace Swoole\Server;
use Swoole\Server;
use Swoole\Timer;
use function Swoole\Coroutine\go;
class Helper
{
public const STATS_TIMER_INTERVAL_TIME = 1000;
public const GLOBAL_OPTIONS = [
'debug_mode' => true,
'trace_flags' => true,
'log_file' => true,
'log_level' => true,
'log_date_format' => true,
'log_date_with_microseconds' => true,
'log_rotation' => true,
'display_errors' => true,
'dns_server' => true,
'socket_dns_timeout' => true,
'socket_connect_timeout' => true,
'socket_write_timeout' => true,
'socket_send_timeout' => true,
'socket_read_timeout' => true,
'socket_recv_timeout' => true,
'socket_buffer_size' => true,
'socket_timeout' => true,
];
public const SERVER_OPTIONS = [
'chroot' => true,
'user' => true,
'group' => true,
'daemonize' => true,
'pid_file' => true,
'reactor_num' => true,
'single_thread' => true,
'worker_num' => true,
'max_wait_time' => true,
'max_queued_bytes' => true,
'enable_coroutine' => true,
'send_timeout' => true,
'dispatch_mode' => true,
'send_yield' => true,
'dispatch_func' => true,
'discard_timeout_request' => true,
'enable_unsafe_event' => true,
'enable_delay_receive' => true,
'enable_reuse_port' => true,
'task_use_object' => true,
'task_object' => true,
'event_object' => true,
'task_enable_coroutine' => true,
'task_worker_num' => true,
'task_ipc_mode' => true,
'task_tmpdir' => true,
'task_max_request' => true,
'task_max_request_grace' => true,
'max_connection' => true,
'max_conn' => true,
'start_session_id' => true,
'heartbeat_check_interval' => true,
'heartbeat_idle_time' => true,
'max_request' => true,
'max_request_grace' => true,
'reload_async' => true,
'open_cpu_affinity' => true,
'cpu_affinity_ignore' => true,
'http_parse_cookie' => true,
'http_parse_post' => true,
'http_parse_files' => true,
'http_compression' => true,
'http_compression_level' => true,
'http_gzip_level' => true,
'compression_min_length' => true,
'websocket_compression' => true,
'upload_tmp_dir' => true,
'enable_static_handler' => true,
'document_root' => true,
'http_autoindex' => true,
'http_index_files' => true,
'static_handler_locations' => true,
'input_buffer_size' => true,
'buffer_input_size' => true,
'output_buffer_size' => true,
'buffer_output_size' => true,
'message_queue_key' => true,
];
public const PORT_OPTIONS = [
'ssl_cert_file' => true,
'ssl_key_file' => true,
'backlog' => true,
'socket_buffer_size' => true,
'kernel_socket_recv_buffer_size' => true,
'kernel_socket_send_buffer_size' => true,
'heartbeat_idle_time' => true,
'buffer_high_watermark' => true,
'buffer_low_watermark' => true,
'open_tcp_nodelay' => true,
'tcp_defer_accept' => true,
'open_tcp_keepalive' => true,
'open_eof_check' => true,
'open_eof_split' => true,
'package_eof' => true,
'open_http_protocol' => true,
'open_websocket_protocol' => true,
'websocket_subprotocol' => true,
'open_websocket_close_frame' => true,
'open_websocket_ping_frame' => true,
'open_websocket_pong_frame' => true,
'open_http2_protocol' => true,
'open_mqtt_protocol' => true,
'open_redis_protocol' => true,
'max_idle_time' => true,
'tcp_keepidle' => true,
'tcp_keepinterval' => true,
'tcp_keepcount' => true,
'tcp_user_timeout' => true,
'tcp_fastopen' => true,
'open_length_check' => true,
'package_length_type' => true,
'package_length_offset' => true,
'package_body_offset' => true,
'package_body_start' => true,
'package_length_func' => true,
'package_max_length' => true,
'ssl_compress' => true,
'ssl_protocols' => true,
'ssl_verify_peer' => true,
'ssl_allow_self_signed' => true,
'ssl_client_cert_file' => true,
'ssl_verify_depth' => true,
'ssl_prefer_server_ciphers' => true,
'ssl_ciphers' => true,
'ssl_ecdh_curve' => true,
'ssl_dhparam' => true,
'ssl_sni_certs' => true,
];
public const AIO_OPTIONS = [
'aio_core_worker_num' => true,
'aio_worker_num' => true,
'aio_max_wait_time' => true,
'aio_max_idle_time' => true,
'enable_signalfd' => true,
'wait_signal' => true,
'dns_cache_refresh_time' => true,
'thread_num' => true,
'min_thread_num' => true,
'max_thread_num' => true,
'socket_dontwait' => true,
'dns_lookup_random' => true,
'use_async_resolver' => true,
'enable_coroutine' => true,
];
public const COROUTINE_OPTIONS = [
'max_coro_num' => true,
'max_coroutine' => true,
'enable_deadlock_check' => true,
'hook_flags' => true,
'enable_preemptive_scheduler' => true,
'c_stack_size' => true,
'stack_size' => true,
'dns_cache_expire' => true,
'dns_cache_capacity' => true,
'max_concurrency' => true,
];
public const HELPER_OPTIONS = [
'stats_file' => true,
'stats_timer_interval' => true,
'admin_server' => true,
];
public static function checkOptions(array $input_options)
{
$const_options = self::GLOBAL_OPTIONS + self::SERVER_OPTIONS + self::PORT_OPTIONS
+ self::AIO_OPTIONS + self::COROUTINE_OPTIONS + self::HELPER_OPTIONS;
foreach ($input_options as $k => $v) {
if (!array_key_exists(strtolower($k), $const_options)) {
trigger_error("unsupported option [{$k}]", E_USER_WARNING);
debug_print_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS);
}
}
}
public static function onBeforeStart(Server $server)
{
if (!empty($server->setting['admin_server'])) {
Admin::init($server);
}
}
public static function onBeforeShutdown(Server $server)
{
if ($server->admin_server) {
$server->admin_server->shutdown();
$server->admin_server = null;
}
}
public static function onWorkerStart(Server $server, int $workerId)
{
if (!empty($server->setting['stats_file']) and $workerId == 0) {
$interval_ms = empty($server->setting['stats_timer_interval']) ? self::STATS_TIMER_INTERVAL_TIME : intval($server->setting['stats_timer_interval']);
$server->stats_timer = Timer::tick($interval_ms, function () use ($server) {
$stats = $server->stats();
$stats_file = swoole_string($server->setting['stats_file']);
if ($stats_file->endsWith('.json')) {
$out = json_encode($stats);
} elseif ($stats_file->endsWith('.php')) {
$out = " $v) {
$lines[] = "{$k}: {$v}";
}
$out = implode("\n", $lines);
}
file_put_contents($server->setting['stats_file'], $out);
});
}
}
public static function onWorkerExit(Server $server, int $workerId)
{
if ($server->stats_timer) {
Timer::clear($server->stats_timer);
$server->stats_timer = null;
}
}
public static function onWorkerStop(Server $server, int $workerId)
{
}
public static function onStart(Server $server)
{
if (!empty($server->setting['admin_server'])) {
go(function () use ($server) {
Admin::start($server);
});
}
}
public static function onShutdown(Server $server)
{
}
public static function onBeforeReload(Server $server)
{
}
public static function onAfterReload(Server $server)
{
}
public static function onManagerStart(Server $server)
{
}
public static function onManagerStop(Server $server)
{
}
public static function onWorkerError(Server $server)
{
}
}
@swoole-src/library/core/NameResolver.php
declare(strict_types=1);
namespace Swoole;
use RuntimeException;
use Swoole\Coroutine\Http\ClientProxy;
use Swoole\NameResolver\Cluster;
use Swoole\NameResolver\Exception;
abstract class NameResolver
{
protected $baseUrl;
protected $prefix;
protected $info;
private $filter_fn;
public function __construct($url, $prefix = 'swoole_service_')
{
$this->checkServerUrl($url);
$this->prefix = $prefix;
}
abstract public function join(string $name, string $ip, int $port, array $options = []): bool;
abstract public function leave(string $name, string $ip, int $port): bool;
abstract public function getCluster(string $name): ?Cluster;
public function withFilter(callable $fn): self
{
$this->filter_fn = $fn;
return $this;
}
public function getFilter()
{
return $this->filter_fn;
}
public function hasFilter(): bool
{
return !empty($this->filter_fn);
}
public function lookup(string $name)
{
if ($this->hasFilter() and ($this->getFilter())($name) !== true) {
return null;
}
$cluster = $this->getCluster($name);
if ($cluster == null) {
return '';
}
if ($cluster->count() == 1) {
return $cluster->pop();
}
return $cluster;
}
protected function checkServerUrl($url)
{
$info = parse_url($url);
if (empty($info['scheme']) or empty($info['host'])) {
throw new RuntimeException("invalid url parameter '{$url}'");
}
if (!filter_var($info['host'], FILTER_VALIDATE_IP)) {
$info['ip'] = gethostbyname($info['host']);
if (!filter_var($info['ip'], FILTER_VALIDATE_IP)) {
throw new RuntimeException("Failed to resolve host '{$info['host']}'");
}
} else {
$info['ip'] = $info['host'];
}
$baseUrl = $info['scheme'] . '://' . $info['ip'];
if (!empty($info['port'])) {
$baseUrl .= ":{$info['port']}";
}
if (!empty($info['path'])) {
$baseUrl .= rtrim($info['path'], '/');
}
$this->baseUrl = $baseUrl;
$this->info = $info;
}
protected function checkResponse($r, $url)
{
if (empty($r)) {
throw new Exception("failed to request URL({$url})");
}
if ($r->getStatusCode() !== 200) {
$msg = '';
if (!empty($r->errMsg)) {
$msg .= 'errMsg: ' . $r->errMsg;
}
$body = $r->getBody();
if (empty($r->errMsg)) {
$msg .= 'Http Body: ' . $body;
}
throw new Exception($msg, $r->errCode ?: $r->getStatusCode());
}
return true;
}
}
@swoole-src/library/core/NameResolver/Exception.php
declare(strict_types=1);
namespace Swoole\NameResolver;
class Exception extends \RuntimeException
{
}
@swoole-src/library/core/NameResolver/Cluster.php
declare(strict_types=1);
namespace Swoole\NameResolver;
use Swoole\Exception;
class Cluster
{
private $nodes = [];
public function add(string $host, int $port, int $weight = 100): void
{
if (!filter_var($host, FILTER_VALIDATE_IP)) {
throw new Exception("Bad IP Address [{$host}]");
}
if ($port < 0 or $port > 65535) {
throw new Exception("Bad Port [{$port}]");
}
if ($weight < 0 or $weight > 100) {
throw new Exception("Bad Weight [{$weight}]");
}
$this->nodes[] = ['host' => $host, 'port' => $port, 'weight' => $weight];
}
public function pop()
{
if (empty($this->nodes)) {
return false;
}
$index = array_rand($this->nodes, 1);
$node = $this->nodes[$index];
unset($this->nodes[$index]);
return $node;
}
public function count(): int
{
return count($this->nodes);
}
}
@swoole-src/library/core/NameResolver/Redis.php
declare(strict_types=1);
namespace Swoole\NameResolver;
use Swoole\NameResolver;
class Redis extends NameResolver
{
private $serverHost;
private $serverPort;
public function __construct($url, $prefix = 'swoole:service:')
{
parent::__construct($url, $prefix);
$this->serverHost = $this->info['ip'];
$this->serverPort = $this->info['port'] ?? 6379;
}
public function join(string $name, string $ip, int $port, array $options = []): bool
{
if (($redis = $this->connect()) === false) {
return false;
}
if ($redis->sAdd($this->prefix . $name, $ip . ':' . $port) === false) {
return false;
}
return true;
}
public function leave(string $name, string $ip, int $port): bool
{
if (($redis = $this->connect()) === false) {
return false;
}
if ($redis->sRem($this->prefix . $name, $ip . ':' . $port) === false) {
return false;
}
return true;
}
public function getCluster(string $name): ?Cluster
{
if (($redis = $this->connect()) === false) {
return null;
}
$members = $redis->sMembers($this->prefix . $name);
if (empty($members)) {
return null;
}
$cluster = new Cluster();
foreach ($members as $m) {
[$host, $port] = explode(':', $m);
$cluster->add($host, intval($port));
}
return $cluster;
}
protected function connect()
{
$redis = new \redis();
if ($redis->connect($this->serverHost, $this->serverPort) === false) {
return false;
}
return $redis;
}
}
@swoole-src/library/core/NameResolver/Nacos.php
declare(strict_types=1);
namespace Swoole\NameResolver;
use Swoole\Coroutine;
use Swoole\NameResolver;
class Nacos extends NameResolver
{
public function join(string $name, string $ip, int $port, array $options = []): bool
{
$params['port'] = $port;
$params['ip'] = $ip;
$params['healthy'] = 'true';
$params['weight'] = $options['weight'] ?? 100;
$params['encoding'] = $options['encoding'] ?? 'utf-8';
$params['namespaceId'] = $options['namespaceId'] ?? 'public';
$params['serviceName'] = $this->prefix . $name;
$url = $this->baseUrl . '/nacos/v1/ns/instance?' . http_build_query($params);
$r = Coroutine\Http\post($url, []);
return $this->checkResponse($r, $url);
}
public function leave(string $name, string $ip, int $port): bool
{
$params['port'] = $port;
$params['ip'] = $ip;
$params['serviceName'] = $this->prefix . $name;
$url = $this->baseUrl . '/nacos/v1/ns/instance?' . http_build_query($params);
$r = Coroutine\Http\request($this->baseUrl . '/nacos/v1/ns/instance?' . http_build_query($params), 'DELETE');
return $this->checkResponse($r, $url);
}
public function getCluster(string $name): ?Cluster
{
$params['serviceName'] = $this->prefix . $name;
$url = $this->baseUrl . '/nacos/v1/ns/instance/list?' . http_build_query($params);
$r = Coroutine\Http\get($url);
if (!$this->checkResponse($r, $url)) {
return null;
}
$result = json_decode($r->getBody());
if (empty($result)) {
return null;
}
$cluster = new Cluster();
foreach ($result->hosts as $node) {
$cluster->add($node->ip, $node->port, $node->weight);
}
return $cluster;
}
}
@swoole-src/library/core/NameResolver/Consul.php
declare(strict_types=1);
namespace Swoole\NameResolver;
use Swoole\NameResolver;
use function Swoole\Coroutine\Http\get;
use function Swoole\Coroutine\Http\request;
class Consul extends NameResolver
{
public function join(string $name, string $ip, int $port, array $options = []): bool
{
$weight = $options['weight'] ?? 100;
$data = [
'ID' => $this->getServiceId($name, $ip, $port),
'Name' => $this->prefix . $name,
'Address' => $ip,
'Port' => $port,
'EnableTagOverride' => false,
'Weights' => [
'Passing' => $weight,
'Warning' => 1,
],
];
$url = $this->baseUrl . '/v1/agent/service/register';
$r = request($url, 'PUT', json_encode($data));
return $this->checkResponse($r, $url);
}
public function leave(string $name, string $ip, int $port): bool
{
$url = $this->baseUrl . '/v1/agent/service/deregister/' . $this->getServiceId(
$name,
$ip,
$port
);
$r = request($url, 'PUT');
return $this->checkResponse($r, $url);
}
public function enableMaintenanceMode(string $name, string $ip, int $port): bool
{
$url = $this->baseUrl . '/v1/agent/service/maintenance/' . $this->getServiceId(
$name,
$ip,
$port
);
$r = request($url, 'PUT');
return $this->checkResponse($r, $url);
}
public function getCluster(string $name): ?Cluster
{
$url = $this->baseUrl . '/v1/catalog/service/' . $this->prefix . $name;
$r = get($url);
if (!$this->checkResponse($r, $url)) {
return null;
}
$list = json_decode($r->getBody());
if (empty($list)) {
return null;
}
$cluster = new Cluster();
foreach ($list as $li) {
$cluster->add($li->ServiceAddress, $li->ServicePort, $li->ServiceWeights->Passing);
}
return $cluster;
}
private function getServiceId(string $name, string $ip, int $port): string
{
return $this->prefix . $name . "_{$ip}:{$port}";
}
}
@swoole-src/library/core/Coroutine/functions.php
declare(strict_types=1);
namespace Swoole\Coroutine;
use Swoole\Coroutine;
function run(callable $fn, ...$args)
{
$s = new Scheduler();
$options = Coroutine::getOptions();
if (!isset($options['hook_flags'])) {
$s->set(['hook_flags' => SWOOLE_HOOK_ALL]);
}
$s->add($fn, ...$args);
return $s->start();
}
function go(callable $fn, ...$args)
{
return Coroutine::create($fn, ...$args);
}
function defer(callable $fn)
{
Coroutine::defer($fn);
}
function batch(array $tasks, float $timeout = -1): array
{
$wg = new WaitGroup(count($tasks));
foreach ($tasks as $id => $task) {
Coroutine::create(function () use ($wg, &$tasks, $id, $task) {
$tasks[$id] = null;
$tasks[$id] = $task();
$wg->done();
});
}
$wg->wait($timeout);
return $tasks;
}
function parallel(int $n, callable $fn): void
{
$count = $n;
$wg = new WaitGroup($n);
while ($count--) {
Coroutine::create(function () use ($fn, $wg) {
$fn();
$wg->done();
});
}
$wg->wait();
}
function map(array $list, callable $fn, float $timeout = -1): array
{
$wg = new WaitGroup(count($list));
foreach ($list as $id => $elem) {
Coroutine::create(function () use ($wg, &$list, $id, $elem, $fn): void {
$list[$id] = null;
$list[$id] = $fn($elem);
$wg->done();
});
}
$wg->wait($timeout);
return $list;
}
function deadlock_check()
{
$all_coroutines = Coroutine::listCoroutines();
$count = Coroutine::stats()['coroutine_num'];
echo "\n===================================================================",
"\n [FATAL ERROR]: all coroutines (count: {$count}) are asleep - deadlock!",
"\n===================================================================\n";
$options = Coroutine::getOptions();
if (empty($options['deadlock_check_disable_trace'])) {
$index = 0;
$limit = empty($options['deadlock_check_limit']) ? 32 : intval($options['deadlock_check_limit']);
$depth = empty($options['deadlock_check_depth']) ? 32 : intval($options['deadlock_check_depth']);
foreach ($all_coroutines as $cid) {
echo "\n [Coroutine-{$cid}]";
echo "\n--------------------------------------------------------------------\n";
echo Coroutine::printBackTrace($cid, DEBUG_BACKTRACE_IGNORE_ARGS, $depth);
echo "\n";
$index++;
if ($index >= $limit) {
break;
}
}
}
}
@swoole-src/library/ext/curl.php
declare(strict_types=1);
function swoole_curl_init(string $url = ''): Swoole\Curl\Handler
{
return new Swoole\Curl\Handler($url);
}
function swoole_curl_setopt(Swoole\Curl\Handler $obj, int $opt, $value): bool
{
return $obj->setOpt($opt, $value);
}
function swoole_curl_setopt_array(Swoole\Curl\Handler $obj, $array): bool
{
foreach ($array as $k => $v) {
if ($obj->setOpt($k, $v) !== true) {
return false;
}
}
return true;
}
function swoole_curl_exec(Swoole\Curl\Handler $obj)
{
return $obj->exec();
}
function swoole_curl_getinfo(Swoole\Curl\Handler $obj, int $opt = 0)
{
$info = $obj->getInfo();
if (is_array($info) and $opt) {
switch ($opt) {
case CURLINFO_EFFECTIVE_URL:
return $info['url'];
case CURLINFO_HTTP_CODE:
return $info['http_code'];
case CURLINFO_CONTENT_TYPE:
return $info['content_type'];
case CURLINFO_REDIRECT_COUNT:
return $info['redirect_count'];
case CURLINFO_REDIRECT_URL:
return $info['redirect_url'];
case CURLINFO_TOTAL_TIME:
return $info['total_time'];
case CURLINFO_STARTTRANSFER_TIME:
return $info['starttransfer_time'];
case CURLINFO_SIZE_DOWNLOAD:
return $info['size_download'];
case CURLINFO_SPEED_DOWNLOAD:
return $info['speed_download'];
case CURLINFO_REDIRECT_TIME:
return $info['redirect_time'];
case CURLINFO_HEADER_SIZE:
return $info['header_size'];
case CURLINFO_PRIMARY_IP:
return $info['primary_ip'];
case CURLINFO_PRIVATE:
return $info['private'];
default:
return null;
}
}
return $info;
}
function swoole_curl_errno(Swoole\Curl\Handler $obj)
{
return $obj->errno();
}
function swoole_curl_error(Swoole\Curl\Handler $obj)
{
return $obj->error();
}
function swoole_curl_reset(Swoole\Curl\Handler $obj)
{
return $obj->reset();
}
function swoole_curl_close(Swoole\Curl\Handler $obj)
{
return $obj->close();
}
function swoole_curl_multi_getcontent(Swoole\Curl\Handler $obj)
{
return $obj->getContent();
}
@swoole-src/library/ext/sockets.php
declare(strict_types=1);
use Swoole\Coroutine\Socket;
function swoole_socket_create(int $domain, int $type, int $protocol)
{
return new Socket($domain, $type, $protocol);
}
function swoole_socket_connect(Socket $socket, string $address, int $port = 0)
{
return $socket->connect($address, $port);
}
function swoole_socket_read(Socket $socket, int $length, int $type = PHP_BINARY_READ)
{
if ($type != PHP_BINARY_READ) {
return $socket->recvLine($length);
}
return $socket->recv($length);
}
function swoole_socket_write(Socket $socket, string $buffer, int $length = 0)
{
if ($length > 0 and $length < strlen($buffer)) {
$buffer = substr($buffer, 0, $length);
}
return $socket->send($buffer);
}
function swoole_socket_send(Socket $socket, string $buffer, int $length, int $flags)
{
if ($flags != 0) {
throw new RuntimeException("\$flags[{$flags}] is not supported");
}
return swoole_socket_write($socket, $buffer, $length);
}
function swoole_socket_recv(Socket $socket, &$buffer, int $length, int $flags)
{
if ($flags & MSG_OOB) {
throw new RuntimeException('\$flags[MSG_OOB] is not supported');
}
if ($flags & MSG_PEEK) {
$buffer = $socket->peek($length);
}
$timeout = $flags & MSG_DONTWAIT ? 0.001 : 0;
if ($flags & MSG_WAITALL) {
$buffer = $socket->recvAll($length, $timeout);
} else {
$buffer = $socket->recv($length, $timeout);
}
if ($buffer === false) {
return false;
}
return strlen($buffer);
}
function swoole_socket_sendto(Socket $socket, string $buffer, int $length, int $flags, string $addr, int $port = 0)
{
if ($flags != 0) {
throw new RuntimeException("\$flags[{$flags}] is not supported");
}
if ($socket->type != SOCK_DGRAM) {
throw new RuntimeException('only supports dgram type socket');
}
if ($length > 0 and $length < strlen($buffer)) {
$buffer = substr($buffer, 0, $length);
}
return $socket->sendto($addr, $port, $buffer);
}
function swoole_socket_recvfrom(Socket $socket, &$buffer, int $length, int $flags, &$name, &$port = null)
{
if ($flags != 0) {
throw new RuntimeException("\$flags[{$flags}] is not supported");
}
if ($length == 0) {
$socket->errCode = SOCKET_EAGAIN;
return false;
}
if ($socket->type != SOCK_DGRAM) {
throw new RuntimeException('only supports dgram type socket');
}
$data = $socket->recvfrom($peer);
if ($data === false) {
return false;
}
$name = $peer['address'];
if (func_num_args() == 6) {
$port = $peer['port'];
}
if ($length < strlen($data)) {
$buffer = substr($data, 0, $length);
} else {
$buffer = $data;
}
return strlen($buffer);
}
function swoole_socket_bind(Socket $socket, string $address, int $port = 0): bool
{
return $socket->bind($address, $port);
}
function swoole_socket_listen(Socket $socket, int $backlog = 0): bool
{
return $socket->listen($backlog);
}
function swoole_socket_create_listen(int $port, int $backlog = 128)
{
$socket = new Socket(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$socket->bind('0.0.0.0', $port)) {
return false;
}
if (!$socket->listen($backlog)) {
return false;
}
return $socket;
}
function swoole_socket_accept(Socket $socket)
{
return $socket->accept();
}
function swoole_socket_getpeername(Socket $socket, &$address, &$port = null)
{
$info = $socket->getpeername();
if (!$info) {
return false;
}
$address = $info['address'];
if (func_num_args() == 3) {
$port = $info['port'];
}
return true;
}
function swoole_socket_getsockname(Socket $socket, &$address, &$port = null)
{
$info = $socket->getsockname();
if (!$info) {
return false;
}
$address = $info['address'];
if (func_num_args() == 3) {
$port = $info['port'];
}
return true;
}
function swoole_socket_set_option(Socket $socket, int $level, int $optname, $optval): bool
{
return $socket->setOption($level, $optname, $optval);
}
function swoole_socket_setopt(Socket $socket, int $level, int $optname, $optval): bool
{
return $socket->setOption($level, $optname, $optval);
}
function swoole_socket_get_option(Socket $socket, int $level, int $optname)
{
return $socket->getOption($level, $optname);
}
function swoole_socket_getopt(Socket $socket, int $level, int $optname)
{
return $socket->getOption($level, $optname);
}
function swoole_socket_shutdown(Socket $socket, int $how = 2): bool
{
return $socket->shutdown($how);
}
function swoole_socket_close(Socket $socket)
{
$socket->close();
}
function swoole_socket_clear_error(Socket $socket = null)
{
if ($socket) {
$socket->errCode = 0;
}
swoole_clear_error();
}
function swoole_socket_last_error(Socket $socket = null): int
{
if ($socket) {
return $socket->errCode;
}
return swoole_last_error();
}
function swoole_socket_set_block(Socket $socket)
{
if ($socket->isClosed()) {
return false;
}
if (isset($socket->__ext_sockets_nonblock) and $socket->__ext_sockets_nonblock) {
$socket->setOption(SOL_SOCKET, SO_RCVTIMEO, $socket->__ext_sockets_timeout);
}
$socket->__ext_sockets_nonblock = false;
return true;
}
function swoole_socket_set_nonblock(Socket $socket)
{
if ($socket->isClosed()) {
return false;
}
if (isset($socket->__ext_sockets_nonblock) and $socket->__ext_sockets_nonblock) {
return true;
}
$socket->__ext_sockets_nonblock = true;
$socket->__ext_sockets_timeout = $socket->getOption(SOL_SOCKET, SO_RCVTIMEO);
$socket->setOption(SOL_SOCKET, SO_RCVTIMEO, ['sec' => 0, 'usec' => 1000]);
return true;
}
function swoole_socket_create_pair(
int $domain,
int $type,
int $protocol,
array &$pair
) {
$_pair = swoole_coroutine_socketpair($domain, $type, $protocol);
if ($_pair) {
$pair = $_pair;
return true;
}
return false;
}
@swoole-src/library/functions.php
declare(strict_types=1);
if (PHP_VERSION_ID < 70200) {
throw new RuntimeException('require PHP version 7.2 or later');
}
if (SWOOLE_USE_SHORTNAME) {
function _string(string $string = ''): Swoole\StringObject
{
return new Swoole\StringObject($string);
}
function _mbstring(string $string = ''): Swoole\MultibyteStringObject
{
return new Swoole\MultibyteStringObject($string);
}
function _array(array $array = []): Swoole\ArrayObject
{
return new Swoole\ArrayObject($array);
}
}
class SwooleLibrary
{
public static $options = [];
}
function swoole_library_set_options(array $options)
{
SwooleLibrary::$options = $options;
}
function swoole_library_get_options()
{
return SwooleLibrary::$options;
}
function swoole_library_set_option(string $key, $value)
{
SwooleLibrary::$options[$key] = $value;
}
function swoole_library_get_option(string $key)
{
return SwooleLibrary::$options[$key] ?? null;
}
function swoole_string(string $string = ''): Swoole\StringObject
{
return new Swoole\StringObject($string);
}
function swoole_mbstring(string $string = ''): Swoole\MultibyteStringObject
{
return new Swoole\MultibyteStringObject($string);
}
function swoole_array(array $array = []): Swoole\ArrayObject
{
return new Swoole\ArrayObject($array);
}
function swoole_table(int $size, string $fields): Swoole\Table
{
$_fields = swoole_string($fields)->trim()->split(',');
$table = new Swoole\Table($size, 0.25);
foreach ($_fields as $f) {
$_f = swoole_string($f)->trim()->split(':');
$name = $_f->get(0)->trim()->toString();
$type = $_f->get(1)->trim();
switch ($type) {
case 'i':
case 'int':
$table->column($name, Swoole\Table::TYPE_INT);
break;
case 'f':
case 'float':
$table->column($name, Swoole\Table::TYPE_FLOAT);
break;
case 's':
case 'string':
if ($_f->count() < 3) {
throw new RuntimeException('need to give string length');
}
$length = intval($_f->get(2)->trim()->toString());
if ($length <= 0) {
throw new RuntimeException("invalid string length[{$length}]");
}
$table->column($name, Swoole\Table::TYPE_STRING, $length);
break;
default:
throw new RuntimeException("unknown field type[{$type}]");
break;
}
}
if (!$table->create()) {
throw new RuntimeException('failed to create table');
}
return $table;
}
function swoole_array_list(...$arrray): Swoole\ArrayObject
{
return new Swoole\ArrayObject($arrray);
}
function swoole_array_default_value(array $array, $key, $default_value = null)
{
return array_key_exists($key, $array) ? $array[$key] : $default_value;
}
if (!function_exists('array_key_last')) {
function array_key_last(array $array)
{
if (!empty($array)) {
return key(array_slice($array, -1, 1, true));
}
return null;
}
}
if (!function_exists('array_key_first')) {
function array_key_first(array $array)
{
foreach ($array as $key => $unused) {
return $key;
}
return null;
}
}
declare(strict_types=1);
if (SWOOLE_USE_SHORTNAME) {
class_alias(Swoole\Coroutine\WaitGroup::class, Co\WaitGroup::class, true);
class_alias(Swoole\Coroutine\Server::class, Co\Server::class, true);
class_alias(Swoole\Coroutine\Server\Connection::class, Co\Server\Connection::class, true);
class_alias(Swoole\Coroutine\FastCGI\Client::class, Co\FastCGI\Client::class, true);
class_alias(Swoole\Coroutine\FastCGI\Client\Exception::class, Co\FastCGI\Client\Exception::class, true);
class_alias(Swoole\Coroutine\FastCGI\Proxy::class, Co\FastCGI\Proxy::class, true);
}
class_alias(Swoole\Process\Manager::class, Swoole\Process\ProcessManager::class, true);
@swoole-src/library/alias_ns.php
declare(strict_types=1);
namespace Co;
use Swoole\Coroutine;
if (SWOOLE_USE_SHORTNAME) {
function run(callable $fn, ...$args)
{
return \Swoole\Coroutine\run($fn, ...$args);
}
function go(callable $fn, ...$args)
{
return Coroutine::create($fn, ...$args);
}
function defer(callable $fn)
{
Coroutine::defer($fn);
}
}
swoole_internal_call_user_shutdown_begin SWOOLE_ERROR_OPERATION_NOT_SUPPORT SWOOLE_ERROR_DNSLOOKUP_DUPLICATE_REQUEST SWOOLE_ERROR_DNSLOOKUP_RESOLVE_FAILED SWOOLE_ERROR_DNSLOOKUP_RESOLVE_TIMEOUT SWOOLE_ERROR_DNSLOOKUP_UNSUPPORTED SWOOLE_ERROR_DNSLOOKUP_NO_SERVER SWOOLE_ERROR_UNREGISTERED_SIGNAL SWOOLE_ERROR_EVENT_SOCKET_REMOVED SWOOLE_ERROR_EVENT_SOCKET_INVALID SWOOLE_ERROR_SESSION_CLOSED_BY_SERVER SWOOLE_ERROR_SESSION_CLOSED_BY_CLIENT SWOOLE_ERROR_SESSION_NOT_EXIST SWOOLE_ERROR_SESSION_INVALID_ID SWOOLE_ERROR_SESSION_DISCARD_TIMEOUT_DATA SWOOLE_ERROR_SESSION_DISCARD_DATA SWOOLE_ERROR_OUTPUT_BUFFER_OVERFLOW SWOOLE_ERROR_OUTPUT_SEND_YIELD SWOOLE_ERROR_SSL_CANNOT_USE_SENFILE SWOOLE_ERROR_SSL_EMPTY_PEER_CERTIFICATE SWOOLE_ERROR_SSL_VERIFY_FAILED SWOOLE_ERROR_SSL_HANDSHAKE_FAILED SWOOLE_ERROR_PACKAGE_LENGTH_TOO_LARGE SWOOLE_ERROR_PACKAGE_LENGTH_NOT_FOUND SWOOLE_ERROR_DATA_LENGTH_TOO_LARGE SWOOLE_ERROR_PACKAGE_MALFORMED_DATA SWOOLE_ERROR_TASK_PACKAGE_TOO_BIG SWOOLE_ERROR_TASK_DISPATCH_FAIL SWOOLE_ERROR_HTTP2_STREAM_ID_TOO_BIG SWOOLE_ERROR_HTTP2_STREAM_NO_HEADER SWOOLE_ERROR_HTTP2_STREAM_NOT_FOUND SWOOLE_ERROR_HTTP2_STREAM_IGNORE SWOOLE_ERROR_HTTP2_SEND_CONTROL_FRAME_FAILED SWOOLE_ERROR_CLIENT_NO_CONNECTION SWOOLE_ERROR_SOCKET_POLL_TIMEOUT SWOOLE_ERROR_SOCKS5_UNSUPPORT_VERSION SWOOLE_ERROR_SOCKS5_UNSUPPORT_METHOD SWOOLE_ERROR_SOCKS5_AUTH_FAILED SWOOLE_ERROR_SOCKS5_SERVER_ERROR SWOOLE_ERROR_SOCKS5_HANDSHAKE_FAILED SWOOLE_ERROR_HTTP_PROXY_HANDSHAKE_ERROR SWOOLE_ERROR_HTTP_INVALID_PROTOCOL SWOOLE_ERROR_HTTP_PROXY_HANDSHAKE_FAILED SWOOLE_ERROR_HTTP_PROXY_BAD_RESPONSE SWOOLE_ERROR_WEBSOCKET_BAD_CLIENT SWOOLE_ERROR_WEBSOCKET_BAD_OPCODE SWOOLE_ERROR_WEBSOCKET_UNCONNECTED SWOOLE_ERROR_WEBSOCKET_HANDSHAKE_FAILED SWOOLE_ERROR_WEBSOCKET_PACK_FAILED SWOOLE_ERROR_WEBSOCKET_UNPACK_FAILED SWOOLE_ERROR_WEBSOCKET_INCOMPLETE_PACKET SWOOLE_ERROR_SERVER_MUST_CREATED_BEFORE_CLIENT SWOOLE_ERROR_SERVER_TOO_MANY_SOCKET SWOOLE_ERROR_SERVER_WORKER_TERMINATED SWOOLE_ERROR_SERVER_INVALID_LISTEN_PORT SWOOLE_ERROR_SERVER_TOO_MANY_LISTEN_PORT SWOOLE_ERROR_SERVER_PIPE_BUFFER_FULL SWOOLE_ERROR_SERVER_NO_IDLE_WORKER SWOOLE_ERROR_SERVER_ONLY_START_ONE SWOOLE_ERROR_SERVER_SEND_IN_MASTER SWOOLE_ERROR_SERVER_INVALID_REQUEST SWOOLE_ERROR_SERVER_CONNECT_FAIL SWOOLE_ERROR_SERVER_INVALID_COMMAND SWOOLE_ERROR_SERVER_IS_NOT_REGULAR_FILE SWOOLE_ERROR_SERVER_WORKER_EXIT_TIMEOUT SWOOLE_ERROR_SERVER_WORKER_ABNORMAL_PIPE_DATA SWOOLE_ERROR_SERVER_WORKER_UNPROCESSED_DATA SWOOLE_ERROR_CO_OUT_OF_COROUTINE SWOOLE_ERROR_CO_HAS_BEEN_BOUND SWOOLE_ERROR_CO_HAS_BEEN_DISCARDED SWOOLE_ERROR_CO_MUTEX_DOUBLE_UNLOCK SWOOLE_ERROR_CO_BLOCK_OBJECT_LOCKED SWOOLE_ERROR_CO_BLOCK_OBJECT_WAITING SWOOLE_ERROR_CO_GETCONTEXT_FAILED SWOOLE_ERROR_CO_SWAPCONTEXT_FAILED SWOOLE_ERROR_CO_MAKECONTEXT_FAILED SWOOLE_ERROR_CO_IOCPINIT_FAILED SWOOLE_ERROR_CO_PROTECT_STACK_FAILED SWOOLE_ERROR_CO_STD_THREAD_LINK_ERROR SWOOLE_ERROR_CO_DISABLED_MULTI_THREAD SWOOLE_LOG_ROTATION_EVERY_MINUTE swoole.enable_preemptive_scheduler %s: inet_ntop failed 127.0.0.1 Swoole Swoole Team Author 4.8.13 Mar 21 2024 %s %s 12:55:13 Built epoll eventfd spinlock rwlock OpenSSL 1.1.1w 11 Sep 2023 openssl dtls pcre 1.2.11 zlib E%u/D%u brotli mutex_timedlock pthread_barrier futex async_redis cli_set_process_title %02X:%02X:%02X:%02X:%02X:%02X basic_string::_M_create STDOUT STDERR trace_flags log_file log_level log_date_format log_date_with_microseconds log_rotation dns_server socket_dns_timeout socket_connect_timeout socket_write_timeout socket_send_timeout socket_read_timeout socket_recv_timeout socket_buffer_size socket_timeout http2_header_table_size http2_enable_push http2_max_concurrent_streams http2_init_window_size http2_max_frame_size http2_max_header_list_size %s() (ERRNO %d): %.*s @swoole-src/library/alias.php SWOOLE_VERSION SWOOLE_VERSION_ID SWOOLE_MAJOR_VERSION SWOOLE_MINOR_VERSION SWOOLE_RELEASE_VERSION SWOOLE_EXTRA_VERSION SWOOLE_DEBUG SWOOLE_HAVE_COMPRESSION SWOOLE_HAVE_ZLIB SWOOLE_HAVE_BROTLI SWOOLE_USE_SHORTNAME SWOOLE_SOCK_TCP SWOOLE_SOCK_TCP6 SWOOLE_SOCK_UDP SWOOLE_SOCK_UDP6 SWOOLE_SOCK_UNIX_DGRAM SWOOLE_SOCK_UNIX_STREAM SWOOLE_TCP SWOOLE_TCP6 SWOOLE_UDP SWOOLE_UDP6 SWOOLE_UNIX_DGRAM SWOOLE_UNIX_STREAM SWOOLE_SOCK_SYNC SWOOLE_SOCK_ASYNC SWOOLE_SYNC SWOOLE_ASYNC SWOOLE_KEEP SWOOLE_SSL SWOOLE_SSLv3_METHOD SWOOLE_SSLv3_SERVER_METHOD SWOOLE_SSLv3_CLIENT_METHOD SWOOLE_TLSv1_METHOD SWOOLE_TLSv1_SERVER_METHOD SWOOLE_TLSv1_CLIENT_METHOD SWOOLE_TLSv1_1_METHOD SWOOLE_TLSv1_1_SERVER_METHOD SWOOLE_TLSv1_1_CLIENT_METHOD SWOOLE_TLSv1_2_METHOD SWOOLE_TLSv1_2_SERVER_METHOD SWOOLE_TLSv1_2_CLIENT_METHOD SWOOLE_DTLS_SERVER_METHOD SWOOLE_DTLS_CLIENT_METHOD SWOOLE_SSLv23_METHOD SWOOLE_SSLv23_SERVER_METHOD SWOOLE_SSLv23_CLIENT_METHOD SWOOLE_TLS_METHOD SWOOLE_TLS_SERVER_METHOD SWOOLE_TLS_CLIENT_METHOD SWOOLE_SSL_TLSv1 SWOOLE_SSL_TLSv1_1 SWOOLE_SSL_TLSv1_2 SWOOLE_SSL_TLSv1_3 SWOOLE_SSL_DTLS SWOOLE_SSL_SSLv2 SWOOLE_EVENT_READ SWOOLE_EVENT_WRITE SWOOLE_STRERROR_SYSTEM SWOOLE_STRERROR_GAI SWOOLE_STRERROR_DNS SWOOLE_STRERROR_SWOOLE SWOOLE_ERROR_MALLOC_FAIL SWOOLE_ERROR_SYSTEM_CALL_FAIL SWOOLE_ERROR_PHP_FATAL_ERROR SWOOLE_ERROR_NAME_TOO_LONG SWOOLE_ERROR_INVALID_PARAMS SWOOLE_ERROR_QUEUE_FULL SWOOLE_ERROR_PROTOCOL_ERROR SWOOLE_ERROR_WRONG_OPERATION SWOOLE_ERROR_FILE_NOT_EXIST SWOOLE_ERROR_FILE_TOO_LARGE SWOOLE_ERROR_FILE_EMPTY SWOOLE_ERROR_BAD_IPV6_ADDRESS SWOOLE_ERROR_SESSION_CLOSING SWOOLE_ERROR_SESSION_CLOSED SWOOLE_ERROR_SSL_NOT_READY SWOOLE_ERROR_SSL_BAD_CLIENT SWOOLE_ERROR_SSL_BAD_PROTOCOL SWOOLE_ERROR_SSL_RESET SWOOLE_ERROR_TASK_TIMEOUT SWOOLE_ERROR_AIO_BAD_REQUEST SWOOLE_ERROR_AIO_CANCELED SWOOLE_ERROR_AIO_TIMEOUT SWOOLE_ERROR_SOCKET_CLOSED SWOOLE_ERROR_CO_YIELD_FAILED SWOOLE_ERROR_CO_CANNOT_CANCEL SWOOLE_ERROR_CO_NOT_EXISTS SWOOLE_ERROR_CO_CANCELED SWOOLE_ERROR_CO_TIMEDOUT SWOOLE_TRACE_SERVER SWOOLE_TRACE_CLIENT SWOOLE_TRACE_BUFFER SWOOLE_TRACE_CONN SWOOLE_TRACE_EVENT SWOOLE_TRACE_WORKER SWOOLE_TRACE_MEMORY SWOOLE_TRACE_REACTOR SWOOLE_TRACE_PHP SWOOLE_TRACE_HTTP SWOOLE_TRACE_HTTP2 SWOOLE_TRACE_EOF_PROTOCOL SWOOLE_TRACE_LENGTH_PROTOCOL SWOOLE_TRACE_CLOSE SWOOLE_TRACE_WEBSOCKET SWOOLE_TRACE_REDIS_CLIENT SWOOLE_TRACE_MYSQL_CLIENT SWOOLE_TRACE_HTTP_CLIENT SWOOLE_TRACE_AIO SWOOLE_TRACE_SSL SWOOLE_TRACE_NORMAL SWOOLE_TRACE_CHANNEL SWOOLE_TRACE_TIMER SWOOLE_TRACE_SOCKET SWOOLE_TRACE_COROUTINE SWOOLE_TRACE_CONTEXT SWOOLE_TRACE_CO_HTTP_SERVER SWOOLE_TRACE_TABLE SWOOLE_TRACE_CO_CURL SWOOLE_TRACE_CARES SWOOLE_TRACE_ZLIB SWOOLE_TRACE_ALL SWOOLE_LOG_DEBUG SWOOLE_LOG_TRACE SWOOLE_LOG_INFO SWOOLE_LOG_NOTICE SWOOLE_LOG_WARNING SWOOLE_LOG_ERROR SWOOLE_LOG_NONE SWOOLE_LOG_ROTATION_SINGLE SWOOLE_LOG_ROTATION_MONTHLY SWOOLE_LOG_ROTATION_DAILY SWOOLE_LOG_ROTATION_HOURLY SWOOLE_IPC_NONE SWOOLE_IPC_UNIXSOCK SWOOLE_IPC_SOCKET SWOOLE_IOV_MAX swoole_coroutine_create swoole_coroutine_defer 7.4.33 PHP_VERSION : %s
cli phpdbg Swoole\Exception swoole_exception Swoole\Error swoole_error swoole.enable_coroutine On swoole.enable_library Off swoole.display_errors swoole.use_shortname swoole.unixsock_buffer_size 8388608 swoole API20190902,NTS swoole_version swoole_cpu_num swoole_last_error swoole_async_dns_lookup_coro swoole_async_set swoole_coroutine_socketpair swoole_test_kernel_coroutine swoole_client_select swoole_select swoole_set_process_name swoole_get_local_ip swoole_get_local_mac swoole_strerror swoole_errno swoole_clear_error swoole_error_log swoole_error_log_ex swoole_ignore_error swoole_hashcode swoole_mime_type_add swoole_mime_type_set swoole_mime_type_delete swoole_mime_type_get swoole_get_mime_type swoole_mime_type_exists swoole_mime_type_list swoole_clear_dns_cache swoole_substr_unserialize swoole_get_objects swoole_get_vm_status swoole_get_object_by_handle filename suffix error_type options read_array write_array error_array sleep_time domain_name basic_string::_M_construct null not valid void zif_swoole_error_log_ex(zend_execute_data*, zval*) A N@ swoole_exceptionBad function set_cookie_headers requestMethod requestHeaders requestBody uploadFiles cookies downloadFile downloadOffset tmpfiles pipeline usePipelineRead trailer master_pid reason finish in_coroutine private_data object_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 reactor_id connect_time last_recv_time last_send_time last_dispatch_time recv_queued_bytes send_queued_bytes total_recv_bytes total_send_bytes cannot use push_back() with connection_list session_list thread_global_memory message_bus socket_list socket_out_buffer php_memory http_buffer zlib_buffer reload_count reload_last_time event_num timer_num No event loop created socket_type fd_type out_buffer_size accepted_process_types backlog connection_num 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 %s:%d: %s: Assertion '%s' failed.
,P4hp( basic_string::append basic_string::_M_replace_aux basic_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 0xhX(TD$4[json.exception. ] <\,,Lout_of_range invalid_iterator cannot compare iterators of different containers type_error __builtin_expect(__n < this->size(), true) /usr/include/c++/8/bits/stl_vector.h %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 __builtin_expect(!this->empty(), true) 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 77777,8,8,8X7cannot use operator[] with a string argument with t@TADAA4AtAtAtAdAtype must be string, but is HB CCB C@C@C@C0C{} {
": ,
": [] [
true false II4M|OO4PQIRvector::_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 dh hgggggpgXg@g ifffffxf`fHf0ff feeeeepeXe@e(eeddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddhddddddddddddddddddddddddddddddddddd i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i i ihhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhXhhh@h0h0h0h g_fufufufufufufufufufufufufIfufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufufuf3fufufufufuf fufufuffufufufufufufufeufufufeufe8einvalid BOM; must be 0xEF 0xBB 0xBF if given invalid literal ggQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgiQgQgQgQgQgQgQgQgQginiQgQgnininininininininini{iQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQgQggQghQgQgQgQgQgQgQgQghQgQgQgQgQgQgQghQgQgQgQgQghQgQgQgQgQgQgiQgitttTuDtutttcannot get value cannot create object from initializer list M2_2V2k2D2w2w2w21pwqkqbqYqqqqPqe}w}n}}\}}}}| 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