VhddlmZmZmZeZdZddlZddlZddl Z ddl Z ddl m Z ddlmZddlmZddlmZddlmZdd lmZmZdd lmZeZGd d eZy) )absolute_importdivisionprint_functiona --- author: - Michael Scherer (@mscherer) name: libvirt_lxc short_description: Run tasks in lxc containers via libvirt description: - Run commands or put/fetch files to an existing lxc container using libvirt. options: remote_addr: description: - Container identifier. default: The set user as per docker's configuration vars: - name: ansible_host - name: ansible_libvirt_lxc_host libvirt_lxc_noseclabel: description: - "This setting causes libvirt to connect to LXC containers by passing ``--noseclabel`` parameter to ``virsh`` command." - This is necessary when running on systems which do not have SELinux. default: False version_added: '1.4.0' type: boolean ini: - section: selinux key: 'libvirt_lxc_noseclabel' env: - name: ANSIBLE_LIBVIRT_LXC_NOSECLABEL vars: - name: ansible_libvirt_lxc_noseclabel N) constants) AnsibleError) shlex_quote) get_bin_path)to_bytes)ConnectionBaseBUFSIZE)DisplayceZdZdZdZdZdZdZfdZdZ dZ fd Z e jfd Zdfd Zd Zfd ZfdZfdZxZS) Connectionz Local lxc based connections zcommunity.general.libvirt_lxcTrootFctt| ||g|i||jj|_|j d|_|j|j y)Nvirsh) superr__init__ _play_context remote_addrlxc_search_executabler _check_domain)self play_context new_stdinargskwargs __class__s t/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/libvirt/plugins/connection/libvirt_lxc.pyrzConnection.__init__FsU j$(yR4R6R%%11,,W5  488$cP t|S#t$rtd|zwxYw)Nz%s command not found in PATH)r ValueErrorr)r executables r rzConnection._search_executableNs5 L + + L=>K K Ls %c tj|jddddt|gtjtj}|j |j rtd|zy)N-q-clxc:///dominfo)stdoutstderrz"%s is not a lxc defined in libvirt) subprocessPopenrr PIPE communicate returncoder)rdomainps r rzConnection._check_domainTs_   djj$iHU[L\]$.OOJOO M  <<CfLM M r!ctt| |js)tj d|j d|_yy)z( connect to the lxc; nothing to do here zTHIS IS A LOCAL LXC DIRhostTN)rr_connect _connecteddisplayvvvrrrs r r6zConnection._connect[s8 j$(* KK1K A"DOr!ctjr!tjjdnd}|jddddg}|j dr|dgz }||j d |d|gz }t jd ||j |Dcgc]}t|d }}tj|d|tjtj}|Scc}w)a/ run a command on the chroot. This is only needed for implementing put_file() get_file() so that we don't have to read the whole file into memory. compared to exec_command() it looses some niceties like being able to return the process's exit code immediately. rz/bin/shr&r'r(zlxc-enter-namespacelibvirt_lxc_noseclabelz --noseclabelz--zEXEC r4surrogate_or_stricterrorsF)shellstdinr*r+) CDEFAULT_EXECUTABLEsplitr get_optionrr8r9r r,r-r.)rcmdrAr$ local_cmdir2s r _buffered_exec_commandz!Connection._buffered_exec_commandbs9:8L8LQ))//1!4R[ ZZtY8MN ??3 4 .) )Idhhj$<<  ,488 R R   Ye5$.OOJOO M SsC&ctt| ||||j|}|j |\}}|j ||fS)z run a command on the chroot )in_datasudoable)rr exec_commandrIr/r0)rrFrKrLr2r*r+rs r rMzConnection.exec_commandysL j$,S'H,U  ' ' ,w/ ff--r!c|jtjjs8tjj tjj|}tjj |S)a Make sure that we put files into a standard path If a path is relative, then we need to choose where to put it. ssh chooses $HOME but we aren't guaranteed that a home dir will exist in any given chroot. So for now we're choosing "/" instead. This also happens to be the former default. Can revisit using $HOME instead if it's a problem ) startswithospathsepjoinnormpath)r remote_paths r _prefix_login_pathzConnection._prefix_login_pathsK%%bggkk2'',,rww{{K@Kww ,,r!c tt| ||tj d|d||j t |j|} tt|dd5}tj|jjsd}nd} |jd |d t|| } |j%\}}|j,dk7rt#d |d|d|d| dddy#t $r t#d wxYw#t&$r&t)j*t#d |d|wxYw#1swYyxYw#t.$rt#d|zwxYw)z# transfer a file from local to lxc zPUT  TO r4r=r>rbz count=0zdd of= bs=)rA3chroot connection requires dd command in the chrootfailed to transfer file  to r:  Nz$file or module does not exist at: %s)rrput_filer8r9rrrVopenr rPfstatfilenost_sizerIr OSErrorrr/ Exception traceback print_excr0IOError) rin_pathout_pathin_filecountr2r*r+rs r razConnection.put_filesu j$((; gx8txx Ht66x@A Qhw/DEtL zPWxx 0199&EE^33(T[]b4ckr3sAa%&]]_NFF<<1$&V]_gioqw'xyy% z z^&'\]]^!a'')&WV^'_``a z z  QEOP P QsTE/3E#DD&E=EDE/E  EEEEE4c tt| ||tj d|d||j t |j|} |jd|dt}tt|dd 5} |jjt}|r3|j!||jjt}|r3|j)\}}|j*d k7rtd |d |d |d| dddy#t$r tdwxYw#t"$r&t%j&td |d |wxYw#1swYyxYw)z fetch a file from lxc to local zFETCH rXr4zdd if=r[r\r=r>zwb+r]r^rr_r`N)rr fetch_filer8r9rrrVrIr rfrrbr r*readwritergrhrir/r0) rrkrlr2out_filechunkr*r+rs r rpzConnection.fetch_filesX j$*7H= : Jd55g>? V++,QRA(8,ABE J vh ] g.NN5)HHMM'2E ]]_NFF||q "RY[cekms#tuu! v v VTU U V ]##%"RZ#[\\ ] v vs1D# E- AD; 9E-#D8;/E**E--E6c8tt| d|_y)z. terminate the connection; nothing to do here FN)rrcloser7r:s r rvzConnection.closes j$%'r!)NF)__name__ __module__ __qualname____doc__ transporthas_pipelining default_userhas_ttyrrrr6r,r.rIrMrVrarprv __classcell__)rs@r rr;s`'/INLG%L N#1;.. -Q4v0  r!r) __future__rrrtype __metaclass__ DOCUMENTATIONrPos.pathr,rhansiblerrBansible.errorsransible.module_utils.six.movesr#ansible.module_utils.common.processr ansible.module_utils._textr ansible.plugins.connectionr r ansible.utils.displayr r8rr!r rsSCB  @ "'6</>) )J J r!