&`iddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZmZmZmZddlmZmZmZmZmZddlZddlZddlmcmcmZddlmcmcm Z ddl!mcmcm"Z"ddl#m$Z$m%Z%m&Z&ddl'm(Z(m)Z)dd l*m+Z+dd l,m-Z-dd l.m/Z/dd l0m1Z1dd l2m3Z3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFddlGmHZHddlIZIejJeKZLdZMdZNdZOdZPdZQdZRe GddZSdeeTdeUfdZVGd d!ZWGd"d#e jXZYd$e@de@fd%ZZd&ej[deej[e@ffd'Z\Gd(d)Z]Gd*d+e j^Z_Gd,d-e j`Zaddddd.d/eTd0ebd1eeTd2eeTd3eeTd4eeTd5eeTfd6ZcdS)7N)futures) dataclass)chain)EventLockRLockThread)CallableDictListOptionalTuple) build_addressis_ipv6 is_localhost) format_authentication_http_error get_auth_headers_if_auth_enabled)disable_client_hook)init_grpc_channel) RayParams)RuntimeEnvContext) ProcessInfostart_ray_client_server)add_port_to_grpc_server)detect_fate_sharing_support) GcsClient)pickle)AuthenticationError) JobConfig)CLIENT_SERVER_MAX_THREADS GRPC_OPTIONSClientServerHandle_get_client_id_from_context_propagate_error_in_context)_get_reconnecting_from_contextiYi]ceZdZUeed<ejed<ded<defdZdde e ddfd Z de efd Z dd Z d e eddfd ZdS)SpecificServerportprocess_handle_futuregrpc._channel.Channelchannelreturnc4|jS)z4Check if the server is ready or not (doesn't block).)r,doneselfs r/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/util/client/server/proxier.pyis_readyzSpecificServer.is_readyDs)..000Ntimeoutc^|j|}|tddS)z; Wait for the server to actually start up. r7NzServer startup failed.)r,result RuntimeError)r3r7ress r4 wait_readyzSpecificServer.wait_readyHs8(///@@ ;788 8 ;r6c |jd}||jSdS#tj$rYdSwxYw)z Check if the process has exited.皙?r9N)r,r:processpollr TimeoutErrorr3procs r4rAzSpecificServer.pollQsg -44S4AAD|((*** #    FF s5:A  A c |jd}||jdSdS#tj$rYdSwxYw)z)Try to send a KILL signal to the process.r?r9N)r,r:r@killrrBrCs r4rFzSpecificServer.killZsm -44S4AAD !!##### #    DD s6<AArDcf|s|j|dSdS)z?Set the result of the internal future if it is currently unset.N)r5r, set_resultrCs r4rHzSpecificServer.set_resultds9}} 8  & 1 1$ 7 7 7 7 7 8 8r6Nr/N)__name__ __module__ __qualname__int__annotations__rFutureboolr5r floatr=rArFrrHr6r4r*r*>s III">))) $$$$1$111199(5/9T9999hsm8x 48888888r6r*commandr/c4d|}d|vS)z Detects if the main process in the given command is the RayClient Server. This works by ensuring that the command is of the form: -m ray.util.client.server  z-m ray.util.client.server)join)rT flatteneds r4_match_running_client_serverrYjs !!I &) 33r6c leZdZddddddeededeedeedeed ef d Zejfd ed efd Z e d efdZ e d e j jjfdZded efdZdededefdZdeded efdZded eefdZded efdZded edfdZdZddZdS) ProxyManagerNr) session_dirredis_usernameredis_passwordruntime_env_agent_portaddressruntime_env_agent_addressr\r]r^r_ct|_t|_||_||_||_tttt|_ ||_ t|jd|_|jt#t%|_d|_t+j|jdS)NT)targetdaemon)dictserversr server_lock_address_redis_username_redis_passwordlistrangeMIN_SPECIFIC_SERVER_PORTMAX_SPECIFIC_SERVER_PORT _free_ports_runtime_env_agent_addressr _check_processes _check_threadstartrQr fate_share_nodeatexitregister_cleanup)r3r`rar\r]r^r_s r4__init__zProxyManager.__init__us37&&  77 --&* *,D E E' ' +D'#4+@NNN   """:<<==7;  &&&&&r6familyr/cH|j5t|j}t|D]}|jd}t j|t j} |d|fn>#t$r1|j |Y| wxYw | n#| wxYw|ccdddS dddn #1swxYwYtd)zB Search for a port in _free_ports that is unused. rNz-Unable to succeed in selecting a random port.) rglenrorlpopsocket SOCK_STREAMbindOSErrorappendcloser;)r3rz num_ports_r+ss r4_get_unused_portzProxyManager._get_unused_ports   D,--I9%%  '++A..M&&*<==FFB:&&&&$++D111GGIIII ' GGIIIIAGGIIII                         JKKKsNAD (B?C$B;$C%D :B;;C?D C**D  DDc|jr|jStj}|d|_|d|_|jS)zW Returns the provided Ray bootstrap address, or creates a new cluster. r`r\)rhrayinit _session_dir)r3connection_tuples r4r`zProxyManager.addresssC = != 8::(3 ,];}r6c|jr|jSt|j}tjj|dddd|_|jS)zGets a 'ray.Node' object for this node (the head node). If it does not already exist, one is created using the bootstrap address. ) gcs_addressFT)headshutdown_at_exit spawn_reaper connect_only)rurr`r_privatenodeNode)r3 ray_paramss r4rzProxyManager.nodesb : : 4<888 \&++ " ,   zr6 client_idc |j5|j| Jd|d}|t |r t jn t j}t|tj tt||t}||j|<|cdddS#1swxYwYdS)z Create, but not start a SpecificServer for a given client. This method must be called once per client. Nz#Server already created for Client: 127.0.0.1)options)r+r,r.)rgrfgetrrrAF_INET6AF_INETr*rrPrrr!)r3rhostr+servers r4create_specific_serverz#ProxyManager.create_specific_servers(       ++33@Y@@433D((#*4==DfnD$&-n&6&6)!$--|F'-DL #%                  sB4C  C C serialized_runtime_envruntime_env_configspecific_serverc Ltd|jd|dt|jdks Jdt j||d|jdd }d}d }d }d }||kr tj |jd } | } ddi} | j d#it| tj| | d| } tj| d } | }t j}|||jt jjkr|jS|jt jjkrt3d|jJd|jd#tjj$r}d} |dd}n6#t<$r)t?|dr|j ntC|}YnwxYwtE|j#|pd}|rtI|||}t%d|j#d|p|d|d||z d Yd }~nMd }~wtjj&$r3}|}t%d|d|d||z dYd }~nd }~wwxYwtOj(||dz }|d z}||ktSd!|d"|)$zIncrease the runtime_env reference by sending an RPC to the agent. Includes retry logic to handle the case when the agent is temporarily unreachable (e.g., hasn't been started up yet). z7Increasing runtime env reference for ray_client_server_z.Serialized runtime env is .rz!runtime_env_agent_address not setray_client_server_zutf-8 client_server)rrjob_idsource_processr'?Nz/get_or_create_runtime_envz Content-Typezapplication/octet-streamPOST)datamethodheadersr9zEFailed to create runtime_env for Ray client server, it is caused by: FzUnknown status: r|ignorereasonz/GetOrCreateRuntimeEnv request failed with HTTP : z. Retrying after zs. z retries remaining.z&GetOrCreateRuntimeEnv request failed: r(z+GetOrCreateRuntimeEnv request failed after z attempts. Last exception: rS)*loggerinfor+r}rpruntime_env_agent_pb2GetOrCreateRuntimeEnvRequestencodeurllibparseurljoinSerializeToStringupdaterrequestRequesturlopenreadGetOrCreateRuntimeEnvReplyParseFromStringstatusAgentRpcStatusAGENT_RPC_STATUS_OKserialized_runtime_env_contextAGENT_RPC_STATUS_FAILEDr; error_messageerror HTTPErrordecode ExceptionhasattrrstrrcoderwarningURLErrortimesleeprB)r3rrrcreate_env_requestretries max_retries wait_time_slast_exceptionurlrrreqresponse response_datarebodyformatted_errors r4_create_runtime_envz ProxyManager._create_runtime_envsc   C!0!5 C C)? C C C    / 0 01 4 4 4 . 5 4 43O#91>(<>>EEgNN*      $$4 l**35Q*;;==)+EFKK!A'!J!JKKKn,,d67-">11#t1DD (  )DFF!!-00084CWWW;;H,;STT'G56_GG A"@QX"@"@"@@@5<)   H6688??7H==DD HHH'.q(';';G188QDDDH#C164:SU"V"V"F-o>>AE"#@af@@PTPYXY@@&1@@"7*@@@ <(   !"@Q@@&1@@"7*@@@  J{ # # # qLG 1 Ku$$x 1+ 1 1 . 1 1   sQ C7GAGK)J(HJ0H;8J:H;;AJK)6)K$$K) job_configc ||}|s Jd||jd|jd\}}|}|}|r|dkr!t }n||||}t|j d|j|||j d||j |j } | jj} t jd krt%j| } nd } | | jt*d |nT| } t1| rn0t*d t5jd| || t*d|jd| d|| jd uS)z Start up a RayClient Server for an incoming client to communicate with. Returns whether creation was successful. z!Server has not been created for: rT)uniquez{})rrrrzspecific-server) stdout_file stderr_filert server_typerr]r^win32Nz*SpecificServer startup failed for client: z6Waiting for Process to reach the actual client server.rz SpecificServer started on port: z with PID: z for client: )_get_server_for_clientrget_log_file_handlesr+_get_serialized_runtime_env_get_proto_runtime_env_configr serializerrr`rtrirjr@pidsysplatformpsutilProcessrArrcmdlinerYdebugrrrHr) r3rrroutputrrrrrDr psutil_proccmds r4start_specific_serverz"ProxyManager.start_specific_server?sG 55i@@OO OI O OOO 66 7!5 7 77  ",!G!G!I!I'EEGG% )?4)G)G.?-@-@-J-J-L-L * *-1-E-E'=#5 /.F.. * ' L   )+I//    l <7 " " .--KKK%|  "". U)UUVVV%%''C+C00  LLQ R R R JsOOO% ""4(((  7/C 7 7 7 7+4 7 7   |  ""d**r6c|j5|j|}|td||cdddS#1swxYwYdS)Nz#Unable to find channel for client: )rgrfrrr)r3rclients r4rz#ProxyManager._get_server_for_client}s    \%%i00F~ N9NNOOO                   s;AAAc\||}|dS|S)NF)rr5r3rrs r4 has_channelzProxyManager.has_channels/,,Y77 >5   r6r-c6||}|dS| tj|jt |jS#tj$r!t d|YdSwxYw)z~ Find the gRPC Channel for the given client_id. This will block until the server process has started. Nr9z Timeout waiting for channel for ) rr=grpcchannel_ready_futurer.r:CHECK_CHANNEL_TIMEOUT_SFutureTimeoutErrorr exceptionrs r4 get_channelzProxyManager.get_channels,,Y77 >4   %fn 5 5 < </ =   > !&      K KK L L L44 s8A((,BBc |j5t|jD]e\}}|Lt d|d|j|j|=|j |jf dddn #1swxYwYtj t)zX Keeps the internal servers dictionary up-to-date with running servers. TNzSpecific server z( is no longer running, freeing its port ) rgrkrfitemsrArrr+rorrrCHECK_PROCESS_INTERVAL_S)r3rrs r4rqzProxyManager._check_processess5 1! F F26t|7I7I7K7K2L2LFF.I&++--9 IyII2A2FII!L3(//0DEEEF F F F F F F F F F F F F F F F J/ 0 0 0 1sB B##B'*B'cf|jD]}|dS)z Forcibly kill all spawned RayClient Servers. This ensures cleanup for platforms where fate sharing is not supported. N)rfvaluesrF)r3rs r4rxzProxyManager._cleanups: l))++  F KKMMMM  r6rJ)rKrLrMr rrNryrrrpropertyr`rrrrr*rrrrQrrrrrqrxrSr6r4r[r[ts1 &*(,(,&''''#'$'' c] ' ! '! '!$''''8.4^LLsLLLLL&    X cl',X&2_ #_  _ ( _ _ _ _ B<+s<+ <+d<+<+<+<+|8P!S!T!!!! ) *,111$r6r[ceZdZdedefdZdedeej fdZ dZ dde j fd Zdde jfd Zdde jfd Zdde jfd Zdde jfd Zdde jfdZ dde jfdZ dde jfdZdde jfdZddZddZ dde j!de j"fdZ#dde j$fdZ%dde j&fdZ'dS)RayletServicerProxyray_connect_handler proxy_managerc"||_||_dSrI)rr)r3rrs r4ryzRayletServicerProxy.__init__s*#6   r6rr/ct|}|j|}|sDtd|d|t jjdStj |} d|fg}|r| }t||||S#t$r9}td|dt||Yd}~dSd}~wwxYw)NzChannel for Client: z not found!rmetadatazProxying call to z failed!)r#rrrrset_coder StatusCode NOT_FOUNDray_client_pb2_grpcRayletDriverStubinvocation_metadatagetattrrrr$) r3rcontextrrchanstubrrs r4_call_inner_functionz(RayletServicerProxy._call_inner_functions&088 !--i88  LLF FFF G G G   T_6 7 7 74"3D99 4$i01H 9"6688(74((8DDD D 4 4 4   AAAA B B B '7 3 3 3 3 3 3 3 3 3 4s5B;; C>.C99C>cTt|}|j|SrI)r#rr)r3rrs r4_has_channel_for_requestz,RayletServicerProxy._has_channel_for_requests&/88 !--i888r6Nc0|||dS)NInitrr3rrs r4r"zRayletServicerProxy.Inits(('6BBBr6c<||r|||dSt5tjj|j|j|j }dddn #1swxYwYtj |S)a=Proxies internal_kv.put. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. KVPut) overwriteN)already_exists) r rrr experimental internal_kv_internal_kv_putkeyvaluer'ray_client_pb2 KVPutResponse)r3rrr(s r4r&zRayletServicerProxy.KVPuts  ( ( 1 1 H,,WgwGG G " "   -9JJ W]g6GKN               +>JJJJs7A>>BBc"||r|||dSt5tjj|j}dddn #1swxYwYtj |S)a=Proxies internal_kv.get. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. KVGetN)r-) r rrrr)r*_internal_kv_getr,r. KVGetResponse)r3rrr-s r4r1zRayletServicerProxy.KVGets  ( ( 1 1 H,,WgwGG G " " O O$0AA'+NNE O O O O O O O O O O O O O O O+%8888*A11A58A5c||r|||dSt5tjj|jdddn #1swxYwYtj S)a@Proxies internal_kv.delete. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. KVDelN) r rrrr)r*_internal_kv_delr,r. KVDelResponser$s r4r6zRayletServicerProxy.KVDels  ( ( 1 1 H,,WgwGG G " " G G   ( 9 9'+ F F F G G G G G G G G G G G G G G G+---r4c"||r|||dSt5tjj|j}dddn #1swxYwYtj |S)a>Proxies internal_kv.list. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. KVListN)keys) r rrrr)r*_internal_kv_listprefixr.KVListResponse)r3rrr;s r4r:zRayletServicerProxy.KVLists  ( ( 1 1 I,,WgxHH H " " R R#/AA'.QQD R R R R R R R R R R R R R R R,$7777r4c"||r|||dSt5tjj|j}dddn #1swxYwYtj |S)a@Proxies internal_kv.exists. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. KVExistsN)exists) r rrrr)r*_internal_kv_existsr,r.KVExistsResponse)r3rrrAs r4r@zRayletServicerProxy.KVExistss  ( ( 1 1 K,,WgzJJ J " " S S%1EEgkRRF S S S S S S S S S S S S S S S.f====r4c,||r|||dSt5tjj|j|jdddn #1swxYwYtj S)aMProxies internal_kv.pin_runtime_env_uri. This is used by the working_dir code to upload to the GCS before ray.init is called. In that case (if we don't have a server yet) we directly make the internal KV call from the proxier. Otherwise, we proxy the call to the downstream server as usual. PinRuntimeEnvURI) expiration_sN) r rrrr)r*_pin_runtime_env_uriurirFr.ClientPinRuntimeEnvURIResponser$s r4rEz$RayletServicerProxy.PinRuntimeEnvURI/s  ( ( 1 1 S,,Wg?QRR R " "     ( = = '*> >                  <>>>s1A88A<?A<c0|||dS)NListNamedActorsr#r$s r4rKz#RayletServicerProxy.ListNamedActorsCs((';LMMMr6c|jtjjkr)tjt ji}|S|||dS)N)json ClusterInfo)typer.ClusterInfoTypePINGClusterInfoResponserMdumpsr)r3rrresps r4rNzRayletServicerProxy.ClusterInfoHsO <>9> > >!54:b>>JJJDK(('=IIIr6c0|||dS)N Terminater#)r3rrs r4rVzRayletServicerProxy.TerminateQs((g{CCCr6c#K |||dEd{VdS#t$r5}tdt ||Yd}~dSd}~wwxYw)N GetObjectz"Proxying call to GetObject failed!)rrrrr$)r3rrrs r4rXzRayletServicerProxy.GetObjectTs 400';OO O O O O O O O O O 4 4 4   A B B B '7 3 3 3 3 3 3 3 3 3 4s# A"*AA"rc0|||dS)N PutObjectr#r$s r4rZzRayletServicerProxy.PutObject\s((';GGGr6c0|||dS)N WaitObjectr#r$s r4r\zRayletServicerProxy.WaitObjectas(('<HHHr6c0|||dS)NScheduler#)r3taskrs r4r^zRayletServicerProxy.Scheduleds((w CCCr6rI)(rKrLrMr r[ryrr rrrr r. InitResponser"r/r&r3r1r8r6r>r:rCr@rIrEClientListNamedActorsResponserKrRrNrVrX PutRequest PutResponserZ WaitResponser\ClientTaskTicketr^rSr6r4r r s7H7\77774(+4 %6 74444*999CC^-HCCCCKKn.JKKKK$99n.J9999 ..n.J.... 88~/L8888 >>1P>>>>" $??  6????* $NN  5NNNN JJN4VJJJJDDDD4444;?HH%0H  #HHHH II>3NIIIIDDn.MDDDDDDr6r rc|SrIrS)rs r4ray_client_server_env_preprghs r6 init_requestc|d}|dksJd|d|j}t}|jrt j|j}t |}tjt j ||jj |jj }|j |||fS)zu Extract JobConfig and possibly mutate InitRequest before it is passed to the specific RayClient Server. rOrz!Received initial message of type z , not 'init'.)rray_init_kwargsreconnect_grace_period) WhichOneofrrrrloadsrgr. InitRequestrSrjrkCopyFrom)rh init_typerrnew_job_configmodified_init_reqs r4prepare_runtime_init_reqrsls''//I    GyGGG     CJ ~2\#.11 / ;;N&2<//$)9+0G 0111 . ))r6c eZdZdZdZdZdS)RequestIteratorProxyc||_dSrI)request_iterator)r3rws r4ryzRequestIteratorProxy.__init__s 0r6c|SrIrSr2s r4__iter__zRequestIteratorProxy.__iter__s r6c t|jS#tj$rC}t |tjur|t dtd}~wwxYw)NzEStop iterating cancelled request stream with the following exception:)nextrwrRpcErrorrOrr StopIteration)r3rs r4__next__zRequestIteratorProxy.__next__sv -.. .} Awwdm++   W     sA(>A##A(N)rKrLrMryryr~rSr6r4rurusA111     r6rucDeZdZdefdZdejdejfdZdZdS)DataServicerProxyrcd|_i|_i|_t|_||_t |_dS)Nr) num_clientsclients_last_seenreconnect_grace_periodsr clients_lockrrstopped)r3rs r4ryzDataServicerProxy.__init__s=359;$ FF*ww r6 init_respr/c|d}|dkr|Stj}|||j5|j|j_dddn #1swxYwY|S)z Modify the `num_clients` returned the ConnectionInfoResponse because individual SpecificServers only have **one** client. rOconnection_infoN)rlr. DataResponserorrr)r3rrp modified_resps r4modify_connection_info_respz-DataServicerProxy.modify_connection_info_resps((00 ) ) ) &355 y)))   I I8<8HM ) 5 I I I I I I I I I I I I I I Is A++A/2A/c #Kt|}d}tj}t|}|dkrdSt|}|r|j5||jvrG|tjj | d ddddS||j|<dddn #1swxYwY|j |}|j |}|} nS|j |}|j5||j|<|xjdz c_dddn #1swxYwY |st d|dt%|} |j5| jj|j|<dddn #1swxYwY t-| \} } |j || s9t d|d| d t3d |jd |j |}|5t d |t3d |jdn#t6$rt9jt9jdt?j } | j!| _!| VY|j"|}|s||j#$||j5||jvr+t |d ddddS|j|}t |d|d|d||kr(t d ddddSt %d||xjdzc_|j|=||jvr|j|=|&dddddS#1swxYwYdSwxYwtO| g|} tQj)|}d|fdtU|fg}|+| |}|D]6}|,d}|dkrd}|-|V7nE#t6$r8}t .dt_||}|sd}Yd}~nd}~wwxYw|j"|}|s||j#$||j5||jvr+t |d ddddS|j|}t |d|d|d||kr(t d ddddSt %d||xjdzc_|j|=||jvr|j|=|&dddddS#1swxYwYdS#|j"|}|s||j#$||j5||jvr-t |d dddYdS|j|}t |d|d|d||kr*t d dddYdSt %d||xjdzc_|j|=||jvr|j|=|&ddddw#1swxYwYwxYw)NFr|zAAttempted to reconnect a session that has already been cleaned uprz New data connection from client rz"Server startup failed for client: z, using JobConfig: !z9Starting Ray client server failed. See ray_client_server_z.err for detailed logs.zChannel not found for zYProxy failed to Connect to backend! Check `ray_client_server.err` and `ray_client_server_zz.err` on the head node of the cluster for the relevant logs. By default these are located at /tmp/ray/session_latest/logs.)okmsg)rr9z not found. Skipping clean up.z last started stream at z. Current stream started at rz%Client reconnected. Skipping cleanup.zClient detached: r reconnectingrrOconnection_cleanupTzProxying Datapath failed!)0rurr#r%rrrrrr set_detailsrrrrrrrr{rrkrrsrrr;r+rr.rr` traceback format_excreq_idrrwaitrrHrrRayletDataStreamerStubrDatapathrlrrr$)r3rwrcleanup_requested start_timerrrr.new_iterinit_reqrrrr cleanup_delay last_seenrr resp_streamrT resp_typer recoverables r4rzDataServicerProxy.DatapathsM /0@AA!Y[[ /88 ?? F5g>>  &" ? ?D$:::$$T_%>???''* ? ? ? ? ? ? ? ?5?&y1 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?'>>yIIF(44Y??G'HH'>>yIIF" & &4>&y1  A%   & & & & & & & & & & & & & & &W (* H LyLLLMMM 011&==! <0!===============! 4LX4V4V1%z-CC!:  >>>0:>>>+-17--- #0<*@*@!!!I (0I$#OOO*!8<3|CTCT2UVH--8-DDK# = = OOF33  444(,%66t<<<<<<  =  ) ) )   8 9 9 95aAAK )$(!  )!8<rs=   !!!!!!00000000000088888888888888 ::::::::::::DDDDDDDDDDDDHHHHHHHHHHHHJJJJJJJJJJ>=====555555,,,,,,>>>>>>FFFFFFFF::::::::::::!!!!!!))))))......$$$$$$ONNNNN  8 $ $    (8(8(8(8(8(8(8 (8V4$s)44444EEEEEEEEP iDiDiDiDiD-BiDiDiDX9* ,* > %y 01****4        0Q(Q(Q(Q(Q(+FQ(Q(Q(h(;(;(;(;(;0J(;(;(;`%)$(!%/3000 0 0#0 SM 0 SM 0#0 (}000000r6