\dqZddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z ddl mZmZddlmZmZddlmZddlmZddlmZdd lmZmZmZmZmZmZdd l m!Z!m"Z"m#Z#Gd d Z$Gd de$Z%Gdde$Z&GddZ'GddZ(dZ)d%dZ*dZ+dZ,GddZ-dZ.dZ/GddZ0Gdd ej1e0Z2d!Z3d"Z4d#Z5d$Z6dS)&N) attrgetter) copyrightloggerplugin)reactorsservice) NoSuchReactorinstallReactor)defer)_ISupportsExitSignalCapturing)sob)failureloglogfileruntimeusageutil)namedAny namedModulequalceZdZdZdZdZdS)_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"||_||_dSN) profileOutput saveStats)selfrrs 7lib/python3.11/site-packages/twisted/application/app.py__init__z_BasicProfiler.__init__%s*"c:d|d|}|dz }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)rmoduleess r_reportImportErrorz!_BasicProfiler._reportImportError)s6 5v 4 4 4 4   mmr N)__name__ __module__ __qualname____doc__rr'r rrrs<###     r rceZdZdZdZdS) ProfileRunnerz1 Runner for the standard profile module. cN ddl}n-#t$r }|d|Yd}~nd}~wwxYw|}||j|jr||jdStj t|jdc}t_ | |tj ct_ }| dS#|tj ct_ }| wxYw)z: Run reactor under the standard profiler. rNprofilea)r0 ImportErrorr'Profileruncallrunr dump_statsrsysstdoutopen print_statsclose)rreactorr0r%ptmps rr5zProfileRunner.run>s 2 NNNN 2 2 2  # #Iq 1 1 1 1 1 1 1 1 2 OO   '+ >  LL+ , , , , ,!j$t/A3*G*GOC  "%sz C #&sz C s 1,12C55/D$Nr(r)r*r+r5r,r rr.r.9s-r r.ceZdZdZdZdS)CProfileRunnerz) Runner for the cProfile module. c ddl}ddl}n-#t$r }|d|Yd}~nd}~wwxYw|}||j|jr||j dSt|j d5}| ||}| | d|ddddS#1swxYwYdS)z: Run reactor under the cProfile profiler. rNcProfilew)stream)rCpstatsr2r'r3r4r5rr6rr9Stats strip_dirs sort_statsr:)rr<rCrGr%r=rEr&s rr5zCProfileRunner.runYs` 3 OOO MMMM 3 3 3  # #J 2 2 2 2 2 2 2 2 3      '+ > LL+ , , , , ,d(#.. &LL6L22  R                       s# 505ADDDNr?r,r rrArATs-     r rAc"eZdZdZeedZdZdS) AppProfilerz Class which selects a specific profile runner based on configuration options. @ivar profiler: the name of the selected profiler. @type profiler: C{str} )r0cprofilecR|dd}|dd}|dd|_|j|jvr*|j|j||}|j|_dSt d|j)N savestatsFr0profilerrMzUnsupported profiler name: )getlowerrP profilersr5r#)roptionsrrrPs rrzAppProfiler.__init__zsKK U33  It44  J ;;AACC =DN * *4t~dm4]INNH|DHHHJ4=JJKK Kr N)r(r)r*r+r.rArSrr,r rrLrLosA*~FFILLLLLr rLc4eZdZdZdZdZdZdZdZdZ 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}. Nct|dd|_|dpd|_dS)zE Initialize an L{AppLogger} with a L{ServerOptions}. rrN)rQ _logfilename_observerFactoryrrTs rrzAppLogger.__init__s9$KK 266 ' H 5 5 =r c|j|}nB|tjd}| |tjd}||}||_tj|jr |jg}nutj|jrtj|jg}n6tj dtdtj|jg}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} NaZPassing 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)rZ getComponentr ILogObserverr_getLogObserver _observer providedByLegacyLogObserverWrapperwarningswarnDeprecationWarningglobalLogBeginnerbeginLoggingTo _initialLog)r applicationobserver observerss rstartzAppLogger.starts;  ,,,..HH"//0CTJJH&33C4DdKK  ++--H!   ) )$. 9 9 J(II   ( ( 8 8 J8HHIII M#     8HHII // ::: r c(ddlm}tj|dt jtjtj tj|dt|j dS)z1 Print twistd start log message. rr<z1twistd {version} ({exe} {pyVersion}) starting up.)versionexe pyVersionzreactor class: {reactor}.N) twisted.internetr<r _loggerForinforrqr7 executablershortPythonVersionr __class__)rr<s rrjzAppLogger._initialLogs -,,,,,$$$ ?%022 %   $$$ 'g6G1H1H %     r c|jdks|js tj}n$tj|j}t j|S)zr Create a log observer to be added to the logging system before running this application. -)rYr7r8rLogFile fromFullPathrtextFileLogObserver)rlogFiles rrazAppLogger._getLogObserversL   # #4+< #jGGo2243DEEG)'222r ctj|d|j-tj|jd|_dSdS)zS Remove all log observers previously set up by L{AppLogger.start}. zServer Shut Down.N)rrurvrbglobalLogPublisherremoveObserverrs rstopzAppLogger.stopsX $$$%8999 > %  % 4 4T^ D D D!DNNN & %r ) r(r)r*r+rbrrnrjrarr,r rrVrVsq"I>>>000d   3 3 3"""""r rVc~d}d}d}|tj_|tj_|tj_dS)Nc||ddlm}|d|jdS)Nrrp)clear_all_breaks set_continuertr< callLaterr)rargr<s rdo_stopzfixPdb..do_stopsU  ,,,,,,!W\***qr c$tddS)NzEstop - Continue execution, then cleanly shutdown the twisted reactor.)printrs r help_stopzfixPdb..help_stops! V     r c.tjddS)Nr)os_exitrs rset_quitzfixPdb..set_quits  r )pdbPdbrrr)rrrs rfixPdbrsT    CGCGO!CGr c|ddlm} |dr|||dSdS|dr|t_|t_t jdkr@tjtj dtjtj dttj |jdS|dS#t$rd }|d r|}ntd d }d } t!j|||r|YdSYdS#|r|wwxYwwxYw)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. Nrrpr0debugposixc(tjSrr set_traceargss rz'runReactorWithLogging..+s CMOOr c(tjSrrrs rrz'runReactorWithLogging..,s 3=??r FnodaemonzTWISTD-CRASH.logr1Tfile)rtr<r5r7r8stderrr platformTypesignalSIGUSR2SIGINTrrr4 BaseExceptionr9 traceback print_excflushr;)config oldstdout oldstderrrPr<r;rs rrunReactorWithLoggingr s(,,,,,, )  # W%%%%%$# G_ "CJ"CJ#w.. fn.K.KLLL fm-J-JKKK HHH K $ $ $ $ $ KKMMMMM     *  DD*C00DE   T * * * * JJLLL     u    s/CBCC)E()E /E( E$$E(c2|rtjdSdS)Nz Passphrase: )getpassneededs r getPassphraser@s ~...tr c2|rtjdSdS)NzEncryption passphrase: )r getPasswordrs rgetSavePassphraserGs!  9:::tr c>eZdZdZeZeZdZdZ dZ dZ dZ dZ 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|||_|||_|||_dSr)rprofilerFactoryrP loggerFactoryr)rrs rrzApplicationRunner.__init__hs7 ,,V44 ((00 r c|||_|j|j||jdS)z& Run the application. N)preApplicationcreateOrGetApplicationrkrrnpostApplicationrrs rr5zApplicationRunner.runmso 6688 $*+++  r c|ddlm}t|j|||j|t j|r|j|_dSd|_dS)z Run the reactor with the given configuration. Subclasses should probably call this from C{postApplication}. @see: L{runReactorWithLogging} Nrrp)rtr<rrrPr rc _exitSignal)rr<rrs r startReactorzApplicationRunner.startReactorysh ? 0 0 0 0 0 0dk9iPWXXX ( 3G < < $&2D   #D   r ct)z Override in subclass. This should set up any state necessary before loading and running the Application. NotImplementedErrorrs rrz ApplicationRunner.preApplications"###r ct)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. rrs rrz!ApplicationRunner.postApplications"###r cP|jjrj|jj|jj}||jj}t j|j}||n/t|jd}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 ApplicationtapnamesetServiceParentrgetApplication)rplgserrk passphrases rrz(ApplicationRunner.createOrGetApplications ; ! B++DK,BCC//$+"899C!-ck::K   - - - -&t{;'?@@J(jAAKr N)r(r)r*r+rLrrVrrr5rrrrr,r rrrNs,"OM111   $$$ $$$$$$r rc\fddDd}|dddi|d|d}} tjd|ztj|||}tjdn#t $r}d |z}t |tr|jdd kr|d z }tj tj tj|tj tjd |zd zYd}~nd}~wwxYw|S)Nc4g|]}| ||fSr,r,).0trs r z"getApplication..s*KKKAK&)QKKKr )pythonsourcerrrpicklerz Loading %s...zLoaded.zFailed to load application: %srkaN 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 )rQrmsgrloadApplication Exception isinstanceKeyErrorrrrrdeferrr7exit)rrr&filenamestylerkr%s` rrrsFKKKK!=KKKANAdVX.221Q41>>eH" (*+++-hzJJ    """ ,q 0 a " " qvayM'A'A  A ----    D!!!!!!!!" sAB D)BD$$D)c`tjdtjDS)Ncg|] }|j Sr,) shortName)rrs rrz"_reactorAction..sOOOqq{OOOr )r CompleteListrgetReactorTypesr,r r_reactorActionrs+  OOH4L4N4NOOO P PPr cveZdZdZejdeiZej Z e e j ZdZdZeZdS)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. r<) optActionsc <t|td}d}|D]} t|j|jd|jdd|jdD#t$r9}|d |j|j|j d z }Yd }~d }~wwxYw|rN|jd|jd |j|td ) zE Display a list of possibly available reactor names. rkeyrXz z<4 rz !{:<4} {} ({}) rNz. reactors not available on this platform: ) sorted_getReactorTypesrr moduleName messageOutputwriter descriptionr2formatrr#)rrctsnotWorkingReactorsrr%s ropt_help_reactorsz'ReactorSelectionMixin.opt_help_reactorssMd++--:k3J3JKKK  A AL)))"(()S )S)S)S!-)S)S)STTTT   "&=&D&DKMF1I''""""""   9   $ $T * * *   $ $E      $ $%7 8 8 8mmsAA99 B</B77B<c t|||d<dS#t$rd|d}tj|t$r}d|d}tj|d}~wwxYw)zX Which reactor to use (see --help-reactors for a list of possibilities) r<z'The specified reactor does not exist: 'z:'. See the list of available reactors with --help-reactorsz9The specified reactor cannot be used, failed with error: z9. See the list of available reactors with --help-reactorsN)r r r UsageErrorr)rrrr%s r opt_reactorz!ReactorSelectionMixin.opt_reactors ( 9 % % % (DOOO ( ( ( (&/YY1  "3'' ' ( ( ( (&'QQ)  "3'' '  (s-A$AA$N)r(r)r*r+r CompletionsrcompDatar7r8r staticmethodrrrrropt_rr,r rrrss!u Y,GHHHHJM#|H$<==2(((8 EEEr rc eZdZdZgdgdgdgZgdgdgddd d d d ejzggd gdgdgdgZe j dge j de j de j de j dZ eejZdZdZeZdZddZdZedZd S) ServerOptionszQtwistd reads a twisted.application.service.Application out of a file and runs it.)rONzBsave the Stats object rather than the text output of the profiler.)no_saveozdo not save state on shutdown)rr%z(The specified tap/aos file is encrypted.)rlNz%log to a specified file, - for stdout)rNNzA fully-qualified name to a log observer factory to use for the initial log observer. Takes precedence over --logfile and --syslog (when available).)r0r=Nz7Run in profile mode, dumping results to specified file.rPNrMz!Name of the profiler to use (%s).z, )rfz twistd.tapzread the given .tap file)ryNz:read an application from within a Python file (implies -o))rr&Nz2Read an application from a .tas file (AOT format).)rundird.z-Change to a supplied directory before running)rrrz*.tapz *.(tac|py)z*.tas)rrrr)mutuallyExclusivercd|d<d|vr|d|_ntj|_tj|dS)NFrr8)r8r7rOptionsr)rr1kws rrzServerOptions.__init__YsFW r>>X,DKK*DK t$$$$$r c^tjdtjd|d<dS)z Run the application in the Python Debugger (implies nodaemon), sending SIGUSR2 will drop into debugger TrN)r setDebuggingrstartDebugModers r opt_debugzServerOptions.opt_debugas1 4      W r ctjtj ddl}n#t $rYdSwxYw|tjdS)z Print an insanely verbose log of everything that happens. Useful when debugging freezes or locks in complex code. rN)r7settracerspewer threadingr2)rrs ropt_spewzServerOptions.opt_spewlsh T[!!!          FF 4;'''''s % 33cx|tjddpdg}tj||dS)Nrz--help)r7argvrr parseOptionsr[s rr zServerOptions.parseOptionsxs; ?hqrrl0xjG ""411111r c|js|drd|d<|d[ t|d|d<dS#t$r3}tjd|d|d}~wwxYwdS)NrTr rz%Logger '{}' could not be imported: {})rrrrrr)rr%s r postOptionszServerOptions.postOptions}s ? #d8n #"DO > % !)$x.!9!9X   &;BB4>STUU  & %s8 A5.A00A5c#K|tj}i|_t |t dD]&}||j|j<|jd|fd|jfV'dS)Nrrc*|Sr)rT)plugs rrz+ServerOptions.subCommands..s$,,..r ) _getPluginsr IServiceMakerrrrrr)rpluginsr%s r subCommandszServerOptions.subCommandss""7#8997 9(=(=>>>  D/3D t| , !000       r r)r(r)r*longdescoptFlagsjoinrLrS optParametersrr CompleteFiles CompleteDirsrrr getPluginsr&rropt_brr r"propertyr)r,r rrrs !    :99FFFH HGG          /$))KrZsS  ----------11111111GFFFFFFF""""""EEEEEE!!!!!!FFFFFFFFFFFFFFFF>>>>>>>>>><N6     ^   6LLLLLLLL,o"o"o"o"o"o"o"o"d""",0000fhhhhhhhhV2QQQBBBBBBBBJ{{{{{EM#8{{{|   PPP        r