IR-emddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZddlmZmZd Zd Zdd Zd Zd ZdZdZdS)N)suppress)urlparse)log) _find_home)get_readable_fileobj) SAMPHubError SAMPWarningci}t|5}|D]X}|dsA|d\}}|||<Y dddn #1swxYwY|S)zK Read in the lockfile given by ``lockfilename`` into a dictionary. #=N)r startswithsplitstrip) lockfilename lockfiledictflinekwvals =lib/python3.11/site-packages/astropy/samp/lockfile_helpers.py read_lockfilers L l + +7q 7 7D??3'' 7**S//C+.99;; RXXZZ( 7777777777777777 sAA;;A?A?ct|d}|tj|tjtjzt|d}tj }| d|d| d| D] \}}| |d|d!|dS)Nwz# SAMP lockfile written on  z!# Standard Profile required keys r ) opencloseoschmodstatS_IREADS_IWRITEdatetimenow isoformatwriteitems)rrlockfilenow_isokeyvalues rwrite_lockfiler,%sL#&&H NNH\4<$-7888L#&&H##%%//11G NN<<<<=== NN7888"((**++ U#)))))**** NNctd}dtjvrtjddrytjdt dd}t |}|ddkr/t jd|tdS|d}nP|9tj d |z|d kr.tj td }ntj td } tj|n#t $rYnwxYwtj|t$jt$jzt$jzn>#tj|t$jt$jzt$jzwxYwtj |d |}ntj dt-|\}}|rt jdtdStj d|zt/|||S)NSAMP_HUB std-lockurl:rfilezAUnable to start a Hub with lockfile {}. Start-up process aborted.FzRunning mode: single.samp.samp-1z samp-hub-zRunning mode: multiplez>Another SAMP Hub is already running. Start-up process aborted.z Lock-file: )remove_garbage_lock_filesrenvironrlenrwarningswarnformatr rdebugpathjoinrmkdirOSErrorrr r!r"S_IEXECcheck_running_hubr,)rmodehub_id hub_params lockfiledirlockfile_parsedhub_is_runningrs rcreate_lock_filerJ3s4KRZ :j ! , ,^ < < 2:j1#n2E2E2G2GHL&|44Oq!V++ 006|0D0D u.q1    I&- . . .x!w||JLL'BB  gll:<<CC WH[))))DH[$,*F*UVVVVBH[$,*F*UVVVV!w||K9MV9M9MNN  I. / / /#4\#B#B NL L    uIml*+++<,,, s*:EF EFEF;Gc|t}|stddtjvr\tjddr(tjdt dd}n;tdtjtd}||S)z Get either the hub given by the environment variable SAMP_HUB, or the one given by the lockfile .samp in the user home directory. z"Unable to find a running SAMP Hub.r0r1NzSAMP Hub profile not supported.r5) get_running_hubsr rr8rr9r>r?r)hubsrs rget_main_running_hubrNps   D A?@@@RZ :j ! , ,^ < < B:j1#n2E2E2G2GHLL@AA Aw||JLL'::  r-ci}d}dtjvrMtjddr'tjdtdd}n,tjt d}t|\}}|r|||<d}tjt d}tj|retj |D]P}|dr9tj||}t|\}}|r|||<Q|S)a Return a dictionary containing the lock-file contents of all the currently running hubs (single and/or multiple mode). The dictionary format is: ``{: {: , ...}, ...}`` where ``{}`` is the lock-file name, ``{}`` and ``{}`` are the lock-file tokens (name and content). Returns ------- running_hubs : dict Lock-file contents of all the currently running hubs. r/r0r1Nr5r6samp-hub) rr8rr9r>r?rrCisdirlistdir)rMrrIrrGfilenames rrLrLs<" DL RZ :j ! , ,^ < < I:j1#n2E2E2G2GHLw||JLL':: #4\#B#B NL*)\K',,z||Y77K w}}[!!6 ;// 6 6H"":.. 6!w||KBB /@/N/N, !6)5D& Kr-cLd}i} t|}n#t$r||fcYSwxYwd|vrt tj|dddd}|jjd}n"#tj$rd}Ynt$rYnwxYw||fS)a| Test whether a hub identified by ``lockfilename`` is running or not. Parameters ---------- lockfilename : str Lock-file name (path + file name) of the Hub to be tested. Returns ------- is_running : bool Whether the hub is running hub_params : dict If the hub is running this contains the parameters from the lockfile Fzsamp.hub.xmlrpc.url\r/r) allow_noneT) rrAxmlrpc ServerProxyreplacesamphubping ProtocolError)r is_runningrproxys rrCrCs JL($\22 (((<''''( ,, &23;;D"EERSE JN   ! ! !JJ#   JJJ    D  | ##s$''ABB BBc`d}tjtd}t |\}}|s_tj|r@t t5tj|dddn #1swxYwYtjtd}tj |rtj |D]}| drtj||}t |\}}|s_tj|r@t t5tj|dddn #1swxYwYdSdS)Nr/r5r6rP) rr>r?rrCisfilerrAremoverQrRr)rrIrrGrSs rr7r7sL7<< g66L#4\#B#B NL ( 7>>, ' ' ('"" ( ( ,''' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ',,z||Y77K w}}[!! 4 ;// 4 4H"":.. 4!w||KBB /@/N/N, %4w~~l334%g..44Il333444444444444444 4 4 4 4s$6BBB?F  F$ 'F$ )NNNN)r#rr r: xmlrpc.clientclientrW contextlibr urllib.parserastropyrastropy.config.pathsrastropy.utils.datarerrorsr r rr,rJrNrLrCr7r-rrls* !!!!!!++++++333333--------      ::::z.111h'$'$'$T44444r-