404Forbiden

✏️ Editing: result_queue.cpython-36.pyc

<+j�������������������@���s���G�d�d��de��ZdS�)c���������������@���sT���e�Zd�ZdZddd�Zdd��Zdd��Zdd	d
�Zdd��Zd
d��Z	dd��Z
dd��ZdS�)�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�krd|�_||�_|�jd�kr2d|�_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�jd��d�S�)N�����)r����pop)r���r���r���r���r
������s����zResultQueue.popc�������������C���s���|�j�j���d�S�)N)r���r
���)r���r���r���r����
pop_latest���s����zResultQueue.pop_latestc�������������C���sZ���|d�kr|�j�}t|�j�|kr*|�j}g�|�_n,t|�j�|�}|�j|d���}|�jd�|��|�_|S�)N)r����lenr���)r����chunk�result�xr���r���r����pop_results���s����zResultQueue.pop_resultsc�������������C���s(���t�|�j�|�jkr|�j���|�jj|��d�S�)N)r���r���r���r
����append)r���r���r���r���r����push*���s����zResultQueue.pushc�������������C���sb���t�|�t�|�j��|�jkr&|�jj|��n8|�jt�|�j��}t�|�|�}|�j|d���|�_|�jj|��d�S�)N)r���r���r����extend)r����resultsZ
free_spaceZremovalr���r���r����update/���s����zResultQueue.updatec�������������C���s���t�|�j�dkS�)Nr	���)r���r���)r���r���r���r����isEmpty9���s����zResultQueue.isEmptyc�������������C���s
���t�|�j�S�)N)r���r���)r���r���r���r����queueLength<���s����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>���s����

Sid Gifari From Gifari Industries - BD Cyber Security Team