Файловый менеджер - Редактировать - /opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/__pycache__/client.cpython-311.opt-1.pyc
Назад
� W�i11 � �* � d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dlmZm Z mZmZ d dlmZ d dlmZ d dlmZmZmZ d dlmZmZ d dlmZ d d lmZmZm Z d d l!m"Z" ej# e$� � Z% G d� d� � Z& G d � de&e� � Z'dS )� N)� Generator)�APIError�APIErrorTooManyRequests� APITokenError�send_message)�license)�Core)�Message�MessageList�MessageType)�MessageSink�expect)�PersistentMessagesQueue)�recurring_check�safe_cancel_task�Scope)�ServerJSONEncoderc � � e Zd ZdZ eej � dd� � � � ZdZ dZ dej fd�Z dd �Zd� Zed� � � Zej deej d d f fd �� � Z eej � � dedd fd�� � Z ee � � d� � � Z ed� � d� � � Zdede fd�Z!de defd�Z"d� Z#d� Z$d� Z%dd�Z&d S )�SendToServerClienta Send messages to server. * process Reportable messages; * add them to a pending messages list; * send all pending messages to server when list is full (contains _PENDING_MESSAGES_LIMIT items or more); * send all pending messages on plugin shutdown.� IMUNIFYAV_MESSAGES_COUNT_TO_SEND� i, �2 �loopc � �~ K � || _ t � � | _ t j � � | _ t j � � | _ t j � � | _ |� | � � � � � | _ |� | � � � � � | _ d S �N)�_loopr �_pending�asyncio�Event� _try_send�Lock�_lock�_shutting_down�create_task�_send�_sender_task�_invoke_send_message�_invoke_send_message_task)�selfr s �S/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/client.py�create_sinkzSendToServerClient.create_sink2 s� � � � ��� �/�1�1�� � �������\�^�^�� �%�m�o�o��� �,�,�T�Z�Z�\�\�:�:���)-�)9�)9��%�%�'�'�* � * ��&�&�&� �returnNc � �x K � | j � � � t j | � � � | j � � � d{V �� nh# t j $ rV t � d| j � � | j � � � st | j � � � d{V �� Y nw xY w| j j dk rrt � d| j j � � | j � � � t � d| j � � � � � dS dS )a~ When shutdown begins it signals any in-flight HTTP sends to abort immediately (via _shutting_down event), then gives 50 seconds to finish the stop() sequence. If stop() isn't done in 50 seconds it force-cancels the sender task. Finally, any messages still in the buffer are flushed to persistent storage so nothing is lost. Nz5Timeout (%ds) sending messages to server on shutdown.r z&Save %s messages to persistent storagezStored queue %r)r# �setr �wait_for�stop�_SHUTDOWN_SEND_TIMEOUT�TimeoutError�logger�errorr&