B `G0@sBdZddlmZmZmZeZddlZddlZddl Z ddl m Z m Z ddl mZmZmZmZmZddlmZddlmZdd lmZd Zd d Zd dZddZddZddZddZddZ ddZ!ddZ"ddZ#dd Z$d8d!d"Z%d#d$Z&d%d&Z'd'd(Z(d)d*Z)d+d,Z*d9d.d/Z+d0d1Z,d2d3Z-d:d4d5Z.d6d7Z/dS);z2Functions for accessing docker via the docker cli.)absolute_importdivisionprint_functionN)open_binary_fileread_text_file)ApplicationErrorcommon_environmentdisplayfind_executableSubprocessError)urlparse) run_command)EnvironmentConfigicCs tdddS)z :rtype: bool dockerF)required)r rrQ/home/dcms/DCMS/lib/python3.7/site-packages/ansible_test/_internal/docker_util.pydocker_available%srcCsytjStk rYnXtjd}|r|dry,t|ddd}t j d|ddWqt k rd}t d |YqXnd}t j d dd|t_|S) z*Return the hostname of the Docker service.Z DOCKER_HOSTztcp://r:rzDetected Docker host: %s) verbosity localhostzQCould not parse DOCKER_HOST environment variable "%s", falling back to localhost.z*Assuming Docker is available on localhost.) get_docker_hostnamehostnameAttributeErrorosenvironget startswithr splitr info ValueErrorwarning)Z docker_hostrrrrr,s  rcCsxytjStk rYnXd}d}tj|rXt|}tj|\}}|dkrX|}|t_|rtt j d|dd|S)z :rtype: str | None z/proc/self/cpusetN)z/dockerz /azpl_jobz*Detected execution in Docker container: %sr)r) get_docker_container_id container_idrrpathexistsrrstripr r )r%r$contentsZ cgroup_pathZ cgroup_namerrrr#Es r#cCsVt||}|dd}|d}|r:t|}||d}n|d}|sRtd||S)zS :type args: EnvironmentConfig :type container_id: str :rtype: str rNetworkSettingsNetworksZ IPAddressz,Cannot retrieve IP address for container: %s)docker_inspectr!get_docker_preferred_network_namer)argsr$resultsZnetwork_settingsnetworksZ network_name ipaddressrrrget_docker_container_ipfs    r1cCsDt||}|std|t|dkrt|d*}t||dd|dtgdg|ddWdQRXdS) zi :type args: EnvironmentConfig :type container_id: str :type src: str :type dst: str wbrFzif=%szbs=%sz-iT)rGstdoutrIN)rrJrK)r-r$rLrMZdst_fdrrr docker_gets rQc Cs|sg}|sg}t|}t|r.|d|gxvtddD]h}yt|dg||g|ddStk r}z&t|td|t dWdd}~XYq:Xq:Wt d |dS) z :type args: EnvironmentConfig :type image: str :type options: list[str] | None :type cmd: list[str] | None :rtype: str | None, str | None z --networkrr=runT)rIzKFailed to run docker image "%s". Waiting a few seconds before trying again.Nz Failed to run docker image "%s".) r,r7extendr@rAr r errorr"rBrCr)r-rDrGcmdr6rEexrrr docker_runs  rWc Csy t|d|ddgddd\}}Wn\tk r|}z>d|jkr@gSd|jkrht|d|ddgddd\}}n|Wd d }~XYnX|d rt|Sd d |DS) zZ :param args: CommonConfig :param image: str :rtype: list[dict[str, any]] Zimagesz--formatz {{json .}}T)rIalwaysz no such imagezfunction "json" not definedjsonN[cSsg|]}t|qSr)rYloads).0linerrr sz!docker_images..)rAr stderrrrYr[ splitlines)r-rDrP_dummyrVrrrr>s     r>c CsPyt|dd|gddWn2tk rJ}zd|jkr6n|Wdd}~XYnXdS)zC :type args: EnvironmentConfig :type container_id: str Zrmz-fT)rIzno such containerN)rAr r_)r-r$rVrrr docker_rm#s  rbc Cs|jr gSy t|d|gddd}t|Stk r}z8d|jkrJgSy t|jStk rn|YnXWdd}~XYnXdS)zZ :type args: EnvironmentConfig :type container_id: str :rtype: list[dict] inspectT)rIrz no such imageN)explainrArYr[r r_rP Exception)r-r$rPrVrrrr+1s   r+cCst|dd||gdddS)z] :param args: EnvironmentConfig :param container_id: str :param network: str r6Z disconnectT)rIN)rA)r-r$r6rrrdocker_network_disconnectFsrfc Csz|jr gSy"t|dd|gddd}t|Stk rt}z*y t|jStk rb|YnXWdd}~XYnXdS)zU :type args: EnvironmentConfig :type network: str :rtype: list[dict] r6rcT)rIrN)rdrArYr[r rPre)r-r6rPrVrrrdocker_network_inspectOs  rgFcCs*|sg}t|dg||g||||dS)z :type args: EnvironmentConfig :type container_id: str :type cmd: list[str] :type options: list[str] | None :type capture: bool :type stdin: BinaryIO | None :type stdout: BinaryIO | None :rtype: str | None, str | None exec)rIrHrP)rA)r-r$rUrGrIrHrPrrrrJbs rJcCs$t|dddgddd\}}t|S)z> :param args: CommonConfig :rtype: dict[str, any] r z--formatz {{json .}}T)rIrX)rArYr[)r-rPrarrr docker_infossricCs$t|dddgddd\}}t|S)z> :param args: CommonConfig :rtype: dict[str, any] versionz--formatz {{json .}}T)rIrX)rArYr[)r-rPrarrrdocker_version|srkc Cs"t}t|dg||||||dS)z :type args: CommonConfig :type cmd: list[str] :type capture: bool :type stdin: file | None :type stdout: file | None :type always: bool :rtype: str | None, str | None r)envrIrHrPrX)docker_environmentr)r-rUrIrHrPrXrlrrrrAs rAcCs$t}|tddtjD|S)z :rtype: dict[str, str] css&|]}|dr|tj|fVqdS)ZDOCKER_N)rrr)r\keyrrr sz%docker_environment..)r updatedictrr)rlrrrrmsrm)N)NFNN)FNNF)0__doc__ __future__rrrtype __metaclass__rYrrBiorrutilrr r r r httpr Z util_commonrconfigrrKrrr#r1r5r,r7r2r?rNrQrWr>rbr+rfrgrJrirkrArmrrrrsB   !