File: //opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyc
�
c�ec @ s� d d l m Z d d l Z y d d l m Z m Z m Z Wn- e k
rk d d l m Z m Z m Z n Xd d l m Z d d l
m Z d d g Z d Z
e Z e � Z d a d � Z d
� Z d � Z d � Z d e j f d
� � YZ d S( i����( t print_functionN( t Queuet Fullt Empty( t sender( t EventTimeR t FluentSenderid c C s
| a d S( s: [For testing] Function to set global sender directly
N( t _global_sender( R ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt _set_global_sender s c K s t | | � a d S( N( R R ( t tagt kwargs( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt setup s c C s t S( N( R ( ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt get_global_sender% s c C s t � j � d S( N( R t close( ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR
) s c B s� e Z d d d d e d e d e e d �
Z e d � Z e d � � Z
e d � � Z e d � � Z d
� Z
d � Z d � Z RS( t localhosti�^ i i g @c
K s� t t | � j d | d | d | d | d | d | d | d | d | | � |
| _ | | _ t j � | _ t | _ t
d
|
� | _ t j d | j
d d
t | � � | _ t | j _ | j j � d S( s~
:param kwargs: This kwargs argument is not used in __init__. This will be removed in the next major version.
R t hostt portt bufmaxt timeoutt verboset buffer_overflow_handlert nanosecond_precisiont msgpack_kwargst maxsizet targett names AsyncFluentSender %dN( t superR t __init__t _queue_maxsizet _queue_circulart threadingt Eventt
_thread_guardt Falset _closedR t _queuet Threadt
_send_loopt idt _send_threadt Truet daemont start(
t selfR R R R R R R R R t
queue_maxsizet queue_circularR
( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR . s 0 c C s� | j �z | j r d St | _ | sb x9 t r^ y | j j d t � Wq) t k
rZ Pq) Xq) Wn | j j t � | j j
� Wd QXd S( Nt block( t lockR" R( R# t getR! R t putt
_TOMBSTONER' t join( R+ t flush( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR
O s
c C s | j S( N( R ( R+ ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR, ] s c C s | j S( N( R ( R+ ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt queue_blockinga s c C s | j S( N( R ( R+ ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR- e s c C s� | j �� | j r t S| j r] | j j � r] y | j j d t � Wq] t k
rY q] Xn y | j j | d | j �Wn t k
r� t SXt
SWd QXd S( NR. ( R/ R" R! R R# t fullR0 R R1 R R( ( R+ t bytes_( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt _sendi s
c C sd t t | � j } z@ x9 t rP | j j d t � } | t k rC Pn | | � q WWd | j � Xd S( NR. ( R R t _send_internalR( R# R0 R2 t _close( R+ t
send_internalR7 ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR% z s c C s | j � d S( N( R
( R+ t exc_typet exc_valt exc_tb( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt __exit__� s i i N( t __name__t
__module__R! t Nonet DEFAULT_QUEUE_MAXSIZEt DEFAULT_QUEUE_CIRCULARR R( R
t propertyR, R5 R- R8 R% R? ( ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyR - s"
( t
__future__R R t queueR R R t ImportErrort fluentR t
fluent.senderR t __all__RC R! RD t objectR2 RB R R R R R
R ( ( ( sC /opt/alt/python27/lib/python2.7/site-packages/fluent/asyncsender.pyt <module> s"