Vh](ddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZmZddZdZdZdZdd Zd Zd Zd Zd Zy)) annotationsN)PY2b)to_bytesto_textc|rgtjjds$tt jd|d|Stt jd|d|Stjjds!tt jd|zStt jd|zS)z This function will check if the service name supplied is enabled in any of the sysv runlevels :arg name: name of the service to test for :kw runlevel: runlevel to check (default: None) z /etc/rc0.d/z/etc/init.d/rcz.d/S??z/etc/rcz/etc/init.d/rc?.d/S??%sz/etc/rc?.d/S??%s)ospathisdirboolglob)namerunlevels L/home/dcms/DCMS/lib/python3.12/site-packages/ansible/module_utils/service.pysysv_is_enabledr,sww}}]+ $"OPQ QDIIXtDEFFww}}]+ ";d"BCD DDII047899c:|jdr|}|Sd|z}|S)z This function will return the expected path for an init script corresponding to the service name supplied. :arg name: name or path of the service to test for /z/etc/init.d/%s) startswith)rresults rget_sysv_scriptr>s- s M"D( MrcRtjjt|S)z This function will return True or False depending on the existence of an init script corresponding to the service name supplied. :arg name: name of the service to test for )r r existsr)rs r sysv_existsrMs 77>>/$/ 00rcd}tjdk(rd}nd}|jdd}|j||g\}}}|dk(r|j D] }||vsd}|S|S)zX Last resort to find a service by trying to match pattern to programs in memory FSunOS-efauxwwpsTr)platformsystem get_bin_path run_command splitlines) modulepatternfoundflagspsbinrcpsoutpserrlines rget_psr.Ws EG#   d +E++UEN;R Qw$$& D$ L   Lrc:|s|jd|d|yy)a{ This function will return an error or exit gracefully depending on check mode status and if the service is missing or not. :arg module: is an AnsibleModule object, used for it's utility methods :arg found: boolean indicating if services were found or not :arg service: name of service :kw msg: extra info to append to error/success msg when missing z%Could not find the requested service z: msgN) fail_json)r%r'servicer1s rfail_if_missingr4ls# gWZ[\ rcdtj}|dk(rtjtjtj}t dD]}||k7s tj || |t dvrtj|tj}|dkDrtjdtj}|dk(r tdtjdtj}|dkDrtjd|S)zk This function performs the double fork process to detach from the parent process and execute. rz*Unable to detach session while daemonizingr) r forkopendevnullO_RDWRrangedup2close_exitsetsid Exceptionchdir)pidfdnumsids r fork_processrGzs '')C ax WWRZZ +8 !CSyC  ! U1X  HHRLggi 7 HHQKiik "9HI I  ggi 7 HHQK Jrcd}d} tjt}dk(rqtjdt|tsGtr!tjt||}n tjt||}g}|D]}|j!t|| t#j$|dt"j&t"j&fd  }|j(|j*g} |j(t-d |j*t-d i} | rt/j.| g| d \} } } | | z| zs|j1ft| D]W}|| vstj2|j5|}|r| |xxt||z cc<G| j7|Ynn| r|j9t;j<|j>t| |j(t| |j*gt:j@ }tjBd t||tjd tjDdy|dk(r|j dytjd tjF|dt-d } t/j.dggdg\} } } d| vr,tj2d|}|sn|t||z }Wt;jHt||S#t$r)|j dt j Yqt$r9}|j t|t j Yd}~d}~wwxYw)a Execute a command while detaching as a daemon, returns rc, stdout, and stderr. :arg module: is an AnsibleModule object, used for it's utility methods :arg cmd: is a list or string representing the command and options to run This is complex because daemonization is hard for people. What we do is daemonize a part of this module, the daemon runs the command, picks up the return code and output, and returns it to the main process. isurrogate_or_strictz"Error while attempting to fork: %s)r1 exceptionNr)errorsFc4tjdS)N)r r>)pipesrzdaemonize..s*vxv~v~@DEF@GwHr)shellstdoutstderr preexec_fnrM)protocolr7zSUnable to fork, no exception thrown, probably due to lack of resources, check logs.r0)%r rNrGOSErrorr2 traceback format_excrArr> isinstancelistrshlexsplitrappend subprocessPopenPIPErQrRrselectpollreadfilenoremovewaitpickledumps returncodeHIGHEST_PROTOCOLwriter?waitpidloads)r%cmdchunkrKrCexcrun_cmdcpfdsoutputrfdwfdefdoutdata return_datarNs @r daemonizer|s= E "FMwwyn ax a#t$kk(3v">?kk'#f"=> 7A NN8Af5 6 7   WE*//R\RaRaoH Ixx"((AbE188QrU3"MM#r3:MCcc CAFFH$49,Ccz!wwszz|U;"3K8D+HHKJJsO , llALL'&:J2KWU[\]\d\dUeMf#grxsJsJK  a(;v>? a  rs a 3e "MM47)R$q'CMCcAw#~wwtAw.xV<< ||H[@AAQ eAYMaMaMcd MWS\Y5I5I5KLLMsM%%.OO.OOctjdk(rd}nd}|jdd}|j|d|\}}}|dk(r|j dD]}||vsyy ) NrrrrT r F)r r!r"r#r\)r%r&psflagsr)r*ryerrr-s rcheck_psrsyG#   d +E''5'(BCNRc QwIIdO D$  rc |jdrbdD]#}tjj|s#y t dd5}|j j }|dk(cdddSy#1swYyxYw#t$rYywxYw) z Find out if the machine supports systemd or not :arg module: is an AnsibleModule object, used for it's utility methods Returns True if the system supports systemd, False if not. systemctl)z/run/systemd/system/z/dev/.run/systemd/z/dev/.systemd/Tz /proc/1/commrsystemdNF)r"r r rr9readlinestripIOError)r%canary init_procinits ris_systemd_managedrs;'W Fww~~f%   nc* )i ))+113y( ) )  )    s/ B#A5* B5A>:B>B B  B )N)rT) __future__rr r rgr rar[r^rWansible.module_utils.sixrr+ansible.module_utils.common.text.convertersrrrrrr.r4rGr|rrrrrsZ:#  +I:$ 1* ]'T\B~(r