�
d�bc@s�
dd
lZdd
l
Z
dd
lZdd
ljjZdd
ljjZdd
ljj	j
Z
ddlmZ
ddl
mZ
ddlmZ
ddlmZmZmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlm Z 
ddl!m"Z"
dd
l#m$Z$
ddl%m&Z&m'Z'
ddl(m)Z)
d�Z*de)f
d��YZ+de)f
d��YZ,de)f
d��YZ-de)f
d��YZ.de)f
d��YZ/de)f
d��YZ0def
d��YZ1d
S(i����N(
tCGroupConfigurator(
tCGroupsTelemetry(
t
ErrorState(t	add_eventtWALAEventOperationt
report_metric(
tustr(
tThreadHandlerInterface(
t
get_osutil(
t
HealthService(
tget_imds_client(
tget_protocol_util(
tIOErrorCounter(
thash_strings(t
AGENT_NAMEtCURRENT_VERSION(
tPeriodicOperationc
Cst�S(
N(
tMonitorHandler(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytget_monitor_handler)s
tPollResourceUsagec
Bs eZ
dZd
�Zd�ZRS(s�
    Periodic operation to poll the tracked cgroups for resource usage data.

    It also checks whether there are processes in the agent's cgroup that should not be there.
    c

Cs/tt
|�jtj��

tj�|_dS(
N(tsuperRt__init__tconftget_cgroup_check_periodtget_cgroup_log_metricst_PollResourceUsage__log_metrics(
tself((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR3s

c
Cs\tj
�}
x6|
D].}t|j|j|j|jd
|j�

qWtj	�j
|
�

dS(Nt	log_event(R
tpoll_all_trackedRtcategorytcountertinstancetvalueRRtget_instancet
check_cgroups(Rttracked_metricstmetric((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyt
_operation7s


,(t__name__t
__module__t__doc__RR%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR-s
	tResetPeriodicLogMessagesc
Bs eZ
dZd
�Zd�ZRS(s�
    Periodic operation to clean up the hash-tables maintained by the loggers. For reference, please check
    azurelinuxagent.common.logger.Logger and azurelinuxagent.common.event.EventLogger classes
    c

Cs&tt
|�jtjd
d�
�

dS(Nthoursi(RR)Rtdatetimet	timedelta(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyREs
c


Cstj
�
dS(
N(tloggertreset_periodic(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR%Hs
(R&R'R(RR%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR)@s
	tReportNetworkErrorsc
BseZ
d�Zd
�ZRS(c

Cs&tt
|�jtjd
d�
�

dS(Ntminutesi(RR/RR+R,(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyRMs
c
Cs�tj
�}
|
jd
�
}|
jd�
}|
jd�
}|dks]|dks]|dkr�dj|||�}tdtjd|�
ndS(Nt
hostplugintprotocoltotheris%hostplugin:{0};protocol:{1};other:{2}toptmessage(Rt
get_and_resettgettformatRRt
HttpErrors(Rt	io_errorsthostplugin_errorstprotocol_errorstother_errorstmsg((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR%Ps



$

(R&R'RR%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR/Ls
	t!ReportNetworkConfigurationChangesc
Bs)eZ
dZd
�Zd�Zd�ZRS(sO
    Periodic operation to check and log changes in network configuration.
    c

CsDtt
|�jtjd
d�
�

t�|_d|_i|_dS(NR0i
t(	RR?RR+R,Rtosutiltlast_route_table_hashtlast_nic_state(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR_s
"

	
c
	Cs

y�d
}
tj
j|
�
r�g}t|
�
�W}xM|D]E}|j|�

t|�
dkr7|jdjt|�
�
�

Pq7q7WWdQXtjd|
dj	|�
�
n|j
jdt�
}|dkr�tjd|�
nWn)t
k
r

}
tjdt|�
�
n
XdS(	Ns/proc/net/routeids<TRUNCATED TO {0} LINESsRouting table from {0}:
{1}R@t	as_stringsNetwork interfaces:
{0}s-Error fetching the network configuration: {0}(tostpathtexiststopentappendtlenR8R-tinfotjoinRAt
get_nic_statetTruet	ExceptiontwarnR(Rt
route_filetlinestfile_objecttlinetnetwork_interfacest	exception((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytlog_network_configurationes 

















c
Cs�|jj
�}
t|
�
}||jkrv||_|jj|
�
}tjd
jdjt	t
jj|��
�
�

n|jj
�}||jkr�|jikr�dnd}tjdj|djt	t|j���
��

||_ndS(NsRoute table: [{0}]t
,tInitialtUpdateds{0} NIC state: [{1}]s, (RAtread_route_tableR
RBtget_list_of_routesR-RKR8RLtmaptnetworkutilt
RouteEntrytto_jsonRMRCtstrtvalues(Rtraw_route_listtdigestt
route_listt	nic_statetdescription((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR%ws



	

1


1
(R&R'R(RRWR%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR?[s
		tSendHostPluginHeartbeatcBsDeZ
dZd
�Zejdd�
Zejdd�
Zd�ZRS(s�
    Periodic operation for reporting the HostGAPlugin's health. The signal is 'Healthy' when we have been able to communicate with
    plugin at least once in the last _HOST_PLUGIN_HEALTH_PERIOD.
    cCsDtt
|�jt
j�

|
|_||_td
t
j�
|_dS(Nt
min_timedelta(	RRhRt_HOST_PLUGIN_HEARTBEAT_PERIODR2thealth_serviceRt_HOST_PLUGIN_HEALTH_PERIODthost_plugin_error_state(RR2Rk((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR�s

	
	
R0i
ic

Cs7
y�|jj
j�}
|
j�
|jj�
|
j�}|rN|jj�
n
|jj�
|jj	�t
k}tjd
|�
|j
j|�

|s�tdtdtdtjdt
ddj|jj�
dt
�
nWnYtk
r2

}
d	jt|�
�
}tdtdtdtjdt
d|dt
�
�n
XdS(
NsHostGAPlugin health: {0}tnametversionR4t
is_successR5s{0} since successful heartbeatRs,Exception sending host plugin heartbeat: {0}(R2tclienttget_host_plugintensure_initializedt"update_host_plugin_from_goal_statet
get_healthRmtresettincrtis_triggeredtFalseR-tverboseRktreport_host_plugin_heartbeatRRRRtHostPluginHeartbeatExtendedR8t	fail_timeRORtHostPluginHeartbeat(Rthost_plugintis_currently_healthyt
is_healthyt
eR>((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR%�s:












	







	



(	R&R'R(RR+R,RjRlR%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyRh�s

	
tSendImdsHeartbeatcBsDeZ
dZd
�Zejdd�
Zejdd�
Zd�ZRS(s�
    Periodic operation to report the IDMS's health. The signal is 'Healthy' when we have successfully called and validated
    a response in the last _IMDS_HEALTH_PERIOD.
    cCsPtt
|�jt
j�

||_t|
j��
|_td
t
j	�
|_
dS(NRi(RR�Rt_IMDS_HEARTBEAT_PERIODRkR
tget_wireserver_endpointtimds_clientRt_IMDS_HEALTH_PERIODtimds_error_state(Rt
protocol_utilRk((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR�s

	

R0i
ic

Cs�yw|jj
�\}
}|
r.|jj�
n
|jj�
|jj�tk}tjd
||�
|j	j
||�
WnYtk
r�
}
djt
|�
�
}tdtdtdtjdtd|dt�
�n
XdS(	NsIMDS health: {0} [{1}]s%Exception sending imds heartbeat: {0}RnRoR4RpR5R(R�tvalidateR�RvRwRxRyR-RzRktreport_imds_statusROR8RRRRRt
ImdsHeartbeat(RR�tresponseR�R�R>((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR%�s$









	



(	R&R'R(RR+R,R�R�R%(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR��s

	
RcBseeZ
dZed
��
Zd�Zd�Zd�Zd�Zd�Z	d�Z
d�Zd	�ZRS(
Rc
Cstj
S(
N(Rt_THREAD_NAME(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytget_thread_name�sc

Csd|_
t|_dS(
N(tNonetmonitor_threadRNt
should_run(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR�s
	
c


Cs|j�
dS(
N(
tstart(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytrun�s
c

Cs&t|_
|j�r"|j�
ndS(
N(RyR�tis_aliveRL(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytstop�s
	

c


Cs|jj
�
dS(
N(R�RL(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyRL�s
c


Cs|jS(
N(
R�(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pytstopped�s
c

Cs|jdk	o|jj�S(
N(R�R�R�(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR��s
c

CsOtj
d
|j�
|_|jjt�

|jj|j��

|jj�
dS(Nttarget(	t	threadingtThreadtdaemonR�t	setDaemonRNtsetNameR�R�(
R((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR��s



c
Cs

y�t�}
|
j
�}t|j��
}t�t�t�t||�t|
|�g}t	�}t
j�r|j|�

nt
jd
�

|j�
x@|j�s�zx|D]}|j�
q�WWdtj|�

Xq�WWn)tk
r

}
t
jdt|�
�
n
XdS(Ns0Monitor.NetworkConfigurationChanges is disabled.sBAn error occurred in the monitor thread; will exit the thread.
{0}(Rtget_protocolR	tget_endpointR)R/RRhR�R?Rt)get_monitor_network_configuration_changesRIR-RKRWR�R�Rtsleep_until_next_operationROterrorR(RR�R2Rktperiodic_operationst$report_network_configuration_changesR4R�((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR�
s*
	





	










(
R&R'R�tstaticmethodR�RR�R�RLR�R�R�R�(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyR�s
							(2R+RER�tazurelinuxagent.common.conftcommonRtazurelinuxagent.common.loggerR-t(azurelinuxagent.common.utils.networkutiltutilsR^t)azurelinuxagent.common.cgroupconfiguratorRt'azurelinuxagent.common.cgroupstelemetryR
t!azurelinuxagent.common.errorstateRtazurelinuxagent.common.eventRRRtazurelinuxagent.common.futureRt!azurelinuxagent.common.interfacesRtazurelinuxagent.common.osutilRt-azurelinuxagent.common.protocol.healthserviceR	t$azurelinuxagent.common.protocol.imdsR
t$azurelinuxagent.common.protocol.utilRt%azurelinuxagent.common.utils.restutilRt%azurelinuxagent.common.utils.textutilR
tazurelinuxagent.common.versionRRt%azurelinuxagent.ga.periodic_operationRRRR)R/R?RhR�R(((s>/usr/lib/python2.7/site-packages/azurelinuxagent/ga/monitor.pyt<module>s6

















	+5(