h#pddlZddlZddlZejddlmZddlmZdZdZ ddZ d dZ y) N)reflect)ReactorAlreadyInstalledError)install_optimal_reactorinstall_reactorcurrent_reactor_klasscdtjvrDtjtjdjj dd}|Sd}|S)zK Return class name of currently installed Twisted reactor or None. ztwisted.internet.reactor.N)sysmodulesrqual __class__split)current_reactors Z/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/twisted/choosereactor.pyrr+sU"S[[0!,,s{{3M'N'X'XY__`cdegh  c*tj}t}dtjvstjj drd|dk7rL|* ddlm}|j|jdn|jd | |rt|jd ntjd vrd|d k7rL|* ddlm}|j|jdnB|jd| |r,t|jdntjj dra|dk7rJ|) ddlm}|j|jdn|jd| |rt|jdn|dk7ri|9 ddlm}|j|jdtjnO|jd |tj!|r+t|jd"tjddlm}|tj$_|S#|jdtjYFxYw#|jdtjYrxYw#|jdtjYxYw#|jdtjtjYxYw)#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 KQueueReactorr) 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!))+ IIcnqnznzI{W_ny|yEyEF*688 II_jmjvjvI w(ELL NYFHHinwoCoCoEHF&}HH`eneyeye{H|&|HH_dmdxdxdzH{*[HHglumAmAmCNQNZNZH[s0IJJ.2K'I?'J+.'K6Lc|stj}|r%ddlm}|r|j d| ||n|r|j dt|ddl m }|tj_ |r)ddl m}|j d ||j|S#|j d|t jdYtxYw) 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* ! @  HH\fvH w  + ,  HHH I 78)ELL/ 7gFWFWAXY N'  KKZ 0  2 HHQKs B$$*C)T)NFNT) r r+r$ use_twistedtwisted.pythonrtwisted.internet.errorr__all__rrrrrrBs<6  "? vr3r