ÿØÿàJFIFÿþ ÿÛC       ÿÛC ÿÀÿÄÿÄ"#QrÿÄÿÄ&1!A"2qQaáÿÚ ?Øy,æ/3JæÝ¹È߲؋5êXw²±ÉyˆR”¾I0ó2—PI¾IÌÚiMö¯–þrìN&"KgX:Šíµ•nTJnLK„…@!‰-ý ùúmë;ºgµŒ&ó±hw’¯Õ@”Ü— 9ñ-ë.²1<yà‚¹ïQÐU„ہ?.’¦èûbß±©Ö«Âw*VŒ) `$‰bØÔŸ’ëXÖ-ËTÜíGÚ3ð«g Ÿ§¯—Jx„–’U/ÂÅv_s(Hÿ@TñJÑãõçn­‚!ÈgfbÓc­:él[ðQe 9ÀPLbÃãCµm[5¿ç'ªjglå‡Ûí_§Úõl-;"PkÞÞÁQâ¼_Ñ^¢SŸx?"¸¦ùY騐ÒOÈ q’`~~ÚtËU¹CڒêV  I1Áß_ÿÙimport asyncio import time from logging import getLogger from defence360agent.contracts import config, messages from defence360agent.feature_management import checkers CONFIG_UPDATE_TIMEOUT = config.SimpleRpc.CLIENT_TIMEOUT / 2 logger = getLogger(__name__) OBSOLETE_SECTION = "KERNELCARE" OBSOLETE_OPTION = "edf" def warn_obsolete_option(data): if OBSOLETE_OPTION in data.get(OBSOLETE_SECTION, dict()): logger.warning( "Configuration update with an obsolete kernelcare option 'edf'." " This option has no effect." ) async def update_config(sink, data, user=None): warn_obsolete_option(data) checkers.config_validation(data, user) conf = config.ConfigFile(user) conf.dict_to_config(data, without_defaults=True) updated = asyncio.Event() await sink.process_message( messages.ConfigUpdate(conf=conf, timestamp=time.time(), event=updated) ) await asyncio.wait_for(updated.wait(), timeout=CONFIG_UPDATE_TIMEOUT)