i<ddlmZddlmZddlZddlZddlmZddlm Z ddlm Z ddl m Z ddl mZeZGd d eZd ZGd d eZGddeZGddeZeZGddZejD]ZefdZeeeeee`[[GddeZGddZdS))deque)contextmanagerN)Pool)timeout)hubs)Timer) GreenThreadceZdZdS)ConnectTimeoutN)__name__ __module__ __qualname__;/usr/local/lib/python3.11/dist-packages/eventlet/db_pool.pyr r sDrr c.|dSN)rollback)conns rcleanup_rollbackrsMMOOOOOrceZdZdddddeffd ZdZdZd Zd Zdd Z fd Z e ffd Z e e fdZdZdZxZS)BaseConnectionPoolr c|sJ||_||_| |_||_||_||_d|_||_t ||ddS)a Constructs a pool with at least *min_size* connections and at most *max_size* connections. Uses *db_module* to construct new connections. The *max_idle* parameter determines how long pooled connections can remain idle, in seconds. After *max_idle* seconds have elapsed without the connection being used, the pool closes the connection. *max_age* is how long any particular connection is allowed to live. Connections that have been open for longer than *max_age* seconds are closed, regardless of idle time. If *max_age* is 0, all connections are closed on return to the pool, reducing it to a concurrency limiter. *connect_timeout* is the duration in seconds that the pool will wait before timing out on connect() to the database. If triggered, the timeout will raise a ConnectTimeout from get(). The remainder of the arguments are used as parameters to the *db_module*'s connection constructor. NT)min_sizemax_sizeorder_as_stack) _db_module_args_kwargsmax_idlemax_ageconnect_timeout_expiration_timercleanupsuper__init__) self db_modulerrr$r%r&r(argskwargs __class__s rr*zBaseConnectionPool.__init__sp4#     .!%  (XdSSSSSrc|jdks |jdkrdS|jt|jddsdS t j}|||jdd|z |jz}td|jD}||z |jz}t||}n#ttf$r d|_YdSwxYw|dkr`t|ttj jj|jgi|_|jdSdS)aSets up a timer that will call _expire_old_connections when the oldest connection currently in the free pool is ready to expire. This is the earliest possible time that a connection could expire, thus, the timer will be running as infrequently as possible without missing a possible expiration. If this function is called when a timer is already scheduled, it does nothing. If max_age or max_idle is 0, _schedule_expiration likewise does nothing. rNcalledFcg|] }|d S)r).0ts r z;BaseConnectionPool._schedule_expiration..Zs8881!A$888r)r%r$r'getattrtime_expire_old_connections free_itemsmin IndexError ValueErrorrr rget_hubgreenletswitch_schedule_expirationschedule)r+now idle_delayoldest age_delay next_delays rrBz'BaseConnectionPool._schedule_expiration>s_ <1    2 2 F  " . 6%HH / F )++C  ( ( - - -/"-a036$-GJ8888899F#5IZ33JJJ'   %)D " FF  >>%*:{4<>>CZ7[7[7b+/+Db"&N&ND "  " + + - - - - - >sBB;;CCcjtj}fdjD}fdjD}jj|xj|tjz zc_|D]}|ddS)aIterates through the open connections contained in the pool, closing ones that have remained idle for longer than max_idle seconds, or have been in existence for longer than max_age seconds. *now* is the current time, as returned by time.time(). cJg|]\}}}||| Sr _is_expiredr5 last_used created_atrrDr+s rr7z>BaseConnectionPool._expire_old_connections..qsG===+ :tY ;;= ===rcPg|]"\}}}|||||f#SrrKrMs rr7z>BaseConnectionPool._expire_old_connections..vsUAAA+ :t##CJ??A  D )AAArTquietN)lenr;clearextend current_size _safe_close)r+rDoriginal_countexpirednew_freers`` rr:z*BaseConnectionPool._expire_old_connectionsisT_--=====/3=== AAAAA/3AAA  x((( ^c$/.B.BBB / /D   T  . . . . / /rcn|jdks'|jdks||z |jks||z |jkrdSdS)z@Returns true and closes the connection if it's expired. rTF)r$r%)r+rDrNrOs rrLzBaseConnectionPool._is_expiredsJ MQ  $,!"3"3?T]22#dl224urcnd} |r|j}|nd}n#t$rYnwxYw|S)a$If the connection was wrapped by a subclass of BaseConnectionWrapper and is still functional (as determined by the __nonzero__, or __bool__ in python3, method), returns the unwrapped connection. If anything goes wrong with this process, returns None. N)_base_destroyAttributeError)r+rbases r_unwrap_connectionz%BaseConnectionPool._unwrap_connectionsW  z     D  s % 22Fc |dS#t$rYdSt$r2|s,tdt jdzYdSYdSwxYw)zVCloses the (already unwrapped) connection, squelching any exceptions. zConnection.close raised: %sr4N)closer_ Exceptionprintsysexc_info)r+rrRs rrWzBaseConnectionPool._safe_closes K JJLLLLL    DD K K K K3s|~~a7HIJJJJJJ K K K Ks A 4A A cBt}|5 |}n#t$r|xjdzc_wxYwt |t r|\}}}ntj}t||}||_ |S)Nr4) r)getcreaterdrV isinstancetupler9PooledConnectionWrapper_db_pool_created_at)r+r _last_usedrOwrappedr/s rrizBaseConnectionPool.getsww{{}} < {{}}    !!Q&!!   dE " " %+/ (J DDJ*$55'1#s :Act|dd}tj}||}||||r||dd}nR|P|t ur|j} |r ||n1#t$r!}td|d|d}Yd}~n d}~wd}xYw|%t |||fnJ| dkr"t dn|xj dzc_ | dS)NrnrFrQzWARNING: cleanup z raised: r4)r8r9rarLrW_MISSINGr(rdrer)putwaitingrVrB)r+rr(rOrDer/s rrszBaseConnectionPool.putsuT#8!<< ikk&&t,,   Cj 1 1    T  / / /DD  ("", "GDMMM   '''11EFFF    GGKKj$/ 0 0 0 0||~~!! D!!!!!!Q&!! !!#####s? B B;B33B;c#K|} |V|||dS#|||wxYw)N)r()rirs)r+r(rs ritemzBaseConnectionPool.itemsYxxzz ,JJJ HHT7H + + + + +DHHT7H + + + +s 5Ac|jr|j|jtc}|_|D]H}t |t r|dn|}||d|xjdzc_IdS)zuClose all connections that this pool still holds a reference to, and removes all references to them. TrQr4N)r'cancelr;rrkrlrWrV)r+r;rwrs rrTzBaseConnectionPool.clears  ! ,  " ) ) + + +&*ouww# DO # #D(u55?4774D   T  . . .    "     # #rc.|dSr)rTr+s r__del__zBaseConnectionPool.__del__s r)F)r r rrr*rBr:rLrarWrirrrsrrwrTr} __classcell__r/s@rrrs'ab!") #T#T#T#T#T#TJ).).).V///6$ K K K K<!)$$$$$$$$$$$$L#,,,^, # # #rrc.eZdZdZdZedZdS)TpooledConnectionPoolzZA pool which gives out :class:`~eventlet.tpool.Proxy`-based database connections. cztj}|||j|j|jg|jRi|jfSrr9connectr!r&r"r#r+rDs rrjzTpooledConnectionPool.create \ikkC OT1P48JPPPBF,PPP Prctj|t} ddlm}|j|jg|Ri|}||d|S#|wxYw)Nr)tpool)cursor)autowrap_names) rTimeoutr eventletrexecuterProxyrz)clsr,r&r-kwr6rrs rrzTpooledConnectionPool.connects OO^-=-= > >  & & & & & & 5=!2@T@@@R@@D;;tK;@@ HHJJJJAHHJJJJs 2A**BNr r r__doc__rj classmethodrrrrrrsKPPP [rrc.eZdZdZdZedZdS)RawConnectionPoolz7A pool which gives out plain database connections. cztj}|||j|j|jg|jRi|jfSrrrs rrjzRawConnectionPool.create!rrctj|t} |j|i||S#|wxYwr)rrr rrz)rr,r&r-rr6s rrzRawConnectionPool.connect&sT OO^-=-= > > $9$d1b11 HHJJJJAHHJJJJs AANrrrrrrsKPPP [rrc*eZdZdZdZdZdZdZdS)GenericConnectionWrapperc||_dSr)r])r+baseconns rr*z!GenericConnectionWrapper.__init__4s  rc4|jSr)r] __enter__r|s rrz"GenericConnectionWrapper.__enter__=sz##%%%rc:|j|||Sr)r]__exit__)r+excvaluetbs rrz!GenericConnectionWrapper.__exit__@sz""3r222rc4|jSr)r]__repr__r|s rrz!GenericConnectionWrapper.__repr__Csz""$$$r)! affected_rows autocommitbegin change_usercharacter_set_namerccommitrdump_debug_infoerrnoerror errorhandlerget_server_info insert_idliteralpingqueryr select_dbserver_capabilitiesset_character_setset_isolation_levelset_server_option set_sql_mode show_warningsshutdownsqlstatestat store_resultstring_literal thread_id use_result warning_countN)r r rr*rrr _proxy_funcsrrrrr3sQ&&&333%%%"LLLrrcBfd}|_|_dz|_|S)Nc:t|j|i|Sr)r8r])r+r-r. _proxy_funs r _proxy_methodz_wrapper.._proxy_methodns$274:z22DCFCC CrzGenericConnectionWrapper.) func_namer r)rrs` r_wrapperrmsD D D D D D", !+ %@:%M "rc>eZdZdZfdZdZeZdZdZdZ xZ S)rmzA connection wrapper where: - the close method returns the connection to the pool instead of closing it directly - ``bool(conn)`` returns a reasonable value - returns itself to the pool if it gets garbage collected cXt|||_dSr)r)r*_pool)r+rpoolr/s rr*z PooledConnectionWrapper.__init__s& """ rcJt|dot|jS)Nr])hasattrboolr]r|s r __nonzero__z#PooledConnectionWrapper.__nonzero__s!g&&;4 +;+;rsO%%%%%% %%%%%%,,,,,, 688     Y   mmmmmmmm`.**&'55555555p+7 H HJ& G $j((:2F2FGGGG) !!!!!6!!!L,$,$,$,$,$,$,$,$,$,$r