← Back
Editing: 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
Save File
Cancel