�
d�bc@sdZd
dl
Z
d
dlmZmZ
d
dlmZ
d
dlmZ
edd�
Zedd	�
Z	edd
�
Z
edd�
Zedd�
Zedd
�
Z
edd�
Zdef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZe�Zdef
d��YZdef
d��YZejdd�Zd�Zd �Zd!�Zd"�Zd#�Z d$�Z!d%�Z"d&�Z#d'�Z$d(�Z%d)�Z&d*�Z'd+�Z(ejdd,�Z)dS(-s
Log utils
i����N(tdatetimet	timedelta(
t
currentThread(
tustrtdaysi
thoursiitminutesiitLoggercBs�eZ
dZd
Zddd�Zd�Zd�Zd�Zd�Z	d�Z
d�Zd	�Zd
�Z
d�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(s
    Logger class
    u%Y-%m-%dT%H:%M:%S.%fZcCs:g|_|
dkr|n|
|_i|_||_dS(
N(t	appenderstNonetloggertperiodic_messagestprefix(tselfR
R((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt__init__+s
	

	
c

Csi|j_
dS(
N(R
R(
R
((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytreset_periodic1s
cCs
|
|_dS(
N(
R(R
R((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt
set_prefix4s
cCs0||jj
kp/|jj
||
tj�k
S(
N(R
RRtnow(R
tdeltat
h((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt_is_period_elapsed7s

cGsHt|�
}|j
|
|�rD|||�

tj�|jj|<ndS(
N(thashRRRR
R(R
Rtlog_level_opt
msg_formattargsR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt	_periodic;s




cGs|j|
|j
||�
dS(
N(Rtinfo(R
RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt
periodic_infoAs
cGs|j|
|j
||�
dS(
N(Rtverbose(R
RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytperiodic_verboseDs
cGs|j|
|j
||�
dS(
N(Rtwarn(R
RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt
periodic_warnGs
cGs|j|
|j
||�
dS(
N(Rterror(R
RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytperiodic_errorJs
cGs|jt
j|
|�
dS(
N(tlogtLogLeveltVERBOSE(R
RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRMs
cGs|jt
j|
|�
dS(
N(R"R#tINFO(R
RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRPs
cGs|jt
j|
|�
dS(
N(R"R#tWARNING(R
RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRSs
cGs|jt
j|
|�
dS(
N(R"R#tERROR(R
RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR Vs
c
s^
��
fd
�}t|�
t
k	r9t
|dd�

}nt|�
dkr]|j|�}n|}tj�jtj�
}t	j
�}t�j�}|j
dk	r�dj||||j
|��
ndj||||��
t
�
jdd�dd�

�
x!|jD]}	|	j��
�
q
W|j|krZ
x'|jjD]}	|	j��
�
q=
WndS(	Nc

s:|js6zt
|_|j��
�
Wd
t|_Xnd
S(sA
            The appender_lock flag is used to signal if the logger is currently in use. This prevents a subsequent log
            coming in due to writing of a log statement to be not written.

            Eg:
            Assuming a logger with two appenders - FileAppender and TelemetryAppender. Here is an example of
            how using appender_lock flag can help.

            logger.warn("foo")
                |- log.warn() (azurelinuxagent.common.logger.Logger.warn)
                    |- log() (azurelinuxagent.common.logger.Logger.log)
                        |- FileAppender.appender_lock is currently False not log_appender.appender_lock is True
                            |- We sets it to True.
                        |- FileAppender.write completes.
                        |- FileAppender.appender_lock sets to False.
                        |- TelemetryAppender.appender_lock is currently False not log_appender.appender_lock is True
                            |- We sets it to True.
                    [A] |- TelemetryAppender.write gets called but has an error and writes a log.warn("bar")
                            |- log() (azurelinuxagent.common.logger.Logger.log)
                            |- FileAppender.appender_lock is set to True (log_appender.appender_lock was false when entering).
                            |- FileAppender.write completes.
                            |- FileAppender.appender_lock sets to False.
                            |- TelemetryAppender.appender_lock is already True, not log_appender.appender_lock is False
                            Thus [A] cannot happen again if TelemetryAppender.write is not getting called. It prevents
                            faulty appenders to not get called again and again.

            :param log_appender: Appender
            :return: None
            N(t
appender_locktTruetwritetFalse(
tlog_appender(tleveltlog_item(sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt	write_logZs
	

	
terrorstbackslashreplaceiu{0} {1} {2} {3} {4}
u{0} {1} {2} {3}
tasciitencoding(ttypeRtlentformatRtutcnowtstrftimeRtLogTimeFormatInUTCR#tSTRINGSRtgetNameRR	tencodeRR*R
(
R
R-RRR/tmsgttimet	level_strtthread_nametappender((R-R.sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR"Ys&
&








!
	


cCs&t|
||�}|j
j|�

dS(
N(t_create_logger_appenderRtappend(R
t
appender_typeR-tpathRA((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytadd_appender�s

c

Cstd
�|j
D�
�
S(se
        Returns True if the current list of appenders includes at least one ConsoleAppender
        c
ss|]}
t|
t
�V
qdS(
N(t
isinstancetConsoleAppender(t.0RA((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pys	<genexpr>�s(tanyR(
R
((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytconsole_output_enabled�sc
Cs2g|jD]}
t
|
t�s
|
^q
|_d
S(sQ
        Removes all ConsoleAppenders from the current list of appenders
        N(RRGRH(R
RA((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytdisable_console_output�sN(t__name__t
__module__t__doc__R9R	RRRRRRRRR!RRRR R"RFRKRL(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR#s&													K		tAppenderc
BseZ
d�Zd
�ZRS(cCst|_
|
|_dS(
N(R+R(R-(R
R-((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR�s
	
c
CsdS(
N((R
R-R=((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR*�s
(RMRNRR*(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRP�s
	RHc
BseZ
d�Zd
�ZRS(cCs#tt
|�j|
�

||_dS(
N(tsuperRHRRE(R
R-RE((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR�s

cCsV|j|
k
rRy,t
|jd
��}|j|�

WdQXWqRtk
rN


qRXndS(Nt
w(R-topenRER*tIOError(R
R-R=tconsole((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR*�s






(RMRNRR*(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRH�s
	tFileAppenderc
BseZ
d�Zd
�ZRS(cCs#tt
|�j|
�

||_dS(
N(RQRVRRE(R
R-RE((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR�s

cCsV|j|
k
rRy,t
|jd
��}|j|�

WdQXWqRtk
rN


qRXndS(Nsa+(R-RSRER*RT(R
R-R=tlog_file((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR*�s






(RMRNRR*(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRV�s
	tStdoutAppenderc
BseZ
d�Zd
�ZRS(cCstt
|�j|
�

dS(
N(RQRXR(R
R-((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR�s
cCs>|j|
k
r:yt
jj|�

Wq:tk
r6


q:XndS(
N(R-tsyststdoutR*RT(R
R-R=((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR*�s






(RMRNRR*(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRX�s
	tTelemetryAppenderc
BseZ
d�Zd
�ZRS(cCs#tt
|�j|
�

||_dS(
N(RQR[Rt
event_func(R
R-R\((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR�s

cCs>|j|
k
r:y|j
|
|�
Wq:tk
r6


q:XndS(
N(R-R\RT(R
R-R=((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR*�s






(RMRNRR*(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR[�s
	R#cBs2eZ
dZd
ZdZdZddddgZRS(ii
iiR$R%R&R'(RMRNR$R%R&R'R:(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR#�s






tAppenderTypec
Bs eZ
dZd
ZdZdZRS(ii
ii(RMRNtFILEtCONSOLEtSTDOUTt	TELEMETRY(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR]
s



cCstj
||
|�
dS(
N(tDEFAULT_LOGGERRF(RDR-RE((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pytadd_logger_appender
s
c
Cs
tj
�S(
N(RbRK(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRK
s
c
Cstj
�
dS(
N(RbRL(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRL
s
c
Cstj
�
dS(
N(RbR(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR
s
c

Cstj
|�

dS(
N(RbR(
R((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR
s
cGstj
||
|�
d
S(s�
    The hash-map maintaining the state of the logs gets reset here -
    azurelinuxagent.ga.monitor.MonitorHandler.reset_loggers. The current time period is defined by RESET_LOGGERS_PERIOD.
    N(RbR(RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR
scGstj
||
|�
d
S(s�
    The hash-map maintaining the state of the logs gets reset here -
    azurelinuxagent.ga.monitor.MonitorHandler.reset_loggers. The current time period is defined by RESET_LOGGERS_PERIOD.
    N(RbR(RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR'
scGstj
||
|�
d
S(s�
    The hash-map maintaining the state of the logs gets reset here -
    azurelinuxagent.ga.monitor.MonitorHandler.reset_loggers. The current time period is defined by RESET_LOGGERS_PERIOD.
    N(RbR!(RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR!/
scGstj
||
|�
d
S(s�
    The hash-map maintaining the state of the logs gets reset here -
    azurelinuxagent.ga.monitor.MonitorHandler.reset_loggers. The current time period is defined by RESET_LOGGERS_PERIOD.
    N(RbR(RRR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR7
sc
Gstj
||
�

dS(
N(RbR(RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR?
s
c
Gstj
||
�

dS(
N(RbR(RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRC
s
c
Gstj
||
�

dS(
N(RbR(RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRG
s
c
Gstj
||
�

dS(
N(RbR (RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR K
s
cGstj
||
|�
dS(
N(RbR"(R-RR((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyR"O
s
cCs}|tj
krt|
|�S|tjkr8t|
|�S|tjkrQt|
�
S|tjkrmt|
|�St	d
�
�
dS(NsUnknown appender type(
R]R_RHR^RVR`RXRaR[t
ValueError(RDR-RE((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyRBS
s











(*RORYRR
t	threadingRtazurelinuxagent.common.futureRt	EVERY_DAYtEVERY_HALF_DAYtEVERY_SIX_HOURSt
EVERY_HOURtEVERY_HALF_HOURtEVERY_FIFTEEN_MINUTEStEVERY_MINUTEtobjectRRPRHRVRXR[RbR#R]R%R	RcRKRLRRRRR!RRRRR R"RB(((sA/usr/lib/python2.7/site-packages/azurelinuxagent/common/logger.pyt<module>sF








�