File: //lib/python3/dist-packages/twisted/application/__pycache__/app.cpython-38.pyc
U
��W[�[ � @ s� d dl mZmZmZ d dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z d dl
mZmZmZ d dlmZmZ d dlmZ d dlmZ d dlmZmZmZm Z m Z m Z d d l m Z d d
l!m"Z"m#Z#m$Z$ d d l%m&Z& d d l'm(Z( d d
l'm)Z) G dd� de*�Z+G dd� de+�Z,G dd� de+�Z-G dd� de*�Z.G dd� de*�Z/dd� Z0d2dd�Z1d d � Z2d d � Z3G d d!� d!e*�Z4d"d#� Z5d$d%� Z6e G d&d'� d'��Z7G d(d)� d)ej8e7�Z9d*d+� Z:d,d-� Z;d.d/� Z<d0d1� Z=dS )3� )�absolute_import�division�print_functionN)�
attrgetter)� copyright�plugin�logger)�service�reactors)�defer)�sob)�runtime�log�usage�failure�util�logfile)� _oldStyle)�qual�namedAny� namedModule)� _ISupportsExitSignalCapturing)�installReactor)�
NoSuchReactorc @ s e Zd ZdZdd� Zdd� ZdS )�_BasicProfilerz�
@ivar saveStats: if C{True}, save the stats information instead of the
human readable format
@type saveStats: C{bool}
@ivar profileOutput: the name of the file use to print profile data.
@type profileOutput: C{str}
c C s || _ || _d S �N)�
profileOutput� saveStats)�selfr r � r �9/usr/lib/python3/dist-packages/twisted/application/app.py�__init__) s z_BasicProfiler.__init__c C s d||f }|d7 }t |��dS )z�
Helper method to report an import error with a profile module. This
has to be explicit because some of these modules are removed by
distributions due to them being non-free.
z Failed to import module %s: %sz�
This is most likely caused by your operating system not including
the module due to it being non-free. Either do not use the option
--profile, or install the module; your operating system vendor
may provide it in a separate package.
N)�
SystemExit)r �module�e�sr r r �_reportImportError. s z!_BasicProfiler._reportImportErrorN)�__name__�
__module__� __qualname__�__doc__r! r& r r r r r s r c @ s e Zd ZdZdd� ZdS )�
ProfileRunnerz1
Runner for the standard profile module.
c
C s� z ddl }W n. tk
r: } z| �d|� W 5 d}~X Y nX |�� }|�|j� | jrd|�| j� n<t j
t | jd� }t _
z |�
� W 5 |t j
t _
}|� � X dS )z:
Run reactor under the standard profiler.
r N�profile�a)r, � ImportErrorr& �Profile�runcall�runr �
dump_statsr �sys�stdout�open�close� print_stats)r �reactorr, r$ �pZtmpr r r r1 D s zProfileRunner.runN�r' r( r) r* r1 r r r r r+ ? s r+ c @ s e Zd ZdZdd� ZdS )�CProfileRunnerz)
Runner for the cProfile module.
c
C s� zddl }ddl}W n. tk
rB } z| �d|� W 5 d}~X Y nX |�� }|�|j� | jrl|�| j � n@t
| j d��.}|j ||d�}|� � |�
d� |�� W 5 Q R X dS )z:
Run reactor under the cProfile profiler.
r N�cProfile�w)�stream���)r< �pstatsr. r& r/ r0 r1 r r2 r r5 ZStatsZ
strip_dirsZ
sort_statsr7 )r r8 r< r@ r$ r9 r> r% r r r r1 ` s
zCProfileRunner.runNr: r r r r r; [ s r; c @ s" e Zd ZdZeed�Zdd� ZdS )� AppProfilerz�
Class which selects a specific profile runner based on configuration
options.
@ivar profiler: the name of the selected profiler.
@type profiler: C{str}
)r, �cprofilec C sf |� dd�}|� dd �}|� dd��� | _| j| jkrR| j| j ||�}|j| _ntd| jf ��d S )N� savestatsFr, �profilerrB z Unsupported profiler name: %s)�get�lowerrD � profilersr1 r" )r �optionsr r rD r r r r! � s
�zAppProfiler.__init__N)r' r( r) r* r+ r; rG r! r r r r rA w s
rA c @ s< e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z dS )
� AppLoggera]
An L{AppLogger} attaches the configured log observer specified on the
commandline to a L{ServerOptions} object, a custom L{logger.ILogObserver},
or a legacy custom {log.ILogObserver}.
@ivar _logfilename: The name of the file to which to log, if other than the
default.
@type _logfilename: C{str}
@ivar _observerFactory: Callable object that will create a log observer, or
None.
@ivar _observer: log observer added at C{start} and removed at C{stop}.
@type _observer: a callable that implements L{logger.ILogObserver} or
L{log.ILogObserver}.
Nc C s" |� dd�| _|� d�pd| _dS )zE
Initialize an L{AppLogger} with a L{ServerOptions}.
r � r N)rE � _logfilename�_observerFactory�r rH r r r r! � s zAppLogger.__init__c C s� | j dk r| � � }n$|�tjd�}|dkr8|�tjd�}|dkrH| �� }|| _tj�| j�rf| jg}n<tj�| j�r�t�| j�g}n t j
dt dd� t�| j�g}tj �
|� | �� dS )a�
Initialize the global logging system for the given application.
If a custom logger was specified on the command line it will be used.
If not, and an L{logger.ILogObserver} or legacy L{log.ILogObserver}
component has been set on C{application}, then it will be used as the
log observer. Otherwise a log observer will be created based on the
command line options for built-in loggers (e.g. C{--logfile}).
@param application: The application on which to check for an
L{logger.ILogObserver} or legacy L{log.ILogObserver}.
@type application: L{twisted.python.components.Componentized}
NaZ Passing a logger factory which makes log observers which do not implement twisted.logger.ILogObserver or twisted.python.log.ILogObserver to twisted.application.app.AppLogger was deprecated in Twisted 16.2. Please use a factory that produces twisted.logger.ILogObserver (or the legacy twisted.python.log.ILogObserver) implementing objects instead.� )�
stacklevel)rL Z getComponentr Z ILogObserverr �_getLogObserver� _observer�
providedByZLegacyLogObserverWrapper�warnings�warn�DeprecationWarningZglobalLogBeginnerZbeginLoggingTo� _initialLog)r � applicationZobserverZ observersr r r �start� s(
� zAppLogger.startc C sJ ddl m} t�| �jdtjtjt �
� d� t�| �jdt |j �d� dS )z1
Print twistd start log message.
r �r8 z1twistd {version} ({exe} {pyVersion}) starting up.)�version�exeZ pyVersionzreactor class: {reactor}.N)
�twisted.internetr8 r �
_loggerFor�infor rZ r3 �
executabler
ZshortPythonVersionr � __class__)r r8 r r r rV � s
� �zAppLogger._initialLogc C s0 | j dks| j stj}ntj�| j �}t�|�S )zr
Create a log observer to be added to the logging system before running
this application.
�-)rK r3 r4 r ZLogFileZ fromFullPathr ZtextFileLogObserver)r ZlogFiler r r rP � s zAppLogger._getLogObserverc C s2 t �| ��d� | jdk r.t j�| j� d| _dS )zS
Remove all log observers previously set up by L{AppLogger.start}.
zServer Shut Down.N)r r] r^ rQ ZglobalLogPublisherZremoveObserver�r r r r �stop� s
zAppLogger.stop)
r' r( r) r* rQ r! rX rV rP rc r r r r rI � s 0
rI c C s4 dd� } dd� }dd� }|t j_| t j_|t j_d S )Nc S s. | � � | �� ddlm} |�d|j� dS )Nr rY � )Zclear_all_breaksZ set_continuer\ r8 Z callLaterrc )r �argr8 r r r �do_stop� s
zfixPdb.<locals>.do_stopc S s t d� d S )NzEstop - Continue execution, then cleanly shutdown the twisted reactor.)�printrb r r r � help_stop s zfixPdb.<locals>.help_stopc S s t �d� d S )Nr )�os�_exitrb r r r �set_quit s zfixPdb.<locals>.set_quit)�pdbZPdbrk rf rh )rf rh rk r r r �fixPdb� s rm c C s� |dkrddl m} z~| d r2|dk r�|�|� n^| d r�|t_|t_tjdkrtt�tj dd� � t�tj
d d� � t � t �
|j� n|�� W nT d
}| d r�|}ntd d
�}d}ztj|d� |�� W 5 |r�|�� X Y nX dS )aN
Start the reactor, using profiling if specified by the configuration, and
log any error happening in the process.
@param config: configuration of the twistd application.
@type config: L{ServerOptions}
@param oldstdout: initial value of C{sys.stdout}.
@type oldstdout: C{file}
@param oldstderr: initial value of C{sys.stderr}.
@type oldstderr: C{file}
@param profiler: object used to run the reactor with profiling.
@type profiler: L{AppProfiler}
@param reactor: The reactor to use. If L{None}, the global reactor will
be used.
Nr rY r, �debug�posixc W s t �� S r �rl Z set_trace��argsr r r �<lambda>3 � z'runReactorWithLogging.<locals>.<lambda>c W s t �� S r rp rq r r r rs 4 rt FZnodaemonzTWISTD-CRASH.logr- T��file)r\ r8 r1 r3 r4 �stderrr
Z platformType�signal�SIGUSR2�SIGINTrm rl r0 r5 r6 � traceback� print_exc�flush)�config� oldstdout� oldstderrrD r8 r6 rv r r r �runReactorWithLogging s4
r� c C s | rt � d�S d S d S )Nz Passphrase: )�getpass�Zneededr r r �
getPassphraseI s
r� c C s | rt �d�S d S d S )NzEncryption passphrase: )r Z getPasswordr� r r r �getSavePassphraseQ s
r� c @ sH e Zd ZdZeZeZdd� Zdd� Z dd� Z
dd � Z d
d � Z d d
� Z
dS )�ApplicationRunnera
An object which helps running an application based on a config object.
Subclass me and implement preApplication and postApplication
methods. postApplication generally will want to run the reactor
after starting the application.
@ivar config: The config object, which provides a dict-like interface.
@ivar application: Available in postApplication, but not
preApplication. This is the application object.
@ivar profilerFactory: Factory for creating a profiler object, able to
profile the application if options are set accordingly.
@ivar profiler: Instance provided by C{profilerFactory}.
@ivar loggerFactory: Factory for creating object responsible for logging.
@ivar logger: Instance provided by C{loggerFactory}.
c C s" || _ | �|�| _| �|�| _d S r )r~ �profilerFactoryrD �
loggerFactoryr )r r~ r r r r! r s zApplicationRunner.__init__c C s6 | � � | �� | _| j�| j� | �� | j�� dS )z&
Run the application.
N)�preApplication�createOrGetApplicationrW r rX �postApplicationrc rb r r r r1 x s
zApplicationRunner.runc C sF |dkrddl m} t| j||| j|� t�|�r<|j| _nd| _dS )z�
Run the reactor with the given configuration. Subclasses should
probably call this from C{postApplication}.
@see: L{runReactorWithLogging}
Nr rY )r\ r8 r� r~ rD r rR Z _exitSignal)r r8 r r� r r r � startReactor� s �
z ApplicationRunner.startReactorc C s
t � �dS )z�
Override in subclass.
This should set up any state necessary before loading and
running the Application.
N��NotImplementedErrorrb r r r r� � s z ApplicationRunner.preApplicationc C s
t � �dS )z�
Override in subclass.
This will be called after the application has been loaded (so
the C{application} attribute will be set). Generally this
should start the application and run the reactor.
Nr� rb r r r r� � s z!ApplicationRunner.postApplicationc C s\ | j jr>| j j| j j }|�| j j�}t�|j�}|�|� nt | j d �}t
| j |�}|S )a�
Create or load an Application based on the parameters found in the
given L{ServerOptions} instance.
If a subcommand was used, the L{service.IServiceMaker} that it
represents will be used to construct a service to be added to
a newly-created Application.
Otherwise, an application will be loaded based on parameters in
the config.
� encrypted) r~ �
subCommand�
loadedPluginsZ makeServiceZ
subOptionsr Z Application�tapnameZsetServiceParentr� �getApplication)r ZplgZserrW �
passphraser r r r� � s z(ApplicationRunner.createOrGetApplicationN)r' r( r) r* rA r� rI r� r! r1 r� r� r� r� r r r r r� Y s
r� c
s� � fdd�dD �d }|d ddi� |d |d � }}z*t�d| � t�|||�}t�d � W n| tk
r� } z^d
| }t|t�r�|jd d kr�|d 7 }t j
tj d
� t�|� t� � t
�d| d � W 5 d }~X Y nX |S )Nc s g | ]}� | r� | |f�qS r r )�.0�t�r~ r r �
<listcomp>� s �z"getApplication.<locals>.<listcomp>)�python�sourcerv r rv �picklerd z
Loading %s...zLoaded.z Failed to load application: %srW aN
Could not find 'application' in the file. To use 'twistd -y', your .tac
file must create a suitable object (e.g., by calling service.Application())
and store it in a variable named 'application'. twistd loads your .tac file
and scans the global variables for one of this name.
Please read the 'Using Application' HOWTO for details.
ru �
)rE r �msgr �loadApplication� Exception�
isinstance�KeyErrorrr r{ r| r Zdeferrr3 �exit)r~ r� r% �filenameZstylerW r$ r r� r r� � s&
��"
$r� c C s t �dd� t�� D ��S )Nc S s g | ]
}|j �qS r )� shortName)r� �rr r r r� � s z"_reactorAction.<locals>.<listcomp>)r Z CompleteListr
�getReactorTypesr r r r �_reactorAction� s
�r� c @ sD e Zd ZdZejdeid�Zej Z
e e j
�Zdd� Zdd� ZeZdS ) �ReactorSelectionMixinz�
Provides options for selecting a reactor to install.
If a reactor is installed, the short name which was used to locate it is
saved as the value for the C{"reactor"} key.
r8 )�
optActionsc C s� t | �� td�d�}d}|D ]j}z&t|j� | j�d|j|jf � W q t k
r� } z |d|j|j|j
d f 7 }W 5 d}~X Y q X q |r�| j�d� | j�d � | j�|� t d��dS )
zE
Display a list of possibly available reactor names.
r� ��keyrJ z %-4s %s
z !%-4s %s (%s)
r Nr� z. reactors not available on this platform:
) �sorted�_getReactorTypesr r Z
moduleName�
messageOutput�writer� � descriptionr. rr r" )r ZrctsZnotWorkingReactorsr� r$ r r r �opt_help_reactors� s"
�
� z'ReactorSelectionMixin.opt_help_reactorsc
C sv z t |� W n\ tk
r4 d|f }t�|��Y n> tk
rh } zd|f }t�|��W 5 d}~X Y n
X || d< dS )zX
Which reactor to use (see --help-reactors for a list of possibilities)
zcThe specified reactor does not exist: '%s'.
See the list of available reactors with --help-reactorsztThe specified reactor cannot be used, failed with error: %s.
See the list of available reactors with --help-reactorsNr8 )r r r �
UsageErrorr� )r r� r� r$ r r r � opt_reactor s �� z!ReactorSelectionMixin.opt_reactorN)r' r( r) r* r � Completionsr� �compDatar3 r4 r� � staticmethodr
r� r� r� r� Zopt_rr r r r r� � s �
r� c @ s e Zd ZdZdddgdddgdd d
ggZd d dd
gddddgddddgddddd�ej� gddddgdd dd gd d dd gd!d"d#d$ggZe j
d%ge � d&�e � d'�e � d(�e � � d)�d*�Z
eej�Zd+d,� Zd-d.� ZeZd/d0� Zd7d1d2�Zd3d4� Zd5d6� Zee�ZdS )8�
ServerOptionszQtwistd reads a twisted.application.service.Application out of a file and runs it.rC NzBsave the Stats object rather than the text output of the profiler.�no_save�oz do not save state on shutdownr� r$ z(The specified tap/aos file is encrypted.r �lz%log to a specified file, - for stdoutr z�A fully-qualified name to a log observer factory to use for the initial log observer. Takes precedence over --logfile and --syslog (when available).r, r9 z7Run in profile mode, dumping results to specified file.rD rB z!Name of the profiler to use (%s).z, rv �fz
twistd.tapzread the given .tap filer� �yz:read an application from within a Python file (implies -o)r� r% z2Read an application from a .tas file (AOT format).�rundir�d�.z-Change to a supplied directory before running)rv r� r� z*.tapz
*.(tac|py)z*.tas)rv r� r� r� )ZmutuallyExclusiver� c O s4 d| d< d|kr |d | _ ntj | _ tj�| � d S )NFrn r4 )r4 r3 r �Optionsr! )r r- �kwr r r r! X s
zServerOptions.__init__c C s t �d� t�� d| d< dS )z�
Run the application in the Python Debugger (implies nodaemon),
sending SIGUSR2 will drop into debugger
Trn N)r Z setDebuggingr ZstartDebugModerb r r r � opt_debuga s
zServerOptions.opt_debugc C s@ t �tj� z ddl}W n tk
r. Y dS X |�tj� dS )z�
Print an insanely verbose log of everything that happens.
Useful when debugging freezes or locks in complex code.
r N)r3 �settracer Zspewer� threadingr. )r r� r r r �opt_spewl s zServerOptions.opt_spewc C s. |d kr t jdd � pdg}tj�| |� d S )Nrd z--help)r3 �argvr r� � parseOptionsrM r r r r� y s zServerOptions.parseOptionsc
C st | j s| d rd| d< | d d k rpzt| d �| d< W n8 tk
rn } zt�d| d |f ��W 5 d }~X Y nX d S )Nr� Tr� r z%Logger '%s' could not be imported: %s)r� r r� r r� )r r$ r r r � postOptions s
�zServerOptions.postOptionsc c sR | � tj�}i | _t|td�d�D ]*}|| j|j< |jd |fdd�|jfV q"d S )Nr� r� c S s | � � S r )rH )�plugr r r rs � rt z+ServerOptions.subCommands.<locals>.<lambda>)� _getPluginsr Z
IServiceMakerr� r� r r� r� )r Zpluginsr� r r r � subCommands� s
�zServerOptions.subCommands)N)r' r( r) ZlongdescZoptFlags�joinrA rG Z
optParametersr r� Z
CompleteFilesZ CompleteDirsr� r� r Z
getPluginsr� r! r� Zopt_br� r� r� r� �propertyr r r r r� , sj ������
���������
r� c
C sb |� }z |� � W nB tjk
rT } z"t|� tdtjd |f � W 5 d }~X Y n
X | |� d S )Nz%s: %sr )r� r �errorrg r3 r� )ZrunAppr� r~ Zuer r r r1 � s (r1 c C sF t �| ||�}t�|��|� t|�}|r.d }t�|�j||d� d S )N)r� r� )r r� r � IPersistableZsetStyler� �save)ZfileinZtypeinr� ZfileoutZtypeoutZencryptrW r r r � convertStyle� s r� c C sT ddl m} t�| ��� |r:t�| �}|�dd|jd� |�ddt�| �j � d S )Nr rY ZafterZshutdownZbefore)
r\ r8 r ZIServiceZ startServicer r� ZaddSystemEventTriggerr� Z stopService)rW r� r8 r9 r r r �startApplication� s
�r� c C s" t � | t j� t�t�� | � dS )a
Force the application to terminate with the specified signal by replacing
the signal handler with the default and sending the signal to ourselves.
@param sig: Signal to use to terminate the process with C{os.kill}.
@type sig: C{int}
N)rx �SIG_DFLri �kill�getpid)Zsigr r r �_exitWithSignal� s r� )NN)>Z
__future__r r r r3 ri rl r� r{ rx rS �operatorr Ztwistedr r r Ztwisted.applicationr r
r\ r Ztwisted.persistedr Ztwisted.pythonr
r r r r r Ztwisted.python._oldstyler Ztwisted.python.reflectr r r Ztwisted.internet.interfacesr Z twisted.application.reactorsr r �objectr r+ r; rA rI rm r� r� r� r� r� r� r� r� r� r1 r� r� r� r r r r �<module> sN o �
5q@n