Ñò
žÅŠKc @ se d Z d d k Z yu d d k Z e i d e i d d ƒ e i d ƒ Z d „ Z y d d k Z e i d ƒ Wn e i
d ƒ n XWnf e j
o? d d k l
Z
l Z l Z d
„ Z e
d e d d
ƒ n d d k Z d „ Z n Xd e i f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d S( s` Connection pooling for psycopg2
This module implements thread-safe (and not) connection pools.
iÿÿÿÿNt levelt formats% %(asctime)s %(levelname)s %(message)st psycopg2c G s> t i d d i g } | D] } | t | ƒ q ~ ƒ ƒ d S( NR t ( t _loggert debugt joint str( t argst _[1]t x( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyt dbg$ s s. installed. Logging using Python logging module( t LOGt DEBUGt INFOc
G sE t d t d d i g } | D] } | t | ƒ q ~ ƒ d ƒ d S( Nt
ZPsycopgDAt R s
( R R
R R ( R R R
( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR . s R t Installeds Logging using Zope's zLOG
c G s! t i i d i | ƒ d ƒ d S( NR s
( t syst stderrt writeR ( R ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR 5 s t PoolErrorc B s e Z RS( ( t __name__t
__module__( ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR 9 s t AbstractConnectionPoolc B sP e Z d Z d „ Z d d „ Z d „ Z d d „ Z d e d „ Z d „ Z
RS( s Generic key-based pooling code.c O sy | | _ | | _ t | _ | | _ | | _ g | _ h | _ h | _ d | _ x! t
| i ƒ D] } | i ƒ qa Wd S( sð 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.
i N( t minconnt maxconnt Falset closedt _argst _kwargst _poolt _usedt _rusedt _keyst ranget _connect( t selfR R R t kwargst i( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyt __init__@ s c C s] t i | i | i Ž } | d j o$ | | i | <| | i t | ƒ e Z d Z d „ Z d d „ Z d d e d „ Z d „ Z RS( s7 A connection pool that works with the threading module.c O s8 d d k } t i | | | | | Ž | i ƒ | _ d S( s Initialize the threading lock.iÿÿÿÿN( t threadingR R( t Lockt _lock( R% R R R R& R@ ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR( ¤ s c C s3 | i i ƒ z | i | ƒ SWd | i i ƒ Xd S( s9 Get a free connection and assign it to 'key' if not None.N( RB t acquireR3 t release( R% R- ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR< « s
c C s9 | i i ƒ z | i | | | ƒ Wd | i i ƒ Xd S( s Put away an unused connection.N( RB RC R5 RD ( R% R. R- R4 ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR= ³ s
c C s0 | i i ƒ z | i ƒ Wd | i i ƒ Xd S( s6 Close all connections (even the one currently in use.)N( RB RC R9 RD ( R% ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR> » s
N( R R R: R( R* R< R R= R> ( ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR? ¡ s
t PersistentConnectionPoolc B s8 e Z d Z d „ Z d „ Z d e d „ Z d „ Z RS( s› A pool that assigns persistent connections to different threads.
Note that this connection pool generates by itself the required keys
using the current thread id. This means that until a thread puts away
a connection it will always get the same connection object by successive
`!getconn()` calls. This also means that a thread can't use more than one
single connection from the pool.
c O sM d d k } t i | | | | | Ž | i ƒ | _ d d k } | | _ d S( s Initialize the threading lock.iÿÿÿÿN( R@ R R( RA RB t threadt! _PersistentConnectionPool__thread( R% R R R R& R@ RF ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR( Î s c C sB | i i ƒ } | i i ƒ z | i | ƒ SWd | i i ƒ Xd S( s+ Generate thread id and return a connection.N( RG t get_identRB RC R3 RD ( R% R- ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR< Ú s
c C s` | i i ƒ } | i i ƒ z/ | p | i | } n | i | | | ƒ Wd | i i ƒ Xd S( s Put away an unused connection.N( RG RH RB RC R R5 RD ( R% R. R4 R- ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR= ã s
c C s0 | i i ƒ z | i ƒ Wd | i i ƒ Xd S( s6 Close all connections (even the one currently in use.)N( RB RC R9 RD ( R% ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyR> í s
N( R R R: R( R< R* R R= R> ( ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyRE Ä s
( R: R t loggingt basicConfigR t getLoggerR R t Appt infoR t ImportErrort zLOGR R
R t ErrorR t objectR R; R? RE ( ( ( s3 /usr/lib64/python2.6/site-packages/psycopg2/pool.pyt s0
\#