a ì)gµ-ã @s<ddlmZmZmZeZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZmZe jddkZe de j e¡¡e ejdd e jdd…¡¡e ¡\ZZ d a!d d „Z"dd d „Z#dd„Z$dd„Z%dd„Z&dd„Z'dd„Z(dd„Z)dd„Z*e+dkr8e*ƒdS)é)Úabsolute_importÚdivisionÚprint_functionN)Úto_textÚto_byteséz ansible-%szInvoked with %sú éÚcCst tj|¡dS©N)ÚsyslogÚ LOG_NOTICE)Úmsg©rúA/usr/lib/python3.9/site-packages/ansible/modules/async_wrapper.pyÚnotice$srcCs.|durtt |¡ƒtj ¡t |¡dSr )ÚprintÚjsonÚdumpsÚsysÚstdoutÚflushÚexit)ÚresZexit_msgrrrÚend(s rcCszt ¡}|dkrtƒWn:tyTt ¡d}td|j|jfddœdƒYn0t ¡t  t ddƒ¡zt ¡}|dkr†tƒWn:tyÂt ¡d}td|j|jfddœdƒYn0t d d ƒ}t  |  ¡tj  ¡¡t  |  ¡tj  ¡¡t  |  ¡tj  ¡¡dS) Nrr zfork #1 failed: %d (%s) T)rÚfailedZ022ézfork #2 failed: %d (%s) z /dev/nullÚw)ÚosÚforkrÚOSErrorrÚexc_infoÚerrnoÚstrerrorÚsetsidÚumaskÚintÚopenÚdup2ÚfilenoÚstdinrÚstderr)ÚpidÚeZdev_nullrrrÚdaemonize_self/s(   "   " r.cCsÊg}| ¡}t|ƒD]\}}| ¡}| d¡rq¦óz_run_module..F)Úshellr*rr+zutf-8Úsurrogateescaper=r+)rÚcmdrÚoutdatar+rX)rr`r<r+r)rUÚ ipc_notifierÚsendrRÚshlexrHrJÚ subprocessÚPopenÚPIPEZ communicateÚPY3ÚdecoderArÚloadsÚgetÚ isinstanceÚlistÚextendr rPrr!rr6Ú ExceptionÚ tracebackÚ format_exc) Z wrapped_cmdÚjidÚresultraZfiltered_outdatar+r`Z interpreterZscriptZ json_warningsZmodule_warningsr-rrrÚ _run_module—sb  ÿ          û ûrtc CsHttjƒdkrtdddœdƒdtjdt ¡f}tjd}tjd}tjd }d tj |¡vrhd}n"ttjƒdkr†tjdd k}nd }|d kr d||f}n|}d}tj  dd¡}tj  |¡}tj  ||¡a z t |ƒWnLty(} z2tdd|t| ƒftt ¡ƒdœdƒWYd} ~ n d} ~ 00zÐt ¡} | ršt ¡d} | dkrtt d¡rdqtn | d} qHqHtdƒtddd|t | dœdƒn`t ¡tƒtdƒt ¡} | rÐt ¡t ¡t|ƒ} t | | ¡td| | fƒt |¡t | tj¡dkr¦td| | fƒt |¡| |} | dkrüdd| dœ}t|ƒtd| ƒt  | t!j"¡td| ƒt d¡|sšt# $tj |¡d¡t|ƒqütd ƒ|sÈt# $tj |¡d¡tƒn*td!t ¡ƒt%||ƒtd"t ¡ƒWnFtyB} z,td#| ƒtdd$| dœd%ƒWYd} ~ n d} ~ 00dS)&NéTzpusage: async_wrapper [-preserve_tmp] Humans, do not call directly!)rrr z%s.%drCréz-tmp-z -preserve_tmpFÚ_z%s %sZANSIBLE_ASYNC_DIRz~/.ansible_asyncz#could not create directory: %s - %s)rrÚ exceptionérgš™™™™™¹?z"Return async_wrapper task started.)rrVrWrXZ results_fileZ_ansible_suppress_tmpdir_deletezStarting module and watcherzStart watching %s (%s))rrz%s still running (%s)zTimeout exceeded)rrZ child_pidzTimeout reached, now killing %szSent kill to group %s zDone in kid B.zStart module (%s)zModule complete (%s)z error: %szFATAL ERROR: %sz async_wrapper exited prematurely)&r9rÚargvrrÚgetpidrLÚdirnameÚenvironrkÚ expanduserr;rNrMrorrprqrrbrRÚ ipc_watcherZpollrr.r&ÚsetpgidÚtimeÚsleepÚwaitpidÚWNOHANGrUÚkillpgÚsignalÚSIGKILLÚshutilÚrmtreert)rrZ time_limitZwrapped_moduleZargsfileZ preserve_tmpr`ÚstepZ async_dirZjobdirr-r,ZretriesZsub_pidZ remainingrrrrÚmainÜs¨þü      ýü     ÿÿ           r‹Ú__main__)Nr),Z __future__rrrÚtypeZ __metaclass__r"rrdrˆrrerrpr†rr ZmultiprocessingZansible.module_utils._textrrÚ version_inforhZopenlogrLÚbasenameÚ__file__r r;rzZPiperrbrNrrr.rArJrMrUrtr‹Ú__name__rrrrÚs>"  !( E