File: //opt/alt/python37/lib/python3.7/site-packages/fluent/__pycache__/sender.cpython-37.pyc
B
��f� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZdadd� Zdd� Z dd� Z
dd � Z G d
d � d ej �Z
G d d
� d
�ZdS )� Nc C s | a dS )z4[For testing] Function to set global sender directlyN)�_global_sender)Zsender� r �>/opt/alt/python37/lib/python3.7/site-packages/fluent/sender.py�_set_global_sender
s r c K s t | f|�ad S )N)� FluentSenderr )�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 Zd� fdd� Zedd� �Z� ZS )� EventTimeNc s< t |�}|d kr t |d d �}t� j| dt�d||�d�S )N� i ʚ;r z>II)�code�data)�int�super�__new__�struct�pack)�cls� timestamp� nanoseconds�seconds)� __class__r r r ! s zEventTime.__new__c C s t |d�\}}| ||�S )Ni ʚ;)�divmod)r Z unix_nanor Znanosr r r �from_unix_nano+ s zEventTime.from_unix_nano)N)�__name__�
__module__� __qualname__r � classmethodr �
__classcell__r r )r r r s
r c @ s� e Zd Zd*dd�d d
�Zd d � Zd
d� Zedd� �Zejdd� �Zd+dd�Z dd� Z
dd� Z dd� Z dd� Z
d d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� ZdS ),r � localhost�^ � � @FNT)�forward_packet_errorc
K sr || _ || _|| _|| _|| _|| _|| _|| _|
| _| dkrBi n| | _ d| _
d| _ t �
� | _d| _t �� | _dS )z~
:param kwargs: This kwargs argument is not used in __init__. This will be removed in the next major version.
NF)r �host�port�bufmax�timeout�verbose�buffer_overflow_handler�nanosecond_precisionr% �msgpack_kwargs�socket�pendings� threading�Lock�lock�_closed�local�_last_error_threadlocal) �selfr r& r' r( r) r* r+ r, r- r% r r r r �__init__2 s
zFluentSender.__init__c C s0 | j rt�t�� �}n tt�� �}| �|||�S )N)r, r r �time�time_nsr �emit_with_time)r6 �labelr Zcur_timer r r �emitU s zFluentSender.emitc C sh y| � |||�}W nJ tk
r\ } z,| js,� || _| � ||ddt�� d��}W d d }~X Y nX | �|�S )N�CRITICALzCan't output to log)�level�message� traceback)� _make_packet� Exceptionr% �
last_errorr@ �
format_exc�_send)r6 r; r r �bytes_�er r r r: \ s zFluentSender.emit_with_timec C s t | jdd �S )N� exception)�getattrr5 )r6 r r r rC n s zFluentSender.last_errorc C s || j _d S )N)r5 rH )r6 �errr r r rC r s c C s t | jd�rt| jd� d S )NrH )�hasattrr5 �delattr)r6 Z
_thread_idr r r �clear_last_errorv s z FluentSender.clear_last_errorc C sl | j �\ | jrd S d| _| jrPy| �| j� W n tk
rN | �| j� Y nX | �� d | _W d Q R X d S )NT)r2 r3 r/ �
_send_datarB � _call_buffer_overflow_handler�_close)r6 r r r r z s zFluentSender.closec C sf |r | j r| j � d|� �n|}n| j }| jr>t|t�r>t|�}|||f}| jrVt|� tj|f| j �S )N�.)
r r, �
isinstance�floatr r* �print�msgpack�packbr- )r6 r; r r r �packetr r r rA � s
zFluentSender._make_packetc C s& | j � | jrdS | �|�S Q R X d S )NF)r2 r3 �_send_internal)r6 rF r r r rE � s zFluentSender._sendc
C s� | j r| j |7 _ | j }y| �|� d | _ dS tk
r� } zB|| _| �� | j rxt| j �| jkrx| �| j � d | _ n|| _ dS d }~X Y nX d S )NTF)r/ rN �OSErrorrC rP �lenr( rO )r6 rF rG r r r rX � s
zFluentSender._send_internalc
C s| zf| j �d� y| j �d�}W n0 tk
rN } z|jtjkr>� d S d }~X Y nX |dkrdttjd��W d | j �| j� X d S )Ng i � z Broken pipe)r. �
settimeout�recvrY �errno� EWOULDBLOCK�EPIPEr) )r6 ZrecvdZrecv_er r r �_check_recv_side� s z FluentSender._check_recv_sidec C sf | � � t|�}d}| �� x<||k rX| j�||d � �}|dkrNttjd��||7 }q W | �� d S )Nr z Broken pipe)�
_reconnectrZ ra r. �sendrY r^ r` )r6 rF Z
bytes_to_sendZ
bytes_sent�sentr r r rN � s
zFluentSender._send_datac C s� | j s�y�| j�d�rJt � t jt j�}|�| j� |�| jtd�d � � n@t � t j t j�}|�| j� |�
t j t j d� |�| j| j
f� W nH tk
r� } z*y |�� W n tk
r� Y nX |�W d d }~X Y nX || _ d S )Nzunix://r
)r. r& �
startswith�AF_UNIX� SOCK_STREAMr\ r) �connectrZ �AF_INET�
setsockopt� IPPROTO_TCP� TCP_NODELAYr' rB r )r6 �sockrG r r r rb � s" zFluentSender._reconnectc C s. y| j r| � |� W n tk
r( Y nX d S )N)r+ rB )r6 Zpending_eventsr r r rO � s
z*FluentSender._call_buffer_overflow_handlerc C sl z^| j }|r\z*y|�t j� W n tk
r2 Y nX W d y |�� W n tk
rX Y nX X W d d | _ X d S )N)r. �shutdown� SHUT_RDWRrY r )r6 rm r r r rP � s
zFluentSender._closec C s | S )Nr )r6 r r r � __enter__ s zFluentSender.__enter__c
C s: y | � � W n( tk
r4 } z
|| _W d d }~X Y nX d S )N)r rB rC )r6 �typ�valuer@ rG r r r �__exit__ s zFluentSender.__exit__)r! r" r# r$ FNFN)N)r r r r7 r< r: �propertyrC �setterrM r rA rE rX ra rN rb rO rP rp rs r r r r r 1 s2
r )r^ r. r r0 r8 r@ rU r r r r
r �ExtTyper r r r r r �<module> s