ixLUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZmZddlmZddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd l m!Z!erdd l"m#Z#m$Z$edZ%dZ&dZ'e(eddZ)e j*dko ej+ej,vZ-eZ.de/d<e j0a1da2da3edGddZ4eGddZ5edGddZ6eGddZ7Gd d!e8Z9Gd"d#e9$Z:Gd%d&e j;ZdEd5Z?dd'dFd:Z@dd'dGd;ZAdd'dGd<ZBdHd>ZCdId?ZDdJd@ZEdJdAZFdJdBZGd#gZHdS)KzZCross-process and cross-host reader/writer lock built on :class:`SoftFileLock` primitives.) annotationsN)contextmanagersuppress) dataclass)Path) TYPE_CHECKINGLiteral)WeakValueDictionary)AcquireReturnProxy)Timeout) SoftFileLock)ensure_directory_exists)Callable Generator)readwritez.breaki O_NOFOLLOWwin32,WeakValueDictionary[Path, SoftReadWriteLock]_all_instancesFT)frozenc.eZdZUded<ded<ded<dS)_PathsstrstaterreadersN__name__ __module__ __qualname____annotations__X/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/filelock/_soft_rw/_sync.pyrr-s+JJJJJJLLLLLr#rc.eZdZUded<ded<ded<dS)_Locksthreading.Lockinternal transactionr rNrr"r#r$r&r&4s6r#r&c.eZdZUded<ded<ded<dS) _MarkerInfortokenintpidhostnameNrr"r#r$r+r+;s+JJJ HHHMMMMMr#r+cdeZdZUdZded<ded<ded<ded <d ed <ded <d ed<ded<dS)_HoldzYEverything that exists only while a lock is held; ``None`` when the instance has no lock.r-level_Modemode int | Nonewrite_thread_idr marker_namebool is_readerr,_HeartbeatThreadheartbeat_threadthreading.Eventheartbeat_stopN)rrr __doc__r!r"r#r$r1r1BslccJJJKKKOOOJJJ&&&&######r#r1cHeZdZUded<ded< dddddd d dfdZxZS) _SoftRWMetar _instancesr'_instances_lockT>@N?blocking is_singletonheartbeat_intervalstale_threshold poll_interval lock_filestr | os.PathLike[str]timeoutfloatrGr8rHrIrJ float | NonerKreturnSoftReadWriteLockc |s(t|||||||St|}|j5|j|} | 3t|||||||} | |j|<n=| j|ks | j|kr'd| jd| jd|d|} t| | cdddS#1swxYwYdS)NrFz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__rresolverBrAgetrNrG ValueError) clsrLrNrGrHrIrJrK normalizedinstancemsg __class__s r$rUz_SoftRWMeta.__call__Ts 77##!)#5 /+$ )__,,..    ~))*55H 77++%!-'9$3"/,.6z**!W,,0AX0M0MT8;KTTX`XiTT5<TTIQTT!oo%'                  sBC//C36C3rC)rLrMrNrOrGr8rHr8rIrOrJrPrKrOrQrR)rrr r!rU __classcell__r]s@r$r@r@Ps|<<<<#### * !$((,#************r#r@cZeZdZUdZeZded<ejZ d;dddddd ddZ e d=ddd>dZ d=ddd?dZd=ddd?dZd@d Zd!d"dAd$Ze d;dddBd%ZdCd(ZdDd)ZdEd.ZdEd/ZdFd2Zd@d3ZdGd4ZdHd6ZdId8ZdGd9Zd@d:ZdS)JrRu Cross-process and cross-host reader/writer lock built on :class:`SoftFileLock` primitives. Use this class instead of :class:`~filelock.ReadWriteLock` when the lock file lives on a network filesystem (NFS, Lustre with ``-o flock``, HPC cluster shared storage). ``ReadWriteLock`` is backed by SQLite and cannot run on NFS because SQLite's ``fcntl`` locking is unreliable there. Layout on disk for a lock at ``foo.lock``: - ``foo.lock.state`` — a :class:`SoftFileLock` taken only during state transitions (microseconds). - ``foo.lock.write`` — writer marker; its presence means a writer is claiming or holding the lock. - ``foo.lock.readers/..`` — one file per reader. Each marker stores a random token (``secrets.token_hex(16)``), the holder's pid, and the holder's hostname. A daemon heartbeat thread refreshes ``mtime`` on every held marker. A marker whose mtime has not advanced in ``stale_threshold`` seconds may be evicted by any process on any host, giving correct behavior when a compute node crashes with a lock held. Writer acquire is two-phase and writer-preferring: phase 1 claims ``.write`` (blocking any new reader), phase 2 waits for existing readers to drain. Writer starvation is impossible. Reentrancy, upgrade/downgrade rules, thread pinning, and singleton caching by resolved path match :class:`~filelock.ReadWriteLock`. Forking while holding a lock invalidates the inherited instance in the child so the child cannot double-own the lock with its parent; ``release()`` on a fork-invalidated instance is a no-op, and the child must re-acquire if it needs a lock. Trust boundary: protects against same-UID non-cooperating processes (one host or cross-host) and same-host different-UID users via ``0o600`` / ``0o700`` permissions. Does not protect against root compromise, NTP tampering on same-UID cross-host nodes, or multi-tenant mounts where hostile co-tenants share the UID. :param lock_file: path to the lock file; sidecar state/write/readers live next to it :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately on contention :param is_singleton: if ``True``, reuse existing instances for the same resolved path :param heartbeat_interval: seconds between heartbeat refreshes; default 30 s :param stale_threshold: seconds of ``mtime`` inactivity before a marker is stale; defaults to ``3 * heartbeat_interval``, matching etcd's ``LeaseKeepAlive`` convention :param poll_interval: seconds between acquire retries under contention; default 0.25 s .. versionadded:: 3.27.0 rrArCTrDNrErFrLrMrNrOrGr8rHrIrJrPrKrQNonecJ|dkrd|}t|||dz}||krd|d|d}t||dkrd|}t|tj||_||_||_||_||_||_t|jd|jd |jd  |_ t|jttjtjt|j jd |_d|_d|_d|_d|_t,5|t.t1|j<t5ddddS#1swxYwYdS)Nrz)heartbeat_interval must be positive, got z0stale_threshold must exceed heartbeat_interval (z <= )z$poll_interval must be positive, got z.statez.writez.readers)rrrrCrNr(r)rF)rXosfspathrLrNrGrIrJrKr_pathsrr& threadingLockr r_locks_readers_dir_fd_hold_fork_invalidated_closed_all_instances_lockrrrV_register_hooks) selfrLrNrGrHrIrJrKr\s r$__init__zSoftReadWriteLock.__init__s  " "R>PRRCS// !  "014O 0 0 0o_ooZloooCS// ! A  HHHCS// ! i 22% & );&5$1^+++^+++~///    ///^%%!((t{0"===    ,0#' ',"   =AN4//7799 :                      s=FFFrG bool | NoneGenerator[None]c#K||| dV|dS#|wxYw)a Context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds rvN) acquire_readreleasertrNrGs r$ read_lockzSoftReadWriteLock.read_locksR 'H555  EEE LLNNNNNDLLNNNN 5A c#K||| dV|dS#|wxYw)a@ Context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds rvN) acquire_writer{r|s r$ write_lockzSoftReadWriteLock.write_locksR 7X666  EEE LLNNNNNDLLNNNNr~r c2|d||S)uf Acquire a shared read lock. If this instance already holds a read lock, the lock level is incremented (reentrant). Attempting to acquire a read lock while holding a write lock raises :class:`RuntimeError` (downgrade not allowed). On the 0→1 transition a daemon heartbeat thread is started that refreshes the reader marker's ``mtime`` every ``heartbeat_interval`` seconds so peers on other hosts do not evict the marker as stale. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable; ``None`` uses the instance default :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance, if this instance was invalidated by :func:`os.fork`, or if :meth:`close` was called :raises Timeout: if the lock cannot be acquired within *timeout* seconds rrv_acquirer|s r$rzzSoftReadWriteLock.acquire_read s*}}VWx}@@@r#c2|d||S)a Acquire an exclusive write lock. If this instance already holds a write lock from the same thread, the lock level is incremented (reentrant). Attempting to acquire a write lock while holding a read lock raises :class:`RuntimeError` (upgrade not allowed). Write locks are pinned to the acquiring thread: a different thread trying to re-enter also raises :class:`RuntimeError`. Writer acquisition runs in two phases. Phase 1 atomically claims ``.write`` via ``O_CREAT | O_EXCL``, which immediately blocks any new reader on any host. Phase 2 waits for existing readers to drain. Writer starvation is impossible: new readers see ``.write`` during phase 2 and wait behind the pending writer. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable; ``None`` uses the instance default :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a read lock is already held, if a write lock is held by a different thread, if this instance was invalidated by :func:`os.fork`, or if :meth:`close` was called :raises Timeout: if the lock cannot be acquired within *timeout* seconds rrvrr|s r$rzSoftReadWriteLock.acquire_write$s2}}Wg}AAAr#cZ|d|jj5|jr ddddSd|_|jLt t 5tj|jdddn #1swxYwYd|_ddddS#1swxYwYdS)u Release any held lock and release internal filesystem resources. Idempotent. After calling this method the instance can no longer acquire locks — subsequent acquires raise :class:`RuntimeError`. A fork-invalidated instance is closed without raising. TforceN) r{rmr(rqrnrOSErrorrhcloserts r$rzSoftReadWriteLock.close?sL 4    [ ! , ,|  , , , , , , , , DL#/g&&33HT1222333333333333333'+$ , , , , , , , , , , , , , , , , , ,s: B "B B5 B B B B B  B$'B$Frrch|jj5|jrd|_ ddddS|j}|:|r ddddSd|jdt |d}t ||rd|_n|xjdzc_|jdkr ddddSd|_dddn #1swxYwY|j |j |j dz|j rt|j|j dSt|jdS) a8 Release one level of the current lock. When the lock level reaches zero the heartbeat thread is stopped and the held marker file is unlinked. On a fork-invalidated instance (that is, the child of a :func:`os.fork` call made while the parent held a lock) this method is a no-op so inherited ``with`` blocks can unwind cleanly in the child. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` NzCannot release a lock on (lock id: z) that is not heldrg?rfdir_fd)rmr(rprorLid RuntimeErrorr2r=setr;joinrIr9_unlinkr7rn)rtrholdr\s r$r{zSoftReadWriteLock.releasePs[ !  % !           :D|        j$.iiRPTXXiii"3'''   a zA~~!        "DJ#               , !!! ""4+BS+H"III > & D$T-A B B B B B B D$ % % % % %s#B3 B3AB3 B33B7:B7c||||S)a Return the singleton :class:`SoftReadWriteLock` for *lock_file*. :param lock_file: path to the lock file; sidecar state/write/readers live next to it :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: the singleton lock instance :raises ValueError: if an instance already exists for this path with different *timeout* or *blocking* values rvr")rYrLrNrGs r$get_lockzSoftReadWriteLock.get_lockzs(s9g9999r#r4r3c ||jn|}||jn|}|jj5|jrd|jd}t ||jrd|jd}t ||j!| |cdddS dddn #1swxYwYtj }|s!|jj d}nH|dkr!|jj d}n!|jj d|}|st|jd |jj5|j?| |cddd|jj S dddn #1swxYwY|dkrdn||z} t!jd } |d kr|| | | \} } n|| | | \} } t)j} t-|j|j| d t3|d }|jj5t5d||d krt)jnd| | | || |_dddn #1swxYwY|t;||jj S#|jj wxYw)NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrvrCT)rGrNrdeadlinerGzfilelock-heartbeat-x)refreshinterval stop_eventnamer)r2r4r6r7r9r,r;r=lock)rNrGrmr(rprLrrqro_validate_reentranttime perf_counterr)acquirer r{secrets token_hex_acquire_writer_slot_acquire_reader_slotrkEventr:_refresh_markerrIrr1 get_identstartr )rtr4rNrGeffective_timeouteffective_blockingr\racquiredrr,r7r9r heartbeats r$rzSoftReadWriteLock._acquiresF-4ODLL.6.>T]]H [ ! 6 6% (rdnrrr"3'''| (NdnNNN"3'''z%//55 6 6 6 6 6 6 6 6& 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6!##! a{.666FFHH " $ ${.666EEHH{.66N_6``H 4$.))t 3' .% : ::)33D99 : : : : : : :L K # + + - - - -K* : : : : : : : : : : : : : : : 1B66ttEDU.try_claim_writers:" ! !#DK$5tG[aeajalalmmmm 122!  ! ! ! ! ! ! ! !!)$+*;UCCCC&!!!  ! ! ! ! ! ! ! ! !D  ! ! ! ! ! ! ! ! ! ! ! ! ! ! !4s6A B-)BB- BB-BB--B14B1cPjj5tt5t jjdddn #1swxYwYtj cdddS#1swxYwYdSN) rmrrr_touchrjr_break_stale_readersr _any_readersrsr$readers_drained_touchingzHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchings" / /g&&..4;,---...............))$)++666,,...  / / / / / / / / / / / / / / / / / /s3BA  B A BA =BB"BrFrQr8)_open_readers_dir _wait_forr rrjr)rtr,rrGrrs`` r$rz&SoftReadWriteLock._acquire_writer_slots            / / / / / / '(XNNN  NN3hQYN Z Z Z Z    DK% & & &  { %''s A%A;cDtjjdt jjttj j z dfd } |||ndfS)N.rQr8cPjj5tjjjt jtjjr ddddStnt ddddS#1swxYwYdS)NrFrT) rmrrrjrrJrrr)rfull_reader_path reader_namertr,sr$try_claim_readerz@SoftReadWriteLock._acquire_reader_slot..try_claim_readers "  #DK$5tG[aeajalalmmmm 122!         %)+uVLLLLL)*:EBBB                  sA B(&BB"BrTr) ruuiduuid4hexrhgetpidrnrrrjrr)rtr,rrGrrrrs`` @@@r$rz&SoftReadWriteLock._acquire_reader_slots    )99BIKK99 %tDK$788;FGG           '(XNNN%1 7G$NNr# predicateCallable[[], bool]c$ |rdStj}|st|j|||krt|j|j}|!t |t ||z d}tj|)NTg)rrr rLrKminmaxsleep)rtrrrGr sleep_fors r$rzSoftReadWriteLock._wait_for,s "y{{ #%%C .dn---#xdn---*I# 3x#~s+C+CDD Jy ! ! ! "r#cZt|jj}tt5|ddddn #1swxYwYt j|jj}tj |j stj |j s|jjd}t||j XtrSt jt!t ddzt"z}t j|jj||_ dSdSdS)Ni)r4zB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORYr)rrjrrrmkdirrhlstatstatS_ISLNKst_modeS_ISDIRrrn_SUPPORTS_DIR_FDO_RDONLYgetattr _O_NOFOLLOWopen)rt readers_pathstr\flagss r$rz#SoftReadWriteLock._open_readers_dir@sEDK/00 o & & + +   E  * * * + + + + + + + + + + + + + + +Xdk) * * < # # $4< +C+C $[(lllCs## #   ',< 'K'"mQ"?"??+ME#%74;+>#F#FD  ( ' ' 'sAAAc8|D]}dSdS)NTF)_iter_reader_entries)rt_s r$rzSoftReadWriteLock._any_readersNs)**,,  A44ur#Generator[tuple[str, bool]]c#K|jXtj|j5}|D]!}t|js |jdfV" dddn #1swxYwYdSt |jj}tj|5}|D]1}t|jst||jz dfV2 ddddS#1swxYwYdS)a# Yield ``(name, dirfd_relative)`` pairs for every live reader marker. ``dirfd_relative`` is ``True`` when *name* should be passed to ``dir_fd=``-aware syscalls; ``False`` when *name* is a full path because dirfd-relative I/O is unavailable on this platform. NTF) rnrhscandir_is_housekeeping_namerrrjrr)rtitentryrs r$rz&SoftReadWriteLock._iter_reader_entriesSs   +D011 /R//E0<</#j$..../ / / / / / / / / / / / / / / / FDK/00 Z % % @ @ @,UZ88@lUZ788%???? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @s#%AAA5CCCrcg} |D]%\}}|||r|jndf&n#t$rYdSwxYw|D]\}}t ||j||dS)N)rJrr)rappendrnrrrJ)rtrnamesrdirfd_relativefds r$rz&SoftReadWriteLock._break_stale_readersfs.0 (,(A(A(C(C W W$n dN$TD$8$8PTUVVVV W    FF  ` `HD" d6JPS\^ _ _ _ _ _ ` `s:? A  A cp|jj5|j}| ddddS|j}|j}|jr|jnd}dddn #1swxYwYt||}|dS|\}}|tj |j|sdS t||n#t$rYdSwxYwdS)NFrT) rmr(ror7r,r9rn _read_markerhmaccompare_digestrFileNotFoundError)rtrr7r,r read_resultinfo_mtimes r$rz!SoftReadWriteLock._refresh_markerps` [ ! F F:D| F F F F F F F F*KJE-1^ET))F  F F F F F F F F F F F F F F F#;v>>>  5" f r rAr!rkrlrBrurr}rrzrrr{ classmethodrrrrrrrrrrrrr"r#r$rRrRs,,\@S?R?T?TJTTTT$in&&O 0 !$((,#000000dQU^&RV^&ATXAAAAAA.BUYBBBBBB6,,,,"(-(&(&(&(&(&(&T:  :::::[:*D.D.D.D.L----(&(&(&(&(POOOO4""""( G G G G @@@@&````. & & & & & &r#rR) metaclassc(eZdZd fd Zdd ZxZS)r:rrrrOrr<rrrQrbcxt|d||_||_||_dS)NT)rdaemon)rTru_refresh _interval _stop_event)rtrrrrr]s r$ruz_HeartbeatThread.__init__s> d4000 !%r#c|j|jsP|s|jdS|j|jNdSdSr)rwaitr r rrs r$runz_HeartbeatThread.runsx"''77 ==??  $$&&&"''77     r#) rrrrOrr<rrrQrbr)rrr rurr_r`s@r$r:r:sQ & & & & & &r#r:rrrr,rr5rQrbctjtjztjztz}t r|tj||d|}ntj||d} |dtjdtj d d}tj ||tj |dS#tj |wxYw)Nir ascii) rhO_CREATO_EXCLO_WRONLYrrrrsocket gethostnameencoderr)rr,rrrcontents r$rrs J "R[ 0; >E)F. WT5% 7 7 7 WT5% ( (EEbikkEEV-?-A-AEEELLWUU W   s (ACC)'tuple[_MarkerInfo | None, float] | Nonectjtz} tr|tj|||ntj||}n#t $rYdSwxYw tj|}tj|tdz}n%#t $rYtj |dSwxYw tj |n#tj |wxYwt||j fS)Nrr) rhrrrrrfstatr_MAX_MARKER_SIZEr_parse_marker_bytesst_mtime)rrrrrdatas r$rrs  K+ %E4D uI[RWT5 0 0 0 0acahimotauau tt "B72/!344DD          t $ $bk 11s;5A AA1BC  B3C 2B33C C"r"bytes_MarkerInfo | NonecJ|rt|tkrdS |d}n#t$rYdSwxYwt jd|tj}|dSt|dd}|dkrdSt|d||dS) Nru \A # start of string (?P [0-9a-f]{32} ) \n # 128-bit hex token (?P [1-9][0-9]{0,9} ) \n # decimal pid: no leading zero, ≤ 10 digits (?P [\x21-\x7e]{1,253}) # printable non-whitespace ASCII (RFC 1123 hostname limit) \n* # tolerate sloppy writers that append extra newlines \Z # end of string r. ir,r/)r,r.r/) lenrdecodeUnicodeDecodeErrorrematchVERBOSEr-r+)r"textr+r.s r$r r s 3t99///t{{7## tt H     E }t eElB  C Yt U7^uZ?P Q Q QQs4 AArJrOrr8cbt||}|dS|\}}||z |krdS|t||dS|tdtjdt jd} tr|tj||||n"t||n#t$rYdSwxYwt||}|dS|\} } | t||dStj |j | j sdS| |krdSt||dS)NrFTrr) src_dir_fd dst_dir_fd)rr _BREAK_SUFFIXrhrrrrrenamerrrrr,) rrJrrr info_before mtime_before break_name read_after info_after mtime_afters r$rrstF333Ku +K \_,,uV$$$$tO-OO")++OO8I"8M8MOOJ  * 2 IdJ6f M M M M M JJ  j ) ) ) uuj888Ju(J  6****t  {0*2B C Cu\!!u Jv&&&& 4s0AB55 CCctt5tr|tj||n!t |ddddS#1swxYwYdSNr)rrrrhunlinkrrrs r$rrs # $ $    2 Id6 * * * * * JJ                        sAA$$A(+A(cttr|tj|d|dStj|ddSr:)rrhutimer<s r$rrsDF. tF++++++ tr#pathc tj|}n#t$rYdSwxYwtj|jS)NF)rhrrrS_ISREGr)r?rs r$rr&sJ Xd^^ uu < # ##s  %%c>|dpt|vS)Nr) startswithr1)rs r$rr.s ??3   8=D#88r#ctjattD]}|dSr)rkrlrrlistrvaluesrr[s r$_reset_all_after_forkrH2sT $.**..0011..++----..r#cttD]D}tt5|ddddn #1swxYwYEdS)NTr)rErrFr Exceptionr{rGs r$_cleanup_all_instancesrK<s..0011)) i  ) )   4  ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )))sA  A$ 'A$ ctstjtdats3t t dr t jtdadSdSdS)NTregister_at_fork)after_in_child) _atexit_registeredatexitregisterrK_fork_registeredhasattrrhrMrHr"r#r$rsrsBsp ".///!  ,> ? ?  +@AAAA    r#)rrr,rrr5rQrb)rrrr5rQr)r"r#rQr$) rrrJrOrrOrr5rQr8)rrrr5rQrb)r?rrQr8)rrrQr8r)Ir> __future__rrPrrhr*rrrsysrkrr contextlibrr dataclassesrpathlibrtypingrr weakrefr filelock._apir filelock._errorr filelock._softr filelock._utilrcollections.abcrrr3r1rrrplatformrsupports_dir_fdrrr!rlrrrOrRrr&r+r1typer@rRThreadr:rrr rrrrrrHrKrs__all__r"r#r$res```""""""   ////////!!!!!!))))))))'''''',,,,,,######''''''222222433333333   gb,** <7*Lrw":L/L?R?R?T?TTTTT$in&& $     $   $ $ $ $ $ $ $  $.....$...bQ&Q&Q&Q&Q&+Q&Q&Q&Q&hy'(JN      59222222&RRRRF ******Z04      /3$$$$9999....))))      r#