ó
oBú]c @ sÁ d d l Z d d l Z d d l Z d d l m Z m Z m Z d d l m Z d d l m Z
d d l m Z d d l m Z e
j
e ƒ Z d Z d Z d Z d
Z e e g Z d g Z d Z d
Z i
d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z e e e j ƒ ƒ d! d" „ ƒZ e j e j ƒ d# e f d$ „ ƒ Yƒ Z d% „ Z! d& „ Z" d' „ Z# d( „ Z$ d) „ Z% d* „ Z& d+ „ Z' d, „ Z( e d- „ Z) d d. „ Z+ d S(/ iÿÿÿÿN( t
PER_ALWAYSt PER_INSTANCEt FREQUENCIES( t importer( t log( t
type_utils( t utils text/x-not-multiparts application/octet-streamt __end__t __begin__s text/part-handlers part-handler-%03ds part-%03ds text/x-include-urls #includes text/x-include-once-urls
#include-onces text/x-shellscripts #!s text/cloud-configs
#cloud-configs text/upstart-jobs #upstart-jobs
#part-handlers text/cloud-boothooks #cloud-boothooks text/cloud-config-archives #cloud-config-archives text/cloud-config-jsonps #cloud-config-jsonps text/jinja2s ## template: jinjat keyc C s d t | ƒ S( Ni ( t len( t e( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt <lambda>< s t Handlerc B s8 e Z d d „ Z d „ Z d „ Z e j d „ ƒ Z RS( i c C s | | _ | | _ d S( N( t handler_versiont frequency( t selfR t version( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt __init__B s c C s d t j | ƒ | j ƒ f S( Ns %s: [%s]( R t obj_namet
list_types( R ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt __repr__F s c C sF t | d ƒ s t d ƒ ‚ n$ g t | d ƒ D] } t | ^ q. Sd S( Nt prefixess# Missing prefixes subclass attribute( t hasattrt NotImplementedErrort getattrt INCLUSION_TYPES_MAP( R t prefix( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyR I s c O s
t ƒ ‚ d S( N( R ( R t argst kwargs( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt handle_partQ s ( t __name__t
__module__R R R t abct abstractmethodR ( ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyR
? s c
C sV | j } | t k p* | t k o* | t k s1 d Sy | j } t | ƒ } Wn t t t f k
rl d } n X| d } y¨ t j d | | | | | ƒ | d k rÁ | j
| | | | | | ƒ n] | d k ré | j
| | | | | ƒ n5 | d k r| j
| | | | ƒ n t d | ƒ ‚ Wn0 t k
rQt j
t d | | | | | ƒ n Xd S( Ni s Content-Types1 Calling handler %s (%s, %s, %s) with frequency %si i s Unknown module version %ss8 Failed calling handler %s (%s, %s, %s) with frequency %s( R R R R t intt TypeErrort
ValueErrort AttributeErrort LOGt debugR t ExceptionR t logexc( t modt datat filenamet payloadR t headerst mod_freqt mod_vert content_type( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt run_partV s4
c C s* i t d 6} t | | d d | | ƒ d S( Ns Content-Type( t
CONTENT_STARTR3 t None( R+ R, R R/ ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt
call_beginx s
c C s* i t d 6} t | | d d | | ƒ d S( Ns Content-Type( t CONTENT_ENDR3 R5 ( R+ R, R R/ ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt call_end€ s
c
C sð | d } t | } | d } t j j | d d | ƒ } | j d ƒ sW d | } n t j | | d ƒ | d } yN t t j | ƒ ƒ } t
| | d | ƒ | j | d
t ƒ| d | d <Wn' t
k
rë t j t d | | ƒ n Xd S(
Nt handlercountR t
handlerdirs %ss .pys %s.pyi€ t handlersR, t initializedi s7 Failed at registering python file: %s (part handler %s)( t PART_HANDLER_FN_TMPLt ost patht joint endswithR t
write_filet
fixup_handlerR t
import_moduleR6 t registert TrueR) R* R' (
t pdatat _ctypet _filenameR. t curcountt modnameR t modfnameR; R+ ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt walker_handle_handlerˆ s
c C s yx t | t j ƒ r. | j d d ƒ d } n* | d | j d d ƒ j d d ƒ d } t | ƒ | k rw | | } n Wn t k
r˜ | d | !} n X| S( Ns
i i i t errorst ignore( t
isinstancet sixt string_typest splitt decodeR
t UnicodeDecodeError( t blobt sizet start( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt _extract_first_or_bytesž s *
c C sd y | j d ƒ SWnL t t f k
rO y | j d ƒ SWq` t k
rK q` Xn t k
r_ n X| S( Nt
string_escapet unicode_escape( t encodet LookupErrorR$ R& ( t text( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt _escape_string° s
c C s | d } | | j d ƒ k r3 t j d | ƒ d S| t k rV t | | | | ƒ d S| d } | | k r” t | | | d | | | d | ƒ nm | rñ t | d ƒ } d t | ƒ } | t k rÛ t j d | | ƒ qt j d
| | ƒ n t j d | ƒ d S( Ns Content-Typet excludeds content_type "%s" is excludedR; R, R i s '%s...'s) Unhandled non-multipart (%s) userdata: %ss0 Unhandled unknown content-type (%s) userdata: %ss Empty payload of type %s(
t getR' R( t PART_CONTENT_TYPESRM R3 RY R_ t NOT_MULTIPART_TYPEt warning( R, R- R. R/ R2 R; RX t details( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt walker_callback s(
c C sÈ d } x» | j ƒ D] } | j ƒ d k r1 q n | j ƒ } | d k rR t } n | j ƒ } | sq t | } n t | ƒ } t j | ƒ | | d <t
j | ƒ } | | | | | ƒ | d } q Wd S( Ni t multiparts Content-Typei ( t walkt get_content_maintypet get_content_typeR5 t
OCTET_TYPEt get_filenamet PART_FN_TPLt dictR' R( R t fully_decoded_payload( t msgt callbackR, t partnumt partt ctypeR- R/ R. ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyRh ß s
c C sy t | d ƒ s" t | d d ƒ n t | d ƒ sD t | d | ƒ n1 | j } | ru | t k ru t j d | | ƒ n | S( NR i R s& Handler %s has an unknown frequency %s( R t setattrR R R' Rd ( R+ t def_freqt freq( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyRC ö s c C sf y t j | ƒ j ƒ } Wn t k
r- | SX| j ƒ } x% t D] } | j | ƒ rA t | SqA W| S( N( R t
decode_binaryt lowerRU t lstript INCLUSION_SRCHt
startswithR ( R. t defaultt
payload_lcR^ ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt type_from_starts_with s
(, R! R> RQ t cloudinit.settingsR R R t cloudinitR R t loggingR R t getLoggerR R' Rc Rk R7 R4 t CONTENT_SIGNALSRb R= Rm R t sortedt listt keysR{ t
add_metaclasst ABCMetat objectR
R3 R6 R8 RM RY R_ Rf Rh RC R5 R ( ( ( s? /usr/lib/python2.7/site-packages/cloudinit/handlers/__init__.pyt <module> sR
"