Root Zanli
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
alt
/
python27
/
lib
/
python2.7
/
site-packages
/
fluent
/
Filename :
asyncsender.pyc
back
Copy
� ���fc @ 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"