&`iZddlZddlZddlZddlmZddlmZddlmZm Z ddl Z ddl m Z m Z ddlmZmZmZddlmZddlmZdd lmZdd lmZdd lmZmZmZdd lmZej e!Z"Gd dZ#e#Z$ dZ%dZ&eedZ'dZ(dZ)dZ* d"de e+de e j,de e+fdZ-eed#dZ.d#dZ/eedZ0eedZ1edZ2edZ3dZ4d Z5d!Z6dS)$N) defaultdict)Lock)DictOptional)HEAD_NODE_RESOURCE_NAMENODE_ID_PREFIX) binary_to_hexdecode hex_to_binary)client_mode_hook)message_to_dict)validate_actor_state_name)GlobalStateAccessor)autoscaler_pb2 common_pb2gcs_pb2) DeveloperAPIc<eZdZdZdZdefdZdZdZ d9de e d e e j d e e fd Z d Zd ZdZdZdZdZd:dZdZdZedddddddddddddd Zgd!Zd:d"Zd:d#Zd$Zd%Zd&Zd'Zd(Z d)Z!d*Z"d+Z#de$e e$e e%fffd,Z&d-Z'd.Z(d/Z)d0e fd1Z*de$e e%ffd2Z+de,j-fd3Z.e/d4e e,j-d5e de e%fd6Z0de e$e e%ffd7Z1de j2de e fd8Z3dS); GlobalStatezA class used to interface with the Ray control state. Attributes: global_state_accessor: The client used to query gcs table from gcs server. cHd|_d|_t|_dS)zCreate a GlobalState object.N) gcs_options_global_state_accessorr _init_lockselfs f/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/_private/state.py__init__zGlobalState.__init__s# &*#&&returnc|j5|j|jcdddS|jtjdt |j|_|j}|s&d|_tjd|jcdddS#1swxYwYdS)a9 This lazily initializes clients needed for state accessors and returns a connected global state accessor. Returns: GlobalStateAccessor: A connected global state accessor. Raises: RuntimeError: An exception is raised if ray.init() has not been called yet. NzXRay has not been started yet. Trying to use state API before ray.init() has been called.zrFailed to connect to GCS. Please check if the GCS server is running and if this node can connect to the head node.)rrrray exceptionsRaySystemErrorrconnect)r connecteds r_connect_and_get_accessorz%GlobalState._connect_and_get_accessor&s0_ / /*62 / / / / / / / /'n33n+>d>N*O*OD '3;;==I .2+n33E.# / / / / / / / / / / / / / / / / / /sB6BB66B:=B:cp|j5d|_|jd|_ddddS#1swxYwYdS)z!Disconnect global state from GCS.N)rrrrs r disconnectzGlobalState.disconnectBs _ 3 3#D *6.2+ 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s +//cT|j5||_ddddS#1swxYwYdS)aRSet args for lazily initialization of the GlobalState object. It's possible that certain keys in gcs kv may not have been fully populated yet. In this case, we will retry this method until they have been populated or we exceed a timeout. Args: gcs_options: The client options for gcs N)rr)rrs r_initialize_global_statez$GlobalState._initialize_global_stateIsx_ + +*D  + + + + + + + + + + + + + + + + + +s !!Nactor_idjob_idactor_state_namec8|}|ntjt|}||}|iSt j|}||St|| ||}i}tt|D]Q} t j|| }|||t|j<R|S)a/Fetch and parse the actor table information for a single actor ID. Args: actor_id: A hex string of the actor ID to fetch information about. If this is None, then the actor table is fetched. If this is not None, `job_id` and `actor_state_name` will not take effect. job_id: To filter actors by job_id, which is of type `ray.JobID`. You can use the `ray.get_runtime_context().job_id` function to get the current job ID actor_state_name: To filter actors based on actor state, which can be one of the following: "DEPENDENCIES_UNREADY", "PENDING_CREATION", "ALIVE", "RESTARTING", or "DEAD". Returns: Information from the actor table. )r&r!ActorIDr get_actor_inforActorTableData FromString_gen_actor_inforget_actor_tablerangelenr r+) rr+r,r-accessor actor_infoactor_table_data actor_tableresultsis rr:zGlobalState.actor_tableYs,1133  {=#:#:;;H!00::J! #*#9#D#DZ#P#P ++,<=== %&6 7 7 7"226;KLLKG3{++,, ; ;#*#9#D#D[QR^#T#T (()9::!"2";<<Nrct|j|j|j|jt|j|jj|jjt|jj d|j j|j jt|j j dtj j jj|jj|j|j|j|j|j|jd}|S)z\Parse actor table data. Returns: Information from actor table. ) IPAddressPortNodeID)r/ActorClassName IsDetachedNameJobIDAddress OwnerAddressState NumRestarts Timestamp StartTimeEndTime DeathCausePid)r r+ class_name is_detachednamer,address ip_addressportnode_id owner_addressrr1 ActorState DESCRIPTORvalues_by_numberstate num_restarts timestamp start_timeend_time death_causepid)rr9r8s rr3zGlobalState._gen_actor_infos%%5%>??.9*6$)"#3#:;;-5@(05'(8(@(HII .;F(6;'(8(F(NOO +6AR &+8)3)4'0*6#'1  4rcR|}|S)zzFetch and parse the Gcs node info table. Returns: Information about the node in the cluster. )r&get_node_tablerr7s r node_tablezGlobalState.node_tables' 1133&&(((rc|}|dd}g}tt|D]}tj||}i}|j|d<|j j |d<|j |d<|j |d<|j |d<|j|d<|j|d <|j|d <|||S) aFetch and parse the gcs job table. Returns: Information about the Ray jobs in the cluster, namely a list of dicts with keys: - "JobID" (identifier for the job), - "DriverIPAddress" (IP address of the driver for this job), - "DriverPid" (process ID of the driver for this job), - "StartTime" (UNIX timestamp of the start time of this job), - "StopTime" (UNIX timestamp of the stop time of this job, if any) T)skip_submission_job_info_fieldskip_is_running_tasks_fieldrDDriverIPAddress DriverPidrIrJrKIsDead Entrypoint)r& get_job_tabler5r6r JobTableDatar2r,hexdriver_addressrR driver_pidr[r\r]is_dead entrypointappend)rr7 job_tabler;r<entryjob_infos rrszGlobalState.job_tables1133**+/T+  s9~~&& % %A(33IaLAAEH % 0 0 2 2HW */*>*IH& '$)$4H[ !$)OH[ !$)$4H[ !"'.HY !&HX %*%5H\ " NN8 $ $ $ $rc|}tj|S)z\Get next job id from GCS. Returns: Next job id in the cluster. )r&r!rDfrom_intget_next_job_idrbs r next_job_idzGlobalState.next_job_ids7 1133y!!(":":"<"<===rc N|}tt}|}t t |D]}t j||}|j }|s1|j }t|j }|j } |jD]c} tj|j} n#t$$ri} YnwxYw|j|| ||j|j| d} ||| dt/|S)aRetrieve and return task profiling events from GCS. Return: Profiling events by component id (e.g. worker id). { : [ { event_type: , component_id: , node_ip_address: , component_type: , start_time: , end_time: , extra_data: , } ] } ) event_type component_idnode_ip_addresscomponent_typer\r] extra_data)r&rlistget_task_eventsr5r6r TaskEventsr2profile_eventsr~r r|r}eventsjsonloadsr ValueError event_namer\r]rrdict) rr7result task_eventsr<eventprofiler~r|r}r profile_events rrzGlobalState.profile_eventssI&1133T""..00 s;''(( ; ;A&11+a.AAE*G $3N()=>>L%5O  ; ;$!%E,.get_stateBs_7??? y'9BBB!z'9AAA y'9FFF%~ yrc|jkrdS|jkrdS|jkrdS|jkrdSt d)NPACK STRICT_PACK STRICT_SPREADSPREADzInvalid strategy returned: )rrrrr)strategyrs r get_strategyz;GlobalState._gen_placement_group_info..get_strategyNsk,111v.:::$}.<<<&.555x !R?P!R!RSSSrcNi|]"}|jjt|d#S) unitResources) bundle_id bundle_indexr .0bundles r z9GlobalState._gen_placement_group_info..as? -v/F/F/WrcLi|]!}|jjt|j"S)rrr rTrs rrz9GlobalState._gen_placement_group_info..gs:### -}V^/L/L###rg@@)end_to_end_creation_latency_msscheduling_latency_msscheduling_attempthighest_retry_delay_msscheduling_state)rrPbundlesbundles_to_node_idrrYstats)ray.core.generated.common_pb2rrr rrPrrrYend_to_end_creation_latency_usscheduling_latency_usrrrPlacementGroupStatsSchedulingStaterWrXr)rrrrrrs @rrz%GlobalState._gen_placement_group_info>s1CCCCCC ! ! ! T T T T T%*#///"/$7##)-3:  ##2:###% %9%BCCY39::86A*/*E*N&+&>*/*F$+$?$O$Z$k*%  #   rc|dz }|S)z=A helper function for converting nanoseconds to microseconds.ir)rtime_in_nanosecondstime_in_microsecondss r_nanoseconds_to_microsecondsz(GlobalState._nanoseconds_to_microsecondszs2T9##rcdS)N generic_workrrrrzGlobalState.srcq_build_abandoned rail_response rail_loadrail_animation rail_idledetailed_memory_dumpgoodterriblevsync_highlight_colorbackground_memory_dump) worker_idletaskztask:deserialize_argumentsz task:executeztask:store_outputswait_for_functionzray.getzray.putzray.wait submit_taskfetch_and_run_functionregister_remote_function)thread_state_uninterruptiblethread_state_iowaitthread_state_runningthread_state_runnablethread_state_sleepingthread_state_unknownrlight_memory_dumprrrrbadryellowoliverrrrstartupheap_dump_stack_frameheap_dump_object_typeheap_dump_child_node_arrowcq_build_runningcq_build_passedcq_build_failedrcq_build_attempt_runnigcq_build_attempt_passedcq_build_attempt_failedc F|ddl}|d|}g}|D]\}}|dd}|dvr|D]}|d|d|d|ddz|d z||d ||d |d z d |j|d|d d } d|d vr|d d| d<d|d vr|d d| d<|| Ќ|st d|@t|d5} tj || ddddS#1swxYwYdS|S)aReturn a list of profiling events that can viewed as a timeline. To view this information as a timeline, simply dump it as a json file by passing in "filename" or using using json.dump, and then load go to chrome://tracing in the Chrome web browser and load the dumped file. Make sure to enable "Flow events" in the "View Options" menu. Args: filename: If a filename is provided, the timeline is dumped to that file. Returns: If filename is not provided, this returns a list of profiling events. Each profile event is a dictionary. rNr~)workerdriverr{r}:r|r\r]Xr catrPr_tidtsdurphcnameargsrrPzNo profiling events found. Ray profiling must be enabled by setting RAY_PROFILING=1, and make sure RAY_task_events_report_interval_ms=0.w) r&timesleepritemsr_default_color_mappingrrloggerwarningopenrdump) rfilenamerr all_eventscomponent_id_hexcomponent_eventsr~r new_eventoutfiles rchrome_tracing_dumpzGlobalState.chrome_tracing_dumpsO* &&(((   1 ,,.. 2@2F2F2H2H& -& - . .-a01ABN%999) - -!.!,/!!23 !12S85;PP;;E,>>49,4G1J<(,BBB16|1D.J@"???5"%Z^R!8!83"S)D%E%EE !.!,/.c2-n=;;E,>>'0~~'7'7$06$W-%%&67777q8 t  h$$ / *g... / / / / / / / / / / / / / / / / / / s6II Ic>|}|}i}tt|D]}tj||}|jr|jtj krt|j j }|j}t|dt|dd||<d|vrt|d||d<d|vrt|d||d<|S)z9Get a dictionary mapping worker ID to worker information.snode_ip_addresssplasma_store_socket)r}plasma_store_sockets stderr_file stderr_files stdout_file stdout_file)r&get_worker_tabler5r6rWorkerTableDatar2is_alive worker_typerWORKERr worker_address worker_id worker_infor )rr7 worker_table workers_datar<worker_table_datar1r2s rworkerszGlobalState.workersns81133 0022  s<(())  A ' 7 B BT2U+V+V++ Y'"[00=C#N3>>L+M:"[00=C#N3>>L+M:rc8|}tj}d|_||j_||_|D]\}}t|d|j |<| | S)aVAdd a worker to the cluster. Args: worker_id: ID of this worker. Type is bytes. worker_type: Type of this worker. Value is common_pb2.DRIVER or common_pb2.WORKER. worker_info: Info of this worker. Type is dict{str: str}. Returns: Is operation success Tzutf-8)encoding) r&rr,r-r0r1r.rbytesr2add_worker_infoSerializeToString)rr1r.r2r7 worker_datakvs r add_workerzGlobalState.add_workers1133-// # /8 ","- %%'' D DDAq).q7)C)C)CK #A & &'' (E(E(G(GHHHrc|}| Jd||dks Jd|||S)zUpdate the debugger port of a worker. Args: worker_id: ID of this worker. Type is bytes. debugger_port: Port of the debugger. Type is int. Returns: Is operation success Nworker_id is not validrzdebugger_port is not valid)r&update_worker_debugger_port)rr1 debugger_portr7s rrBz'GlobalState.update_worker_debugger_portsc1133$$&>$$$  %-!*;*;*; '+<*; ;33I}MMMrcl|}| Jd||S)zGet the debugger port of a worker. Args: worker_id: ID of this worker. Type is bytes. Returns: Debugger port of the worker. NrA)r&get_worker_debugger_port)rr1r7s rrEz$GlobalState.get_worker_debugger_ports>1133$$&>$$$00;;;rc|}| Jd| Jd|||S)aUpdates the number of paused threads of a worker. Args: worker_id: ID of this worker. Type is bytes. num_paused_threads_delta: The delta of the number of paused threads. Returns: Is operation success NrA)r& update_worker_num_paused_threads)rr1num_paused_threads_deltar7s rrGz,GlobalState.update_worker_num_paused_threadss]1133$$&>$$$'335M33388 /   rc|tt}|D],}|D]\}}||xx|z cc<-t |S)a'Get the current total cluster resources. Note that this information can grow stale as nodes are added to or removed from the cluster. Returns: A dictionary mapping resource name to the total quantity of that resource in the cluster. )r&rrtotal_resources_per_nodevaluesrr)rtotal_resourcesnode_total_resources resource_idvalues rcluster_resourceszGlobalState.cluster_resourcess &&(((&c**$($A$A$C$C$J$J$L$L 6 6 &:&@&@&B&B 6 6" U ,,,5,,,, 6O$$$rcht|S)z=Returns a set of node IDs corresponding to nodes still alive.)setrJkeysrs r_live_node_idszGlobalState._live_node_idss(400227799:::rcJ|}i}|}|D]u}tj|}i}|jD] \}}|||< tjj |j } ||| <v|S)z>@@$7 > > ,778LMMGN)0)@)F)F)H)H 7 7% X.6{++k'55goFFG/= #G , ,&&rc||}tt}|D],}|D]\}}||xx|z cc<-t |S)a<Get the current available cluster resources. This is different from `cluster_resources` in that this will return idle (available) resources rather than total resources. Note that this information can grow stale as tasks start and finish. Returns: A dictionary mapping resource name to the total quantity of that resource in the cluster. Note that if a resource (e.g., "CPU") is currently not available (i.e., quantity is 0), it will not be included in this dictionary. )r&rarrrKrr)rr[total_available_resourcesavailable_resourcesrN num_availables rrkzGlobalState.available_resourcess &&((($($E$E$G$G!%0$4$4!#<#C#C#E#E H H .A.G.G.I.I H H* ])+666-G6666 H-...rcv|}tj|S)z%Get the system config of the cluster.)r&rrget_system_configrbs rrnzGlobalState.get_system_config-s/1133z(4466777rcT|}||S)z)Get the node to connect for a Ray driver.)r&get_node_to_connect_for_driver)rr}r7s rrpz*GlobalState.get_node_to_connect_for_driver2s'113366GGGrrTcT|}||S)z'Get the node information for a node id.)r&get_node)rrTr7s rrrzGlobalState.get_node7s'1133  )))rcR|}|S)zGet all the hex ids of nodes that are being drained and the corresponding draining deadline timestamps in ms. There is no deadline if the timestamp is 0. )r&get_draining_nodesrbs rrtzGlobalState.get_draining_nodes<s' 1133**,,,rc |}|tjjtjj}|rtj |SdS)z.Get the cluster config of the current cluster.N) r&get_internal_kvr!_rayletGCS_AUTOSCALER_STATE_NAMESPACEencode!GCS_AUTOSCALER_CLUSTER_CONFIG_KEYr ClusterConfigr2)rr7serialized_cluster_configs rget_cluster_configzGlobalState.get_cluster_configEsy1133$,$<$< K 6 = = ? ? K 9 @ @ B B% % ! % V!/::;TUU Utrcluster_configrcB|dSd}|jD]T}|j|d}|j}|dks|dkr2|dks|dkrtjcS|||zz }U|dkrdS|j|tj}t||S)zCalculate the maximum available resources for a given resource type from cluster config. If the resource type is not available, return None. Nr)default)node_group_configs resourcesget max_countsysmaxsize max_resourcesmin)r~r max_valuenode_group_config num_resources num_nodesmax_value_limits r+_calculate_max_resource_from_cluster_configz7GlobalState._calculate_max_resource_from_cluster_configPs  !4 !/!B 3 3 -7;;C;KKM)3IA~~!!3!3B-2"5"5{""" ]2 2II >>4(6::3 :TT9o...rcBt}|}|dS|jr6|jD].}||j/t |dkrdSi}|D]!}|||}||nd||<"|S)aGet the maximum available resources for all resource types from cluster config. Returns: A dictionary mapping resource name to the maximum quantity of that resource that could be available in the cluster based on the cluster config. Returns None if the config is not available. Values in the dictionary default to 0 if there is no such resource. Nr)rRr}rupdaterrSr6r)rall_resource_keysconfigrrrrs r%get_max_resources_from_cluster_configz1GlobalState.get_max_resources_from_cluster_confighs EE((** >4  $ M%+%> M M!!(():)D)I)I)K)KLLLL  ! !Q & &4$ D DCHHQTUUI'0'<))!F3KK rcT|}||S)z"Get the actor info for a actor id.)r&r0)rr+r7s rr0zGlobalState.get_actor_infos'1133&&x000r)NNr)4__name__ __module__ __qualname____doc__rrr&r(r*rstrr!rDr:r3rcrsryrrrrrrrrr r&r6r?rBrErGrPrTrarrrJrkrnrprrrtrr{r} staticmethodrrr/r0rrrrrs!!!/+>////8333+++&'+*. **3-*#*#3- ****X   D)))   D>>>222h N N N>: : : x$$$)[/#*5,"-!7!/3&<(> &###JTTTTl]]]]~<III,NNN& < < <   &%%%(;;;)))&'$sDcN/B*C''''"///4888 HHH ***** -DcN---- N$@    / !=>/EH/ #///\/.xS#X7O81s{1x}111111rrc4tS)aGet a list of the jobs in the cluster (for debugging only). Returns: Information from the job table, namely a list of dicts with keys: - "JobID" (identifier for the job), - "DriverIPAddress" (IP address of the driver for this job), - "DriverPid" (process ID of the driver for this job), - "StartTime" (UNIX timestamp of the start time of this job), - "StopTime" (UNIX timestamp of the stop time of this job, if any) )rYrsrrrjobsrs ??  rc4tS)zjGet next job id from GCS. Returns: Next job id in integer representation in the cluster. )rYryrrrryrys     rc4tS)zGet a list of the nodes in the cluster (for debugging only). Returns: Information about the Ray clients in the cluster. )rYrcrrrnodesrs     rc4tS)zvGet a list of the workers in the cluster. Returns: Information about the Ray workers in the cluster. )rYr6rrrr6r6s ==??rcNttjzS)aReturn the node id of the current node. For example, "node:172.10.5.34". This can be used as a custom resource, e.g., {node_id: 1} to reserve the whole node, or {node_id: 0.001} to just force placement on the node. Returns: Id of the current node. )rr!utilget_node_ip_addressrrrcurrent_node_idrs CH88:: ::rcg}tD]S}|D]<}|t r |t kr||=T|S)a6Get a list of the node ids in the cluster. For example, ["node:172.10.5.34", "node:172.42.3.77"]. These can be used as custom resources, e.g., {node_id: 1} to reserve the whole node, or {node_id: 0.001} to just force placement on the node. Returns: List of the node resource ids. )rYrJrKrS startswithrrrr)node_idsrMrNs rrrsH % > > @ @ G G I I--/4466 - -K&&~66 -#::: ,,,  - Orr+r,r-c<t|||S)aFetch actor info for one or more actor IDs (for debugging only). Args: actor_id: A hex string of the actor ID to fetch information about. If this is None, then all actor information is fetched. If this is not None, `job_id` and `actor_state_name` will not take effect. job_id: To filter actors by job_id, which is of type `ray.JobID`. You can use the `ray.get_runtime_context().job_id` function to get the current job ID actor_state_name: To filter actors based on actor state, which can be one of the following: "DEPENDENCIES_UNREADY", "PENDING_CREATION", "ALIVE", "RESTARTING", or "DEAD". Returns: Information about the actors. r+r,r-)rYr:rs ractorsrs)*   &;K   rc8t|S)aReturn a list of profiling events that can viewed as a timeline. Ray profiling must be enabled by setting the RAY_PROFILING=1 environment variable prior to starting Ray, and set RAY_task_events_report_interval_ms=0 To view this information as a timeline, simply dump it as a json file by passing in "filename" or using json.dump, and then load go to chrome://tracing in the Chrome web browser and load the dumped file. Args: filename: If a filename is provided, the timeline is dumped to that file. Returns: If filename is not provided, this returns a list of profiling events. Each profile event is a dictionary. r)rYr rs rtimeliners(  $ $h $ 7 77rc8t|S)aTReturn a list of transfer events that can viewed as a timeline. To view this information as a timeline, simply dump it as a json file by passing in "filename" or using json.dump, and then load go to chrome://tracing in the Chrome web browser and load the dumped file. Make sure to enable "Flow events" in the "View Options" menu. Args: filename: If a filename is provided, the timeline is dumped to that file. Returns: If filename is not provided, this returns a list of profiling events. Each profile event is a dictionary. r)rYr&rs robject_transfer_timeliner s  4 4h 4 G GGrc4tS)aGet the current total cluster resources. Note that this information can grow stale as nodes are added to or removed from the cluster. Returns: A dictionary mapping resource name to the total quantity of that resource in the cluster. )rYrPrrrrPrPs  " " $ $$rc4tS)aGet the current available cluster resources. This is different from `cluster_resources` in that this will return idle (available) resources rather than total resources. Note that this information can grow stale as tasks start and finish. Returns: A dictionary mapping resource name to the total quantity of that resource in the cluster. Note that if a resource (e.g., "CPU") is currently not available (i.e., quantity is 0), it will not be included in this dictionary. )rYrkrrrrkrk.s  $ $ & &&rc4tS)zGet the current available resources of each live node. Note that this information can grow stale as tasks start and finish. Returns: A dictionary mapping node hex id to available resources dictionary. )rYrarrrraraAs  - - / //rc4tS)zGet the current total resources of each live node. Note that this information can grow stale as tasks start and finish. Returns: A dictionary mapping node hex id to total resources dictionary. )rYrJrrrrJrJNs  ) ) + ++rc8t||S)zUpdate the debugger port of a worker. Args: worker_id: ID of this worker. Type is bytes. debugger_port: Port of the debugger. Type is int. Returns: Is operation success )rYrB)r1rCs rrBrB[s  , ,Y F FFrc8t||S)zUpdate the number of paused threads of a worker. Args: worker_id: ID of this worker. Type is bytes. num_paused_threads_delta: The delta of the number of paused threads. Returns: Is operation success )rYrG)r1rHs rrGrGhs  1 1)=U V VVrc6t|S)zGet the debugger port of a worker. Args: worker_id: ID of this worker. Type is bytes. Returns: Debugger port of the worker. )rYrE)r1s rrErEus  ) )) 4 44r)NNNr)7rloggingr collectionsr threadingrtypingrrr!ray._common.constantsrrray._common.utilsr r r ray._private.client_mode_hookr ray._private.protobuf_compatr ray._private.utilsr ray._rayletrray.core.generatedrrrray.util.annotationsr getLoggerrrrrYrryrr6rrrrDrrrrPrkrarJrBrGrErrrrs4  ######!!!!!!!! IIIIIIIIBBBBBBBBBB::::::888888,+++++BBBBBBBBBB------  8 $ $p 1p 1p 1p 1p 1p 1p 1p 1f  @    ; ; ;,#"&&*sm SY sm48888*HHHH& % % %'''" 0 0 0 , , , G G G W W W 5 5 5 5 5r