p f<&ddlZddlZddlZddlZddlmcmZddlmcmZddl m Z ddl m Z m Z mZddlmZddlmZddlmZddlmZddlmZmZdd lmZej8d ej:ej8d ej:ej8d ej:gZd ZdZ GddeZ!GddeZ"GddeZ#GddeZ$GddeZ%GddeZ&GddeZ'y)N)get_dhcp_handler) add_periodicWALAEventOperation add_event)ustr)ThreadHandlerInterface) get_osutil)get_protocol_util) AGENT_NAMECURRENT_VERSION)PeriodicOperationz^(.*)\.(\d+)\.(agentsManifest)$z^(.*)\.(\d+)\.(manifest\.xml)$z^(.*)\.(\d+)\.(xml)$2ctSN) EnvHandler8/usr/lib/python3/dist-packages/azurelinuxagent/ga/env.pyget_env_handlerr.s <rc$eZdZfdZdZxZS)RemovePersistentNetworkRulesc^tt| tj||_yr)superr__init__conf&get_remove_persistent_net_rules_periodosutilselfr __class__s rrz%RemovePersistentNetworkRules.__init__3s# *D:4;f;f;hi rc8|jjyr)rremove_rules_filesrs r _operationz'RemovePersistentNetworkRules._operation7s &&(r__name__ __module__ __qualname__rr$ __classcell__r s@rrr2s )rrc*eZdZfdZdZdZxZS)MonitorDhcpClientRestartctt| tj||_t |_|jjd|_ g|_ yNT) rr,rr&get_monitor_dhcp_client_restart_periodrr dhcp_handler conf_routesdhcp_warning_enabled dhcp_id_listrs rrz!MonitorDhcpClientRestart.__init__<sP &6t7b7b7de ,. %%'$(!rcjtjdk(rj_ytfdjDryj}t|dk7rG|jk7r7t j dj j|_yyy)Nrc3TK|]}jj|!ywr)rcheck_pid_alive).0pidrs r z6MonitorDhcpClientRestart._operation..Is MCt{{**3/Ms%(zBEnvMonitor: Detected dhcp client restart. Restoring routing table.)lenr3_get_dhcp_client_pidallloggerinfor0r1)rnew_pids` rr$z#MonitorDhcpClientRestart._operationDs t  !Q & $ 9 9 ;D   M4;L;LM M ++- w<1 D,=,=!= KK\ ]    ) ) + 'D "> rcXg} t|jj}t|dk(r!|jrt j dt|dk7|_|S#t$r5}|jrt jdt|Yd}~Nd}~wwxYw)NrzDhcp client is not running.z-Failed to get the PID of the DHCP client: {0}) sortedr get_dhcp_pidr:r2r=warn Exceptionerrorr)rr8 exceptions rr;z-MonitorDhcpClientRestart._get_dhcp_client_pidRs _1134C3x1}!:!: 9: %(HM!  _(( LdS\o^ _sAA++ B)4+B$$B))r&r'r(rr$r;r)r*s@rr,r,;s (rr,c$eZdZfdZdZxZS)EnableFirewallcztt| tj||_||_d|_y)NF)rrHrrget_enable_firewall_period_osutil _protocol _try_remove_legacy_firewall_rule)rrprotocolr s rrzEnableFirewall.__init__fs1 nd,T-L-L-NO !05-rc\|js;|jj|jj d|_|jj |jj t j\}}|rddj|jj}tj|ttttj |dt#tj$tttj |dy)N)dst_ipT)rPuidzKSuccessfully added Azure fabric firewall rules. Current Firewall rules: {0}F)versionopmessage log_event)rRrS is_successrU)rMrKremove_legacy_firewall_rulerL get_endpointenable_firewallosgetuidformatget_firewall_listr=r>rr r rFirewallr EVERY_HOUR)rsuccessis_firewall_rules_updatedmsgs rr$zEnableFirewall._operationls44 LL 4 4DNNP>Y>Ycfrw x    #!**  rr%r*s@rrHrHes 6 rrHc(eZdZdZfdZdZxZS)LogFirewallRulesz Log firewall rules state once a day. Goal is to capture the firewall state when the agent service startup, in addition to add more debug data and would be more useful long term. c^tt| tj||_yr)rrdrrget_firewall_rules_log_periodrKrs rrzLogFirewallRules.__init__s# .t/Q/Q/ST rc|tjdj|jj y)NzCurrent Firewall rules: {0})r=r>r\rKr]r#s rr$zLogFirewallRules._operations' 299$,,:X:X:Z[\r)r&r'r(__doc__rr$r)r*s@rrdrds ]rrdc$eZdZfdZdZxZS)SetRootDeviceScsiTimeoutc^tt| tj||_yr)rrjrr#get_root_device_scsi_timeout_periodrKrs rrz!SetRootDeviceScsiTimeout.__init__s# &6t7_7_7ab rc^|jjtjyr)rKset_scsi_disks_timeoutrget_root_device_scsi_timeoutr#s rr$z#SetRootDeviceScsiTimeout._operations ++D,M,M,OPrr%r*s@rrjrjsQrrjc$eZdZfdZdZxZS)MonitorHostNameChangesctt| tj||_|j j |_yr)rrqrrget_monitor_hostname_periodrKget_hostname_record _hostnamers rrzMonitorHostNameChanges.__init__s7 $d4T5U5U5WX 99;rctj}||jk7r_tjd|j||j j ||j j|||_yy)Nz0EnvMonitor: Detected hostname change: {0} -> {1})socket gethostnamerur=r>rK set_hostnamepublish_hostname)r curr_hostnames rr$z!MonitorHostNameChanges._operationsg**, DNN * KKJ% ' LL % %m 4 LL ) )- 8*DN +rr%r*s@rrqrqs < +rrqcHeZdZdZdZedZdZdZdZ dZ dZ dZ y ) rz 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 c"tjSr)r _THREAD_NAMErrrget_thread_namezEnvHandler.get_thread_names&&&rc.d|_d|_d|_yr.)stoppedhostname env_threadr#s rrzEnvHandler.__init__s  rc|js%tjd|jd|_tjd|j y)Nz"Stop existing env monitor service.FzStarting env monitor service.)rr=r>stopstartr#s rrunzEnvHandler.runs<|| KK< = IIK  34 rc6|jjSr)ris_aliver#s rrzEnvHandler.is_alives''))rc tj|j|_|jj d|jj |j |jjy)N)targetT) threadingThreaddaemonr setDaemonsetNamerrr#s rrzEnvHandler.startsU#**$++> !!$'  4 4 67 rc\ t}|j}t}t|t |g}t j r5|jt|||jt|t j|jt|t jr|jt||js< |D]}|j t)j*||js;yy#t $r)}t#j$dt'|Yd}~Qd}~wwxYw#t)j*|wxYw#t $r)}t#j$dt'|Yd}~yd}~wwxYw)Nz[An error occurred in the environment thread main loop; will skip the current iteration. {0}zFAn error occurred in the environment thread; will exit the thread. {0})r get_protocolr rr,rrYappendrHrdrorjget_monitor_hostnamerqrrrDr=rErr sleep_until_next_operation)r protocol_utilrNrperiodic_operationsrSes rrzEnvHandler.daemonsu m./M$113H\F-V4(0#  ##%#**>&(+KL#**+;F+CD002>#**+CF+KL((*#**+A&+IJllV1!! &@@ATUll!JLL!BFGHBIJJJ&@@ATU m LLbdhijdk l l msTC+E9.D*E!E9* E3EEEEE66E99 F+F&&F+c`d|_|j|jjyy)zO Stop server communication and join the thread to main thread. TN)rrjoinr#s rrzEnvHandler.stops* ?? & OO " 'rN) r&r'r(rhr~ staticmethodrrrrrrrrrrrrs@ L'' * m@#rr)(rerZrwrazurelinuxagent.common.confcommonrazurelinuxagent.common.loggerr=azurelinuxagent.common.dhcprazurelinuxagent.common.eventrrrazurelinuxagent.common.futurer!azurelinuxagent.common.interfacesrazurelinuxagent.common.osutilr $azurelinuxagent.common.protocol.utilr azurelinuxagent.common.versionr r %azurelinuxagent.ga.periodic_operationr compile IGNORECASECACHE_PATTERNSMAXIMUM_CACHED_FILESrrr,rHrdrjrqrrrrrs( **..8TT.D4BFCBJJ12==ABJJ0"--@BJJ& 6 )#4)'0'T!&!H ]( ]Q0Q+.+"L#'L#r