gifdZddlmZddlmZddlmZddlmZmZddl m Z ddl m Z dd l mZmZerdd lmZGd d ZGd dZdS)z9 psycopg connection pool base class and functionalities. ) annotations) monotonicrandom) TYPE_CHECKINGAny)errors) PoolClosed)CounterDeque)BaseConnectionceZdZUdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZded< d>d?d%Zd@d'ZedAd(ZedAd)ZedBd+ZdCd-ZdDd/ZdDd0ZdEd3ZdFd5ZdFd6ZdFd7Z e!dGd;Z"dEd<Z#d=S)HBasePoolrpool_minpool_max pool_sizepool_availablerequests_waiting requests_numrequests_queuedrequests_wait_msrequests_errorsusage_ms returns_badconnections_numconnections_msconnections_errorsconnections_lostz Deque[Any]_poolconninfostrkwargsdict[str, Any] | Nonemin_sizeintmax_size int | Nonename str | Nonetimeoutfloat max_waiting max_lifetimemax_idlereconnect_timeout num_workersc |||\}}|s tjdzx} t_d| }| dkrtd||_|pi|_||_||_||_||_ ||_ | |_ ||_ | |_ | |_||_t!|_t%t&|_||_d|_d|_d|_d|_dS)Nr zpool-znum_workers must be at least 1FT) _check_sizer _num_pool ValueErrorr"r$r* _min_size _max_sizer,r.r1r/r0r2_nconnsr r r r#_stats _nconns_min_growing_opened_closed_open_implicit) selfr"r$r&r(r*r,r.r/r0r1r2nums a/var/www/html/Pagina-Ingenieria-Requisitos/venv/lib/python3.11/site-packages/psycopg_pool/base.py__init__zBasePool.__init__-s"--hAA( !'/'9A'= =C($ 3==D ??=>> >  &,l  !! &!2(  & WW clnn $    #returnc nd|jjd|jjd|jdt |dd S)N<. z at 0xx>) __class__ __module____name__r*idr@s rB__repr__zBasePool.__repr__fsX 1) 1 1DN,C 1 1  1 1#%d88 0 1 1 1 rDc|jSN)r7rPs rBr&zBasePool.min_sizel ~rDc|jSrS)r8rPs rBr(zBasePool.max_sizeprTrDboolc|jS)z`!True` if the pool is closed.)r>rPs rBclosedzBasePool.closedts |rDtuple[int, int]c||}|dkrtd||krtd||cxkrdkrnntd||fS)Nrzmin_size cannot be negativez/max_size must be greater or equal than min_sizez3if min_size is 0 max_size must be greater or than 0)r6)r@r&r(s rBr4zBasePool._check_sizeys{  H a<<:;; ; h  NOO O x $ $ $ $1 $ $ $ $ $RSS S!!rDNonecN|jr|jrtjddSdS)Nz8pool has already been opened/closed and cannot be reused)r>r=eOperationalErrorrPs rB _check_openzBasePool._check_opensA < DL $J     rDc|jr7|jrtd|jdtd|jddS)Nz the pool z is already closedz is not open yet)r>r=r r*rPs rB_check_open_getconnzBasePool._check_open_getconns\ < L| L !LTY!L!L!LMMM !JTY!J!J!JKKK  L LrDconnBaseConnection[Any]ct|ddx}|urdS|r d|j}nd}td|jd|d|)Nr zit comes from pool zit doesn't come from any poolz can't return connection to pool z, z: )getattrr*r6)r@rbpoolmsgs rB_check_pool_putconnzBasePool._check_pool_putconnspD'400 0DT 9 9 F  25 55CC1C Kty K Kc K KT K K   rDdict[str, int]c|t|j}|||S)z< Return current stats about the pool usage. )dictr:update _get_measures)r@rvs rB get_statszBasePool.get_statss6$+   $$$&&''' rDc|jtc}|_t|}|||S)zy Return current stats about the pool usage. After the call, all the counters are reset to zero. )r:r rkrlrm)r@statsrns rB pop_statszBasePool.pop_statssF "['))t{ %[[ $$$&&''' rDc |j|j|j|j|j|j|jt|jiS)zG Return immediate measures of the pool (not counters). ) _POOL_MINr7 _POOL_MAXr8 _POOL_SIZEr9_POOL_AVAILABLElenr rPs rBrmzBasePool._get_measuress9 NDN NDN OT\  #dj//   rDvaluemin_pcmax_pcc<|d||z tzz|zzS)zV Add a random value to *value* between *min_pc* and *max_pc* percent. ?r)clsryrzr{s rB_jitterzBasePool._jitters& 688;rs* #"""""%%%%%%%%########8777777sTsTsTsTsTsTsTsTl@@@@@@@@@@rD