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
*Å]z ã @ sì d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZz d dlZW n e k
rh d dl
ZY nX d dl m Z d dl m
Z
d dl mZ d dl mZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ G d
d dZG dd dZG dd dZ G dd dZ G dd dZ G dd dej Z G dd dej!Z"G dd d ejZ#G d d d e#Z$G d d d e#Z%G d!d" d"Z&G d#d$ d$Z'G d%d& d&Z(d'd( Z)G d)d* d*Z*G d+d, d,Z+G d-d. d.eZ,dS )/é N)Úurllib)Úsha1)Úas_bytes)Ú as_string)Ú asyncore_25)Ú http_date)Ú http_server)Ú producers)Úfilesys)Údefault_handler)Ú auth_handlerc @ s e Zd ZdS )Ú NOT_DONE_YETN)Ú__name__Ú
__module__Ú __qualname__© r r ú ./build/lib/supervisor/http.pyr
s r
c @ s" e Zd ZdZdddZdd ZdS )Údeferring_chunked_producera' A producer that implements the 'chunked' transfer coding for HTTP/1.1.
Here is a sample usage:
request['Transfer-Encoding'] = 'chunked'
request.push (
producers.chunked_producer (your_producer)
)
request.done()
Nc C s || _ || _d| _d S ©N皙¹?)ÚproducerÚfootersÚdelay)Úselfr r r r r Ú__init__) s z#deferring_chunked_producer.__init__c C sp | j rh| j ¡ }|tkr tS |r@dt| }t|d | d S d | _ | jrbd dg| j ¡d S dS ndS d S )Nz%xs
ó 0s
s 0
ó )r Úmorer
Úlenr r Újoin)r ÚdataÚsr r r r . s
z deferring_chunked_producer.more)N©r r r Ú__doc__r r r r r r r s
r c @ s e Zd ZdZdd Zdd ZdS )Ú deferring_composite_producerz$combine a fifo of producers into onec C s || _ d| _d S r )r r )r r r r r r A s z%deferring_composite_producer.__init__c C sB t | jr>| jd }| ¡ }|tkr(tS |r0|S | j d¡ q dS )Nr r )r r r r
Úpop)r ÚpÚdr r r r E s
z!deferring_composite_producer.moreNr" r r r r r$ ? s r$ c @ s" e Zd ZdZdddZdd ZdS ) Údeferring_globbing_producerzÌ
'glob' the output from a producer into a particular buffer size.
helps reduce the number of calls to send(). [this appears to
gain about 30% performance on requests to a single channel]
é c C s || _ d| _|| _d| _d S )Nr r )r ÚbufferÚ buffer_sizer )r r r+ r r r r Z s z$deferring_globbing_producer.__init__c C sz t | j| jk rj| j ¡ }|tkr&tS |rjz| j| | _W qh tk
rb t| jt| | _Y qhX q qjq | j}d| _|S ©Nr )r r* r+ r r r
Ú TypeErrorr )r r Úrr r r r ` s
z deferring_globbing_producer.moreN)r) r" r r r r r( S s
r( c @ s e Zd ZdZdd Zdd ZdS )Údeferring_hooked_producerz¨
A producer that will call <function> when it empties,.
with an argument of the number of bytes produced. Useful
for logging/instrumentation purposes.
c C s || _ || _d| _d| _d S )Nr r )r ÚfunctionÚbytesr )r r r0 r r r r x s z"deferring_hooked_producer.__init__c C sR | j rJ| j ¡ }|tkr tS |s4d | _ | | j¡ n| jt|7 _|S dS d S r, )r r r
r0 r1 r )r Úresultr r r r ~ s
z deferring_hooked_producer.moreNr" r r r r r/ q s r/ c @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) Údeferring_http_requesta The medusa http_request class uses the default set of producers in
medusa.producers. We can't use these because they don't know anything
about deferred responses, so we override various methods here. This was
added to support tail -f like behavior on the logtail handler c O sN t t j| j¡}| ¡ }d}d}d}| jdkrT|dkrNd| krDd}qRd| d< qºd}nf| jdkr¬|d krld}qºd| krºd
| kr| d
d ksªd}qº| jr¦d | d
< d}d}qºd}n| jd krºd}t | ¡ ¡}|rÔd | d< |rôt
t | j }t ||g}n| j
d|¡ t | j }t|| j}|r&t|}| j |¡ d | j_|rJ| j ¡ d S )
z I didn't want to override this, but there's no way around
it in order to support deferreds - CM
finalize this transaction - send output to the http channelr é z1.0z
keep-alivezContent-Lengthz
Keep-AliveZ
Connectionz1.1ÚclosezTransfer-EncodingZchunkedN)r Z
get_headerZ
CONNECTIONÚheaderÚlowerÚversionZ use_chunkedr Zsimple_producerZbuild_reply_headerr r$ ZoutgoingÚinsertr/ Úlogr( ÚchannelZpush_with_producerÚcurrent_requestÚclose_when_done) r ÚargÚkwÚ
connectionZclose_itZwrap_in_chunkingZglobbingZoutgoing_headerZoutgoing_producerr r r Údone s\
ÿÿ
ÿ zdeferring_http_request.donec C s\ | j jr"| j jd }| j jd }nd}d}| j jj |d|| t ¡ ¡| j| j|f ¡ dS )z We need to override this because UNIX domain sockets return
an empty string for the addr rather than a (host, port) combination r r4 Z localhostz%d - - [%s] "%s" %d %d
N) r; ÚaddrÚserverÚloggerr: Zlog_date_stringÚtimeÚrequestZ
reply_code)r r1 ÚhostÚportr r r r: æ s
ûþzdeferring_http_request.logc C s´ i }dddd}t ¡ }| ¡ \}}}}|r4|| }|rR|d dkrR|dd
}q4d|krdt |¡}|rt|dd
}| jj}| j ¡ |d < t |j
|d
< |j |d < |j |d < d
| j
|d< | jj|d< d|d< d| |d< t j t j ||d ¡¡|d< |r||d< d|d< | jjr*| jjd |d< nd|d< | jD ]v} | dd¡\}
} |
¡ }
| ¡ } |
|kr|| r|| || |
¡< n0dd |
d ¡¡ ¡ }
| r8|
|kr8| ||
< q8|S ) NZCONTENT_LENGTHZ CONTENT_TYPEZCONNECTION_TYPE)zcontent-lengthz content-typer@ r ú/r4 ú%ZREQUEST_METHODÚ SERVER_PORTÚ SERVER_NAMEZSERVER_SOFTWAREzHTTP/ZSERVER_PROTOCOLzchannel.creation_timeÚ Z SCRIPT_NAMEZ PATH_INFOZPATH_TRANSLATEDZ QUERY_STRINGzCGI/1.1ZGATEWAY_INTERFACEZ REMOTE_ADDRz 127.0.0.1ú:zHTTP_%sÚ_ú-)ÚosÚgetcwdÚ split_urir Úunquoter; rC ÚcommandÚupperÚstrrH Ú server_nameZ SERVER_IDENTr8 Z
creation_timeÚpathÚnormpathr rB r6 Úsplitr7 ÚstripÚget) r ÚenvZ
header2envZworkdirrY ÚparamsÚqueryÚfragmentrC r6 ÚkeyÚvaluer r r Úcgi_environmentú sX þ
ÿ
z&deferring_http_request.cgi_environmentc C s ddd}| ¡ }| d¡dks.| d¡dkr4d}nd }d
|kr\|d
¡ }t |¡\}}n|d ¡ }|d }|d
ks|| |kr|}n |d | }d||f }|dd
dkr¾|d
d
}|S )z Functionality that medusa's http request doesn't have; set an
attribute named 'server_url' on the request based on the Host: header
Z80Z443)ÚhttpÚhttpsZHTTPS)ZonZONZSERVER_PORT_SECUREÚ1rf re Z HTTP_HOSTrL rK NrN z%s://%séÿÿÿÿrI )rd r] r\ r Z splitport)r Z default_portÚenvironZprotocolrG ÚhostnamerH Z
server_urlr r r Úget_server_url/ s&
ÿ z%deferring_http_request.get_server_urlN)r r r r# rA r: rd rk r r r r r3 s
S5r3 c @ s2 e Zd ZdZdZdZd
ddZdd Zdd ZdS ) Údeferring_http_channeli r Nc C sL |d krt ¡ }| jr@|| j }|| jks2|dk r<|| _dS dS tj | ¡S )Nr TF)rE r Úlast_writable_checkr Ú http_channelÚwritable)r ZnowÚelapsedr r r ro U s
z deferring_http_channel.writablec C sª t | jr | j ¡ }|dkr8| js4| j ¡ | ¡ dS t|tr^| j ¡ | j|7 _dS | ¡ }|t krz|j
| _
dS |r| j| | _d| _
dS | j ¡ q dS q dS )z Implement deferreds NF) r Z
producer_fifoÚfirstZ
ac_out_bufferr% r5 Ú
isinstancer1 r r
r )r r& r r r r Ú
refill_bufferd s*
z$deferring_http_channel.refill_bufferc C s¸ | j r| j ¡ n t| j}d| _| d¡}|rH|d sH|dd
}q.|sX| ¡ dS |d }t |¡\}}}t |dd
¡}t |¡\}}d|krº|r°t
|¡d | }n
t
|¡}t | |||||} | j
¡ | jj
¡ |dkr| dt| d ¡ | d
¡ dS | jjD ]}
|
| ¡rz| | _ |
| ¡ W nd | jj
¡ t ¡ \\} } }
}}}| j d ||| |
f d ¡ z| d ¡ W n Y nX Y nX dS q| d
¡ dS )z We only override this to use 'deferring_http_request' class
instead of the normal http_request class; it sucks to need to override
this r z
r r4 NrJ ú?zBad HTTP request: %sÚerroré z'Server Error: %s, %s: file: %s line: %siô é )r< Úfound_terminatorr Z in_bufferr[ r= r Z
crack_requestZ join_headersZ
splitqueryrT r3 Zrequest_counterZ incrementrC Útotal_requestsÚlog_infoÚreprru ÚhandlersÚmatchÚhandle_requestÚ
exceptionsÚasyncoreZcompact_traceback)r r6 ÚlinesrF rU Úurir8 ZrpathZrqueryr. ÚhÚfileZfunÚlineÚtÚvZtbinfor r r rx s`
ÿ
ÿ
ÿý
z'deferring_http_channel.found_terminator)N) r r r Zac_out_buffer_sizer rm ro rs rx r r r r rl L s
rl c @ s. e Zd ZeZdZdd Zdd Zd ddZdS )
Úsupervisor_http_serverNc C s^ ddl m} |s | tj¡}| |¡}|| _tj | ¡ | |¡ g | _
| d¡ | ¡ dS )zj Override __init__ to do logger setup earlier so it can
go to our logger object instead of stdout r ©rD N)
Úsupervisor.medusarD Z file_loggerÚsysÚstdoutZunresolving_loggerr Ú
dispatcherr Z
set_socketr| Z setblockingZset_reuse_addr)r ÚsockÚ
logger_objectrD r r r ÚprebindØ s
z supervisor_http_server.prebindc C sr ddl m} ddlm} | d¡ | | _| | _| | _| | _| | _ |
d|t t ¡ ¡| j
| jf ¡ d S )Nr )Úcounter)ÚVERSION_STRINGé z2Medusa (V%s) started at %s
Hostname: %s
Port:%s
)Zsupervisor.medusa.counterr Z supervisor.medusa.http_serverr ZlistenZ
total_clientsry r Z bytes_outZbytes_inrz rE ÚctimerX rH )r r r r r r Úpostbindë s"
üýÿz supervisor_http_server.postbindÚinfoc C s, d}t | dd d k r| j}| j ||¡ d S )NrM Úip)Úgetattrr rD r: )r ÚmessageÚtyper r r r rz s z supervisor_http_server.log_info)r ) r r r rl Z
channel_classr r r rz r r r r r Ô s
r c @ s e Zd ZdZdd ZdS )Ú supervisor_af_inet_http_serverz+ AF_INET version of supervisor HTTP server c C sÊ || _ || _t tjtj¡}| ||¡ | ||f¡ |s| dd¡ t ¡ }zt |¡}W n" tj
k
r~ t d| Y nX zt |¡d | _
W n( tj
k
r¼ | dd¡ || _
Y nX | ¡ d S )NzComputing default hostnameZwarningzØCould not determine IP address for hostname %s, please try setting an explicit IP address in the "port" setting of your [inet_http_server] section. For example, instead of "port = 9001", try "port = 127.0.0.1:9001."r zCannot do reverse lookup)r rH ÚsocketÚAF_INETÚ SOCK_STREAMr Úbindrz Z gethostnameZ
gethostbynameru Ú
ValueErrorZ
gethostbyaddrrX r )r r rH r r rj r r r r s, üÿ
z'supervisor_af_inet_http_server.__init__N)r r r r# r r r r r r s r c @ s e Zd ZdZdd Zdd ZdS )Ú supervisor_af_unix_http_serverz+ AF_UNIX version of supervisor HTTP server c
C sÆ || _ || _d|t ¡ f }zt |¡ W n tk
r> Y nX t tjtj¡}z6| |¡ t
||¡ zt ||¡ W nx tk
rò | |¡}|r¤t
tj¡d| }tj |¡ zt |¡ W n Y nX | ¡ t d¡ Y W ¢q@Y nX zt ||d |d ¡ W nb tk
rp } zB| jd tjkr^d}t||t|t t ¡ ¡d f n W 5 d } ~ X Y nX | ||¡ W ¢q´W 5 zt |¡ W n tk
r® Y nX X q@d| _ | ¡ d S )Nz%s.%dzUnlinking stale socket %s
g333333Ó?r r4 zNot permitted to chown %s to uid/gid %s; adjust "sockchown" value in config file or on command line to values that the current user (%s) can successfully chownz<unix domain socket>)!r rH rQ ÚgetpidÚunlinkÚOSErrorr ÚAF_UNIXr r ÚchmodÚlinkÚ checkusedru ÚerrnoZ
EADDRINUSEr ÚstderrÚwriter5 rE ÚsleepÚchownÚargsZEPERMr r{ ÚpwdÚgetpwuidÚgeteuidr rX r )
r Ú
socketnameÚ sockchmodÚ sockchownr Ztempnamer ZusedÚmsgZwhyr r r r * s`
ÿÿþ
z'supervisor_af_unix_http_server.__init__c C s` t t jt j¡}z.| |¡ | td¡ | d¡ | ¡ W n t jk
rV Y dS X dS d S )NzGET / HTTP/1.0
r4 FT) r r¥ r ZconnectÚsendr Zrecvr5 ru )r r² r! r r r r¨ q s
z(supervisor_af_unix_http_server.checkusedN)r r r r# r r¨ r r r r r¡ ' s Gr¡ c @ sD e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dS )Útail_f_producerc C s> t |¡| _|| _d| _| ¡ | ¡ }||kr:|| | _d S r )ÚweakrefÚrefrF Úfilenamer Ú_openÚ_fsizeÚsz)r rF rº Úheadr½ r r r r ~ s ztail_f_producer.__init__c C s | ¡ d S ©N)Ú_close©r r r r Ú__del__ s ztail_f_producer.__del__c C s~ | ¡ z | ¡ }W n ttfk
r. Y dS X || j }|dk rLd| _dS |dkrz| j | d¡ | j |¡}|| _|S tS )Nr r z==> File truncated <==
é ) Ú_followr¼ r¤ r r½ r ÚseekÚreadr
)r ZnewszZ bytes_addedr1 r r r r s
ztail_f_producer.morec C s0 t | jd| _t | j ¡ ¡tj | _d| _ d S )NÚrbr )
Úopenrº r rQ ÚfstatÚfilenoÚstatÚST_INOÚinor½ rÁ r r r r» s ztail_f_producer._openc C s | j ¡ d S r¿ )r r5 rÁ r r r rÀ ¢ s ztail_f_producer._closec C sP zt | j¡tj }W n ttfk
r0 Y d S X | j|krL| ¡ | ¡ d S r¿ ) rQ rË rº rÌ r¤ r rÍ rÀ r» )r rÍ r r r rÄ ¥ s
ztail_f_producer._followc C s t | j ¡ ¡tj S r¿ )rQ rÉ r rÊ rË ÚST_SIZErÁ r r r r¼ ° s ztail_f_producer._fsizeN)
r r r r r r r» rÀ rÄ r¼ r r r r r· } s
r· c @ s, e Zd ZdZdZdd Zdd Zdd Zd S )
Úlogtail_handlerz Logtail HTTP Request Handlerz/logtailc C s
|| _ d S r¿ ©Ú supervisord©r rÑ r r r r · s zlogtail_handler.__init__c C s |j | j¡S r¿ ©r Ú
startswithrY ©r rF r r r r} º s zlogtail_handler.matchc C st |j dkr| d¡ d S | ¡ \}}}}d|kr:t |¡}|rX|d dkrX|dd
}q:| dd¡\}}z| dd¡\}}W n tk
r |}d}Y nX ddlm} | |\}
}| j j
|
¡} | d krÖ| d ¡ d S | j |¡} | d krø| d ¡ d S t
| jd
| d }
|
d ks"tj |
¡s0| d ¡ d S t |
¡tj }t |¡|d < d
|d< | t||
d¡ | ¡ d S )NÚGETrv rJ r rI r4 r )Úsplit_namespecrw z
%s_logfileé ú
Last-Modifiedútext/plain;charset=utf-8ú Content-Typer )rU ru rS r rT r[ r Zsupervisor.optionsr× rÑ Zprocess_groupsr] Z processesr ÚconfigrQ rY ÚexistsrË ÚST_MTIMEr Úbuild_http_dateÚpushr· rA )r rF rY r_ r` ra Zprocess_name_and_channelZ process_namer; r× Z
group_nameÚgroupZprocessÚlogfileÚmtimer r r r~ ½ sB
z logtail_handler.handle_requestN©r r r ZIDENTrY r r} r~ r r r r rÏ ³ s
rÏ c @ s, e Zd ZdZdZdd Zdd Zdd Zd S )
Úmainlogtail_handlerz!Main Logtail HTTP Request Handlerz /mainlogtailc C s
|| _ d S r¿ rÐ rÒ r r r r ø s z mainlogtail_handler.__init__c C s |j | j¡S r¿ rÓ rÕ r r r r} û s zmainlogtail_handler.matchc C s |j dkr| d¡ d S | jjj}|d ks6tj |¡sD| d¡ d S t |¡tj }t
|¡|d< d|d< | t
||d¡ | ¡ d S )NrÖ rv rØ rÙ rÚ rÛ r )rU ru rÑ Úoptionsrâ rQ rY rÝ rË rÞ r rß rà r· rA )r rF râ rã r r r r~ þ s
z"mainlogtail_handler.handle_requestNrä r r r r rå ô s
rå c C s: g }t | j}| jD ] }|d }|tjkrN|d |d }}t|||d}n@|tjkr|d } |d }
|d } t| |
| |d}n td| d d
l m
} d d l m }
d d l m
} g }| jD ]f\}}}z||f|}W n, t ¡ }| j |¡ td
| Y nX | ||f¡ | j d| ¡ q¼| d|
|f¡ | ||}t|}t|}||}tj tj t¡¡}tj |d¡}t |¡}t |¡} |d } |d } | rà| | i} t | |}t | |}t | |}t | |}t | | } n| j d|d ¡ | !| ¡ | !|¡ | !|¡ | !|¡ | !|¡ | ||f¡ q|S )NÚfamilyrG rH )r r r¦ r z Cannot determine socket type %rr )Úsupervisor_xmlrpc_handler)ÚSystemNamespaceRPCInterface)Úsupervisor_ui_handlerz Could not make %s rpc interfacez RPC interface %r initializedÚsystemZuiÚusernameÚpasswordz:Server %r running without any HTTP authentication checkingZsection)"Ú
LogWrapperrD Zserver_configsr r r r¥ r¡ r Zsupervisor.xmlrpcrè ré Zsupervisor.webrê Zrpcinterface_factoriesÚ tracebackÚ
format_excÚwarnÚappendr rÏ rå rQ rY ÚabspathÚdirnameÚ__file__r r
Z
os_filesystemr Úsupervisor_auth_handlerZcriticalZinstall_handler) ræ rÑ ZserversÚwrapperrÜ rç rG rH Zhsr² r³ r´ rè ré rê Z
subinterfacesÚnameÚfactoryr' ÚinstÚtbZ
xmlrpchandlerZ tailhandlerZmaintailhandlerZ uihandlerÚhereZ templatedirZ
filesystemZdefaulthandlerrì rí Zusersr r r Úmake_http_servers s|
ÿ
ÿ ÿ
ÿÿ
rý c @ s e Zd ZdZdd Zdd ZdS )rî z\Receives log messages from the Medusa servers and forwards
them to the Supervisor loggerc C s
|| _ d S r¿ r )r rD r r r r _ s zLogWrapper.__init__c C s@ | d¡r|dd
}d| ¡ kr0| j |¡ n | j |¡ dS )z¼Medusa servers call this method. There is no log level so
we have to sniff the message. We want "Server Error" messages
from medusa.http_server logged as errors at least.Ú
Nrh ru )Úendswithr7 rD ru Ztrace)r rµ r r r r: b s
zLogWrapper.logN)r r r r# r r: r r r r rî \ s rî c @ s e Zd Zdd Zdd ZdS )Ú encrypted_dictionary_authorizerc C s
|| _ d S r¿ )Údict)r r r r r r n s z(encrypted_dictionary_authorizer.__init__c C sX |\}}|| j krP| j | }| d¡rFtt| ¡ }|dd
|kS ||kS ndS d S )Nz{SHA}é F)r rÔ r r Z hexdigest)r Z auth_inforì rí Zstored_passwordZ
password_hashr r r Ú authorizeq s
z)encrypted_dictionary_authorizer.authorizeN)r r r r r r r r r r m s r c @ s e Zd ZdddZdS )rö Údefaultc C s t | |||¡ t|| _d S r¿ )r r r Z
authorizer)r r ZhandlerZrealmr r r r ~ s z supervisor_auth_handler.__init__N)r )r r r r r r r r rö } s rö )-rQ rË rE r r r© r¸ rï r¯ Ú ImportErrorZgetpassZsupervisor.compatr r r r r r r r r r r
r Z supervisor.medusa.auth_handlerr r
r r$ r( r/ Z http_requestr3 rn rl r r r¡ r· rÏ rå rý rî r rö r r r r Ú<module> sR @ 5 V6A I