+ jpZ^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RI H t H t H t ^RI HtHt^RIHtHt^RIHt^RIHt^RIHt^R IHtHtHtHtHtHt^R I H!t!H"t"H#t#!R R 4t$!R R]$4t%!RR]$4t&!RR4t'!RR4t(Rt)R%Rlt*Rt+Rt,!RR4t-Rt.Rt/!RR4t0!RR ]Pb]04t2R!t3R"t4R#t5R$t6R#)&N) attrgetter) copyrightloggerplugin)reactorsservice) NoSuchReactorinstallReactor)defer)_ISupportsExitSignalCapturing)sob)failureloglogfileruntimeusageutil)namedAny namedModulequalc0a]tRt^toRtRtRtRtVtR#)_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} cWnW nR#N profileOutput saveStats)selfrrs&&&9/usr/lib/python3/dist-packages/twisted/application/app.py__init___BasicProfiler.__init__%s *"c :RV RV 2pVR, p\V4h)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_reportImportError!_BasicProfiler._reportImportError)s1 'vhb 4   mr"rN) __name__ __module__ __qualname____firstlineno____doc__r r)__static_attributes____classdictcell__ __classdict__s@rrrs#  r"rc*a]tRt^9toRtRtRtVtR#) ProfileRunnerz) Runner for the standard profile module. c T^RIpXP4pVP VP 4VP 'dVPVP4R#\P\VPR4up\n VP4V\Pu\n pVP4R# \dpTPRT4Rp?LRp?ii;i T\Pu\n pTP4i;i)z* Run reactor under the standard profiler. Nprofilea)r7 ImportErrorr)Profileruncallrunr dump_statsrsysstdoutopen print_statsclose)rreactorr7r'ptmps&& rr<ProfileRunner.run>s 2  OO  '++ >>> LL++ ,!jj$t/A/A3*GOC  "%szz C  2  # #Iq 1 1 2#&szz C s#CC9 C6C11C69.D'Nr+r,r-r.r/r<r0r1r2s@rr5r59sr"r5c*a]tRt^TtoRtRtRtVtR#)CProfileRunnerz! Runner for the cProfile module. c ^RIp^RIpXP 4pVP VP 4VP'dVPVP4R#\VPR4;_uu_4pXPWVR7pVP4VPR4VP4RRR4R# \dpTPRT4Rp?LRp?ii;i +'giR#;i)z* Run reactor under the cProfile profiler. NcProfilew)stream)rLpstatsr9r)r:r;r<rr=rr@Stats strip_dirs sort_statsrA)rrCrLrPr'rDrNr(s&& rr<CProfileRunner.runYs 3       '++ >>> LL++ ,d((#..&LLL2  R   /. 3  # #J 2 2 3/..s$CAC: C7C22C7: D rGNrHr2s@rrJrJTs  r"rJc6a]tRt^otoRtR]R]/tRtRt Vt R#) AppProfilerz Class which selects a specific profile runner based on configuration options. @ivar profiler: the name of the selected profiler. @type profiler: C{str} r7cprofilecfVPRR4pVPRR4pVPRR4P4VnVPVP9d7VPVP,!W24pVPVnR#\ RVP 24h) savestatsFr7NprofilerrWzUnsupported profiler name: )getlowerrZ profilersr<r%)roptionsrrrZs&& rr AppProfiler.__init__zsKK U3  It4  J ;AAC ==DNN *~~dmm4]NH||DH:4==/JK Kr")rZr<N) r+r,r-r.r/r5rJr]r r0r1r2s@rrVrVos&M:~FILLr"rVcFa]tRt^toRtRtRtRtRtRt Rt Rt Vt R#) 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 tVPRR4VnVPR4;'gRVnR#)z5 Initialize an L{AppLogger} with a L{ServerOptions}. rrN)r[ _logfilename_observerFactoryrr^s&&rr AppLogger.__init__s0$KK 26 ' H 5 = =r"c VPeVP4pMDVP\PR4pVf!VP\PR4pVfVP 4pW n\PPVP 4'dVP .pM\PPVP 4'd#\P!VP 4.pM>\P!R\^R7\P!VP 4.p\PPV4VP4R#)aK 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)re getComponentr ILogObserverr_getLogObserver _observer providedByLegacyLogObserverWrapperwarningswarnDeprecationWarningglobalLogBeginnerbeginLoggingTo _initialLog)r applicationobserver observerss&& rstartAppLogger.starts  ,,,.H"//0C0CTJH&33C4D4DdK  ++-H!    ) )$.. 9 9(I    ( ( 8 888HII MM#  88HII  // : r"c 6^RIHp\P!V4P R\ P \P\P!4R7\P!V4P R\VP4R7R#)z! Print twistd start log message. rCz1twistd {version} ({exe} {pyVersion}) starting up.)versionexe pyVersionzreactor class: {reactor}.N) twisted.internetrCr _loggerForinforr}r> executablershortPythonVersionr __class__)rrCs& rruAppLogger._initialLogst -$$$ ?%%002 % $$$ 'g6G6G1H % r"c VPR8XgVP'g\PpM)\PP VP4p\ P!V4#)zZ Create a log observer to be added to the logging system before running this application. -)rdr>r?rLogFile fromFullPathrtextFileLogObserver)rlogFiles& rrlAppLogger._getLogObserversQ    #4+<+<+<jjGoo2243D3DEG))'22r"c \P!V4PR4VPe3\PP VP4RVnR#R#)zC Remove all log observers previously set up by L{AppLogger.start}. zServer Shut Down.N)rrrrmglobalLogPublisherremoveObserverrs&rstopAppLogger.stopsL $$$%89 >> %  % % 4 4T^^ D!DN &r")rdrmre) r+r,r-r.r/rmr ryrurlrr0r1r2s@rraras0"I>0d 3""r"racRpRpRpV\PnV\PnV\PnR#)cVP4VP4^RIHpVP ^VP 4^#)rr|)clear_all_breaks set_continuerrC callLaterr)rargrCs&& rdo_stopfixPdb..do_stops4  ,!W\\*r"c\R4R#)zEstop - Continue execution, then cleanly shutdown the twisted reactor.N)printrs&r help_stopfixPdb..help_stops  V r"c2\P!^4R#)rN)os_exitrs&rset_quitfixPdb..set_quits   r"N)pdbPdbrrr)rrrs rfixPdbrs6  CGGCGGO!CGGr"cVf^RIHpVR,'dVeVPV4R#R#VR,'dV\nV\n\ PR8XdM\P!\PR4\P!\PR4\4\P!VP4R#VP4R# \dRpTR ,'dTpM\R R 4pR p\ P"!TR 7TP%4T'dTP'4R#R# T'dTP'4ii;ii;i)a 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|r7debugposixc,\P!4#rr set_traceargss*r'runReactorWithLogging..+s CMMOr"c,\P!4#rrrs*rrr,s 3==?r"FnodaemonzTWISTD-CRASH.logr8Tfile)rrCr<r>r?stderrr platformTypesignalSIGUSR2SIGINTrrr; BaseExceptionr@ traceback print_excflushrB)config oldstdout oldstderrrZrCrBrs&&&&& rrunReactorWithLoggingr s(, )  # W%$ G__"CJ"CJ##w. fnn.KL fmm-JK H KK $ KKM   *  D*C0DE    T * JJL u  s@C8C8C8B!C8&C88F F &'E+ F +FF cBV'd\P!R4#R#)z Passphrase: N)getpassneededs&r getPassphraser@s ~..r"cBV'd\P!R4#R#)zEncryption passphrase: N)r getPasswordrs&rgetSavePassphraserGs  9::r"cPa]tRtRtoRt]t]tRt Rt Rt Rt Rt RtR tVtR #) ApplicationRunneriNa 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}. cjWnVPV4VnVPV4VnR#r)rprofilerFactoryrZ loggerFactoryr)rrs&&rr ApplicationRunner.__init__hs+ ,,V4 ((0 r"c VP4VP4VnVPP VP4VP 4VPP 4R#)z Run the application. N)preApplicationcreateOrGetApplicationrvrrypostApplicationrrs&rr<ApplicationRunner.runmsU 668 $**+  r"c Vf^RIHp\VPW#VPV4\ P !V4'dVPVnR#RVnR#)z Run the reactor with the given configuration. Subclasses should probably call this from C{postApplication}. @see: L{runReactorWithLogging} Nr|)rrCrrrZr rn _exitSignal)rrCrrs&&&&r startReactorApplicationRunner.startReactorysJ ? 0dkk9PWX ( 3 3G < <&22D #D r"c \4h)zk Override in subclass. This should set up any state necessary before loading and running the Application. NotImplementedErrorrs&rr ApplicationRunner.preApplications "##r"c \4h)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&rr!ApplicationRunner.postApplications "##r"c VPP'dVPPVPP,pVPVPP4p\ P !VP4pVPV4V#\VPR,4p\VPV4pV#)aM 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)rplgserrv passphrases& rr(ApplicationRunner.createOrGetApplications ;; ! ! !++++DKK,B,BCC//$++"8"89C!--ckk:K   -'t{{;'?@J(jAKr")rrvrrrZN)r+r,r-r.r/rVrrarr r<rrrrr0r1r2s@rrrNs9,"OM1 $ $$r"rcR Uu.uFq V,'gKW,V3NK up^,pV^,RR/PV^,V^,4rT\P!RV,4\P!WEV4p\P!R4V#uupi \ dpRT,p\ T\4'd"TP^,R8Xd TR, p\P!\PR7\P!T4\P!4\P!R T,R ,4R p?X#R p?ii;i) pythonrpicklez Loading %s...zLoaded.zFailed to load application: %srvaN 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 N)rsourcer)r[rmsgrloadApplication Exception isinstanceKeyErrorrrrrdeferrr>exit)rrtr(filenamestylervr's&& rrrs!=K!=A&)Q!=KANAdVX.221Q41>e" (*+--hzJ    + L " ,q 0 a " "qvvayM'A  A -    D!! "s$B)B)A B.. E89B4E33E8c\P!\P!4Uu.uFqPNK up4#uupir)r CompleteListrgetReactorTypes shortName)rs r_reactorActionrs2   H4L4L4NO4Nq{{4NO PPOsAca]tRtRtoRt]P !R]/R7t] Pt ] !] P4tRtRt]tRtVtR#) ReactorSelectionMixiniz 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. rC) optActionsc  t\VP4\R4R7pRpVFPp\VP4VP P RVPR RVP R24KR V'dRVP P R4VP P R 4VP P V4\^4h \dLpTRPTPTPTP^,4, pR p?EK R p?ii;i) z5 Display a list of possibly available reactor names. rkeyrcz z<4 rz !{:<4} {} ({}) Nz. reactors not available on this platform: ) sorted_getReactorTypesrr moduleName messageOutputwriter descriptionr9formatrr%)rrctsnotWorkingReactorsrr's& ropt_help_reactors'ReactorSelectionMixin.opt_help_reactorssd++-:k3JKA ALL)""((4 B/?r!--PR)ST     $ $T *    $ $E     $ $%7 8m "&=&D&DKKMMFF1I'" sA C!! D7,?D22D7c \V4WR&R# \dRT: R2p\P!T4h\d#pRT: R2p\P!T4hRp?ii;i)zH Which reactor to use (see --help-reactors for a list of possibilities) rCz'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_reactor!ReactorSelectionMixin.opt_reactorsv ( 9 % (O (&/1  ""3' ' (&')  ""3' '  (s 0A'A'A""A'rGN)r+r,r-r.r/r CompletionsrcompDatar>r?r  staticmethodrrr rropt_rr0r1r2s@rrrsL  Y,GHHJJM#H$<$<=2(8 Er"rc a]tRtRtoRt.RO.RO.RO.t.RO.RO.RORRRRRP ]P4,..RO.RO.RO.R O.t ] P!R!.R] P!R 4R ] P!R 4R ] P!R4R ] P!4/R7t]!]P"4tRtRt]tRtR"RltRt]R4tRtVtR#)# ServerOptionsizQtwistd reads a twisted.application.service.Application out of a file and runs it.NrZrWz!Name of the profiler to use (%s).z, rrrrundirz*.tapz *.(tac|py)z*.tas)mutuallyExclusivercRVR&RV9dVR,VnM\PVn\PP V4R#)Frr?N)r?r>rOptionsr )rr8kws&*,rr ServerOptions.__init__Xs:W r>X,DK**DK t$r"c f\P!R4\P!4RVR&R#)zh Run the application in the Python Debugger (implies nodaemon), sending SIGUSR2 will drop into debugger TrN)r setDebuggingrstartDebugModers&r opt_debugServerOptions.opt_debug`s' 4  W r"c \P!\P4^RIpTP\P4R# \ dR#i;i)zs Print an insanely verbose log of everything that happens. Useful when debugging freezes or locks in complex code. N)r>settracerspewer threadingr9)rr-s& ropt_spewServerOptions.opt_spewksD T[[!   4;;'   sA AAcVf#\PR,;'gR.p\PP W4R#)N:NNz--help)r>argvrr" parseOptionsrfs&&rr3ServerOptions.parseOptionsws0 ?hhrl00xjG ""41r"cVP'gVR,'dRVR&VR,e\VR,4VR&R#R# \d3p\P!RP TR,T44hRp?ii;i)rTno_saverNz%Logger '{}' could not be imported: {})rrrrrr)rr's& r postOptionsServerOptions.postOptions|s| ???d8nn"DO > % !)$x.!9X & &&;BB4>STU sA B -BB c#"VP\P4p/Vn\ V\ R4R7F;pW PVP &VP RV3RlVP3xK= R#5i)rrNc"VP4#r)r^)plugs&rr+ServerOptions.subCommands..s $,,.r") _getPluginsr IServiceMakerrr rrr)rpluginsr;s& r subCommandsServerOptions.subCommandssp""7#8#897 9(=>D/3  t|| , !0   ?sA>B)rr?)rYNzBsave the Stats object rather than the text output of the profiler.)r6ozdo 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).)r7rDNz7Run in profile mode, dumping results to specified file.)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).)rd.z-Change to a supplied directory before running)rrrr)r+r,r-r.longdescoptFlagsjoinrVr] optParametersrr CompleteFiles CompleteDirsrrr getPluginsr=r r(opt_br.r3r7propertyr@r0r1r2s@rrrs !  :FH H      /$))Kr2r)runApprruecommstrs&& rr<r<sl _F v ;;"((388C=) f   B4 !!"s#BAA??Bc\P!WV4p\P!V4P V4\ V4pV'dRp\P!V4P W2R7R#)N)rr)rrr IPersistablesetStylersave)fileintypeinrfileouttypeoutencryptrvs&&&&&& r convertStyleras[))&*EK[!**73"7+J[!&&&Or"c4^RIHp\P!V4P 4V'd5\ P !V4pVPRRVPR4VPRR\P!V4P4R#)rr|aftershutdownbeforeN) rrCrIService startServicer rYaddSystemEventTriggerr[ stopService)rvr[rCrDs&& rstartApplicationrjsm( [!..0   [ )%%gz166:N !!*g..{;GGr"c\P!V\P4\P!\P!4V4R#)z 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)rSIG_DFLrkillgetpid)sigs&r_exitWithSignalrps* MM#v~~&GGBIIKr")NN)7rrrrr>rrpoperatorrtwistedrrrtwisted.applicationrrtwisted.application.reactorsr r rr twisted.internet.interfacesr twisted.persistedr twisted.pythonrrrrrrtwisted.python.reflectrrrrr5rJrVrarrrrrrrrr"rr<rarjrprGr"rrys  --1G"E!FF>><N6 ^ 6LL,o"o"d",0fhhV2QBBJzEMM#8zz P  r"