in azurelinuxagent/ga/exthandlers.py [0:0]
def get_extension_handler_statuses(self, handler_status, goal_state_changed):
"""
Get the list of ExtHandlerStatus objects corresponding to each extension in the Handler. Each object might have
its own status for the Extension status but the Handler status would be the same for each extension in a Handle
:return: List of ExtHandlerStatus objects for each extension in the Handler
"""
ext_handler_statuses = []
# TODO Refactor or remove this common code pattern (for each extension subordinate to an ext_handler, do X).
for ext in self.extensions:
# In MC, for disabled extensions we dont need to report status. Skip reporting if disabled and state == disabled
# Extension.state corresponds to the state requested by CRP, self.__get_extension_state() corresponds to the
# state of the extension on the VM. Skip reporting only if both are Disabled
if self.should_perform_multi_config_op(ext) and \
ext.state == ExtensionState.Disabled and self.get_extension_state(ext) == ExtensionState.Disabled:
continue
# Breaking off extension reporting in 2 parts, one which is Handler dependent and the other that is Extension dependent
try:
ext_handler_status = ExtHandlerStatus()
set_properties("ExtHandlerStatus", ext_handler_status, get_properties(handler_status))
except Exception as error:
msg = "Something went wrong when trying to get a copy of the Handler status for {0}".format(
self.get_extension_full_name())
self.report_error_on_incarnation_change(goal_state_changed, event_msg=msg,
log_msg="{0}.\nStack Trace: {1}".format(
msg, textutil.format_exception(error)))
# Since this is a Handler level error and we need to do it per extension, breaking here and logging
# error since we wont be able to report error anyways and saving it as a handler status (legacy behavior)
self.set_handler_status(message=msg, code=-1)
break
# For the extension dependent stuff, if there's some unhandled error, we will report it back to CRP as an extension error.
try:
ext_status = self.collect_ext_status(ext)
if ext_status is not None:
ext_handler_status.extension_status = ext_status
ext_handler_statuses.append(ext_handler_status)
except ExtensionError as error:
msg = "Unknown error when trying to fetch status from extension {0}".format(
self.get_extension_full_name(ext))
self.report_error_on_incarnation_change(goal_state_changed, event_msg=msg,
log_msg="{0}.\nStack Trace: {1}".format(
msg, textutil.format_exception(error)),
extension=ext)
# Unexpected error, for single config, keep the behavior as is
if not self.should_perform_multi_config_op(ext):
self.set_handler_status(message=ustr(error), code=error.code)
break
# For MultiConfig, create a custom ExtensionStatus object with the error details and attach it to the Handler.
# This way the error would be reported back to CRP and the failure would be propagated instantly as compared to CRP eventually timing it out.
ext_status = ExtensionStatus(name=ext.name, seq_no=ext.sequenceNumber,
code=ExtensionErrorCodes.PluginUnknownFailure,
status=ExtensionStatusValue.error, message=msg)
ext_handler_status.extension_status = ext_status
ext_handler_statuses.append(ext_handler_status)
return ext_handler_statuses