o ßý°jÂ)ã@sXdZddlmZmZddlmZddlmZddlmZm Z m Z m Z Gdd „d e ƒZ d S) Ú é)ÚdatetimeÚ timedelta)Úlinesepé)ÚLDAPMetricsErroré)ÚlogÚ log_enabledÚERRORÚBASICc@sfeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z ddd„Z dd„Z e dd„ƒZdS)ÚConnectionUsagez0 Collect statistics on connection usage cCsªd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ttƒrSttdƒdSdS)Nrzreset usage metrics)Ú open_socketsÚclosed_socketsÚwrapped_socketsÚbytes_transmittedÚbytes_receivedÚmessages_transmittedÚmessages_receivedÚ operationsÚabandon_operationsÚadd_operationsÚbind_operationsÚcompare_operationsÚdelete_operationsÚextended_operationsÚmodify_operationsÚmodify_dn_operationsÚsearch_operationsÚunbind_operationsÚreferrals_receivedÚreferrals_followedÚreferrals_connectionsÚrestartable_failuresÚrestartable_successesÚservers_from_poolr r r ©Úself©r(úƒ/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/ldap3/core/usage.pyÚreset&s6ÿzConnectionUsage.resetcCsÈd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ttƒrbttdƒdSdS)Nrzinstantiated Usage object) Úinitial_connection_start_timeÚopen_socket_start_timeÚconnection_stop_timeÚlast_transmitted_timeÚlast_received_timerrrrrrrrrrrrrrrrrrr r!r"r#r$r%r r r r&r(r(r)Ú__init__Bs@ÿzConnectionUsage.__init__cCsVdt}|dt|jƒdt7}|d|jrt|j ¡ƒndt7}|d|jr/t|j ¡ƒndt7}|d|jrAt|j ¡ƒndt7}|d|jrSt|j ¡ƒndt7}|d |jret|j ¡ƒndt7}|d t7}|d t|j ƒt7}|d t|j ƒt7}|d t|j ƒt7}|dt|j ƒt7}|dt|j |jƒt7}|dt|j ƒt7}|dt|jƒt7}|dt|j|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt|jƒt7}|dt7}|dt|jƒt7}|dt|jƒt7}|d t|jƒt7}|d!t|j|j ƒt7}|d"t|jƒt7}|d#t|j ƒt7}|S)$NzConnection Usage:z Time: [elapsed: ú]z Initial start time: Úz Open socket time: z Last transmitted time: z Last received time: z Close socket time: z Server:z Servers from pool: z Sockets open: z Sockets closed: z Sockets wrapped: z Bytes: z Transmitted: z Received: z Messages: z Operations: z Abandon: z Bind: z Add: z Compare: z Delete: z Extended: z Modify: z ModifyDn: z Search: z Unbind: z Referrals: z Followed: z Connections: z Restartable tries: z Failed restarts: z Successful restarts: )!rÚstrÚ elapsed_timer+Ú isoformatr,r.r/r-r%rrrrrrrrrrrrrrrrrrr r!r"r#r$)r'Úrr(r(r)Ú__repr__dsJ$$$$$  zConnectionUsage.__repr__cCs| ¡S)N)r7r&r(r(r)Ú__str__‹szConnectionUsage.__str__cCs–t|tƒs tdƒ‚|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j |j 7_ |j |j 7_ |j |j 7_ |j |j 7_ |j |j 7_ |j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|j|j7_|S)Nz unable to add to ConnectionUsage)Ú isinstancer rrrrrrrrrrrrrrrrrrrr r!r"r#r$r%)r'Úotherr(r(r)Ú__iadd__Žs6 zConnectionUsage.__iadd__cCs€t ¡|_|j|7_|jd7_|jd7_|ddkr)|jd7_dS|ddkr8|jd7_dS|ddkrG|jd7_dS|ddkrV|j d7_ dS|ddkre|j d7_ dS|ddkrt|j d7_ dS|dd krƒ|j d7_ dS|dd kr’|j d7_ dS|dd kr¡|jd7_dS|dd kr°|jd7_dSttƒr¼ttd |dƒtdƒ‚)NrÚtypeÚabandonRequestÚ addRequestÚ bindRequestÚcompareRequestÚ delRequestÚ extendedReqÚ modifyRequestÚ modDNRequestÚ searchRequestÚ unbindRequestz5unable to collect usage for unknown message type <%s>z0unable to collect usage for unknown message type)rÚnowr.rrrrrrrrrrrrrr r r r)r'ÚmessageÚlengthr(r(r)Úupdate_transmitted_message¬s6           z*ConnectionUsage.update_transmitted_messagecCs*t ¡|_|j|7_|jd7_dS)Nr)rrGr/rr)r'rIr(r(r)Úupdate_received_messageÊs z'ConnectionUsage.update_received_messageTcCsD|r| ¡t ¡|_d|_|js|j|_ttƒr ttdƒdSdS)Nzstart collecting usage metrics) r*rrGr,r-r+r r r )r'r*r(r(r)ÚstartÏs ÿzConnectionUsage.startcCs.|jrt ¡|_ttƒrttdƒdSdSdS)Nzstop collecting usage metrics)r,rrGr-r r r r&r(r(r)ÚstopÚs  ýzConnectionUsage.stopcCs.|jr |j|jS|jrt ¡|jStdƒS)Nr)r-r,rrGrr&r(r(r)r4às zConnectionUsage.elapsed_timeN)T)Ú__name__Ú __module__Ú __qualname__Ú__doc__r*r0r7r8r;rJrKrLrMÚpropertyr4r(r(r(r)r !s"'  r N)rQrrÚosrÚ exceptionsrÚ utils.logr r r r Úobjectr r(r(r(r)Ús