⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.19
Server IP:
178.33.27.10
Server:
Linux cpanel.dev-unit.com 3.10.0-1160.108.1.el7.x86_64 #1 SMP Thu Jan 25 16:17:31 UTC 2024 x86_64
Server Software:
Apache/2.4.57 (Unix) OpenSSL/1.0.2k-fips
PHP Version:
8.2.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib64
/
python2.7
/
site-packages
/
psycopg2
/
View File Name :
pool.pyc
� 0��Qc @ s� d Z d d l Z d d l j Z d e j 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 PoolErrorc B s e Z RS( ( t __name__t __module__( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR 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 | _ i | _ i | _ d | _ x! t | j � D] } | j � 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 t argst kwargst i( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt __init__& s c C s[ t j | j | j � } | d k rG | | j | <| | j t | � <n | j j | � | S( s; Create a new connection and assign it to 'key' if not None.N( t psycopg2t connectR R t NoneR R t idR t append( R t keyt conn( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR < s c C s | j d 7_ | j S( s Return a new unique key.i ( R ( R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt _getkeyF s c C s� | j r t d � � n | d k r3 | j � } n | | j k rM | j | S| j r� | j j � | j | <} | | j t | � <| St | j � | j k r� t d � � n | j | � Sd S( s9 Get a free connection and assign it to 'key' if not None.s connection pool is closeds connection pool exaustedN( R R R R R R t popR R t lenR R ( R R R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt _getconnK s c C s* | j r t d � � n | d k r? | j j t | � � } n | sT t d � � n t | j � | j k r� | r� | j s� | j � } | t j k r� | j � q� | t j k r� | j � | j j | � q� | j j | � q� n | j � | j s | | j k r&| j | =| j t | � =n d S( s Put away a connection.s connection pool is closeds trying to put unkeyed connectionN( R R R R t getR R R R t get_transaction_statust _extt TRANSACTION_STATUS_UNKNOWNt closet TRANSACTION_STATUS_IDLEt rollbackR R ( R R R R$ t status( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt _putconn\ s& c C sd | j r t d � � n x< | j t | j j � � D] } y | j � Wq5 q5 Xq5 Wt | _ d S( s� 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. s connection pool is closedN( R R R t listR t valuesR$ t True( R R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt _closeall} s #N( R R t __doc__R R R R R R R( R, ( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR # s !t SimpleConnectionPoolc B s) e Z d Z e j Z e j Z e j Z RS( s@ A connection pool that can't be shared across different threads.( R R R- R R t getconnR( t putconnR, t closeall( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR. � s t ThreadedConnectionPoolc B s> 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 l } t j | | | | | � | j � | _ d S( s Initialize the threading lock.i����N( t threadingR R t Lockt _lock( R R R R R R3 ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR � s c C s3 | j j � z | j | � SWd | j j � Xd S( s9 Get a free connection and assign it to 'key' if not None.N( R5 t acquireR t release( R R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR/ � s c C s9 | j j � z | j | | | � Wd | j j � Xd S( s Put away an unused connection.N( R5 R6 R( R7 ( R R R R$ ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR0 � s c C s0 | j j � z | j � Wd | j j � Xd S( s6 Close all connections (even the one currently in use.)N( R5 R6 R, R7 ( R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR1 � s N( R R R- R R R/ R R0 R1 ( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR2 � 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 si d d l } | j d t � d d l } t j | | | | | � | j � | _ d d l } | | _ d S( s Initialize the threading lock.i����Ns. deprecated: use ZPsycopgDA.pool implementation( t warningst warnt DeprecationWarningR3 R R R4 R5 t threadt! _PersistentConnectionPool__thread( R R R R R R9 R3 R< ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR � s c C sB | j j � } | j j � z | j | � SWd | j j � Xd S( s+ Generate thread id and return a connection.N( R= t get_identR5 R6 R R7 ( R R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR/ � s c C s^ | j j � } | j j � z- | s5 | j | } n | j | | | � Wd | j j � Xd S( s Put away an unused connection.N( R= R> R5 R6 R R( R7 ( R R R$ R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR0 � s c C s0 | j j � z | j � Wd | j j � Xd S( s6 Close all connections (even the one currently in use.)N( R5 R6 R, R7 ( R ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR1 � s N( R R R- R R/ R R R0 R1 ( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyR8 � s ( R- R t psycopg2.extensionst extensionsR" t ErrorR t objectR R. R2 R8 ( ( ( s3 /usr/lib64/python2.7/site-packages/psycopg2/pool.pyt <module> s j#