6h SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r SSKJ r \ R \R"S:XGa:SSKrSSKr\R(rSrS rS rS r\R2"S 5R4rS rS rSrSrSr Sr!Sr"Sr#Sr$\R(RJr&"SS\RN5r(\RR"\RT5r+\RXRZr.\.R^r0\Rb\RT\RT\Rd\RT\RT\Rf/\0l4\Rf\0l5\.Rlr6\Rf/\6l4\Rn\6l5\.Rpr8\Rf\Rd\RT\+\RR"\(5/\8l4\Rn\8l5\.Rrr9\Rf\Rd\RT\+\RR"\(5/\9l4\Rn\9l5\.Rtr:/\:l4\RT\:l5\.Rvr;\RT/\;l4S\;l5\.Rxr=\RT\Rd\RT\RT\RR"\Rb5\RT\Rd/\=l4\RT\=l5\.R|r>\.R~r?\Rf\RR"\(5\+\Rn/\?l4\Rn\?l5\@"\.SS5rA\AbK\Rf\RR"\(5\+\RT\Rn/\Al4\Rn\Al5\.RrB\Rf\RT\Rn/\Bl4\RT\Bl5\.RrD\+\Rn\Rn\Rb/\Dl4\Rf\Dl5\.RrE\Rf\RR"\(5/\El4\Rn\El5SrFSrG\G(aSrHOSrHSrI"SS\J5rK"SS\K5rL"SS \K5rM"S!S"\K5rN"S#S$\K5rO"S%S&\K5rP"S'S(\K5rQ"S)S*5rR"S+S,5rS"S-S.\R5rTS/rU"S0S1\R5rVSAS2jrW"S3S4\R5rX"S5S6\S5rY"S7S8\Y5rZ"S9S:\Y5r["S;S<\[\Z5r\"S=S>\S5r]"S?S@5r^g!\a SSKJr GN> * x '   r!rGetOverlappedResultEx Fc [S[R"S[R"55<SXSS-<35 g)N[z%a, %d %b %Y %H:%M:%Sz] )printtimestrftimegmtimefmtargss rlogr8s/  5t{{}E1g   r!cgNr,r5s rr8r8 r!c [R"5n[[[-[ -SUSUSS5 UR [U5 $![U5 f=f)z7expand a win32 error code into a human readable messageNr)ctypesc_char_p FormatMessageFORMAT_MESSAGE_FROM_SYSTEMFORMAT_MESSAGE_ALLOCATE_BUFFERFORMAT_MESSAGE_IGNORE_INSERTSvalue LocalFree)errbufs r_win32_strerrorrGsZ // C" ( ) ' (       yy# #s A Ac*\rSrSrSSjrSrSrSrg) WatchmanErrorNcXlX lgr:)msgcmd)rrLrMs rrWatchmanError.__init__s r!cXlgr:)rM)rrMs r setCommandWatchmanError.setCommandsr!cvUR(aUR<SUR<3$UR$)Nz, while executing rMrLrs r__str__WatchmanError.__str__s% 88/3xxB Bxxr!rSNN)r"r#r$r%rrPrTr+r,r!rrIrIsr!rIc\rSrSrSrg)BSERv1Unsupportedir,Nr"r#r$r%r+r,r!rrXrXr!rXc\rSrSrSrg) UseAfterForkir,NrYr,r!rr\r\rZr!r\c,^\rSrSrSU4SjjrSrU=r$)WatchmanEnvironmentErrori c6>[TU]USUSU3U5 g)Nz: errno=z errmsg=superr)rrLerrnoerrmsgrM __class__s rr!WatchmanEnvironmentError.__init__ s# C5xx@#Fr!r,r:r"r#r$r%rr+ __classcell__rds@rr^r^ sGGr!r^c(^\rSrSrU4SjrSrU=r$)SocketConnectErroricL>[TU]SU<SU<35 XlX lg)Nzunable to connect to z: )rarsockpathexc)rrlrmrds rrSocketConnectError.__init__s (CHI r!)rmrlrfrhs@rrjrjs r!rjc\rSrSrSrSrg) SocketTimeoutiaxA specialized exception raised for socket timeouts during communication to/from watchman. This makes it easier to implement non-blocking loops as callers can easily distinguish between a routine timeout and an actual error condition. Note that catching WatchmanError will also catch this as it is a super-class, so backwards compatibility in exception handling is preserved. r,Nr"r#r$r%__doc__r+r,r!rrprpsr!rpc0^\rSrSrSrSU4SjjrSrU=r$) CommandErrorizJerror returned by watchman self.msg is the message returned by watchman. c.>[TU]SU<3U5 g)Nzwatchman command error: r`)rrLrMrds rrCommandError.__init__%s >Dr!r,r:)r"r#r$r%rrrr+rgrhs@rrtrts EEr!rtc:\rSrSrSrSrSrSrSrSr Sr S r g) Transporti)z.communication transport to the watchman serverNc[5e)z tear it downNotImplementedErrorrs rcloseTransport.close. !##r!c[5e)zread size bytesrz)rsizes r readBytesTransport.readBytes2r~r!c[5e)zwrite some datarz)rrFs rwriteTransport.write6r~r!cgr:r,rrCs r setTimeoutTransport.setTimeout:r;r!cURc/Ul[UR5S:Xa>SURS;a+URSRSS5upU/UlU$URS5nSU;a;SR UR5nURSS5upU/UlX1-$URR U5 Mo)zoread a line Maintains its own buffer, callers of the transport should not mix calls to readBytes and readLine. r rrr!)rFlensplitrjoinappend)rlinebresults rreadLineTransport.readLine=s 88 DH txx=A %488A;"6 ))%3ITsDHKt$Az$((+GGE1- 3}$ HHOOA r!)rF) r"r#r$r%rrrFr|rrrrr+r,r!rrxrx)s#8 C$$$ r!rxc4\rSrSrSrSrSrSrSrSr Sr g) CodeciVz.communication encoding for the watchman serverNcXlgr: transport)rrs rrCodec.__init__[s"r!c[5er:rzrs rreceive Codec.receive^ !##r!c[5er:rzrr7s rsend Codec.sendarr!c:URRU5 gr:)rrrs rrCodec.setTimeoutds !!%(r!r) r"r#r$r%rrrrrrrr+r,r!rrrVs8I#$$)r!rc:\rSrSrSrSrSrSrSrSr Sr S r g) UnixSocketTransportihz"local unix domain socket transportNclXlX l[R"[R[R5nUR UR5 UR UR5 X0lg![a+nUR5 [URU5eSnAff=fr:) rltimeoutsocketAF_UNIX SOCK_STREAM settimeoutconnectsockOSErrorr|rj)rrlrres rrUnixSocketTransport.__init__msz  }}V^^V-?-?@ 7 OODLL ) LL 'I 7 JJL$T]]A6 6 7s> B3&B..B3cjUR(a"URR5 SUlggr:)rr|rs rr|UnixSocketTransport.closezs# 99 IIOO DI r!cZXlURRUR5 gr:)rrrrs rrUnixSocketTransport.setTimeouts  T\\*r!cURRU5/nUS(d [S5eUS$![Ra [ S5ef=f)Nrempty watchman responseztimed out waiting for response)rrecvrIrrrp)rrrFs rrUnixSocketTransport.readBytessZ B99>>$'(Cq6#$=>>q6M~~ B @A A Bs 58 AcURRU5 g![Ra [ S5ef=f)Nztimed out sending query command)rsendallrrrp)rdatas rrUnixSocketTransport.writes; C II  d #~~ C AB B Cs >)rrlr) r"r#r$r%rrrrr|rrrr+r,r!rrrhs%, D 7 +BCr!rc~[SU5 US:wa[URX45nU[:XaO~U[:Xa[ [5 OdU[ :Xa[ [ 5 gU[:Xa [5n[S[U55 g[5n[S[U55 g[XUS5$)aWindows 7 and earlier does not support GetOverlappedResultEx. The alternative is to use GetOverlappedResult and wait for read or write operation to complete. This is done be using CreateEvent and WaitForSingleObjectEx. CreateEvent, WaitForSingleObjectEx and GetOverlappedResult are all part of Windows API since WindowsXP. This is the exact same implementation that can be found in the watchman source code (see get_overlapped_result_ex_impl in stream_win.c). This way, maintenance should be simplified. z"Preparing to wait for maximum %dmsrFz WaitForSingleObjectEx failed: %szUnexpected error: %s) r8WaitForSingleObjectExr WAIT_OBJECT_0WAIT_IO_COMPLETION SetLastError WAIT_TIMEOUT WAIT_FAILED GetLastErrorrGGetOverlappedResult)pipeolapnbytesmillis alertablewaitReturnCoderEs r_get_overlapped_result_ex_implrs,f5 {.t{{FN ] *  1 1 + ,  | +  & { *.C 2OC4H I.C &(< = t65 99r!cB\rSrSrSrSrSrSrSrSr Sr S r S r g ) WindowsNamedPipeTransportizconnect to a named pipec Xl[[R"US-55UlSUl[ R(a[R"U5n[U[[-SS[[S5Ul[!5nUR[":XdURS:Xa-SUl[%URUR'SU55e[)SSSS5Ul[!5nUR*cUR-SU5 [.Ul[R2"S5S:Xd UR0c [4Ulgg) NrTFzCreateEvent failedWATCHMAN_WIN7_COMPAT1)rlintmathceilr_iobufrPYTHON3osfsencode CreateFile GENERIC_READ GENERIC_WRITE OPEN_EXISTINGFILE_FLAG_OVERLAPPEDrrINVALID_HANDLE_VALUErj _make_win_err CreateEvent _waitable_raise_win_errr-_get_overlapped_result_exgetenvr)rrlrrEs rr"WindowsNamedPipeTransport.__init__s 499Wt^45  >>{{8,H  = (     n 99, , QDI$T]]D4F4Fr34OP P%T4=n >> !    4c :)>& II, - 4--5-KD *6r!c$URX5er:)rrrLrEs rr(WindowsNamedPipeTransport._raise_win_errs  **r!c4[SX[U54-5$)Nz%s win32 error code: %d %s)IOErrorrGrs rr'WindowsNamedPipeTransport._make_win_errs! (Coc6J+K K  r!cUR(a [S5 [UR5 SUlURb[UR5 SUlg)Nz Closing pipe)rr8 CloseHandlerrs rr|WindowsNamedPipeTransport.closesA 99    " >> %  'r!c*[US-5Ulg)Nr)rrrs rr$WindowsNamedPipeTransport.setTimeouts54<( r!cUR(aSU[UR5:aURnSUlU$URSUnURUSUlU$[R"U5n[ 5nUR Ul[SU5 [URX1SU5nU(d)[5nU[:waURSU-U5 [R5nUR!URXGU(aSO UR"S5(dk[5n[%URU5 U[&:Xa#[S5 [)SUR"-5e[SU5 URS U5 UR*nUS:Xa![%URU5 [-S 5eUSUn[/Xq5nX:XaU$X8SUlUSU$) zA read can block for an unbounded amount of time, even if the kernel reports that the pipe handle is signalled, so we need to always perform our reads asynchronously Nzmade read buff of size %dzfailed to read %d bytesrTzGetOverlappedResultEx timedoutz%timed out after waiting %dms for readz&GetOverlappedResultEx reports error %dzerror while waiting for readz'Async read yielded 0 bytes; unpossible!)rrrFr=create_string_bufferrrrr8ReadFilerrERROR_IO_PENDINGrr'r(rr CancelIoExrrprCrmin) rrresrFr immediaterEnread returned_sizes rr#WindowsNamedPipeTransport.readBytess ;;s4;;''kk ++et$C++de,DKJ))$/|nn  '.TYY4> .C&&##$=$DcJ -- IItA d  .C tyy$ 'l"45#;dllJ 8# >    > D  A: tyy$ 'CD D&5kE(  !J.) >M""r!c[5nURUl[UR[ R "U5[U5SU5nU(d>[5nU[:wa*URS[U5UR4-U5 [R5nURURX%U(aSO URS5(a"[SUR 5 UR $[5n[#URU5 U[$:Xa['SUR-5eURS[U5-U5 g)Nz%failed to write %d bytes to handle %rrTzmade write of %d bytesz&timed out after waiting %dms for writez)error while waiting for write of %d bytes)rrr WriteFilerr=r>rrrrr'r(rrr8rCrrrp)rrrrrEnwrotes rrWindowsNamedPipeTransport.write<s|nn  IIvt,c$it .C&&##;4y$)),-!  ) ) IIt)Qt   (&,, 7<< n 499d# , 84<<G   7#d) CS r!)rrrrFrrlrN) r"r#r$r%rrrrrr|rrrr+r,r!rrrs,!!LF+ )B#H% r!rcTU(aU$[RRSS5$)NWATCHMAN_BINARYwatchman)renvironget)binpaths r_default_binpathr ds" ::>>+Z 88r!cB\rSrSrSrSrSrS SjrSrSr Sr S r S r g) CLIProcessTransportimaopen a pipe to the cli to talk to the service This intended to be used only in the test harness! The CLI is an oddball because we only support JSON input and cannot send multiple commands through the same instance, so we spawn a new process for each command. We disable server spawning for this implementation, again, because it is intended to be used only in our test harness. You really should not need to use the CLI transport for anything real. While the CLI can output in BSER, our Transport interface doesn't support telling this instance that it should do so. That effectively limits this implementation to JSON input and output only at this time. It is the responsibility of the caller to set the send and receive codecs appropriately. NTc<XlX l[U5Ulgr:)rlrr r)rrlrrs rrCLIProcessTransport.__init__s  '0 r!c\UR(aURRbURR5 URRR 5 URR R 5 URR 5 SUlggr:)procpidkillstdinr|stdoutwaitrs rr|CLIProcessTransport.closesi 99yy}}(  IIOO ! ! # II   " " $ IINN DI r!cUR(a UR$URSUR3SSSSSS/n[R"U[R [R S9UlUR$) Nz --sockname=z--logfile=/BOGUSz--statefile=/BOGUSz --no-spawnz --no-localz --no-prettyz-j)rr)rrrl subprocessPopenPIPErs r_connectCLIProcessTransport._connectsp 9999  LL$-- )       $$     yyr!cUR5 URRRU5nU(d [ S5eU$)NzEOF on CLI process transport)rrrreadrI)rrrs rrCLIProcessTransport.readBytess9 ii##D) >? ? r!cUR(aUR5 SUlUR5nURR U5nURR5 SUlU$)NFT)closedr|rrr)rrrrs rrCLIProcessTransport.writesT ;; JJLDK}}jjt$   r!)rr rrlrr:) r"r#r$r%rrrr rr|rrrr+r,r!rr r ms,& D F1 $r!r c>^\rSrSrSrU4SjrSrSrSrSr U=r $) BserCodeciz[TU]U5 X lX0lgr:)rar_value_encoding _value_errors)rrvalue_encoding value_errorsrds rrBserCodec.__init__s #-)r!cV[R"UURURS9$)Nr'r(r loadsr%r&rresponses r_loadsBserCodec._loadss(zz //++  r!cURR[5/nUS(d [S5e[R "US5up#n[ US5nXE:aDURURRXE- 55 U[ US5- nXE:aMDSRU5nURU5nU$![an[SU-5eSnAff=f)Nrrr r!"watchman response decode error: %s) rr sniff_lenrIr pdu_inforrrr0 ValueError) rrF_1_2elenrlenr/rrs rrBserCodec.receives~~'' 231v 9: :}}SV, 3q6{k JJt~~// < = CBL Dk88C= J++h'CJ J Dq HI I Js;C C+C&&C+c`[R"U6nURRU5 gr:)r dumpsrrrr7rMs rrBserCodec.sends"jj$ S!r!)r%r&) r"r#r$r%rrrr0rrr+rgrhs@rr#r#s F*  J&""r!r#c\rSrSrSrSrSrg)ImmutableBserCodeciOuse the BSER encoding, decoding values using the newer immutable object supportcX[R"USURURS9$)NFr+r,r.s rr0ImmutableBserCodec._loadss+zz  //++   r!r,N)r"r#r$r%rrr0r+r,r!rrArAs   r!rAc8^\rSrSrSrU4SjrSrSrSrU=r $)Bser2WithFallbackCodecizuse BSER v2 encodingc>[TU]XU5 [R(aSnOSnUR SUS/0/5 UR 5nSU;a [ S5eUSS(aSUlS UlgS UlS Ulg) Nrequiredoptionalversionzbser-v2errorz[The watchman server version does not support Python 3. Please upgrade your watchman server.rrr) rarrrrrrX bser_versionbser_capabilities)rrr'r( bserv2_keyrrds rrBser2WithFallbackCodec.__init__s LA >>#J#J 9zI;789||~ l "#0   ' 2 !D %&D " !D %&D "r!c\URR[5/nUS(d [S5e[R "US5up#n[ US5(a/[URU5UlURU-Ul [US5nXE:aDURURRXE- 55 U[US5- nXE:aMDSRU5nURU5nU$![an[SU-5eSnAff=f)NrrrMr r!r3)rrr4rIr r5hasattrmaxrMrNrrrrr0r6) rrFrecv_bser_versionrecv_bser_capabilitiesr9r:r/rrs rrBser2WithFallbackCodec.receives~~'' 231v 9: ::>--A:O74 4 ( ( #D$5$57H ID  $ 6 69O OD 3q6{k JJt~~// < = CBL Dk88C= J++h'CJ J Dq HI I Js;D D+D&&D+c[US5(a,[R"UURURS.6nO[R"U6nUR R U5 g)NrM)rJr)rRr r=rMrNrrr>s rrBser2WithFallbackCodec.sendsT 4 ( (**))!33C **d#C S!r!)rNrMr) r"r#r$r%rrrrrr+rgrhs@rrFrFs'0J0 " "r!rFc\rSrSrSrSrg)ImmutableBser2Codeci)rBr,Nrqr,r!rrZrZ)s   r!rZc<^\rSrSrSrSrU4SjrSrSrSr U=r $) JsonCodeci0z[TU]U5 SSKnX lgr)rarjson)rrr^rds rrJsonCodec.__init__5s # r!cURR5n[R(aUR S5nUR R U5$![an[X!5 eSnAff=f)Nzutf-8) rrrrdecoder^r- Exceptionr1)rrrs rrJsonCodec.receive<s]~~&&(  ~~{{7+99??4( (  !N  sAA A8' A33A8cURR"U6n[R(aUR S5nUR R US-5 g)Nasciir)r^r=rrencoderrr>s rrJsonCodec.sendKsAiioot$ >>**W%C S5[)r!)r^) r"r#r$r%rrr^rrrr+rgrhs@rr\r\0sF D **r!r\c\rSrSrSrSrSrSrSrSr Sr 0r 0r /r SS/rSrSrSrSSjrSrSrS rS rS rS rS rSrSrSrSrSSjrSSjrSr SSjr!Sr"Sr#g)clientiUz3Handles the communication with the watchman serviceNr8 subscriptionc XlX lX`l[U 5Ul[ R "U5(a[U[5(aX0l OU=(d [R"S5=(d SnUS:Xa [RS:Xa [Ul OT"UTRTR5$r:)rzr|)rcodecrs r make_codec)client._makeBSERCodec..make_codecsD$6$68H8HI Ir!r,)rrrs`` r_makeBSERCodecclient._makeBSERCodecs Jr!czUS:Xa;UR(aUR[5$UR[5$US:Xa[[R (a [ S5eUR(aUR[5$UR[5$US:Xa[$[SU-5e)Nr zbser-v1zrPython 3 does not support the BSER v1 encoding: specify "bser" or omit the sendEncoding and recvEncoding argumentsr^zinvalid encoding %s) rprrZrFrrrXrAr#r\rI)rencs rrvclient._parseEncodings &=$$**+>??&&'=> > I ~~'  $$**+=>>&&y1 1 F]  5 ;<  IJ JF# f  86'? JK Kj!! N H1 LM M NsB D&& E0D>>Ec UR(a/UR[R"5:wa [ S5egUR cUR 5Ul0nUR[:XaURUS'UR"UR UR40UD6Ul URUR5Ul URUR5Ul[R"5Ulg)zestablish transport connectionz@do not re-use a connection after fork; open a new client insteadNr)recvConnrrgetpidr\rlrrr rrtportrxsendConnrw)rkwargss rrclient._connects ==xx299;&"V  ==  113DM >>0 0 $ F9 ^^DMM4<<J6J tzz2 tzz2 99;r!c$UR5 gr:r|rs r__del__client.__del__   r!c&UR5 U$r:)rrs r __enter__client.__enter__ s  r!c$UR5 gr:r)rexc_type exc_value exc_tracebacks r__exit__client.__exit__rr!cUR(a0URR5 SUlSUlSUlggr:)rr|rrrs rr| client.closes3 :: JJ   DJ DM DM r!cUR5 URR5nURUS5(a[ US5eURUS5(aUR R US5 URUS5(aUSnX R;a/URU'URUR U5 [RR[RRUS55nX0R;a0URU'X RU;a/URUU'URUUR U5 U$)areceive the next PDU from the watchman service If the client has activated subscriptions or logs then this PDU may be a unilateral PDU sent by the service to inform the client of a log event or subscription change. It may also simply be the response portion of a request initiated by query. There are clients in production that subscribe and call this in a loop to retrieve all subscription responses, so care should be taken when making changes here. rKr8rjroot) rrrrrtlogsrsubsrrnormpathnormcase sub_by_root)rrsubrs rrclient.receives< &&( == ) )vg/ / == ' ' II  VE] + == 0 0(C99$!# # IIcN ! !& )77##BGG$4$4VF^$DED+++)+  &**400.0  &s+   T "3 ' . .v 6 r!cZSU;a US(agURH nX!;dM g g)N unilateralTF)r)rrks risUnilateralResponseclient.isUnilateralResponseAs/ 3 3|#4Ax!r!c:URnU(a/UlU$)zRetrieve buffered log data If remove is true the data will be removed from the buffer. Otherwise it will be left in the buffer )r)rremovers rgetLog client.getLogJs ii DI r!cUb[RR[RRU55nX0R;agXRU;agURUUnU(a,URUU XR ;a UR U U$XR ;agUR UnU(a UR U U$)aRetrieve the data associated with a named subscription If remove is True (the default), the subscription data is removed from the buffer. Otherwise the data is returned but left in the buffer. Returns None if there is no data associated with `name` If root is not None, then only return the subscription data that matches both root and name. When used in this way, remove processing impacts both the unscoped and scoped stores for the subscription data. N)rrrrrr)rrtrrrs rgetSubscriptionclient.getSubscriptionUs  77##BGG$4$4T$:;D+++++D11""4(.C$$T*4099$ $J yy iio  $ r!c[S5 UR5 URRU5 UR 5nUR U5(a(UR 5nUR U5(aM(U$![ a'n[SURURU5eSnAf[anURU5 eSnAff=f)aSend a query to the watchman service and return the response This call will block until the response is returned. If any unilateral responses are sent by the service in between the request-response they will be buffered up in the client object and NOT returned via this method. zcalling client.queryz,I/O error communicating with watchman daemonN) r8rrrrrrr^rbstrerrorrIrP)rr7reeexs rquery client.queryxs "#   MM  t $,,.C++C00lln++C00J +>      MM$   s*A'BB C"B44 CCCcURSU=(d /U=(d /S.5nURUS5(d*[R"X15 SU;a[ US5eU$)z!Perform a server capability checkrJ)rIrHrrK)rrr synthesizert)rrIrHrs rcapabilityCheckclient.capabilityChecks`jj HNBO }}S.11  # #C 2#~"3w<00 r!cpURRU5 URRU5 gr:)rrrrs rrclient.setTimeouts&   '   'r!)rrrrwrrxrrlrrrrprzr|) Ng?NNNFFFN)T)TNrV)$r"r#r$r%rrrlrrxrwrrrrrrrrprrrrvrrrrrrr|rrrrrrrr+r,r!rririUs=HIIIHH DK D(J E C>/@ =( ("T4!%N !F@ (r!rir:)_ __future__rrqrrrrr2rrrrrr r5 ImportErrorr rtr=ctypes.wintypesr'rrrrc_void_prCrr@rArBrrrrINFINITErWPARAMr& StructurerPOINTERr(LPDWORDwindllkernel32 _kernel32 CreateFileArLPSTRLPVOIDr)argtypesrestyperBOOLrrrrFormatMessageAr?rDrgetattrr-r CreateEventArrr4 _debuggingr8rGrbrIrXr\r^rjrprtrxrrrrr r r#rArFrZr\rir,r!rrs:#  22 ! MM 77d?HLM%M!??2.44!+%/"$.!KLM#H"&&IV%% nnX^^,G &&I&&JJ"J''K$OO,K"--K!!Hz" H }}H##Iz" I! I))LL#>>L))L%^^,LL,,Mx~~&M%NNM##I#77z" $ #+--#I/FM( OO NN: &  NN MM * &)1 %%;; &" %-NN!((K   K #//K%%J#??FNN:,FGJ!J      , I    = G}G ME=E**Z))$(C)(CV%:Pf f R9F)FR$"$"N    <"Y<"~ 02D "*"*JT(T(I!  !sU++ U;:U;