Edit File: base.cpython-36.pyc
3 �k�`%� � @ sT d Z dZddlZddlZddlZddlmZ ddlmZ yddlm Z m Z m Z W n( e k rx ddl m Z m Z m Z Y nX yddlj Z W n e k r� ddl Z Y nX G dd� d�ZG d d � d �ZG d d � d �ZG d d� d�ZG dd� d�ZG dd� d�ZejG dd� de��ZG dd� d�ZdFdd�ZdGdd�ZG d d � d �ZG d d � d �ZG d d!� d!�Z G d"d#� d#e�Z G d$d%� d%�Z G d&d'� d'�Z G d(d)� d)�Z G d*d+� d+�Z!G d,d-� d-�Z"G d.d/� d/e"�Z#ejG d0d1� d1e��Z$G d2d3� d3e$�Z%G d4d5� d5e�Z&G d6d7� d7�Z'G d8d9� d9�Z(G d:d;� d;�Z)G d<d=� d=�Z*d>d?� Z+d@dA� Z,dBdC� Z-dDdE� Z.dS )Hi�p�Dz%b %d %I:%M %p� N)�Fault)�as_bytes)�Mock�patch�sentinelc @ s� e Zd ZdZdZdZdZdZdZdZ dZ dZ dd� Z dd� Z dd � ZdZd d �Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z d'd(� Z d)d*� Z d+d,� Z d-d.� Z d/d0� Z!d1d2� Z"d[d3d4�Z#d5d6� Z$d7d8� Z%d9d:� Z&d;d<� Z'd=d>� Z(d?d@� Z)dAdB� Z*dCdD� Z+dEdF� Z,dGdH� Z-dIdJ� Z.dKdL� Z/dMdN� Z0dOdP� Z1dQdR� Z2d\dTdU�Z3dVdW� Z4dXdY� Z5dS )]� DummyOptions� � Nc C s\ d| _ d| _d| _| j� | _d| _d| _d| _d| _i | _ g | _ d| _ i | _ d| _ d| _d | _d| _d| _d| _d| _d| _d| _d | _d| _d| _d| _d | _d | _i | _ d | _ d | _ d | _ d| _ d | _!i | _"i | _#g | _$d | _%d| _&d | _'d | _(d | _)d| _*d | _+d | _,g | _-g | _.d | _/d | _0g | _1g | _2g | _3d | _4d| _5d | _6t7| �| _8d| _9d S ) N� supervisorz/tmpi� � z /tmp/logfileF� r z/foo/bar� zhttp://localhost:9001)NN):Z identifierZ childlogdir�uid� getLogger�loggerZ backofflimitZlogfileZ nocleanupZ strip_ansiZ pidhistoryZprocess_group_configsZnodaemon� socket_map�moodZ mustreopen� realizeargs�fds_cleaned_upZ rlimit_set� setuid_called�httpservers_opened� signals_set� daemonizedZmake_logger_messages�autochildlogdir_cleared� cleaned_up�pidfile_written� directory�waitpid_return�kills�_signal�parent_pipes_closed�child_pipes_closed�forkpid�pgrp_set�duped�written� fds_closed� _exitcode� execve_called� execv_args� setuid_msg� privsdropped� logs_reopened� write_accept� tempfile_name�removed�existing� openreturn� readfd_result�parse_criticalsZparse_warnings� parse_infos� serverurl�changed_directory�umaskset� DummyPollerZpollerZsilent)�self� r: �/usr/lib/python3.6/base.py�__init__% sp zDummyOptions.__init__c O s t � }t � g|_||f|_|S )N)� DummyLoggerZhandlers�args)r9 r> �kwr r: r: r; r _ s zDummyOptions.getLoggerc K s || _ || _d S )N)r Z realizekw)r9 r> r? r: r: r; �realizee s zDummyOptions.realizeTc C s d S )Nr: )r9 Zdo_usager: r: r; �process_configi s zDummyOptions.process_configc C s d| _ d S )NT)r )r9 r: r: r; � cleanup_fdsl s zDummyOptions.cleanup_fdsc C s d| _ | jjd� d S )NT� rlimits_set)rC r4 �append)r9 r: r: r; �set_rlimits_or_exito s z DummyOptions.set_rlimits_or_exitc C s d| _ | jjd� d S )NTr )r r3 rD )r9 r: r: r; �set_uid_or_exits s z DummyOptions.set_uid_or_exitc C s d| _ d S )NT)r )r9 � supervisordr: r: r; �openhttpserversw s z DummyOptions.openhttpserversc C s d| _ d S )NT)r )r9 r: r: r; � daemonizez s zDummyOptions.daemonizec C s d| _ d S )NT)r )r9 r: r: r; � setsignals} s zDummyOptions.setsignalsc C s | j S )N)r )r9 r: r: r; � get_signal� s zDummyOptions.get_signalc C s | j S )N)r )r9 r: r: r; �get_socket_map� s zDummyOptions.get_socket_mapc C s d S )Nr: )r9 r: r: r; � make_logger� s zDummyOptions.make_loggerc C s d| _ d S )NT)r )r9 r: r: r; �clear_autochildlogdir� s z"DummyOptions.clear_autochildlogdirc G s | j S )N)r. )r9 Zignoredr: r: r; �get_autochildlog_name� s z"DummyOptions.get_autochildlog_namec C s d| _ d S )NT)r )r9 r: r: r; �cleanup� s zDummyOptions.cleanupc C s d| _ d S )NT)r )r9 r: r: r; � write_pidfile� s zDummyOptions.write_pidfilec C s | j S )N)r )r9 r: r: r; �waitpid� s zDummyOptions.waitpidc C s | j d k r| j �|| j|< d S )N)�kill_exceptionr )r9 �pidZsigr: r: r; �kill� s zDummyOptions.killc C s dd l }|j|�S )Nr )�os�stat)r9 �filenamerV r: r: r; rW � s zDummyOptions.statc C s dddgS )Nz/binz/usr/binz/usr/local/binr: )r9 r: r: r; �get_path� s zDummyOptions.get_pathc C s dd l }|j� S )Nr )rV �getpid)r9 rV r: r: r; �get_pid� s zDummyOptions.get_pidc C s |dkr ddl m} |d��d S )Nz /bad/filenamer )�NotFoundz bad filename)Zsupervisor.optionsr\ )r9 rX �argv�str\ r: r: r; �check_execv_args� s z DummyOptions.check_execv_argsc C sH | j d k r| j �ddddd�}|r4d \|d< |d < nd \|d< |d < |S ) N� � r � )Z child_stdin�stdin�stdoutZ child_stdout� � �stderrZ child_stderr)re rf )NN)�make_pipes_exception)r9 rg �pipesr: r: r; � make_pipes� s zDummyOptions.make_pipesc C sH | j d k r| j �| jr || j }| jj|d�}||7 }|| j|< t|�S )Nr )�write_exceptionr- r% � setdefault�len)r9 �fd�chars�datar: r: r; �write� s zDummyOptions.writec C s | j d k r| j �| jS )N)�fork_exceptionr" )r9 r: r: r; �fork� s zDummyOptions.forkc C s | j j|� d S )N)r& rD )r9 rn r: r: r; �close_fd� s zDummyOptions.close_fdc C s || _ d S )N)r )r9 ri r: r: r; �close_parent_pipes� s z DummyOptions.close_parent_pipesc C s || _ d S )N)r! )r9 ri r: r: r; �close_child_pipes� s z DummyOptions.close_child_pipesc C s d| _ d S )NT)r# )r9 r: r: r; �setpgrp� s zDummyOptions.setpgrpc C s || j |< d S )N)r$ )r9 ZfrmZtor: r: r; �dup2� s zDummyOptions.dup2c C s || _ d S )N)r' )r9 �coder: r: r; �_exit� s zDummyOptions._exitc C s* d| _ | jd k r| j�||f| _|| _d S )NT)r( �execv_exceptionr) Zexecv_environment)r9 rX r] � environmentr: r: r; �execve� s zDummyOptions.execvec C s | j r | j S || _d S )N)r* r+ )r9 r r: r: r; �drop_privileges� s z DummyOptions.drop_privilegesc C s | j S )N)r2 )r9 rn r: r: r; �readfd� s zDummyOptions.readfdc C s d| _ d S )NT)r, )r9 r: r: r; � reopenlogs� s zDummyOptions.reopenlogsc C s | j S )N)r. )r9 �prefix�suffix�dirr: r: r; � mktempfile� s zDummyOptions.mktempfilec C s( dd l }| jd k r| j�| jj|� d S )Nr )rV �remove_exceptionr/ rD )r9 �pathrV r: r: r; �remove� s zDummyOptions.removec C s || j krdS dS )NTF)r0 )r9 r� r: r: r; �exists� s zDummyOptions.exists�rc C s | j r | j S t||�S )N)r1 �open)r9 �name�moder: r: r; r� � s zDummyOptions.openc C s | j d k r| j �d| _d S )NT)�chdir_exceptionr6 )r9 r� r: r: r; �chdir� s zDummyOptions.chdirc C s || _ d S )N)r7 )r9 �maskr: r: r; �setumask s zDummyOptions.setumask)T)T)r� )6�__name__� __module__� __qualname__ZloglevelZminfdsr� rr r{ rS rh r� rk r< r r@ rA rB rE rF rH rI rJ rK rL rM rN rO rP rQ rR rU rW rY r[ r_ rj rq rs rt ru rv rw rx rz r} r~ r r� r� r� r� r� r� r� r: r: r: r; r sf : r c @ sp e Zd ZdZdd� Zdd� Ze Z Z Z Z Z Z dd� Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� ZdS )r= Nc C s d| _ d| _d| _g | _d S )NF)�reopenedr/ �closedrp )r9 r: r: r; r< s zDummyLogger.__init__c K s |r || }| j j|� d S )N)rp rD )r9 �msgr? r: r: r; �info s zDummyLogger.infoc K s |r || }| j j|� d S )N)rp rD )r9 �levelr� r? r: r: r; �log s zDummyLogger.logc C s |j � d S )N)�close)r9 Zhandlerr: r: r; � addHandler s zDummyLogger.addHandlerc C s d| _ d S )NT)r� )r9 r: r: r; �reopen s zDummyLogger.reopenc C s d| _ d S )NT)r� )r9 r: r: r; r� s zDummyLogger.closec C s d| _ d S )NT)r/ )r9 r: r: r; r� s zDummyLogger.removec C s d| _ d S )NT)�flushed)r9 r: r: r; �flush" s zDummyLogger.flushc C s dj | j�S )Nr )�joinrp )r9 r: r: r; �getvalue$ s zDummyLogger.getvalue)r� r� r� r� r< r� �warn�debugZcriticalZtrace�errorZblatherr� r� r� r� r� r� r� r: r: r: r; r= s r= c @ s e Zd Zddd�Zdd� ZdS )�DummySupervisorNc C sZ |d krt � | _n|| _|d kr8ddlm} |j| j_n|| j_|d krPi | _n|| _d S )Nr )�SupervisorStates)r �optionsZsupervisor.supervisordr� �RUNNINGr �process_groups)r9 r� �stater� r� r: r: r; r< ( s zDummySupervisor.__init__c C s | j jS )N)r� r )r9 r: r: r; � get_state7 s zDummySupervisor.get_state)NNN)r� r� r� r< r� r: r: r: r; r� ' s r� c @ sP e Zd ZdZdZdZdZdZdd� Zdd� Z dd� Z d d � Z d d � Z d d� Z dS )� DummySocketFNc C s || _ d S )N)rn )r9 rn r: r: r; r< A s zDummySocket.__init__c C s | j S )N)rn )r9 r: r: r; �filenoD s zDummySocket.filenoc C s d| _ || _d S )NT)� bind_called� bind_addr)r9 �addrr: r: r; �bindG s zDummySocket.bindc C s d| _ || _d S )NT)� listen_called�listen_backlog)r9 �backlogr: r: r; �listenK s zDummySocket.listenc C s d| _ d S )NT)� close_called)r9 r: r: r; r� O s zDummySocket.closec C s dS )Nz dummy socketr: )r9 r: r: r; �__str__R s zDummySocket.__str__)r� r� r� r� r� r� r� r� r< r� r� r� r� r� r: r: r: r; r� : s r� c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )�DummySocketConfig� c C s || _ || _d| _d S )Nz unix:///sock)rn r� Zurl)r9 rn r� r: r: r; r< V s zDummySocketConfig.__init__c C s dS )Nz dummy addrr: )r9 r: r: r; r� [ s zDummySocketConfig.addrc C s | j |j kS )N)rn )r9 �otherr: r: r; �__eq__^ s zDummySocketConfig.__eq__c C s | j |� S )N)r� )r9 r� r: r: r; �__ne__a s zDummySocketConfig.__ne__c C s | j S )N)r� )r9 r: r: r; � get_backlogd s z DummySocketConfig.get_backlogc C s t | j�S )N)r� rn )r9 r: r: r; �create_and_bindg s z!DummySocketConfig.create_and_bindN)r� ) r� r� r� r< r� r� r� r� r� r: r: r: r; r� U s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DummySocketManagerc K s || _ d S )N)�_config)r9 �config�kwargsr: r: r; r< k s zDummySocketManager.__init__c C s | j S )N)r� )r9 r: r: r; r� n s zDummySocketManager.configc C s t | jj�S )N)r� r� rn )r9 r: r: r; � get_socketq s z DummySocketManager.get_socketN)r� r� r� r< r� r� r: r: r: r; r� j s r� c @ s e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZdZdZdZdZdZdZdZdZdZd/dd�Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Z!dd� Z"dd� Z#dd� Z$dd � Z%d d � Z&d d � Z'd!d"� Z(d#d$� Z)d%d&� Z*d'd(� Z+d)d*� Z,d+d,� Z-d-d.� Z.dS )0� DummyProcessNr Fr c C s� || _ d| _d| _d| _d | _d| _|d kr>ddlm} |j}|| _ d| _ d | _ d| _ t d�| _t d�| _t d�| _t d�| _t d�| _i | _i | _i | _d | _d| _d | _d | _d | _d| _d S )NFTr )� ProcessStatesr ) r� � logsremoved� stop_called�stop_report_calledZ backoff_secs�spawned�supervisor.processr� r� r� �error_at_clear� killed_with�drainedr � stdout_buffer� stderr_buffer� stdout_logged� stderr_logged� stdin_bufferri �rpipes� dispatchers�finishedr, �execv_arg_exception�input_fd_drained�output_fd_drained� transitioned)r9 r� r� r� r: r: r; r< � s6 zDummyProcess.__init__c C s d| _ d S )NT)r, )r9 r: r: r; r� � s zDummyProcess.reopenlogsc C s | j rtd��d| _d S )N�whateverT)r� �IOErrorr� )r9 r: r: r; � removelogs� s zDummyProcess.removelogsc C s | j S )N)r� )r9 r: r: r; r� � s zDummyProcess.get_statec C s$ d| _ d| _ddlm} |j| _d S )NTFr )r� )r� �killingr� r� �STOPPEDr� )r9 r� r: r: r; �stop� s zDummyProcess.stopc C s d| _ d S )NT)r� )r9 r: r: r; � stop_report� s zDummyProcess.stop_reportc C s || _ d S )N)r� )r9 �signalr: r: r; rU � s zDummyProcess.killc C s || _ d S )N)� sent_signal)r9 r� r: r: r; r� � s zDummyProcess.signalc C s d| _ ddlm} |j| _d S )NTr )r� )r� r� r� r� r� )r9 r� r: r: r; �spawn� s zDummyProcess.spawnc C s d| _ d S )NT)r� )r9 r: r: r; �drain� s zDummyProcess.drainc C s g S )Nr: )r9 r: r: r; � readable_fds� s zDummyProcess.readable_fdsc C s0 | j | j7 _ d| _| j| j7 _d| _d S )Nr )r� r� r� r� )r9 r: r: r; � record_output� s zDummyProcess.record_outputc C s ||f| _ d S )N)r� )r9 rT �stsr: r: r; �finish� s zDummyProcess.finishc C s ddl m} |j| _d S )Nr )r� )r� r� �FATALr� )r9 r� r: r: r; �give_up� s zDummyProcess.give_upc C s6 | j r| j d��dd l}|j| jj�}|d }||fS )Nr� r )r� �shlex�splitr� �command)r9 r� Z commandargsZprogramr: r: r; �get_execv_args� s zDummyProcess.get_execv_argsc C s || _ d S )N)r� )r9 rn r: r: r; �drain_output_fd� s z DummyProcess.drain_output_fdc C s || _ d S )N)r� )r9 rn r: r: r; �drain_input_fd� s zDummyProcess.drain_input_fdc C s" | j d k r| j �| j|7 _d S )N)rk r� )r9 ro r: r: r; rq � s zDummyProcess.writec C s d| _ d S )NT)r� )r9 r: r: r; � transition� s zDummyProcess.transitionc C s | j j|j jkS )N)r� �priority)r9 r� r: r: r; r� � s zDummyProcess.__eq__c C s | j j|j jk S )N)r� r� )r9 r� r: r: r; �__lt__� s zDummyProcess.__lt__)N)/r� r� r� rk rT Z laststartZlaststopZdelayZadministrative_stopZ system_stopr� ZbackoffZ waitstatusZ exitstatusri r� r� r� r� �spawnerrr� r� r� Zlistener_state�groupr� r< r� r� r� r� r� rU r� r� r� r� r� r� r� r� r� r� rq r� r� r� r: r: r: r; r� t sX r� c @ s8 e Zd Zddd�Zd d � Zd d � Zdd d�Zdd� ZdS )� DummyPConfigN�� Tr r Fc ! C s� || _ || _|| _|| _|| _|| _| | _| | _| | _| | _ | | _ || _ || _ || _ || _|| _|| _|| _|| _|| _|| _|| _|d kr�dd l} | j}|| _|| _|| _| | _| | _ | | _ || _ || _ d| _ | | _!d S )Nr F)"r� r� r� r� � autostart� autorestart� startsecs� startretriesr �stdout_logfile�stdout_capture_maxbytes�stdout_events_enabled�stdout_logfile_backups�stdout_logfile_maxbytes� stdout_syslog�stderr_logfile�stderr_capture_maxbytes�stderr_events_enabled�stderr_logfile_backups�stderr_logfile_maxbytes� stderr_syslog�redirect_stderrr� �SIGTERM� stopsignal� stopwaitsecs� stopasgroup� killasgroup� exitcodesr| r �umask�autochildlogs_createdr5 )!r9 r� r� r� r r r� r� r� r� r� r r� r� r� r� r� r r r r r r r r r r r r r r| r5 r� r: r: r; r< � sF zDummyPConfig.__init__c C s dddgS )Nz/binz/usr/binz/usr/local/binr: )r9 r: r: r; rY 0 s zDummyPConfig.get_pathc C s d| _ d S )NT)r )r9 r: r: r; �create_autochildlogs3 s z!DummyPConfig.create_autochildlogsc C s t | �}||_|S )N)r� r� )r9 r� �processr: r: r; � make_process6 s zDummyPConfig.make_processc C s~ | j }| jj|�}|d |d |d }}}i }|d k rJtdd�||< |d k r`tdd�||< |d k rvtdd�||< ||fS )Nrd rg rc T)�readable)�writable)r r� rj �DummyDispatcher)r9 �procZ use_stderrri Z stdout_fdZ stderr_fdZstdin_fdr� r: r: r; �make_dispatchers; s z DummyPConfig.make_dispatchers�r ) NNr� TTr r� NNr Fr r FNr Fr r FFNr FFr NN)N)r� r� r� r< rY r r r r: r: r: r; r� � s$ % r� c C s� dd l }dd l}dd l}|d kr$i }t| �j� }|jj| �d }|j|d< x(|j� D ] }|j d|j � || �}qTW |j |d�}t|d��} | j |� W d Q R X |j |d� |S )Nr r �PYTHONz<<%s>>)r� �wi� )rV �sys�tempfiler� �readr� r� � executable�keys�replace�upperZmktemprq �chmod) �fileZ substitutionsrV r r rp Zlast�keyZtmpnam�fr: r: r; �makeExecutableI s r& Fc C s< dd l }|jjt�}| s*t|jj|d��S t|jj|d��S )Nr zfixtures/spew.pyzfixtures/unkillable_spew.py)rV r� �dirname�__file__r& r� )Z unkillablerV �herer: r: r; �makeSpew] s r* c @ s e Zd Zdd� Zdd� ZdS )�DummyMedusaServerLoggerc C s g | _ d S )N)�logged)r9 r: r: r; r< e s z DummyMedusaServerLogger.__init__c C s | j j||f� d S )N)r, rD )r9 �categoryr� r: r: r; r� g s zDummyMedusaServerLogger.logN)r� r� r� r< r� r: r: r: r; r+ d s r+ c @ s e Zd Zdd� ZdS )�DummyMedusaServerc C s t � | _d S )N)r+ r )r9 r: r: r; r< k s zDummyMedusaServer.__init__N)r� r� r� r< r: r: r: r; r. j s r. c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �DummyMedusaChannelc C s t � | _d | _d S )N)r. Zserver�producer)r9 r: r: r; r< o s zDummyMedusaChannel.__init__c C s || _ d S )N)r0 )r9 r0 r: r: r; �push_with_producers s z%DummyMedusaChannel.push_with_producerc C s d S )Nr: )r9 r: r: r; �close_when_donev s z"DummyMedusaChannel.close_when_donec C s d S )Nr: )r9 � terminatorr: r: r; �set_terminatory s z!DummyMedusaChannel.set_terminatorN)r� r� r� r< r1 r2 r4 r: r: r: r; r/ n s r/ c @ s� e Zd ZdZdZdZdZd!dd�Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )"� DummyRequestZGETNFz1.0c C sH ||||f| _ g | _i | _g | _g | _t� | _|d kr>i | _n|| _d S )N)r> � producers�headers�headerZoutgoingr/ �channel�env)r9 r� ZparamsZqueryZfragmentr: r: r: r; r< � s zDummyRequest.__init__c C s | j S )N)r> )r9 r: r: r; � split_uri� s zDummyRequest.split_uric C s || _ d S )N)�_error)r9 ry r: r: r; r� � s zDummyRequest.errorc C s | j j|� d S )N)r6 rD )r9 r0 r: r: r; �push� s zDummyRequest.pushc C s || j |< d S )N)r7 )r9 r8 �valuer: r: r; � __setitem__� s zDummyRequest.__setitem__c C s | j | S )N)r7 )r9 r8 r: r: r; � __getitem__� s zDummyRequest.__getitem__c C s | j |= d S )N)r7 )r9 r8 r: r: r; � __delitem__� s zDummyRequest.__delitem__c C s || j kS )N)r7 )r9 r8 r: r: r; �has_key� s zDummyRequest.has_keyc C s || j kS )N)r7 )r9 �itemr: r: r; � __contains__� s zDummyRequest.__contains__c C s d| _ d S )NT)�_done)r9 r: r: r; �done� s zDummyRequest.donec C s dS )Nr r: )r9 r: r: r; �build_reply_header� s z DummyRequest.build_reply_headerc O s d S )Nr: )r9 �argr? r: r: r; r� � s zDummyRequest.logc C s | j S )N)r: )r9 r: r: r; �cgi_environment� s z DummyRequest.cgi_environmentc C s dS )Nzhttp://example.comr: )r9 r: r: r; �get_server_url� s zDummyRequest.get_server_url)N)r� r� r� r� r< rE �versionr< r; r� r= r? r@ rA rB rD rF rG r� rI rJ r: r: r: r; r5 | s$ r5 c @ s e Zd Zdd� ZdS )�DummyRPCInterfaceFactoryc K s || _ || _d S )N)rG r� )r9 rG r� r: r: r; r< � s z!DummyRPCInterfaceFactory.__init__N)r� r� r� r< r: r: r: r; rL � s rL c @ s e Zd Zdd� ZdS )�DummyRPCServerc C s t � | _t� | _d S )N)�DummySupervisorRPCNamespacer �DummySystemRPCNamespace�system)r9 r: r: r; r< � s zDummyRPCServer.__init__N)r� r� r� r< r: r: r: r; rM � s rM c @ s e Zd ZdS )rO N)r� r� r� r: r: r: r; rO � s rO c @ sz e Zd ZdZdZdZdZddlmZ dddej de d dd e d d � d d d ej de d e d de dd � dddej de d e d d e dd � gZ dd� ZeZdd� Zd d � Zd d � ZeZd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"e"Z#e"Z$e"Z%d>d?� Z&d@dA� Z'dBdC� Z(dDdE� Z)dFdG� Z*dHdI� Z+dJdK� Z,dLdM� Z-dNS )OrN TFr )r� �foo� r� �d r zfoo description) r� r� rT r� Z statename�startr� r� Znow� descriptionZbar� r� �2 Zscrewedzbar descriptionZbaz_01Zbaz� r� � zbaz descriptionc C s dS )Nz3.0r: )r9 r: r: r; � getAPIVersion� s z)DummySupervisorRPCNamespace.getAPIVersionc C s dS )N�* r: )r9 r: r: r; �getPID� s z"DummySupervisorRPCNamespace.getPIDc C sj ddl m} |dkr$t|jjd��n.|dkr<t|jjd��n|dkrRt|jjd��|d d }||d � S )Nr )�xmlrpc�BAD_NAME�FAILED�NO_FILEz line r )r r] r �Faultsr^ r_ r` )r9 r9 r� �offset�lengthr] �ar: r: r; � _read_log� s z%DummySupervisorRPCNamespace._read_logc C s | j d|||�S )Nrd )re )r9 r� rb rc r: r: r; �readProcessStdoutLog s z0DummySupervisorRPCNamespace.readProcessStdoutLogc C s | j d|||�S )Nrg )re )r9 r� rb rc r: r: r; �readProcessStderrLog s z0DummySupervisorRPCNamespace.readProcessStderrLogc C s | j S )N)�all_process_info)r9 r: r: r; �getAllProcessInfo s z-DummySupervisorRPCNamespace.getAllProcessInfoc C sv ddl m} x"| jD ]}|d |kr|}|S qW |dkrFt|jjd��|dkr\t|jjd��|dkrrt|jjd��d S )Nr )r] r� r^ r_ r` )r r] rh r ra r^ r_ r` )r9 r� r] �ir� r: r: r; �getProcessInfo s z*DummySupervisorRPCNamespace.getProcessInfoc C s� ddl m} |dkr"t|jjd��|dkr8t|jjd��|dkrNt|jjd��|dkrdt|jjd��|dkrzt|jjd��|dkr�t|jjd��|d kr�t|jj d ��d S ) Nr )r] zBAD_NAME:BAD_NAMEr^ r` �NOT_EXECUTABLE�ALREADY_STARTED� SPAWN_ERROR�ABNORMAL_TERMINATIONT) r r] r ra r^ r` rl rm rn ro )r9 r� r] r: r: r; � startProcess s" z(DummySupervisorRPCNamespace.startProcessc C sR ddl m} ddlm} |dkr.||jjd��dd|jjdd�d d|jjdd�gS ) Nr )r] )r r^ �foo_00rQ �OK)r� r� �statusrU �foo_01)r r] �supervisor.compatr ra r^ �SUCCESS)r9 r� r] r r: r: r; �startProcessGroup. s z-DummySupervisorRPCNamespace.startProcessGroupc C s@ ddl m} dd|jjdd�dd|jjdd�dd|jjd d�gS ) Nr )r] rQ rr )r� r� rs rU �foo2�failed� failed_grouprn )r r] ra rv rn )r9 r] r: r: r; �startAllProcesses< s z-DummySupervisorRPCNamespace.startAllProcessesc C sR ddl m} ddlm} |dkr.||jjd��dd|jjdd�d d|jjdd�gS ) Nr )r] )r r^ rq rQ rr )r� r� rs rU rt )r r] ru r ra r^ rv )r9 r� r] r r: r: r; �stopProcessGroupJ s z,DummySupervisorRPCNamespace.stopProcessGroupc C sh ddl m} |dkr"t|jjd��|dkr8t|jjd��|dkrNt|jjd��|dkrdt|jjd��dS )Nr )r] zBAD_NAME:BAD_NAMEr^ � NOT_RUNNINGr_ T)r r] r ra r^ r} r_ )r9 r� r] r: r: r; � stopProcessX s z'DummySupervisorRPCNamespace.stopProcessc C s@ ddl m} dd|jjdd�dd|jjdd�dd|jjd d�gS ) Nr )r] rQ rr )r� r� rs rU rx ry rz r_ )r r] ra rv r^ )r9 r] r: r: r; �stopAllProcessese s z,DummySupervisorRPCNamespace.stopAllProcessesc C s. | j rd| _d S ddlm} t|jjd��d S )NTr )r] r )� _restartable� _restartedr r] r ra �SHUTDOWN_STATE)r9 r] r: r: r; �restartr s z#DummySupervisorRPCNamespace.restartc C s. | j rd| _d S ddlm} t|jjd��d S )NTr )r] r )r� � _shutdownr r] r ra r� )r9 r] r: r: r; �shutdowny s z$DummySupervisorRPCNamespace.shutdownc C s dgdgdgggS )NZaddedZchangedr/ r: )r9 r: r: r; � reloadConfig� s z(DummySupervisorRPCNamespace.reloadConfigc C s� ddl m} |dkr"t|jjd��|dkr8t|jjd��|dkrNt|jjd��|dkrdt|jjd��t| d�r|| j j |� n|g| _ d S ) Nr )r] � ALREADY_ADDEDr r^ r_ r� � processes) r r] r ra r� r^ r_ r� �hasattrr� rD )r9 r� r] r: r: r; �addProcessGroup� s z+DummySupervisorRPCNamespace.addProcessGroupc C s^ ddl m} |dkr"t|jjd��|dkr8t|jjd��|dkrNt|jjd��| jj|� d S )Nr )r] � STILL_RUNNINGr r^ r_ ) r r] r ra r� r^ r_ r� r� )r9 r� r] r: r: r; �removeProcessGroup� s z.DummySupervisorRPCNamespace.removeProcessGroupc C s& ddl m} |dkr"t|jjd��dS )Nr )r] r^ T)r r] r ra r^ )r9 r� r] r: r: r; �clearProcessStdoutLog� s z1DummySupervisorRPCNamespace.clearProcessStdoutLogc C s@ ddl m} dd|jjdd�dd|jjdd�dd|jjd d�gS ) Nr )r] rQ rr )r� r� rs rU rx ry rz r_ )r r] ra rv r_ )r9 r] r: r: r; �clearAllProcessLogs� s z/DummySupervisorRPCNamespace.clearAllProcessLogsc C s t d��d S )Nr� )� ValueError)r9 r: r: r; � raiseError� s z&DummySupervisorRPCNamespace.raiseErrorc C s dd iS )Nr� r: )r9 r: r: r; �getXmlRpcUnmarshallable� s z3DummySupervisorRPCNamespace.getXmlRpcUnmarshallablec C s dS )NZ3000r: )r9 r: r: r; �getSupervisorVersion� s z0DummySupervisorRPCNamespace.getSupervisorVersionc C s | j rt| j d��dS )Nr Z mainlogdata)�_readlog_errorr )r9 �whencerb r: r: r; �readLog� s z#DummySupervisorRPCNamespace.readLogc C sF ddl m} |dkr"t|jjd��dd|jjdd�dd|jjdd�gS ) Nr )r] r^ rq rQ rr )r� r� rs rU rt )r r] r ra r^ rv )r9 r� r� r] r: r: r; �signalProcessGroup� s z.DummySupervisorRPCNamespace.signalProcessGroupc C s~ ddl m} |dkr"t|jjd��|dkr8t|jjd��|dkrNt|jjd��|dkrdt|jjd��|dkrzt|jjd��dS ) Nr )r] � BAD_SIGNALzBAD_NAME:BAD_NAMEr^ r} r_ T)r r] r ra r� r^ r} r_ )r9 r� r� r] r: r: r; � signalProcess� s z)DummySupervisorRPCNamespace.signalProcessc C s@ ddl m} dd|jjdd�dd|jjdd�dd|jjd d�gS ) Nr )r] rQ rr )r� r� rs rU rx ry rz r_ )r r] ra rv r^ )r9 r� r] r: r: r; �signalAllProcesses� s z.DummySupervisorRPCNamespace.signalAllProcessesN).r� r� r� r� r� r� r� r� r� r� �_NOWr� r� rh rZ Z getVersionr\ re rf ZreadProcessLogrg ri rk rp rw r{ r| r~ r r� r� r� r� r� r� ZclearProcessLogZclearProcessStderrLogZclearProcessLogsr� r� r� r� r� r� r� r� r: r: r: r; rN � s� rN c @ s. e Zd Zd dd�Zdd� Zdd � Zd d � ZdS ) �DummyPGroupConfigr� �� Nc C s: || _ || _|| _|d kr g }|| _d| _g | _d| _d S )NFr )r� r� r� Zprocess_configs�after_setuid_calledZ pool_events� buffer_size)r9 r� r� r� �pconfigsr: r: r; r< � s zDummyPGroupConfig.__init__c C s d| _ d S )NT)r� )r9 r: r: r; � after_setuid s z DummyPGroupConfig.after_setuidc C s t | �S )N)�DummyProcessGroup)r9 r: r: r; � make_group s z DummyPGroupConfig.make_groupc C s d| j t| �| jf S )Nz <%s instance at %s named %s>)� __class__�idr� )r9 r: r: r; �__repr__ s zDummyPGroupConfig.__repr__)r� r� N)r� r� r� r< r� r� r� r: r: r: r; r� � s r� c @ s" e Zd Zddded�fdd�ZdS )�DummyFCGIGroupConfigr� i� Nr c C s t j| ||||� || _d S )N)r� r< � socket_config)r9 r� r� r� r� r� r: r: r; r< s z DummyFCGIGroupConfig.__init__)r� r� r� r� r< r: r: r: r; r� s r� c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dS )r� c C s( || _ d| _d| _i | _g | _d| _d S )NF)r� r� � all_stoppedr� �unstopped_processes�before_remove_called)r9 r� r: r: r; r< s zDummyProcessGroup.__init__c C s d| _ d S )NT)r� )r9 r: r: r; r� s z DummyProcessGroup.transitionc C s d| _ d S )NT)r� )r9 r: r: r; � before_remove s z DummyProcessGroup.before_removec C s d| _ d S )NT)r� )r9 r: r: r; �stop_all s zDummyProcessGroup.stop_allc C s | j S )N)r� )r9 r: r: r; �get_unstopped_processes" s z)DummyProcessGroup.get_unstopped_processesc C s | j S )N)r� )r9 r: r: r; �get_dispatchers% s z!DummyProcessGroup.get_dispatchersc C s | j j|j jk S )N)r� r� )r9 r� r: r: r; r� ( s zDummyProcessGroup.__lt__c C s | j j|j jkS )N)r� r� )r9 r� r: r: r; r� + s zDummyProcessGroup.__eq__c C s d| _ d S )NT)r, )r9 r: r: r; r� . s z DummyProcessGroup.reopenlogsN) 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 )�DummyFCGIProcessGroupc C s t j| |� t|j�| _d S )N)r� r< r� r� Zsocket_manager)r9 r� r: r: r; r< 3 s z DummyFCGIProcessGroup.__init__N)r� r� r� r< r: r: r: r; r� 1 s r� c @ s& e Zd Zdd� Zddd�Zdd� ZdS ) �PopulatedDummySupervisorc G sf t j| |� i | _i }|| _t|||d�}t|�}|| j|< x |D ]}t|�}|||j< qBW ||_d S )N)r� ) r� r< r� � group_namer� r� r� r� r� ) r9 r� r� r� r� ZgconfigZpgroupZpconfigr r: r: r; r< 8 s z!PopulatedDummySupervisor.__init__Nc C s. |d kr| j }| j| j| }t|||� d S )N)r� r� r� �setattr)r9 Z process_nameZ attr_name�valr� r r: r: r; � set_procattrE s z%PopulatedDummySupervisor.set_procattrc C s d| _ d S )NT)Zreaped)r9 r: r: r; �reapK s z PopulatedDummySupervisor.reap)N)r� r� r� r< r� r� r: r: r: r; r� 7 s r� c @ sn e Zd ZdZdZdZdZdZdZdZ dZ ddd�Z dd� Z dd� Z d d � Zd d � Zd d� Zdd� Zdd� ZdS )r NFc sD |� _ |� _|� _d� _|r@� fdd�}|� _� fdd�}|� _d S )Nr c s d� _ d S )NT)r, r: )r9 r: r; r� ` s z,DummyDispatcher.__init__.<locals>.reopenlogsc s d� _ d S )NT)� logs_removedr: )r9 r: r; r� c s z,DummyDispatcher.__init__.<locals>.removelogs)� _readable� _writabler< Z input_bufferr� r� )r9 r r r� r� r� r: )r9 r; r< Y s zDummyDispatcher.__init__c C s | j S )N)r� )r9 r: r: r; r g s zDummyDispatcher.readablec C s | j S )N)r� )r9 r: r: r; r i s zDummyDispatcher.writablec C s | j r | j �d| _d S )NT)r< �write_event_handled)r9 r: r: r; �handle_write_eventk s z"DummyDispatcher.handle_write_eventc C s | j r | j �d| _d S )NT)r< �read_event_handled)r9 r: r: r; �handle_read_evento s z!DummyDispatcher.handle_read_eventc C s d| _ d S )NT)� error_handled)r9 r: r: r; � handle_errors s z DummyDispatcher.handle_errorc C s d| _ d S )NT)r� )r9 r: r: r; r� u s zDummyDispatcher.closec C s | j r | j �d| _d S )NT)�flush_exceptionr� )r9 r: r: r; r� w s zDummyDispatcher.flush)FFF)r� r� r� r� r� r� r� r, r� r� r� r< r r r� r� r� r� r� r: r: r: r; r N s r c @ sH e Zd Zddd�Zdd� Zdd� Zd d � Zdd d �Zdd� Zdd� Z dS )� DummyStreamNr c C s" || _ d| _d| _d| _|| _d S )NF� )r� r� r� r% �_fileno)r9 r� r� r: r: r; r< } s zDummyStream.__init__c C s | j r | j �d| _d S )NT)r� r� )r9 r: r: r; r� � s zDummyStream.closec C s | j r | j �d| _d S )NT)r� r� )r9 r: r: r; r� � s zDummyStream.flushc C s, | j r| j }d | _ |�| jt|�7 _d S )N)r� r% r )r9 r� r� r: r: r; rq � s zDummyStream.writer c C s d S )Nr: )r9 Znumr� r: r: r; �seek� s zDummyStream.seekc C s t | j�S )N)rm r% )r9 r: r: r; �tell� s zDummyStream.tellc C s | j S )N)r� )r9 r: r: r; r� � s zDummyStream.fileno)Nr )r ) r� r� r� r< r� r� rq r� r� r� r: r: r: r; r� | s r� c @ s e Zd Zddd�Zdd� ZdS )� DummyEvent�abcc C s |d k r|| _ d S )N)�serial)r9 r� r: r: r; r< � s zDummyEvent.__init__c C s dS )Nz dummy eventr: )r9 r: r: r; �payload� s zDummyEvent.payloadN)r� )r� r� r� r< r� r: r: r: r; r� � s r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) r8 c C s g g f| _ d| _d S )NF)�resultr� )r9 r� r: r: r; r< � s zDummyPoller.__init__c C s d S )Nr: )r9 rn r: r: r; �register_readable� s z DummyPoller.register_readablec C s d S )Nr: )r9 rn r: r: r; �register_writable� s z DummyPoller.register_writablec C s | j S )N)r� )r9 Ztimeoutr: r: r; �poll� s zDummyPoller.pollc C s d| _ d S )NT)r� )r9 r: r: r; r� � s zDummyPoller.closeN)r� r� r� r< r� r� r� r� r: r: r: r; r8 � s r8 c C s d S )Nr: )�eventr� r: r: r; � dummy_handler� s r� c C s ddl m} ||��d S )Nr )� RejectEvent)Zsupervisor.dispatchersr� )r� r� r� r: r: r; �rejecting_handler� s r� c C s t |��d S )N)r� )r� r� r: r: r; �exception_handler� s r� c C s dd� | j d�D �}dj|�S )Nc S s g | ] }|j � �qS r: )�strip)�.0�xr: r: r; � <listcomp>� s zlstrip.<locals>.<listcomp>� )r� r� )�sZstringsr: r: r; �lstrip� s r� )N)F)/r� Z _TIMEFORMAT�errno� functoolsrV ru r r Z unittest.mockr r r � ImportErrorZmockr r= r� r� r� r� �total_ordering�objectr� r� r& r* r+ r. r/ r5 rL rM rO rN r� r� r� r� r� r r� r� r8 r� r� r� r� r: r: r: r; �<module> sf m" L 9 4!.
Back to File Manager