| Server IP : 93.127.173.17 / Your IP : 216.73.216.199 Web Server : LiteSpeed System : Linux in-mum-web669.main-hosting.eu 5.14.0-503.23.2.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Feb 12 05:52:18 EST 2025 x86_64 User : u479334040 ( 479334040) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/alt/python27/lib/python2.7/site-packages/fluent/ |
Upload File : |
�
u�fc @ 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