.`i\ddlZddlZddlZddlZddlZddlmZmZmZddl m Z ddl m Z ddl m Z ddlZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lm Z ddl!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDmEZEddlFmGZGddlHmIZImJZJdd lKmLZLdd!lMmNZNdd"lOmPZPdd#lQmRZRmSZSmTZTdd$lUmVZVdd%lWmXZXeeYZZe Gd&d'Z[Gd(d)e\Z]Gd*d+eZ^dS),N)AsyncGeneratorIterableMapping)copy) dataclass)Any) TokensPrompt) VllmConfig)AsyncEngineArgs) EngineClient)_validate_truncation_size) PromptType) init_logger) LoRARequest)MULTIMODAL_REGISTRYMultiModalRegistry)STREAM_FINISHEDPoolingRequestOutput RequestOutput)get_io_processor) PoolingParams) RendererLike)RequestOutputKindSamplingParams) SupportedTask) TokenizerLike) init_tracer)(maybe_register_config_serialize_by_value) UsageContext)cancel_task_threadsafe)as_list)EngineCoreRequest)EngineCoreClient)EngineDeadErrorEngineGenerateError)InputProcessor)OutputProcessorRequestOutputCollector) ParentRequest)get_prompt_text)Executor)StatLoggerFactoryStatLoggerManager!load_stat_logger_plugin_factories)shutdown_prometheus)IterationStatsc2eZdZUdZeed<dZedzed<dS)StreamingInputzInput data for a streaming generation request. This is used with generate() to support multi-turn streaming sessions where inputs are provided via an async generator. promptNsampling_params)__name__ __module__ __qualname____doc__r__annotations__r4rl/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/vllm/v1/engine/async_llm.pyr2r28s? -1O^d*11111r;r2c(eZdZdZdeffd ZxZS)InputStreamErrorzWrapper for errors from the input stream generator. This is used to propagate errors from the user's input generator without wrapping them in EngineGenerateError. causecr||_tt|dSN)r?super__init__str)selfr? __class__s r<rCzInputStreamError.__init__Ks.  U$$$$$r;)r5r6r7r8 ExceptionrC __classcell__)rFs@r<r>r>DsN %i%%%%%%%%%%r;r>ceZdZejeddddddddf dedeede d ed e d e d e d e de e dzde de eefdzdededdfdZedejdddddddf ded e d ede e dzde de de de eefdzdededdfdZedejdfded e d ede e dzddf dZdZdZdeedffdZ dededeezeedfzd eezd!e dzd"e!dzd#e ee"fdzd$e#eefdzd%ed&edzd'edzde$fd(Z%d)ededzd*e&dzd+ed,e$f d-Z' dfded.eedfd/eezd!e dzd"e!dzd#e ee"fdzd$e#eefdzd%ed&edzde$fd0Z(e)d eezfd1Z*ddddddd2deezeedfzd/eded'edzd"e!dzd#e ee"fdzd$e#eefdzd%ed&edzdee+dffd3Z,d4Z- dgdee.ezd5e ddfd6Z/ddd7d8e d9e ddfd:Z0dhd;Z1de fd<Z2 dided=eded"e!dzd$e#eefdzd%ed>edzd#e ee"fdzdee3dffd?Z4e5de6dzfd@Z7de6fdAZ8e5de9fdBZ:de fdCZ;dhdDZdhdGZ?dhdHZ@ djdIe dJe de fdKZAdkdLeddfdMZBdldNe edzddfdOZCde fdPZDd"e!de fdQZEdRede fdSZFdeGefdTZHdRede fdUZI dmdWedXe dzdYedZe dzfd[ZJdnd]efd^ZK dnd_ed]efd`ZLe5de fdaZMe5de fdbZNe5de fdcZOe5dePfddZQdS)oAsyncLLMFTNr vllm_configexecutor_class log_stats usage_context mm_registryuse_cached_outputs log_requestsstart_engine_loop stat_loggersaggregate_engine_loggingclient_addresses client_count client_indexreturnc t|j|_||_|j|_||_t | pg}|tt|}|p||_ |s|rt dt|j|_ t|j|jj|_t#|j|j |jjj|_|jj}|t/d|}||j_t3j|||j | | | |_d|_|j r=t;||jj||| | |_|jtAj!|_"d|_#d|_$ tAj%|&n#tN$rYnwxYw|j(j)dkr|j(j*s|j(j+}t d |tYj-d t]j/d }t`j)1t`j)j2j3g|j(j4t`j)5|||j(j6  |_)dSd|_)dS)a Create an AsyncLLM. Args: vllm_config: global configuration. executor_class: an Executor impl, e.g. MultiprocExecutor. log_stats: Whether to log stats. usage_context: Usage context of the LLM. mm_registry: Multi-modal registry. use_cached_outputs: Whether to use cached outputs. log_requests: Whether to log requests. start_engine_loop: Whether to start the engine loop. stat_loggers: customized stat loggers for the engine. If not provided, default stat loggers will be used. PLEASE BE AWARE THAT STAT LOGGER IS NOT STABLE IN V1, AND ITS BASE CLASS INTERFACE MIGHT CHANGE. Returns: None zyAsyncLLM created with log_stats=False, but custom stat loggers were found; enabling logging without default stat loggers.)rNstream_intervalNzvllm.llm_engine)rLrMrNrVrWrX)rL engine_idxscustom_stat_loggersenable_default_loggersrWrUFtorchzFTorch profiler enabled. AsyncLLM CPU traces will be collected under %s_z .async_llm) worker_nameuse_gzip) activities with_stackon_trace_ready)7r model_configrLobservability_configrRlistextendr.boolrNloggerinfor&input_processorrio_processor_plugin io_processorr' tokenizerscheduler_configr[output_processorotlp_traces_endpointrtracerr#make_async_mp_client engine_corelogger_managerr-engine_ranks_managedlog_engine_initializedasyncio Condition _pause_cond_pausedoutput_handlerget_running_loop_run_output_handler RuntimeErrorprofiler_configprofilerignore_frontendtorch_profiler_dirsocket gethostnameosgetpidr_profileProfilerActivityCPUtorch_profiler_with_stacktensorboard_trace_handlertorch_profiler_use_gzip)rErLrMrNrOrPrQrRrSrTrUrVrWrXr]has_custom_loggersendpointrt profiler_dirras r<rCzAsyncLLM.__init__QsJ 1222'4&$/$D!("<#5266""#D#F#FGGG!"566"8&8 /  KKA    .d.>??,     1   !0 Nn ,=M! ! !  ,A   !2H==F+1D ! (,@#)n-%%    9= > 9"3' ,A$7'0))A ###D    6 6 8 8 8#,.. 37   $ & & &  $ $ & & & &    D   ' 0G ; ;/? <'6IL KKX   $/11KKBIKKKKKK!N22N37'6P$~GG +(8P H   3  DMMM!DMMMs 'G22 G?>G?enable_log_requestsdisable_log_statsc T||tj||||| |||| |  S)N) rLrMrSrTrRrNrUrOrVrWrX)r+ get_class) clsrLrSrOrTrrUrrVrWrXs r<from_vllm_configzAsyncLLM.from_vllm_configsLs##-k::/%,++%='-%%    r; engine_argsc ||}tj|}||||j|j |||S)z'Create an AsyncLLM from the EngineArgs.)rLrMrRrNrSrOrT)create_engine_configr+rrr)rrrSrOrTrLrMs r<from_engine_argszAsyncLLM.from_engine_argss`"66}EE !+K88s#)$8%77/'%    r;c.|dSrA)shutdownrEs r<__del__zAsyncLLM.__del__ s r;ctt|ddx}r|t|ddx}r|t|dd}|t |dSdS)z2Shutdown, cleaning up the background proc and IPC.rvNrmr~)r/getattrrcloser )rErvrmhandlers r<rzAsyncLLM.shutdowns !$ t<< <; #  " " "%d,=tDD D? $  ! ! # # #$ 0$77   "7 + + + + +  r;.cDK|jd{VSrA)rvget_supported_tasks_asyncrs r<get_supported_taskszAsyncLLM.get_supported_taskss-%??AAAAAAAAAr; request_idr3params arrival_time lora_requesttokenization_kwargs trace_headersprioritydata_parallel_rank prompt_textc PKjrtt|t} jjjr| s|jrtd|i}tj j |j |t|tr#||||||||| d{VSt|tr(|} || jkrt"dnB| tdj||||||||| } t+|} j| j4d{Vjfdd{Vdddd{Vn#1d{VswxYwYt5|j| j} | j}| s |jdkr!| | dd| d{V| S|}t|t>sJtA| }tC|jD]f}|"|\}}||jdz kr| ntG| }||_||_$|| ||| d{Vg| S)z Add new request to the AsyncLLM.z--kv-sharing-fast-prefill produces incorrect logprobs for prompt tokens, please disable it when the requests need prompt logprobsNzAsyncLLM.add_request() was passed a request_id parameter that does not match the EngineCoreRequest.request_id attribute. The latter will be used, and the former will be ignored.z6should only provide prompt_text with EngineCoreRequestcj SrA)r}rsr<z&AsyncLLM.add_request..ys  4Dr;rKr)%erroredr$ isinstancerrL cache_configkv_sharing_fast_prefillprompt_logprobs ValueErrorr rf max_model_lentruncate_prompt_tokensr_add_streaming_input_requestr"rrk warning_oncermprocess_inputsr*assign_request_idrr|wait_forr( output_kindrn _add_requestrr)rangeget_child_inforr4)rErr3rrrrrrrr is_poolingrequestqueue parent_paramsparent_requestidx child_params child_requests` r< add_requestzAsyncLLM.add_request s& < $!## # 66    ) A  &  "   &"$ !   +  )    fn - - ::#"          f/ 0 0 2GW///##K & L*99#"  G*&11K ..w777   """# F F F F F F F F"++,D,D,D,DEE E E E E E E E F F F F F F F F F F F F F F F F F F F F F F F F F F F'v'97;MNN  Q##G[$5II I I I I I I IL -88888'w//))  C'5'D'DS'I'I $J '*mo.A'A'AGGtG}}M'1M $,8M )##{NC         s-$F## F-0F-r parent_reqindexrcK|j||||||j|d{V|jr"t d|jdSdS)NzAdded request %s.)rrrrvadd_request_asyncrRrkrlr)rErr3rrrs r<rzAsyncLLM._add_requests ))'6:ueTTT00999999999   A KK+W-? @ @ @ @ @ A Ar; input_streamr4c  Kt||||||  jsd_jjdt dgd  j  j tj   fd} tj | _S)N)rrrrrrTr)prompt_token_ids)rr3rc Kd} 23d{V}|j}|r |n } jjd |j|dd} |_|jtdt|j} ||dd d{V6nR#tj tf$rd}Yn8t$r,} t|Yd}~nd}~wwxYwd _|s! ddd d{VdSdS#d _|s ddd d{VwwxYw)NFT)rr3r resumablez0prompt_embeds not supported for streaming inputsrr:)r4)_validate_streaming_input_sampling_paramsrmrr3external_req_id prompt_embedsrr*rrzCancelledError GeneratorExitrGputr>_input_stream_task) cancelled input_chunkspreqrerror final_reqrinputsinternal_req_idrrr4rEs r< handle_inputsz.handle_inputss.I M)5NNNNNNN+$4B-FFrJJJJ,=$.=#2*1!"&  ! C+5C'(4(N#2+2D"E"EK++CdAuMMMMMMMMMM'*6(*M: ! ! !  3 3 3 *51122222222 3 ,0( M++ItT1eLLLLLLLLLLLMM,0( M++ItT1eLLLLLLLLLLMsFB BBB D C/8D: C/"C*%D*C//D+E r:)rdict skip_cloneclonermrr rrr(rrrz create_taskr)rErrr4rrrrrrrrrrrs```` @@@@r<rz%AsyncLLM._add_streaming_input_requestsa 66GGG%% 3'1    ) .-3355O)-O &8D(7 !!555"     ..y999#.&'BOTT" M" M" M" M" M" M" M" M" M" M" M" MJ   """#*#6}}#G#G  r;ct|tr'|jdks|jtjks|jrtddS)NrKzrInput streaming not currently supported for pooling models, n > 1, request_kind = FINAL_ONLY or with stop strings.)rrrrr FINAL_ONLYstopr)rs r<rz2AsyncLLM._validate_streaming_input_sampling_paramss` 6>22 x!||!%6%AAA{B( BAr;)rrrrrrc Kd} ||||||||| | d{V} d} | s\| p| d{V} t| tsJ| j} | t ur| WV| \n#tjtf$rH| "| | j dd{V|j rtd|t$r$|j rtd|t $r)} |j rtd|| d} ~ wt"$rT} | "| | j dd{V|j rtd || | j| d} ~ wt&$r} | "| | j dd{V|j re | jjd | }n6#t&$r)}| jjd d z|jjz}Yd}~nd}~wwxYwtd ||t-| d} ~ wwxYw| | dSdS#| | wwxYw) aj Main function called by the API server to kick off a request * 1) Making an AsyncStream corresponding to the Request. * 2) Processing the Input. * 3) Adding the Request to the Detokenizer. * 4) Adding the Request to the EngineCore (separate process). A separate output_handler loop runs in a background AsyncIO task, pulling outputs from EngineCore and putting them into the per-request AsyncStream. The caller of generate() iterates the returned AsyncGenerator, returning the RequestOutput back to the caller. N)rrrrrrFTinternalRequest %s aborted. Request %s failed (engine dead).z$Request %s failed (bad request): %s.z$Request %s failed (input error): %s.z: z+error during printing an exception of classzRequest %s failed due to %s.)r get_nowaitgetrrfinishedrrzrrabortrrRrkrlr$rr>r?rGrFr5r%r)rEr3r4rrrrrrrqroutese2s r<generatezAsyncLLM.generate si8,0K &&)$7+!#5''        AH llnn5aeegg "#}55555<o--IIII & 6   }jjj=========  ? 1:>>>      L > KKK      S BJPQRRR   ! ! !}jjj=========  S BJPQRRR'q  / / /}jjj========= K;/66166AA ;/333GH,/0AAAAA  :JJJJ%''Q . /} }q} snBB I, BI$E IAF I++I G)(I ) H3HI H.I  II,,Jc|jdS|j|j|j|j|jt jfd}tj ||_dS)zBBackground loop: pulls from EngineCore and pushes to AsyncStreams.NcK d{V}t|j} r|rtnd}|j}t d| D]}}| z}|||}||j|}|jrJ||krtj dd{V|j r |j d{V~ |j  r5 |j|j | +#t"$r:}t$d|Yd}~dSd}~wwxYw)NTr) engine_idxscheduler_statsiteration_statsmm_cache_statszAsyncLLM output_handler failed.)get_output_asynclenoutputsr0rprocess_outputs timestamprequest_outputsrzsleep reqs_to_abortabort_requests_asyncupdate_scheduler_statsrrecord engine_index stat_mm_cacherGrk exceptionpropagate_error)r num_outputsrengine_core_outputsstartend outputs_sliceprocessed_outputsr chunk_sizervrmrNrwrrs r<r~z4AsyncLLM._run_output_handler..output_handlers 0 4,$/$@$@$B$BBBBBBBG"%go"6"6K.7Q;Q(((T$+2/'!&q+z!B!B#j0(;E#I(F ,<,L,L)7+Q>Q />>{HUU33ODDDDDDDDD   I KK0#((;2G2G H H H H H I Ir;)wait_for_inflight_requests clear_cacher"r#c(K|j4d{V|jr dddd{VdSd|_dddd{Vn#1d{VswxYwY|sJt|jj}|r||dd{V|jr|jd{V|r6| d{V| d{VdSdS)a4 Pause generation to allow model weight updates. New generation/encoding requests are blocked until resume. Args: wait_for_inflight_requests: When ``True`` waits for in-flight requests to finish before pausing. When ``False`` (default), immediately aborts any in-flight requests. clear_cache: Whether to clear KV cache and prefix cache after draining. Set to ``False`` to preserve cache for faster resume. Default is ``True`` (clear caches). NTr) r|r}rhrrrequest_stateskeysrhas_unfinished_requestswait_for_requests_to_drainreset_prefix_cachereset_mm_cache)rEr"r#r s r<pause_generationzAsyncLLM.pause_generations(#        |                DL                           * =t4CHHJJKKK =jjtj<<<<<<<<<  8 8 : : E'BBDD D D D D D D D  ())++ + + + + + + +%%'' ' ' ' ' ' ' ' ' ' ( (s AA AAcK|j4d{Vd|_|jdddd{VdS#1d{VswxYwYdS)z1Resume generation after :meth:`pause_generation`.NF)r|r} notify_allrs r<resume_generationzAsyncLLM.resume_generations# * * * * * * * * DL   ' ' ) ) ) * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *s!A AAczK|j4d{V|jcdddd{VS#1d{VswxYwYdS)z.Return whether the engine is currently paused.N)r|r}rs r< is_pausedzAsyncLLM.is_pauseds#        <                              s * 44pooling_paramsrc Kd} |tjdtd||||||||d{V} d} | sS| p| d{V} t | tsJ| j} | WV| Sn#tj $rH| "| | j dd{V|j rtd |t $r$|j rtd |t"$r$|j rtd |t$$rZ} | "| | j dd{V|j rtd |t'| d} ~ wwxYw| | dSdS#| | wwxYw) a Main function called by the API server to kick off a request * 1) Making an AsyncStream corresponding to the Request. * 2) Processing the Input. * 3) Adding the Request to the EngineCore (separate process). A separate output_handler loop runs in a background AsyncIO task, pulling outputs from EngineCore and putting them into the per-request AsyncStream. The caller of generate() iterates the returned AsyncGenerator, returning the RequestOutput back to the caller. NOTE: truncate_prompt_tokens is deprecated in v0.14. TODO: Remove truncate_prompt_tokens in v0.15. NzThe `truncate_prompt_tokens` parameter in `AsyncLLM.encode()` is deprecated and will be removed in v0.15. Please use `pooling_params.truncate_prompt_tokens` instead.) stacklevel)rrrrFTrrrz Request %s failed (bad request).zRequest %s failed.)warningswarnDeprecationWarningrrrrrrrzrrrrRrkrlr$rrGr%r) rEr3r1rrrrrrrrrrs r<encodezAsyncLLM.encodes8,0? %1 R' &&)$7+!'AH llnn5aeegg !#';<<<<<<  %   }jjj=========  ? 1:>>>      L > KKK      L > KKK  / / /}jjj=========  > 0*===%''Q .  /} }q} s,BBG B7F0AF++F00G G&c|jjSrA)rmrprs r<rpzAsyncLLM.tokenizerZs#--r;c4|jSrA)rm get_tokenizerrs r<r;zAsyncLLM.get_tokenizer^s#11333r;c|jjSrA)rmrendererrs r<r=zAsyncLLM.rendereras#,,r;c"K|jjduSrA)rgrsrs r<is_tracing_enabledzAsyncLLM.is_tracing_enabledes(=TIIr;cNK|jr|jdSdSrA)rwlogrs r< do_log_statszAsyncLLM.do_log_statshs6   &   # # % % % % % & &r;cZKtd|jr|jdS)NzCalled check_health.)rkdebugr dead_errorrs r< check_healthzAsyncLLM.check_healthls5 +,,, < "/ ! " "r;cK|jdg}|j1|t j|jjt j|d{VdS)NT)rv profile_asyncrappendrz to_threadrgatherrEcoross r< start_profilezAsyncLLM.start_profileqsn!//556 = $ LL*4=+>?? @ @ @ne$$$$$$$$$$r;cK|jdg}|j1|t j|jjt j|d{VdS)NF)rvrHrrIrzrJrrKrLs r< stop_profilezAsyncLLM.stop_profilewsn!//667 = $ LL*4=+=>> ? ? ?ne$$$$$$$$$$r;czK|j|jd{VdSrA)rmclear_mm_cachervreset_mm_cache_asyncrs r<r*zAsyncLLM.reset_mm_cache}sH ++---3355555555555r;reset_running_requestsreset_connectorcHK|j||d{VSrA)rvreset_prefix_cache_async)rErTrUs r<r)zAsyncLLM.reset_prefix_cachesF%>> "O         r;levelcK|d{V|j|d{V|j|jd|dSdS)NrK)r)rv sleep_asyncrwrecord_sleep_state)rErXs r<r zAsyncLLM.sleeps%%'''''''''**5111111111   *   2 21e < < < < < + *r;tagscK|j|d{V|j|jdddSdS)Nr)rv wake_up_asyncrwr[)rEr\s r<wake_upzAsyncLLM.wake_ups_,,T222222222   *   2 21a 8 8 8 8 8 + *r;cDK|jd{VSrA)rvis_sleeping_asyncrs r< is_sleepingzAsyncLLM.is_sleepings-%77999999999r;cFK|j|d{VS)zT(; "$: : :t~ : #4 , '=!>!>??$(###D    ; : : :r;cH|jdup|j SrA)r~doners r< is_runningzAsyncLLM.is_runnings)"d*L$2E2J2J2L2L.LLr;c|jSrA)rrs r< is_stoppedzAsyncLLM.is_stoppeds |r;c4|jjjp|j SrA)rv resources engine_deadrrs r<rzAsyncLLM.erroreds)5LT_9LLr;ctSrA)r$rs r<rEzAsyncLLM.dead_errors   r;)NNNNrNN)NNNNrN)F)rYN)NNrNN)FF)rKrA)Nr:N)rx)Rr5r6r7rENGINE_CONTEXTrr typer+rjrrhr,rrDintrC classmethodrr rrrtuplerrr"rrr2rrfloatrrrr(rr)rr staticmethodrrrrrrr+r.r0rr8propertyrrpr;rr=r?rBrFrNrPr*r)r r_rbrerjsetrmrprwr(rrrr BaseExceptionrEr:r;r<rJrJPs '3&A*=#(!"&7;).26B!B!B!XB! B! $ B! ( B!!B!B! B!,-4B!#'B!sCx.4/B!B!B! B!B!B!B!H#'&2&A7;$))."'26     $  ,-4  "  #'   sCx.4/       [ 8#'&2&A7;   $   $  ,-4      [ 0 , , ,B51C+DBBBB&*+/5926)-"&rrr"J.PT@T1UUr. r dl r "D( r"#s(^d2rsCx(4/rr $Jr4Zr rrrrhA"Ad A"D( A  A & AAAA,&*+/5926)-PPP%^T%9:P(-7 P dl P "D( P"#s(^d2PsCx(4/PP $JP PPPPd .   \ 4#'+/5926)-hhh!J.PT@T1UUh(h h 4Z h"D(h"#s(^d2hsCx(4/hh $Jh  t+ ,hhhhTBDBDBDJAF I I - I9= I  I I I I",1 %(%(%(%)%( %(  %(%(%(%(N****     ,026-159\\\&\ \ "D( \ sCx(4/ \\!$d \"#s(^d2\ ,d2 3\\\\|.=4/...X.4}4444-,---X-J$JJJJ&&&&"""" %%%% %%%% 6666 MR  &* EI     ===T====99$s)d"29d9999 :4::::C;C4CCCCAAAAAA9#c(9999>c>d>>>>!%"         t       c    "AD((&)(:=((((TMDMMMXMDXMMMMXM!M!!!X!!!r;rJ)_rzrrr{r5collections.abcrrrr dataclassesrtypingrr_ vllm.envsrvllmr vllm.configr vllm.engine.arg_utilsr vllm.engine.protocolr vllm.entrypoints.utilsr vllm.inputsr vllm.loggerrvllm.lora.requestrvllm.multimodalrr vllm.outputsrrrvllm.plugins.io_processorsrvllm.pooling_paramsrvllm.renderersrvllm.sampling_paramsrr vllm.tasksrvllm.tokenizersr vllm.tracingrvllm.transformers_utils.configrvllm.usage.usage_librvllm.utils.async_utilsr vllm.utils.collection_utilsr!vllm.v1.enginer"vllm.v1.engine.core_clientr#vllm.v1.engine.exceptionsr$r%vllm.v1.engine.input_processorr&vllm.v1.engine.output_processorr'r( vllm.v1.engine.parallel_samplingr)vllm.v1.engine.utilsr*vllm.v1.executorr+vllm.v1.metrics.loggersr,r-r.vllm.v1.metrics.prometheusr/vllm.v1.metrics.statsr0r5rkr2rGr>rJr:r;r<rs ==========!!!!!! """"""111111------<<<<<<""""""######))))))CCCCCCCCMMMMMMMMMM777777------''''''BBBBBBBB$$$$$$))))))$$$$$$SSSSSS------999999//////,,,,,,777777JJJJJJJJ999999SSSSSSSS::::::000000%%%%%% ;:::::000000 X   2222222 2 % % % % %y % % %o!o!o!o!o!|o!o!o!o!o!r;