File: //lib/python2.7/site-packages/azurelinuxagent/ga/update.pyo
�
d�bc @ s 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 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
m
Z
m Z d d l j j Z d d l j j Z d d l j j j Z d d l j j j Z d d l j j j Z d d l m Z m Z d d l m Z d d l m! Z! d d l" m# Z# m$ Z$ m% Z% m& Z& d d l' m( Z( m) Z) m* Z* m+ Z+ d d l, m- Z- d d l. m/ Z/ m0 Z0 d d
l1 m2 Z2 m3 Z3 d d l4 m5 Z5 d d l6 m7 Z7 d d
l8 m9 Z9 d d l: m; Z; d d l< m= Z= d d l> m? Z? d d l@ mA ZA mB ZB mC ZC mD ZD mE ZE mF ZF mG ZG mH ZH mI ZI mJ ZJ mK ZK mL ZL mM ZM d d lN mO ZO mP ZP d d lQ mR ZR d d lS mT ZT d d lU mV ZV mW ZW mX ZX mY ZY mZ ZZ d d l[ m\ Z\ d d l] m^ Z^ d d l_ m` Z` ma Za d Zb d Zc d Zd d d Ze d d Zf d Zg d Zh d Zi d d Zj d Zk d d Zl d Zm d! Zn d" d# d$ d% d& g Zo d' ep f d( � � YZq d) ep f d* � � YZr d+ � Zs d, ep f d- � � YZt d. ep f d/ � � YZu d0 ep f d1 � � YZv d S(2 i����N( t datetimet timedelta( t get_supported_feature_by_namet SupportedFeatureNames( t PersistFirewallRulesHandler( t CGroupConfigurator( t add_eventt0 initialize_event_logger_vminfo_common_parameterst WALAEventOperationt EVENTS_DIRECTORY( t ResourceGoneErrort UpdateErrort
ExitExceptiont AgentUpgradeExitException( t ustr( t
get_osutilt systemd( t VMAgentUpdateStatust VMAgentUpdateStatuses( t get_protocol_util( t HostPluginProtocol( t shellutil( t FlexibleVersion( t AddFirewallRules( t CommandError(
t
AGENT_NAMEt
AGENT_VERSIONt AGENT_DIR_PATTERNt
CURRENT_AGENTt CURRENT_VERSIONt DISTRO_NAMEt DISTRO_VERSIONt is_current_agent_installedt get_lis_versiont
has_logrotatet PY_VERSION_MAJORt PY_VERSION_MINORt PY_VERSION_MICRO( t get_collect_logs_handlert is_log_collection_allowed( t get_env_handler( t$ get_collect_telemetry_events_handler( t HandlerManifestt ExtHandlersHandlert list_agent_lib_directoryt ExtensionStatusValuet ExtHandlerStatusValue( t get_monitor_handler( t! get_send_telemetry_events_handler( t get_firewall_drop_commandt get_accept_tcp_rules
error.jsons HandlerManifest.jsont partitioni i< i i t current_versiont initial_goal_states *.crts *.p7ms *.pems *.prvs ovf-env.xmlt ExtensionsSummaryc B s5 e Z d Z d d � Z d � Z d � Z d � Z RS( s�
The extensions summary is a list of (extension name, extension status) tuples for the current goal state; it is
used to report changes in the status of extensions and to keep track of when the goal state converges (i.e. when
all extensions in the goal state reach a terminal state: success or error.)
The summary is computed from the VmStatus reported to blob storage.
c C s� | d k r! g | _ t | _ nl g t d � | j j � D] } | j | j f ^ q: | _ | j j d d � � t
d � | j D� � | _ d S( Nc S s | j d k r | j S| S( N( t extension_statust None( t h( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt <lambda>s s t keyc S s | d S( Ni ( ( t s( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR: t s c s s9 | ]/ \ } } | t j t j t j t j f k Vq d S( N( R- t successt errorR. t readyt not_ready( t .0t _t status( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pys <genexpr>u s ( R8 t summaryt Truet convergedt mapt vmAgentt extensionHandlerst nameRC t sortt all( t selft vm_statust o( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __init__m s :c C s | j | j k S( N( RD ( RM t other( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __eq__w s c C s | | k S( N( ( RM RQ ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __ne__z s c C s
t | j � S( N( R RD ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __str__} s N( t __name__t
__module__t __doc__R8 RP RR RS RT ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR6 f s
t AgentUpgradeTypec B s e Z d Z d Z d Z RS( s3
Enum for different modes of Agent Upgrade
t Hotfixt Normal( RU RV RW RY RZ ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRX � s c C s t � S( N( t
UpdateHandler( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt get_update_handler� s R[ c B s e Z e d d � Z d � Z d2 d � Z e d � Z d � Z d � Z
d � Z d � Z e
d � � Z d
� Z d � Z d � Z d
� Z d � Z e
d � � Z e d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � � Z! e! j" d � � Z! e d � � Z# e d � � Z$ d � Z% d � Z& d � Z' e d! � � Z( d" � Z) d2 d# � Z* e+ d$ d% � Z, d& � Z- e
d' � � Z. d( � Z/ e0 d) � Z1 d* � Z2 d+ � Z3 e
d, � � Z4 e
d- � � Z5 d. � Z6 d/ � Z7 e
d0 � � Z8 d1 � Z9 RS(3 t minutesi c C s1 t � | _ t � | _ t | _ d | _ d | _ d | _ g | _
d | _ d | _ d | _
d | _ d | _ d | _ t t j � � j � | _ d | _ d | _ t | _ d | _ d | _ t � | _ t j j | j! � � | _" t# j$ � st% | _& n* | j" r t# j' � | _& n t# j( � | _& d S( Ni i����() R t osutilR t
protocol_utilRE t _is_runningR8 t last_attempt_timet _last_hotfix_upgrade_timet _last_normal_upgrade_timet agentst child_agentt child_launch_timet child_launch_attemptst
child_processt signal_handlert _last_telemetry_heartbeatt strt uuidt uuid4t uppert
_heartbeat_idt _heartbeat_countert( _heartbeat_update_goal_state_error_countt Falset" _last_try_update_goal_state_failedt& _report_status_last_failed_incarnationt last_incarnationR6 t _extensions_summaryt ost patht existst _initial_goal_state_file_patht _is_initial_goal_statet conft get_extensions_enabledt% GOAL_STATE_PERIOD_EXTENSIONS_DISABLEDt _goal_state_periodt get_initial_goal_state_periodt get_goal_state_period( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRP � s4 c
C s� | j d k r t d � � n | j d k rK t j t j | j � | _ n | j � } | d k r� t j d t
� d j t j
d � } t j � } t
} t } n= t j d | j � | j � } | j � } | j } | j } | d k rd j | | � } n y@t j | � } | d j � d k rIt j | d <d j | � } n | j | � t j | d | d
t j d t j d t j �| _ t j d
| | � d } d } t! j! � }
xd t! j! � |
t" k rt! j# | � y | j j$ � } Wn t% k
rd } n X| d k r�Pq�q�W| d k s3| d k r�d j | | � } t j | � t& t' d | d t( j) d t* d | d t+ �| d k r�| j j, � } q�nG d j | | | � } t j- | � t& t' d | d t( j) d t+ d | �| d k rA| d k rAd j | | | � } t j- | � | d k rA| j. d t* � qAn Wn� t k
r�} | j/ r�d j | | � } t j- | � d j | t j0 | � � }
t& t' d | d t( j) d t+ d |
�| d k r�| j. d t* � q�q�n Xd | _ d S( s�
This method is called from the daemon to find and launch the most
current, downloaded agent.
Note:
- Most events should be tagged to the launched agent (agent_version)
s= Illegal attempt to launch multiple goal state Agent processesu- Installed Agent {0} is the most current agents python -u {0} -run-exthandlersi u+ Determined Agent {0} to be the latest agents {0} {1}t pythont t cwdt stdoutt stderrt envu% Agent {0} launched with command '{1}'i i����u= Agent {0} launched with command '{1}' is successfully runningt versiont opt
is_successt messaget log_eventuB Agent {0} launched with command '{1}' failed with return code: {2}u8 Agent {0} launched with command '{1}' returned code: {2}t is_fatalu> Agent {0} launched with command '{1}' failed with exception:
N(1 Rh R8 t ExceptionRi t signalt SIGTERMt forward_signalt get_latest_agentt loggert infoR t formatt syst argvRw t getcwdR RJ t
get_agent_cmdt
get_agent_dirR� t textutilt safe_shlex_splitt lowert
executablet joint _evaluate_agent_healtht
subprocesst PopenR� R� t environt verboset timet CHILD_HEALTH_INTERVALt sleept pollt OSErrorR R R t EnableRE Rr t waitt warnt mark_failuret
is_runningt format_exception( RM t
child_argst latest_agentt agent_cmdt agent_dirt
agent_namet
agent_versiont cmdst
poll_intervalt rett
start_timet msgt et detailed_message( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt
run_latest� s�
c C sf yjt j d t � | j j � } x& | j | � sJ t j t j � � q% Wt
| � d j d t d t
d t | j � j d | j j d t d t d t d
t j � d t � d t � �
} t j | � t t d
t j d | �d d l m } m } | | � } | � d d l m! } | | � } | j" � | j# � | j$ � | j% � | j& � | j' � | j( | � | j) d | j* � � | j+ d | j* � � t, | j � } t- � t. � | t/ | � g }
t0 � r�|
j1 t2 � � n x |
D] } | j3 � q�Wt j d | j4 � xT | j5 rh| j6 | � | j7 |
� | j8 | | � | j9 | � t j | j4 � qWWn� t: k
r�} t t d
t j; d t< d t= d | j> d t? �t j | j> � n� t@ k
r�} t j | j> � nl tA k
rJ}
d j t tB |
� � } | jC d | � t jD | � t jD tE jF |
� � tG jH d � d SX| jI � tG jH d � d S( sV
This is the main loop which watches for agent and extension updates.
u, Agent {0} is running as the goal state agentu� Distro: {dist_name}-{dist_ver}; OSUtil: {util_name}; AgentService: {service_name}; Python: {py_major}.{py_minor}.{py_micro}; systemd: {systemd}; LISDrivers: {lis_ver}; logrotate: {has_logrotate};t dist_namet dist_vert util_namet service_namet py_majort py_minort py_microR t lis_verR" R� R� i����( t get_exthandlers_handlert migrate_handler_state( t get_remote_access_handlert dst_ipsm Goal State Period: {0} sec. This indicates how often the agent checks for new goal states and reports status.R� R� R� u$ Agent {0} failed with exception: {1}R� i Ni (J R� R� R R_ t get_protocolt _try_update_goal_stateR� R� R| R� R R� R R t typeR^ RU R� R# R$ R% R t
is_systemdR! R" R R R t OSInfot azurelinuxagent.ga.exthandlersR� R� t azurelinuxagent.ga.remoteaccessR� t _ensure_no_orphanst _emit_restart_eventt& _emit_changes_in_default_configurationt _ensure_partition_assignedt _ensure_readonly_filest _ensure_cgroups_initializedt5 _ensure_extension_telemetry_state_configured_properlyt _ensure_firewall_rules_persistedt get_endpointt, _add_accept_tcp_firewall_rule_if_not_enabledR0 R/ R( R) R' t appendR& t runR R� t _check_daemon_runningt _check_threads_runningt _process_goal_statet _send_heartbeat_telemetryR
t AgentUpgradeR RE t reasonRr R R� R t
_set_sentinelR� R� R� R� t exitt _shutdown( RM t debugt protocolt os_info_msgR� R� t exthandlers_handlerR� t remote_access_handlert telemetry_handlert all_thread_handlerst thread_handlert
exitExceptionR> R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� 9 sx
c C s, | r( | j r( t d j t � � � n d S( Ns! Agent {0} is an orphan -- exiting( t _is_orphanedR R� R ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C sW xP | D]H } | j � r | j � r t j d j | j � � � | j � q q Wd S( Ns {0} thread died, restarting( t
keep_alivet is_aliveR� R� R� t get_thread_namet start( RM R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s
c C s ya | j � | j r` t | _ d } t t d t j d t d t d | d t �t j
| � n Wn� t k
r
} | j s� t | _ d j t
j | � � } t j | � t t d t j d t d t d | d t �n d j t | � � } t j t j d j | � � t SXt S(
s�
Attempts to update the goal state and returns True on success or False on failure, sending telemetry events about the failures.
u8 Retrieving the goal state recovered from previous errorsR� R� R� R� R� u6 An error occurred while retrieving the goal state: {0}u4 Attempts to retrieve the goal state are failing: {0}s [PERIODIC] {0}( t update_goal_stateRs Rr R R R t FetchGoalStateR RE R� R� R� R� R� R� R� R t
periodic_warnt EVERY_SIX_HOURS( RM R� R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s"
+
. c C s | j } | j | � s> | j d 7_ | j | d t �d S| j | � r$| j � } | d k r} t d j t
� � � q$| j � \ } } | j | � } | t
j k r� | n | } d j | | j t j | � j t j j � � } t t d t j d t d t d | d t �t j | � n | j � | j � }
z� |
| j k r�| j j! s�d
j | j � } t j" | � t d t j# d | d t d t � | j$ r�| j% | j � q�n t& � | _ | j' � n | j | d |
| j k �|
| j k r | j' � n Wd |
| _ Xd S( Ni t incarnation_changeds8 Agent {0} is reverting to the installed agent -- exitings< Discovered new {0} upgrade {1}; Will upgrade on or after {2}R� R� R� R� R� sh A new goal state was received, but not all the extensions in the previous goal state have completed: {0}(( R� R� Rq t _report_statusRr t. _check_and_download_agent_if_upgrade_availableR� R8 R
R� R t& _UpdateHandler__get_next_upgrade_timest& _UpdateHandler__get_agent_upgrade_typeRX RY RJ R t utcfromtimestampt strftimeR� t Loggert LogTimeFormatInUTCR R R R� R RE R� t* _UpdateHandler__upgrade_agent_if_permittedt get_incarnationRu Rv RF R� t GoalStateR{ t _on_initial_goal_state_completedR6 R� ( RM R� R� R� t available_agentt next_normal_timet next_hotfix_timet upgrade_typet next_timeR� t incarnation( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � sD !
"
c
C sD t j � s d
Sd
} y� | j � \ } } y t d � | D� � } Wn7 t k
r~ | rz t j d j t j � � � n d
SX| j
r� t | j k r� t
j } d } n t
j } d } t d | j d | d | � } n Wnc t k
r?} | r@d j t j | � � } t j | � t d t j d
t d | d t � q@n X| S( s�
This function gets the VMAgent update status as per the last GoalState.
Returns: None if the last GS does not ask for requested version else VMAgentUpdateStatus
c s s* | ] } | j t j � k r | Vq d S( N( t familyR| t get_autoupdate_gafamily( RA t m( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pys <genexpr> s sL Unable to report update status as no matching manifest found for family: {0}i i t expected_versionRC t codes� [This error will only be logged once per incarnation] Ran into error when trying to fetch updateStatus for the agent, skipping reporting update satus. Error: {0}R� R� R� R� N( R| t get_enable_ga_versioningR8 t get_vmagent_manifestst nextt
StopIterationR� R� R� R t is_requested_version_specifiedR t requested_versionR t Successt ErrorR t requested_version_stringR� R� R� R� R R R� Rr (
R� R� t
update_statust agent_manifestsRB t manifestRC R R> t err_msg( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __get_vmagent_update_status� s6
)c C s� | j | j | � } | j d | d | � } | d k r= d Sy� t | � } | j | k r� | | _ d j | j � } t j | � t d t
j d | � | j j r� d j | � } t j | � t d t
j d | � | j
r� | j | j � q� q� n Wn� t k
r}} | j | j j � k r~| j j � | _ d j t j | � � } t j | � t d t
j d t d | � q~n Xd S( NR� t vm_agent_update_statuss Extension status: {0}R� R� sC All extensions in the goal state have reached a terminal state: {0}u) Error logging the goal state summary: {0}R� ( t) _UpdateHandler__get_vmagent_update_statusR� t report_ext_handlers_statusR8 R6 Rv R� R� R� R R R RF R{ R R� Rt R R� R� R� Rr ( RM R� R� R RN t extensions_summaryR� R> R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s0
c C so t j | j � t | � � t j � rb | j t j � k rb t j � | _ t j d | j � n t
| _ d S( NsC Initial goal state completed, switched the goal state period to {0}( t fileutilt
write_fileRz R R| R} R R� R� R� Rr R{ ( RM R! ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR = s
!c C s� | t j k r | j � n | j d k r/ d St j d t | | j d k rY | j j n t � | j j
| � | j d t j t j
f k r� | j | | � n> | j t j
k r� | t j k r� | j � t j d � q� n d S( Nu& Agent {0} forwarding signal {1} to {2}i ( R� R� R� Rh R8 R� R� R Re RJ t send_signalRi t SIG_IGNt SIG_DFLR� R� ( RM t signumt frame( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� D s"
"
c C sr t j � s d S| j � g | j D]* } | j r$ | j t t � k r$ | ^ q$ } t | � d k rn | d Sd S( s�
If autoupdate is enabled, return the most current, downloaded,
non-blacklisted agent which is not the current version (if any).
Otherwise, return None (implying to use the installed agent).
i i N(
R| t get_autoupdate_enabledR8 t _find_agentsRd t is_availableR� R R t len( RM t agentt available_agents( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� [ s
!c
C sx y` | j s_ d j t j | j � � � } t j | � t t d t d t
j d t d | �n Wn t
k
rs n Xd S( Nu$ Agent did not terminate cleanly: {0}R� R� R� R� ( t _is_clean_startR� R" t read_filet _sentinel_file_pathR� R� R R R R t RestartRr R� ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� l s
c s5 yd � � d � f d � } � f d � } | d t j � d � | d t j � d � | d t j � � | d t j � � | d
t j � � t j � r� | d t j � � n t j � r� | d t j � � n t j � d
k r� d j t j � � � n Wn) t
k
r0} t j d t
| � � n Xd S( Nc S s- t j d | � t t d t j d | �d S( Ns ******** {0} ********R� R� ( R� R� R R R t ConfigurationChange( R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s t c s> t j | � } | | k r: � d j | | | | � � n d S( Ns6 {0} changed from its default: {1}. New value: {2}. {3}( R| t get_int_default_valueR� ( RJ t currentR� t default( R� ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt log_if_int_changed_from_default� s c s | s � d j | � � n d S( Ns1 {0} is set to False, not processing the operation( R� ( RJ t value( R� ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt log_if_op_disabled� s s Extensions.GoalStatePeriods� Changing this value affects how often extensions are processed and status for the VM is reported. Too small a value may report the VM as unresponsives! Extensions.InitialGoalStatePeriods OS.EnableFirewalls Extensions.Enableds AutoUpdate.Enableds OS.EnableFirewallPeriods Autoupdate.Frequencys /var/lib/waagents) lib dir is in an unexpected location: {0}s+ Failed to log changes in configuration: {0}( R| R� R� t enable_firewallR} R) t get_enable_firewall_periodt get_autoupdate_frequencyt get_lib_dirR� R� R� R� R ( R8 R: R� ( ( R� s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� } s& c C s� | j � \ } } x� | D]� } y� t j | � } | } xv | j j | � r� | t 8} | d k r� t j d t | � t j
| t j � Pn t j
d t | � t j t � q: Wt j | � Wq t k
r� } t j d t | � � q Xq Wd S( Ni u* {0} forcibly terminated orphan process {1}u/ {0} waiting for orphan process {1} to terminateu= Exception occurred waiting for orphan agent to terminate: {0}( t _write_pid_fileR" R0 R^ t check_pid_alivet ORPHAN_POLL_INTERVALR� R� R Rw t killR� t SIGKILLR� R� R� t removeR� R ( RM t orphan_wait_intervalt pid_filest ignoredt pid_filet pidt
wait_intervalR� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s2
c
C ss t j j | j � so t t t j � j d � � } t j
| j | � t t d t
d t j d t d | �n d S( s�
Assign the VM to a partition (0 - 99). Downloaded updates may be configured
to run on only some VMs; the assigned partition determines eligibility.
i' R� R� R� R� N( Rw Rx Ry t _partition_fileR t intR t utcnowt microsecondR" R# R R R R t PartitionRE ( RM R3 ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C sW xP t D]H } x? t j t j j t j � | � � D] } t j | t j
� q2 Wq Wd S( N( t READONLY_FILE_GLOBSt globt iglobRw Rx R� R| R> t chmodt statt S_IRUSR( RM t gRx ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s
+c C s t j � } | j � d S( N( R t get_instancet
initialize( RM t configurator( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s� | d k r d | _ d S| j d k s= | j | j j k r[ | | _ d | _ d | _ n | j d k r| t j � | _ n | j d 7_ t j � | j t k r� | j t k r� d j | j j t t � } t
| � � n d S( s�
Evaluate the health of the selected agent: If it is restarting
too frequently, raise an Exception to force blacklisting.
Ni i u6 Agent {0} restarted more than {1} times in {2} seconds( R8 Re R� Rf Rg R� t CHILD_LAUNCH_INTERVALt CHILD_LAUNCH_RESTART_MAXR� RJ R� ( RM R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s$ $ c C s, g | j D] } | j s
| ^ q
| _ d S( N( Rd t is_blacklisted( RM R- ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _filter_blacklisted_agents� s c C sQ y! | j | j � � | j � Wn) t k
rL } t j d t | � � n Xd S( sD
Load all non-blacklisted agents currently on disk.
u0 Exception occurred loading available agents: {0}N( t _set_agentst _load_agentsR] R� R� R� R ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR* � s c C s | r | j r | j j � Sd S( N( t clientt get_host_pluginR8 ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _get_host_plugin s c C s^ t j � } t j j | � } t j j | � } t j d j t j | � � � } | | | f S( Ns (\d+)_{0}(
R| t get_agent_pid_file_pathRw Rx t dirnamet basenamet ret compileR� t escape( RM RH t pid_dirt pid_namet pid_re( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _get_pid_parts s
!c sr | j � \ } } � g t j | � D]* } � j | � r% t j j | | � ^ q% } | j d � f d � � | S( NR; c s( t � j t j j | � � j d � � S( Ni ( RL t matchRw Rx Re t group( t f( Rk ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR: s ( Rl Rw t listdirRm Rx R� RK ( RM Ri Rj Ro RF ( ( Rk s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _get_pid_files s @c C s | j S( N( R` ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s c C s
| | _ d S( N( R` ( RM R9 ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s c C s t j j | j � � S( N( Rw Rx t isfileR1 ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR/ s c C sW t j � } | d k r t St j j t j � � s8 t St j t j � � t
| � k S( Ni ( i N( Rw t getppidR8 RE Rx Rr R| Rc R" R0 R ( RM t
parent_pid( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s c C sG | t k r t � r t Sx' | j D] } | j | k r# | j Sq# Wt S( N( R R RE Rd R� R+ Rr ( RM R� R- ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _is_version_eligible) s c C s_ t j j t j � d j t � � } g t j | � D]' } t j j | � r4 t
d | � ^ q4 S( Ns {0}-*Rx ( Rw Rx R� R| R> R� R RQ RR t isdirt
GuestAgent( RM Rx R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR_ 4 s $c C s t t j | j � � S( N( RL R" R0 RK ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt
_partition9 s c C s t j j t j � t � S( N( Rw Rx R� R| R> t AGENT_PARTITION_FILE( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRK < s c C sZ t j j t j � d j t � � } g | j D] } | j ^ q. } t | k ro t
j d t � | j t � n x� t
j | � D]� } y� t j | d � } t j | � } | d k r"t | j d � � | k r"t j j | � rt
j d | � t j | � q"t
j d | � t j | � n Wq t k
rQ} t
j d | t | � � q Xq Wd S( s�
Remove from disk all directories and .zip files of unknown agents
(without removing the current, running agent).
s {0}-*uF Running Agent {0} was not found in the agent manifest - adding to listt zipi u Purging outdated Agent file {0}u$ Purging outdated Agent directory {0}u! Purging {0} raised exception: {1}N( Rw Rx R� R| R> R� R Rd R� R R� R� R� RQ RR R" t trim_extR Rm R8 R Rn Rr R� RD t shutilt rmtreeR� R� R ( RM Rx R- t known_versionst
agent_pathRJ R
R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt
_purge_agents@ s( $ '!c C s> | d k r g } n | | _ | j j d d � d t � d S( NR; c S s | j S( N( R� ( R- ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR: a s t reverse( R8 Rd RK RE ( RM Rd ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR^ ] s
s
Unknown causec C s_ y& t j | j � d j | | � � Wn2 t k
rZ } t j d | j � t | � � n Xd S( Ns [{0}] [{1}]u( Exception writing sentinel file {0}: {1}( R" R# R1 R� R� R� R� Rk ( RM R- R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� d s c C s t j j t j � t � S( N( Rw Rx R� R| R> t AGENT_SENTINEL_FILE( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR1 p s c C s t j j t j � t � S( N( Rw Rx R� R| R> t INITIAL_GOAL_STATE_FILE( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRz s s c C su t | _ t j j | j � � s% d Sy t j | j � � Wn2 t k
rp } t j d | j � t
| � � n Xd S( Nu) Exception removing sentinel file {0}: {1}( Rr R� Rw Rx Rr R1 RD R� R� R� Rk ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� w s c
C s� t j � s t St j � } | j d k rA | j t j � } n | } | | k rW t St j � } t j d | � | | _ y | j
� \ } } g | D]0 } | j | k r� t | j
� d k r� | ^ q� } t | � d k r� t j d | | � t S| j | d � }
| j d | � } | j g |
j D] } t d | d | � ^ q,� | j � | j � | j | � p�t | j � d k o�| j d j | k SWnQ t k
r�}
d j t j |
� � } t t d t j d t! d
t d | �t SXd S(
s,
This function periodically (1hr by default) checks if new Agent upgrade is available and downloads it on filesystem if it is.
rtype: Boolean
return: True if current agent is no longer available or an agent with a higher version number is available
else False
s( Checking for agent updates (family: {0})i u( Incarnation {0} has no {1} agent updatesR� t pkgt hostu) Exception retrieving agent manifests: {0}R� R� R� R� N(" R| R) Rr R� Ra R8 R= R R� R� R R R, t urisR� t get_vmagent_pkgsRb R^ t versionsRw R� R] Ru Rd R� R� R� R� R� R R R t DownloadR ( RM R� t base_versiont nowt next_attempt_timeR t
manifest_listt etagR
t manifestst pkg_listR� R� R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s< =
2
- c C s% | j � } | j � \ } } } t | � d k r9 d n | d } | d k rU d n' t | j t j j | � � j d � � } t j j
| d j | d | � � } y? t j
| t t j � � � t j d t t t j � � � Wn5 t k
r} d } t j d t | t | � � n X| | f S( Ni i����i s {0}_{1}u {0} running as process {1}u6 Expection writing goal state agent {0} pid to {1}: {2}( Rq Rl R, R8 RL Rm Rw Rx Re Rn R� R� R" R# R t getpidR� R� R R� R� ( RM RF Ri Rj Rk t previous_pid_filet pid_indexRH R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR? � s" "*% #c
C s+ | j d k r( t j � t j | _ n t j � | j t j k r'| j j | j � � } t j
� rn d n d } d j | j | j
| | j | � } d j | j | j
| | j | � } t d t d t d t j d t d | d
t � t j d t | � | j d 7_ d | _ t j � | _ n d S( Ni i s {0};{1};{2};{3};{4}sf [DEBUG HeartbeatCounter: {0};HeartbeatId: {1};DroppedPackets: {2};UpdateGSErrors: {3};AutoUpdate: {4}]RJ R� R� R� R� R� u< [HEARTBEAT] Agent {0} is running as the goal state agent {1}( Rj R8 R RM R[ t TELEMETRY_HEARTBEAT_PERIODR^ t get_firewall_dropped_packetsR� R| R) R� Rp Ro Rq R R R R t HeartBeatRE Rr R� R� R ( RM R� t dropped_packetst auto_update_enabledt
telemetry_msgt
debug_log_msg( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s& !
c C s� t t j � j } x� t d t � D]� \ } } y" t j d | d | d | � } Wn t k
rf q" n XyX | d k r� | j
� | j � } | r� t j
j | � r� t j | d d �q� n Wq" t k
r� } t j d j t | � � � q" q" Xq" WyX | sOt j t j
j t j � d t � � } x$ | D] } t j | d t �q/Wn Wn/ t k
r�} t j d
j t | � � � n Xd S( Nt skip_agent_packageRJ Rx R� t modei� sJ Unable to re-create HandlerEnvironment file on service startup. Error: {0}t *t
ignore_errorssK Error when trying to delete existing Extension events directory. Error: {0}( R R t ExtensionTelemetryPipelinet is_supportedR, RE R+ t" get_ext_handler_instance_from_pathR� R8 t create_handler_envt get_extension_events_dirRw Rx Ry R" t mkdirR� R� R� R RQ R� R| t get_ext_log_dirR R| R} ( R� t etp_enabledRJ Rx t handler_instancet
events_dirR� t extension_event_dirst ext_dir( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s2
'
c C s� t j � s t j d � d St } t j d � y< t d | d t j � � j � d } t } t j | � Wn5 t
k
r� } d j t | � � } t j
| � n Xt d t j d | d | d
t � d S( NsC Not setting up persistent firewall rules as OS.EnableFirewall=Falses, Starting setup for Persistent firewall rulesR� t uids, Persistent firewall rules setup successfullys2 Unable to setup the persistent firewall rules: {0}R� R� R� R� ( R| R; R� R� Rr R Rw t getuidt setupRE R� R� R R> R R t PersistFirewallRules( R� R� R� R> ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s$
c C sL t j � s d Sd � } y� | j j � } t | t j | � } | | � s] t j d � d St | t j | � } | | � sy@ t j d � t | t j
| � } t j | � t j d � Wqt
k
r� } d j | j | j | j � } t j | � qXn
t j d � Wn5 t k
rG} d j t | � � } t j | � n Xd S( Nc S sD y t j | � t SWn( t k
r? } | j d k r@ � q@ n Xt S( Ni ( R t run_commandRE R t
returncodeRr ( t commandt err( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt _execute_run_command9 s
sj DROP rule is not available which implies no firewall rules are set yet. Environment thread will set it up.se Firewall rule to allow DNS TCP request to wireserver for a non root user unavailable. Setting it now.s] Succesfully added firewall rule to allow non root users to do a DNS TCP request to wireserversx Unable to set the non root tcp access firewall rule :Run command execution for {0} failed with error:{1}.Return Code:{2}sp Not setting the firewall rule to allow DNS TCP request to wireserver for a non root user since it already existss' Error while checking ip table rules:{0}( R| R; R^ t get_firewall_will_waitR1 R t
CHECK_COMMANDR� R� R2 t INSERT_COMMANDR R� R R� R� R� R� R> R� R ( RM R� R� R� t drop_rulet accept_tcp_ruleR> R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� 4 s6
c sU � f d � } t j � � | | j t j � � } | | j t j � � } | | f S( so
Get the next upgrade times
return: Next Normal Upgrade Time, Next Hotfix Upgrade Time
c s | d k r � S| | S( N( R8 ( t last_valt frequency( R� ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt get_next_process_timel s ( R� Rb R| t get_hotfix_upgrade_frequencyRc t get_normal_upgrade_frequency( RM R� R R ( ( R� s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __get_next_upgrade_timesf s
c C s8 | j j t j k r1 | j j t j k r1 t j St j S( N( R� t majorR t minorRX RY RZ ( R ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __get_agent_upgrade_typeu s *c C s | j � \ } } t j � } | | k r: | | k r: d S| | k rL | n | j | _ | | k rj | n | j | _ | j � } | d k r� t j d � d S| j | � } d j | | j
� } | t j k r� | | k s� | t j
k r| | k rt | � � n d S( s�
Check every 4hrs for a Hotfix Upgrade and 24 hours for a Normal upgrade and upgrade the agent if available.
raises: ExitException when a new upgrade is available in the relevant time window, else returns
Ns No agent upgrade discovereds8 {0} Agent upgrade discovered, updating to {1} -- exiting( R� R� Rb Rc R� R8 R� R� R� R� RJ RX RY RZ R
( RM R R R� R R t upgrade_message( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt __upgrade_agent_if_permitted} s
N(: RU RV R R� RP R8 R� Rr R� R� R� R� R� t staticmethodR R� R R� R� R� R� t ORPHAN_WAIT_INTERVALR� R� R� R� R� R] R* Rb Rl Rq t propertyR� t setterR/ R� Ru R_ Rx RK R� R^ R R� R1 Rz R� R R� R? R� R� R� R� R� R� R ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR[ � s` + ~ g 1+ $ ; & 2 Rw c B s� e Z d d d d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z
d � Z e d � � Z e d � � Z
e d
� � Z e d � Z d � Z d
� Z d � Z d e d d � Z d � Z d � Z d � Z RS( c
C s� | | _ | | _ d } | d k ri t j | � } | d k rW t d j | � � � n | j d � } n | j d k r� | j } n | d k r� t d j | � � � n t | � | _ | d k r� d n d } t
j d | j | � t
| j � � | _ | j j � y | j � | j � Wn� t k
r�} t | t � rF� n t | t � r[� n | j d t j j | j � � � d j | j � } d j | t j | � � } t t d
| j d t j! d t" d
| �n Xd S( Nu Illegal agent directory: {0}i u Illegal agent version: {0}u disku packageu Loading Agent {0} from {1}R� u( Agent {0} install failed with exception:s {0} {1}R� R� R� R� (# R� R� R8 R Rm R R� Rn R� R R� R� RJ t GuestAgentErrort get_agent_error_fileR> t loadt _ensure_downloadedt _ensure_loadedR� t
isinstanceR
t IOErrorR� Rw Rx Rr t get_agent_pkg_pathR� R� R R R t InstallRr (
RM Rx R� R� R� R
t locationR� R� t detailed_msg( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRP � sF
" c C s d j t | j � S( Ns {0}-{1}( R� R R� ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRJ � s c C s
| j j � S( N( R t get_enable_command( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s t j j t j � | j � S( N( Rw Rx R� R| R> RJ ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s t j j t j � | j t � S( N( Rw Rx R� R| R> RJ t AGENT_ERROR_FILE( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s t j j | j � t � S( N( Rw Rx R� R� t AGENT_MANIFEST_FILE( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt get_agent_manifest_path� s c C s+ d j t j j t j � | j � d f � S( Nt .Rz ( R� Rw Rx R| R> RJ ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s | j j � | j j � d S( N( R> t cleart save( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt clear_error� s
c C s | j o | j S( N( t
is_downloadedR\ ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR+ � s c C s | j d k o | j j S( N( R> R8 R\ ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR\ � s c C s | j p t j j | j � � S( N( R\ Rw Rx Rr R� ( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s� yt t j j | j � � s1 t j | j � � n | j j d | � | j j � | j j rs t j
d | j � n Wn/ t k
r� } t j
d | j t
| � � n Xd S( NR� u$ Agent {0} is permanently blacklistedu+ Agent {0} failed recording error state: {1}( Rw Rx Rv R� t makedirsR> R� R� R\ R� R� RJ R� R ( RM R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s
c
C s� t j d | j � | j r3 t j d | j � d S| j d k r] t d j | j � � � n | j � | j � d j | j � } t j | � t
t d | j d t
j d t d | �d S( Nu Ensuring Agent {0} is downloadedu7 Agent {0} was previously downloaded - skipping downloadu. Agent {0} is missing package and download URIsu! Agent {0} downloaded successfullyR� R� R� R� ( R� R� RJ R� R� R8 R R� t _downloadt _unpackR R R� R R� RE ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s"
c C s | j � | j � d S( N( t _load_manifestt _load_error( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s
c C s� | j j } t j | � x| D]} t j rC | j | � rC Pq | j d k r&| j j � r&t j sz t
j d � n
t
j d � | j j
| | j j � \ } } y[ | j | d | d t d t j �r� t j s� t
j d � t t _ n Pn
t
j d � Wq3t k
r"t t _ � q3Xq t
j d � q Wt j j | j � � s�d j | j � } t t d
t j d t d t d
| �t | � � n d S( Ns) Download failed, switching to host plugins$ Using host plugin as default channelt headerst use_proxyt retry_codess& Setting host plugin as default channels Host plugin download faileds No download channels availableu) Unable to download Agent {0} from any URIR� R� R� R� (! R� R� t randomt shuffleR t is_default_channelt _fetchR� R8 t ensure_initializedR� R� R� t get_artifact_requestt manifest_uriRr t restutilt' HGAP_GET_EXTENSION_ARTIFACT_RETRY_CODESRE R
R> Rw Rx Rr R� R� RJ R R R R� R R ( RM t
uris_shuffledt uriR� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� s<
!$
c
C sD d } y� t } d } t j | d | d | d d d | �} t j | � r� | j � } t j | j � t | � d t �t
j d | j | � n/ t j
| � } t
j d | � t j | � } | j d k r� | j j | | d
d d | �n WnD t j k
r9} t | t � r � n t
j d
| j | | � n X| d k S( NR4 R� R� t max_retryi R� t asbinu Agent {0} downloaded from {1}s Fetch was unsuccessful [{0}]t sourceRw t responseu( Agent {0} download from {1} failed [{2}]( R8 RE R� t http_gett request_succeededt readR" R# R� t bytearrayR� R� RJ t read_response_errort request_failed_at_hostpluginR� t report_fetch_healtht HttpErrorR� R
(
RM R� R� R� R� t packaget
is_healthyt error_responset respt
http_error( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� C s0 ' & c C s{ yE t | j � � | _ | j j � t j d | j t | j � � Wn/ t k
rv } t j d | j t | � � n Xd S( Nu Agent {0} error state: {1}u) Agent {0} failed loading error state: {1}(
R� R� R> R� R� R� RJ R R� R� ( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� b s
#c C s� | j � } t j j | � sB d j | j t � } t | � � n t | d � �� } y t j
| � } Wn4 t k
r� } d j | j t � } t | � � n Xt | � t
k r� t | � d k r� d j | j t � } t | � � n | d } n | } Wd QXy= t | � | _ t | j j � � d k r;t d � � n Wn= t k
r{} d j | j t t | � � } t | � � n Xt j d | j | j � � t j d | j t t | j j � � d S(
Nu! Agent {0} is missing the {1} filet ru Agent {0} has a malformed {1}i u Agent {0} has an empty {1}u& Manifest is missing the enable commandu! Agent {0} has an illegal {1}: {2}u" Agent {0} loaded manifest from {1}u& Successfully loaded Agent {0} {1}: {2}( R� Rw Rx Rr R� RJ R� R t opent jsonR� R� R� t listR, R* R R� R R� R� t data( RM Rx R� t
manifest_fileR� R� R ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� j sF
c C s! yT t j j | j � � r1 t j | j � � n t j | j � � j | j � � Wnh t
k
r� } t j | d | j � | j � g �d j
| j | j � t | � � } t | � � n Xt j j | j � � sd j
| j | j � � } t | � � n t j d | j | j � � d S( Nt pathsu+ Exception unpacking Agent {0} from {1}: {2}u2 Unpacking Agent {0} failed to create directory {1}u& Agent {0} unpacked successfully to {1}( Rw Rx Rv R� R| R} t zipfilet ZipFileR� t
extractallR� R" t
clean_ioerrorR� RJ R R R� R� ( RM R� R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s, &
N( RU RV R8 RP R� RJ R� R� R� R� R� R� R+ R\ R� Rr R� R� R� R� RE R� R� R� R� ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRw � s& 3 * )R� c B sb e Z d � Z e d � Z d � Z e d � � Z d � Z d � Z d � Z
d � Z d � Z RS( c C s2 | d k r t d � � n | | _ | j � d S( Nu GuestAgentError requires a path( R8 R Rx R� ( RM Rx ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRP � s
c C s+ t j � | _ | j d 7_ | | _ d S( Ni ( R� t last_failuret
failure_countt was_fatal( RM R� ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s d | _ d | _ t | _ d S( Ng i ( R R Rr R
( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s c C s | j p | j t k S( N( R
R t MAX_FAILURE( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR\ � s c C s� | j d k r� t j j | j � r� y5 t | j d � � } | j t j | � � Wd QXWq� t k
r� } t j
d j | j t j
| � � � y t j | j � Wq� t k
r� q� Xq� Xn d S( NR sY Ran into error when trying to load error file {0}, deleting it to clean state. Error: {1}( Rx R8 Rw Rr R t from_jsonR R� R� R� R� R� R� R� RD ( RM Ro R> ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s $
c C sY t j j t j j | j � � rU t | j d � � } t j | j � | � Wd QXn d S( Nt w( Rw Rx Rv Rd R R t dumpt to_json( RM Ro ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s ! c C sd t | j | j d d � � | _ t | j | j d d � � | _ | j pZ | j d t � | _ d S( Nu last_failureg u
failure_counti u was_fatal( t maxR t getR R
Rr ( RM R ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR � s c C s( i | j d 6| j d 6| j d 6} | S( Nu last_failureu
failure_countu was_fatal( R R R
( RM R ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR � s
c C s d j | j | j | j � S( Ns2 Last Failure: {0}, Total Failures: {1}, Fatal: {2}( R� R R R
( RM ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyRT � s (
RU RV RP Rr R� R� R� R\ R� R� R R RT ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyR� � s
(w RQ R Rw R� Rf R| R� RT R� R� R� Rl R R R t azurelinuxagent.common.conft commonR| t azurelinuxagent.common.loggerR� t% azurelinuxagent.common.utils.fileutilt utilsR" t% azurelinuxagent.common.utils.restutilR� t% azurelinuxagent.common.utils.textutilR� t. azurelinuxagent.common.agent_supported_featureR R t- azurelinuxagent.common.persist_firewall_rulesR t) azurelinuxagent.common.cgroupconfiguratorR t azurelinuxagent.common.eventR R R R t azurelinuxagent.common.exceptionR
R R R
t azurelinuxagent.common.futureR t azurelinuxagent.common.osutilR R t' azurelinuxagent.common.protocol.restapiR R t$ azurelinuxagent.common.protocol.utilR t* azurelinuxagent.common.protocol.hostpluginR t azurelinuxagent.common.utilsR t- azurelinuxagent.common.utils.flexible_versionR t( azurelinuxagent.common.utils.networkutilR t& azurelinuxagent.common.utils.shellutilR t azurelinuxagent.common.versionR R R R R R R R R! R" R# R$ R% t azurelinuxagent.ga.collect_logsR& R' t azurelinuxagent.ga.envR( t+ azurelinuxagent.ga.collect_telemetry_eventsR) R� R* R+ R, R- R. t azurelinuxagent.ga.monitorR/ t( azurelinuxagent.ga.send_telemetry_eventsR0 t% azurelinuxagent.common.osutil.defaultR1 R2 R� R� Ry R� RZ R[ t CHILD_POLL_INTERVALR R~ RA R� R� R� RP t objectR6 RX R\ R[ Rw R� ( ( ( s= /usr/lib/python2.7/site-packages/azurelinuxagent/ga/update.pyt <module> s� ""X(
� � � � �