a ƹDfk@spdZddgZddlZddlZddlZddlZddlZddlmZddl m Z Gddde Z Gddde ZdS) a This module contains the base class for popen pipes, and describes the popen pipe interface. The 'config' method can be overwritten for pipe customization. The pipe's 'launch' method can be overwritten with a derived pipe's new execution algorithm. See the following for an example of standard use. Usage ===== A typical call to a popen 'pipe' will roughly follow this example: >>> # instantiate the pipe >>> pipe = Pipe() >>> >>> # configure the pipe to stage the command >>> pipe(command='hostname') >>> >>> # execute the launch and retrieve the response >>> pipe.launch() >>> print(pipe.response()) Pipe PipeExceptionN)Selector)_strc@seZdZdZdS)rz)Exception for failure to launch a commandN)__name__ __module__ __qualname____doc__r r ^/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/pathos/connection.pyr,sc@sreZdZdZdZddlmZeddZ[ddd Zd d Z d d Z ddZ ddZ ddZ ddZddZe ZdS)rz9a popen-based pipe for parallel and distributed computingTr)logger)levelNc stj|dur*dfddtdDn||_|dd|_|dtj|_|d d |_ |d d |j|_ d|_ d |_ |j fi|dS)aOcreate a popen-pipe Inputs: name: a unique identifier (string) for the pipe command: a command to send [default = 'echo '] background: run in background [default = False] decode: ensure response is 'ascii' [default = True] stdin: file-like object to serve as standard input for the remote process Nc3s|]}tVqdSN)randomchoice.0iZxyzr r Cz Pipe.__init__.. backgroundFstdindecodeasciicommandecho %sr)string ascii_lettersjoinrangenamepoprsysrcodecmessage _response_pidconfig)selfr$kwdsr rr __init__8s z Pipe.__init__cCs d|jS)Nz Pipe('%s'))r(r,r r r __repr__Osz Pipe.__repr__c sjdurdj_jdur(tj_jdur8d_|D]F\}}|dkrX|_q@|dkrh|_q@|dkrx|_q@|dkr@|_q@d_gd}tfd d |DS) aXconfigure the pipe using given keywords (Re)configure the pipe for the following inputs: command: a command to send [default = 'echo '] background: run in background [default = False] decode: ensure response is 'ascii' [default = True] stdin: file-like object to serve as standard input for the remote process Nrrrrrr)r(rrr'c3s|]}|t|fVqdSr)getattrrr/r r rmrzPipe.config..) r(r$rr&r'itemsr_stdoutdict)r,r-keyvaluenamesr r/r r+Rs$    z Pipe.configcCsd|_|dS)zlaunch a configured commandN)r)_executer/r r r launchosz Pipe.launchcCsddlm}m}m}|jrdz||jd|j||dd}Wntd|jYn0|j|_ |j |_ nBz||jd|j|d}Wntd|jYn0|j |_ d|_ dS)Nr)PopenPIPESTDOUTT)shellrstdoutstderr close_fdszfailure to pipe: %s)r=rr>) subprocessr:r;r<rr(rrpidr*r>r3)r,r:r;r<pr r r r8us(   z Pipe._executecsjdurtdjdur"d}n&jdur2d}njdurBd}nj}jdur^tj|Sjdkrj_tj|Sfdd}d d }t}|j|| || d tj|S) zReturn the response from the launched process. Return None if no response was received yet from a background process. Nz.'launch' is required after any reconfigurationTrFrcs.jrtdjd|_d|_dS)Nzhandling pipe responseZ on_remoteF)verboseprint_debuginforeadr)state)selectorZfobjr/r r onDatas   zPipe.response..onDatacSs d|_dS)NF)rI)rJr r r onTimeoutsz Pipe.response..onTimeoutg@) r3rr'r)rr*rHrZnotifyOnReadReadyZnotifyWhenIdleZwatch)r,r'rKrLselr r/r responses"       z Pipe.responsecCs|jS)z get pipe pid)r*r/r r r rBszPipe.pidcCsF|jdkrB|jrtd|jt|jtjt|jdd|_dS)zterminate the piperz Kill pid=%dN)r*rDrEoskillsignalSIGTERMwaitpidr/r r r rPs  z Pipe.kill)N)rrrr rDZpathosr rFr.r0r+r9r8rNrBrP__call__r r r r r1s   & )r __all__rOr&rQrr Zpathos.selectorrZ pathos.utilr Exceptionrobjectrr r r r  s