a ߙfb@sddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZddlmZmZd d Zd d Zdd dZddZddZddZddZdS)N)suppress)urlparse) _find_home)log)get_readable_fileobj) SAMPHubError SAMPWarningcCsbi}t|B}|D],}|ds|d\}}|||<qWdn1sT0Y|S)zK Read in the lockfile given by ``lockfilename`` into a dictionary. #=N)r startswithsplitstrip) lockfilename lockfiledictflinekwvalrAnother SAMP Hub is already running. Start-up process aborted.z Lock-file: )remove_garbage_lock_filesrenvironr lenrwarningswarnformatr rdebugpathjoinrmkdirOSErrorrrrr S_IEXECcheck_running_hubr&)rmodeZhub_idZ hub_params lockfiledirZlockfile_parsedhub_is_runningrrrrcreate_lock_file8sR         r>cCsft}|stddtjvrNtjddrDtjdtdd}q^tdntjtd}||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.r(r)NzSAMP Hub profile not supported.r,) get_running_hubsrrr/r r0r5r6r)hubsrrrrget_main_running_hubys  rAcCsi}d}dtjvr:tjddrJtjdtdd}ntjtd}t|\}}|rb|||<d}tjtd}tj|rt |D]4}|drtj||}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'r(r)Nr,r-samp-hub) rr/r r0r5r6rr:isdirlistdir)r@rr=rr<filenamerrrr?s&      r?cCsd}i}z t|}Wnty.||fYS0d|vrz.tj|ddddd}|jjd}Wn*tjy~d}Ynt j yYn0||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)Z allow_noneT) rr8xmlrpcZ ServerProxyreplaceZsampZhubZpingZ ProtocolErrorsocketerror)rZ is_runningrproxyrrrr:s(    r:c Csd}tjtd}t|\}}|sbtj|rbttt|Wdn1sX0Ytjtd}tj |rt |D]j}| drtj||}t|\}}|stj|rttt|Wdq1s0YqdS)Nr'r,r-rB) rr5r6rr:isfilerr8removerCrDr )rr=rr<rErrrr.s"   (     r.)NNNN)r!rrIrr1 contextlibrZ urllib.parserZ xmlrpc.clientZclientrGZastropy.config.pathsrZastropyrZastropy.utils.datarerrorsrr rr&r>rAr?r:r.rrrrs(       A5*