tfEddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl m Z mZddlmZddlmZddlmZmZmZdd lmZdd lmZdd lmZdd lmZdd lmZ m!Z!m"Z"ddlm#Z#m$Z$m%Z%ddl m&Z&ddl'm(Z(dZ)dZ*ea+ej,ej-cZ.Z/da0ej1a2da3da4iZ5ej6eej6e dZ7dZ8d!dZ9Gdde:Zde dfdZ;ee"Gdde:ZGdde:Z?dZ@d ZAe?tVZBeBjCZCeBjDZDeBjEZEeBjFZFeBjGZGeBjHZHeBjIZIeBjJZJeBjKZKeBjLZLeBjMZMeBjNZNeBjOZOeBjPZPeBjQZQeBjRZReBjSZSeBjTZTejUZUejVZVdS)"N)partialFailure) maybeDeferredDeferred DeferredList)succeedfail) IReactorTime)provider) IFailedFutureILogger log_levels)guess_stream_needs_encoding)_Config _BatchedTimer)_util)Logger formatEvent ILogObserver)globalLogBeginner formatTimeLogLevel)ensureDeferred)iscoroutinefunctionTFinfocdSN)argskwargss G/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/txaio/tx.py_no_opr$LsDc:t|dSr) _categoriesupdate) categoriess r#add_log_categoriesr*Psz"""""r%c|)tjtj|urtdttS)NzTwisted has only a single, global reactor. You passed in a reactor different from the one already configured in txaio.config.loop)configloop RuntimeError_TxApi)r-s r# with_configr0TsA  ; "v{$'>'>'  &>>r%cFeZdZd dZd dZdZdZd dZdZd d Z d Z dS)rNc|s Jd||||_d|_|r||n|tt |dS)Nz$Should not be instantiated directly.)observer namespaceF)_logger_log_level_set_explicitly set_log_level_set_log_level _log_level_loggersadd)selflevelloggerr4r3s r#__init__zLogger.__init__gs======vx9EEE ).&  ,   u % % % %    + + + Tr%c|Srr )r<oselftypes r#__get__zLogger.__get__us  r%cd|vr@|dtvr1t}t|d|d<|jj|g|Ri|dS)N log_categoryformat)r'tuplegetr5emitr<r=r!r"s r#_logz Logger._log}sm V # #~(>+(M(M77D*vn/EFFF8  %1$111&11111r%ctj|jtj|krdS|dkr |j|i|St j|}|j|g|Ri|S)Ntrace)rindexr9_tracer lookupByNamerKrJs r#rIz Logger.emits~  DO , ,z/?/F/F F F F G  4;/// /%e,,ty0000000r%Tc>||||_dS)zt Set the log level. If keep is True, then it will not change along with global log changes. N)r8r6)r<r=keeps r#r7zLogger.set_log_levels& E""")-&&&r%c >tj|}ttD]\}}|dkr ||krQt||d}|tkr|t ||t|dkrt |dtct||dtdfvro|dkrt |d|jn6t ||t|jtj ||dkrt |d|j ||_ dS)NnoneerrorfailurerM) rrN enumerategetattrr$setattrrOrrKrrP_failurer9)r<r= desired_indexidxnamecurrents r#r8zLogger._set_log_levels1#(// $Z00 @ @KS$v~~]""!$d33&((GOD$///7??D)V4444t,,>>wgt{;;;;d ' 83H3N3N O OQQQwi???r%c.|jj|g|Ri|Sr)r5rV)r<rFr!kws r#rZzLogger._failures'#t|#F8T888R888r%c$|j|ddi|dS)N txaio_traceT)debug)r<r!r`s r#rOz Logger._traces&  D1d1b11111r%)NNNNrT) __name__ __module__ __qualname__r?rCrKrIr7r8rZrOr r%r#rres    222 1 1 1....   >999922222r%rc2tjj}d|jvr3|jdj}d|j|j}n/|jd}|j j dkr|dz|j j z}t||||}|S)Nr<z{0}.{1}rez.)r=r4r>r3) inspect currentframef_backf_locals __class__rFrfre f_globalsf_codeco_namer)r=r>r3cfclsr4s r# make_loggerrts     &B k&!+$$S^S\BB L, 9  * *"C")*;;I %9V%'''F Mr%creZdZdZejejejejej ej dZ dZ dZ dZ dS) _LogObserverzQ Internal helper. An observer which formats events to a given file. )criticalrUwarnrrcrMcJ||_t||_d|_dSr)_filer_encode_levels)r<outs r#r?z_LogObserver.__init__s# 2377  r%cj2tjtfdtD_|jvS)Ncfg|]-}tj|k|dk j|.S)rT)rrNto_tx).0lvlr< target_levels r# z2_LogObserver._acceptable_level..sE#C((L88SF]] 3=J]]r%)r|rrNr9)r<r=rs` @r#_acceptable_levelz_LogObserver._acceptable_levelsZ < %+J77L%DL  $$r%cH|ddt|dt|dtj}|jr|d}|j|dSd|vr| |dr{dt|dt|tj}|jr|d}|j|dSdSdS)N log_formatz {0} {1}{2}log_time log_failureutf8 log_level) rFrfailure_format_tracebackoslinesepr{encoderzwriterr)r<eventmsgs r#__call__z_LogObserver.__call__s#   &%%5,--(})=>> C | )jj(( J  S ! ! ! ! !e##(>(>u[?Q(R(R#"))uZ011&&J <-**V,,C   %%%%%$###r%N)rerfrg__doc__rrwrUrxrrcrr?rrr r%r#rvrvsx %     E %%%&&&&&r%rvc`|tvr;td|dttrdSda|at t |rt|ag}tr| ttj |dS)z[ Start logging to the file-like object in ``out``. By default, this is stdout. z'Invalid log level '{0}'; valid are: {1}z, NT) rr.rFjoin_started_loggingr9set_global_log_levelrv _observerappendrbeginLoggingTo)r}r= _observerss r# start_loggingrs J 5 < <tyy,,     J$$$ & %% J%)$$$$Z00000r%ceZdZdZdZdZdZeedfdZdZ ddZ d Z d Z d Z dd ZdZddZddZddZddZdZddZdZdZdS)r/c||_dSr)_config)r<r,s r#r?z_TxApi.__init__6s  r%c d|jjj|jS#t $rd|cYSwxYw)z_ :param fail: must be an IFailedFuture returns a unicode error-message z{0}: {1}z+Failed to produce failure message for "{0}")rFvaluernregetErrorMessage Exceptionr<r s r#failure_messagez_TxApi.failure_message9st  N$$ $-$$&&  N N N@GGMM M M M Ns14AAc|jS)z\ :param fail: must be an IFailedFuture returns a traceback instance )tbrs r#failure_tracebackz_TxApi.failure_tracebackFs wr%c tj}|j||S#t$rd|cYSwxYw)zP :param fail: must be an IFailedFuture returns a string )filez,Failed to format failure traceback for '{0}')ioStringIOprintTracebackgetvaluerrF)r<r fs r#rz_TxApi.failure_format_tracebackMsp  O A D Q ' ' ' '::<<  O O OAHHNN N N N Os7:AANc|tur|turtdt|}|turt||n|turt |||S)Nz"Cannot have both result and error.) canceller) _unspecified ValueErrorrresolvereject)r<resultrUrrs r# create_futurez_TxApi.create_futureYst  % %%|*C*CABB B y ) ) )  % % Av     , & & 1e   r%c t|Sr)r )r<rs r#create_future_successz_TxApi.create_future_successdsvr%c:tt|Sr)r create_failure)r<rUs r#create_future_errorz_TxApi.create_future_errorgsN5))***r%ct|r< t||i|S#t$r}t|cYd}~Sd}~wwxYwt |g|Ri|Sr)rr TypeErrorrr)r<funr!r"es r# as_futurez_TxApi.as_futurejs s # # . .%cc4&:6&:&:;;; . . .*1-------- .S242226222s& A AA A c,t|tSr) isinstancer)r<objs r# is_futurez_TxApi.is_futuress#x(((r%cdt|j||g|Ri|Sr)r _get_loop callLater)r<delayrr!r"s r# call_laterz_TxApi.call_latervs97|DNN,,--7sTTTTTVTTTr%dcDfd}fd}t|dz|||S)a& Creates and returns an object implementing :class:`txaio.IBatchedTimer`. :param bucket_seconds: the number of seconds in each bucket. That is, a value of 5 means that any timeout within a 5 second window will be in the same bucket, and get notified at the same time. This is only accurate to "milliseconds". :param chunk_size: when "doing" the callbacks in a particular bucket, this controls how many we do at once before yielding to the reactor. cPSr)rseconds)r<sr# get_secondsz._TxApi.make_batched_timer..get_secondss>>##++-- -r%cLj||g|Ri|Sr)rr)rrr!r"r<s r#create_delayed_callz6_TxApi.make_batched_timer..create_delayed_calls2-4>>##-eSJ4JJJ6JJ Jr%g@@)seconds_providerdelayed_call_creatorr)r<bucket_seconds chunk_sizerrs` r#make_batched_timerz_TxApi.make_batched_timerysc . . . . . K K K K K V #Z(!4    r%c|jSr)called)r<futures r# is_calledz_TxApi.is_calleds }r%c0||dSr)callback)r<rrs r#rz_TxApi.resolvesr%c|t}nIt|trt|}n$t|tst d||dS)Nz&reject requires a Failure or Exception)rrrrr.errback)r<rrUs r#rz _TxApi.rejectsn ="$$EE y ) ) MENNEEeW-- M"#KLLLur%c.|dSr)cancel)r<rrs r#rz _TxApi.cancels r%c@|rt|StS)z Create a Failure instance. if ``exception`` is None (the default), we MUST be inside an "except" block. This encapsulates the exception into an object that implements IFailedFuture r)r< exceptions r#rz_TxApi.create_failures$  &9%% %yyr%cr|J||J||n||||S)z] callback or errback may be None, but at least one must be non-None. ) addErrback addCallbacks)r<rrrs r# add_callbacksz_TxApi.add_callbackssV !!!  &&&   g & & & &   ' 2 2 2 r%Tcpfd}tt|}t||d|S)Ncvg}|D]2\}}|||ss|3|Sr)rraiseException)resrtnokrconsume_exceptionss r# completedz _TxApi.gather..completedsUC" + + U 5!!!+"4+((***Jr%) consumeErrors)rlistr)r<futuresrrdls ` r#gatherz _TxApi.gathersP     $w--7I J J J b)T*** r%c~t}|||jd|S)z Inline sleep for use in co-routines. :param delay: Time to sleep in seconds. :type delay: float N)rrrr)r<rds r#sleepz _TxApi.sleeps6 JJ ""5!*d;;;r%cV|jjddlm}||j_|jjS)z! internal helper Nr)reactor)rr-twisted.internetr)r<rs r#rz_TxApi._get_loops6 <  $ 0 0 0 0 0 0 'DL |  r%r)rrd)rerfrgr?rrrrrrrrrrrrrrrrrrrrr r%r#r/r/4sz N N N O O O$0|t    ++++333)))UUU    6           *    ! ! ! ! !r%r/cVtD]}|js|||adS)zH Set the global log level on all loggers instantiated by txaio. N)r:r6r8r9)r=items r#rrs<''- '    & & &JJJr%ctSr)r9r r%r#get_global_log_levelrs r%r)Wrrsysweakrefrj functoolsrtwisted.python.failurertwisted.internet.deferrrrr r twisted.internet.interfacesr zope.interfacer txaio.interfacesr rr txaio._iotypertxaior txaio._commonrrtwisted.loggerr_Loggerrrrrrrasyncior using_twisted using_asyncior,stderrstdout_stderr_stdoutrWeakSetr:r9rr'registerr$r*r0objectrtrvrrr/rr _default_apirrrrrrrrrrrrrrrrrrtime_nsperf_counter_nsr r%r#rs6 ******HHHHHHHHHH00000000444444######??????????555555''''''GGGGGGGGGGBBBBBBBBBB111111''''''  :sz  7?      w   ###    "Y2Y2Y2Y2Y2VY2Y2Y2x7T( ,9&9&9&9&9&69&9&9&xV1111>vxx w!w!w!w!w!Vw!w!w!tvf~~ . 2'@* $:"6  "  "  $ !4  "      ,*   -'r%