af#nddlZddlZddlZejddlmZddlmZdZdZ d dZ d d Z dS) N)reflect)ReactorAlreadyInstalledError)install_optimal_reactorinstall_reactorcurrent_reactor_klasscdtjvrCtjtjdjdd}nd}|S)zK Return class name of currently installed Twisted reactor or None. ztwisted.internet.reactor.N)sysmodulesrqual __class__split)current_reactors P/var/www/html/env/lib/python3.11/site-packages/autobahn/twisted/choosereactor.pyrr+sM"S[00!,s{3M'N'XYY__`cddegh Tctj}t}dtjvstjdr|dkr|b ddlm}|| dn#| dtj YnxYw| d | |rtni| d nRtjd vr|dkr|b ddlm}|| dn #| dtj YnxYw| d| |rtn| dntjdr|dkr|b ddlm}|| dnA#| dtj YnxYw| d| |rtn| dn|dkr|w ddlm}|| dtjn#| dtj tj YnWxYw| d!|tj"|rtn!| d#tjddlm}|tj_|S)$a Try to install the optimal Twisted reactor for this platform: - Linux: epoll - BSD/OSX: kqueue - Windows: iocp - Other: select Notes: - This function exists, because the reactor types selected based on platform in `twisted.internet.default` are different from here. - The imports are inlined, because the Twisted code base is notorious for importing the reactor as a side-effect of merely importing. Hence we postpone all importing. See: http://twistedmatrix.com/documents/current/core/howto/choosing-reactor.html#reactor-functionality :param require_optimal_reactor: If ``True`` and the desired reactor could not be installed, raise ``ReactorAlreadyInstalledError``, else fallback to another reactor. :type require_optimal_reactor: bool :returns: The Twisted reactor in place (`twisted.internet.reactor`). bsddarwin KQueueReactorNr) kqreactorzERunning on *BSD or MacOSX and optimal reactor (kqueue) was installed.zJRunning on *BSD or MacOSX, but cannot install kqueue Twisted reactor: {tb})tbz}Running on *BSD or MacOSX, but cannot install kqueue Twisted reactor, because another reactor ({klass}) is already installed.)klasszIRunning on *BSD or MacOSX and optimal reactor (kqueue) already installed.)win32 IOCPReactorreactorz>>>>>!))+++ IIcnqnzI{{{{[HHglumAmCmCNQNZH[[[[[W_ny|yEFFF*968889 II_jmjvI w w w((((((EL Ns0B *B6E*E.H *H7J==5K4Fc|stj}|r^ddlm}|r|d| ||nX#|d|t jdYn)xYw|r|dt|ddl m }|tj _ |r+ddl m}|d ||j|S) a Install Twisted reactor. :param explicit_reactor: If provided, install this reactor. Else, install the optimal reactor. :type explicit_reactor: obj :param verbose: If ``True``, log (at level "info") the reactor that is in place afterwards. :type verbose: bool :param log: Explicit logging to this txaio logger object. :type log: obj :param require_optimal_reactor: If ``True`` and the desired reactor could not be installed, raise ``ReactorAlreadyInstalledError``, else fallback to another reactor. :type require_optimal_reactor: bool :returns: The Twisted reactor in place (`twisted.internet.reactor`). r)installReactorzETrying to install explicitly specified Twisted reactor "{reactor}" ..rz?Could not install Twisted reactor {reactor} {log_failure.value}z1Automatically choosing optimal Twisted reactor ..)r z$Running on Twisted reactor {reactor})r$r%twisted.application.reactorsr4infofailurer exitrr'rr.r/twisted.python.reflectr r)explicit_reactorverboser1r0r4rr s rrrs;* "!!9 @?????  x HH\fvH w w w  N+ , , , ,  KKZ 0  2 2 2 HQKKKKK  J HHH I I I 7888)(((((ELZ////// 7gFWAXAXYYY Ns A-A3)T)NFNT) r r+r$ use_twistedtwisted.pythonrtwisted.internet.errorr__all__rrrrrrBs6  """"""?????? vvvvr333333r