File: //opt/alt/python37/lib/python3.7/site-packages/fluent/__pycache__/asyncsender.cpython-37.pyc
B
��fZ � @ s� d dl Z d dlmZmZmZ d dlmZ d dlmZ ddgZ dZ
dZ e � Z
dad d
� Zd d � Zd
d� Zdd� ZG dd� dej�ZdS )� N)�Empty�Full�Queue)�sender)� EventTimer � FluentSender�d Fc C s | a dS )z4[For testing] Function to set global sender directlyN)�_global_sender)r � r
�C/opt/alt/python37/lib/python3.7/site-packages/fluent/asyncsender.py�_set_global_sender s r c K s t | f|�ad S )N)r r )�tag�kwargsr
r
r �setup s r c C s t S )N)r r
r
r
r �get_global_sender s r c C s t � �� d S )N)r �closer
r
r
r r s r c s� e Zd Zddddddddeedf � fdd� Zdd
d �Zed d
� �Zedd� �Z edd� �Z
dd� Z � fdd�Z dd� Z
dd� Z� ZS )r � localhosti�^ i g @FNc
s� t � jf ||||||||| d� |
�� |
| _| | _| rB| rB| | _n| j| _t�� | _d| _ t
|
d�| _ tj | j
dt| � d�| _d| j_| j�� dS )z~
:param kwargs: This kwargs argument is not used in __init__. This will be removed in the next major version.
) r
�host�port�bufmax�timeout�verbose�buffer_overflow_handler�nanosecond_precision�msgpack_kwargsF)�maxsizezAsyncFluentSender %d)�target�nameTN)�super�__init__�_queue_maxsize�_queue_circular�_queue_overflow_handler� _queue_overflow_handler_default� threading�EventZ
_thread_guard�_closedr �_queue�Thread�
_send_loop�id� _send_thread�daemon�start)�selfr
r r r r r r r r �
queue_maxsize�queue_circularZqueue_overflow_handlerr )� __class__r
r r % s.
zFluentSender.__init__Tc C sp | j �` | jrd S d| _|sLx.y| jjdd� W q tk
rF P Y q X q W | j�t� | j�� W d Q R X d S )NTF)�block) �lockr& r' �getr �put�
_TOMBSTONEr+ �join)r. �flushr
r
r r W s zFluentSender.closec C s | j S )N)r )r. r
r
r r/ e s zFluentSender.queue_maxsizec C s | j S )N)r! )r. r
r
r �queue_blockingi s zFluentSender.queue_blockingc C s | j S )N)r! )r. r
r
r r0 m s zFluentSender.queue_circularc C s� | j �� | jrdS | jrT| j�� rTy| jjdd�}W n tk
rH Y n X | �|� y| jj|| j d� W n t k
r� dS X dS Q R X d S )NF)r2 T)
r3 r& r! r' �fullr4 r r" r5 r )r. �bytes_�discarded_bytesr
r
r �_sendq s
zFluentSender._sendc sB t � j}z*x$| jjdd�}|tkr$P ||� q W W d | �� X d S )NT)r2 )r Z_send_internalr' r4 r6 �_close)r. Z
send_internalr; )r1 r
r r) � s zFluentSender._send_loopc C s d S )Nr
)r. r< r
r
r r# � s z,FluentSender._queue_overflow_handler_defaultc C s | � � d S )N)r )r. �exc_type�exc_val�exc_tbr
r
r �__exit__� s zFluentSender.__exit__)T)�__name__�
__module__� __qualname__�DEFAULT_QUEUE_MAXSIZE�DEFAULT_QUEUE_CIRCULARr r �propertyr/ r9 r0 r= r) r# rB �
__classcell__r
r
)r1 r r $ s& %
)r$ �queuer r r Zfluentr Z
fluent.senderr �__all__rF rG �objectr6 r r r r r r r
r
r
r �<module> s