o iE@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*eZ+ej,ej-Z.Z/da0e1Z2da3da4iZ5e6ee6e ddZ7ddZ8d(ddZ9Gddde:Zde dfddZ;ee"Gddde:ZGd"d#d#e:Z?d$d%Z@d&d'ZAe?e+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)argskwargsrrNC:\Users\psant\Downloads\PAF backend\school\venv\Lib\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__fs   zLogger.__init__cCs|Srr)r7Zoselftyperrr!__get__tszLogger.__get__cOsJd|vr|dtvrt}t|d|d<|jj|g|Ri|dS)NZ log_categoryformat)r$tuplegetr0emitr7r8rr rrr!_log|sz Logger._logcOsTt|jt|kr dS|dkr|j|i|St|}|j|g|Ri|S)Ntrace)rindexr4_tracer lookupByNamerBrArrr!r@s  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)r7r8Zkeeprrr!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)NnoneerrorfailurerC) rrD enumerategetattrr"setattrrErrBrrF_failurer4)r7r8Z desired_indexidxnamecurrentrrr!r3s*     zLogger._set_log_levelcOs|jj|g|Ri|Sr)r0rI)r7r=rkwrrr!rMszLogger._failurecOs|j|ddi|dS)NZ txaio_traceT)debug)r7rrQrrr!rEsz Logger._trace)NNNNrT) __name__ __module__ __qualname__r:r<rBr@r2r3rMrErrrr!rds    rcCsltj}d|jvr|jdj}d|j|j}n|jd}|j j dkr,|d|j j }t ||||d}|S)Nr7z{0}.{1}rTz.)r8r/r9r.) inspect currentframef_backf_locals __class__r=rUrT f_globalsf_codeco_namer)r8r9r.cfclsr/rrr! make_loggers     rbc@sFeZdZdZejejejejej ej dZ ddZ ddZ ddZ d S) _LogObserverzQ Internal helper. An observer which formats events to a given file. )criticalrHwarnrrRrCcCs||_t||_d|_dSr)_filer_encode_levels)r7outrrr!r:s  z_LogObserver.__init__cs4jdurttfddtD_|jvS)Ncs,g|]}t|kr|dkrj|qS)rG)rrDto_tx).0Zlvlr7Z target_levelrr! s z2_LogObserver._acceptable_level..)rhrrDr4)r7r8rrlr!_acceptable_levels    z_LogObserver._acceptable_levelcCs|ddur&dt|dt|dtj}|jr|d}|j|dSd|vrO| |drQdt|dt |tj}|jrG|d}|j|dSdSdS)NZ log_formatz {0} {1}{2}Zlog_timeZ log_failureutf8 log_level) r=rfailure_format_tracebackoslineseprgencoderfwriternr)r7eventmsgrrr!__call__s&      z_LogObserver.__call__N)rTrUrV__doc__rrdrHrerrRrjr:rnrxrrrr!rcs  rccCsb|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_levelrc _observerappendrZbeginLoggingTo)rir8Z _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}"N)r=valuer\rTZgetErrorMessage Exceptionr7r rrr!failure_message9s z_TxApi.failure_messagecC|jS)z\ :param fail: must be an IFailedFuture returns a traceback instance N)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}'N)ioStringIOZprintTracebackgetvaluerr=)r7r frrr!rqMs   z_TxApi.failure_format_tracebackNcCsN|tur |tur tdt|d}|turt|||S|tur%t|||S)Nz"Cannot have both result and error.) canceller) _unspecified ValueErrorrresolvereject)r7resultrHrrrrr! create_futureYs   z_TxApi.create_futurecCst|Sr)r)r7rrrr!create_future_successdsz_TxApi.create_future_successcCs tt|Sr)r create_failure)r7rHrrr!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@@)Zseconds_providerZdelayed_call_creatorNr)r7Zbucket_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)r7rrHrrr!rs   z _TxApi.rejectcCs |dSr)cancel)r7rrwrrr!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 Nr)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)Z addErrbackZ addCallbacks)r7rrrrrr! add_callbackss    z_TxApi.add_callbacksTcs,fdd}tt|d}t||d|S)Ncs0g}|D]\}}|||ss|q|Sr)r~ZraiseException)resZrtnokrconsume_exceptionsrr! completeds  z _TxApi.gather..completed)Z 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*Ztwisted.internetr)r7rrrr!rs  z_TxApi._get_loopr)rrS)rTrUrVr:rrrqrrrrrrrrrrrrrrrrrrrrr!r,4s*          r,cCs"tD] }|js ||q|adS)zH Set the global log level on all loggers instantiated by txaio. N)r5r1r3r4)r8itemrrr!r|s  r|cCstSr)r4rrrr!get_global_log_levelr#rr)WrrrsysweakrefrX functoolsrZtwisted.python.failurerZtwisted.internet.deferrrrrr Ztwisted.internet.interfacesr Zzope.interfacer Ztxaio.interfacesr r rZ txaio._iotyperZtxaiorZ txaio._commonrrZtwisted.loggerrZ_LoggerrrrrrrasynciorZ using_twistedZ using_asyncior)stderrstdout_stderrZ_stdoutr}WeakSetr5r4r{r$registerr"r'r-objectrbrcrrr,r|rZ _default_apirrrqrrrrrrrrrrrrrrrtime_nsperf_counter_nsrrrr!s             ]==