o >hE@sRddlZddlZddlZddlZddlZddlmZddlmZddl 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-Z.Z/da0e1a2da3da4iZ5e6ee6e ddZ7ddZ8d(ddZ9Gddde:Zde dfddZ;ee"Gddde:ZGd"d#d#e:Z?d$d%Z@d&d'ZAe?t+ZBeBjCZCeBjDZDeBjEZEeBjFZFeBjGZGeBjHZHeBjIZIeBjJZJeBjKZKeBjLZLeBjMZMeBjNZNeBjOZOeBjPZPeBjQZQeBjRZReBjSZSeBjTZTejUZUejVZVdS))N)partialFailure) maybeDeferredDeferred DeferredList)succeedfail) IReactorTime)provider) IFailedFutureILogger log_levels)guess_stream_needs_encoding)_Config _BatchedTimer)_util)Logger formatEvent ILogObserver)globalLogBeginner formatTimeLogLevel)ensureDeferred)iscoroutinefunctionTFinfocOsdSN)argskwargsrrh/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/txaio/tx.py_no_opLr"cCst|dSr) _categoriesupdate) categoriesrrr!add_log_categoriesPr'cCs,|durtjdurtj|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*rrr! with_configTs r-c@sTeZdZdddZdddZddZdd Zdd d Zd dZdddZ ddZ dS)rNcCsH|sJd|||d|_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)selflevelloggerr/r.rrr!__init__gs   zLogger.__init__cCs|Srr)r7oselftyperrr!__get__uszLogger.__get__cOsJd|vr|dtvrt}t|d|d<|jj|g|Ri|dS)N log_categoryformat)r$tuplegetr0emitr7r8rr rrr!_log}sz Logger._logcOsTt|jt|kr dS|dkr|j|i|St|}|j|g|Ri|S)Ntrace)rindexr4_tracer lookupByNamerDrCrrr!rBs  z Logger.emitTcCs||||_dS)zt Set the log level. If keep is True, then it will not change along with global log changes. N)r3r1)r7r8keeprrr!r2s  zLogger.set_log_levelc Cst|}ttD]Z\}}|dkrq ||kr5t||d}|tkr$|dur*t||t|dkr4t|dtq t||dtdfvrc|dkrKt|d|jn t||t|jt ||dkrct|d|j q ||_ dS)NnoneerrorfailurerE) rrF enumerategetattrr"setattrrGrrDrrH_failurer4)r7r8 desired_indexidxnamecurrentrrr!r3s*     zLogger._set_log_levelcOs|jj|g|Ri|Sr)r0rL)r7r?rkwrrr!rPszLogger._failurecOs|j|ddi|dS)N txaio_traceT)debug)r7rrUrrr!rGsz Logger._trace)NNNNrT) __name__ __module__ __qualname__r:r=rDrBr2r3rPrGrrrr!res     rcCsltj}d|jvr|jdj}d|j|j}n|jd}|j j dkr,|d|j j }t ||||d}|S)Nr7z{0}.{1}rYz.)r8r/r9r.) inspect currentframef_backf_locals __class__r?rZrY f_globalsf_codeco_namer)r8r9r.cfclsr/rrr! make_loggers     rgc@sFeZdZdZejejejejej ej dZ ddZ ddZ ddZ d S) _LogObserverzQ Internal helper. An observer which formats events to a given file. )criticalrKwarnrrWrEcCs||_t||_d|_dSr)_filer_encode_levels)r7outrrr!r:s  z_LogObserver.__init__cs4jdurttfddtD_|jvS)Ncs,g|]}t|kr|dkrj|qS)rJ)rrFto_tx).0lvlr7 target_levelrr! s z2_LogObserver._acceptable_level..)rmrrFr4)r7r8rrrr!_acceptable_levels    z_LogObserver._acceptable_levelcCs|ddur&dt|dt|dtj}|jr|d}|j|dSd|vrO| |drQdt|dt |tj}|jrG|d}|j|dSdSdS)N log_formatz {0} {1}{2}log_time log_failureutf8 log_level) r?rfailure_format_tracebackoslineseprlencoderkwriterur)r7eventmsgrrr!__call__s&      z_LogObserver.__call__N)rYrZr[__doc__rrirKrjrrWror:rurrrrr!rhs  rhcCsb|tvrtd|dttrdSda|att|r!t|ag}tr*| tt |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+r?join_started_loggingr4set_global_log_levelrh _observerappendrbeginLoggingTo)rnr8 _observersrrr! start_loggings"  rc@seZdZddZddZddZddZeed fd d Zd d Z d,ddZ ddZ ddZ ddZ d-ddZddZd,ddZd,ddZd,dd Zd,d!d"Zd#d$Zd.d&d'Zd(d)Zd*d+Zd S)/r,cCs ||_dSr)_config)r7r)rrr!r:6 z_TxApi.__init__cCs6z d|jjj|WStyd|YSw)z_ :param fail: must be an IFailedFuture returns a unicode error-message z{0}: {1}z+Failed to produce failure message for "{0}")r?valuerarYgetErrorMessage Exceptionr7r rrr!failure_message9s z_TxApi.failure_messagecC|jS)z\ :param fail: must be an IFailedFuture returns a traceback instance )tbrrrr!failure_tracebackFsz_TxApi.failure_tracebackcCs<zt}|j|d|WStyd|YSw)zP :param fail: must be an IFailedFuture returns a string )filez,Failed to format failure traceback for '{0}')ioStringIOprintTracebackgetvaluerr?)r7r frrr!r{Ms   z_TxApi.failure_format_tracebackNcCsN|tur |tur tdt|d}|turt|||S|tur%t|||S)Nz"Cannot have both result and error.) canceller) _unspecified ValueErrorrresolvereject)r7resultrKrrrrr! create_futureYs   z_TxApi.create_futurecCst|Sr)r)r7rrrr!create_future_successdsz_TxApi.create_future_successcCs tt|Sr)r create_failure)r7rKrrr!create_future_errorg z_TxApi.create_future_errorc Os`t|r%z t||i|WSty$}z t|WYd}~Sd}~wwt|g|Ri|Sr)rr TypeErrorrr)r7funrr errr! as_futurejsz_TxApi.as_futurecCs t|tSr) isinstancer)r7objrrr! is_futuresrz_TxApi.is_futurecOs"t|j||g|Ri|Sr)r _get_loop callLater)r7delayrrr rrr! call_latervs"z_TxApi.call_laterdcs,fdd}fdd}t|d|||dS)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. cs Sr)rsecondsrr7rr! get_secondsrz._TxApi.make_batched_timer..get_secondscsj||g|Ri|Sr)rr)rrrr rrr!create_delayed_callsz6_TxApi.make_batched_timer..create_delayed_callg@@)seconds_providerdelayed_call_creatorr)r7bucket_seconds chunk_sizerrrrr!make_batched_timerys  z_TxApi.make_batched_timercCrr)called)r7futurerrr! is_calledsz_TxApi.is_calledcCs||dSr)callback)r7rrrrr!rr(z_TxApi.resolvecCsD|durt}nt|trt|}n t|tstd||dS)Nz&reject requires a Failure or Exception)rrrrr+errback)r7rrKrrr!rs   z _TxApi.rejectcCs |dSr)cancel)r7rrrrr!rrz _TxApi.cancelcCs|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)r7 exceptionrrr!rsz_TxApi.create_failurecCs>|dusJ|dur|dusJ|||S||||S)z] callback or errback may be None, but at least one must be non-None. N) addErrback addCallbacks)r7rrrrrr! add_callbackss    z_TxApi.add_callbacksTcs,fdd}tt|d}t||d|S)Ncs0g}|D]\}}|||ss|q|Sr)rraiseException)resrtnokrconsume_exceptionsrr! completeds  z _TxApi.gather..completed) consumeErrors)rlistr)r7futuresrrdlrrr!gathers  z _TxApi.gathercCst}|||jd|S)z Inline sleep for use in co-routines. :param delay: Time to sleep in seconds. :type delay: float N)rrrr)r7rdrrr!sleepsz _TxApi.sleepcCs(|jjdurddlm}||j_|jjS)z! internal helper Nr)reactor)rr*twisted.internetr)r7rrrr!rs  z_TxApi._get_loopr)rrX)rYrZr[r:rrr{rrrrrrrrrrrrrrrrrrrrr!r,4s*          r,cCs"tD] }|js ||q|adS)zH Set the global log level on all loggers instantiated by txaio. N)r5r1r3r4)r8itemrrr!rs  rcCstSr)r4rrrr!get_global_log_levelr#rr)Wrr|sysweakrefr] functoolsrtwisted.python.failurertwisted.internet.deferrrrrr twisted.internet.interfacesr zope.interfacer txaio.interfacesr r r txaio._iotypertxaior txaio._commonrrtwisted.loggerr_Loggerrrrrrrasyncior using_twisted using_asyncior)stderrstdout_stderr_stdoutrWeakSetr5r4rr$registerr"r'r-objectrgrhrrr,rr _default_apirrr{rrrrrrrrrrrrrrrtime_nsperf_counter_nsrrrr!s             \<;