kA~!aA<
p ?_@L Wv qA?[ o6'owd$ |G#}'? 'J_ɺ\\ߗu!#)MxW;=}ot x ڠ6cwchqW`>G L]lA > f fc|m
9"P[%dMņ J-S)ҙWT<v[F_:|6ãa2AbG 5?N-_em؋
IԜ.1 H$8ګRR.)խj H$ja`9?{Ks ,x(CI-wƯ㺴d8[UTRjњJ?핰6jguOf&DR
I fFO=NZa
TǙ_볹e^C ߥLs/jO?wML0[6~Y=Zt5j|j^+ Pd Mi7VL~, X=&c+)O ~t]ʖk/z-R
_H;l U߶ I¿'!䟭q*; k)V1> k<`7h>/x@g%
;-`PYAץ 7j
kف^ 2U3\N Ona
<)a.Ŝq,,{r}a
zHU;sZxeqY4
-k$jVL==ݏĈ# Tu,9!a%O;߷oةeUFlޑܭ캻z^6qNb,*b{oK _O5&9rrgzd ӵa|S_]=* ?iߑ'=!Qw!"Hmcs VO#ե
d(]~k7ѫ"H}.t0)amx{)\htOJ7>$'{7N探QG^o sǺ$ܦYeߵUJF=k|I
(9Zf&mNvI)G.~>yifdUT2o]?쌖h*@4[/)* "X>2pE:٬zC0%s_+*T;˴0FǍ ob~> ěutCO6K|offm@_;P>ze
w;>xȞEh~:i2* 9ݫYLyz8At}oQlyNvq
,'kJc 8ϕv ?ďCkT^PKa\x|'R[x$vAN 2;Xj~g~^yh טvuψ 8t} ^jf{6u{oOǐoOdt^PƓ[3qKǾrR㭋.vkx# = ix0 }A%l_![pWWqS2gsU =gC͞ b""əy -WRUmr[J5g$8U{SJqݙmG4x R;{O,2Sa,! )
`hG@as]O>+ApgoGyjx}xבq3ԍKՕ
i
>]xNP{m4Ml ɤxS%Zc,kg
U
䩺D9Ltԝ!;eB;=-͌뱏">pI"?{>b| PY8s_g@ v'_\ i(QnZY5Eu=ʃ1.ݘ^wc'{ә LbhxvNb(+BuT5ž %8F e wLl~Rtl
.2d*1)>%aLW֑pv!>UkjYc uc?i˔s4 PB3c3i>{7_ (15|pUw"0W 玮%lrzacp OiǏ9I dZaoR?=tฌ<|bUdFuBH1Nv8, с%pxQ=87
rNoe< /X(?f vy/6$>uϔ&$!!ᅁS~W~j^6mtK>=W7$W [R<Oh$5(Oʅ 2lw= xd R 1 t }kq/Wvڔ{gڻ8~E[C? E3 %Q>Mrېt_s:Z̰G ?l>(w-\I|ǿ>ȹ1 ]t ~cA,l;<}MfbS2ݟnW{0}X73^pB Nm.V[JImvV.QdoWdwGl\F~uAn cP9ɝ7!Ut Eee
>7~GnӔ6$`kGw⚯,Ib]g|?n\^; 5U[!;NW thoeSy`<(ocvK\s- e?mVr܍.TL{qbMI䆠1 !a"]/Mϻwٮ 6t6Z-?w4H??
`K$:Gn*IY`sJiDjrk5ܬ#·K$Ci[>{'~?_!2 b! N%OV/IĕC>2+z)vMfvy*D0TnGo.v= U-cB;ٚ4m#6V Zʹl\eD#/:s_-o[dұFZea]+~RK֚gv[1
%&m,[+^JYу! &!\3r kygQh;jϏ}t кUsXRɇfDd_[ OꚌbs0F.PEQhM7!ZtOazӻl g_嶣|IIXrh{Tm6k0r~RZ4M֍Q'E*[.&0eV݆BRU^,MM x3)^=*JleU)vsϞgɌ'q
*w1:yi#ٮ2r3ȫj)њ;<U*TYI]җ<36s@/GKBGraW;w-/
O}t Teu(`L_ Yid*~XZ rQ;$4 d7hY#\+tfݺQ o)O=XJƿyRwh}۷Y4ZO2'UAV&OVx&+GpHM)dndesN p:oG搀#y+%Lj 7<!qU \ƣ垊gf{/;r\Lhf:}TRcGvޒ`AHz;XA _==~$4JnC{yRS}wfZ^殪K~kR8< /RϿjacr@H #Oؤ%2=魲w$~.' m\* <>$\^a{c\ܜ^1꾤ik_vײaeWu'
e/B Ιr !;h/&eQz~ni% xAl_z~n8x_TScy]WA
RWϵ笹S$T훜̟ E<:wrwu~ ]yxEQ" :=래o)Iq\٢ƀGtM eeS;;:"Um!)+Yo 4(-F$Hrݝ#ѕw^S
qCՔ4? =㓜
=bw^ww9xpcT|Nsόٺ:]~jإf?*M,2Q |ɬu;9o4/X /2?9r˖6LJ?i68O =;l*7RCޱ|Mj5/ 梇V8҉mپvP8)dloD
gs`~H{~\ڒK*0/,rwR!-fS ^:V-;KoXx~M?;^hJ8R }Ts$U%iIYr|x:DzSvn̗y8?g*^ʪY AX'Uj0'lR#}^iP7čQbVΟ5~pn``)`ԗ$^:#&=:mgJ*#OYhFw%ry;VVw#Tu(Ts6XEo`8;HL?4bEe!{jL9>=xZycxrf:xGmRդU7 I 9\rg室ZzZ҃mo$/ $Z{q+1t?zVUygo?Dq-\9lkR iPy ֪_ j:fhVr8r!/ZMŨX|3 :V?+y -Q)kMTkGVDSo"el,/c[Ug$@oM)꾍*/O9d|Nq{I工z=
r# A`f9jjG4vhg& H@"V]&P+so wrTt٦F]g!nıu<(bЪ]Ѩ St?4; rRtq2xOdx"yf$l{G0uj-/ԸTm]<2|$*?jBsf?ut]ɑ/Whв$~'F*|1Hh0u2CR$fjrἌA;*Oٸ ڨgGxNYIOGM*-gW, 7\:hk8˸X) E _(S-FM>GdL'LeR]tɽ侖' ]MoUkѠ3B5LU~[RN0̃wQ\[* O r}nV Ns~_ N<璫1U
{[Bm<Ӌo攟|i`WHb-^6LVpDu.|vk,
_+#EꇺωyҊep>yCzфėԫVqV({ʱUo]!{||g=.щ$hߖСrGe`oYE94*2#='0/_xU}ruzƑF}nz11O/iLOgشo7ȥ +<$G%|xcҰA͝fb'-A ŭHZC=N}am;bˌ.\M#/ K~ ;ŅRRم뽺5{!Y?Zz-/ ,خ\ww@xCoJQ>TR) ǟ;uMP-,dj}d=̚hqH]y}
њ%,?&ePIrh)DuF{88Y=Ys׆Λ-é7 ?p% 3&jPŚ eWhM8y#W[V;1tJ[ Ϻ&E۔؟?㠴D~\#{? MHj }ݤcV͇6'Yo
]a>T= [Λӕ2${?УWx 3U R\ #o}{=uȋ5Bs5 !0M|sHя/
h=ocoi~7<5o+B$l+ g \S}:wbs)Rҗ"%.7
n W\]@v7^Lh]A ZI
Ҵ>}:G;P%Av<. wӪ 09՟HCL(hc067-{D|C.
ݒI8b)H8DŽm>|`8'E 9xBIPG%~KkM~ c )6N`ЦG3Q0a0 6E_ya6rwO+z,pL(g\'wui y2<FPjbwZbs,+Ct qcf0dd }5]O K nEgoRrwU]1zڳgw̪x_}yHFy{DTI+b`śi}Cjѱ,)N{ZAοgl <ƾK|ڬ oa D&)Q\&g1_DݠqZ۪ƃJEU:ym}i L'
+?VVWZ=8 kI2Ŗr yސ7{îN`
7? ,)>u_ Z%&[gUBk^VehIgAr u㽱T|hjS=DytAte2 ,}&`@DJQ~ՂR*䵀Ʒ4KS÷4tHje
R8/Gʎ컥`NbX5Ev-CSl\'3O_\:^7X;;;|DNΏ"̨}
|˝Yxǐ :yK: L"riA3 >/ sae_d&.=dI/Mr};X+[yB ]ĚDoMٓiF'(wu#x3E
߉N)
^
j
peh^q0nL9^/,"Zɐy&.˅:` Pki7j5Vwd#VT0)O@P Ӆ eo&9ּD! *?mߏ̋"-& PׇW0 P&8?Is"|Y"3Gbcjk]Lk4OVgCWcl)!Napn LQ=)nW(>cCt'vgOe< }er%Vx Dx^",m9^;9^"z(Fʥ*ܑ^Y4_A-Y.>bcT+έp8 Z,@mp=p?Q1p^h|8[!=*2Q"CTLs% urp7 :g[A Fg!br}nktP `cBAHgP̜ ]m kDhK.߈ޝ.Jb+o
Q}æiXLkSƭcfZ{n;O>TPkui9 )Is&ΎO匬a6҄<'*2%zkB!Ҋd&&ul;ש6r3b)\P/1%$d'4dpJlA9NS gWŸ^@4F{qܓ^ 0*m"hK;& "!蒕k, ,4zrFCnJ>ox\rsTiv#z!a )2%.Wl墉9
I[xҳTLw2za6n2 drPKL>뻜<@6 f%#؍0O.H!3H=לUP TEIW1mo_ˁ5
c@߬ CoVū[M'NJ?[1PרNr?웑{)r+Uq檓=E]TFZ>1YQD {|O8|SOm+v=ߟ22c'mk r[wVY)uWAQȘqfҦIp ^M&o?^ Rҭ
ސ'lfОR{]rC(}B< <\ll=g$k&0ՇW-Sxn8i p(*h;M M|W/jJB4]UbX_Z-*USW M+
)xFj-5n~&"JFmmv0dA!sU&cǛxŒID
_X s?ߘ7pZIjn;t D`yO>MnK*xǵZSY|JԿ/}1zL`Xw;%p12TۖwǑ
=+?v@ݮsE$|uyqV0XuݻJ; DQTtk;Ǐ/RSOȧ=0;Qn|EJ$}/,1d։|L[?%&mdVeVՇ EOnLb pM]/rs 4^WSz~CBEw8t:yc R#eOo@Ahg?ZHen1 7q_cA`#; AGs9Gdl9 HC߄x_6Ũw<8%9!F{g
)g}$/H ç]Y ۈ:?P,cڂ]BmC'!]|, VM?=~c±:m5s% m ?MW:8:X/}|IZ$>DMWJ?ooONm#ҷN ԭ{->QJk<mR\Ue5 .\t]SpB0))a`
:k+1Z|1QLߵcg =2%'ό۽a]{rc礢eQ-|U˷9tBx'䜊H Gv%Y[zLYk0u.<۟?Y,jX,|z3b>6Էc(S
}_tٛ[́ޔ"g=WiFkf"hY-eE G =C'/af6_
Ğ:)Sx||j 'c> l{|Q13?f⪳HDھ8;XW1
aEu$uز_ LD^Qy YSy
S,OF)qXVR LO9(ntVtT`q!x;D R2n15E?oE !AEM G\Zs~N 4m9\ٻz`&qy]g+\MV [#gG?[`mj}*K
x>ZR['.2~{bWfX?ұH M4gSlnTzX}dl"hl%YE
}>aOl C6V WGҿdJGJ7aCO/evѷ)u;={7hq}5LkzzJx &5MR23p%RE+'W~z? ALK'Y g%2:_)?̜8Z¶ps$*-[!N`a eeLz}#^>BAj m[7| 0|gRֶbCmV+~SY%)wZR~K?O>hcswKA( p9\a}tzIvR;zpHj\dO֍ if'iߝ.w}{'8/ χ mͽ61( ̇ǀvɨp](?XgYS1k.J(SebW{h)Y̗=J{&ʧ/6ZOMl3Ty| u dQK>
7m}b\N<ܝOqtk#Jظ{W a
CGW黇 V!˷Rye1 OMn/hfT}sOÞC+>%@WH6
'Op%]UaOAqŗRGwu.)]w)_yD2.
EtV3}%j`TJ}?\X:_[mG=NZ]ugzyDHqڍR/77'$C Nxt g.ɿՄ.ky:]RM˚d>"yX$: 7~hnrr%˻yCMϣ A xK
dcp<7iR l|)S/NSMea}e3ƪ
C0xQ$_B%TcW̜ Xyz+'RP刳Zo߽KסןVE @JaMzdjnHPd3TxJ/98%{˒3a!vRB?p1sQNQ1*22WVQݺw
u 4 2ca$lRq2t1vuc #H՜ʕ}$ JӅ973?sMϢiWShI5lg!pB6[۲zwRz1kh/g|GOt[Gv #Fau)չ͋8z3$v~
VV9l)91y,Kg@[1=n4(k>t jV Ý'AʗhX"{` jg U71i3`X@l) `!{@XVe*o +x{Zrғ)DnN0of93g E ?7_O'= Y3κM)TYzMe3K:Q9jw\HJ: jS1& Q)T 5x݅ ugNT`
/uʚX3f( qŧTw9 w4(+k h ~sb]qu8LM9@Ko^p>. ImMm;׀sVv: gh2ê4:T;` KyTvOT
UF=킾@g bQ5~}G- ^ է\_^h, Vc#-ič:h@}R ; p9Z9Ft;~X5M 4y ]~5F kQ8L`@qI>X :
pO^͉QvVWVQWaw8 +l#$% VO?DW22{ÈcS
9r[&cy,`ޏǫSXgfk7 ͖m na _JB/y@yrUN8j7ʿ9/&kg ?sxcK ]u|ysg O_/N`&{ WȫWPF4j]4j,ߪ?͠oŜeU]1oWk, 'mi~SO>ਿ|J6G6M-:-q\%6D~]B L^i/\bD$IG aOwp c2|< A
ÅGV&֛1O Xda cLay] Ֆڏ$?qI_S'OeWR#kS嬭gXٓ2N `HgSX 앢J/choH[ۀ=?.Hmtz4U)tuhVƚJ_gdk8
H}>CbˮXdK)p[#4zl3|f^] /W;c1<$k0,d9 HZKuBaԾC_op!J!
4כV6 sbzY}{
ʾ%
-B[jl0"ҝ{a%UUGFXG! ǨlY1-x
㺇p@e 7'k{J8NszR6 q P aY|PF I)r `oSC!݇ _h$@r9j[ rFߏfÞ pK ~\
0ՀYh}L&m}%h(nG9c9`Y:! t̾!ϒ0{=pdXxR6o5ʗA|kغ=u$nƀVsyDp
!}4>+D8#YP|ٔ|RC5n .ifw w/ճy#*W Oaz.L +U+4 / 2C)2 eaD% $, 29o-%dpnch) R вQ{>
[;r9f
F 'L; ՙҕ|yo)春 ІI)Ѻ~|E4I3( JAPfWL \Ob?IEYl
9_"þJ*j~WtU/{ՅcCA+b1)kh7J5|vP2,ڿ| ~k~
n .C6R tI(ü\-?|%XJ <ˏO߹3n;BJ8PP] gyS_C)L]p6FN°0kJKΰJ| fR 7oC˅]=3XƲ*.83O-Faz' LDanRqqdJ9߄e 8 !^GBn& w|?mq=+ݭz6BՆ5ϐCDzUt{)2 yD%gh ~xp]?$ +pF?ʢ}*x:Q1CDS + E۫H9݀!7P%$riIFp#epA*Vt!d3l(j Kxy%gA7b\pڷ~Z^X8l)d.= <ۆTO_]àƳ=Q3~vb?B |RNE>Jۋ! $iq Ğ03 Xvmi>z=1 = |yY6trphX**`+BE)y& wwB-LAS[L>AT,`aӼH+뢄h <?V{TG {y?~#5)\
\5@.)~M(B%kD1< ʐqg]:_] U|q'ᑷ馶鸀&KkC
AWړ@QoK*5ztN+J"6
f54'\=Hų^UWeD%ڙ_,+K[f8cZ1"샳cVdK7
Ac| 0
>z5Ȿ>3h9qҙPY6^f) ~%IJj^Dޟbfc b lmQZ W {UN.N*qsLbઁҴ
l?kZЬ;||
,r)8jE %% ڮ,dž/ o.rλ1)5C6#0 XLeAolq p
L B㱿 )X};6r`q ʻtOA|.am^rMpǃǏe?2 aWbŚ}J}2tKdm"}fY :@\t7w*T1 ~q7/ QţGj ۀNl+f1u}&8x6<d*F1ΰ.=by! `_bYNF&< :髺RHMb$;
R@'3UTc
ebU]胒ULeJ#W,b8c{,(q $ne*_Ӿ+%V 2rqO(ڹn$삺5z>%468%5L/J]ֻ A/4[==ZksP#W<(>uxw݉k
ye{ʸu-ǿ F&@jPΜl %#NHR O /¸zQLBѕ'ꭽ8{
u0!Ⲏpq r2D K+qlM !Caύl0UVN *# &9aM[\pk+l,Ri8fB2Z#sjR6 5myl%:
=oX"O.Xџ~5Wչס j[W):Y}1T@ .;{ c5l=dJJ]|D`~$z%
P~^ (lbZ^~aSKrg?,#|~ xET/T=bdC2J/'_rY k}11)=tב2DA7s7:a"erLN!P6ޏ5`GQݚ|OO0Oi pAo
"[0F*:L Tx
N hrraT,$6 *{ ZsՇjRlXꂬpc-*Hv/ IAc|OSBYڕoPsqng: Y
TQ p,#a5$G /M, 4y>wI <˕
K*f KMX9*.gH~l}*
j _I¡ثO:>;k#M:R?0d5{`֛f(UJ/7HG>[+3 [?ق8Hl`d*CNp څ8[ R+]߆؝!ɫ!pg(R|Lѿg'㧺jT
v"D#f'Umݴk+d76nd&f% *,djBКg#LTEiIi 4w`FGMg8#sw kcBKI0NMEhUoӸ@Kg'C !S
yVՏJC1 4zKC)gB@~RzE
opM a{/O^@lN PُA4%& w/iũ|U*"N5:&
ÏW#~eN
,"0[28+CL5J 7=kƣt :8&s6j75B V1{^Ok<]^t59ܳzFC@߱{B_.umݤm F]+u#P OeP.r3X}1(y R)d Vb^&𡡛 22~M"gؿc dj]
[z,?UѸO\^~>UuF_j@ϲxA]\r v~pYК(4=vmÇ6>`'>]3A1?4.K*q CaCvhw= ̀gP ?83elnpIcPN/d+˹{!<|""4:a\p VO5y+[ ) Z{Svᴃy [ C ;nhC9T p> )b΅;a*6/aS ؿ+_@pTd-%> ɕ y;
P kt i^Τ`SИG{ugB혓#
+%Z S>Xۣذ5WwgJofhg- 6d"`~]o ljk]3x`܂ǸB19!@P }pf3W<2[ uk)3c0<0asqnL[:GK\ 8p_g:Cs9g , *z 8`;;um]2
GM^C֦ W:~`4_jnGL7O :cƌ`,wqNߦ~ @]꼔\eE71ΣVkt+) ۰ y27(.͞?>AnBҋl#Q9DF؇FeEstl'l^*Z:+և
B(R1]S B7"f :%@#9߮BoKB^~I9"n5#X^͟ |ڥҀdMZi~8&{9BNTR==\Y]ԿF$.VWr]ƧZ#K˖'&~/.G^|<jdkC8yD3 ;rZK+AqEQVJֺ$#2ח ~]&5lI:O
pzZG8580
R@& 2hMvs(lJ5 L"kd<@:뜃PpݺPE7 ao
*~pAu G*Z0L8lMel?ν0 G
1?A)pE #*ˆ 8O.M?Y%:Cq6J {ŁYVD%[;{: 6B*aq7xg 32lϫt5Ewؙpqw -E՝ %\ Jj6 :\?JTޒmt%f,AoGFw&ؓ;ebE ug_L%Ǽ:cKSĐ|t 0c;
1>lJiL KOQL("*X"!Ff7
h,n
Ɂ<$ł5t·zac` ٬ O|w`g-(7ccG
e[?;9V!OW`aXMB۲&˭xt5
(c6EŬqN1psN*{RkOJ!8wAXqQF
i;jCѾb>-r(,a[*̪*~Xz){ϯEGڸ֢.v r w8pg)NobFJa""{ ɶ2:: C~bC6u4s/Z: #Xn`Nksps>D \ ;q
ғ= 7Õ.zƹyop̘Tg&^*ёCðʛ+w )
r*YQNPI9XGYCY ZH"0
kEH-t/n_'m6(Ųm!/0! 2
VDd 旗
zLE.+w vR2Z#)8 M)YIVbY}
ӳ*euőңm9D$J?Fr @6f>t>Bj2@sn l\ʈ/Ih7 o>9v3%mNOb
RX!@al O d 0 dBXt!ʤ; }rT墸0 A}&}:9-
G^߷jG~O:E7IKʈ?E IG
{ DDDq
ϊuFd4 6e8^*sGYwqJ.D<2./ \fdtun_J9j aW<g/`!Qh.74-Z͈
w$㼾oR*(jԖ"*H
Ֆ>Qܔ:7Ugۥ/Ldy(MN)W?銿;^yrY3"f7;ׇpSLRU~ K9٦4ǎ#cvJw c Iwء=\U
L^W7|\5PR3rb3c%挽ω7dBt?<(ī751Ni}ǒ_ܜ֟\ |d6) x͞ߙcOQLk#M3ߛ9O-|v9v篩ھѩ*ִ.U OsGFW_ea>}
'fn,al||Z-|Sɪg/i I @y;ו?Q&\=Yf!CV\ HU>s{qc4 KO4OhHriUi6W +1&iS۔xO;JD(нmkߣ^L( ħ yӴ~&ʦȍZh\fI ܌ԑ8&+y(P }ER
|M*p#wXC mfd4S| C軠wp~QC^I7QIN!L:J3Sdtʲz&ʰi=D<-cM qBhO,{DžG83\mŵ=LntѡYTK_
zTdN:̅y'VWеd^ob \}s_Ҹ| ڨRS61^ҲȒm}1`b3N}
#*cى{1N/Q"L
48 qC#r¿}MƾU>tXռ %L6NE^ϱO+0O( 3}_،C866Q61^ L<^zY=w>{y&:! rTN
0MiU_f]4A[R^,{?_7^QiA\˔Cp&d'}6?a8<o
՝$^C*A<~
a'] @l)=N#?q}+ gLeklRh 8(Xxԕ!$ MJJ,CVDڨqܚќA.E(W̼F-+! {cpq
m ㈖% D[_8dB&߅̱;t( ox6dD1mUUR5gTgzh1(XPdEw{*#㌻۪ rK9wOù;Zw ?,Np 1 '?a>F~9GdL|H:8Qe&Tbz5Eg@9 oW"2-hnfĆ>q'१nvt#Ģyp)hNǨ;{i
/~]DUfm %"TA'sZmi~>*]EͪX<[4wqHAI:54[#X?Rpibr0)M 6zX)sP7-eКŅ=0wWpp _bJYi Ff:1HFp3MFN2de:q ]Ӥt1EC2Eq1\AWqTqæ5;H l{cW @kB.tCf.o,/,3`\͘W<4NJ5+խ&@08+yZ ed#bߠz-<4X6` !p.oԴ ~ ߀gQO=:Й&$cmv#Dx_S=]>h0q~=X2v?q73'V5T7l9֠X-D'͢;˾7覱2t̖?d տvM0 ǭwAlFdyJ
j^bTfUpʅ- X3
%$*(ٕ
xL%W $1nπv~վU0ԙ@-.[өa te
0.L}; Ԑ B5o`" 0 H:^K |B-> L^c1P? [hN$`mXlxS9@vQ;Ƒ
C$ l.I?yv1튮CDg `k c''{n Щ{nZumKW7P^l-[]s{/zK|xH 9˿旕l5٣c+̂LOSD/J=|Sm]ct'J 3=xԟveQR`nZnՕ ^OMk9g)#CbQ7 1D˖ ?'s8 iy4=< =?GL9eO1LMYT IP ,luc' 4
`^>=:/~3 2?o,o.7 >:ۉ]llV~եviM+Hfm;lE|첐r"-灼T'Vgi)6}-Oˆ$ieo?N# X,t_0_B
ܳޣuQ8qΞ /MA=>R'\H+q)kߏ> j8>_Ty:Put1.' ^y
HV&` b\ w}^z~:uyXfy^c"fOY9arưT$ //VOV zxn\ aHb l^PW {NVkG脑 "]9Y5 Ā XK]xU)*jTpnu O!NN֮!Uu!Wms86Rgn5W)u}obނ+?
6 EBNeOw>uJ Լc SzޛWB/Ċe/KuWch{%'N~ qӈlv zw>4(BD
6u\GEy^e}it#%(qaNM[6 d:v*%W0љ #y-^
? 3 0ova_=BH_+T<{]?^%^(ۖ"o :~Lۇ( )nA~ڀaZy'*JPēLg-mзy?${) \&tzQWp ~N
$DIF%egLb{W8#,}6\ l@n_qek{P/'Eb{z˹a#0.%0ݰ:n7Ts
'=˹ T@Vs#/9"LZ NncO5{6.ZG;P$ZN (
}`%BvFUY2@7WQ2wCuEyT2e!F! wb*Lʂ6QT5fW(-?G kK_'- [-.O+,TU \0Pk~T) es.!]bʂ ^`kp ipSWy4{TfqG̼,'mF=20b3ZE1ĔlT6bav2c11|-+WȯWQwg#beθZ+2hm?gZE܀LD⦛s
Q11 NY 5%CC-}k}BJp߶ s17'wm3s_5#j; e/ H4NqпaWZg Є{PUpU~
f\ 7>2 .#F{2r8AxTgD} վ&ꜥڇTg72Oڞ+% .j"V~Km_@"5!_hHdHIX6&f"OYXNo6-ͳT;:nضmTAEB8oZWD]2oLy=W%,s 7x7YKoq߸{eB{+h)-M機 cR%xmm m15/ˮ*ҟ>d>Agf
ۼL~%zK/HE,k
p\r$-_pJ
y<(>$WA,S,{.kb>={ = S57z xKIJu bmqap0f@%1DD_=!xbLg_O t;%it
Zѥпң
,Q'PM4((*
***jTT LiWQ GD ȜA_EEE2 `2 a!)B$;;~o8u){WWOJқR Kꋟ̒kRb |
8yz7$"$M&l
/yʆ蘶Ֆ)Gh*R4#srKJ/q Erά9W,GVyU6^?::^:1\pN>!]KrF T
PH,?VX*t,c/]/XIJ),qǨօE5m%=I_qkâDiQj+ a EB%nȵտ yr7:E}YfhjPr "B7Mk ^rXIB'nM1E8,*; *8iNO~Rx݈UЭ80Q[jAeQ`ix#M6墬2AL84ˡ?
~5"PAq'*Ul%^oрC\y`>iGj) ʃZ'A@3I~=[ 11 Y$Q CIHd=="d? 5%ɓ Rpz*x |JG>g^I&DskxB[ [LwS`N/u / sy@8G7[DobH&=:ʥ=iSc=T]I(n"u!E.Q-0yXB3b6Dϧ[VT5l-ĔblǸln@\$Z ~8ٝt T8b{G ~j4EK^ ;(njGM
a<6mC}ZzY+,wi i-@KX
3`{ΝԋOb}w WN\;GkfCd(fbY:]%p}ngiu8] Λ&0z
&=ϑmc Frg d9|3gb8|;&t@cnCD#8igdwE4PC}K*=#SFpH:lt7(J `TH)So 7; N ME Dn2`Y>9`d^np&Mbq^!Qs17+
G lU "sq"|dS(<,k D5 j@Fis4#|J5F2pmҬT+i_-
ˇMjH] ulɄ 5uqz rOoD
_4 ;sX͒ NB4<8rf9 Q$E
ۨ%ˤSpY~pR|JI:~zb ,l]." v!xu
VܧcH4[l#7g#X6;GAm-f2D#r<'X[s2I p@N ] 䝤Sիp f.1j EZ%ԖV;%^ fe;0! SĹ
ot?2% aQpUo{
%^Aq$''Pxq iȈ [Y T}
I2 g38|2!DqBZn,5cZ('䖪BE(s0lthǮdYx :tGκpZޱL#AӤq
gH3QjЅb'09Bbr#! *'+i YnOGDr)v4_hUA_!_ żtQ1R>F/K0hwҏ&@:2ԣ#fC8bffS!-i
v+슎UKg v_R]+|YCBI0Efzf܇2
/ ι*t @q
PC
1o]}(_)e
Cmɇ{'~\+m'| Mv'Y%gm&o3Գq߈O7euxzތ~5n6~?]HZQ. '
Κ Wgy}sb8-<~sqPZ`B}-h+}7*7(Z'Ρ?e㭽zN mN T1/_iߺTr&%ߔw?*1}nr_6̾b#j6V-ڵ$O.;hg9t][jDŽ F-t܇kKhjGaETyo͊p
vj&^cWo ksn=xjNL]Sl n.gjiΏ/ 0b8PwYs1CdmMN&^Kk *d|9γ
|dƗe9;͏sE+R #ZxFj
h OX oe| y뎤|uᤩkECꪳzu sEy#=\ܧo7ޖd+* &j,F G$3`F w]Q2 JΗU}`\e߳ T2 kɾyrN7%avǤC|~ A{/W3 Tq܋ ;?<ƪ+5rIL /v4T;Y|ٿMM:59- \/72 w ߎS%N}- "zm_nF5AnM4DMr'o^PQ
y#MM?SW3wEɼ]uXJK=xzM8*GwݒV L@>ii~##kDӼBI __, וBÆqבdGh!nW V :7 o)kgBׁ;wJsc"^ E 'J-Ι8}-_w<*[OM" Wj@|AW4&G\B+ h~ H wCQVDZ
1o4S>.u/f6Ӵ wY- aƠC Š!-g(Eݢܲ>QYEpfZ"qQփWar|p\>~BVU9Y=!͒Etgr]=@`vT(YQ~M]'ROZwEnr0`
'I˶@gC=f@`<$o ߈yG[X.Rv ?#@ v%wh1&9geSde]
ai{hiAD/
P^mG"kQK %nx#`f(Ylv -Dhӥ8
Չ@%څ
K9:2V(k0#/e o2{_ݙRiRAo,) %cgKAzTwTEnZ`m^fMHJT>fT-0oGo}I#b#OGQ 8jv J?n/vUxRl XUbtQM{Ny$wȨ@I褶>-.'D]~Ye+&qq,h3t`0}
> /pD(\v4 焍96V~-<\|ka 'E?ګ H]1Q4`v @o=6%8y Pԁڃ;=P i5dq :5Hlz:|EE OKV\ {zMmq X[A&eW~˚^ 21t%.+WYޮ@^1 Su+aTkL0Õx!|K_ JN e 9U] 5b:3rQ"3xޚL^
[F_ Nq\[ w[&yw\HUKYuW!x[ !~AeJ1`EM:[@z.ʙZ ރM8 J>&]x}@~)MBU^*"|fPcM^}ɯ3~c7"i{SPUge^ɨ"@)n@/#ܨH /h- ڼ s3U`׆l=(Q&CDŵL̼
{NqÖ}9D$f:Y[8qd/_hAmOax{N$ND
h!]:Y D>:㎜Uu14癭k \ uY$Iﴹ)g?5iFg ePR-ߚiM9g K ZF۱ ˈ*Լ cZ*TkF.!
2£媽}
N_xhl=SuZmQh^!x4Pw[X*Q:Vz2mڏ{iOIkRyJ)Bk? [(km Jit-ksFtɢ4Π:|.]z^%NhzUrW VY_hUR?V+rqX UZ'U!Jòwx_n:Nc]}Vi)|ؤPel=FYK<]NDu
8?Ԗ"֟P,طC jdPju~l=84Y kT0:#Y4N}FW5Tf0Q0
vT
u@]%&4 ҔGdŷZє
-*'[U\|
}%jߓkީnAta9VZ7Uǔ Idռ47By~Y͍j }釾ܯ=|eGUԄ^[4j^L51~蕪߆_;WtL քB
Z&gW
BEo1(z55&Q
-leȫٿhek}Y&<-]BK%R}ꗦ5,97j2N?^١۸c~㨬4y (E`}慼*]m>MtU#B*QzXsXV(V=;=Y\ ~ڮbr#UYUU-]*g|)塑G̫5Lz[JGOM L˥YZɟ^Vizl3fvI)lep;)}v ",k}(]z[,[S
N_q 1Mbh\/Sm{,{8?eɛV ݺȷ4$Sg z_/ }aؗ0`g˷fI.ŧf[w4J1vƵ_WGE Ɣ^Iրw`$;Qϙc%ι>Y
&n;.zBhO Gv<,;_*o L: 6e@-wE5 ##;'-'?EwuwVՅ$xEP ]%^CHD1*ǏvrI0(@@GxGV$U
Y
jk O6 YaA$ʥzuh;*W;@ "@^; FZ&uNZlGI^D}FI
Rwp: TXBl p `$V@dJQRzf( {y&`!^:Gx^Y_h*, =24f f`,IȁO~-R^.r :WjP6o CM; NK7 ~m>jL[@;g=T玞*A+m^PK *S
{?>$SLƢm= ȿ;\N ,͟r> ֖TM+Ɲ:t,[܉|G[kEꝈ
2Nbwelbm y/r|JY 0܇
^M rھsDDbgAw"@ l@Lz"fY[YU˨GQ]HM,kl]7&Б?.<+|rO7K= jC!e3}wNJbiFyc,\0b`JMJ8T⫈
1r@[< M{{&]V"I.s#8T^C@.BB))DyWe0_|9ÿM f=4xDx$_Pi,vf0(< POߍX.jc%-,gy3#R6
ӯ> I{0H]*Vኄ%txw0j z4¾h ZAh?L")=ϐpL(pxW_aTF rKa( =t%y25 OQJhP;1SH
zev
oDEl:ѹ UL`bp} P\r; ͋/LB䘯v{Øz1ԞY&ķ|Eh܆bPՃ?b pA@ }2g@?p@#t'SqUz05o]
,ߔK Иc3%bLN&5X]In*{Ӄhȩn
#.IvXBϹ|`"1y̕%O/=^ydZ۹~̏qnmsS'g[.rʹtx-xXęTcZ
ؽ^A?(f↟|s`\$vYgNҕg$ڝ q`Xp4v=,!tS+]8-f ts]A YQ?㦈g ?1wʇ';Li& Jچ#?D S_ ^n1}*u ^%;J/7D
;&*M̐:"$+0ly"/£a渢P/-܄Iȅ""n0,5|_$ KVPR"Y fк8A42wߨb
1>Wvy&{ p12
F1&v̦:!f7
q +c 7$Z 3AyH-ÿ-x-_tEb=JJQ$7U# 2b ?Yx
1&-)7)1`Zii'>bE2#FL=
IǿBMxW(~'q0'%@EeiR\*\+>.鼄y>42o Ul9@'U#urB-s stQGdĨs"l7(
!Cf ,_aX䶴X'}8 NS tLB KOɸ>v
Zݲ-'LСWV$u._(p◨;>GE,n2" pQ K'S6r*?gd:v9<,Ξ_V/:8w5J Y -_Ӓ`WtIb`cbDށ"YؿĹ0#%B}9vL"} Grh2)nad(:Q2&++|1?nt@ j}fIE*?wɸ.c@ #O6Xftuq!x9X| h? $v0~eT:"KS8G9"3& 9@=bLatLUH;*QC1ÀMp}$SÓ_zˍ?ߣj!yq
P{"6E/\?!Bd s@z
hdҜ?r܁byȒ
Le!PffS)!LS^6ѩb xFG 1-tнP7/An7j蕯0\ r[ ^js
jQWHx?/ic˶8'_E(s[ɴ?W1`!x0 GHr%Q_b,UBrIR$~ H& H/Ac_sRY4%6NLQrh^ÔjzRMGQg0' l\ߤwZo7
1
2msqpWpLä]ɨ9{{揟
}8浕Lƪ=EѨ
Zo X 51 T$3w}Z? ;Td{oZV$ʆϛR 6o86v7)1UFml>ykE?ZR/ܘ=kMLr{Rgͯ߸~*X9֜v%1)'[ ?FxwTd'R7 h9n^e5fm6YsTJPisD{֦mv7S~8qt1,:C Sn՚>mr~TmUGGOɞ4M
!/[ιr\qi
i;'KX^-^IUmRX!ձԪ|j A9 lS£2f'}6Fns(uy]νPZ;
%
XU*?&Ԗv.W*
cnh9S0c a_f-}އYbB n^oU/u(z9s^Foߝ|=iU~ӝ,źд\&}m,9u_c;M sg9}:*_T@wz I; ]*Ѵewݏxv,.Z uG' r0Kғ^EQ _{cKe;Yj^˔mT DĊ2Xn^+ZVϱ 4G/u'b:\E{VԬB/( t]Y;An66.s7c굼 ͡QrH9UF,#A=(f9̼\Vj*?=[ÒN#J4c<~lN!j
< 'U5
B ME(^2m UQ~wcJ9=-:%ʰ)d:Xp~gZ|e?gu5V~sV=8үok;HKeN zvso]CXnx/KB>}9p
-areԹR7m3yiGƋNR$DzܬN|<\13# dD>6i!gH( Ϻi@UC'm/No]]㾽=L}ͪiwllSxBluHגxb;XN s@ϳj'LJ0
66kW%n5r0 d:MQ
Yrcn⍘厶.ҩc .' ΥGw`3o gQu>/1e]5 )Fz͓_WUd&d9'j?%0 1~ zXzMAleؽ w%=[ְ;IA6h Ѳ|wheL}d'<&&9
+:>$O5pB /%fsI4 s eX%˽'?y/cF*S\'=y -M0!}P<߁ x1-.{mE7s]ye? &¾в+] +ri@W* Җr6FmyͲMٹ݀p\U0sWN8#-_BZ2Jd &fv . s8vvh
;C/y#1Kb!ƿ|Ma; y [u+5}H?s按$qfIN/٦B9*v#0{x ,JTL%.*FS eQʐB {ROwRl C[ѫ*Ex4Vp!0ί v(1(=.J[ 8$> h T1ݲ-duqFV_ 0wc}_iYk7[O92{!i)q?.zz.͚TߦvzALfԏ<٘kiW'V]ޯ Sp
%]Q>:a!/6eLZ]TM-e:?ȾO9@".L8;9: 突ua⧒_ 9, ews\Zw){ ԍ(Ji!CT |S_wP7ObY$+Jn N$5?l^>W3#r#G@C2Pmmjm2c6i7|?jG6r?$IfOLDiOSYiW "쑰ݠʎӘJHG(O=*3` l hg- f;L
const s16 d_opt = MYMIN(g_settings->getS16("block_send_optimize_distance"), wanted_range);
const s16 d_blocks_in_sight = full_d_max * BS * MAP_BLOCKSIZE;
//infostream << "Fov from client " << camera_fov << " full_d_max " << full_d_max << std::endl;
s16 d_max = full_d_max;
s16 d_max_gen = MYMIN(g_settings->getS16("max_block_generate_distance"), wanted_range);
// Don't loop very much at a time
s16 max_d_increment_at_time = 2;
if(d_max > d_start + max_d_increment_at_time)
d_max = d_start + max_d_increment_at_time;
s32 nearest_emerged_d = -1;
s32 nearest_emergefull_d = -1;
s32 nearest_sent_d = -1;
//bool queue_is_full = false;
s16 d;
for(d = d_start; d <= d_max; d++) {
/*
Get the border/face dot coordinates of a "d-radiused"
box
*/
std::vector<v3s16> list = FacePositionCache::getFacePositions(d);
std::vector<v3s16>::iterator li;
for(li = list.begin(); li != list.end(); ++li) {
v3s16 p = *li + center;
/*
Send throttling
- Don't allow too many simultaneous transfers
- EXCEPT when the blocks are very close
Also, don't send blocks that are already flying.
*/
// Start with the usual maximum
u16 max_simul_dynamic = max_simul_sends_usually;
// If block is very close, allow full maximum
if(d <= BLOCK_SEND_DISABLE_LIMITS_MAX_D)
max_simul_dynamic = max_simul_sends_setting;
// Don't select too many blocks for sending
if (num_blocks_selected >= max_simul_dynamic) {
//queue_is_full = true;
goto queue_full_break;
}
// Don't send blocks that are currently being transferred
if (m_blocks_sending.find(p) != m_blocks_sending.end())
continue;
/*
Do not go over-limit
*/
if (blockpos_over_limit(p))
continue;
// If this is true, inexistent block will be made from scratch
bool generate = d <= d_max_gen;
/*
Don't generate or send if not in sight
FIXME This only works if the client uses a small enough
FOV setting. The default of 72 degrees is fine.
*/
if(isBlockInSight(p, camera_pos, camera_dir, camera_fov, d_blocks_in_sight) == false)
{
continue;
}
/*
Don't send already sent blocks
*/
{
if(m_blocks_sent.find(p) != m_blocks_sent.end())
{
continue;
}
}
/*
Check if map has this block
*/
MapBlock *block = env->getMap().getBlockNoCreateNoEx(p);
bool surely_not_found_on_disk = false;
bool block_is_invalid = false;
if(block != NULL)
{
// Reset usage timer, this block will be of use in the future.
block->resetUsageTimer();
// Block is dummy if data doesn't exist.
// It means it has been not found from disk and not generated
if(block->isDummy())
{
surely_not_found_on_disk = true;
}
// Block is valid if lighting is up-to-date and data exists
if(block->isValid() == false)
{
block_is_invalid = true;
}
if(block->isGenerated() == false)
block_is_invalid = true;
/*
If block is not close, don't send it unless it is near
ground level.
Block is near ground level if night-time mesh
differs from day-time mesh.
*/
if(d >= d_opt)
{
if(block->getDayNightDiff() == false)
continue;
}
}
/*
If block has been marked to not exist on disk (dummy)
and generating new ones is not wanted, skip block.
*/
if(generate == false && surely_not_found_on_disk == true)
{
// get next one.
continue;
}
/*
Add inexistent block to emerge queue.
*/
if(block == NULL || surely_not_found_on_disk || block_is_invalid)
{
if (emerge->enqueueBlockEmerge(peer_id, p, generate)) {
if (nearest_emerged_d == -1)
nearest_emerged_d = d;
} else {
if (nearest_emergefull_d == -1)
nearest_emergefull_d = d;
goto queue_full_break;
}
// get next one.
continue;
}
if(nearest_sent_d == -1)
nearest_sent_d = d;
/*
Add block to send queue
*/
PrioritySortedBlockTransfer q((float)d, p, peer_id);
dest.push_back(q);
num_blocks_selected += 1;
}
}
queue_full_break:
// If nothing was found for sending and nothing was queued for
// emerging, continue next time browsing from here
if(nearest_emerged_d != -1){
new_nearest_unsent_d = nearest_emerged_d;
} else if(nearest_emergefull_d != -1){
new_nearest_unsent_d = nearest_emergefull_d;
} else {
if(d > full_d_max){
new_nearest_unsent_d = 0;
m_nothing_to_send_pause_timer = 2.0;
} else {
if(nearest_sent_d != -1)
new_nearest_unsent_d = nearest_sent_d;
else
new_nearest_unsent_d = d;
}
}
if(new_nearest_unsent_d != -1)
m_nearest_unsent_d = new_nearest_unsent_d;
}
void RemoteClient::GotBlock(v3s16 p)
{
if (m_blocks_modified.find(p) == m_blocks_modified.end()) {
if (m_blocks_sending.find(p) != m_blocks_sending.end())
m_blocks_sending.erase(p);
else
m_excess_gotblocks++;
m_blocks_sent.insert(p);
}
}
void RemoteClient::SentBlock(v3s16 p)
{
if (m_blocks_modified.find(p) != m_blocks_modified.end())
m_blocks_modified.erase(p);
if(m_blocks_sending.find(p) == m_blocks_sending.end())
m_blocks_sending[p] = 0.0;
else
infostream<<"RemoteClient::SentBlock(): Sent block"
" already in m_blocks_sending"<<std::endl;
}
void RemoteClient::SetBlockNotSent(v3s16 p)
{
m_nearest_unsent_d = 0;
m_nothing_to_send_pause_timer = 0;
if(m_blocks_sending.find(p) != m_blocks_sending.end())
m_blocks_sending.erase(p);
if(m_blocks_sent.find(p) != m_blocks_sent.end())
m_blocks_sent.erase(p);
m_blocks_modified.insert(p);
}
void RemoteClient::SetBlocksNotSent(std::map<v3s16, MapBlock*> &blocks)
{
m_nearest_unsent_d = 0;
m_nothing_to_send_pause_timer = 0;
for(std::map<v3s16, MapBlock*>::iterator
i = blocks.begin();
i != blocks.end(); ++i)
{
v3s16 p = i->first;
m_blocks_modified.insert(p);
if(m_blocks_sending.find(p) != m_blocks_sending.end())
m_blocks_sending.erase(p);
if(m_blocks_sent.find(p) != m_blocks_sent.end())
m_blocks_sent.erase(p);
}
}
void RemoteClient::notifyEvent(ClientStateEvent event)
{
std::ostringstream myerror;
switch (m_state)
{
case CS_Invalid:
//intentionally do nothing
break;
case CS_Created:
switch (event) {
case CSE_Hello:
m_state = CS_HelloSent;
break;
case CSE_InitLegacy:
m_state = CS_AwaitingInit2;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SetDenied:
m_state = CS_Denied;
break;
/* GotInit2 SetDefinitionsSent SetMediaSent */
default:
myerror << "Created: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
}
break;
case CS_Denied:
/* don't do anything if in denied state */
break;
case CS_HelloSent:
switch(event)
{
case CSE_AuthAccept:
m_state = CS_AwaitingInit2;
if ((chosen_mech == AUTH_MECHANISM_SRP)
|| (chosen_mech == AUTH_MECHANISM_LEGACY_PASSWORD))
srp_verifier_delete((SRPVerifier *) auth_data);
chosen_mech = AUTH_MECHANISM_NONE;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SetDenied:
m_state = CS_Denied;
if ((chosen_mech == AUTH_MECHANISM_SRP)
|| (chosen_mech == AUTH_MECHANISM_LEGACY_PASSWORD))
srp_verifier_delete((SRPVerifier *) auth_data);
chosen_mech = AUTH_MECHANISM_NONE;
break;
default:
myerror << "HelloSent: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
}
break;
case CS_AwaitingInit2:
switch(event)
{
case CSE_GotInit2:
confirmSerializationVersion();
m_state = CS_InitDone;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SetDenied:
m_state = CS_Denied;
break;
/* Init SetDefinitionsSent SetMediaSent */
default:
myerror << "InitSent: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
}
break;
case CS_InitDone:
switch(event)
{
case CSE_SetDefinitionsSent:
m_state = CS_DefinitionsSent;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SetDenied:
m_state = CS_Denied;
break;
/* Init GotInit2 SetMediaSent */
default:
myerror << "InitDone: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
}
break;
case CS_DefinitionsSent:
switch(event)
{
case CSE_SetClientReady:
m_state = CS_Active;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SetDenied:
m_state = CS_Denied;
break;
/* Init GotInit2 SetDefinitionsSent */
default:
myerror << "DefinitionsSent: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
}
break;
case CS_Active:
switch(event)
{
case CSE_SetDenied:
m_state = CS_Denied;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SudoSuccess:
m_state = CS_SudoMode;
if ((chosen_mech == AUTH_MECHANISM_SRP)
|| (chosen_mech == AUTH_MECHANISM_LEGACY_PASSWORD))
srp_verifier_delete((SRPVerifier *) auth_data);
chosen_mech = AUTH_MECHANISM_NONE;
break;
/* Init GotInit2 SetDefinitionsSent SetMediaSent SetDenied */
default:
myerror << "Active: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
break;
}
break;
case CS_SudoMode:
switch(event)
{
case CSE_SetDenied:
m_state = CS_Denied;
break;
case CSE_Disconnect:
m_state = CS_Disconnecting;
break;
case CSE_SudoLeave:
m_state = CS_Active;
break;
default:
myerror << "Active: Invalid client state transition! " << event;
throw ClientStateError(myerror.str());
break;
}
break;
case CS_Disconnecting:
/* we are already disconnecting */
break;
}
}
u32 RemoteClient::uptime()
{
return getTime(PRECISION_SECONDS) - m_connection_time;
}
ClientInterface::ClientInterface(con::Connection* con)
:
m_con(con),
m_env(NULL),
m_print_info_timer(0.0)
{
}
ClientInterface::~ClientInterface()
{
/*
Delete clients
*/
{
MutexAutoLock clientslock(m_clients_mutex);
for (UNORDERED_MAP<u16, RemoteClient*>::iterator i = m_clients.begin();
i != m_clients.end(); ++i) {
// Delete client
delete i->second;
}
}
}
std::vector<u16> ClientInterface::getClientIDs(ClientState min_state)
{
std::vector<u16> reply;
MutexAutoLock clientslock(m_clients_mutex);
for(UNORDERED_MAP<u16, RemoteClient*>::iterator i = m_clients.begin();
i != m_clients.end(); ++i) {
if (i->second->getState() >= min_state)
reply.push_back(i->second->peer_id);
}
return reply;
}
void ClientInterface::step(float dtime)
{
m_print_info_timer += dtime;
if(m_print_info_timer >= 30.0)
{
m_print_info_timer = 0.0;
UpdatePlayerList();
}
}
void ClientInterface::UpdatePlayerList()
{
if (m_env != NULL) {
std::vector<u16> clients = getClientIDs();
m_clients_names.clear();
if(!clients.empty())
infostream<<"Players:"<<std::endl;
for (std::vector<u16>::iterator i = clients.begin(); i != clients.end(); ++i) {
RemotePlayer *player = m_env->getPlayer(*i);
if (player == NULL)
continue;
infostream << "* " << player->getName() << "\t";
{
MutexAutoLock clientslock(m_clients_mutex);
RemoteClient* client = lockedGetClientNoEx(*i);
if(client != NULL)
client->PrintInfo(infostream);
}
m_clients_names.push_back(player->getName());
}
}
}
void ClientInterface::send(u16 peer_id, u8 channelnum,
NetworkPacket* pkt, bool reliable)
{
m_con->Send(peer_id, channelnum, pkt, reliable);
}
void ClientInterface::sendToAll(u16 channelnum,
NetworkPacket* pkt, bool reliable)
{
MutexAutoLock clientslock(m_clients_mutex);
for(UNORDERED_MAP<u16, RemoteClient*>::iterator i = m_clients.begin();
i != m_clients.end(); ++i) {
RemoteClient *client = i->second;
if (client->net_proto_version != 0) {
m_con->Send(client->peer_id, channelnum, pkt, reliable);
}
}
}
RemoteClient* ClientInterface::getClientNoEx(u16 peer_id, ClientState state_min)
{
MutexAutoLock clientslock(m_clients_mutex);
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client may not exist; clients are immediately removed if their
// access is denied, and this event occurs later then.
if (n == m_clients.end())
return NULL;
if (n->second->getState() >= state_min)
return n->second;
else
return NULL;
}
RemoteClient* ClientInterface::lockedGetClientNoEx(u16 peer_id, ClientState state_min)
{
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client may not exist; clients are immediately removed if their
// access is denied, and this event occurs later then.
if (n == m_clients.end())
return NULL;
if (n->second->getState() >= state_min)
return n->second;
else
return NULL;
}
ClientState ClientInterface::getClientState(u16 peer_id)
{
MutexAutoLock clientslock(m_clients_mutex);
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client may not exist; clients are immediately removed if their
// access is denied, and this event occurs later then.
if (n == m_clients.end())
return CS_Invalid;
return n->second->getState();
}
void ClientInterface::setPlayerName(u16 peer_id,std::string name)
{
MutexAutoLock clientslock(m_clients_mutex);
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client may not exist; clients are immediately removed if their
// access is denied, and this event occurs later then.
if (n != m_clients.end())
n->second->setName(name);
}
void ClientInterface::DeleteClient(u16 peer_id)
{
MutexAutoLock conlock(m_clients_mutex);
// Error check
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client may not exist; clients are immediately removed if their
// access is denied, and this event occurs later then.
if (n == m_clients.end())
return;
/*
Mark objects to be not known by the client
*/
//TODO this should be done by client destructor!!!
RemoteClient *client = n->second;
// Handle objects
for(std::set<u16>::iterator
i = client->m_known_objects.begin();
i != client->m_known_objects.end(); ++i)
{
// Get object
u16 id = *i;
ServerActiveObject* obj = m_env->getActiveObject(id);
if(obj && obj->m_known_by_count > 0)
obj->m_known_by_count--;
}
// Delete client
delete m_clients[peer_id];
m_clients.erase(peer_id);
}
void ClientInterface::CreateClient(u16 peer_id)
{
MutexAutoLock conlock(m_clients_mutex);
// Error check
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// The client shouldn't already exist
if (n != m_clients.end()) return;
// Create client
RemoteClient *client = new RemoteClient();
client->peer_id = peer_id;
m_clients[client->peer_id] = client;
}
void ClientInterface::event(u16 peer_id, ClientStateEvent event)
{
{
MutexAutoLock clientlock(m_clients_mutex);
// Error check
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// No client to deliver event
if (n == m_clients.end())
return;
n->second->notifyEvent(event);
}
if ((event == CSE_SetClientReady) ||
(event == CSE_Disconnect) ||
(event == CSE_SetDenied))
{
UpdatePlayerList();
}
}
u16 ClientInterface::getProtocolVersion(u16 peer_id)
{
MutexAutoLock conlock(m_clients_mutex);
// Error check
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// No client to get version
if (n == m_clients.end())
return 0;
return n->second->net_proto_version;
}
void ClientInterface::setClientVersion(u16 peer_id, u8 major, u8 minor, u8 patch, std::string full)
{
MutexAutoLock conlock(m_clients_mutex);
// Error check
UNORDERED_MAP<u16, RemoteClient*>::iterator n = m_clients.find(peer_id);
// No client to set versions
if (n == m_clients.end())
return;
n->second->setVersionInfo(major,minor,patch,full);
}