U e»{joã@s¶ddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZddlmZmZd d „Zd d „Zdd d„Zdd„Zdd„Zdd„Zdd„ZdS)éN)Úsuppress)Úurlparse)Úlog)Ú _find_home)Úget_readable_fileobjé)Ú SAMPHubErrorÚ SAMPWarningc CsNi}t|ƒ8}|D],}| d¡s| d¡\}}| ¡|| ¡<qW5QRX|S)zK Read in the lockfile given by ``lockfilename`` into a dictionary. ú#ú=)rÚ startswithÚsplitÚstrip)Ú lockfilenameÚ lockfiledictÚfÚlineÚkwÚval©rú\/var/www/html/bwave/python/venv/lib/python3.8/site-packages/astropy/samp/lockfile_helpers.pyÚ read_lockfiles  rcCsŽt|dƒ}| ¡t |tjtj¡t|dƒ}tj ¡  ¡}|  d|›d¡|  d¡|  ¡D]\}}|  |›d|›d¡qb| ¡dS)NÚwz# SAMP lockfile written on Ú z!# Standard Profile required keys r ) ÚopenÚcloseÚosÚchmodÚstatÚS_IREADÚS_IWRITEÚdatetimeÚnowÚ isoformatÚwriteÚitems)rrZlockfileZnow_isoÚkeyÚvaluerrrÚwrite_lockfile%s   r(c CsTtƒd}dtjkrntjd d¡rltjdtdƒd…}t|ƒ}|ddkrdt d |¡t ¡dS|d}n¨|dkr t   d |¡|d kr tj   tƒd ¡}njtj   tƒd ¡}z(zt |¡Wntk rÔYnXW5t |tjtjtj¡Xtj   |d |›¡}n t   d¡t|ƒ\}}|r8t dt ¡dSt   d|¡t||ƒ|S)NÚÚSAMP_HUBú std-lockurl:rÚfilezAUnable to start a Hub with lockfile {}. Start-up process aborted.FézRunning mode: Zsingleú.sampú.samp-1z samp-hub-zRunning mode: multiplez>Another SAMP Hub is already running. Start-up process aborted.z Lock-file: )Úremove_garbage_lock_filesrÚenvironr ÚlenrÚwarningsÚwarnÚformatr rÚdebugÚpathÚjoinrrrrr ÚS_IEXECÚmkdirÚOSErrorÚcheck_running_hubr()rÚmodeZhub_idZ hub_paramsÚ lockfiledirZlockfile_parsedÚhub_is_runningrrrrÚcreate_lock_file3sJ  ÿý     þ 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*r+NzSAMP Hub profile not supported.r.) Úget_running_hubsrrr1r r2r7r8r)ÚhubsrrrrÚget_main_running_hubps  rCcCsÆi}d}dtjkr:tjd d¡rJtjdtdƒd…}ntj tƒd¡}t|ƒ\}}|rb|||<d}tj tƒd¡}tj |¡rÂt  |¡D]4}| d¡rŒtj ||¡}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) rr1r r2r7r8rr<ÚisdirÚlistdir)rBrr?rr>ÚfilenamerrrrA‡s&      rAcCsžd}i}z t|ƒ}Wntk r0||fYSXd|kr–z.tj|d dd¡dd}|jj ¡d}Wn,tjk r‚d}Yntk 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)Ú allow_noneT) rr;ÚxmlrpcÚ ServerProxyÚreplaceZsampZhubZpingÚ ProtocolError)rZ is_runningrÚproxyrrrr<¼s& ÿ r<c CsÐd}tj tƒd¡}t|ƒ\}}|sNtj |¡rNttƒt |¡W5QRXtj tƒd¡}tj  |¡rÌt  |¡D]V}|  d¡rttj ||¡}t|ƒ\}}|sttj |¡rtttƒt |¡W5QRXqtdS)Nr)r.r/rD) rr7r8rr<Úisfilerr;ÚremoverErFr )rr?rr>rGrrrr0çs"        r0)NNNN)r!rrr3Ú xmlrpc.clientÚclientrJÚ contextlibrÚ urllib.parserZastropyrZastropy.config.pathsrZastropy.utils.datarÚerrorsrr rr(r@rCrAr<r0rrrrÚs"       =5+