§ x<ˆj¬ãó–—dZddlZddlmZGd„dej¦«ZGd„d¦«ZGd„d e¦«ZGd „de¦«ZdS)z`Connection pooling for psycopg2 This module implements thread-safe (and not) connection pools. éN)Ú extensionscó—eZdZdS)Ú PoolErrorN)Ú__name__Ú __module__Ú__qualname__©óúa/builddir/build/BUILD/cloudlinux-venv-1.0.12/venv/lib64/python3.11/site-packages/psycopg2/pool.pyrr s€€€€€Ø€Dr rcó<—eZdZdZd„Zd d„Zd„Zd d„Zdd„Zd „Z dS)ÚAbstractConnectionPoolzGeneric key-based pooling code.có—t|¦«|_t|¦«|_d|_||_||_g|_i|_i|_d|_ t|j¦«D]}| ¦«ŒdS)zèInitialize the connection pool. New 'minconn' connections are created immediately calling 'connfunc' with given parameters. The connection pool will support a maximum of about 'maxconn' connections. FrN)ÚintÚminconnÚmaxconnÚclosedÚ_argsÚ_kwargsÚ_poolÚ_usedÚ_rusedÚ_keysÚrangeÚ_connect)ÚselfrrÚargsÚkwargsÚis rÚ__init__zAbstractConnectionPool.__init__'s€õ˜7‘|”|ˆŒÝ˜7‘|”|ˆŒØˆŒàˆŒ ØˆŒàˆŒ ØˆŒ ØˆŒØˆŒ åt”|Ñ$Ô$ð ð ˆAØMŠM‰OŒOˆOˆOð ð r Ncó¸—tj|ji|j¤Ž}|"||j|<||jt |¦«<n|j |¦«|S)z;Create a new connection and assign it to 'key' if not None.) Úpsycopg2ÚconnectrrrrÚidrÚappend©rÚkeyÚconns rrzAbstractConnectionPool._connect=s[€åÔ ¤Ð<¨t¬|Ð<Ð<ˆØˆ?Ø"ˆDŒJs‰OØ$'ˆDŒK˜4™œÑ!Ð!àŒJ×Ò˜dÑ#Ô#Ð#Øˆr có0—|xjdz c_|jS)zReturn a new unique key.é)r©rs rÚ_getkeyzAbstractConnectionPool._getkeyGs€àˆ Œ a‰ˆ Œ ØŒzÐr cóŽ—|jrtd¦«‚|€| ¦«}||jvr |j|S|jr<|j ¦«x|j|<}||jt|¦«<|St|j¦«|j krtd¦«‚| |¦«S)ú9Get a free connection and assign it to 'key' if not None.úconnection pool is closedNzconnection pool exhausted)rrr+rrÚpoprr#Úlenrrr%s rÚ_getconnzAbstractConnectionPool._getconnLs¹€àŒ;ð 9ÝÐ7Ñ8Ô8Ð8Øˆ;Ø—,’,‘.”.ˆCà$”*ÐÐØ”:˜c”?Ð"àŒ:ð &Ø%)¤Z§^¢^Ñ%5Ô%5Ð5ˆDŒJs‰O˜dØ$'ˆDŒK˜4™œÑ!ØˆKå4”:‰Œ $¤,Ò.Ð.ÝÐ ;Ñ<Ô<Ð<Ø—=’= Ñ%Ô%Ð%r FcóŽ—|jrtd¦«‚|€8|j t |¦«¦«}|€td¦«‚t|j¦«|jkr”|s’|jsŠ|jj }|tjkr| ¦«nn|tj kr/| ¦«|j |¦«n/|j |¦«n| ¦«|jr ||jvr|j|=|jt |¦«=dSdS)zPut away a connection.r.Nz trying to put unkeyed connection)rrrÚgetr#r0rrÚinfoÚtransaction_statusÚ_extÚTRANSACTION_STATUS_UNKNOWNÚcloseÚTRANSACTION_STATUS_IDLEÚrollbackr$r)rr'r&r8Ústatuss rÚ_putconnzAbstractConnectionPool._putconn_s5€àŒ;ð 9ÝÐ7Ñ8Ô8Ð8àˆ;Ø”+—/’/¥" T¡(¤(Ñ+Ô+ˆCØˆ{ÝÐ BÑCÔCÐCåˆtŒz‰?Œ?˜Tœ\Ò)Ð)°%Ð)ð”;ð ,ØœÔ5ØTÔ<Ò<Ð<à—J’J‘L”LLLØtÔ;Ò;Ð;à—M’M‘O”OOØ”J×%Ò% dÑ+Ô+Ð+Ð+ð”J×%Ò% dÑ+Ô+Ð+øð JŠJ‰LŒLˆLðŒ{ð &˜c T¤ZÐ/Ð/Ø” ˜3Ø”B˜t™HœHÐ%Ð%Ð%ð0Ð/r cóì—|jrtd¦«‚|jt|j ¦«¦«zD]'} | ¦«Œ#t$rYŒ$wxYwd|_dS)z×Close all connections. Note that this can lead to some code fail badly when trying to use an already closed connection. If you call .closeall() make sure your code can deal with it. r.TN)rrrÚlistrÚvaluesr8Ú Exception)rr's rÚ _closeallz AbstractConnectionPool._closeall‚sˆ€ðŒ;ð 9ÝÐ7Ñ8Ô8Ð8Ø”J¥ d¤j×&7Ò&7Ñ&9Ô&9Ñ!:Ô!:Ñ:ð ð ˆDð Ø— ’ ‘”øÝð ð ð Øð øøøàˆŒˆˆsÁAÁ A*Á)A*©N)NF) rrrÚ__doc__rrr+r1r<rAr r rr r $s„€€€€€Ø)Ð)ðððð,ððððððð &ð&ð&ð&ð&!&ð!&ð!&ð!&ðFððððr r có<—eZdZdZejZejZej Z dS)ÚSimpleConnectionPoolz@A connection pool that can't be shared across different threads.N)rrrrCr r1Úgetconnr<ÚputconnrAÚcloseallr r rrErE“s,€€€€€ØJÐJà$Ô-€GØ$Ô-€GØ%Ô/€H€H€Hr rEcó.—eZdZdZd„Zdd„Zd d„Zd„ZdS) ÚThreadedConnectionPoolz7A connection pool that works with the threading module.cón—ddl}tj|||g|¢Ri|¤Ž| ¦«|_dS)zInitialize the threading lock.rN)Ú threadingr rÚLockÚ_lock)rrrrrrLs rrzThreadedConnectionPool.__init__žsY€àÐÐÐÝÔ'Ø'˜7ð 5Ø%)ð 5ð 5ð 5Ø-3ð 5ð 5ð 5à—^’^Ñ%Ô%ˆŒ ˆ ˆ r NcóÎ—|j ¦« | |¦«|j ¦«S#|j ¦«wxYw)r-)rNÚacquirer1Úrelease)rr&s rrFzThreadedConnectionPool.getconn¥s[€àŒ ×ÒÑÔÐð !Ø—=’= Ñ%Ô%àŒJ×ÒÑ Ô Ð Ð øˆDŒJ×ÒÑ Ô Ð Ð øøøs›A Á A$FcóÖ—|j ¦« | |||¦«|j ¦«dS#|j ¦«wxYw)zPut away an unused connection.N)rNrPr<rQ)rr'r&r8s rrGzThreadedConnectionPool.putconnse€àŒ ×ÒÑÔÐð !ØMŠM˜$ UÑ+Ô+Ð+àŒJ×ÒÑ Ô Ð Ð Ð øˆDŒJ×ÒÑ Ô Ð Ð øøøs›A Á A(cóÐ—|j ¦« | ¦«|j ¦«dS#|j ¦«wxYw)z6Close all connections (even the one currently in use.)N)rNrPrArQr*s rrHzThreadedConnectionPool.closeallµs_€àŒ ×ÒÑÔÐð !ØNŠNÑÔÐàŒJ×ÒÑ Ô Ð Ð Ð øˆDŒJ×ÒÑ Ô Ð Ð øøøs›A Á A%rB)NNF)rrrrCrrFrGrHr r rrJrJ›s`€€€€€ØAÐAð&ð&ð&ð!ð!ð!ð!ð!ð!ð!ð!ð!ð!ð!ð!ð!r rJ) rCr!rr6ÚErrorrr rErJr r rúrUséðððð6€€€Ø'Ð'Ð'Ð'Ð'Ð'ð ð ð ð ð ”ñ ô ð ðlðlðlðlðlñlôlðlð^0ð0ð0ð0ð0Ð1ñ0ô0ð0ð !ð !ð !ð !ð !Ð3ñ !ô !ð !ð !ð !r