�
d�bc@s�
dd
lZdd
l
Z
dd
lZdd
lZdd
ljjZdd
ljjZddl	m
Z

ddlmZm
Z

ddlmZ
ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZmZ
dd
lmZ
ejdej�ejdej�ejd
ej�gZdZ d�Z!def
d��YZ"def
d��YZ#def
d��YZ$def
d��YZ%def
d��YZ&def
d��YZ'def
d��YZ(d
S(i����N(
tget_dhcp_handler(tadd_periodictWALAEventOperation(
tustr(
tThreadHandlerInterface(
t
get_osutil(
tget_protocol_util(
t
StateArchiver(t
AGENT_NAMEtCURRENT_VERSION(
tPeriodicOperations^(.*)\.(\d+)\.(agentsManifest)$s^(.*)\.(\d+)\.(manifest\.xml)$s^(.*)\.(\d+)\.(xml)$i2c
Cst�S(
N(
t
EnvHandler(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pytget_env_handler/s
tRemovePersistentNetworkRulesc
BseZ
d�Zd
�ZRS(cCs)tt
|�jtj��

|
|_dS(
N(tsuperR
t__init__tconft&get_remove_persistent_net_rules_periodtosutil(tselfR((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR4s

c


Cs|jj
�
dS(
N(Rtremove_rules_files(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyt
_operation8s
(t__name__t
__module__RR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR
3s
	tMonitorDhcpClientRestartc
Bs#eZ
d�Zd
�Zd�ZRS(cCsTtt
|�jtj��

|
|_t�|_|jj�
t	|_
g|_dS(
N(RRRRt&get_monitor_dhcp_client_restart_periodRRtdhcp_handlertconf_routestTruetdhcp_warning_enabledtdhcp_id_list(RR((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR=s

	



	
c
s�t�j
�
d
kr(�j��_
dSt�f
d��j
D�
�
rKdS�j�}
t|
�
d
kr�|
�j
kr�tjd�

�jj�
|
�_
ndS(Nic
3s!|]}
�jj
|
�
V
qdS(
N(Rtcheck_pid_alive(t.0tpid(
R(s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pys	<genexpr>JssBEnvMonitor: Detected dhcp client restart. Restoring routing table.(tlenRt_get_dhcp_client_pidtalltloggertinfoRR(Rtnew_pid((
Rs:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyREs




!




c
Cs�g}
yDt|j
j��
}
t|
�
d
krI|jrItjd�

nWn5tk
r�
}
|jr�tjdt	|�
�
q�n
Xt|
�
d
k|_|
S(NisDhcp client is not running.s-Failed to get the PID of the DHCP client: {0}(
tsortedRtget_dhcp_pidR"RR%twarnt	ExceptionterrorR(RR!t	exception((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR#Ss



	
(RRRRR#(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR<s
		tCleanupGoalStateHistoryc
BseZ
d�Zd
�ZRS(c

Cs5tt
|�jtj��

ttj��
|_dS(
N(RR.RRt%get_goal_state_history_cleanup_periodRtget_lib_dirtarchiver(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRgs

c


Cs|jj
�
|jj�
d
S(sY
        Purge history and create a .zip of the history that has been preserved.
        N(R1tpurgetarchive(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRks

(RRRR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR.fs
	tEnableFirewallc
BseZ
d�Zd
�ZRS(cCs;tt
|�jtj��

|
|_||_t|_dS(
N(	RR4RRtget_enable_firewall_periodt_osutilt	_protocoltFalset _try_remove_legacy_firewall_rule(RRtprotocol((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRts

	
	
c
Cs�|js1|j
jd
|jj��

t|_n|j
jd
|jj�dtj��}
t	t
jtdt
dtjd|
dt�
dS(Ntdst_iptuidtversiontopt
is_successt	log_event(R9R6tremove_legacy_firewall_ruleR7tget_endpointRtenable_firewalltostgetuidR
R%t
EVERY_HOURRR	RtFirewallR8(Rtsuccess((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRzs	

*



	

(RRRR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR4ss
	tSetRootDeviceScsiTimeoutc
BseZ
d�Zd
�ZRS(cCs)tt
|�jtj��

|
|_dS(
N(RRIRRt#get_root_device_scsi_timeout_periodR6(RR((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s

c

Cs|jj
tj��

dS(
N(R6tset_scsi_disks_timeoutRtget_root_device_scsi_timeout(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s
(RRRR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRI�s
	tMonitorHostNameChangesc
BseZ
d�Zd
�ZRS(cCs;tt
|�jtj��

|
|_|jj�|_dS(
N(RRMRRtget_monitor_hostname_periodR6tget_hostname_recordt	_hostname(RR((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s

	
c
Csatj
�}
|
|jkr]tjd
|j|
�
|jj|
�

|jj|
�

|
|_ndS(Ns0EnvMonitor: Detected hostname change: {0} -> {1}(tsockettgethostnameRPR%R&R6tset_hostnametpublish_hostname(Rt
curr_hostname((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s


	




(RRRR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRM�s
	RcBsYeZ
dZd
Zed��
Zd�Zd�Zd�Zd�Z	d�Z
d�ZRS(	s�
    Monitor changes to dhcp and hostname.
    If dhcp client process re-start has occurred, reset routes, dhcp with fabric.

    Monitor scsi disk.
    If new scsi disk found, set timeout
    Rc
Cstj
S(
N(Rt_THREAD_NAME(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pytget_thread_name�sc

Cst|_
d|_d|_dS(
N(RtstoppedtNonethostnamet
env_thread(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s
	
	
c

CsG|js#t
jd
�

|j�
nt|_t
jd�

|j�
dS(Ns"Stop existing env monitor service.sStarting env monitor service.(RXR%R&tstopR8tstart(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pytrun�s
	



	


c


Cs
|jj
�S(
N(R[tis_alive(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR_�s
c

CsOtj
d
|j�
|_|jjt�

|jj|j��

|jj�
dS(Nttarget(	t	threadingtThreadtdaemonR[t	setDaemonRtsetNameRWR](
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR]�s



c
CsO
y
t�}
|
j
�}t�}t|�
t|�
t�g}tj�rd|jt	||��

ntj
�dk	r�|jt|�
�

ntj
�r�|jt|�
�

nxm|js
zOyx|D]}|j�
q�WWn)tk
r

}
tjd
t|�
�
n
XWdtj|�

Xq�WWn)tk
rJ

}
tjdt|�
�
n
XdS(Ns[An error occurred in the environment thread main loop; will skip the current iteration.
{0}sFAn error occurred in the environment thread; will exit the thread.
{0}(Rtget_protocolRR
RR.RRCtappendR4RLRYRItget_monitor_hostnameRMRXR^R+R%R,RR
tsleep_until_next_operation(Rt
protocol_utilR:Rtperiodic_operationsR>t
e((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyRc�s.
	

		
	














c

Cs,t|_
|jd
k	r(|jj�
nd
S(sO
        Stop server communication and join the thread to main thread.
        N(RRXR[RYtjoin(
R((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR\�s	

(RRt__doc__RVtstaticmethodRWRR^R_R]RcR\(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyR�s						 ()treRDRQRatazurelinuxagent.common.conftcommonRtazurelinuxagent.common.loggerR%tazurelinuxagent.common.dhcpRtazurelinuxagent.common.eventR
Rtazurelinuxagent.common.futureRt!azurelinuxagent.common.interfacesRtazurelinuxagent.common.osutilRt$azurelinuxagent.common.protocol.utilRt$azurelinuxagent.common.utils.archiveRtazurelinuxagent.common.versionRR	t%azurelinuxagent.ga.periodic_operationR
tcompilet
IGNORECASEtCACHE_PATTERNStMAXIMUM_CACHED_FILESRR
RR.R4RIRMR(((s:/usr/lib/python2.7/site-packages/azurelinuxagent/ga/env.pyt<module>s4













		*