B îq\ðã@s¾ddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZddlmZmZd d „Zd d „Zdd d„Zdd„Zdd„Zdd„Zdd„ZdS)éN)Úsuppress)Úurlparse)Ú _find_home)Úlog)Úget_readable_fileobjé)Ú SAMPHubErrorÚ SAMPWarningc CsRi}t|ƒ<}x4|D],}| d¡s| d¡\}}| ¡|| ¡<qWWdQRX|S)zK Read in the lockfile given by ``lockfilename`` into a dictionary. ú#ú=N)rÚ startswithÚsplitÚstrip)Ú lockfilenameÚ lockfiledictÚfÚlineÚkwÚval©rúAnother SAMP Hub is already running. Start-up process aborted.z Lock-file: )Úremove_garbage_lock_filesrÚenvironr ÚlenrÚwarningsÚwarnr"r rÚdebugÚpathÚjoinrÚmkdirÚOSErrorrrrrÚS_IEXECÚcheck_running_hubr&)rÚmodeZhub_idZ hub_paramsÚ lockfiledirZlockfile_parsedÚhub_is_runningrrrrÚcreate_lock_file8sD        r:cCsftƒ}|stdƒ‚dtjkrNtjd d¡rDtjdtdƒd…}q^tdƒ‚ntj tƒd¡}||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(z std-lockurl:NzSAMP Hub profile not supported.z.samp) Úget_running_hubsrrr,r r-r1r2r)ÚhubsrrrrÚget_main_running_hubys  r=cCsÊi}d}dtjkr:tjd d¡rJtjdtdƒd…}ntj tƒd¡}t|ƒ\}}|rb|||<d}tj tƒd¡}tj |¡rÆxBt  |¡D]4}| d¡rŽtj ||¡}t|ƒ\}}|rŽ|||<qŽW|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(z std-lockurl:Nz.sampz.samp-1zsamp-hub) rr,r r-r1r2rr6ÚisdirÚlistdir)r<rr9rr8Úfilenamerrrr;s&      r;cCsœd}i}y t|ƒ}Wntk r,||fSXd|kr”y.tj|d dd¡dd}|jj ¡d}Wn.tjk r~d}Ynt j k r’YnX||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) rr4ÚxmlrpcZ ServerProxyÚreplaceZsampZhubZpingZ ProtocolErrorÚsocketÚerror)rZ is_runningrÚproxyrrrr6Ås"    r6c CsÔd}tj tƒd¡}t|ƒ\}}|sNtj |¡rNttƒt |¡WdQRXtj tƒd¡}tj  |¡rÐxdt  |¡D]V}|  d¡rvtj ||¡}t|ƒ\}}|svtj |¡rvttƒt |¡WdQRXqvWdS)Nr'z.sampz.samp-1zsamp-hub) rr1r2rr6Úisfilerr4Úremover>r?r )rr9rr8r@rrrr+ïs"        r+)NNNN)r rrDrr.Ú contextlibrZ urllib.parserZ xmlrpc.clientZclientrBZastropy.config.pathsrZastropyrZastropy.utils.datarÚerrorsrr rr&r:r=r;r6r+rrrrÚs&       @5*