U “jpZ@sddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z ddl mZmZddlmZmZddlmZddlmZddlmZdd lmZmZmZmZmZmZdd l m!Z!m"Z"m#Z#Gd d d Z$Gd dde$Z%Gddde$Z&GdddZ'GdddZ(ddZ)d/ddZ*ddZ+ddZ,GdddZ-dd Z.d!d"Z/Gd#d$d$Z0Gd%d&d&ej1e0Z2d'd(Z3d)d*Z4d+d,Z5d-d.Z6dS)0N) attrgetter) copyrightloggerplugin)reactorsservice) NoSuchReactorinstallReactor)defer)_ISupportsExitSignalCapturing)sob)failureloglogfileruntimeusageutil)namedAny namedModulequalc@s eZdZdZddZddZdS)_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} cCs||_||_dSN) profileOutput saveStats)selfrrr;/tmp/pip-unpacked-wheel-59kc99xd/twisted/application/app.py__init__%sz_BasicProfiler.__init__cCs$d|d|}|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. 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. N) SystemExit)rmoduleesrrr_reportImportError)sz!_BasicProfiler._reportImportErrorN)__name__ __module__ __qualname____doc__rr#rrrrrs rc@seZdZdZddZdS) ProfileRunnerz1 Runner for the standard profile module. c Csz ddl}Wn.tk r:}z|d|W5d}~XYnX|}||j|jrd||jns   zProfileRunner.runNr$r%r&r'r.rrrrr(9sr(c@seZdZdZddZdS)CProfileRunnerz) Runner for the cProfile module. c Cszddl}ddl}Wn.tk rB}z|d|W5d}~XYnX|}||j|jrl||j n@t |j d.}|j ||d}| | d|W5QRXdS)z: Run reactor under the cProfile profiler. rNcProfilew)stream)r:pstatsr+r#r,r-r.rr/rr2ZStatsZ strip_dirsZ sort_statsr4)rr5r:r>r!r6r<r"rrrr.Ys   zCProfileRunner.runNr8rrrrr9Tsr9c@s"eZdZdZeedZddZdS) 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)cprofilecCsf|dd}|dd}|dd|_|j|jkrR|j|j||}|j|_ntd|jdS)N savestatsFr)profilerr@zUnsupported profiler name: )getlowerrB profilersr.r)roptionsrrrBrrrrzs    zAppProfiler.__init__N)r$r%r&r'r(r9rErrrrrr?os r?c@s<eZdZdZdZddZddZddZd 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}. NcCs"|dd|_|dpd|_dS)zE Initialize an L{AppLogger} with a L{ServerOptions}. rrN)rC _logfilename_observerFactoryrrFrrrrszAppLogger.__init__cCs|jdk r|}n$|tjd}|dkr8|tjd}|dkrH|}||_tj|jrf|jg}n.do_stopcSs tddS)NzEstop - Continue execution, then cleanly shutdown the twisted reactor.)printr_rrr help_stopszfixPdb..help_stopcSstddS)Nr)os_exitr_rrrset_quitszfixPdb..set_quit)pdbZPdbrhrcre)rcrerhrrrfixPdbs rjc Cs|dkrddlm}z~|dr2|dk r||n^|dr|t_|t_tjdkrtttj ddttj d dt t |jn|Wn\tk rd }|d r|}ntd d }d}ztj|d|W5|r|XYnXdS)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. NrrWr)debugposixcWstSrri set_traceargsrrr+z'runReactorWithLogging..cWstSrrmrorrrrq,rrFZnodaemonzTWISTD-CRASH.logr*Tfile)rYr5r.r0r1stderrrZ platformTypesignalSIGUSR2SIGINTrjrir- BaseExceptionr2r3 traceback print_excflush)config oldstdout oldstderrrBr5r3rtrrrrunReactorWithLogging s4       rcCs|rtdSdSdS)Nz Passphrase: )getpassneededrrr getPassphrase@s rcCs|rtdSdSdS)NzEncryption passphrase: )rZ getPasswordrrrrgetSavePassphraseGs rc@sHeZdZdZeZeZddZddZ ddZ 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}. cCs"||_|||_|||_dSr)r}profilerFactoryrB loggerFactoryr)rr}rrrrhs zApplicationRunner.__init__cCs6|||_|j|j||jdS)z& Run the application. N)preApplicationcreateOrGetApplicationrUrrVpostApplicationr`r_rrrr.ms  zApplicationRunner.runcCsF|dkrddlm}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} NrrW)rYr5rr}rBr rPZ _exitSignal)rr5r~rrrr startReactorys    zApplicationRunner.startReactorcCs tdS)z Override in subclass. This should set up any state necessary before loading and running the Application. NNotImplementedErrorr_rrrrsz ApplicationRunner.preApplicationcCs tdS)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. Nrr_rrrrsz!ApplicationRunner.postApplicationcCs\|jjr>|jj|jj}||jj}t|j}||nt |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 loadedPluginsZ makeServiceZ subOptionsr ApplicationtapnameZsetServiceParentrgetApplication)rZplgZserrU passphraserrrrs    z(ApplicationRunner.createOrGetApplicationN)r$r%r&r'r?rrGrrr.rrrrrrrrrNs   rc sfdddDd}|dddi|d|d}}z*td|t|||}td Wn|tk r}z^d |}t|tr|jdd kr|d 7}t j tj d t|t t d|dW5d}~XYnX|S)Ncs g|]}|r||fqSrr).0tr}rr sz"getApplication..)pythonsourcertrrtpickleraz Loading %s...zLoaded.zFailed to load application: %srUaN 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. rs )rCrmsgrloadApplication Exception isinstanceKeyErrorrprzr{rZdeferrr0exit)r}rr"filenamestylerUr!rrrrs" $rcCstddtDS)NcSsg|] }|jqSr) shortName)rrrrrrsz"_reactorAction..)rZ CompleteListrgetReactorTypesrrrr_reactorActionsrc@sDeZdZdZejdeidZej Z e e j ZddZddZeZdS) 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. r5) optActionsc Cst|tdd}d}|D]r}z.t|j|jd|jdd|jdWqt k r}z |d |j|j|j d 7}W5d }~XYqXq|r|jd|jd |j|t d d S) zE Display a list of possibly available reactor names. rkeyrHz z<4 rz !{:<4} {} ({}) rNz. reactors not available on this platform: ) sorted_getReactorTypesrrZ moduleName messageOutputwriter descriptionr+formatrpr)rZrctsZnotWorkingReactorsrr!rrropt_help_reactorss& $  z'ReactorSelectionMixin.opt_help_reactorsc Csvz t|Wn\tk r4d|f}t|Yn>tk rh}zd|f}t|W5d}~XYn 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-reactorsNr5)r rr UsageErrorr)rrrr!rrr opt_reactors  z!ReactorSelectionMixin.opt_reactorN)r$r%r&r'r CompletionsrcompDatar0r1r staticmethodrrrrrZopt_rrrrrrs rc @seZdZdZdddgdddgdd d ggZd d dd gddddgddddgdddddejgddddgddddgdddd gd!d"d#d$ggZe j d%ge d&e d'e d(e d)d*Z eejZd+d,Zd-d.ZeZd/d0Zd7d1d2Zd3d4Zed5d6ZdS)8 ServerOptionszQtwistd reads a twisted.application.service.Application out of a file and runs it.rANzBsave the Stats object rather than the text output of the profiler.no_saveozdo not save state on shutdownrr!z(The specified tap/aos file is encrypted.rlz%log to a specified file, - for stdoutrzA fully-qualified name to a log observer factory to use for the initial log observer. Takes precedence over --logfile and --syslog (when available).r)r6z7Run in profile mode, dumping results to specified file.rBr@z!Name of the profiler to use (%s).z, rtfz twistd.tapzread the given .tap fileryz:read an application from within a Python file (implies -o)rr"z2Read an application from a .tas file (AOT format).rundird.z-Change to a supplied directory before running)rtrrz*.tapz *.(tac|py)z*.tas)rtrrr)ZmutuallyExclusivercOs4d|d<d|kr|d|_ntj|_tj|dS)NFrkr1)r1r0rOptionsr)rr*kwrrrrXs  zServerOptions.__init__cCstdtd|d<dS)z Run the application in the Python Debugger (implies nodaemon), sending SIGUSR2 will drop into debugger TrkN)r Z setDebuggingr ZstartDebugModer_rrr opt_debug`s zServerOptions.opt_debugcCs@ttjz ddl}Wntk r.YdSX|tjdS)z Print an insanely verbose log of everything that happens. Useful when debugging freezes or locks in complex code. rN)r0settracerZspewer threadingr+)rrrrropt_spewks   zServerOptions.opt_spewcCs.|dkrtjddpdg}tj||dS)Nraz--help)r0argvrr parseOptionsrKrrrrwszServerOptions.parseOptionsc Cst|js|drd|d<|ddk rpzt|d|d<Wn8tk rn}ztd|d|W5d}~XYnXdS)NrTrrz%Logger '{}' could not be imported: {})rrrrrr)rr!rrr postOptions|s zServerOptions.postOptionsccsR|tj}i|_t|tddD]*}||j|j<|jd|fdd|jfVq"dS)NrrcSs|Sr)rF)plugrrrrqrrz+ServerOptions.subCommands..) _getPluginsrZ IServiceMakerrrrrr)rZpluginsrrrr subCommandss   zServerOptions.subCommands)N)r$r%r&ZlongdescZoptFlagsjoinr?rEZ optParametersrrZ CompleteFiles CompleteDirsrrrZ getPluginsrrrZopt_brrrpropertyrrrrrrsf     !    rc Csr|}z |WnRtjk rd}z2dtjdd}t|t|d|W5d}~XYn X||dS)N rrLr)rrerrorrr0rrd)ZrunApprr}ZueZcommstrrrrr.s $r.cCsFt|||}t||t|}|r.d}t|j||ddS)N)rr)rrr IPersistableZsetStylersave)ZfileinZtypeinrfileoutZtypeoutZencryptrUrrr convertStyles rcCsTddlm}t||r:t|}|dd|jd|ddt|j dS)NrrWaftershutdownbefore) rYr5rZIServiceZ startServicer rZaddSystemEventTriggerrZ stopService)rUrr5r6rrrstartApplications   rcCs"t|tjtt|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)rvSIG_DFLrfkillgetpid)sigrrr_exitWithSignalsr)NN)7rrfrirvr0rzrQoperatorrZtwistedrrrZtwisted.applicationrrZtwisted.application.reactorsrr rYr Ztwisted.internet.interfacesr Ztwisted.persistedr Ztwisted.pythonr rrrrrZtwisted.python.reflectrrrrr(r9r?rGrjrrrrrrrrrr.rrrrrrrsB     r 3kE}