Edit File: http.cpython-36.pyc
3 �k�`p{ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZy 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� d�ZG dd� d�ZG dd� d�Z G dd� d�Z G dd� d�Z G dd� dej �Z G dd� dej!�Z"G dd � d ej�Z#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.e�Z,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 �/usr/lib/python3.6/http.pyr s r c @ s" e Zd ZdZddd�Zdd� 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 )Ng�������?)�producer�footers�delay)�selfr r r r r �__init__) s z#deferring_chunked_producer.__init__c C sp | j rh| j j� }|tkr tS |r@dt|� }t|�d | d S d | _ | jrbdjdg| 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 )Ng�������?)r r )r r r r r r A s z%deferring_composite_producer.__init__c C sJ xDt | j�r@| jd }|j� }|tkr*tS |r2|S | jjd� qW dS d S )Nr r )r r r r �pop)r �p�dr r r r E s z!deferring_composite_producer.moreN)r r r r r r r r r r r! ? s r! c @ s" e Zd ZdZd dd�Zdd� 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 g�������?)r �buffer� buffer_sizer )r r r) r r r r Z s z$deferring_globbing_producer.__init__c C s~ xlt | j�| jk rl| jj� }|tkr(tS |rhy| j| | _W qj tk rd t| j�t|� | _Y qjX qP qW | 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 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 g�������?)r �function�bytesr )r r r. r r r r x s z"deferring_hooked_producer.__init__c C sR | j rJ| j j� }|tkr tS |s4d | _ | j| j� n| jt|�7 _|S dS d S )Nr )r r r r. r/ r )r �resultr r r r ~ s z deferring_hooked_producer.moreN)r r r r r r 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 jt j| 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}tj| j � �}|r�d | d< |r�t t | j ��}t ||g�}n| j j d|� t | j �}t|| j�}|�r&t|�}| jj|� d | j_|�rJ| jj� 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 r& 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� sV zdeferring_http_request.donec C s\ | j jr"| j jd }| j jd }nd}d}| j jjj|d|| jtj� �| 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 r& Z localhostz%d - - [%s] "%s" %d %d N) r8 �addr�server�loggerr7 Zlog_date_string�time�requestZ reply_code)r r/ �host�portr r r r7 � s zdeferring_http_request.logc C s� i }dddd�}t j� }| j� \}}}}|r4|| }x |rT|d dkrT|dd � }q6W d|krhtj|�}|rx|dd � }| jj}| jj� |d < t |j �|d < |j |d < |j |d < d | j |d< | jj|d< d|d< d| |d< t jjt jj||d ��|d< |�r ||d< d|d< | jj�r.| jjd |d< nd|d< x�| jD ]v} | jdd�\} } | j� } | j� } | |k�r�| �r�| ||j| �< n0ddj| jd ��j� } | �r>| |k�r>| || < �q>W |S ) NZCONTENT_LENGTHZ CONTENT_TYPEZCONNECTION_TYPE)zcontent-lengthz content-typer= r �/r& �%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 �unquoter8 r@ �command�upper�strrE � server_nameZ SERVER_IDENTr5 Z creation_time�path�normpathr r? r3 �splitr4 �strip�get) r �envZ header2envZworkdirrV �params�query�fragmentr@ r3 �key�valuer r r �cgi_environment� sR z&deferring_http_request.cgi_environmentc C s� ddd�}| j � }|jd�dks.|jd�dkr4d }nd }d |kr\|d j� }tj|�\}}n|d j� }|d }|dks�|| |kr�|}n |d | }d||f }|dd� dkr�|dd� }|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�on�ONZSERVER_PORT_SECURE�1rc rb Z HTTP_HOSTrI rH NrK z%s://%sr& rF )rd re ���rg )ra rZ rY r Z splitport)r Z default_port�environZprotocolrD �hostnamerE Z server_urlr r r �get_server_url/ s$ z%deferring_http_request.get_server_urlN)r r r r r> r7 ra rj r r r r r1 � s S5r1 c @ s2 e Zd ZdZdZdZd dd�Zdd� Zdd � ZdS ) �deferring_http_channeli r Nc C sL |d krt j � }| jr@|| j }|| jks2|dk r<|| _dS dS tjj| �S )Nr TF)rB r �last_writable_checkr � http_channel�writable)r Znow�elapsedr r r rn U s z deferring_http_channel.writablec C s� x�t | j�r�| jj� }|dkr:| js6| jj� | j� dS t|t�r`| jj� | j|7 _dS |j� }|t kr||j | _ dS |r�| j| | _d| _ dS | jj� qdS qW dS )z Implement deferreds NF) r Z producer_fifo�firstZ ac_out_bufferr" r2 � isinstancer/ r r r )r r# r r r r � refill_bufferd s, z$deferring_http_channel.refill_bufferc C s� | j r| j j� �n�t| j�}d| _|jd�}x |rL|d rL|dd� }q0W |s^| j� dS |d }tj|�\}}}tj|dd� �}tj |�\}}d|kr�|r�tj |�d | }n tj |�}t | |||||�} | j j � | jjj � |dk�r| jdt|� d � | jd � dS x�| jjD ]�} | j| ��r y| | _ | j| � W nd | jjj � tj� \\} } } }}}| jjd ||| | f d � y| jd � W n Y nX Y nX dS �q W | jd � 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 r& NrG �?zBad HTTP request: %s�errori� z'Server Error: %s, %s: file: %s line: %si� i� )r9 �found_terminatorr Z in_bufferrX r: r Z crack_requestZ join_headersZ splitqueryrQ r1 Zrequest_counterZ incrementr@ �total_requests�log_info�reprrt �handlers�match�handle_request� exceptions�asyncoreZcompact_traceback)r r3 �linesrC rR �urir5 ZrpathZrqueryr+ �h�fileZfun�line�t�vZtbinfor r r ru � sX z'deferring_http_channel.found_terminator)N) r r r Zac_out_buffer_sizer rl rn rr ru r r r r rk L s rk c @ s. e Zd ZeZdZdd� Zdd� Zd dd�ZdS ) �supervisor_http_serverNc C s^ ddl m} |s |jtj�}|j|�}|| _tjj| � | j |� g | _ |j d� | j � dS )zj Override __init__ to do logger setup earlier so it can go to our logger object instead of stdout r )rA N) �supervisor.medusarA Z file_logger�sys�stdoutZunresolving_loggerr} Z dispatcherr Z set_socketry Z setblockingZset_reuse_addr)r �sock� logger_objectrA r r r �prebind� s z supervisor_http_server.prebindc C sr ddl m} ddlm} | jd� |� | _|� | _|� | _|� | _|� | _ | j d|t j t j � �| j | jf � d S )Nr )�counter)�VERSION_STRINGi z2Medusa (V%s) started at %s Hostname: %s Port:%s )Zsupervisor.medusa.counterr� Z supervisor.medusa.http_serverr� ZlistenZ total_clientsrv r| Z bytes_outZbytes_inrw rB ZctimerU rE )r r� r� r r r �postbind� s z supervisor_http_server.postbind�infoc C s, d}t | dd �d k r| j}| jj||� d S )NrJ �ip)�getattrr� rA r7 )r �message�typer� r r r rw s z supervisor_http_server.log_info)r� ) r r r rk Z channel_classr� r� r� rw 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� || _ || _tjtjtj�}| j||� | j||f� |s�| jdd� tj� }ytj |�}W n" tj k r~ t d| ��Y nX ytj |�d | _ W n( tj k r� | jdd� || _ Y nX | j� 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� rE �socket�AF_INET� SOCK_STREAMr� �bindrw Z gethostnameZ gethostbynamert � ValueErrorZ gethostbyaddrrU r� )r r� rE r� r� ri 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 0 C s� || _ || _d|tj� f }ytj|� W n tk r> Y nX �xjtjtjtj�}�z*|j |� tj ||� ytj ||� W nr tk r� | j |�}|r�tj tj��d| }tjj|� ytj|� W n Y nX |j� tjd� wDY n�X ytj||d |d � W nb tk �rn } zD| jd tjk�r\d}t||t|�tj tj � �d f ��n� W Y d d } ~ X nX | j ||� P W d ytj|� W n tk �r� Y nX X qDW d| _ | j � d S )Nz%s.%dzUnlinking stale socket %s g333333�?r r& z�Not 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� rE rN �getpid�unlink�OSErrorr� �AF_UNIXr� r� �chmod�link� checkusedrt �errnoZ EADDRINUSEr� �stderr�writer2 rB Zsleep�chown�argsZEPERMr� rx �pwd�getpwuid�geteuidr� rU r� ) r � socketname� sockchmod� sockchownr� Ztempnamer� Zused�msgZwhyr r r r * sZ z'supervisor_af_unix_http_server.__init__c C s^ t j t jt j�}y.|j|� |jtd�� |jd� |j� W n t jk rT dS X dS d S )NzGET / HTTP/1.0 r& FT) r� r� r� Zconnect�sendr Zrecvr2 rt )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 j|�| _|| _d| _| j� | j� }||kr:|| | _d S )Ng�������?)�weakref�refrC �filenamer �_open�_fsize�sz)r rC r� �headr� r r r r ~ s ztail_f_producer.__init__c C s | j � d S )N)�_close)r r r r �__del__� s ztail_f_producer.__del__c C s| | j � y | j� }W n ttfk r, dS X || j }|dk rJd| _dS |dkrx| jj| d� | jj|�}|| _|S tS )Nr r z==> File truncated <== � ) �_followr� r� r� r� r� �seek�readr )r ZnewszZ bytes_addedr/ r r r r � s ztail_f_producer.morec C s0 t | jd�| _tj| jj� �tj | _d| _ d S )N�rbr ) �openr� r� rN �fstat�fileno�stat�ST_INO�inor� )r r r r r� � s ztail_f_producer._openc C s | j j� d S )N)r� r2 )r r r r r� � s ztail_f_producer._closec C sN yt j| j�tj }W n ttfk r. d S X | j|krJ| j� | j� d S )N) rN r� r� r� r� r� r� r� r� )r r� r r r r� � s ztail_f_producer._followc C s t j| jj� �tj S )N)rN r� r� r� r� �ST_SIZE)r 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 )N)� supervisord)r r� r r r r � s zlogtail_handler.__init__c C s |j j| j�S )N)r � startswithrV )r rC r r r rz � s zlogtail_handler.matchc C s� |j dkr|jd� d S |j� \}}}}d|kr:tj|�}x |rZ|d dkrZ|dd � }q<W |jdd�\}}y|jdd�\}}W n tk r� |}d}Y nX ddlm} | |�\} }| j j j | �} | d kr�|jd � d S | j j |�} | d kr�|jd � d S t | jd | d �} | d k�s(tjj| � �r6|jd � d S tj| �tj }tj|�|d < d |d< d|d< |jt|| d�� |j� d S )N�GETi� rG r rF r& r� )�split_namespeci� z %s_logfilei� z Last-Modifiedztext/plain;charset=utf-8z Content-Type�nozX-Accel-Bufferingi )rR rt rP r rQ rX r� Zsupervisor.optionsr� r� Zprocess_groupsrZ Z processesr� �configrN rV �existsr� �ST_MTIMEr �build_http_date�pushr� r> )r rC rV r\ r] r^ Zprocess_name_and_channelZ process_namer8 r� Z group_name�groupZprocess�logfile�mtimer r r r{ � sD z logtail_handler.handle_requestN)r r r �IDENTrV r rz 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 )N)r� )r r� r r r r � s z mainlogtail_handler.__init__c C s |j j| j�S )N)r r� rV )r rC r r r rz � s zmainlogtail_handler.matchc C s� |j dkr|jd� d S | jjj}|d ks8tjj|� rF|jd� d S tj|�tj }t j |�|d< d|d< |j t ||d�� |j� d S )Nr� i� i� z Last-Modifiedztext/plain;charset=utf-8z Content-Typei )rR rt r� �optionsr� rN rV r� r� r� r r� r� r� r> )r rC r� r� r r r r{ s z"mainlogtail_handler.handle_requestN)r r r r� rV r rz r{ r r r r r� � s r� c C sD g }t | j�}�x.| jD �]"}|d }|tjkrR|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 }xp| jD ]f\}}}y||f|�}W n, tj� }| jj|� td | ��Y nX |j||f� | jjd| � q�W |jd| |�f� | ||�}t|�}t|�}||�}tjjtjjt��}tjj|d�}t j |�}t j |�} |d } |d } | �r�| | i} t | |�}t | |�}t | |�}t | |�}t | | �} n| jj d|d � |j!| � |j!|� |j!|� |j!|� |j!|� |j||f� qW |S )N�familyrD rE )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)"� LogWrapperrA Zserver_configsr� r� r� r� r� r� Zsupervisor.xmlrpcr� r� Zsupervisor.webr� Zrpcinterface_factories� traceback� format_exc�warn�appendr� r� r� rN rV �abspath�dirname�__file__r r Z os_filesystemr �supervisor_auth_handlerZcriticalZinstall_handler) r� r� Zservers�wrapperr� r� rD rE Zhsr� r� r� r� r� r� Z subinterfaces�name�factoryr$ Zinst�tbZ xmlrpchandlerZ tailhandlerZmaintailhandlerZ uihandler�hereZ templatedirZ filesystemZdefaulthandlerr� r� Zusersr r r �make_http_servers sr 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 )N)rA )r rA r r r r b s zLogWrapper.__init__c C s@ |j d�r|dd� }d|j� kr0| jj|� n | jj|� 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.� Nr& rt rg )�endswithr4 rA rt Ztrace)r r� r r r r7 e s zLogWrapper.logN)r r r r r r7 r r r r r� _ s r� c @ s e Zd Zdd� Zdd� ZdS )� encrypted_dictionary_authorizerc C s || _ d S )N)�dict)r r� r r r r q s z(encrypted_dictionary_authorizer.__init__c C sX |\}}|| j krP| j | }|jd�rFtt|��j� }|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 � authorizet s z)encrypted_dictionary_authorizer.authorizeN)r r r r r� r r r r r� p s r� c @ s e Zd Zddd�ZdS )r� �defaultc C s t j| |||� t|�| _d S )N)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� )-rN r� rB 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_requestr1 rm rk r� r� r� r� r� r� r� r� r� r� r r r r �<module> sR @ 5 V6D I
Back to File Manager