← Back
Editing: csocket.cpython-312.pyc
� =�*f� � �T � d Z dZdZddlmZmZmZ ddlmZ ddl Z ddl Z G d� d � Z y) z Cyril Jaquierz Copyright (c) 2004 Cyril Jaquier�GPL� )�dumps�loads�HIGHEST_PROTOCOL� )�CSPROTONc �P � e Zd Zd d�Zd� Zd d�Zd� Zd� Zed� � Z ed d�� Z y) �CSocketc � � t j t j t j � | _ | j j � | _ |dk7 r| j |� | j j |� y �N���)�socket�AF_UNIX� SOCK_STREAM�_CSocket__csock� gettimeout�_CSocket__deftout� settimeout�connect)�self�sock�timeouts �</usr/lib/python3.12/site-packages/fail2ban/client/csocket.py�__init__zCSocket.__init__# sY � � � � �v�~�~�v�/A�/A�B�$�,��<�<�*�*�,�$�.� ��]��?�?�7���,�,���t� � c �$ � | j � y �N)�close�r s r �__del__zCSocket.__del__- s � ��*�*�,r Nc �& � t t t t j |� � t � }| j j |� | j j t j � | j | j ||� S r ) r �list�mapr �convertr r �sendr �END�receive)r �msg� nonblockingr �objs r r% z CSocket.send0 s^ � � �d�3�w����,�-�/?�@�#��,�,���C���,�,���G�K�K� � � � �d�l�l�K�� 9�9r c �f � | j j |dk7 r|� y | j � y r )r r r )r r s r r zCSocket.settimeout7 s# � ��,�,���W��]�'�G����Gr c � � | j sy | j j t j t j z � | j j t j � | j j � d | _ y # t j $ r Y �8w xY w# t j $ r Y d | _ y w xY wr ) r �sendallr �CLOSEr& �shutdownr � SHUT_RDWR�errorr r s r r z CSocket.close: s� � � � � � ���<�<���� � �� � �3�4��<�<����)�)�*���<�<���� �$�,�� � � � ���� � � � ���$�,��s$ �A#B �3B. �B+�*B+�.C � C c �z � t | t t t t t t t f� r| S t | � S )z6Convert every "unexpected" member of message to string)� isinstance�str�bool�int�floatr" �dict�set)�ms r r$ zCSocket.convertH s+ � � ��C��s�E�4��s�;�<� �8� �a�&�=r c �� � t j }|r| j d� |r| j |� d}|j t j d� dk( r�| j |� }t |� st j dd� �|t j k( r t |� S ||z }|dk r|dz }|j t j d� dk( r��t |� S ) Nr i i��r �h zConnection reset by peeri � � ) r �EMPTY� setblockingr �rfindr& �recv�lenr r1 r )r r) r r( �bufsize�chunks r r' zCSocket.receiveP s� � �� � �#��$�"�"�1�%� �d�o�o�g�&� �'� � � �'�+�+�s�#�r�)� �9�9�W� �5� �e�*� �,�,�s� 6� 7�7� �w�{�{��E� �s��� �u��3� ��o�w�1�}�w� � � �'�+�+�s�#�r�)� �s��r )z /var/run/fail2ban/fail2ban.sockr )FN) �__name__� __module__� __qualname__r r r% r r � staticmethodr$ r' � r r r r ! sD � � ��:�H� � �� �� � � � r r ) � __author__� __copyright__� __license__�pickler r r �protocolr r �sysr rI r r �<module>rP s1 ��. � �2� �� � 2� 1� � � �<� <r
Save File
Cancel