Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
doctorondemand
doctorondemand / supervisor python
Repository URL to install this package:
|
Version:
4.2.1 ▾
|
U
B]N ã @ sF d Z dZddlmZ ddlmZ ddlmZ zddlmZm Z m
Z
W n( e k
rl ddl mZm Z m
Z
Y nX zddlm Z W n e k
r ddl Z Y nX G dd d Z
G d
d d ZG d d
d
ZG dd dZG dd dZG dd dZeG dd deZG dd dZdGddZdHdd ZG d d d ZG d d d ZG d!d" d"ZG d#d$ d$eZG d%d& d&Z G d'd( d(Z G d)d* d*Z G d+d, d,Z G d-d. d.Z G d/d0 d0e Z!eG d1d2 d2eZ"G d3d4 d4e"Z#G d5d6 d6eZ$G d7d8 d8Z%G d9d: d:Z&G d;d< d<Z'G d=d> d>Z(d?d@ Z)dAdB Z*dCdD Z+dEdF Z,dS )Iiêp Dz%b %d %I:%M %pé )Útotal_ordering©ÚFault)Úas_bytes)ÚMockÚpatchÚsentinelNc @ s e Zd ZdZdZdZdZdZdZdd Z dd Z
dd Z d\d d Z d
d Z
dd Zdd Zdd Zdd Zdd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Z d-d. Z d/d0 Z d1d2 Z d]d3d4Z d5d6 Z!d7d8 Z"d9d: Z#d;d< Z$d=d> Z%d?d@ Z&dAdB Z'dCdD Z(dEdF Z)dGdH Z*dIdJ Z+dKdL Z,dMdN Z-dOdP Z.dQdR Z/dSdT Z0d^dVdWZ1dXdY Z2dZd[ Z3dS )_Ú DummyOptionsNé é c C sn d| _ d| _d| _| ¡ | _d| _d| _d| _d| _i | _ g | _
d| _ i | _ d| _
d| _d | _d| _d| _d| _d| _d| _d| _d | _d| _d| _d| _d | _d| _i | _ d | _ d | _ d | _ d | _ d | _!i | _"i | _#g | _$d | _%d| _&d | _'d | _(d | _)d| _*d| _+d | _,d | _-d
| _.d | _/g | _0g | _1d | _2d | _3g | _4g | _5g | _6d | _7d| _8d | _9d | _:t;| | _<d S )
NÚ
supervisorz/tmpéç é
z /tmp/logfileFé ©NNr z/foo/barÚ zhttp://localhost:9001)=Z
identifierZ childlogdirÚuidÚ getLoggerÚloggerZ backofflimitZlogfileZ nocleanupZ
strip_ansiZ
pidhistoryZprocess_group_configsZnodaemonÚ
socket_mapÚmoodZ
mustreopenÚ realizeargsÚfds_cleaned_upZ
rlimit_setÚ
setuid_calledÚhttpservers_openedÚ signals_setÚ
daemonizedZmake_logger_messagesÚautochildlogdir_clearedÚ
cleaned_upÚpidfile_writtenÚ directoryÚwaitpid_returnÚkillsÚ_signalÚparent_pipes_closedÚchild_pipes_closedÚforkpidÚpgrp_setÚdupedÚwrittenÚ
fds_closedÚ _exitcodeÚ
execve_calledÚ
execv_argsÚ
setuid_msgÚ privsdroppedÚ
logs_reopenedÚenvironment_processedÚ write_acceptÚ write_errorÚ
tempfile_nameÚ remove_errorÚremovedÚexistingÚ
openreturnÚ
readfd_resultÚparse_criticalsZparse_warningsÚ parse_infosÚ serverurlÚchanged_directoryÚ chdir_errorÚumasksetÚ DummyPollerZpoller©Úself© rC ú$./build/lib/supervisor/tests/base.pyÚ__init__ sv
zDummyOptions.__init__c O s t }t g|_||f|_|S ©N)Ú DummyLoggerZhandlersÚargs)rB rH Úkwr rC rC rD r ] s
zDummyOptions.getLoggerc K s || _ || _d S rF )r Z realizekw)rB rH rI rC rC rD Úrealizec s zDummyOptions.realizeTc C s d S rF rC )rB Zdo_usagerC rC rD Úprocess_configg s zDummyOptions.process_configc C s
d| _ d S ©NT)r rA rC rC rD Ú cleanup_fdsj s zDummyOptions.cleanup_fdsc C s d| _ | j d¡ d S )NTÚ rlimits_set)rN r; ÚappendrA rC rC rD Úset_rlimits_or_exitm s z DummyOptions.set_rlimits_or_exitc C s d| _ | j d¡ d S )NTr )r r: rO rA rC rC rD Úset_uid_or_exitq s z DummyOptions.set_uid_or_exitc C s
d| _ d S rL )r )rB Ú supervisordrC rC rD Úopenhttpserversu s z DummyOptions.openhttpserversc C s
d| _ d S rL )r rA rC rC rD Ú daemonizex s zDummyOptions.daemonizec C s
d| _ d S rL )r rA rC rC rD Ú
setsignals{ s zDummyOptions.setsignalsc C s | j S rF )r# rA rC rC rD Ú
get_signal~ s zDummyOptions.get_signalc C s | j S rF )r rA rC rC rD Úget_socket_map s zDummyOptions.get_socket_mapc C s d S rF rC rA rC rC rD Ú make_logger s zDummyOptions.make_loggerc C s
d| _ d S rL )r rA rC rC rD Úclear_autochildlogdir s z"DummyOptions.clear_autochildlogdirc G s | j S rF ©r4 )rB ZignoredrC rC rD Úget_autochildlog_name s z"DummyOptions.get_autochildlog_namec C s
d| _ d S rL )r rA rC rC rD Úcleanup s zDummyOptions.cleanupc C s
d| _ d S rL )r rA rC rC rD Ú
write_pidfile s zDummyOptions.write_pidfilec C s | j S rF )r! rA rC rC rD Úwaitpid s zDummyOptions.waitpidc C s | j rt| j || j|< d S rF )Ú
kill_errorÚOSErrorr" )rB ÚpidZsigrC rC rD Úkill s
zDummyOptions.killc C s dd l }| |¡S ©Nr )ÚosÚstat)rB Úfilenamerd rC rC rD re s zDummyOptions.statc C s
dddgS ©Nz/binz/usr/binz/usr/local/binrC rA rC rC rD Úget_path s zDummyOptions.get_pathc C s dd l }| ¡ S rc )rd Úgetpid)rB rd rC rC rD Úget_pid¢ s zDummyOptions.get_pidc C s |dkr ddl m} |dd S )Nz
/bad/filenamer )ÚNotFoundz bad filename)Zsupervisor.optionsrk )rB rf ÚargvÚstrk rC rC rD Úcheck_execv_args¦ s z DummyOptions.check_execv_argsc C sH | j rt| j ddddd}|r4d\|d< |d< nd \|d< |d< |S )
Né é r
é )Z child_stdinÚstdinÚstdoutZ child_stdout)é é ÚstderrZ child_stderrr )Úmake_pipes_errorr` )rB rv ÚpipesrC rC rD Ú
make_pipes« s
zDummyOptions.make_pipesc C sH | j rt| j | jr || j }| j |d¡}||7 }|| j|< t|S ©Nr )r3 r` r2 r) Ú
setdefaultÚlen)rB ÚfdÚcharsÚdatarC rC rD Úwriteµ s
zDummyOptions.writec C s | j rt| j | jS rF )Ú
fork_errorr` r& rA rC rC rD Úfork¿ s
zDummyOptions.forkc C s | j |¡ d S rF )r* rO ©rB r} rC rC rD Úclose_fdÄ s zDummyOptions.close_fdc C s
|| _ d S rF )r$ ©rB rx rC rC rD Úclose_parent_pipesÇ s z DummyOptions.close_parent_pipesc C s
|| _ d S rF )r% r
rC rC rD Úclose_child_pipesÊ s z DummyOptions.close_child_pipesc C s
d| _ d S rL )r' rA rC rC rD ÚsetpgrpÍ s zDummyOptions.setpgrpc C s || j |< d S rF )r( )rB ZfrmÚtorC rC rD Údup2Ð s zDummyOptions.dup2c C s
|| _ d S rF )r+ ©rB ÚcoderC rC rD Ú_exitÓ s zDummyOptions._exitc C s@ d| _ | jr,| jdkr"t| jn
t| j||f| _|| _d S )NTr )r, Ú execv_errorr` Ú RuntimeErrorr- Zexecv_environment)rB rf rl Ú environmentrC rC rD ÚexecveÖ s
zDummyOptions.execvec C s | j r | j S || _d S rF )r. r/ )rB r rC rC rD Údrop_privilegesà s z DummyOptions.drop_privilegesc C s | j S rF )r9 r rC rC rD Úreadfdå s zDummyOptions.readfdc C s
d| _ d S rL ©r0 rA rC rC rD Ú
reopenlogsè s zDummyOptions.reopenlogsc C s
d| _ d S rL )r1 rA rC rC rD Úprocess_environmentë s z DummyOptions.process_environmentc C s | j S rF rZ )rB ÚprefixÚsuffixÚdirrC rC rD Ú
mktempfileî s zDummyOptions.mktempfilec C s* dd l }| jr| | j¡| j |¡ d S rc )rd r5 Úerrorr6 rO )rB Úpathrd rC rC rD Úremoveñ s zDummyOptions.removec C s || j krdS dS )NTF)r7 )rB r rC rC rD Úexists÷ s
zDummyOptions.existsÚrc C s | j r | j S t||S rF )r8 Úopen)rB ÚnameÚmoderC rC rD r ü s zDummyOptions.openc C s | j rt| j d| _d S rL )r> r` r= )rB r rC rC rD Úchdir s
zDummyOptions.chdirc C s
|| _ d S rF )r? )rB ÚmaskrC rC rD Úsetumask s zDummyOptions.setumask)T)T)r )4Ú__name__Ú
__module__Ú __qualname__rw r r r_ ZminfdsZloglevelrE r rJ rK rM rP rQ rS rT rU rV rW rX rY r[ r\ r] r^ rb re rh rj rn ry r r r r r r r r r r r r r r r r r r£ r¥ rC rC rC rD r sb =
r c @ sp e Zd ZdZdd Zdd Ze Z Z Z Z Z
Z dd Z dd Z
d
d Zd d
Zdd Zdd Zdd ZdS )rG Nc C s d| _ d| _d| _g | _d S ©NF)Úreopenedr6 Úclosedr rA rC rC rD rE s zDummyLogger.__init__c K s |r || }| j |¡ d S rF ©r rO )rB ÚmsgrI rC rC rD Úinfo s zDummyLogger.infoc K s |r || }| j |¡ d S rF r¬ )rB Úlevelr rI rC rC rD Úlog s zDummyLogger.logc C s | ¡ d S rF )Úclose)rB ZhandlerrC rC rD Ú
addHandler s zDummyLogger.addHandlerc C s
d| _ d S rL )rª rA rC rC rD Úreopen s zDummyLogger.reopenc C s
d| _ d S rL ©r« rA rC rC rD r± " s zDummyLogger.closec C s
d| _ d S rL )r6 rA rC rC rD r $ s zDummyLogger.removec C s
d| _ d S rL )ÚflushedrA rC rC rD Úflush& s zDummyLogger.flushc C s d | j¡S rz )Újoinr rA rC rC rD Úgetvalue( s zDummyLogger.getvalue)r¦ r§ r¨ r¯ rE r® ÚwarnÚdebugZcriticalZtracer Zblatherr° r² r³ r± r r¶ r¸ rC rC rC rD rG s rG c @ s e Zd ZdddZdd ZdS )ÚDummySupervisorNc C sZ |d krt | _n|| _|d kr8ddlm} |j| j_n|| j_|d krPi | _n|| _d S )Nr )ÚSupervisorStates)r ÚoptionsZsupervisor.supervisordr¼ ÚRUNNINGr Úprocess_groups)rB r½ Ústater¿ r¼ rC rC rD rE , s
zDummySupervisor.__init__c C s | j jS rF )r½ r rA rC rC rD Ú get_state; s zDummySupervisor.get_state)NNN)r¦ r§ r¨ rE rÁ rC rC rC rD r» + s
r» c @ sP e Zd ZdZdZdZdZdZdd Zdd Z dd Z
d d
Z d d Z d
d Z
dS )Ú DummySocketFNc C s
|| _ d S rF ©r} r rC rC rD rE E s zDummySocket.__init__c C s | j S rF rà rA rC rC rD ÚfilenoH s zDummySocket.filenoc C s d| _ || _d S rL )Ú bind_calledÚ bind_addr)rB ÚaddrrC rC rD ÚbindK s zDummySocket.bindc C s d| _ || _d S rL )Ú
listen_calledÚlisten_backlog)rB ZbacklogrC rC rD ÚlistenO s zDummySocket.listenc C s
d| _ d S rL )Ú close_calledrA rC rC rD r± S s zDummySocket.closec C s dS )Nz dummy socketrC rA rC rC rD Ú__str__V s zDummySocket.__str__)r¦ r§ r¨ rÅ rÆ rÉ rÊ rÌ rE rÄ rÈ rË r± rÍ rC rC rC rD r > s r c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
S )ÚDummySocketConfigc C s || _ d| _d S )Nz unix:///sock)r} Zurlr rC rC rD rE Z s zDummySocketConfig.__init__c C s dS )Nz
dummy addrrC rA rC rC rD rÇ ^ s zDummySocketConfig.addrc C s | j |j kS rF rà ©rB ÚotherrC rC rD Ú__eq__a s zDummySocketConfig.__eq__c C s | |¡ S rF )rÑ rÏ rC rC rD Ú__ne__d s zDummySocketConfig.__ne__c C s dS )Né rC rA rC rC rD Ú get_backlogg s z DummySocketConfig.get_backlogc C s
t | jS rF )r r} rA rC rC rD Úcreate_and_bindj s z!DummySocketConfig.create_and_bindN) r¦ r§ r¨ rE rÇ rÑ rÒ rÔ rÕ rC rC rC rD rÎ Y s rÎ c @ s$ e Zd Zdd Zdd Zdd ZdS )ÚDummySocketManagerc K s
|| _ d S rF ©Ú_config)rB ÚconfigÚkwargsrC rC rD rE n s zDummySocketManager.__init__c C s | j S rF r× rA rC rC rD rÙ q s zDummySocketManager.configc C s t | jjS rF )r rØ r} rA rC rC rD Ú
get_sockett s z DummySocketManager.get_socketN)r¦ r§ r¨ rE rÙ rÛ rC rC rC rD rÖ m s rÖ c @ s e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZdZdZdZdZdZdZdZdZd/ddZdd Zd d
Zd d Z d
d Z dd Z dd Z dd Z dd Z!dd Z"dd Z#dd Z$d d Z%d d Z&d!d" Z'd#d$ Z(d%d& Z)d'd( Z*d)d* Z+d+d, Z,d-d. Z-dS )0Ú DummyProcessr FNr c C sÈ || _ d| _d| _d| _d | _d| _|d kr>ddlm} |j}|| _ d| _
d | _ d| _ t
d| _t
d| _t
d| _t
d| _t
d| _i | _i | _i | _d | _d| _d | _d | _d | _d| _d | _ d S )NFTr ©Ú
ProcessStatesr ) rÙ Ú logsremovedÚ stop_calledÚstop_report_calledZ backoff_secsÚspawnedÚsupervisor.processrÞ r¾ rÀ Úerror_at_clearÚ killed_withÚdrainedr Ú
stdout_bufferÚ
stderr_bufferÚ
stdout_loggedÚ
stderr_loggedÚ stdin_bufferrx ÚrpipesÚ dispatchersÚfinishedr0 Úexecv_arg_exceptionÚinput_fd_drainedÚoutput_fd_drainedÚ transitionedr3 )rB rÙ rÀ rÞ rC rC rD rE s8
zDummyProcess.__init__c C s
d| _ d S rL r rA rC rC rD r ¯ s zDummyProcess.reopenlogsc C s | j rtdd| _d S )NÚwhateverT)rä ÚIOErrorrß rA rC rC rD Ú
removelogs² s zDummyProcess.removelogsc C s | j S rF )rÀ rA rC rC rD rÁ · s zDummyProcess.get_statec C s$ d| _ d| _ddlm} |j| _d S )NTFr rÝ )rà Úkillingrã rÞ ÚSTOPPEDrÀ ©rB rÞ rC rC rD Ústopº s zDummyProcess.stopc C s
d| _ d S rL )rá rA rC rC rD Ú stop_reportÀ s zDummyProcess.stop_reportc C s
|| _ d S rF )rå ©rB ÚsignalrC rC rD rb à s zDummyProcess.killc C s
|| _ d S rF )Ú sent_signalrû rC rC rD rü Æ s zDummyProcess.signalc C s d| _ ddlm} |j| _d S )NTr rÝ )râ rã rÞ r¾ rÀ rø rC rC rD ÚspawnÊ s zDummyProcess.spawnc C s
d| _ d S rL )ræ rA rC rC rD ÚdrainÏ s zDummyProcess.drainc C s g S rF rC rA rC rC rD Ú readable_fdsÒ s zDummyProcess.readable_fdsc C s0 | j | j7 _ d| _| j| j7 _d| _d S rz )ré rç rê rè rA rC rC rD Ú
record_outputÕ s zDummyProcess.record_outputc C s ||f| _ d S rF )rî )rB ra ÚstsrC rC rD ÚfinishÜ s zDummyProcess.finishc C s ddl m} |j| _d S )Nr rÝ )rã rÞ ÚFATALrÀ rø rC rC rD Úgive_upß s zDummyProcess.give_upc C s6 | j r| d¡dd l}| | jj¡}|d }||fS )Nró r )rï ÚshlexÚsplitrÙ Úcommand)rB r Z commandargsZprogramrC rC rD Úget_execv_argsã s
zDummyProcess.get_execv_argsc C s
|| _ d S rF )rñ r rC rC rD Údrain_output_fdë s z DummyProcess.drain_output_fdc C s
|| _ d S rF )rð r rC rC rD Údrain_input_fdî s zDummyProcess.drain_input_fdc C s" | j rt| j | j|7 _d S rF )r3 r` rë )rB r~ rC rC rD r ñ s
zDummyProcess.writec C s
d| _ d S rL ©rò rA rC rC rD Ú
transitionö s zDummyProcess.transitionc C s | j j|j jkS rF ©rÙ ÚpriorityrÏ rC rC rD rÑ ù s zDummyProcess.__eq__c C s | j j|j jk S rF r rÏ rC rC rD Ú__lt__ü s zDummyProcess.__lt__)N).r¦ r§ r¨ ra Z laststartZlaststopZdelayZadministrative_stopZ system_stoprö ZbackoffZ
waitstatusZ
exitstatusrx rì rí ré rê Úspawnerrrç rè rë Zlistener_stateÚgrouprý rE r rõ rÁ rù rú rb rü rþ rÿ r r r r r r
r r r
rÑ r rC rC rC rD rÜ w sV
rÜ c @ s8 e Zd Zddd Zd
d Zd d
ZdddZdd ZdS )Ú DummyPConfigNr
Tr r F©r c ! C sÚ || _ || _|| _|| _|| _|| _| | _|
| _| | _| | _ |
| _
|| _ || _ || _
|| _|| _|| _|| _|| _|| _|| _|| _|d krdd l} | j}|| _|| _|| _| | _| | _ | | _ || _ || _ d| _ | | _!d S )Nr F)"r½ r¡ r r Ú autostartÚ autorestartÚ startsecsÚ startretriesr Ústdout_logfileÚstdout_capture_maxbytesÚstdout_events_enabledÚstdout_logfile_backupsÚstdout_logfile_maxbytesÚ
stdout_syslogÚstderr_logfileÚstderr_capture_maxbytesÚstderr_events_enabledÚstderr_logfile_backupsÚstderr_logfile_maxbytesÚ
stderr_syslogÚredirect_stderrrü ÚSIGTERMÚ
stopsignalÚ stopwaitsecsÚ stopasgroupÚ killasgroupÚ exitcodesr r ÚumaskÚautochildlogs_createdr< )!rB r½ r¡ r r r, r r r r r r r r r r r r r r r! r" r# r$ r% r' r( r) r* r+ r r< rü rC rC rD rE sF zDummyPConfig.__init__c C s
dddgS rg rC rA rC rC rD rh 2 s zDummyPConfig.get_pathc C s
d| _ d S rL )r- rA rC rC rD Úcreate_autochildlogs5 s z!DummyPConfig.create_autochildlogsc C s t | }||_|S rF )rÜ r )rB r ÚprocessrC rC rD Ú make_process8 s zDummyPConfig.make_processc C s~ | j }| j |¡}|d |d |d }}}i }|d k rJtdd||< |d k r`tdd||< |d k rvtdd||< ||fS )Nrs rv rr T)Úreadable)Úwritable)r% r½ ry ÚDummyDispatcher)rB ÚprocZ
use_stderrrx Z stdout_fdZ stderr_fdZstdin_fdrí rC rC rD Úmake_dispatchers= s ÿ
z DummyPConfig.make_dispatchers) NNr
TTr r
NNr Fr r FNr Fr r FFNr FFr NN)N)r¦ r§ r¨ rE rh r. r0 r5 rC rC rC rD r ÿ s@ ó
2
r c
C s¬ dd l }dd l}dd l}|d kr$i }t| ¡ }|j | ¡d }|j|d< | ¡ D ] }| d|
¡ || ¡}qR|j |d}t|d} | |¡ W 5 Q R X |
|d¡ |S )Nr r ZPYTHONz<<%s>>)r Úwií )rd ÚsysÚtempfiler Úreadr r Ú
executableÚkeysÚreplaceÚupperZmktempr Úchmod)
ÚfileZ
substitutionsrd r7 r8 r ZlastÚkeyZtmpnamÚfrC rC rD ÚmakeExecutableK s
rB Fc C s< dd l }|j t¡}| s*t|j |d¡S t|j |d¡S )Nr zfixtures/spew.pyzfixtures/unkillable_spew.py)rd r ÚdirnameÚ__file__rB r· )Z
unkillablerd ÚhererC rC rD ÚmakeSpew_ s
rF c @ s e Zd Zdd Zdd ZdS )ÚDummyMedusaServerLoggerc C s
g | _ d S rF )ÚloggedrA rC rC rD rE g s z DummyMedusaServerLogger.__init__c C s | j ||f¡ d S rF )rH rO )rB Úcategoryr rC rC rD r° i s zDummyMedusaServerLogger.logN)r¦ r§ r¨ rE r° rC rC rC rD rG f s rG c @ s e Zd Zdd ZdS )ÚDummyMedusaServerc C s t | _d S rF )rG r rA rC rC rD rE m s zDummyMedusaServer.__init__N©r¦ r§ r¨ rE rC rC rC rD rJ l s rJ c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
ÚDummyMedusaChannelc C s t | _d | _d S rF )rJ ZserverÚproducerrA rC rC rD rE q s zDummyMedusaChannel.__init__c C s
|| _ d S rF )rM ©rB rM rC rC rD Úpush_with_produceru s z%DummyMedusaChannel.push_with_producerc C s d S rF rC rA rC rC rD Úclose_when_donex s z"DummyMedusaChannel.close_when_donec C s d S rF rC )rB Ú
terminatorrC rC rD Úset_terminator{ s z!DummyMedusaChannel.set_terminatorN)r¦ r§ r¨ rE rO rP rR rC rC rC rD rL p s rL c @ s e Zd ZdZdZdZdZd!ddZdd Zd d
Z d d Z
d
d Z dd Z dd Z
dd Zdd Zdd Zdd Zdd Zd d Zd d ZdS )"Ú DummyRequestZGETNFz1.0c C sH ||||f| _ g | _i | _g | _g | _t | _|d kr>i | _n|| _d S rF )rH Ú producersÚheadersÚheaderZoutgoingrL ÚchannelÚenv)rB r ZparamsZqueryZfragmentrX rC rC rD rE s zDummyRequest.__init__c C s | j S rF )rH rA rC rC rD Ú split_uri s zDummyRequest.split_uric C s
|| _ d S rF )Ú_errorr rC rC rD r s zDummyRequest.errorc C s | j |¡ d S rF )rT rO rN rC rC rD Úpush s zDummyRequest.pushc C s || j |< d S rF ©rU )rB rV ÚvaluerC rC rD Ú __setitem__ s zDummyRequest.__setitem__c C s
| j | S rF r\ ©rB rV rC rC rD Ú __getitem__ s zDummyRequest.__getitem__c C s | j |= d S rF r\ r_ rC rC rD Ú __delitem__ s zDummyRequest.__delitem__c C s
|| j kS rF r\ r_ rC rC rD Úhas_key¡ s zDummyRequest.has_keyc C s
|| j kS rF r\ )rB ÚitemrC rC rD Ú __contains__¤ s zDummyRequest.__contains__c C s
d| _ d S rL )Ú_donerA rC rC rD Údone§ s zDummyRequest.donec C s dS rz rC rA rC rC rD Úbuild_reply_headerª s z DummyRequest.build_reply_headerc O s d S rF rC )rB ÚargrI rC rC rD r° s zDummyRequest.logc C s | j S rF )rX rA rC rC rD Úcgi_environment° s z DummyRequest.cgi_environmentc C s dS )Nzhttp://example.comrC rA rC rC rD Úget_server_url³ s zDummyRequest.get_server_url)N)r¦ r§ r¨ r rZ re ÚversionrE rY r r[ r^ r` ra rb rd rf rg r° ri rj rC rC rC rD rS ~ s$
rS c @ s e Zd Zdd ZdS )ÚDummyRPCInterfaceFactoryc K s || _ || _d S rF )rR rÙ )rB rR rÙ rC rC rD rE ¸ s z!DummyRPCInterfaceFactory.__init__NrK rC rC rC rD rl · s rl c @ s e Zd Zdd ZdS )ÚDummyRPCServerc C s t | _t | _d S rF )ÚDummySupervisorRPCNamespacer ÚDummySystemRPCNamespaceÚsystemrA rC rC rD rE ½ s zDummyRPCServer.__init__NrK rC rC rC rD rm ¼ s rm c @ s e Zd ZdS )ro N)r¦ r§ r¨ rC rC rC rD ro Á s ro c
@ sz e Zd ZdZdZdZdZddlmZ dddej de
d dd e
d
d
d d d
ej de
d e
d de
dd
dddej de
d e
d d e
dd
gZ
dd ZeZdd Zd d Zd d ZeZd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Zd0d1 Z d2d3 Z d4d5 Z d6d7 Z d8d9 Z d:d; Z!d<d= Z"e"Z#e"Z$e"Z%d>d? Z&d@dA Z'dBdC Z(dDdE Z)dFdG Z*dHdI Z+dJdK Z,dLdM Z-dNS )Orn TFr rÝ Úfooé r¾ éd r zfoo description)
r¡ r ra rÀ Z statenameÚstartrù r ZnowÚ descriptionZbaré r é2 Zscrewedzbar descriptionZbaz_01Zbazé
r÷ é zbaz descriptionc C s dS )Nz3.0rC rA rC rC rD Ú
getAPIVersionó s z)DummySupervisorRPCNamespace.getAPIVersionc C s dS )Né* rC rA rC rC rD ÚgetPIDø s z"DummySupervisorRPCNamespace.getPIDc C sj ddl m} |dkr$t|jjdn.|dkr<t|jjdn|dkrRt|jjd|d d }||d
S )Nr ©ÚxmlrpcÚBAD_NAMEÚFAILEDÚNO_FILEz line
r )r r~ r ÚFaultsr r r )rB rW r¡ ÚoffsetÚlengthr~ ÚarC rC rD Ú _read_logû s z%DummySupervisorRPCNamespace._read_logc C s | d|||¡S )Nrs ©r ©rB r¡ r r rC rC rD ÚreadProcessStdoutLog s z0DummySupervisorRPCNamespace.readProcessStdoutLogc C s | d|||¡S )Nrv r r rC rC rD ÚreadProcessStderrLog
s z0DummySupervisorRPCNamespace.readProcessStderrLogc C s | j S rF )Úall_process_inforA rC rC rD ÚgetAllProcessInfo
s z-DummySupervisorRPCNamespace.getAllProcessInfoc C sv ddl m} | jD ] }|d |kr|}| S q|dkrFt|jjd|dkr\t|jjd|dkrrt|jjdd S )Nr r} r¡ r r r )r r~ r r r r r r )rB r¡ r~ Úir® rC rC rD ÚgetProcessInfo s
z*DummySupervisorRPCNamespace.getProcessInfoc C sª ddl m} |dkr"t|jjd|dkr8t|jjd|dkrNt|jjd|dkrdt|jjd|dkrzt|jjd|dkrt|jjd|d kr¦t|jj d d
S ) Nr r} úBAD_NAME:BAD_NAMEr r ÚNOT_EXECUTABLEÚALREADY_STARTEDÚ SPAWN_ERRORÚABNORMAL_TERMINATIONT)
r r~ r r r r r r r r ©rB r¡ r~ rC rC rD Ú startProcess s$ ÿz(DummySupervisorRPCNamespace.startProcessc C sR ddl m} ddlm} |dkr.||jjddd|jjddd d|jjddgS ©
Nr r} r r Úfoo_00rq ÚOK©r¡ r Zstatusru Úfoo_01©r r~ Úsupervisor.compatr r r ÚSUCCESS©rB r¡ r~ r rC rC rD ÚstartProcessGroup0 s þþüz-DummySupervisorRPCNamespace.startProcessGroupc C s@ ddl m} dd|jjdddd|jjdddd|jjd dgS )
Nr r} rq r r Úfoo2ÚfailedÚ failed_groupr )r r~ r r r ©rB r~ rC rC rD ÚstartAllProcesses> s þþþùz-DummySupervisorRPCNamespace.startAllProcessesc C sR ddl m} ddlm} |dkr.||jjddd|jjddd d|jjddgS r r r rC rC rD ÚstopProcessGroupL s þþüz,DummySupervisorRPCNamespace.stopProcessGroupc C sh ddl m} |dkr"t|jjd|dkr8t|jjd|dkrNt|jjd|dkrdt|jjddS )Nr r} r r Ú NOT_RUNNINGr T)r r~ r r r r¦ r r rC rC rD Ú stopProcessZ s z'DummySupervisorRPCNamespace.stopProcessc C s@ ddl m} dd|jjdddd|jjdddd|jjd dgS ©
Nr r} rq r r r r¡ r¢ r ©r r~ r r r r£ rC rC rD ÚstopAllProcessesg s þ ÿþúz,DummySupervisorRPCNamespace.stopAllProcessesc C s. | j rd| _d S ddlm} t|jjdd S ©NTr r} r )Ú _restartableÚ
_restartedr r~ r r ÚSHUTDOWN_STATEr£ rC rC rD Úrestartt s
z#DummySupervisorRPCNamespace.restartc C s. | j rd| _d S ddlm} t|jjdd S r« )r¬ Ú _shutdownr r~ r r r® r£ rC rC rD Úshutdown{ s
z$DummySupervisorRPCNamespace.shutdownc C s dgdgdgggS )NZaddedZchangedr6 rC rA rC rC rD Ú reloadConfig s z(DummySupervisorRPCNamespace.reloadConfigc C s ddl m} |dkr"t|jjd|dkr8t|jjd|dkrNt|jjd|dkrdt|jjdt| dr|| j
|¡ n|g| _ d S ) Nr r} Ú
ALREADY_ADDEDr r r r® Ú processes) r r~ r r r³ r r r® Úhasattrr´ rO r rC rC rD ÚaddProcessGroup
s
z+DummySupervisorRPCNamespace.addProcessGroupc C s^ ddl m} |dkr"t|jjd|dkr8t|jjd|dkrNt|jjd| j |¡ d S )Nr r} Ú
STILL_RUNNINGr r r ) r r~ r r r· r r r´ r r rC rC rD ÚremoveProcessGroup s z.DummySupervisorRPCNamespace.removeProcessGroupc C s& ddl m} |dkr"t|jjddS )Nr r} r T)r r~ r r r r rC rC rD ÚclearProcessStdoutLog s z1DummySupervisorRPCNamespace.clearProcessStdoutLogc C s@ ddl m} dd|jjdddd|jjdddd|jjd dgS r¨ )r r~ r r r r£ rC rC rD ÚclearAllProcessLogs¨ s" ýýý÷z/DummySupervisorRPCNamespace.clearAllProcessLogsc C s t dd S )Nr ©Ú
ValueErrorrA rC rC rD Ú
raiseError¹ s z&DummySupervisorRPCNamespace.raiseErrorc C s dd iS )Nr rC rA rC rC rD ÚgetXmlRpcUnmarshallable¼ s z3DummySupervisorRPCNamespace.getXmlRpcUnmarshallablec C s dS )NZ3000rC rA rC rC rD ÚgetSupervisorVersion¿ s z0DummySupervisorRPCNamespace.getSupervisorVersionc C s | j rt| j ddS )Nr Z mainlogdata)Ú_readlog_errorr )rB Úwhencer rC rC rD ÚreadLog s z#DummySupervisorRPCNamespace.readLogc C sF ddl m} |dkr"t|jjddd|jjdddd|jjddgS ) Nr r} r r rq r r r )r r~ r r r r ©rB r¡ rü r~ rC rC rD ÚsignalProcessGroupÇ s ýýûz.DummySupervisorRPCNamespace.signalProcessGroupc C s~ ddl m} |dkr"t|jjd|dkr8t|jjd|dkrNt|jjd|dkrdt|jjd|dkrzt|jjddS ) Nr r} Ú
BAD_SIGNALr r r¦ r T)r r~ r r rÅ r r¦ r rà rC rC rD Ú
signalProcessÖ s z)DummySupervisorRPCNamespace.signalProcessc C s@ ddl m} dd|jjdddd|jjdddd|jjd dgS r¨ r© )rB rü r~ rC rC rD ÚsignalAllProcesseså s" ýýý÷z.DummySupervisorRPCNamespace.signalAllProcessesN).r¦ r§ r¨ r¬ r r° rÀ rã rÞ r¾ Ú_NOWr r÷ r rz Z
getVersionr| r r ZreadProcessLogr r r r r r¤ r¥ r§ rª r¯ r± r² r¶ r¸ r¹ ZclearProcessLogZclearProcessStderrLogZclearProcessLogsrº r½ r¾ r¿ r rÄ rÆ rÇ rC rC rC rD rn Ä s ö
ö
öç'
rn c @ s. e Zd Zd ddZdd Zdd Zd
d ZdS )
ÚDummyPGroupConfigró r
Nc C s: || _ || _|| _|d kr g }|| _d| _g | _d| _d S )NFr )r½ r¡ r Zprocess_configsÚafter_setuid_calledZ pool_eventsZ buffer_size)rB r½ r¡ r ÚpconfigsrC rC rD rE ÷ s zDummyPGroupConfig.__init__c C s
d| _ d S rL )rÊ rA rC rC rD Ú after_setuid s z DummyPGroupConfig.after_setuidc C s t | S rF )ÚDummyProcessGrouprA rC rC rD Ú
make_group s z DummyPGroupConfig.make_groupc C s d| j t| | jf S )Nz <%s instance at %s named %s>)Ú __class__Úidr¡ rA rC rC rD Ú__repr__ s ÿzDummyPGroupConfig.__repr__)ró r
N)r¦ r§ r¨ rE rÌ rÎ rÑ rC rC rC rD rÉ ö s
rÉ c @ s" e Zd ZdddedfddZdS )ÚDummyFCGIGroupConfigró r
Nr c C s t | ||||¡ || _d S rF )rÉ rE Ú
socket_config)rB r½ r¡ r rË rÓ rC rC rD rE
s z DummyFCGIGroupConfig.__init__)r¦ r§ r¨ rÎ rE rC rC rC rD rÒ s rÒ c @ sT e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dS )rÍ c C s( || _ d| _d| _i | _g | _d| _d S r© )rÙ rò Ú all_stoppedrí Úunstopped_processesÚbefore_remove_called©rB rÙ rC rC rD rE s zDummyProcessGroup.__init__c C s
d| _ d S rL r rA rC rC rD r
s z DummyProcessGroup.transitionc C s
d| _ d S rL )rÖ rA rC rC rD Ú
before_remove s z DummyProcessGroup.before_removec C s
d| _ d S rL )rÔ rA rC rC rD Ústop_all! s zDummyProcessGroup.stop_allc C s | j S rF )rÕ rA rC rC rD Úget_unstopped_processes$ s z)DummyProcessGroup.get_unstopped_processesc C s | j S rF )rí rA rC rC rD Úget_dispatchers' s z!DummyProcessGroup.get_dispatchersc C s | j j|j jk S rF r rÏ rC rC rD r * s zDummyProcessGroup.__lt__c C s | j j|j jkS rF r rÏ rC rC rD rÑ - s zDummyProcessGroup.__eq__c C s
d| _ d S rL r rA rC rC rD r 0 s z DummyProcessGroup.reopenlogsN) r¦ r§ r¨ rE r
rØ rÙ rÚ rÛ r rÑ r rC rC rC rD rÍ s rÍ c @ s e Zd Zdd ZdS )ÚDummyFCGIProcessGroupc C s t | |¡ t|j| _d S rF )rÍ rE rÖ rÓ Zsocket_managerr× rC rC rD rE 5 s z DummyFCGIProcessGroup.__init__NrK rC rC rC rD rÜ 3 s rÜ c @ s& e Zd Zdd ZdddZdd ZdS ) ÚPopulatedDummySupervisorc G sb t | |¡ i | _i }|| _t|||d}t|}|| j|< |D ]}t|}|||j< q@||_d S )N)rË ) r» rE r¿ Ú
group_namerÉ rÍ rÜ r¡ r´ ) rB r½ rÞ rË r´ ZgconfigZpgroupZpconfigr/ rC rC rD rE : s
z!PopulatedDummySupervisor.__init__Nc C s. |d kr| j }| j| j| }t||| d S rF )rÞ r¿ r´ Úsetattr)rB Z process_nameZ attr_nameÚvalrÞ r/ rC rC rD Ú set_procattrG s z%PopulatedDummySupervisor.set_procattrc C s
d| _ d S rL )ZreapedrA rC rC rD ÚreapM s z PopulatedDummySupervisor.reap)N)r¦ r§ r¨ rE rá râ rC rC rC rD rÝ 9 s
rÝ c @ sn e Zd ZdZdZdZdZdZdZdZ dZ
dddZ dd Z dd Z
d d
Zd d Zd
d Zdd Zdd ZdS )r3 FNc sD | _ | _| _d _|r@ fdd}| _ fdd}| _d S )Nr c s
d _ d S rL r rC rA rC rD r ` s z,DummyDispatcher.__init__.<locals>.reopenlogsc s
d _ d S rL )Ú logs_removedrC rA rC rD rõ c s z,DummyDispatcher.__init__.<locals>.removelogs)Ú _readableÚ _writablerZ Z input_bufferr rõ )rB r1 r2 r r rõ rC rA rD rE Y s zDummyDispatcher.__init__c C s | j S rF )rä rA rC rC rD r1 g s zDummyDispatcher.readablec C s | j S rF )rå rA rC rC rD r2 i s zDummyDispatcher.writablec C s | j r | j d| _d S rL )rZ Úwrite_event_handledrA rC rC rD Úhandle_write_eventk s z"DummyDispatcher.handle_write_eventc C s | j r | j d| _d S rL )rZ Úread_event_handledrA rC rC rD Úhandle_read_evento s z!DummyDispatcher.handle_read_eventc C s
d| _ d S rL )Ú
error_handledrA rC rC rD Ú handle_errors s z DummyDispatcher.handle_errorc C s
d| _ d S rL r´ rA rC rC rD r± u s zDummyDispatcher.closec C s | j rt| j d| _d S rL )Ú flush_errorr` rµ rA rC rC rD r¶ w s
zDummyDispatcher.flush)FFF)r¦ r§ r¨ ræ rè rê r0 rã r« rì rµ rE r1 r2 rç ré rë r± r¶ rC rC rC rD r3 P s
r3 c @ sH e Zd ZdddZdd Zdd Zd d
Zdd d
Zdd Zdd Z dS )Ú DummyStreamNr c C s" || _ d| _d| _d| _|| _d S )NFó )r r« rµ r) Ú_fileno)rB r rÄ rC rC rD rE } s
zDummyStream.__init__c C s | j r | j d| _d S rL )r r« rA rC rC rD r± s zDummyStream.closec C s | j r | j d| _d S rL )r rµ rA rC rC rD r¶ s zDummyStream.flushc C s, | j r| j }d | _ || jt|7 _d S rF )r r) r )rB r r rC rC rD r s
zDummyStream.writer c C s d S rF rC )rB ZnumrÁ rC rC rD Úseek s zDummyStream.seekc C s
t | jS rF )r| r) rA rC rC rD Útell s zDummyStream.tellc C s | j S rF )rï rA rC rC rD rÄ s zDummyStream.fileno)Nr )r )
r¦ r§ r¨ rE r± r¶ r rð rñ rÄ rC rC rC rD rí | s
rí c @ s e Zd ZdddZdd ZdS )Ú
DummyEventÚabcc C s |d k r|| _ d S rF )Úserial)rB rô rC rC rD rE s zDummyEvent.__init__c C s dS )Nz dummy eventrC rA rC rC rD Úpayload s zDummyEvent.payloadN)ró )r¦ r§ r¨ rE rõ rC rC rC rD rò s
rò c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) r@ c C s g g f| _ d| _d S r© )Úresultr« )rB r½ rC rC rD rE ¡ s
zDummyPoller.__init__c C s d S rF rC r rC rC rD Úregister_readable¥ s z DummyPoller.register_readablec C s d S rF rC r rC rC rD Úregister_writable¨ s z DummyPoller.register_writablec C s | j S rF )rö )rB ZtimeoutrC rC rD Úpoll« s zDummyPoller.pollc C s
d| _ d S rL r´ rA rC rC rD r± ® s zDummyPoller.closeN)r¦ r§ r¨ rE r÷ rø rù r± rC rC rC rD r@ s
r@ c C s d S rF rC ©Úeventrö rC rC rD Ú
dummy_handler± s rü c C s ddl m} ||d S )Nr )Ú RejectEvent)Zsupervisor.dispatchersrý )rû rö rý rC rC rD Úrejecting_handler´ s rþ c C s t |d S rF r» rú rC rC rD Úexception_handler¸ s rÿ c C s dd | d¡D }d |¡S )Nc S s g | ] }| ¡ qS rC )Ústrip)Ú.0ÚxrC rC rD Ú
<listcomp>¼ s zlstrip.<locals>.<listcomp>Ú
)r r· )ÚsZstringsrC rC rD Úlstrip» s r )N)F)-rÈ Z _TIMEFORMATÚ functoolsr r r r Z
unittest.mockr r r Ú ImportErrorZmockr rG r» r rÎ rÖ ÚobjectrÜ r rB rF rG rJ rL rS rl rm ro rn rÉ rÒ rÍ rÜ rÝ r3 rí rò r@ rü rþ rÿ r rC rC rC rD Ú<module> sb s"
L
9 4!,