+
    ˜qgj@  ã                   ó  € ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t	^ RI
H
t
Ht ^ RIHt ^ RIHt ^ RIHtHtHtHt ^ RIHt ]P,                  ! ]4      t ! R R]4      t ! R	 R
] P6                  R7      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R]4      t ]]]]]] 3,          t!]! 4       t"]"PG                  R]4       ]"PG                  R]4       ]"PG                  R]4       ]"PG                  R] 4       R# )é    N)ÚdatetimeÚtimezone)ÚEvent)ÚUnion)ÚdmiÚperformanceÚ
url_helperÚutil)ÚDictRegistryc                   ó   € ] tR t^tRtR# )ÚReportException© N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r   ó    Ú>/usr/lib/python3/dist-packages/cloudinit/reporting/handlers.pyr   r      s   † Ûr   r   c                   óN   a € ] tR t^t o Rt]P                  R 4       tR tRt	V t
R# )ÚReportingHandlerzwBase class for report handlers.

Implement :meth:`~publish_event` for controlling what
the handler does with an event.
c                ó   € R# )zPublish an event.Nr   ©ÚselfÚevents   &&r   Úpublish_eventÚReportingHandler.publish_event"   ó   ‚ r   c                ó   € R# )z0Ensure ReportingHandler has published all eventsNr   ©r   s   &r   ÚflushÚReportingHandler.flush&   r   r   r   N)r   r   r   r   Ú__doc__ÚabcÚabstractmethodr   r!   r   Ú__classdictcell__©Ú__classdict__s   @r   r   r      s.   ø‡ € ñð 	×Ññ ó ð ÷?ð ?r   r   )Ú	metaclassc                   ó@   a a€ ] tR t^*t oRtRV 3R lltR tRtVtV ;t	# )Ú
LogHandlerzBPublishes events to the cloud-init log at the ``DEBUG`` log level.c                ó  <€ \         \        V `  4        \        V\        4      '       d   M!Tp \        \        VP                  4       4      pWn        R#   \         d*    \        P                  R T4       \        P                  p L;i ; i)zinvalid level '%s', using WARNN)Úsuperr+   Ú__init__Ú
isinstanceÚintÚgetattrÚloggingÚupperÚ	ExceptionÚLOGÚwarningÚWARNÚlevel)r   r8   Úinput_levelÚ	__class__s   && €r   r.   ÚLogHandler.__init__-   sl   ø€ ÜŒj˜$Ñ(Ô*Ü�eœS×!Ò!ØàˆKð%Ü¤¨¯©«Ó7�ð Ž
øô ô %Ü—‘Ð<¸kÔJÜŸ™’ð%ús   ®A Á1BÂBc                óÔ   € \         P                  ! R P                  RRVP                  VP                  .4      4      pVP                  V P                  VP                  4       4       R# )Ú.Ú	cloudinitÚ	reportingN)r2   Ú	getLoggerÚjoinÚ
event_typeÚnameÚlogr8   Ú	as_string)r   r   Úloggers   && r   r   ÚLogHandler.publish_event:   sL   € Ü×"Ò"Ø�H‰H�k ;°×0@Ñ0@À%Ç*Á*ÐMÓNó
ˆð 	�
‰
�4—:‘:˜uŸ™Ó0Ö1r   )r8   )ÚDEBUG)
r   r   r   r   r#   r.   r   r   r&   Ú__classcell__©r:   r(   s   @@r   r+   r+   *   s   ù‡ € ÙL÷÷2ò 2r   r+   c                   ó*   a € ] tR t^At o RtR tRtV tR# )ÚPrintHandlerzPrint the event as a string.c                ó8   € \        VP                  4       4       R # ©N)ÚprintrE   r   s   &&r   r   ÚPrintHandler.publish_eventD   s   € Üˆe�o‰oÓÖ r   r   N)r   r   r   r   r#   r   r   r&   r'   s   @r   rL   rL   A   s   ø‡ € Ù&÷!ð !r   rL   c                   óH   a a€ ] tR t^Ht oRV 3R lltR tR tR tRtVt	V ;t
# )ÚWebHookHandlerc                ó   <€ \         \        V `  4        \        W#WE.4      '       d-   \        P
                  ! VVVVR 7      pVP                  V n        M\        P                  V n        Wn        W`n        Wpn	        \        P                  ! 4       V n        \        4       V n        \        P                   ! 4       V n        \"        P$                  ! V P&                  R7      V n        RV P(                  n        V P(                  P-                  4        R# ))Úconsumer_keyÚ	token_keyÚtoken_secretÚconsumer_secret©ÚtargetTN)r-   rR   r.   Úanyr	   ÚOauthUrlHelperÚreadurlÚendpointÚtimeoutÚretriesr
   Úfetch_ssl_detailsÚssl_detailsr   Úflush_requestedÚqueueÚQueueÚ	threadingÚThreadÚprocess_requestsÚevent_processorÚdaemonÚstart)
r   r]   rT   rU   rV   rW   r^   r_   Úoauth_helperr:   s
   &&&&&&&& €r   r.   ÚWebHookHandler.__init__I   sÊ   ø€ ô 	Œn˜dÑ,Ô.ä�¨ÐG×HÒHÜ%×4Ò4Ø)Ø#Ø)Ø /ô	ˆLð (×/Ñ/ˆD�Lä%×-Ñ-ˆDŒLØ ŒØŒØŒÜ×1Ò1Ó3ˆÔä$›wˆÔÜ"'§+¢+£-ˆŒ
Ü(×/Ò/°t×7LÑ7LÔMˆÔØ&*ˆ×ÑÔ#Ø×Ñ×"Ñ"Ö$r   c           	     óØ  € ^ p V P                   P                  4       '       du   V^8”  dn   \        P                  R4       V P                  P                  4       '       g7   V P                  P                  4        V P                  P                  4        KV  ^ pV P                  P                  RR7      p V P                  V^ ,          V^,          V^,          V^,          V^,          RR7       ^ pV P                  P                  4        EK    \         d2   p\        P                  RT^,          T4       T^,          p Rp?LTRp?ii ; i  T P                  P                  4        i ; i)r   TzNMultiple consecutive failures in WebHookHandler. Cancelling all queued events.©ÚblockF)Údatar^   r_   ra   Úlog_req_respz0Failed posting event: %s. This was caused by: %sN)rb   Úis_setr5   r6   rc   ÚemptyÚ
get_nowaitÚ	task_doneÚgetr\   r4   )r   Úconsecutive_failedÚargsÚes   &   r   rg   ÚWebHookHandler.process_requestsj   s+  € ØÐØØ×#Ñ#×*Ñ*×,Ò,Ð1CÀaÔ1Gô —‘ð4ôð Ÿ*™*×*Ñ*×,Ò,Ø—J‘J×)Ñ)Ô+Ø—J‘J×(Ñ(Ö*Ø%&Ð"Ø—:‘:—>‘>¨�>Ó-ˆDð'Ø—‘Ø˜•GØ˜a�Ø  �GØ  �GØ $ Q¥Ø!&ð ô ð &'Ð"ð —
‘
×$Ñ$×&øô ô (Ü—‘ØFØ˜•GØôð
 # aÕ'Õ"ûð(ûð —
‘
×$Ñ$Õ&ús*   Â5<D ÄE
Ä'EÅ E ÅE
Å
E ÅE)c                ó   € VP                  4       p\        P                  R V P                  V4       V P                  P                  V P                  \        P                  ! V4      V P                  V P                  V P                  34       R# )zQueuing POST to %s, data: %sN)Úas_dictr5   Údebugr]   rc   ÚputÚjsonÚdumpsr^   r_   ra   )r   r   Ú
event_datas   && r   r   ÚWebHookHandler.publish_event�   sg   € Ø—]‘]“_ˆ
Ü�	‰	Ø*Ø�M‰MØô	
ð
 	�
‰
�‰à—‘Ü—
’
˜:Ó&Ø—‘Ø—‘Ø× Ñ ðö	
r   c                óÌ   € V P                   P                  4        \        P                  R 4       V P                  P                  4        V P                   P                  4        R# )z(WebHookHandler flushing remaining eventsN)rb   Úsetr5   r}   rc   rA   Úclearr    s   &r   r!   ÚWebHookHandler.flush¡   sA   € Ø×Ñ× Ñ Ô"Ü�	‰	Ð<Ô=Ø�
‰
�‰ÔØ×Ñ×"Ñ"Ö$r   )r]   rh   rb   rc   r\   r_   ra   r^   )NNNNNN)r   r   r   r   r.   rg   r   r!   r   r&   rI   rJ   s   @@r   rR   rR   H   s    ù‡ € ÷%òB$'òL
÷"%ò %r   rR   c                   óB  a a€ ] tR t^¨t oRtRtRtRt]],           tRt	]
! ]P                  ! ^ R7      4      tRtRtR	tRtR
tRt]R3V 3R llt]R 4       tR t]R 4       t]P4                  R 4       tR tR tR tR tR tR t V3R lR lt!R t"R t#R t$R t%Rt&Vt'V ;t(# ) ÚHyperVKvpReportingHandlera  
Reports events to a Hyper-V host using Key-Value-Pair exchange protocol
and can be used to obtain high level diagnostic information from the host.

To use this facility, the KVP user-space daemon (hv_kvp_daemon) has to be
running. It reads the kvp_file when the host requests the guest to
enumerate the KVP's.

This reporter collates all events for a module (origin|name) in a single
json string in the dictionary.

For more information, see
https://technet.microsoft.com/en-us/library/dn798287.aspx#Linux%20guests
i   i   i   Ú
CLOUD_INIT)r0   ÚmsgÚresultÚmsg_iz/var/lib/hyperv/.kvp_pool_1FNc                ó.  <€ \         \        V `  4        Wn        \        P	                  V P                  4       W n        \        P                  ! 4       V n        V P                  4       V n
        R P                  V P                  V P                  4      V n        V P                  V n        \         P"                  ! 4       V n        \         P&                  ! V P(                  R7      V n        RV P*                  n        V P*                  P/                  4        R# )z{0}|{1}rX   TN)r-   rˆ   r.   Ú_kvp_file_pathÚ_truncate_guest_pool_fileÚ_event_typesrc   rd   ÚqÚ_get_incarnation_noÚincarnation_noÚformatÚEVENT_PREFIXÚevent_key_prefixÚ	ZERO_GUIDÚ_vm_idre   ÚLockÚ_vm_id_lockrf   Ú_publish_event_routineÚpublish_threadri   rj   )r   Úkvp_file_pathÚevent_typesr:   s   &&&€r   r.   Ú"HyperVKvpReportingHandler.__init__È   sÒ   ø€ ÜÔ'¨Ñ7Ô9Ø+ÔÜ!×;Ñ;Ø×Ñô	
ð (ÔÜ#Ÿkšk›mˆŒØ"×6Ñ6Ó8ˆÔØ )× 0Ñ 0Ø×Ñ˜t×2Ñ2ó!
ˆÔð —n‘nˆŒÜ$Ÿ>š>Ó+ˆÔä'×.Ò.Ø×.Ñ.ô
ˆÔð &*ˆ×ÑÔ"Ø×Ñ×!Ñ!Ö#r   c                óÜ  € V P                   '       d   R# \        P                  ! 4       \        \        P                  ! 4       4      ,
          p \
        P                  P                  V4      V8  d    \        VR4      ;_uu_ 4         RRR4       M RV n         R#   + '       g   i     L; i  \        \        3 d!   p\        P                  RT4        Rp?LHRp?ii ; i  RT n         i ; i)a¾  
Truncate the pool file if it has not been truncated since boot.
This should be done exactly once for the file indicated by
KVP_POOL_FILE_GUEST constant above. This method takes a filename
so that we can use an arbitrary file during unit testing.
Since KVP is a best-effort telemetry channel we only attempt to
truncate the file once and only if the file has not been modified
since boot. Additional truncation can lead to loss of existing
KVPs.
NÚwz$failed to truncate kvp pool file, %sT)Ú_already_truncated_pool_fileÚtimeÚfloatr
   ÚuptimeÚosÚpathÚgetmtimeÚopenÚOSErrorÚIOErrorr5   r6   )ÚclsÚkvp_fileÚ	boot_timery   s   &&  r   r�   Ú3HyperVKvpReportingHandler._truncate_guest_pool_fileß   s­   € ð ×+×+Ð+ÙÜ—I’I“K¤%¬¯ª«Ó"6Õ6ˆ	ð	4Ü�w‰w×Ñ Ó)¨IÔ5Ü˜( C×(Õ(Ø÷ )Ð(ð 6ð 04ˆCÖ,÷ )×(ûäœÐ!ô 	CÜ�K‰KÐ>À×BÑBûð	Cûð 04ˆCÕ,úsT   Á8B. ÂBÂB. ÂC" ÂB+	Â&B. Â*C" Â+B. Â.CÂ?CÃC" ÃCÃC" Ã"	C+c                óÚ   € \         P                  ! 4       p \        \        P                  ! 4       \	        V4      ,
          4      #   \
         d    \        P                  RT4        ^ # i ; i)z 
use the time passed as the incarnation number.
the incarnation number is the number which are used to
distinguish the old data stored in kvp and the new data.
z"uptime '%s' not in correct format.)r
   r¥   r0   r£   r¤   Ú
ValueErrorr5   r6   )r   Ú
uptime_strs   & r   r’   Ú-HyperVKvpReportingHandler._get_incarnation_no÷   sP   € ô —[’[“]ˆ
ð	Ü”t—y’y“{¤U¨:Ó%6Õ6Ó7Ð7øÜô 	Ü�K‰KÐ<¸jÔIÚð	ús   —-A Á!A*Á)A*c                óz  € V P                   ;_uu_ 4        V P                  V P                  8X  d5    \        P                  ! R4      pV'       d   VP                  4       V n        V P                  uuRRR4       #   \         d!   p\        P                  RT4        Rp?L<Rp?ii ; i  + '       g   i     R# ; i)z…Get vm_id, with DMI system-uuid fallback.

If vm_id hasn't been set explicitly, falls back to reading
the system-uuid from DMI data.
zsystem-uuidz(Failed reading system-uuid for vm_id: %sN)	rš   r˜   r—   r   Úread_dmi_dataÚlowerr4   r5   r}   )r   Úsystem_uuidry   s   &  r   Úvm_idÚHyperVKvpReportingHandler.vm_id  sŒ   € ð ××ÓØ�{‰{˜dŸn™nÔ,ðMÜ"%×"3Ò"3°MÓ"B�Kß"Ø&1×&7Ñ&7Ó&9˜œð —;‘;÷ Òøô !ô MÜ—I‘IÐHÈ!×LÑLûðMú÷ ×Ðús:   •B)²A;ÁA;Á%B)Á;B&ÂB!ÂB)Â!B&Â&B)Â)B:	c                ót   € V P                   ;_uu_ 4        Wn        RRR4       R#   + '       g   i     R# ; i)zSet vm_id directly.N)rš   r˜   )r   Úvalues   &&r   r¸   r¹     s$   € ð ××ÓØŒK÷ ××Òús   •&¦7	c              #  ó  "  € \        V P                  R4      ;_uu_ 4       p\        P                  ! V\        P                  4       VP                  V4       VP                  V P                  4      p\        V4      V P                  8X  d3   V P                  V4      pVx € VP                  V P                  4      pKL  \        P                  ! V\        P                  4       RRR4       R#   + '       g   i     R# ; i5i)z-iterate the kvp file from the current offset.ÚrbN)r©   rŽ   ÚfcntlÚflockÚLOCK_EXÚseekÚreadÚHV_KVP_RECORD_SIZEÚlenÚ_decode_kvp_itemÚLOCK_UN)r   ÚoffsetÚfÚrecord_dataÚkvp_items   &&   r   Ú_iterate_kvpsÚ'HyperVKvpReportingHandler._iterate_kvps  s§   é € ä�$×%Ñ% t×,Ô,°Ü�KŠK˜œ5Ÿ=™=Ô)Ø�F‰F�6ŒNØŸ&™& ×!8Ñ!8Ó9ˆKÜ�kÓ" d×&=Ñ&=Ô=Ø×0Ñ0°Ó=�Ø’ØŸf™f T×%<Ñ%<Ó=’Ü�KŠK˜œ5Ÿ=™=Ô)÷ -×,×,Ò,üs   ‚D¡CC.Ã$
DÃ.C?	Ã9	Dc                ó¢   € RP                  V P                  VP                  VP                  V P                  \
        P                  ! 4       4      # )zu
the event key format is:
CLOUD_INIT|<incarnation number>|<event_type>|<event_name>|<vm_id>
|<uuid>[|subevent_index]
z{0}|{1}|{2}|{3}|{4})r”   r–   rB   rC   r¸   ÚuuidÚuuid4r   s   &&r   Ú
_event_keyÚ$HyperVKvpReportingHandler._event_key'  s@   € ð %×+Ñ+Ø×!Ñ!Ø×ÑØ�J‰JØ�J‰JÜ�JŠJ‹Ló
ð 	
r   c                ó¬   € \         P                  ! R V P                  V P                  3,          VP	                  R4      VP	                  R4      4      pV# )z%ds%dsúutf-8)ÚstructÚpackÚHV_KVP_EXCHANGE_MAX_KEY_SIZEÚHV_KVP_EXCHANGE_MAX_VALUE_SIZEÚencode©r   Úkeyr»   rp   s   &&& r   Ú_encode_kvp_itemÚ*HyperVKvpReportingHandler._encode_kvp_item5  sP   € Ü�{Š{Øà×1Ñ1Ø×3Ñ3ðõð
 �J‰J�wÓØ�L‰L˜Ó!ó
ˆð ˆr   c                óT  € \        V4      pW P                  8w  d%   \        R P                  W P                  4      4      hV^ V P                   P                  R4      P                  R4      pVV P                  V P                   P                  R4      P                  R4      pRVRV/# )z$record_data len not correct {0} {1}.rÓ   Ú rÚ   r»   )rÄ   rÃ   r   r”   rÖ   ÚdecodeÚstrip)r   rÉ   Úrecord_data_lenÚkÚvs   &&   r   rÅ   Ú*HyperVKvpReportingHandler._decode_kvp_itemA  sª   € Ü˜kÓ*ˆØ×5Ñ5Ô5Ü!Ø6×=Ñ=Ø#×%<Ñ%<óóð ð ˜˜D×=Ñ=Ð>ß‰V�G‹_ß‰U�6‹]ð 	
ð Ø×1Ñ1°D×4KÑ4Kð÷ ‰V�G‹_ß‰U�6‹]ð 	
ð �q˜' 1Ð%Ð%r   c           	     óò  € \         P                  ! R V P                   24      ;_uu_ 4        \        V P                  R4      ;_uu_ 4       p\        P
                  ! V\        P                  4       V F  pVP                  V4       K  	  VP                  4        \        P
                  ! V\        P                  4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)z
Appending ÚabN)
r   ÚTimedrŽ   r©   r¾   r¿   rÀ   Úwriter!   rÆ   )r   rÉ   rÈ   rp   s   &&  r   Ú_append_kvp_itemÚ*HyperVKvpReportingHandler._append_kvp_itemX  s¢   € Ü×Ò ¨D×,?Ñ,?Ð+@ÐA×BÕBÄDØ×Ñ ÷E
ô E
àÜ�KŠK˜œ5Ÿ=™=Ô)Û#�Ø—‘˜–ñ $à�G‰GŒIÜ�KŠK˜œ5Ÿ=™=Ô)÷E
×BÑB÷ E
÷ E
ú×B×BÐBús$   ¬C%ÁA5C	Ã C%ÃC"ÃC%Ã%C6	c           	     ód  € W P                    \        P                  ! V4      pV^\        V4      ^,
           p^ p. pRV P                   ,           R,           p WRV P                  &   RW P                   &   \        P                  ! W P
                  R7      pV P                  \        V4      ,
          ^,
          p	VP                  VRP                  V P                   VRV	 R7      4      p
RP                  W4      pVP                  V P                  Wº4      4       V^,          pWIR pV'       d   KÙ   V# )	é   Ú"z":""Ú ©Ú
separatorsz"{key}":"{desc}"N)rÚ   Údescz{}|{})ÚMSG_KEYr   r€   rÄ   ÚDESC_IDX_KEYÚJSON_SEPARATORSÚHV_KVP_AZURE_MAX_VALUE_SIZEÚreplacer”   ÚappendrÛ   )r   rÚ   Ú	meta_dataÚdescriptionÚdes_in_jsonÚiÚresult_arrayÚmessage_place_holderÚdata_without_descÚroom_for_descr»   Úsubkeys   &&&&        r   Ú_break_downÚ%HyperVKvpReportingHandler._break_downb  s%  € Ø—l‘lÐ#Ü—j’j Ó-ˆØ! !¤s¨;Ó'7¸!Õ';Ð=ˆØˆØˆØ" T§\¡\Õ1°FÕ:ÐØØ+,�d×'Ñ'Ñ(Ø&(ˆI—l‘lÑ#Ü $§
¢
Ø×&:Ñ&:ô!Ðð ×0Ñ0´3Ð7HÓ3IÕIÈAÕMð ð &×-Ñ-Ø$Ø"×)Ñ)ØŸ™¨;°~¸Ð+Fð *ó óˆEð —^‘^ CÓ+ˆFØ×Ñ × 5Ñ 5°fÓ DÔEØ��FˆAØ% nÐ5ˆKß‘;ØØÐr   c                ó*   <€ V ^8„  d   QhRS[ RS[ RR/# )é   rÚ   r»   ÚreturnN)Ústr)r”   r(   s   "€r   Ú__annotate__Ú&HyperVKvpReportingHandler.__annotate__€  s'   ø€ ÷ Fñ F™Sð F©ð F°ñ Fr   c                ó
  € \        V4      V P                  8¼  d   V^ V P                  ^,
           pV P                  W4      .p V P                  V4       R#   \        \
        3 d    \        P                  RY4        R# i ; i)z:Write KVP key-value.

Values will be truncated as needed.
zfailed posting kvp=%s value=%sN)rÄ   rõ   rÛ   ré   rª   r«   r5   r6   rÙ   s   &&& r   Ú	write_keyÚ#HyperVKvpReportingHandler.write_key€  sy   € ô
 ˆu‹:˜×9Ñ9Ô9Ø˜!˜d×>Ñ>ÀÕBÐCˆEà×%Ñ% cÓ1Ð2ˆð	FØ×!Ñ! $Ö'øÜœÐ!ô 	FÜ�K‰KÐ8¸#×Eð	Fús   ÁA Á'BÂBc           	     ó€  € V P                  V4      pRVP                  RVP                  R\        P                  ! VP
                  \        P                  4      P                  4       /p\        WP                  4      '       d   VP                  W0P                  &   \        VR4      '       d   VP                  VR&   VP                  W0P                  &   \        P                   ! W0P"                  R7      p\%        V4      V P&                  8”  d   V P)                  W#VP                  4      # V P+                  W$4      pV.# )zŽ
encode the event into kvp data bytes.
if the event content reaches the maximum length of kvp value.
then it would be cut to multiple slices.
rC   ÚtypeÚtsÚdurationrï   )rÐ   rC   rB   r   ÚfromtimestampÚ	timestampr   ÚutcÚ	isoformatÚhasattrÚ
RESULT_KEYr‹   r  rù   rò   r   r€   rô   rÄ   rõ   r  rÛ   )r   r   rÚ   rø   r»   rp   s   &&    r   Ú_encode_eventÚ'HyperVKvpReportingHandler._encode_event�  sø   € ð �o‰o˜eÓ$ˆà�E—J‘JØ�E×$Ñ$ØÜ×&Ò&Ø—O‘O¤X§\¡\óç‘)“+ð
ˆ	ô �5Ÿ/™/×*Ò*Ø).¯©ˆI—o‘oÑ&Ü�5˜*×%Ò%Ø$)§N¡NˆI�jÑ!Ø"'×"3Ñ"3ˆ	—,‘,ÑÜ—
’
˜9×1EÑ1EÔFˆô ˆu‹:˜×8Ñ8Ô8Ø×#Ñ# C°E×4EÑ4EÓFÐFà×(Ñ(¨Ó4ˆDØ�6ˆMr   c                óˆ  €  ^ p V P                   P                  R R7      pV^,          p. pVe@   W0P                  V4      ,          p V P                   P                  RR7      pV^,          pKC   V P                  V4       \        V4       F  pV P                   P                  4        K  	  K®    \        P                   d    Rp K�  i ; i  \        \        3 d!   p\        P                  RT4        Rp?LxRp?ii ; i  \        T4       F  pT P                   P                  4        K  	  i ; i  \         d     R# i ; i)Trn   NFz failed posting events to kvp, %s)r‘   rv   r  rc   ÚEmptyré   rª   r«   r5   r6   Úrangeru   ÚEOFError)r   Úitems_from_queuer   Úencoded_datary   Ú_s   &     r   r›   Ú0HyperVKvpReportingHandler._publish_event_routine®  s   € ØØ ÐðØŸ™Ÿ
™
¨˜
Ó.�Ø  AÕ%Ð Ø!�ØÒ'Ø ×$6Ñ$6°uÓ$=Õ=�Lð%à $§¡§
¡
° 
Ó 7˜Ø(¨AÕ-Ò(ð+Ø×)Ñ)¨,Ô7ô #Ð#3Ö4˜ØŸ™×(Ñ(Ö*ó 5øô !Ÿ;™;ô %Ø $›ð%ûô  ¤Ð)ô GÜ—K‘KÐ BÀA×FÑFûðGûô #Ð#3Ö4˜ØŸ™×(Ñ(Ö*ò 5ûô ô Úðúsl   …AD2 Á%B/ Á-D2 Á0C Â,D2 Â/C
ÃD2 Ã	C
Ã
D2 ÃC>ÃC9Ã4D Ã9C>Ã>D Ä.D/Ä/D2 Ä2EÅ Ec                óš   € V P                   '       d   VP                  V P                   9   d   V P                  P                  V4       R # R # rN   )r�   rB   r‘   r~   r   s   &&r   r   Ú'HyperVKvpReportingHandler.publish_eventÌ  s7   € Ø× × Ð  E×$4Ñ$4¸×8IÑ8IÔ$IØ�F‰F�J‰J�uÖñ %Jr   c                ód   € \         P                  R 4       V P                  P                  4        R# )z0HyperVReportingHandler flushing remaining eventsN)r5   r}   r‘   rA   r    s   &r   r!   ÚHyperVKvpReportingHandler.flushÐ  s   € Ü�	‰	ÐDÔEØ�‰�‰Žr   )r�   rŽ   r˜   rš   r–   r“   rœ   r‘   )Ú,Ú:))r   r   r   r   r#   r×   rõ   rÖ   rÃ   r•   r  rÎ   ÚUUIDr—   rò   r  ró   rô   ÚKVP_POOL_FILE_GUESTr¢   r.   Úclassmethodr�   r’   Úpropertyr¸   ÚsetterrË   rÐ   rÛ   rÅ   ré   r  r
  r  r›   r   r!   r   r&   rI   rJ   s   @@r   rˆ   rˆ   ¨   sø   ù‡ € ñð &*Ð"à"&ÐØ#&Ð à$Ð'EÕEð ð  €LÙ�D—I’I !Ô$Ó%€IØ€GØ€JØ€LØ €OØ7ÐØ#(Ð à%8Àd÷ $ð. ñ4ó ð4ò.ð ñó ðð  ‡\�\ñ ó ð ò

*ò
ò
ò&ò.*ò÷<Fð Fòò>ò<÷ò r   rˆ   rD   rO   ÚwebhookÚhyperv)$r$   r¾   r   r2   r¦   rc   rÔ   re   r£   rÎ   r   r   r   Útypingr   r>   r   r   r	   r
   Úcloudinit.registryr   r@   r   r5   r4   r   ÚABCMetar   r+   rL   rR   rˆ   ÚHandlerTypeÚavailable_handlersÚregister_itemr   r   r   Ú<module>r3     s  ðó Û Û Û Û 	Û Û Û Û Û ß 'Ý Ý ç 8Ó 8Ý +à×Ò˜Ó!€ô	�iô 	ô? §¡õ ?ô2Ð!ô 2ô.!Ð#ô !ô]%Ð%ô ]%ô@jÐ 0ô jð^	 ØØØØØð	õ€ñ "“^Ð Ø ×  Ñ   ¨
Ô 3Ø ×  Ñ   ¨,Ô 7Ø ×  Ñ   ¨NÔ ;Ø ×  Ñ   Ð+DÖ Er   