Skip to content

Commit

Permalink
Merge pull request openshift#295 from mlguerrero12/OCPBUGS-29648-415
Browse files Browse the repository at this point in the history
OCPBUGS-36367: [release-4.15] Return previous IP allocation for add cmd
  • Loading branch information
openshift-merge-bot[bot] authored Jul 5, 2024
2 parents 8a3df96 + aa12118 commit 8cb2e10
Show file tree
Hide file tree
Showing 17 changed files with 729 additions and 495 deletions.
2 changes: 2 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -13,3 +13,5 @@

bin/
/github.com/

.idea/
15 changes: 6 additions & 9 deletions cmd/whereabouts.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,12 @@ func main() {
return err
}
logging.Debugf("ADD - IPAM configuration successfully read: %+v", *ipamConf)
ipam, err := kubernetes.NewKubernetesIPAM(args.ContainerID, *ipamConf)
ipam, err := kubernetes.NewKubernetesIPAM(args.ContainerID, args.IfName, *ipamConf)
if err != nil {
return logging.Errorf("failed to create Kubernetes IPAM manager: %v", err)
}
defer func() { safeCloseKubernetesBackendConnection(ipam) }()
return cmdAdd(args, ipam, confVersion)
return cmdAdd(ipam, confVersion)
},
cmdCheck,
func(args *skel.CmdArgs) error {
Expand All @@ -41,12 +41,12 @@ func main() {
}
logging.Debugf("DEL - IPAM configuration successfully read: %+v", *ipamConf)

ipam, err := kubernetes.NewKubernetesIPAM(args.ContainerID, *ipamConf)
ipam, err := kubernetes.NewKubernetesIPAM(args.ContainerID, args.IfName, *ipamConf)
if err != nil {
return logging.Errorf("IPAM client initialization error: %v", err)
}
defer func() { safeCloseKubernetesBackendConnection(ipam) }()
return cmdDel(args, ipam)
return cmdDel(ipam)
},
cniversion.All,
fmt.Sprintf("whereabouts %s", version.GetFullVersionWithRuntimeInfo()),
Expand All @@ -64,13 +64,12 @@ func cmdCheck(args *skel.CmdArgs) error {
return fmt.Errorf("CNI CHECK method is not implemented")
}

func cmdAdd(args *skel.CmdArgs, client *kubernetes.KubernetesIPAM, cniVersion string) error {
func cmdAdd(client *kubernetes.KubernetesIPAM, cniVersion string) error {
// Initialize our result, and assign DNS & routing.
result := &current.Result{}
result.DNS = client.Config.DNS
result.Routes = client.Config.Routes

logging.Debugf("Beginning IPAM for ContainerID: %v", args.ContainerID)
var newips []net.IPNet

ctx, cancel := context.WithTimeout(context.Background(), types.AddTimeLimit)
Expand Down Expand Up @@ -108,9 +107,7 @@ func cmdAdd(args *skel.CmdArgs, client *kubernetes.KubernetesIPAM, cniVersion st
return cnitypes.PrintResult(result, cniVersion)
}

func cmdDel(args *skel.CmdArgs, client *kubernetes.KubernetesIPAM) error {
logging.Debugf("Beginning delete for ContainerID: %v", args.ContainerID)

func cmdDel(client *kubernetes.KubernetesIPAM) error {
ctx, cancel := context.WithTimeout(context.Background(), types.DelTimeLimit)
defer cancel()

Expand Down
Loading

0 comments on commit 8cb2e10

Please sign in to comment.