File: //usr/lib/fm-agent/library/__pycache__/result_queue.cpython-39.pyc
a
��i� � @ 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< 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> �