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
1ϧ\є ã @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dlm
Z
d dlm Z d dlm Z d dl
mZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZmZ d dlmZ d dl m Z d dl m Z d dl m!Z! eG dd de"Z#G dd de#Z$eG dd de"Z%G dd de%Z&G dd d e&Z'G d d d e%Z(G d d d e"Z)e) Z)d!d" Z*dS )#é N)Útotal_ordering)Úmaxint)Úas_bytes)Ú as_string)ÚPY2)Ú asyncore_25)Ú
ProcessStates)ÚSupervisorStates)ÚgetProcessStateDescription)ÚSTOPPED_STATES)Údecode_wait_status)Úsigname)ÚProcessExceptionÚ
BadCommand)ÚEventListenerStates)Úevents)ÚRestartUnconditionally)Ú
SocketManagerc @ sn e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZdZdZdZdZdZdd Zdd Zd d
Zd d Zd
d Zdd Ze j e j e j e j!e j"e j#e j$e j%e j&e j'e j(e j)e j*e j+e j,e j-iZ.d:ddZ/dd Z0dd Z1dd Z2dd Z3d d Z4d d Z5d d! Z6d"d# Z7d$d% Z8d&d' Z9d(d) Z:d*d+ Z;d,d- Z<d.d/ Z=d0d1 Z>d2d3 Z?d4d5 Z@d6d7 ZAd8d9 ZBdS );Ú
Subprocessz A class to manage a subprocess.r NFc C s || _ i | _i | _tj| _dS )zDConstructor.
Argument is a ProcessConfig instance.
N)ÚconfigÚ dispatchersÚpipesr ÚSTOPPEDÚstate©Úselfr © r ú!./build/lib/supervisor/process.pyÚ__init__; s zSubprocess.__init__c C s& | j ¡ D ]}t|dr
| ¡ q
d S )NÚ
removelogs)r ÚvaluesÚhasattrr ©r Ú
dispatcherr r r r E s
zSubprocess.removelogsc C s& | j ¡ D ]}t|dr
| ¡ q
d S )NÚ
reopenlogs)r r r! r$ r" r r r r$ J s
zSubprocess.reopenlogsc C s4 | j ¡ D ]$}| ¡ r | ¡ | ¡ r
| ¡ q
d S ©N)r r ÚreadableZhandle_read_eventÚwritableZhandle_write_eventr" r r r ÚdrainO s
zSubprocess.drainc C sl | j r | jrttjd| jd }|d kr6ttjd| j| }|jrRttjd| j|7 _| ¡ d S )NzProcess already closedÚstdinz Process has no stdin channelz Process' stdin channel is closed)
ÚpidÚkillingÚOSErrorÚerrnoÚEPIPEr r ÚclosedZ input_bufferÚflush)r ÚcharsZstdin_fdr# r r r ÚwriteZ s
zSubprocess.writec
C s" zt | jj¡}W n: tk
rL } z td| jjt|f W 5 d}~X Y nX |r\|d }ntdd|kr|}z| jj |¡}W n t k
r d}Y nX nj| j
¡ }d}d}|D ]>}t j
||¡}z| jj |¡}W n t k
rì Y q´X qôq´|dkr|}n|}| jj |||¡ ||fS )zInternal: turn a program name into a file name, using $PATH,
make sure it exists / is executable, raising a ProcessException
if not zcan't parse command %r: %sNr zcommand is emptyú/)ÚshlexÚsplitr ZcommandÚ
ValueErrorr ÚstrÚoptionsÚstatr, Zget_pathÚosÚpathÚjoinZcheck_execv_args) r Z commandargsÚeZprogramÚfilenameÚstr; ÚfoundÚdirr r r Úget_execv_argsi s< ÿ
zSubprocess.get_execv_argsTc C sr | j }||krdS | j |¡}|d k r<|| ||}t |¡ |tjkrht ¡ }| jd7 _|| j | _ || _ d S )NFé )
r Ú event_mapÚgetr Únotifyr ÚBACKOFFÚtimeÚbackoffÚdelay)r Z new_stateÚexpectedZ old_stateZ event_classÚeventÚnowr r r Ú change_state¢ s
zSubprocess.change_statec G sF | j |krBt| j }d tt|¡}t| jj}td|||f d S )Nú z%Assertion failed for %s: %s not in %s)r r
r< Úmapr r ÚnameÚAssertionError)r ZstatesZ
current_stateZallowable_statesÚ processnamer r r Ú_assertInState´ s
ÿzSubprocess._assertInStatec C s || _ | jjj d| ¡ d S )Nz spawnerr: %s)Úspawnerrr r8 ÚloggerÚinfo©r Úmsgr r r Úrecord_spawnerr¼ s zSubprocess.record_spawnerrc
C sL | j j}t| j j}| jr2d| }|j |¡ dS d| _d| _d| _ d| _
d| _ t ¡ | _
| tjtjtjtj¡ | tj¡ z| ¡ \}}W nP tk
rÞ } z2| |jd ¡ | tj¡ | tj¡ W Y ¢dS d}~X Y nX z| j | ¡\| _| _ W n t t fk
r~ } zb|jd }|t j kr0d| }nd|t j! "||¡f }| |¡ | tj¡ | tj¡ W Y ¢dS d}~X Y nX z | #¡ } W n t k
r& } zz|jd }|t j$krÀd| }nd|t j! "||¡f }| |¡ | tj¡ | tj¡ | %| j ¡ | &| j ¡ W Y ¢dS d}~X Y nX | dkr<| '| ¡S | (||¡S dS ) zStart the subprocess. It must not be running already.
Return the process id. If the fork() call fails, return None.
z process '%s' already runningNFr z!too many open files to spawn '%s'z-unknown error making dispatchers for '%s': %sz1Too many processes in process table to spawn '%s'z&unknown error during fork for '%s': %s))r r8 r rQ r* rV Úwarnr+ rU Ú
exitstatusÚ system_stopÚadministrative_stoprH Ú laststartrT r ÚEXITEDÚFATALrG r rN ÚSTARTINGrB r rZ ÚargsZmake_dispatchersr r r, ÚIOErrorr- ZEMFILEÚ errorcoderE ÚforkZEAGAINÚclose_parent_pipesÚclose_child_pipesÚ_spawn_as_parentÚ_spawn_as_child)
r r8 rS rY r> ÚargvZwhatÚwhyÚcoder* r r r ÚspawnÀ sv
ÿ
ÿ
ÿ ÿ
zSubprocess.spawnc C s\ || _ | jj}| | j¡ |j dt| jj|f ¡ d | _ t
¡ | jj | _ | |j
|< |S )Nzspawned: '%s' with pid %s)r* r r8 rh r rV rW r rQ rU rH Ú startsecsrJ Z
pidhistory)r r* r8 r r r ri s
zSubprocess._spawn_as_parentc C sz | j j}| | jd d¡ | | jd d¡ | j jrH| | jd d¡ n| | jd d¡ td|jD ]}| |¡ qfd S )NZ child_stdinr Ú child_stdoutrC é Ú child_stderré )r r8 Údup2r Úredirect_stderrÚrangeÚminfdsÚclose_fd)r r8 Úir r r Ú_prepare_child_fds s z Subprocess._prepare_child_fdsc
C sF | j j}z | ¡ | ¡ | ¡ }|rV| j j}d||f }| dd| ¡ W ¢Ød S tj
¡ }d|d< | j j }|d kr| j jj }|r||d< | j j |d < | j
r®| j
j j |d
< | j jd k rÈ| | j j¡ | j j} z| d k rä| | ¡ W nd tk
rJ }
zDtj |
jd |
jd ¡} d | | f }| dd| ¡ W Y ¢W ¢ðd S d }
~
X Y nX z.| j jd k rj| | j j¡ | |||¡ W nª tk
rØ }
z>tj |
jd |
jd ¡} d
|d | f }| dd| ¡ W 5 d }
~
X Y nN t ¡ \\} }
}}}}d||| |f }d
||f }| dd| ¡ Y nX W 5 | dd¡ | d¡ X d S )Nrq z*supervisor: child process was not spawned
é zcouldn't setuid to %s: %s
z supervisor: Ú1ZSUPERVISOR_ENABLEDZSUPERVISOR_SERVER_URLZSUPERVISOR_PROCESS_NAMEZSUPERVISOR_GROUP_NAMEr zcouldn't chdir to %s: %s
zcouldn't exec %s: %s
z%s, %s: file: %s line: %s) r r8 r2 Ú_exitÚsetpgrprz Úset_uidÚuidr: ÚenvironÚcopyÚ serverurlrQ ÚgroupZ environmentÚupdateZ directoryÚchdirr, r- re rE rc ÚumaskZsetumaskÚexecveÚasyncoreZcompact_traceback)r r> rk r8 Z
setuid_msgr rY Úenvr Úcwdrl rm ÚfileZfunÚlineÚtÚvZtbinfoÚerrorr r r rj s\
zSubprocess._spawn_as_childc C sþ | j tjkrH|| jk r || _| jdkrú|| j| jj k rú|| jj | _n²| j tjkr|| jkrú|| j| jj k rú|| jj | _nz| j tjkrÈ|| j k r|| _ | jdkrú|| j| jj
k rú|| jj
| _n2| j tj krú| jdkrú|| j| j k rú|| j | _dS )z
Check if system clock has rolled backward beyond test_time. If so, set
affected timestamps to test_time.
r N)
r r rb r_ rJ r ro ÚRUNNINGÚSTOPPINGÚlaststopreportÚ stopwaitsecsrG rI )r Z test_timer r r Ú+_check_and_adjust_for_system_clock_rollbackf s
z6Subprocess._check_and_adjust_for_system_clock_rollbackc C s d| _ d| _| | jj¡S )z Administrative stop Tr )r^ r Úkillr Z
stopsignal©r r r r Ústop| s zSubprocess.stopc C sR | j tjkrNt ¡ }| |¡ || jd krN| jjj dt
| jj ¡ || _dS )z8 Log a 'waiting for x to stop' message with throttling. rq zwaiting for %s to stopN) r r r rH r r r r8 rV rW r rQ )r rM r r r Ú stop_report s
ÿzSubprocess.stop_reportc C s. d| _ d| _d| _| tj¡ | tj¡ d S )Nr T)rJ rI r] rT r rG rN ra r r r r Úgive_up s
zSubprocess.give_upc
C sj t ¡ }| jj}t| jj}| jtjkrLd| }|j |¡ |
tj ¡ dS | j srd|t
|f }|j |¡ |S | jtjkr| jj}n| jj}d}|rd}|j d|| j |t
|f ¡ d| _|| jj | _| tjtjtj¡ |
tj¡ | j }|r| j }z| ||¡ W nR t ¡ } d|| j | f }|j |¡ |
tj¡ d | _ d
| _d | _| Y S X dS ) zÑSend a signal to the subprocess. This may or may not kill it.
Return None if the signal was sent, or an error message string
if an error occurred or if the subprocess is not running.
z0Attempted to kill %s, which is in BACKOFF state.Nz6attempted to kill %s with sig %s but it wasn't runningÚ zprocess group z$killing %s (pid %s) %swith signal %sTz"unknown problem killing %s (%s):%sr F) rH r r8 r rQ r r rG rV ÚdebugrN r r* r
r Ú killasgroupZ stopasgroupr+ r rJ rT r rb r Ú tracebackÚ
format_excÚcriticalÚUNKNOWN)
r ÚsigrM r8 rS rY r Zas_groupr* Útbr r r r sl ÿ
ÿ
ýÿþ ÿ
zSubprocess.killc C sÈ | j j}t| j j}| js:d|t|f }|j |¡ |S |j d|| jt|f ¡ | t j
t j t j ¡ z|
| j|¡ W nF t ¡ }d|| j|f }|j |¡ | t j¡ d| _| Y S X dS )zÑSend a signal to the subprocess, without intending to kill it.
Return None if the signal was sent, or an error message string
if an error occurred or if the subprocess is not running.
z1attempted to send %s sig %s but it wasn't runningzsending %s (pid %s) sig %sz&unknown problem sending sig %s (%s):%sr N)r r8 r rQ r* r
rV r rT r r rb r r r r r rN r¡ )r r¢ r8 rS rY r£ r r r Úsignalà s@
ÿ þÿþ ÿ
zSubprocess.signalc C sÞ | ¡ t|\}}t ¡ }| |¡ || _t| jj}|| jkrV|| j | jj k }n d}| jj
j d|| j
f ¡ || jjk}| jr¾d| _d| _|| _d||f }| tj¡ | tj¡ nÄ|rød| _d| _d||d f }| tj¡ | tj¡ nd| _d| _|| _| jtjkr$| tj ¡ | tj ¡ |rXd||d f }| jtj d
d n*d | | _d||d f }| jtj dd | jj
j |¡ d| _
| jj
| j ¡ i | _ i | _!| j"dk rÚt# $t# %| | j"¡¡ d| _"dS )
zK The process was reaped and we need to report and manage its state
Fzprocess '%s' (%s) laststart time is in the future, don't know how long process was running so assuming it did not exit too quicklyr zstopped: %s (%s)Nz1Exited too quickly (process log may have details)zexited: %s (%s)z; not expectedz
; expectedT)rK zBad exit code %s)&r( r rH r Úlaststopr r rQ r_ ro r8 rV r[ r* Ú exitcodesr+ rJ r\ rT r r rN r rU rb rG rI r r r` rW rg r r rL r rF ÚEventRejectedEvent) r r* ÚstsZesrY rM rS Z too_quicklyZ
exit_expectedr r r Úfinish s`
þÿ
zSubprocess.finishc C s& | j jd krd S | j j | j j¡}|S r% )r r r8 Zdrop_privilegesrX r r r r \ s zSubprocess.set_uidc C s | j j|j jk S r% ©r Zpriority©r Úotherr r r Ú__lt__b s zSubprocess.__lt__c C s | j j|j jkS r% rª r« r r r Ú__eq__e s zSubprocess.__eq__c C s4 | j j}trt| d¡}dt| |t| ¡ f S )Núunicode-escapez+<Subprocess at %s with name %s in state %s>)r rQ r r ÚencodeÚidr
Ú get_state©r rQ r r r Ú__repr__i s
ýzSubprocess.__repr__c C s | j S r% )r r r r r r² t s zSubprocess.get_statec C s² t ¡ }| j}| |¡ | jjj}| jjjtjkr¾|t j
krr| jj r¾| jj t krZ|
¡ q¾| j| jjkr¾|
¡ nL|t jkr| js| jjr¾|
¡ n*|t jkr¾| j| jjkr¾|| jkr¾|
¡ t| jj}|t jkr,|| j | jjkr,d| _d| _| t j¡ | t j ¡ d| jj }| d||f ¡ |t jkrh| j| jjkr®| ¡ d}| d||f ¡ nF|t j kr®| j| }|dkr®| jjj !d|| j"f ¡ | #t$j%¡ d S )Nr zNentered RUNNING state, process has stayed up for > than %s seconds (startsecs)zsuccess: %s %sz7entered FATAL state, too many start retries too quicklyzgave up: %s %sz killing '%s' (%s) with SIGKILL)&rH r r r r8 rV Zmoodr Z
RESTARTINGr r` Z autorestartr rn r\ r¦ r r_ Z autostartrG rI Z startretriesrJ r rQ rb ro rT rN r rW r r r[ r* r r¤ ÚSIGKILL)r rM r rV rS rY Z time_leftr r r Ú
transitionw sX
ÿÿ
ÿÿzSubprocess.transition)T)CÚ__name__Ú
__module__Ú __qualname__Ú__doc__r* r r Úlistener_staterL r_ r¥ r rJ r^ r] r+ rI r r r\ rU r r r r$ r( r2 rB r rG r ZProcessStateBackoffEventra ZProcessStateFatalEventr¡ ZProcessStateUnknownEventr ZProcessStateStoppedEventr` ZProcessStateExitedEventr ZProcessStateRunningEventrb ZProcessStateStartingEventr ZProcessStateStoppingEventrD rN rT rZ rn ri rz rj r r r r r r¤ r© r r r® r´ r² r¶ r r r r r ! s|
/ ø
I G K%W r c @ s@ e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd d
Z dS )ÚFastCGISubprocessz7Extends Subprocess class to handle FastCGI subprocessesc C s t | |¡ d | _d S r% )r r Ú fcgi_sockr r r r r º s zFastCGISubprocess.__init__c C sH | j dkrtdt| j ds6td| j t| j f | j j ¡ | _dS )zU
The FastCGI socket needs to be created by the parent before we fork
Nz"No group set for FastCGISubprocessÚsocket_managerz No SocketManager set for %s:%s)r ÚNotImplementedErrorr! rA r¾ Ú
get_socketr½ r r r r Ú before_spawn¾ s
ÿz FastCGISubprocess.before_spawnc C s$ | ¡ t | ¡}|dkr d| _|S )zR
Overrides Subprocess.spawn() so we can hook in before it happens
N)rÁ r rn r½ )r r* r r r rn É s
zFastCGISubprocess.spawnc C s
d| _ dS )zM
Releases reference to FastCGI socket when process is reaped
N)r½ r r r r Ú after_finishÔ s z FastCGISubprocess.after_finishc C s t | ||¡}| ¡ |S )zR
Overrides Subprocess.finish() so we can hook in after it happens
)r r© r )r r* r¨ Zretvalr r r r© Û s zFastCGISubprocess.finishc C s~ | j ¡ }| jj}| |d¡ | | jd d¡ | jjrL| | jd d¡ n| | jd d¡ td|jD ]}| |¡ qjdS )z
Overrides Subprocess._prepare_child_fds()
The FastCGI socket needs to be set to file descriptor 0 in the child
r rp rC rq rr rs N)
r½ Úfilenor r8 rt r ru rv rw rx )r Zsock_fdr8 ry r r r rz ã s
z$FastCGISubprocess._prepare_child_fdsN)
r· r¸ r¹ rº r rÁ rn r r© rz r r r r r¼ · s r¼ c @ s\ e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dS )ÚProcessGroupBasec C s0 || _ i | _| j jD ]}| | ¡| j|j< qd S r% )r Ú processesZprocess_configsZ make_processrQ )r r Zpconfigr r r r ö s zProcessGroupBase.__init__c C s | j j|j jk S r% rª r« r r r r ý s zProcessGroupBase.__lt__c C s | j j|j jkS r% rª r« r r r r® s zProcessGroupBase.__eq__c C s. | j j}trt| d¡}d| jt| |f S )Nr¯ z <%s instance at %s named %s>)r rQ r r r° Ú __class__r± r³ r r r r´ s ÿzProcessGroupBase.__repr__c C s | j ¡ D ] }| ¡ q
d S r% )rÅ r r ©r Úprocessr r r r s zProcessGroupBase.removelogsc C s | j ¡ D ] }| ¡ q
d S r% )rÅ r r$ rÇ r r r r$ s zProcessGroupBase.reopenlogsc C sn t | j ¡ }| ¡ | ¡ |D ]F}| ¡ }|tjkrB| ¡ q"|tj krV| ¡ q"|tj
kr"| ¡ q"d S r% ) ÚlistrÅ r ÚsortÚreverser² r r r rb rG r )r rÅ Úprocr r r r Ústop_all s
zProcessGroupBase.stop_allc C s dd | j ¡ D S )z@ Processes which aren't in a state that is considered 'stopped' c S s g | ]}| ¡ tkr|qS r )r² r )Ú.0Úxr r r Ú
<listcomp>' s
ÿ z<ProcessGroupBase.get_unstopped_processes.<locals>.<listcomp>)rÅ r r r r r Úget_unstopped_processes% s z(ProcessGroupBase.get_unstopped_processesc C s$ i }| j ¡ D ]}| |j¡ q|S r% )rÅ r r
r )r r rÈ r r r Úget_dispatchers* s z ProcessGroupBase.get_dispatchersc C s d S r% r r r r r Ú
before_remove0 s z ProcessGroupBase.before_removeN)
r· r¸ r¹ r r r® r´ r r$ rÍ rÑ rÒ rÓ r r r r rÄ ô s rÄ c @ s e Zd Zdd ZdS )Ú ProcessGroupc C s | j ¡ D ] }| ¡ q
d S r% )rÅ r r¶ )r rÌ r r r r¶ 4 s zProcessGroup.transitionN)r· r¸ r¹ r¶ r r r r rÔ 3 s rÔ c @ s e Zd Zdd ZdS )ÚFastCGIProcessGroupc
K sx t | |¡ | dt¡}||j|jjd| _z| j ¡ W n8 t k
rr } zt
d| j ¡ |f W 5 d }~X Y nX d S )NZ
socketManager)rV z&Could not create FastCGI socket %s: %s) rÔ r rE r Z
socket_configr8 rV r¾ rÀ Ú Exceptionr6 r )r r ÚkwargsZsockManagerKlassr= r r r r : s ÿ ÿÿz FastCGIProcessGroup.__init__N©r· r¸ r¹ r r r r r rÕ 8 s rÕ c @ s^ e Zd Zdd Zdd Zdd Zdd Zd d
Zdd d
Zdd Z dd Z
dd Z dd Z dS )ÚEventListenerPoolc C s0 t | |¡ g | _d| _d| _d| _| ¡ d S )Néÿÿÿÿr )rÄ r Ú event_bufferÚserialÚ
last_dispatchÚdispatch_throttleÚ
_subscriber r r r r J s zEventListenerPool.__init__c C s, |j }| j ¡ }||kr(| j|jdd d S )NT©Úhead)rÈ rÅ r Ú _acceptEventrL )r rL rÈ Zprocsr r r Úhandle_rejectedR s
z!EventListenerPool.handle_rejectedc C s~ | j ¡ }d}|D ](}| ¡ |jtjkr|jtjkrd}q|rz| j rrt
¡ }|| j k r^|| _ || j | j k rrd S | ¡ d S )NFT)
rÅ r r¶ r r r r» r ÚREADYrÞ rH rÝ Údispatch)r rÅ Zdispatch_capablerÈ rM r r r r¶ Y s
z EventListenerPool.transitionc C s | ¡ d S r% )Ú _unsubscriber r r r rÓ p s z EventListenerPool.before_removec C s@ | j r2| j d¡}| |¡}|s | j|dd q2q t ¡ | _d S )Nr Trà )rÛ ÚpopÚ_dispatchEventrâ rH rÝ )r rL Úokr r r rå s s
zEventListenerPool.dispatchFc C sÜ t | jj}t|ds tt|_t|ds0i |_| jj|jkrRt| |j| jj< n(| jjj
d|j|t | j | jj
f ¡ t | j | jj
kr¸| j r¸| j d¡}| jjj d||jf ¡ |rÌ| j d|¡ n | j |¡ d S )NrÜ Ú pool_serialsz6rebuffering event %s for pool %s (buf size=%d, max=%d)r z4pool %s event buffer overflowed, discarding event %s)r r rQ r! Ú
new_serialÚ GlobalSerialrÜ rê r8 rV r ÚlenrÛ Z buffer_sizerç r ÚinsertÚappend)r rL rá rS Zdiscarded_eventr r r râ s2
ÿÿÿ
ÿÿz EventListenerPool._acceptEventc
C s |j | jj }| j ¡ D ]æ}|jtjkr*q|jt j
krt |jj}| ¡ }z.|j
}|j}| ||||¡}| t|¡ W nV tk
rÎ } z8| jd tjkr | jjj d|j|f ¡ W Y ¢qW 5 d } ~ X Y nX t j|_||_| jjj d|j|f ¡ dS qdS )Nr zNepipe occurred while sending event %s to listener %s, listener state unchangedz event %s sent to listener %sTF)rê r rQ rÅ r r r r r» r rä r ÚpayloadrÆ rÜ Ú_eventEnveloper2 r r, rc r- r. r8 rV r ZBUSYrL )
r rL Ú pool_serialrÈ rS rð Ú
event_typerÜ Zenveloperl r r r rè sH ÿ
ÿÿÿ
ÿÿz EventListenerPool._dispatchEventc C s: t |¡}t|}d| jjj|| jj||||d}d| S )Nz3.0)ZverZsidrÜ Z pool_namerò Ú
event_namerí rð zver:%(ver)s server:%(sid)s serial:%(serial)s pool:%(pool_name)s poolserial:%(pool_serial)s eventname:%(event_name)s len:%(len)s
%(payload)s)r ZgetEventNameByTyperí r r8 Z
identifierrQ )r ró rÜ rò rð rô Z payload_lenÚDr r r rñ ¾ s
ø
þz EventListenerPool._eventEnvelopec C s0 | j jD ]}t || j¡ qt tj| j¡ d S r% )r Ú pool_eventsr Z subscriberâ r§ rã ©r ró r r r rß Ï s z EventListenerPool._subscribec C s0 | j jD ]}t || j¡ qt tj| j¡ d S r% )r rö r Z unsubscriberâ r§ rã r÷ r r r ræ Ô s z EventListenerPool._unsubscribeN)F)
r· r¸ r¹ r rã r¶ rÓ rå râ rè rñ rß ræ r r r r rÙ I s
"rÙ c @ s e Zd Zdd ZdS )rì c C s
d| _ d S )NrÚ )rÜ r r r r r Û s zGlobalSerial.__init__NrØ r r r r rì Ú s rì c C s$ | j tkrd| _ | j d7 _ | j S )NrÚ rC )rÜ r )Úinstr r r rë à s
rë )+r: rH r- r4 r r¤ Ú functoolsr Zsupervisor.compatr r r r Zsupervisor.medusar r Zsupervisor.statesr r r
r Zsupervisor.optionsr r
r r Zsupervisor.dispatchersr Z
supervisorr Zsupervisor.datatypesr Zsupervisor.socket_managerr Úobjectr r¼ rÄ rÔ rÕ rÙ rì rë r r r r Ú<module> sN =>