Server : Apache/2.4.52 (Ubuntu) System : Linux webserver 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov 6 17:42:15 UTC 2 x86_64 User : www-data ( 33) PHP Version : 8.1.2-1ubuntu2.21 Disable Function : NONE Directory : /lib/python3/dist-packages/twisted/application/__pycache__/ |
o
�bqZ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
m Z m Z d dl
mZmZ d dlmZmZ d dlmZ d dlmZ d dlmZ d d lmZmZm Z m Z m Z m Z d d
l m!Z!m"Z"m#Z# G d d � d �Z$G d
d� de$�Z%G dd� de$�Z&G dd� d�Z'G dd� d�Z(dd� Z)d/dd�Z*dd� Z+dd � Z,G d d � d �Z-d d � Z.d!d"� Z/G d#d$� d$�Z0G d%d&� d&e j1e0�Z2d'd(� Z3d)d*� Z4d+d,� Z5d-d.� Z6dS )0� N)�
attrgetter)� copyright�logger�plugin)�reactors�service)�
NoSuchReactor�installReactor)�defer)� _ISupportsExitSignalCapturing)�sob)�failure�log�logfile�runtime�usage�util)�namedAny� namedModule�qualc @ 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|� d|� �}|d7 }t |��)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.
zFailed to import module �: z�
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.
)�
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 @ � e Zd ZdZdd� ZdS )�
ProfileRunnerz1
Runner for the standard profile module.
c
C s� zddl }W n ty } z | �d|� W Y d}~nd}~ww |�� }|�|j� | jr4|�| j� dS t j
t | jd�}t _
z|� � W |t j
t _
}|�
� dS |t j
t _
}|�
� w )z:
Run reactor under the standard profiler.
r N�profile�a)r* � ImportErrorr# �Profile�runcall�runr �
dump_statsr �sys�stdout�open� print_stats�close)r �reactorr* r! �p�tmpr r r r/ > s" ��
�
zProfileRunner.runN�r$ r% r& r' r/ r r r r r) 9 � r) c @ r( )�CProfileRunnerz)
Runner for the cProfile module.
c
C s� z
ddl }ddl}W n ty" } z | �d|� W Y d}~nd}~ww |�� }|�|j� | jr8|�| j � dS t
| j d�� }|j ||d�}|� � |�
d� |�� W d � dS 1 s^w Y dS )z:
Run reactor under the cProfile profiler.
r N�cProfile�w)�stream���)r< �pstatsr, r# r- r. r/ r r0 r r3 �Stats�
strip_dirs�
sort_statsr4 )r r6 r< r@ r! r7 r> r" r r r r/ Y s" ��
"�zCProfileRunner.runNr9 r r r r r; T r: 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 sd |� dd�}|� dd �}|� dd��� | _| j| jv r*| j| j ||�}|j| _d S td| j� ���)N� savestatsFr* �profilerrE zUnsupported profiler name: )�get�lowerrG � profilersr/ r )r �optionsr r rG r r r r z s zAppProfiler.__init__N)r$ r% r& r' r) r; rJ r r r r r rD o s
rD 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�p
d| _dS )zE
Initialize an L{AppLogger} with a L{ServerOptions}.
r � r N)rH � _logfilename�_observerFactory�r rK r r r r � s zAppLogger.__init__c C s� | j dur
| � � }n|�tjd�}|du r |�tjd�}|du r$| �� }|| _tj�| j�r3| jg}n tj�| j�rBt�| j�g}nt 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)rO � getComponentr � ILogObserverr �_getLogObserver� _observer�
providedBy�LegacyLogObserverWrapper�warnings�warn�DeprecationWarning�globalLogBeginner�beginLoggingTo� _initialLog)r � application�observer� 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 �r6 z1twistd {version} ({exe} {pyVersion}) starting up.)�version�exe� pyVersionzreactor class: {reactor}.N)
�twisted.internetr6 r �
_loggerFor�infor rd r1 �
executabler �shortPythonVersionr � __class__)r r6 r r r r^ � s
�
�zAppLogger._initialLogc C s0 | j dks| j s tj}ntj�| j �}t�|�S )zr
Create a log observer to be added to the logging system before running
this application.
�-)rN r1 r2 r �LogFile� fromFullPathr �textFileLogObserver)r �logFiler r r rU � s
zAppLogger._getLogObserverc C s6 t �| ��d� | jdurt j�| j� d| _dS dS )zS
Remove all log observers previously set up by L{AppLogger.start}.
zServer Shut Down.N)r rh ri rV �globalLogPublisher�removeObserver�r r r r �stop� s
�zAppLogger.stop)
r$ r% r& r' rV r rb r^ rU ru r r r r rL � s 2 rL c C s4 dd� } dd� }dd� }|t j_| t j_|t j_d S )Nc S s. | � � | �� ddlm} |�d|j� dS )Nr rc � )�clear_all_breaks� set_continuerg r6 � callLaterru )r �argr6 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.)�printrt r r r � help_stop s �zfixPdb.<locals>.help_stopc S s t �d� d S )Nr )�os�_exitrt r r r �set_quit s zfixPdb.<locals>.set_quit)�pdb�Pdbr� r{ r} )r{ r} r� r r r �fixPdb� s r� c C s |du r
ddl m} zG| d r |dur|�|� W dS W dS | d rK|t_|t_tjdkr?t�tj dd� � t�tj
d d� � t � t �
|j� W dS |�� W dS ty� d
}| d ra|}ntd d
�}d}ztj|d� |�� W |r}|�� Y dS Y dS |r�|�� w w w )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 rc r* �debug�posixc W � t �� S r �r� � set_trace��argsr r r �<lambda>+ � z'runReactorWithLogging.<locals>.<lambda>c W r� r r� r� r r r r� , r� F�nodaemonzTWISTD-CRASH.logr+ T��file)rg r6 r/ r1 r2 �stderrr � platformType�signal�SIGUSR2�SIGINTr� r� r. �
BaseExceptionr3 � traceback� print_exc�flushr5 )�config� oldstdout� oldstderrrG r6 r5 r� r r r �runReactorWithLogging
s> �
�
��r� c C s | rt � d�S d S )Nz Passphrase: )�getpass��neededr r r �
getPassphrase@ �
r� c C s | rt �d�S d S )NzEncryption passphrase: )r � getPasswordr� r r r �getSavePassphraseG r� 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� �profilerFactoryrG �
loggerFactoryr )r r� r r r r h s zApplicationRunner.__init__c C s6 | � � | �� | _| j�| j� | �� | j�� dS )z&
Run the application.
N)�preApplication�createOrGetApplicationr_ r rb �postApplicationru rt r r r r/ m s
zApplicationRunner.runc C sH |du r
ddl m} t| j||| j|� t�|�r |j| _dS d| _dS )z�
Run the reactor with the given configuration. Subclasses should
probably call this from C{postApplication}.
@see: L{runReactorWithLogging}
Nr rc )rg r6 r� r� rG r rW � _exitSignal)r r6 r� r� r r r � startReactory s
z ApplicationRunner.startReactorc C � t � �)z�
Override in subclass.
This should set up any state necessary before loading and
running the Application.
��NotImplementedErrorrt r r r r� � s z ApplicationRunner.preApplicationc C r� )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.
r� rt r r r r� � s z!ApplicationRunner.postApplicationc C s^ | j jr | j j| j j }|�| j j�}t�|j�}|�|� |S t | 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�
loadedPlugins� makeService�
subOptionsr � Application�tapname�setServiceParentr� �getApplication)r �plg�serr_ �
passphraser r r r� � s
� z(ApplicationRunner.createOrGetApplicationN)r$ r% r& r' rD r� rL r� r r/ r� r� r� r� r r r r r� N s
r� c
s� � fdd�dD �d }|d ddi� |d |d �}}zt�d| � t�|||�}t�d � W |S tyr } z4d
| }t|t�rN|jd d krN|d 7 }t j
tj d
� t�|� t� � t
�d| d � W Y d }~|S d }~ww )Nc s g | ] }� | r� | |f�qS r r )�.0�t�r� r r �
<listcomp>� s z"getApplication.<locals>.<listcomp>)�python�sourcer� r r� �picklerv z
Loading %s...zLoaded.z Failed to load application: %sr_ 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.
r� �
)rH r �msgr �loadApplication� Exception�
isinstance�KeyErrorr� r� r� r �deferrr1 �exit)r� r� r" �filename�styler_ 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 � 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.
r6 )�
optActionsc C s� t | �� td�d�}d}|D ]9}zt|j� | j�d|jd�d|j� d�� W q t yG } z|d�
|j|j|j d �7 }W Y d
}~qd
}~ww |r\| j�d� | j�d � | j�|� t d ��) zE
Display a list of possibly available reactor names.
r� ��keyrM z z<4� r� z !{:<4} {} ({})
r Nz. reactors not available on this platform:
)
�sorted�_getReactorTypesr r �
moduleName�
messageOutput�writer� � descriptionr, �formatr� r )r �rcts�notWorkingReactorsr� r! r r r �opt_help_reactors� s*
$��� � z'ReactorSelectionMixin.opt_help_reactorsc
C sf zt |� W n& ty d|f }t�|�� ty, } z
d|f }t�|��d}~ww || 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-reactorsNr6 )r r r �
UsageErrorr� )r r� r� r! r r r � opt_reactor� s" ��
��
�� z!ReactorSelectionMixin.opt_reactorN)r$ r% r& r' r � Completionsr� �compDatar1 r2 r� � staticmethodr r� r� r� r� �opt_rr r r r r� � s
r� c
@ s� e Zd ZdZg d�g d�g d�gZg d�g d�g d�dd d
d d �ej� gg d
�g d�g d�g d�gZe j
dge � d�e � d�e � d�e � � d�d�Z
eej�Zdd� Zdd� ZeZdd � Zd#d d �Zd d � Zed!d"� �Zd S )$�
ServerOptionszQtwistd reads a twisted.application.service.Application out of a file and runs it.)rF NzBsave the Stats object rather than the text output of the profiler.)�no_save�oz do not save state on shutdown)r� r! z(The specified tap/aos file is encrypted.)r �lNz%log to a specified file, - for stdout)r NNz�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* r7 Nz7Run in profile mode, dumping results to specified file.rG NrE z!Name of the profiler to use (%s).z, )r� �fz
twistd.tapzread the given .tap file)r� �yNz:read an application from within a Python file (implies -o))r� r" Nz2Read an application from a .tas file (AOT format).)�rundir�d�.z-Change to a supplied directory before running)r� r� r� z*.tapz
*.(tac|py)z*.tas)r� r� r� r� )�mutuallyExclusiver� c O s4 d| d< d|v r|d | _ ntj | _ tj�| � d S )NFr� r2 )r2 r1 r �Optionsr )r r+ �kwr r r r Y 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
Tr� N)r
� setDebuggingr
�startDebugModert r r r � opt_debuga s
zServerOptions.opt_debugc C s> t �tj� zddl}W n
ty Y dS w |�tj� dS )z�
Print an insanely verbose log of everything that happens.
Useful when debugging freezes or locks in complex code.
r N)r1 �settracer �spewer� threadingr, )r r� r r r �opt_spewl s �zServerOptions.opt_spewc C s. |d u rt jdd � p
dg}tj�| |� d S )Nrv z--help)r1 �argvr r� � parseOptionsrP r r r r� x s zServerOptions.parseOptionsc
C sl | j s| d r d| d< | d d ur4z t| d �| d< W d S ty3 } z t�d�| d |���d }~ww d S )Nr� Tr� r z%Logger '{}' could not be imported: {})r� r r� r r� r� )r r! r r r � postOptions} s ����zServerOptions.postOptionsc c sT � | � tj�}i | _t|td�d�D ]}|| j|j< |jd |fdd�|jfV qd S )Nr� r� c S s | � � S r )rK )�plugr r r r� � r� z+ServerOptions.subCommands.<locals>.<lambda>)� _getPluginsr �
IServiceMakerr� r� r r� r� )r �pluginsr� r r r � subCommands� s �
��zServerOptions.subCommandsr )r$ r% r& �longdesc�optFlags�joinrD rJ �
optParametersr r� �
CompleteFiles� CompleteDirsr� r� r �
getPluginsr� r r� �opt_br� r� r� �propertyr r r r r r� sJ �� ��!��
r� c
C sv |� }z|� � W n+ tjy4 } z d�tjdd� �}t|� t|� d|� �� W Y d }~d S d }~ww | |� d S )N� r rQ r )r� r �errorr r1 r� r| )�runAppr� r� �ue�commstrr r r r/ � s �� r/ c C sF t �| ||�}t�|��|� t|�}|rd }t�|�j||d� d S )N)r� r� )r r� r � IPersistable�setStyler� �save)�filein�typeinr� �fileout�typeout�encryptr_ r r r � convertStyle� s r c C sT ddl m} t�| ��� |r t�| �}|�dd|jd� |�ddt�| �j � d S )Nr rc �after�shutdown�before)
rg r6 r �IService� startServicer r �addSystemEventTriggerr � stopService)r_ r r6 r7 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)r� �SIG_DFLr~ �kill�getpid)�sigr r r �_exitWithSignal� s r$ )NN)7r� r~ r� r� r1 r� rY �operatorr �twistedr r r �twisted.applicationr r � twisted.application.reactorsr r rg r
�twisted.internet.interfacesr �twisted.persistedr �twisted.pythonr
r r r r r �twisted.python.reflectr r r r r) r; rD rL r� r� r� r� r� r� r� r� r� r� r/ r r r$ r r r r �<module> sD r
3kE~