/usr/lib/python3/dist-packages/fail2ban/client/__pycache__
Edit: /usr/lib/python3/dist-packages/fail2ban/client/__pycache__/csocket.cpython-310.pyc (2529B)
o
;s*b³ ã @ sN d Z dZdZddlmZmZmZ ddlmZ ddl Z ddl
Z
G dd „ d ƒZ dS )
z
Cyril Jaquierz Copyright (c) 2004 Cyril JaquierÚGPLé )ÚdumpsÚloadsÚHIGHEST_PROTOCOLé )ÚCSPROTONc @ sR e Zd Zddd„Zdd„ Zdd d
„Zd d „ Zd
d„ Zedd„ ƒZ eddd„ƒZ
dS )ÚCSocketú /var/run/fail2ban/fail2ban.sockéÿÿÿÿc C s@ t t jt j¡| _| j ¡ | _|dkr| |¡ | j |¡ d S ©Nr
)ÚsocketÚAF_UNIXÚ SOCK_STREAMÚ_CSocket__csockÚ
gettimeoutÚ_CSocket__deftoutÚ
settimeoutÚconnect)ÚselfÚsockÚtimeout© r ú9/usr/lib/python3/dist-packages/fail2ban/client/csocket.pyÚ__init__# s
zCSocket.__init__c C s | ¡ d S ©N)Úclose©r r r r Ú__del__- s zCSocket.__del__FNc C s@ t tttj|ƒƒtƒ}| j |¡ | j tj ¡ |
| j||¡S r ) r ÚlistÚmapr Úconvertr r Úsendr ÚENDÚreceive)r ÚmsgÚ nonblockingr Úobjr r r r! 0 s z CSocket.sendc C s$ | j |dkr |¡ d S | j¡ d S r )r r r )r r r r r r 7 s $zCSocket.settimeoutc C st | j sd S z| j tjtj ¡ | j tj¡ W n
tjy" Y nw z| j ¡ W n
tjy4 Y nw d | _ d S r )
r Úsendallr ÚCLOSEr" Úshutdownr Ú SHUT_RDWRÚerrorr r r r r r : s ÿÿ
z
CSocket.closec C s$ t | tttttttfƒr| S t| ƒS )z6Convert every "unexpected" member of message to string)Ú
isinstanceÚstrÚboolÚintÚfloatr ÚdictÚset)Úmr r r r H s zCSocket.convertc C sš t j}|r
| d¡ |r| |¡ d}| t jd¡dkrI| |¡}t|ƒs+t dd¡‚|t jkr4t
|ƒS || }|dk r@|dK }| t jd¡dks t
|ƒS ) Nr i iàÿÿÿr
éh zConnection reset by peeri € é ) r ÚEMPTYÚ setblockingr Úrfindr" ÚrecvÚlenr r+ r )r r% r r$ ÚbufsizeÚchunkr r r r# P s
þúzCSocket.receive)r r
)FN) Ú__name__Ú
__module__Ú __qualname__r r r! r r Ú staticmethodr r# r r r r r ! s
r ) Ú
__author__Ú
__copyright__Ú __license__Úpickler r r Úprotocolr r Úsysr r r r r Ú
s