github/multus-cni
1
0
Fork 1
mirror of https://github.com/k8snetworkplumbingwg/multus-cni.git synced 2025-08-28 21:01:11 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #54 from dougbtv/test-readiness-on-del

Browse Source 
Adds readinessindicatorfile check on CNI DEL
This commit is contained in:
OpenShift Merge Robot 2020-04-03 00:39:41 +02:00 committed by GitHub
commit 25d0d0ae3c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
multus/multus.go
View File

@ -528,6 +528,16 @@ func cmdDel(args *skel.CmdArgs, exec invoke.Exec, kubeClient k8s.KubeClient) err
return cmdErr(nil, "error getting k8s args: %v", err) return cmdErr(nil, "error getting k8s args: %v", err)
} }
if in.ReadinessIndicatorFile != "" {
err := wait.PollImmediate(pollDuration, pollTimeout, func() (bool, error) {
_, err := os.Stat(in.ReadinessIndicatorFile)
return err == nil, nil
})
if err != nil {
return cmdErr(k8sArgs, "PollImmediate error waiting for ReadinessIndicatorFile (on del): %v", err)
}
}
// Read the cache to get delegates json for the pod // Read the cache to get delegates json for the pod
netconfBytes, path, err := consumeScratchNetConf(args.ContainerID, in.CNIDir) netconfBytes, path, err := consumeScratchNetConf(args.ContainerID, in.CNIDir)
if err != nil { if err != nil {