/
opt
/
alt
/
python27
/
lib
/
python2.7
/
site-packages
/
fluent
/
up file
home
� { vhc @ s� d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d a d � Z d � Z d � Z d � Z d e j f d � � YZ d e f d � � YZ d S( i����( t print_functionNc C s | a d S( s: [For testing] Function to set global sender directly N( t _global_sender( t sender( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt _set_global_sender s c K s t | | � a d S( N( t FluentSenderR ( t tagt kwargs( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt setup s c C s t S( N( R ( ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt get_global_sender s c C s t � j � d S( N( R t close( ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR ! s t EventTimec B s e Z d � Z RS( c C sQ t | � } t | d d � } t t | � j | d d d t j d | | � �S( Ni i i t codei t datas >IIi ʚ;( t intt superR t __new__t structt pack( t clst timestampt secondst nanoseconds( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR & s ( t __name__t __module__R ( ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR % s R c B s� e Z d d d d e d e d d � Z d � Z d � Z e d � � Z e j d � � Z d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( t localhosti�^ i i g @c K s� | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | d k rZ i n | | _ d | _ d | _ t j � | _ t | _ t j � | _ d S( s~ :param kwargs: This kwargs argument is not used in __init__. This will be removed in the next major version. N( R t hostt portt bufmaxt timeoutt verboset buffer_overflow_handlert nanosecond_precisiont Nonet msgpack_kwargst sockett pendingst threadingt Lockt lockt Falset _closedt localt _last_error_threadlocal( t selfR R R R R R R R R! R ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt __init__1 s c C sC | j r t t j � � } n t t j � � } | j | | | � S( N( R R t timeR t emit_with_time( R+ t labelR t cur_time( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt emitO s c C s� | j r' t | t � r' t | � } n y | j | | | � } WnL t k r� } | | _ | j | | i d d 6d d 6t j � d 6� } n X| j | � S( Nt CRITICALt levels Can't output to logt messaget traceback( R t isinstancet floatR t _make_packett Exceptiont last_errorR5 t format_exct _send( R+ R/ R R t bytes_t e( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR. V s c C s t | j d d � S( Nt exception( t getattrR* R ( R+ ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR: c s c C s | | j _ d S( N( R* R? ( R+ t err( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR: g s c C s) t | j d � r% t | j d � n d S( NR? ( t hasattrR* t delattr( R+ t _thread_id( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt clear_last_errork s c C s� | j �r | j r d St | _ | j rd y | j | j � Wqd t k r` | j | j � qd Xn | j � d | _ Wd QXd S( N( R& R( t TrueR# t _send_dataR9 t _call_buffer_overflow_handlert _closeR ( R+ ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR o s c C sb | r! d j | j | f � } n | j } | | | f } | j rO t | � n t j | | j � S( Nt .( t joinR R t printt msgpackt packbR! ( R+ R/ R R R t packet( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR8 } s c C s. | j � | j r t S| j | � SWd QXd S( N( R& R( R' t _send_internal( R+ R= ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR< � s c C s� | j r$ | j | 7_ | j } n y | j | � d | _ t SWnp t j k r� } | | _ | j � | j r� t | j � | j k r� | j | j � d | _ n | | _ t SXd S( N( R# RG R RF R" t errorR: RI t lenR RH R' ( R+ R= R> ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyRP � s ! c C s� z� | j j d � y | j j d � } Wn/ t j k rZ } | j t j k rV � n d SX| d k r t j t j d � � n Wd | j j | j � Xd S( Ng i t s Broken pipe( R" t settimeoutt recvRQ t errnot EWOULDBLOCKt EPIPER ( R+ t recvdt recv_e( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt _check_recv_side� s c C s� | j � t | � } d } | j � xT | | k r| | j j | | � } | d k ro t j t j d � � n | | 7} q) W| j � d S( Ni s Broken pipe( t _reconnectRR R[ R" t sendRQ RV RX ( R+ R= t bytes_to_sendt bytes_sentt sent( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyRG � s c C s | j sy� | j j d � rc t j t j t j � } | j | j � | j | j t d � � nZ t j t j t j � } | j | j � | j t j t j d � | j | j | j f � Wn; t k r� } y | j � Wn t k r� n X| � qX| | _ n d S( Ns unix://i ( R" R t startswitht AF_UNIXt SOCK_STREAMRT R t connectRR t AF_INETt setsockoptt IPPROTO_TCPt TCP_NODELAYR R9 R ( R+ t sockR> ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR\ � s" c C s7 y | j r | j | � n Wn t k r2 } n Xd S( N( R R9 ( R+ t pending_eventsR> ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyRH � s c C s zn | j } | rm z/ y | j t j � Wn t j k r? n XWd y | j � Wn t j k rh n XXn Wd d | _ Xd S( N( R" t shutdownt SHUT_RDWRRQ R R ( R+ Ri ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyRI � s c C s | S( N( ( R+ ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt __enter__� s c C s1 y | j � Wn t k r, } | | _ n Xd S( N( R R9 R: ( R+ t typt valueR5 R> ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt __exit__� s i i N( R R R' R R, R1 R. t propertyR: t setterRE R R8 R< RP R[ RG R\ RH RI Rm Rp ( ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyR 0 s0 ( t __future__R RV R" R R$ R- R5 RM R R R R R R t ExtTypeR t objectR ( ( ( s> /opt/alt/python27/lib/python2.7/site-packages/fluent/sender.pyt <module> s