YtjdZddlmZddlmZddlmZddlmZmZddl m Z m Z ddl m Z erdd lmZGd d ZGd d ZdS)z9 psycopg connection pool base class and functionalities. ) annotations) monotonicrandom) TYPE_CHECKINGAny)Counterdeque) PoolClosed)BaseConnectionc eZdZUdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZded<d;d"Zdd(Zd?d*Zd@d,Zd@d-ZdAd0ZdBd2ZdBd3ZdBd4Z e!dCd8Z"dAd9Z#d:S)DBasePoolrpool_minpool_max pool_sizepool_availablerequests_waiting requests_numrequests_queuedrequests_wait_msrequests_errorsusage_ms returns_badconnections_numconnections_msconnections_errorsconnections_lostz deque[Any]_poolmin_sizeintmax_size int | Nonename str | None close_returnsbooltimeoutfloat max_waiting max_lifetimemax_idlereconnect_timeout num_workersc |||\}}|s tjdzx} t_d| }| dkrtd||_||_||_||_||_||_ | |_ ||_ ||_ | |_ ||_t|_t#t$|_d|_||_d|_d|_d|_d|_dS)Nr zpool-znum_workers must be at least 1FT) _check_sizer _num_pool ValueErrorr$r& _min_size _max_sizer(r*r-r+r,r._nconnsr rr str_stats _drained_at _nconns_min_growing_opened_closed_open_implicit) selfr r"r$r&r(r*r+r,r-r.nums O/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg_pool/base.py__init__zBasePool.__init__+s"--hAA( !'/'9A'= =C($ 3==D ??=>> > *!! &!2(  & WW clnn $    #returnr7c nd|jjd|jjd|jdt |dd S)N<. z at 0xx>) __class__ __module____name__r$idr?s rA__repr__zBasePool.__repr__csX 1) 1 1DN,C 1 1  1 1#%d88 0 1 1 1 rCc|jSN)r4rOs rAr zBasePool.min_sizei ~rCc|jSrR)r5rOs rAr"zBasePool.max_sizemrSrCc|jS)z`!True` if the pool is closed.)r=rOs rAclosedzBasePool.closedqs |rCtuple[int, int]c||}|dkrtd||krtd||cxkrdkrnntd||fS)Nrzmin_size cannot be negativez/max_size must be greater or equal than min_sizez0if min_size is 0 max_size must be greater than 0)r3)r?r r"s rAr1zBasePool._check_sizevs{  H a<<:;; ; h  NOO O x $ $ $ $1 $ $ $ $ $OPP P!!rCNonecD|jr|jrtddSdS)Nz8pool has already been opened/closed and cannot be reused)r=r<r rOs rA _check_openzBasePool._check_opens> < YDL YWXX X Y Y Y YrCc|jr7|jrtd|jdtd|jddS)Nz the pool z is already closedz is not open yet)r=r<r r$rOs rA_check_open_getconnzBasePool._check_open_getconns\ < L| L !LTY!L!L!LMMM !JTY!J!J!JKKK  L LrCconnBaseConnection[Any]ct|ddx}|urdS|r d|j}nd}td|jd|d|)Nrzit comes from pool zit doesn't come from any poolz can't return connection to pool z, z: )getattrr$r3)r?r^poolmsgs rA_check_pool_putconnzBasePool._check_pool_putconnspD'400 0DT 9 9 F  25 55CC1C Kty K Kc K KT K K   rCdict[str, int]c|t|j}|||S)z< Return current stats about the pool usage. )dictr8update _get_measures)r?rvs rA get_statszBasePool.get_statss6$+   $$$&&''' rCc|jtc}|_t|}|||S)zy Return current stats about the pool usage. After the call, all the counters are reset to zero. )r8r rgrhri)r?statsrjs rA pop_statszBasePool.pop_statssF "['))t{ %[[ $$$&&''' rCc |j|j|j|j|j|j|jt|jiS)zG Return immediate measures of the pool (not counters). ) _POOL_MINr4 _POOL_MAXr5 _POOL_SIZEr6_POOL_AVAILABLElenrrOs rArizBasePool._get_measuress9 NDN NDN OT\  #dj//   rCvaluemin_pcmax_pcc<|d||z tzz|zzS)zV Add a random value to *value* between *min_pc* and *max_pc* percent. ?r)clsrurvrws rA_jitterzBasePool._jitters& 688;rs #"""""%%%%%%%%&&&&&&&&8777777qJqJqJqJqJqJqJqJh@@@@@@@@@@rC