2i PddlZddlZddlZddlZddlZddlZddlmZddlmZddlm Z ddlm Z eje Z GddeZGd d ej ed ZGd dZGddZGddZddddddddej*e j,d dZy)N)compat connection) exceptions)protocolc4eZdZddfd ZedZxZS)PoolConnectionProxyMetaF)wrapc|rttjD]t}|jds||vrt tj|}t j |sI|j|}tj||}|||<vd|vrtjj|d<t|1||||S)N___doc__) dirr Connection startswithgetattrinspect isfunction_wrap_connection_method functoolsupdate_wrapperrsuper__new__) mclsnamebasesdctr attrnamemethwrapper __class__s T/var/www/html/marco-python-backend/venv/lib/python3.12/site-packages/asyncpg/pool.pyrzPoolConnectionProxyMeta.__new__s  5 56 (&&s+x3z44h?))$/66x@#227DA 'H  (#!+!6!6!>!>IwtT5#66cfd}|S)Nc|j$tjdjt |jj }||jg|i|S)NzJcannot call Connection.{}(): connection has been released back to the pool)_conrInterfaceErrorformatrr!)selfargskwargsr meth_names r"call_con_methodzHPoolConnectionProxyMeta._wrap_connection_method..call_con_method/seyy  //DDJF!E#$$ 499.. :D 3D3F3 3r#)r,r-s` r"rz/PoolConnectionProxyMeta._wrap_connection_method-s 4r#)__name__ __module__ __qualname__r staticmethodr __classcell__)r!s@r"r r s057&  r#r c`eZdZdZdddej fdZdZdej fdZd Z y ) PoolConnectionProxy)r&_holderholderPoolConnectionHolderconcB||_||_|j|yN)r&r6 _set_proxy)r)r7r9s r"__init__zPoolConnectionProxy.__init__Cs   tr#c.t|j|Sr;)rr&)r)attrs r" __getattr__zPoolConnectionProxy.__getattr__Istyy$''r#returncj|jy|jdc}|_|jd|Sr;)r&r<)r)r9s r"_detachzPoolConnectionProxy._detachMs1 99  DTY t r#c|j0dj|jjt |Sdj|jj|jt |S)Nz <{classname} [released] {id:#x}>) classnameidz<{classname} {con!r} {id:#x}>)rEr9rF)r&r(r!r/rFr)s r"__repr__zPoolConnectionProxy.__repr__Usn 99 5<<..11bh=@ @399..11tyyRX:O Or#N) r/r0r1 __slots__rrr=r@rCrHr.r#r"r5r5=sA$I5 ++ (..Or#r5T) metaclassr cjeZdZdZdZdZdZdZdefdZ dZ d Z d Z d Z d Zd ZdZdZdZy)r8) r&_pool_loop_proxy _max_queries_setup_max_inactive_time_in_use_inactive_callback_timeout _generationc||_d|_d|_||_||_||_d|_d|_d|_d|_ yr;) rLr&rNrOrQrPrSrRrTrU)r)pool max_queriessetupmax_inactive_times r"r=zPoolConnectionHolder.__init__fsL   '"3 "&  r#cX|jduxr|jj Sr;)r& is_closedrGs r" is_connectedz!PoolConnectionHolder.is_connectedts&yy$BTYY-@-@-B)BBr#c|j Sr;rRrGs r"is_idlezPoolConnectionHolder.is_idlews<<r#cK|jtjd|jj d{|_|jj |_|j |jy7Ew)NzMPoolConnectionHolder.connect() called while another connection already exists)r&rInternalClientErrorrL_get_new_connectionrU_maybe_cancel_inactive_callback_setup_inactive_callbackrGs r"connectzPoolConnectionHolder.connectzsp 99 00,- -**88:: ::11 ,,. %%';s?B BAB rAcPK|j|jjr d|_|jd{n|j|jjk7rh|jj j |jj|jd|_|jd{|jt||jx|_ }|j |j|d{|jj j!|_|S7774#ttjf$r1} |jjd{7|#|xYwd}~wwxYww)Ntimeout)r&r\rfrUrLrM create_taskcloserTrdr5rNrP ExceptionasyncioCancelledError create_futurerR)r)proxyexs r"acquirezPoolConnectionHolder.acquiresG 99  3 3 5DI,,.   !7!7 7 JJ   ( (  6 8DI,,.  ,,.1$ BB e ;; " kk%(((zz''557  A ! !)w556   ))//+++H"H syAF&EB F&E=F&E"E#E',F&F&EF#3FFFFFFF##F&cK|jtjd|jj ryd|_|jj j|jk\r%|jj|d{y|j|jjk7r%|jj|d{y |}|jj jrptj}tj |jj j#|d{||tj|z z}|jj%|d{|j/|j1y7*77j7,#t&t(j*f$r(} |jj-|#|xYwd}~wwxYww)NzAPoolConnectionHolder.release() called on a free connection holderrh)rRrrbr&r\rT _protocol queries_countrOrkrUrL_is_cancellingtime monotonicrwait_for_wait_for_cancellationresetrlrmrn terminate_releasere)r)ribudgetstartedrqs r"releasezPoolConnectionHolder.releases << 00+, , 99     99   , ,0A0A A))//'/2 2 2    tzz55 5))//'/2 2 2  Fyy""113..*ooII''>>@%dnn.88F))//&/1 1 1  %%'Q 3 3 27112   ##%b sBH F<AH F?H !A5GG?GGG"H ?H GGHG;9H;G>>HHH cRK|jy|jd{y7wr;r_rGs r"wait_until_releasedz(PoolConnectionHolder.wait_until_releaseds <<  ,,  s '%'cnK|j#|jjd{yy7wr;)r&rkrGs r"rkzPoolConnectionHolder.closes0 99 ))//# # # ! $s *535cR|j|jjyyr;)r&r|rGs r"r|zPoolConnectionHolder.terminates# 99  II   ! !r#c|jtjd|jr@|jj j |j|j|_yy)Nz/pool connection inactivity timer already exists)rSrrbrQrLrM call_later_deactivate_inactive_connectionrGs r"rez-PoolConnectionHolder._setup_inactive_callbackse  " " .00AC C  " "&*jj&6&6&A&A'')M)M'OD # #r#c`|j"|jjd|_yyr;)rScancelrGs r"rdz4PoolConnectionHolder._maybe_cancel_inactive_callbacks-  " " .  # # * * ,&*D # /r#c|jtjd|j+|jj |j yy)Nz/attempting to deactivate an acquired connection)rRrrbr&r|_release_on_closerGs r"rz4PoolConnectionHolder._deactivate_inactive_connectionsU << #00AC C 99  II   !  " " $ !r#cR|j|jd|_yr;)rdr}r&rGs r"rz&PoolConnectionHolder._release_on_closes ,,.  r#c:|jy|jjs|jjdd|_|j!|jj d|_|j j j|y)zRelease this connection holder.N)rRdone set_resultrNrCrL_queue put_nowaitrGs r"r}zPoolConnectionHolder._releasesu <<  ||  " LL # #D )  ;; " KK   !DK $$T*r#N)r/r0r1rIr=r]r`rfr5rrrrrkr|rerdrrr}r.r#r"r8r8^s[ I  C  (#2#J8(t $ " O+ % +r#r8ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d0d Z d Zd ddededefdZd ddedefdZd d ddefdZdd ddZd d ddZd d d d d d d d d d d d d dZd d d d d d d d d d d dZd d d d d d d d d d d d d d d d dd Zd d d d d!d"Zd dd#Zd$Zd dd%Zd&Zd'Zd(Z d)Z!d*Z"d+Z#d,Z$d-Z%d.Z&d/Z'y )1PoolaA connection pool. Connection pool can be used to manage a set of connections to the database. Connections are first acquired from the pool, then used, and then released back to the pool. Once a connection is released, it's reset to close all open cursors and other resources *except* prepared statements. Pools are created by calling :func:`~asyncpg.pool.create_pool`. )rrM_minsize_maxsize_init _connect_args_connect_kwargs_holders _initialized _initializing_closing_closed_connection_class _record_classrUrPrO!_max_inactive_connection_lifetimec t| dkDrtjdtd|t j }||_|dkr td|dkr td||kDr td|dkr td |dkr td t|tjstd j|t| tjstd j| ||_||_g|_d |_d |_d|_||_| |_d |_d |_d|_||_| |_| |_||_||_||_y)NrzPassing multiple positional arguments to asyncpg.Pool constructor is deprecated and will be removed in asyncpg 0.17.0. The non-deprecated form is asyncpg.Pool(, **kwargs)) stacklevelrz,max_size is expected to be greater than zeroz3min_size is expected to be greater or equal to zeroz!min_size is greater than max_sizez/max_queries is expected to be greater than zerozKmax_inactive_connection_lifetime is expected to be greater or equal to zerozMconnection_class is expected to be a subclass of asyncpg.Connection, got {!r}zErecord_class is expected to be a subclass of asyncpg.Record, got {!r}F) lenwarningswarnDeprecationWarningrmget_event_looprM ValueError issubclassrr TypeErrorr(rRecordrrrrrrrrrrrUrrrrPrOr) r)min_sizemax_sizerX max_inactive_connection_lifetimerYinitloopconnection_class record_class connect_argsconnect_kwargss r"r=z Pool.__init__>s | q MM0#q  2 <))+D q=KL L a<EG G h @A A ! NO O +a /#$ $*J,A,AB//5v6F/GI I,8++16,+?A A!    !" !1)   )- ' , .r#c2K|jry|jrtjd|jrtjdd|_ |j d{|d|_d|_S7#d|_d|_wxYww)Nz)pool is being initialized in another taskpool is closedTF)rrrr'r _initializerGs r"_async__init__zPool._async__init__s       ++;= = <<++,<= =! %""$ $ $!&D  $D  %"'D  $D s0ABB-B.B3BBBBcKtj|j|_t |jD]e}t ||j |j|j}|jj||jj|g|jr|jd}|jd{|jdkDryg}tt|jddD]8\}}||jdz k\rn!|j|j:tj |d{yyy77 w)N)maxsize)rXrZrYr)rm LifoQueuerrranger8rOrrPrappendrrrf enumeratereversedgather)r)r chfirst_ch connect_tasksis r"rzPool._initializes5'' > t}}% 'A% --"&"H"Hkk #B MM  $ KK " "2 & ' ==}}R(H""$ $ $}}q " &x cr0B'CD7EArDMMA--!((6 7 nnm444!  %5s%CE&E"BE&E$E&$E&c6|jxs |jS)z_Return ``True`` if the pool is closing or is closed. .. versionadded:: 0.28.0 )rrrGs r" is_closingzPool.is_closings ||,t}},r#c:td|jDS)zaReturn the current number of connections in this pool. .. versionadded:: 0.25.0 c3<K|]}|jywr;)r].0hs r" z Pool.get_size..s;1>>#;ssumrrGs r"get_sizez Pool.get_sizes ;T]];;;r#c|jS)zaReturn the minimum number of connections in this pool. .. versionadded:: 0.25.0 )rrGs r" get_min_sizezPool.get_min_size }}r#c|jS)ziReturn the maximum allowed number of connections in this pool. .. versionadded:: 0.25.0 )rrGs r" get_max_sizezPool.get_max_sizerr#c:td|jDS)zfReturn the current number of idle connections in this pool. .. versionadded:: 0.25.0 c3`K|]&}|jxr|j(ywr;)r]r`rs r"rz%Pool.get_idle_size..s%K1>>#3 3Ks,.rrGs r" get_idle_sizezPool.get_idle_sizes KT]]KKKr#Nc "|g|_||_y)aSet the new connection arguments for this pool. The new connection arguments will be used for all subsequent new connection attempts. Existing connections will remain until they expire. Use :meth:`Pool.expire_connections() ` to expedite the connection expiry. :param str dsn: Connection arguments specified using as a single string in the following format: ``postgres://user:pass@host:port/database?option=value``. :param \*\*connect_kwargs: Keyword arguments for the :func:`~asyncpg.connection.connect` function. .. versionadded:: 0.16.0 N)rr)r)dsnrs r"set_connect_argszPool.set_connect_argss*"U-r#cKtj|j|j|j|j d|j d{}|j |j|d{|S|S7.7 #ttjf$r'} |jd{7|#|xYwd}~wwxYww)N)rrr) rrfrrMrrrrrlrmrnrk)r)r9rqs r"rczPool._get_new_connections&&   !33++  ""    :: ! jjo%% s 3 &w556   ))+%%H"H sfACBC#B7B8B<CBCB91B42B97B?9B<<B??CCrhqueryrirAcK|j4d{}|j|g|d|id{cdddd{S7377 #1d{7swYyxYww)aExecute an SQL command (or commands). Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.execute() `. .. versionadded:: 0.10.0 Nri)rrexecute)r)rrir*r9s r"rz Pool.executesj<<> D DS$UCTC7CC D D DC D D D DsSA&A A&AA A A&AA& AA&A#A A#A&commandcK|j4d{}|j|||d{cdddd{S7177 #1d{7swYyxYww)aCExecute an SQL *command* for each sequence of arguments in *args*. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.executemany() `. .. versionadded:: 0.10.0 Nrh)rr executemany)r)rr*rir9s r"rzPool.executemanysd<<> I IS$HH I I IH I I I IsSA$A A$AA A A$A A$ A A$A!A A!A$rircK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)a-Run a query and return the results as a list of :class:`Record`. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetch() `. .. versionadded:: 0.10.0 Nr)rrfetchr)rrirr*r9s r"rz Pool.fetch*ss<<>  S" )        SA'A A'AAA A'AA'AA'A$A A$ A'rcolumnricK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)a+Run a query and return a value in the first row. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetchval() `. .. versionadded:: 0.10.0 Nr)rrfetchval)r)rrrir*r9s r"rz Pool.fetchvalAsp<<> > >S%>>%+W>> > > >> > > > >rcK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)aRun a query and return the first row. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetchrow() `. .. versionadded:: 0.10.0 Nr)rrfetchrowrs r"rz Pool.fetchrowOss<<>  S% )        r) columns schema_namerir(oids delimiternullheaderquoteescape force_quoteencodingc K|j4d{}|j||||||||| | | | | |d{cdddd{S7<77 #1d{7swYyxYww)a;Copy table contents to a file or file-like object. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_from_table() `. .. versionadded:: 0.24.0 N) outputrrrir(rrrrrrrr)rrcopy_from_table)r) table_namerrrrir(rrrrrrrrr9s r"rzPool.copy_from_table`s6<<>  S,,'#'!-       sTA/AA/#AAA A/AA/AA/A, A# !A,(A/) rir(rrrrrrrrc K|j4d{}|j|g| |||||||| | | | d d{cdddd{S7=77 #1d{7swYyxYww)aCCopy the results of a query to a file or file-like object. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_from_query() `. .. versionadded:: 0.24.0 N) rrir(rrrrrrrr)rrcopy_from_query)r)rrrir(rrrrrrrrr*r9s r"rzPool.copy_from_querys2<<>  S,,,#'!       sUA0AA0$AAA A0AA0AA0A-!A$ "A-)A0)rrrir(rfreezerrrrrrforce_not_null force_nullrwherecK|j4d{}|j||||||||| | | | | |||||d{cdddd{S7@77 #1d{7swYyxYww)a&Copy data to the specified table. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_to_table() `. .. versionadded:: 0.24.0 N)sourcerrrir(rrrrrrrrrrrr)rr copy_to_table)r)rrrrrir(rrrrrrrrrrrrr9s r"rzPool.copy_to_tables><<>  S**'#'-%!%+       sVA3AA3'AAA A3AA3AA3A0$A' %A0,A3)rrrirc K|j4d{}|j||||||d{cdddd{S7477 #1d{7swYyxYww)aUCopy a list of records to the specified table using binary COPY. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_records_to_table() `. .. versionadded:: 0.24.0 N)recordsrrrir)rrcopy_records_to_table)r)rrrrrirr9s r"rzPool.copy_records_to_tablesr&<<>  S22' 3       rct||S)aTAcquire a database connection from the pool. :param float timeout: A timeout for acquiring a Connection. :return: An instance of :class:`~asyncpg.connection.Connection`. Can be used in an ``await`` expression or with an ``async with`` block. .. code-block:: python async with pool.acquire() as con: await con.execute(...) Or: .. code-block:: python con = await pool.acquire() try: await con.execute(...) finally: await pool.release(con) )PoolAcquireContext)r)ris r"rrz Pool.acquire s."$00r#cKfd}jrtjdj|d{St j |d{S7(7w)NcKjjd{} |jd{}|_|S7&7#tt j f$rjj|wxYwwr;)rgetrrrTrlrmrnr)rrpr)ris r" _acquire_implz$Pool._acquire.._acquire_impl#sr{{((B  jjl*&  )*w556  &&r* s5BABA A A B A 6BBzpool is closingrh)rrr' _check_initrry)r)rirs`` r"_acquirez Pool._acquire"sk  ==++,=> >  ?&( (22 2)2s$AA5A1 #A5,A3-A53A5cKt|tus|jj|ur%t j dj ||jy|j|jj|j}| |j}tj|j|d{S7w)aRelease a database connection back to the pool. :param Connection connection: A :class:`~asyncpg.connection.Connection` object to release. :param float timeout: A timeout for releasing the connection. If not specified, defaults to the timeout provided in the corresponding call to the :meth:`Pool.acquire() ` method. .. versionchanged:: 0.14.0 Added the *timeout* parameter. zWPool.release() received invalid connection: {connection!r} is not a member of this poolrN)typer5r6rLrr'r(r&r _on_releaserTrmshieldr)r)rrirs r"rz Pool.release:s  $7 7""((4++>>Df)?E?+, , ?? "   ##%    ?kkG ^^BJJw$78888sCC C CcK|jry|jd|_d} |jj d|j }|j Dcgc]}|j}}tj|d{|j Dcgc]}|j}}tj|d{ ||jd|_d|_ycc}w7lcc}w72#ttjf$r|jwxYw#||jd|_d|_wxYww)aAttempt to gracefully close all connections in the pool. Wait until all pool connections are released, close them and shut down the pool. If any error (including cancellation) occurs in ``close()`` the pool will terminate by calling :meth:`Pool.terminate() `. It is advisable to use :func:`python:asyncio.wait_for` to set a timeout. .. versionchanged:: 0.16.0 ``close()`` now waits until all pool connections are released before closing them and the pool. Errors raised in ``close()`` will cause immediate pool termination. NT<F)rrrrMr_warn_on_long_closerrrmrrkrlrnr|r)r)warning_callbackr release_coros close_coross r"rkz Pool.close`sB <<    "#zz44D,, . 48==B-/&&(BMB..-0 0 0&*]]4! 4K4..+. . . + '')DL!DM!B 04 .7112  NN     + '')DL!DMsd'E4DC45D C9 DC;6D DD!E4D;D+D--D00"EEc.tjdy)NzPool.close() is taking over 60 seconds to complete. Check if you have any unreleased connections left. Use asyncio.wait_for() to set a timeout for Pool.close().)loggerwarningrGs r"rzPool._warn_on_long_closes' (r#c|jry|j|jD]}|jd|_y)z&Terminate all connections in the pool.NT)rrrr|r)rs r"r|zPool.terminates; <<  -- B LLN  r#c6K|xjdz c_yw)zExpire all currently open connections. Cause all currently open connections to get replaced on the next :meth:`~asyncpg.pool.Pool.acquire()` call. .. versionadded:: 0.16.0 rN)rUrGs r"expire_connectionszPool.expire_connectionss Asc|js6|jrtjdtjd|jrtjdy)Nzipool is being initialized, but not yet ready: likely there is a race between creating a pool and using itzpool is not initializedr)rrrr'rrGs r"rzPool._check_inits^  !! //  ++,EF F <<++,<= = r#ct|jD])}|j|jj+yr;)rr&_drop_local_statement_cachers r"_drop_statement_cachezPool._drop_statement_caches/-- 6Bww"335 6r#ct|jD])}|j|jj+yr;)rr&_drop_local_type_cachers r"_drop_type_cachezPool._drop_type_caches/-- 1Bww"..0 1r#c>|jjSr;)r __await__rGs r"r*zPool.__await__s""$..00r#cBK|jd{|S7wr;)rrGs r" __aenter__zPool.__aenter__s"!!###  $s c@K|jd{y7wr;)rk)r)excs r" __aexit__zPool.__aexit__sjjls r;)(r/r0r1rrIr=rrrrrrrrrcstrfloatrrlistrrrrrrrrrrrrkrr|r!rr%r(r*r,r/r.r#r"rr+sII-V% 5B-<L.08?C D3 D Ds DGK I I I"   .34T >48d,  !+d  (^  )3t:"&122048$9L+"Z(  >6 1 1r#rc(eZdZdZdZdZdZdZy)r )rirrrWc<||_||_d|_d|_y)NF)rWrirr)r)rWris r"r=zPoolAcquireContext.__init__s   r#cK|j |jrtjd|jj |j d{|_|jS7w)Nz a connection is already acquired)rrrr'rWrrirGs r"r,zPoolAcquireContext.__aenter__sU ?? &$))++,NO O $ 2 24<< @@AsAA0A.A0cKd|_|j}d|_|jj|d{y7wNT)rrrWr)r)r.r9s r"r/zPoolAcquireContext.__aexit__s5 ooii$$$s9AAAcvd|_|jj|jj Sr7)rrWrrir*rGs r"r*zPoolAcquireContext.__await__s+ yy!!$,,/99;;r#N)r/r0r1rIr=r,r/r*r.r#r"r r s9I  % ` and :meth:`Connection.cursor() ` become invalid once the connection is released. Likewise, all notification and log listeners are removed, and ``asyncpg`` will issue a warning if there are any listener callbacks registered on a connection that is being released to the pool. :param str dsn: Connection arguments specified using as a single string in the following format: ``postgres://user:pass@host:port/database?option=value``. :param \*\*connect_kwargs: Keyword arguments for the :func:`~asyncpg.connection.connect` function. :param Connection connection_class: The class to use for connections. Must be a subclass of :class:`~asyncpg.connection.Connection`. :param type record_class: If specified, the class to use for records returned by queries on the connections in this pool. Must be a subclass of :class:`~asyncpg.Record`. :param int min_size: Number of connection the pool will be initialized with. :param int max_size: Max number of connections in the pool. :param int max_queries: Number of queries after a connection is closed and replaced with a new connection. :param float max_inactive_connection_lifetime: Number of seconds after which inactive connections in the pool will be closed. Pass ``0`` to disable this mechanism. :param coroutine setup: A coroutine to prepare a connection right before it is returned from :meth:`Pool.acquire() `. An example use case would be to automatically set up notifications listeners for all connections of a pool. :param coroutine init: A coroutine to initialize a connection when it is created. An example use case would be to setup type codecs with :meth:`Connection.set_builtin_type_codec() <\ asyncpg.connection.Connection.set_builtin_type_codec>` or :meth:`Connection.set_type_codec() <\ asyncpg.connection.Connection.set_type_codec>`. :param loop: An asyncio event loop instance. If ``None``, the default event loop will be used. :return: An instance of :class:`~asyncpg.pool.Pool`. .. versionchanged:: 0.10.0 An :exc:`~asyncpg.exceptions.InterfaceError` will be raised on any attempted operation on a released connection. .. versionchanged:: 0.13.0 An :exc:`~asyncpg.exceptions.InterfaceError` will be raised on any attempted operation on a prepared statement or a cursor created on a connection that has been released to the pool. .. versionchanged:: 0.13.0 An :exc:`~asyncpg.exceptions.InterfaceWarning` will be produced if there are any active listeners (added via :meth:`Connection.add_listener() ` or :meth:`Connection.add_log_listener() `) present on the connection at the moment of its release to the pool. .. versionchanged:: 0.22.0 Added the *record_class* parameter. ) rrrrrXrrYrr)r) rrrrXrrYrrrrrs r" create_poolr;s;@   )!Hd%d)I    r#r;)rmrrloggingrwrrrrr getLoggerr/rrr _ConnectionProxyr5r8rr rrr;r.r#r"r@s    8 $"d"JO*55$;#OBJ+J+ZZ Z z<<6G!16!+!6!6%__Gr#