_iLdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddlmZmZmZmZmZmZddlmZmZmZmZddlmZmZddlmZmZdd l m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-dd l.m/Z/dd l0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6m7Z7m8Z8m9Z9ddl:m;Z;ddlm?Z?m@Z@mAZAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIerddlJmKZKddlLmMZMddlNmOZOmPZPdZQeRe eSjTZUd-dZVGddZWGddZXd.d#ZYd/d'ZZ d0d1d,Z[dS)2zZdwd?Zdbd@ZdbdAZedxdCZdydEZdzdHZ d{dJZ!d|dLZ"dbdMZ#d}dPZ$d~dQZ%d~dRZ&dbdSZ'dbdTZ(ddVZ)ddWZ*ddXZ+dbdYZ,ddZZ-dd\Z.dd_Z/dd`Z0d S)Topologyz*Monitor a topology of one or more servers.topology_settingsr4c 2|j|_|jj|_|jduo |jj|_|jduo |jj|_d|_d|_ |js|jrtj d|_tj tjr&t!tt"j|j|jr5|jJ|j|jj|jff||_t-|||jdd|}||_t-t6jiddd|j}|jr<|jJ|j|jj||j|jfftj tjrGt!tt"j|jt?|t?|j|j D]}|jr6|jJ|j|jj!||jfftj tjr4t!tt"j"|j|d|dtG|$|_%d|_&d|_'tQ|_)tU|j)tVr |jj,nd|_-i|_.d|_/d|_0tc|_2|js|jru|jJdfd }tgj4tjj6tjj7|d }tqj9|j|j:||_ |;d|_<|jj=&|jj>st||j|_<g|_@dS)Nd)maxsizemessage topologyIdrLrMpreviousDescriptionnewDescriptionr)rLrM serverHost serverPortFr9r:c&KtSN)rD)weaksrCtargetz!Topology.__init__..targets+D111pymongo_events_thread)interval min_intervalrWname)r9r:)A _topology_id _pool_options_event_listeners _listenersenabled_for_server_publish_serverenabled_for_topology _publish_tp_events_Topology__events_executorr=Queuer" isEnabledForloggingDEBUGr$r%START_TOPOLOGYputpublish_topology_opened _settingsr0get_topology_typeget_server_descriptionsreplica_set_name _descriptionr/Unknown$publish_topology_description_changedTOPOLOGY_CHANGEreprseedspublish_server_opened START_SERVERlistserver_descriptions_seed_addresses_opened_closedr!_lockr _IS_SYNCcondition_class _condition_servers_pid_max_cluster_timer _session_poolrAsyncPeriodicExecutorr EVENTS_QUEUE_FREQUENCYMIN_HEARTBEAT_INTERVALweakrefrefcloseopen _srv_monitorfqdn load_balancedr_monitor_tasks)selfrGtopology_description initial_tdseedrWexecutorrVs @rC__init__zTopology.__init__ks-:+9J#d:at?a?$6_4?;_ &*   44#3 4 ;s333DL  $W] 3 3  *9,       ^<+++ L  doEHYG[\ ] ] ]*2  / / 1 1  5 5 7 7  .      1(  !2tT4     <+++ L  OH!2D4EF     $W] 3 3  *:,$($4$4#D$566     &+  D# e|///   $/"G$PTPaIb!cddd(77  .;#0#Aw#Aw  $$8$L$L$N$NOO  ')) 1 J(L66  13 #' 8</11   4#3 <+++ 2 2 2 2 2 2)>6#:, H;t|X^<  *4>3O * *4 @ @D 24rXr9Nonec|Ktj}|j||_n||jkr||_tjdddkr dt fi}nddi}t j di||j4d{V|j D]}| d{V|j dddd{Vn#1d{VswxYwY|j4d{V|d{Vdddd{VdS#1d{VswxYwYdS) aStart monitoring, or restart after a fork. No effect if called multiple times. .. warning:: Topology is shared among multiple threads and is protected by mutual exclusion. Using Topology from a process other than the one that initialized it will emit a warning and may result in deadlock. To prevent this from happening, AsyncMongoClient must be created after any forking. N) skip_file_prefixes stacklevelAsyncMongoClient opened before fork. May not be entirely fork-safe, proceed with caution. See PyMongo's documentation for details: https://dochub.mongodb.org/core/pymongo-fork-deadlock)r)osgetpidrsys version_info _pymongo_dirwarningswarnrrvaluesrrreset_ensure_opened)rpidkwargsservers rCrz Topology.opensikk 9 DII DI  DI#w...@&* MH       z + + + + + + + +"m2244))F ,,..(((((((("((***  + + + + + + + + + + + + + + + + + + + + + + + + + + +: ( ( ( ( ( ( ( (%%'' ' ' ' ' ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s%=AC C),C)=D++ D58D5floatcHtj}| |jjS|SrU)r remainingrnserver_selection_timeout)rtimeouts rCget_server_selection_timeoutz%Topology.get_server_selection_timeouts$/## ?>: :rXNselector Callable[[Selection], Selection] operationstrrOptional[float]addressOptional[_Address] operation_id Optional[int] list[Server]cJK|}n|}ts!jrd{Vj4d{V|||||d{V}fd|Dcdddd{VS#1d{VswxYwYdS)aReturn a list of Servers matching selector, or time out. :param selector: function that takes a list of Servers and returns a subset of them. :param operation: The name of the operation that the server is being selected for. :param server_selection_timeout: maximum seconds to wait. If not provided, the default value common.SERVER_SELECTION_TIMEOUT is used. :param address: optional server address to select. Calls self.open() if needed. Raises exc:`ServerSelectionTimeoutError` after `server_selection_timeout` if no matching servers are found. Ncjg|]/}tt|j0S)r rget_server_by_addressr).0sdrs rC z+Topology.select_servers..*s@IKVT77 CCDDrX)rrrcleanup_monitorsr_select_servers_loop)rrrrrrserver_timeoutr{s` rCselect_serverszTopology.select_serverss. $ +!>>@@NN5N *D/ *'')) ) ) ) ) ) ) ):        (,(A(A.)\7))###### Ob                               s-B BBrlist[ServerDescription]cKtj}||z}d}tjtjr9t ttj||||j |j j j |j |||jj} | s|dks||krtjtjrMt ttj||||j |j j j ||t%||d|d|j |s`t ttj||||j |j j j t)d|tjz z d }|d {V|t/|jt2jd {V|j tj}|j |||jj} | |j | S) z7select_servers() guts. Hold the lock when calling this.F)rLrr operationIdtopologyDescriptionclientId)custom_selectorr)rLrrrrrfailurez , Timeout: zs, Topology Description: i)rLrrrrrremainingTimeMSTN)time monotonicr#rhrirjr$r&STARTED description_topology_settingsr]rrapply_selectorrnserver_selectorFAILED_error_messagerWAITINGintr_request_check_allrrr rcheck_compatible) rrrrrrnowend_timelogged_waitingr{s rCrzTopology._select_servers_loop.sn= # 0 ? ?  (5=!#($($4)<I    #/>> gt~/M?  &+ !||sX~~+8GG 0 = D!)"+$0,0,;K;K0K(L$M$M    "&%%'' ' ' ' ' ' ' '  # # % % % #4?F4QRR R R R R R R R   . . 0 0 0.""C"&"3"B"B'4>3Q#C## S&+ Z **,,,""rXdeprioritized_serversOptional[list[Server]]rcK||||||d{V}t||}t|dkr|dStj|d\}} |jj| jjkr|S| S)NrQrr)r_filter_serverslenrandomsamplepooloperation_count) rrrrrrrserversserver1server2s rC_select_serverzTopology._select_serverzs++ i!97L        "'+@AA w<<1  1: !=!44 < '7<+G G GNNrXc K|||||||d{V}tjrtj|jjt jtj r[tt tj ||||j|jj j|jjd|jjd |S)zALike select_servers, but choose a random server if several match.rNrrQ)rLrrrrrrRrS)rr get_timeoutset_rttrmin_round_trip_timer#rhrirjr$r& SUCCEEDEDrr]r)rrrrrrrrs rC select_serverzTopology.select_servers**   $  !% +             B M&,@ A A A # 0 ? ?  (5?!#($($4)<I!-5a8!-5a8     rXr6cPK|t||||d{VS)a=Return a Server for "address", reconnecting if necessary. If the server's type is not known, request an immediate check of all servers. Time out after "server_selection_timeout" if the server cannot be reached. :param address: A (host, port) pair. :param operation: The name of the operation that the server is being selected for. :param server_selection_timeout: maximum seconds to wait. If not provided, the default value common.SERVER_SELECTION_TIMEOUT is used. :param operation_id: The unique id of the current operation being performed. Defaults to None if not provided. Calls self.open() if needed. Raises exc:`ServerSelectionTimeoutError` after `server_selection_timeout` if no matching servers are found. rN)rr*)rrrrrs rCselect_server_by_addressz!Topology.select_server_by_addresssR2''   $ % (         rXFserver_descriptionr( reset_poolr:interrupt_connectionsc K|j}|j|j}t||rdSt |j|}|js|jrU|jtj kr@|j |j}|r|j d{V||k}|jr?|s=|jJ|j|jj|||j|jff||_|d{V|jr>|s<|jJ|j|jj||j|jfft/jt2jrI|sGt7t.t8j|jt=|t=|j|jrm|jtj krX|jjtBvrE|j"d{VtFs|j$%|j|j&'dS)ziProcess a new ServerDescription on an opened topology. Hold the lock when calling this. NrN)(rr_server_descriptionsr_is_stale_server_descriptionr2 is_readableis_server_type_known topology_typer/Singlergetrreadyrbrerlr`"publish_server_description_changedr]_update_serversrdrtr"rhrirjr$r%rurvrrsr.rrrappendr notify_all) rrrrtd_oldsd_oldnew_tdrsuppress_events rC_process_changezTopology._process_changes",-?-GH '0B C C  F-d.?ASTT  ) *  3 *8>8LP]Pd8d8d]&&'9'ABBF *k'')))))))))#55    <+++ L  OF/1C1KTM^_   #""$$$$$$$$$   N <+++ L  OHT.0AB     $W] 3 3 N  *:,$(LL#D$566        >  M$9 9 9!/7MMM#))++ + + + + + + + >#**4+<=== ""$$$$$rXcK|j4d{V|jr<|j|jr||||d{Vdddd{Vn#1d{VswxYwY|rD|j|j}|r%|j |d{VdSdSdS)z>Process a new ServerDescription after an hello call completes.N)r) rr}rr has_serverrr rrrr)rrrrrs rC on_changezTopology.on_changes: b b b b b b b b| b 1 < <=O=W X X b**+=zK`aaaaaaaaa b b b b b b b b b b b b b b b b b b b b b b b b b b b  U]&&'9'ABBF Uk''>S'TTTTTTTTTTT U U U UsAA&& A03A0seedlistlist[tuple[str, Any]]c K|j}|jtvrdSt|j||_|d{V|jr<|jJ|j|jj ||j|j fftj tjrIttt j|j t%|t%|jdSdS)z_Process a new seedlist on an opened topology. Hold the lock when calling this. NrN)rrrr.r1rrdrerlr`rtr]r"rhrirjr$r%rurv)rrrs rC_process_srv_updatezTopology._process_srv_update0s"  '= = = FEdFWYabb""$$$$$$$$$   <+++ L  OHT.0AB     $W] 3 3  *:,$(LL#D$566         rXcK|j4d{V|jr||d{Vdddd{VdS#1d{VswxYwYdS)z?Process a new list of nodes obtained from scanning SRV records.N)rr}r)rrs rC on_srv_updatezTopology.on_srv_updateLs: 9 9 9 9 9 9 9 9| 9..x888888888 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9s#A AAOptional[Server]c6|j|S)aJGet a Server or None. Returns the current version of the server immediately, even if it's Unknown or absent from the topology. Only use this in unittests. In driver code, use select_server_by_address, since then you're assured a recent view of the server's type and wire protocol version. )rrrrs rCrzTopology.get_server_by_addressSs}  )))rXc||jvSrU)rrs rCr zTopology.has_server]s$-''rXc$K|j4d{V|jj}|tjkr dddd{VdSt |djcdddd{VS#1d{VswxYwYdS)z!Return primary's address or None.Nr)rrrrr/ReplicaSetWithPrimaryr-_new_selectionr)rrs rC get_primaryzTopology.get_primary`s: N N N N N N N N -;M CCC N N N N N N N N N N N N N N ,D,?,?,A,ABB1EM  N N N N N N N N N N N N N N N N N N N N N N N N N N N N N NsA?+A?? B  B  set[_Address]c`K|j4d{V|jj}|tjtjfvr t cdddd{VSdt||Dcdddd{VS#1d{VswxYwYdS)z+Return set of replica set member addresses.Nch|] }|j Sr)r)rrs rC z4Topology._get_replica_set_members..wsOOO2BJOOOrX) rrrrr/rReplicaSetNoPrimarysetiterr)rrrs rC_get_replica_set_membersz!Topology._get_replica_set_membersjs : P P P P P P P P -;M31%uu  P P P P P P P P P P P P P PPOhht7J7J7L7L.M.M)N)NOOO P P P P P P P P P P P P P P P P P P P P P P P P P P P P P Ps4B3B B'*B'cFK|td{VS)z"Return set of secondary addresses.N)r$r,rs rCget_secondarieszTopology.get_secondariesys-223LMMMMMMMMMrXcFK|td{VS)z Return set of arbiter addresses.N)r$r+r&s rC get_arbiterszTopology.get_arbiters}s-223JKKKKKKKKKrXOptional[ClusterTime]c|jS)z1Return a document, the highest seen $clusterTime.rr&s rCmax_cluster_timezTopology.max_cluster_times %%rX cluster_timeOptional[Mapping[str, Any]]c\|r'|jr|d|jdkr ||_dSdSdS)N clusterTimer,rr.s rC_receive_cluster_time_no_lockz&Topology._receive_cluster_time_no_locksR  6* 6 .1G 1VVV)5&&&  6 6WVrXcK|j4d{V||dddd{VdS#1d{VswxYwYdSrU)rr3r2s rCreceive_cluster_timezTopology.receive_cluster_times: = = = = = = = =  . .| < < < = = = = = = = = = = = = = = = = = = = = = = = = = = = = = =s9 AA wait_timercK|j4d{V|t|j|d{Vdddd{VdS#1d{VswxYwYdS)z=Wake all monitors, wait for at least one to check its server.N)rrrr)rr7s rCrequest_check_allzTopology.request_check_alls: ? ? ? ? ? ? ? ?  # # % % %"4?I>> > > > > > > > ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?s0A A Acf|jjtjkr |jjS|jjS)z~Return a list of all data-bearing servers. This includes any server that might be selected for an operation. )rrrr/r known_serversreadable_serversr&s rCdata_bearing_serverszTopology.data_bearing_serverss0   *m.B B B$2 2 11rXc Kg}|j4d{V|D]G}|j|j}|||jjfH dddd{Vn#1d{VswxYwY|D]r\}} |j|d{V'#t$r?}t|d|dd}| |j j|d{Vd}~wwxYwdS)NrF) rr=rrrrgen get_overallremove_stale_socketsr _ErrorContext handle_errorr)rrrr generationexcctxs rC update_poolzTopology.update_pools: H H H H H H H H//11 H Hrz2 (C(C(E(EFGGGG H H H H H H H H H H H H H H H H H H H H H H H H H H H H #*   FJ k66zBBBBBBBBBB   #CJtDD''(:(BCHHHHHHHHH   s*AB B B  B<< D:DDc "K|j4d{V|j}|jD]B}|d{Vt s|j|jC|j |_|j D] \}}||jvr||j|_ !|j rE|j d{Vt s|j|j d|_d|_dddd{Vn#1d{VswxYwY|jr|jJt%t&ji|jj|jj|jj|jj|_|j|jj||j|jff|j|jj|jfft=jt@j!rmtEt<tFj$|jtK|tK|jtEt<tFj&|j|j's|jra|j(|j()dd{VtUtWj,|jdSdS)zClear pools and terminate monitors. Topology does not reopen on demand. Any further operations will raise :exc:`~.errors.InvalidOperation`. NFTrNrKrQ)-rrrrrrrrr_monitorrr{itemsrrr}r~rdrer0r/rsrqmax_set_versionmax_election_idrrlr`rtr]publish_topology_closedr"rhrirjr$r%rurv STOP_TOPOLOGYrbrfjoinrDrr)rold_tdrrrs rCrzTopology.closes :        &F-..00 @ @llnn$$$$$$$@'..v???!% 1 7 7 9 9D #0DDFFLLNN < < dm++9;DM'*6  B'--/////////B'..t/@AAA DLDL)                           .   ^<+++ 3%!2!1!1!4 !!D  L  OH))    L  doEHYG[\ ] ] ]  $W] 3 3  *:,$(LL#D$566      &8&FSWSd       <4#3 <  " ( ( * * *(--a00 0 0 0 0 0 0 0 T\!:!: ; ; ; ; ;  < Start or resume a server session, or raise ConfigurationError.)rget_server_session)rrVs rCrXzTopology.get_server_sessions!445LMMMrXserver_sessionc:|j|dSrU)rreturn_server_session)rrYs rCr[zTopology.return_server_sessions 00@@@@@rXr)c4tj|jS)zmA Selection object, initially including all known servers. Hold the lock when calling this. )r)from_topology_descriptionrrr&s rCrzTopology._new_selection s 243DEEErXc RK|jrtd|jsd|_|d{V|js|jr|j|jr,|j j tvr|j|j j rJ|t|jdt#d|jddd{V|jD]}|d{VdS)z[Start monitors, or restart after a fork. Hold the lock when calling this. z'Cannot use AsyncMongoClient after closeTNrrQ )ok serviceIdmaxWireVersion)r~rr}rrdrbrfrrrrr.rnrr r(r|rr]rrrrs rCrzTopology._ensure_openedsv < N"#LMM M| DL&&(( ( ( ( ( ( ( ( .4#7 .&++---  )d&6&DH^&^&^!&&(((~+ **%,Q/QT5FZ\]]^^m**,,  F++--          rXerr_ctxrBcb|j|}|dS|j|j|jrdS|jj}|j}d}|rDt|dr4t|j tr|j d}t||S)NTdetailstopologyVersion)rr_poolstale_generationsock_generation service_idrtopology_versionerrorhasattr isinstancerfdict _is_stale_error_topology_version)rrrdrcur_tvrmerror_tvs rC_is_stale_errorzTopology._is_stale_error2s""7++ >4 < ( ()@'BT U U 4#4   @WUI.. @%-.. @ =,,->??/AAArXcK|||rdS|j|}|j}|j}|jjr |s |jsdSt|tr |jrdSt|trdSt|ttfr8t|dr|j }n4t|trdnd}|jd|}|t jvr|t jv}|jjs*|t)||d{V|s |jdkr||d{V|dS|jsS|jjs*|t)||d{V||d{VdSdSt|t0rt|t2rdS|jjs*|t)||d{V||d{V|jdSdS)Ncodei{'rm)rtrrmrkrnrcompleted_handshakerorrrrrnrvrfrr _NOT_PRIMARY_CODES_SHUTDOWN_CODESr r(max_wire_versionr request_checkrrrI cancel_check) rrrdrrmrkerr_codedefaultis_shutting_downs rC _handle_errorzTopology._handle_errorFs    1 1  Fw' ' > '   7C^  F e^ , ,3 +1L3 + F z * *- + F 1AB C C* +uf%% > :$.e_#E#EO%%4 =,,VW==><<<#+~/M#M ~3X../@PU/V/V/VWWWWWWWWW#3(@A(E(E ,,z222222222$$&&&&&0 /~3X../@PU/V/V/VWWWWWWWWWll:...........  / / 0 1 1 +%!677 >/ T**+m**,, # #F  " " " " # #rXc K|jD])\}}||jvr|j|||||j}d}|jr |jtj |j}t|| |||j |j|}||j|<|d{V|j|jj}||j|_||jkr0|j|j|jd{V+t)|jD]y\}}|j|sZ|d{Vt.s|j|j|j|zdS)zrSync our Servers from TopologyDescription.server_descriptions. Hold the lock while calling this. )rtopologyrrGN)rrmonitor topology_id listenersevents)rrr{rJrrn monitor_class_create_pool_for_monitorrbrerrr_create_pool_for_serverr]r`rr is_writablerupdate_is_writablerzr rrrrrIpop)rrrrrVr was_writables rCrzTopology._update_serverss  ,@@BBHHJJ Y YKGRdm++.66')!66w??&*n 7'5DL,D";t|44D')55g>># $ 1"o *0 g&kkmm######## $}W5AM 57 g&22>11-05HHXXXXXXXXX#DM$7$7$9$9:: + +OGV$//88 +llnn$$$$$$$@'..v??? !!'***  + +rXrcZ|j||jj|jS)N) client_id)rn pool_class pool_optionsr]rs rCrz Topology._create_pool_for_servers0~(( T^0D) ~(( )44CT)   rXc|jjtjtjfv}|rd}n|jjtjkrd}nd}|jjr|tur |rdSd|zSd|d|dSt|j }t|j }|s'|r d ||j j Sd |zS|d jtfd |d dD}|rDd|zS|r,t!||jsd|zSt'Sdd|DS)zeFormat an error message if server selection fails. Hold the lock when calling this. zreplica set membersmongosesrzNo primary available for writeszNo %s available for writeszNo z match selector ""z)No {} available for replica set name "{}"zNo %s availablerc3.K|]}|jkVdSrUrw)rrrms rC z*Topology._error_message..s*GGv|u,GGGGGGrXrQNzNo %s found yetz\Could not reach any servers in %s. Replica set is configured with internal hostnames or IPs?,c3LK|]}|j t|jV dSrU)rmr)rrs rCrz*Topology._error_message..s3XXf6<XFL 1 1XXXXXXrX)rrrr/rr!Shardedr;r-rzr{rformatrnrqrmallr" intersectionr|rrO)rris_replica_set server_plural addressesrsamerms @rCrzTopology._error_messages *8  /  -=    &1MM   , 0E E E&MM%M   *' Y333!H<<7-GGH]HHXHHHHT.BBDDEEI4,@@BBIIKKLLG =!=FMM%7 -}<<AJ$EGGGG7122;GGGGGD Y=,}<<!#i..*E*EdFZ*[*[FHQR 5zz!xxXXXXXXXXrXcKg} |jr3||j|j3n#t$rYnwxYwt jd|Dddid{VdS)Nc6g|]}|Sr)rO)rts rCrz-Topology.cleanup_monitors.. s 777Aqvvxx777rXreturn_exceptionsT)rrr IndexErrorasynciogather)rtaskss rCrzTopology.cleanup_monitorss % 8 T04466777% 8    D n77777P4PPPPPPPPPPPs:A A AcLd}|jsd}d|jjd||jdS)NzCLOSED < >)r} __class____name__rr)rmsgs rC__repr__zTopology.__repr__"s<| CH4>*HHSH$2CHHHHrX>tuple[tuple[_Address, ...], Optional[str], Optional[str], str]cx|j}tt|j|j|j|jfS)zDThe properties to use for AsyncMongoClient/Topology equality checks.)rntuplesortedrwrqrsrv_service_name)rtss rCeq_propszTopology.eq_props(s2 ^fRX&&'').ds$WWW66AV3V3V3V3V3VrXr)rrfiltereds ` rCrr]s9 !WWWWZWWWH  !z!rX)r7r8r9r:)rr/rsr/r9r:)rr(rr(r9r:rU)rrrrr9r)\r __future__rrrirr=rrrrrpathlibrtypingrrrrr r pymongor r r r#pymongo.asynchronous.client_sessionrrpymongo.asynchronous.monitorrrpymongo.asynchronous.poolrpymongo.asynchronous.serverrpymongo.errorsrrrrrrrrr pymongo.hellor pymongo.lockrr r!pymongo.loggerr"r#r$r%r&pymongo.pool_optionsr'pymongo.server_descriptionr(pymongo.server_selectorsr)r*r+r,r-pymongo.topology_descriptionr.r/r0r1r2bsonr3pymongo.asynchronous.settingsr4pymongo.typingsr5r6rr__file__parentrrDrFrBrqrrrrXrCrsCB"""""" HHHHHHHHHHHHHHHHDDDDDDDDDDDDRRRRRRRR@@@@@@@@******......                        -,,,,,8888886>>>>>>55555555 s44>>()) "K%K%K%K%K%K%K%K%\%%%%%%%%$88885555OS " " " " " " "rX