EVOLUTION-NINJA
Edit File: result_queue.cpython-36.pyc
3 q��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 kr d| _|| _| 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