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
VƧ\
ã @ s® d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z dd Z d
d Z
d d
Zdd ZdddZG dd dZe ZG dd dZe ZdS )é N)Ú xmlrpclib)Úlong)Ú as_string)ÚSupervisorTransport)ÚProcessCommunicationEvent)ÚPEventListenerDispatcherc C s( | dd¡}| dd¡}t||| d S )NZSUPERVISOR_USERNAMEÚ ZSUPERVISOR_PASSWORDZSUPERVISOR_SERVER_URL)Úgetr )ÚenvÚuÚp© r
ú$./build/lib/supervisor/childutils.pyÚgetRPCTransport s r c C s t dt| ¡S )Nzhttp://127.0.0.1)r Z ServerProxyr )r
r
r
r ÚgetRPCInterface s r c C s t dd | ¡ D S )Nc S s g | ]}| d ¡qS )ú:)Úsplit)Ú.0Úxr
r
r Ú
<listcomp> s z get_headers.<locals>.<listcomp>)Údictr )Úliner
r
r Ú get_headers s r c C s | dd¡\}}t|}||fS )NÚ
é )r r )ÚpayloadZ
headerinfoÚdataÚheadersr
r
r Ú eventdata s r c C sB | d krt ¡ } | t| d }t dt | ¡¡}d||f }|S )Niè z%Y-%m-%d %H:%M:%Sz%s,%03d)Útimer ÚstrftimeÚ localtime)ZnowZmsecsZpart1Úasctimer
r
r Ú get_asctime s r# c @ s* e Zd ZejfddZdd Zdd ZdS )Ú ProcessCommunicationsProtocolc C s. | tj¡ | |¡ | tj¡ | ¡ d S ©N)Úwriter Z BEGIN_TOKENZ END_TOKENÚflush)ÚselfÚmsgÚfpr
r
r Úsend( s
z"ProcessCommunicationsProtocol.sendc C s | |tj¡S r% )r+ ÚsysÚstdout©r( r) r
r
r r- . s z$ProcessCommunicationsProtocol.stdoutc C s | |tj¡S r% )r+ r, Ústderrr. r
r
r r/ 1 s z$ProcessCommunicationsProtocol.stderrN)Ú__name__Ú
__module__Ú __qualname__r, r- r+ r/ r
r
r
r r$ ' s r$ c @ sV e Zd ZejejfddZejfddZejfddZejfddZ ejfd d
Z
d S ) ÚEventListenerProtocolc C s4 | |¡ | ¡ }t|}| t|d ¡}||fS )NÚlen)ÚreadyÚreadliner ÚreadÚint)r( Ústdinr- r r r r
r
r Úwait7 s
zEventListenerProtocol.waitc C s | ttj¡ | ¡ d S r% )r& r r ZREADY_FOR_EVENTS_TOKENr' ©r( r- r
r
r r5 > s zEventListenerProtocol.readyc C s | d|¡ d S )NZOK©r+ r; r
r
r ÚokB s zEventListenerProtocol.okc C s | d|¡ d S )NZFAILr< r; r
r
r ÚfailE s zEventListenerProtocol.failc C s6 t |}dttjt||f }| |¡ | ¡ d S )Nz%s%s
%s)r4 r r ZRESULT_TOKEN_STARTÚstrr& r' )r( r r- Z resultlenÚresultr
r
r r+ H s
þ
zEventListenerProtocol.sendN) r0 r1 r2 r, r9 r- r: r5 r= r> r+ r
r
r
r r3 6 s
r3 )N)r, r Zsupervisor.compatr r r Zsupervisor.xmlrpcr Zsupervisor.eventsr Zsupervisor.dispatchersr r r r r r# r$ Zpcommr3 Zlistenerr
r
r
r Ú<module> s