File: //usr/lib/python3.6/site-packages/supervisor/medusa/__pycache__/xmlrpc_handler.cpython-36.opt-1.pyc
3
�k�`? �
@ s� d Z ddlmZ ddljjZy ddlZW n ddljZY nX ddl Z G dd� d�Z
G dd� d�Z e dkr�G d d
� d
e
�Z
ddljjZejd d �Ze
� Zeje� ej� dS )
z@$Id: xmlrpc_handler.py,v 1.6 2004/04/21 14:09:24 akuchling Exp $� )� as_stringNc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�xmlrpc_handlerc C s |j d d� dkrdS dS d S )N� z/RPC2� r )Zuri)�self�request� r �$/usr/lib/python3.6/xmlrpc_handler.py�match s zxmlrpc_handler.matchc C s& |j dkrt| |�|_n
|jd� d S )NZPOSTi� )Zcommand� collector�error)r r r r r �handle_request s
z xmlrpc_handler.handle_requestc C s� t j|�\}}ypy&| j||�}t|�tf �kr4|f}W n6 t jt jddtj� d tj� d f ��}Y nX t j|dd�}W n |jd� Y n X d|d< |j |� |j
� d S )Nr z%s:%sr )Zmethodresponsei� ztext/xmlz Content-Type) � xmlrpclib�loads�call�type�dumpsZFault�sys�exc_infor �push�done)r �datar �params�methodZresponser r r �continue_request# s
,
z xmlrpc_handler.continue_requestc C s t d��d S )NZNotYetImplemented)� Exception)r r r r r r r ; s zxmlrpc_handler.callN)�__name__�
__module__� __qualname__r
r
r r r r r r r s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r z'gathers input for POST and PUT requestsc C sF || _ || _g | _|jd�}|s,|jd� nt|�}| jjj|� d S )Nzcontent-lengthi� )�handlerr r Z
get_headerr �int�channel�set_terminator)r r r Zclr r r �__init__C s
zcollector.__init__c C s | j j|� d S )N)r �append)r r r r r �collect_incoming_dataS s z collector.collect_incoming_datac C s2 | j jjd� tdj| j��}| jj|| j � d S )Ns
� )r r! r" r �joinr r r )r r r r r �found_terminatorV s zcollector.found_terminatorN)r r r �__doc__r# r% r( r r r r r ? s r �__main__c @ s e Zd Zdd� ZdS )�rpc_democ C s t d||f � dS )Nzmethod="%s" params=%szSure, that works)�print)r r r r r r r a s z
rpc_demo.callN)r r r r r r r r r+ _ s r+ � i@ )�VERSIONZsupervisor.compatr Z supervisor.medusa.http_serverZmedusaZ http_serverr Z
xmlrpc.clientZclientr r r r r+ Z supervisor.medusa.asyncore_25Z asyncore_25ZasyncoreZhsZrpcZinstall_handlerZloopr r r r �<module> s +