o x[h@sPUddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z mZddlmZddlmZeeZdZe ed<dZe ed <ejd ejd ejd iZe e eefed <Gddde Z e dej!Z"e ed<e dej#Z$e ed<e"a%e&Z'deee dfddfddZ(ddZ)ddZ*ddZ+ej,ddZ-dS)N)StringIO)CallableDictFinal NamedTupleUnion)version)log_utilz#Cloud-init {} received {}, exiting SIG_MESSAGEBACK_FRAME_TRACE_DEPTHz/Cloud-init %(version)s received SIGINT, exitingz0Cloud-init %(version)s received SIGTERM, exitingz0Cloud-init %(version)s received SIGABRT, exitingSIGNALSc@seZdZUeed<eed<dS) ExitBehavior exit_code log_levelN)__name__ __module__ __qualname__int__annotations__rr:/usr/lib/python3/dist-packages/cloudinit/signal_handler.pyr s  rSIGNAL_EXIT_BEHAVIOR_CRASHSIGNAL_EXIT_BEHAVIOR_QUIETsigreturncCst|rt|tjstd|dSdS|tjkr tddS|dur+tddS|tjkr8td|dSt dt ||dS)z+inspect_handler() logs signal handler statez.Signal state [%s] - previously custom handler.z,Signal state [SIG_IGN] - previously ignored.Nz;Signal state [None] - previously not installed from Python.zISignal state [%s] - default way of handling signal was previously in use.zSignal state [%s(%s)] - unknown) callable isinstancetypesBuiltinFunctionTypeLOGinfosignalSIG_IGNSIG_DFLwarningtype)rrrrinspect_handler+s   r(cCsz||ks|sdSt|}d|d}|d||jf|d||jf|d||jft|j|d||dS)N z%sFilename: %s z%sFunction: %s z%sLine number: %s r)inspect getframeinfowritefilenamefunctionlineno _pprint_framef_back)framedepth max_depthcontents frame_infoprefixrrrr1Bs   r1cCs^t|tjr |jn|}ttt|}t |dt |t j | ttjdttjdS)Nr)logr)rr#Signalsnamerr formatvrversion_stringr1r r multi_loggetvaluer!_SIGNAL_EXIT_BEHAVIORrsysexitr)signumr3r;r6rrr _handle_exitMs rEcCs2d}tD] }tt|tq|tt7}|S)zattach cloud-init's handlersr)r keysr(r#rElen) sigs_attachedrDrrrattach_handlersXs   rIccs:ttadVtaWddS1swYdS)a$suspend_crash() allows signals to be received without exiting 1 This allow signal handling without a crash where it is expected. The call stack is still printed if signal is received during this context, but the return code is 0 and no traceback is printed. Threadsafe. N)_SUSPEND_WRITE_LOCKrrArrrrr suspend_crashas "rK). contextlibr+loggingr#rB threadingriortypingrrrrr cloudinitrr= cloudinit.logr getLoggerrr!r rr SIGINTSIGTERMSIGABRTr rstrrERRORrINFOrrARLockrJr(r1rErIcontextmanagerrKrrrrs: