⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.82
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
fm-agent
/
library
/
__pycache__
/
View File Name :
result_queue.cpython-39.pyc
a � �f� � @ s G d d� de �ZdS )c @ sT e Zd ZdZddd�Zdd� Zdd� Zdd d �Zd d � Zd d� Z dd� Z dd� Z dS )� ResultQueuez� If the aggregator can't be reached for some reason, we want to still keep calculating results and store them locally until we can reach the agg again.Nc C s6 g | _ || _| jd u r d| _|| _| jd u r2d| _d S )Ni�I i' )�data�queue_max_results�queue_batch_size)�selfr r � r �)/usr/lib/fm-agent/library/result_queue.py�__init__ s zResultQueue.__init__c C s | j �d� d S �N� �r �pop�r r r r r s zResultQueue.popc C s | j �� d S �Nr r r r r � pop_latest s zResultQueue.pop_latestc C sZ |d u r| j }t| j�|kr*| j}g | _n,t| j�| }| j|d � }| jd |� | _|S r )r �lenr )r �chunk�result�xr r r � pop_results s zResultQueue.pop_resultsc C s( t | j�| jkr| �� | j�|� d S r )r r r r �append)r r r r r �push* s zResultQueue.pushc C sb t |�t | j� | jkr&| j�|� n8| jt | j� }t |�| }| j|d � | _| j�|� d S r )r r r �extend)r �resultsZ free_spaceZremovalr r r �update/ s zResultQueue.updatec C s t | j�dkS r �r r r r r r �isEmpty9 s zResultQueue.isEmptyc C s t | j�S r r r r r r � queueLength< � zResultQueue.queueLength)NN)N) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r r r r s r N)�objectr r r r r �<module> r