• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

kubeovn / kube-ovn / 23633945170

27 Mar 2026 06:17AM UTC coverage: 24.203% (+0.1%) from 24.096%
23633945170

push

github

web-flow
feat(controller): support per-pod NIC granular DHCP control via annotations (#6475)

* feat(controller): support per-pod NIC granular DHCP control via annotations

Allow pod annotations to override subnet-level DHCP settings at the
per-LSP (logical switch port) granularity. Annotations follow the
provider-prefixed format:
  <provider>.kubernetes.io/dhcp-v4-options
  <provider>.kubernetes.io/dhcp-v6-options

Key behaviors:
- Pod annotation takes highest priority and overrides subnet enableDHCP
- Supports multi-NIC (Multus) by scoping annotations per provider name
- Override semantics: annotation completely replaces subnet-level DHCP
- GC extended to clean up orphaned per-port DHCP_Options entries
- reconcilePodDHCPOptions handles annotation changes on running pods

Implementation:
- Unified internal OVN DHCP_Options helpers (portName="" = subnet-level,
  portName!="" = per-port) to eliminate code duplication
- Added PortKey ExternalID to discriminate per-port from subnet entries
- Extracted getSubnetMTU() helper for reuse across controllers
- Added SetLogicalSwitchPortDHCPOptions for targeted LSP DHCP field update

Signed-off-by: Mengxin Liu <liumengxinfly@gmail.com>

* fix(controller): address review issues in per-pod DHCP options

Fix all issues raised in code review:

Bug fixes:
- Fix error messages: "logical router name" -> "logical switch name"
- Add portName validation in DeleteDHCPOptionsForPort to prevent
  accidentally deleting all per-port entries when portName is empty
- Add lsName/portName validation and dual-stack bounds check in
  UpdateDHCPOptionsForPort
- Fix per-family override semantics: on dual-stack subnets, only create
  per-port DHCP_Options for families with a non-empty annotation value;
  fall back to subnet-level UUIDs for un-annotated families
- Add missing nil assertion in GetDHCPOptions isolation test

Improvements:
- Add no-op fast path in SetLogicalSwitchPortDHCPOptions to avoid
  unnecessary OVN NB transactions when DHCP ... (continued)

154 of 321 new or added lines in 5 files covered. (47.98%)

1 existing line in 1 file now uncovered.

13476 of 55678 relevant lines covered (24.2%)

0.28 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

10.01
/pkg/controller/subnet.go
1
package controller
2

3
import (
4
        "context"
5
        "errors"
6
        "fmt"
7
        "maps"
8
        "net"
9
        "reflect"
10
        "slices"
11
        "sort"
12
        "strings"
13

14
        "github.com/ovn-kubernetes/libovsdb/ovsdb"
15
        v1 "k8s.io/api/core/v1"
16
        k8serrors "k8s.io/apimachinery/pkg/api/errors"
17
        metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
18
        "k8s.io/apimachinery/pkg/labels"
19
        "k8s.io/apimachinery/pkg/types"
20
        "k8s.io/client-go/tools/cache"
21
        "k8s.io/klog/v2"
22
        "sigs.k8s.io/controller-runtime/pkg/client"
23
        "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
24

25
        kubeovnv1 "github.com/kubeovn/kube-ovn/pkg/apis/kubeovn/v1"
26
        "github.com/kubeovn/kube-ovn/pkg/ipam"
27
        "github.com/kubeovn/kube-ovn/pkg/ovs"
28
        "github.com/kubeovn/kube-ovn/pkg/ovsdb/ovnnb"
29
        "github.com/kubeovn/kube-ovn/pkg/util"
30
)
31

32
func (c *Controller) enqueueAddSubnet(obj any) {
×
33
        key := cache.MetaObjectToName(obj.(*kubeovnv1.Subnet)).String()
×
34
        klog.V(3).Infof("enqueue add subnet %s", key)
×
35
        c.addOrUpdateSubnetQueue.Add(key)
×
36
}
×
37

38
func (c *Controller) enqueueDeleteSubnet(obj any) {
×
39
        var subnet *kubeovnv1.Subnet
×
40
        switch t := obj.(type) {
×
41
        case *kubeovnv1.Subnet:
×
42
                subnet = t
×
43
        case cache.DeletedFinalStateUnknown:
×
44
                s, ok := t.Obj.(*kubeovnv1.Subnet)
×
45
                if !ok {
×
46
                        klog.Warningf("unexpected object type: %T", t.Obj)
×
47
                        return
×
48
                }
×
49
                subnet = s
×
50
        default:
×
51
                klog.Warningf("unexpected type: %T", obj)
×
52
                return
×
53
        }
54

55
        klog.V(3).Infof("enqueue delete subnet %s", subnet.Name)
×
56
        c.deleteSubnetQueue.Add(subnet)
×
57
}
58

59
func readyToRemoveFinalizer(subnet *kubeovnv1.Subnet) bool {
1✔
60
        if subnet.DeletionTimestamp.IsZero() {
2✔
61
                return false
1✔
62
        }
1✔
63

64
        if subnet.Status.V4UsingIPs.EqualInt64(0) && subnet.Status.V6UsingIPs.EqualInt64(0) {
2✔
65
                return true
1✔
66
        }
1✔
67

68
        usingIPs := subnet.Status.V4UsingIPs.Add(subnet.Status.V6UsingIPs)
1✔
69

1✔
70
        if subnet.Status.U2OInterconnectionIP != "" {
2✔
71
                return usingIPs.EqualInt64(int64(len(strings.Split(subnet.Status.U2OInterconnectionIP, ","))))
1✔
72
        }
1✔
73

74
        return false
1✔
75
}
76

77
func (c *Controller) enqueueUpdateSubnet(oldObj, newObj any) {
×
78
        oldSubnet := oldObj.(*kubeovnv1.Subnet)
×
79
        newSubnet := newObj.(*kubeovnv1.Subnet)
×
80
        key := cache.MetaObjectToName(newSubnet).String()
×
81

×
82
        if readyToRemoveFinalizer(newSubnet) {
×
83
                klog.Infof("enqueue update subnet %s triggered by ready to remove finalizer", key)
×
84
                c.addOrUpdateSubnetQueue.Add(key)
×
85
                return
×
86
        }
×
87

88
        if !reflect.DeepEqual(oldSubnet.Spec, newSubnet.Spec) {
×
89
                klog.V(3).Infof("enqueue update subnet %s", key)
×
90

×
91
                if oldSubnet.Spec.U2OInterconnection != newSubnet.Spec.U2OInterconnection {
×
92
                        klog.Infof("enqueue update vpc %s to update always-lear-from-arp option triggered by u2o interconnection change of subnet %s", newSubnet.Spec.Vpc, key)
×
93
                        c.addOrUpdateVpcQueue.Add(newSubnet.Spec.Vpc)
×
94
                }
×
95

96
                if oldSubnet.Spec.GatewayType != newSubnet.Spec.GatewayType {
×
97
                        c.recorder.Eventf(newSubnet, v1.EventTypeNormal, "SubnetGatewayTypeChanged",
×
98
                                "subnet gateway type changes from %q to %q", oldSubnet.Spec.GatewayType, newSubnet.Spec.GatewayType)
×
99
                }
×
100

101
                if oldSubnet.Spec.GatewayNode != newSubnet.Spec.GatewayNode {
×
102
                        c.recorder.Eventf(newSubnet, v1.EventTypeNormal, "SubnetGatewayNodeChanged",
×
103
                                "gateway node changes from %q to %q", oldSubnet.Spec.GatewayNode, newSubnet.Spec.GatewayNode)
×
104
                }
×
105

106
                c.addOrUpdateSubnetQueue.Add(key)
×
107
        }
108
}
109

110
func (c *Controller) formatSubnet(subnet *kubeovnv1.Subnet) (*kubeovnv1.Subnet, error) {
1✔
111
        newSubnet := subnet.DeepCopy()
1✔
112
        if err := formatAddress(newSubnet); err != nil {
1✔
113
                klog.Error(err)
×
114
                return nil, err
×
115
        }
×
116

117
        if newSubnet.Spec.Provider == "" {
2✔
118
                newSubnet.Spec.Provider = util.OvnProvider
1✔
119
        }
1✔
120

121
        if newSubnet.Spec.Vpc == "" {
2✔
122
                if isOvnSubnet(newSubnet) {
2✔
123
                        newSubnet.Spec.Vpc = c.config.ClusterRouter
1✔
124
                }
1✔
125
        }
126

127
        if newSubnet.Spec.Vpc == c.config.ClusterRouter && newSubnet.Name != c.config.NodeSwitch {
2✔
128
                // Some format only needed in the default VPC
1✔
129
                if newSubnet.Spec.GatewayType == "" {
2✔
130
                        newSubnet.Spec.GatewayType = kubeovnv1.GWDistributedType
1✔
131
                }
1✔
132
                if newSubnet.Spec.Default && newSubnet.Name != c.config.DefaultLogicalSwitch {
1✔
133
                        newSubnet.Spec.Default = false
×
134
                }
×
135
        }
136

137
        if newSubnet.Spec.EnableLb == nil && newSubnet.Name != c.config.NodeSwitch {
2✔
138
                newSubnet.Spec.EnableLb = &c.config.EnableLb
1✔
139
        }
1✔
140
        // set join subnet Spec.EnableLb to nil
141
        if newSubnet.Spec.EnableLb != nil && newSubnet.Name == c.config.NodeSwitch {
1✔
142
                newSubnet.Spec.EnableLb = nil
×
143
        }
×
144

145
        if newSubnet.Spec.U2OInterconnectionIP != "" && !newSubnet.Spec.U2OInterconnection {
1✔
146
                newSubnet.Spec.U2OInterconnectionIP = ""
×
147
        }
×
148

149
        if newSubnet.Spec.Vlan == "" && newSubnet.Spec.U2OInterconnection {
1✔
150
                newSubnet.Spec.U2OInterconnection = false
×
151
        }
×
152

153
        changed := !reflect.DeepEqual(subnet, newSubnet)
1✔
154
        klog.Infof("format subnet %v, changed %v", subnet.Name, changed)
1✔
155
        if changed {
2✔
156
                ret, err := c.config.KubeOvnClient.KubeovnV1().Subnets().Update(context.Background(), newSubnet, metav1.UpdateOptions{})
1✔
157
                if err != nil {
1✔
158
                        klog.Errorf("failed to update subnet %s, %v", subnet.Name, err)
×
159
                        return nil, err
×
160
                }
×
161
                return ret, nil
1✔
162
        }
163
        return subnet, nil
1✔
164
}
165

166
// errVlanNotReady is returned when the vlan has not been fully processed by
167
// the vlan handler yet. The caller should requeue silently without patching
168
// the subnet status as failed.
169
var errVlanNotReady = errors.New("vlan not ready")
170

171
func (c *Controller) validateSubnetVlan(subnet *kubeovnv1.Subnet) error {
1✔
172
        if subnet.Spec.Vlan == "" {
2✔
173
                return nil
1✔
174
        }
1✔
175

176
        vlan, err := c.vlansLister.Get(subnet.Spec.Vlan)
1✔
177
        if err != nil {
2✔
178
                err = fmt.Errorf("failed to get vlan %s: %w", subnet.Spec.Vlan, err)
1✔
179
                klog.Error(err)
1✔
180
                return err
1✔
181
        }
1✔
182

183
        if vlan.Status.Conflict {
2✔
184
                err = fmt.Errorf("subnet %s has invalid conflict vlan %s", subnet.Name, vlan.Name)
1✔
185
                klog.Error(err)
1✔
186
                return err
1✔
187
        }
1✔
188

189
        // Ensure the vlan has been fully processed by the vlan handler before
190
        // allowing the subnet to proceed. A newly created vlan has Conflict=false
191
        // (zero value) which is indistinguishable from a processed non-conflicting
192
        // vlan. Use pn.Status.Vlans as a "vlan ready" signal — only set after
193
        // the vlan handler completes successfully (including conflict check).
194
        // This prevents a race where the subnet allocates IPAM before the vlan's
195
        // conflict status is determined.
196
        if vlan.Spec.Provider == "" {
2✔
197
                return fmt.Errorf("vlan %s provider not yet set, deferring subnet %s: %w", vlan.Name, subnet.Name, errVlanNotReady)
1✔
198
        }
1✔
199
        pn, err := c.providerNetworksLister.Get(vlan.Spec.Provider)
1✔
200
        if err != nil {
1✔
201
                return fmt.Errorf("vlan %s not yet ready (provider network %s not found): %w", vlan.Name, vlan.Spec.Provider, errVlanNotReady)
×
202
        }
×
203
        if !slices.Contains(pn.Status.Vlans, vlan.Name) {
2✔
204
                return fmt.Errorf("vlan %s not yet processed by vlan handler, deferring subnet %s: %w", vlan.Name, subnet.Name, errVlanNotReady)
1✔
205
        }
1✔
206

207
        return nil
1✔
208
}
209

210
func formatAddress(subnet *kubeovnv1.Subnet) error {
1✔
211
        if err := formatCIDR(subnet); err != nil {
1✔
212
                klog.Error(err)
×
213
                return err
×
214
        }
×
215

216
        if err := formatGateway(subnet); err != nil {
1✔
217
                klog.Error(err)
×
218
                return err
×
219
        }
×
220

221
        formatExcludeIPs(subnet)
1✔
222

1✔
223
        subnet.Spec.Protocol = util.CheckProtocol(subnet.Spec.CIDRBlock)
1✔
224

1✔
225
        return nil
1✔
226
}
227

228
func formatCIDR(subnet *kubeovnv1.Subnet) error {
1✔
229
        var cidrBlocks []string
1✔
230

1✔
231
        for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
2✔
232
                _, ipNet, err := net.ParseCIDR(cidr)
1✔
233
                if err != nil {
1✔
234
                        klog.Error(err)
×
235
                        return fmt.Errorf("subnet %s cidr %s is invalid", subnet.Name, cidr)
×
236
                }
×
237
                cidrBlocks = append(cidrBlocks, ipNet.String())
1✔
238
        }
239
        subnet.Spec.CIDRBlock = strings.Join(cidrBlocks, ",")
1✔
240
        return nil
1✔
241
}
242

243
func formatGateway(subnet *kubeovnv1.Subnet) error {
1✔
244
        var (
1✔
245
                gw  string
1✔
246
                err error
1✔
247
        )
1✔
248

1✔
249
        switch {
1✔
250
        case subnet.Spec.Gateway == "":
1✔
251
                gw, err = util.GetGwByCidr(subnet.Spec.CIDRBlock)
1✔
252
        case subnet.Spec.Protocol == kubeovnv1.ProtocolDual && util.CheckProtocol(subnet.Spec.Gateway) != util.CheckProtocol(subnet.Spec.CIDRBlock):
×
253
                gw, err = util.AppendGwByCidr(subnet.Spec.Gateway, subnet.Spec.CIDRBlock)
×
254
        default:
1✔
255
                gw = subnet.Spec.Gateway
1✔
256
        }
257
        if err != nil {
1✔
258
                klog.Error(err)
×
259
                return err
×
260
        }
×
261
        subnet.Spec.Gateway = gw
1✔
262

1✔
263
        return nil
1✔
264
}
265

266
func formatExcludeIPs(subnet *kubeovnv1.Subnet) {
1✔
267
        var excludeIPs []string
1✔
268
        excludeIPs = append(excludeIPs, strings.Split(subnet.Spec.Gateway, ",")...)
1✔
269
        sort.Strings(excludeIPs)
1✔
270
        if len(subnet.Spec.ExcludeIps) == 0 {
2✔
271
                subnet.Spec.ExcludeIps = excludeIPs
1✔
272
        } else {
2✔
273
                formatExcludeIPRanges(subnet)
1✔
274
                for _, gw := range excludeIPs {
2✔
275
                        gwExists := false
1✔
276
                        for _, excludeIP := range subnet.Spec.ExcludeIps {
2✔
277
                                if util.ContainsIPs(excludeIP, gw) {
2✔
278
                                        gwExists = true
1✔
279
                                        break
1✔
280
                                }
281
                        }
282
                        if !gwExists {
1✔
283
                                subnet.Spec.ExcludeIps = append(subnet.Spec.ExcludeIps, gw)
×
284
                                sort.Strings(subnet.Spec.ExcludeIps)
×
285
                        }
×
286
                }
287
        }
288
}
289

290
func (c *Controller) syncSubnetFinalizer(cl client.Client) error {
×
291
        // migrate deprecated finalizer to new finalizer
×
292
        subnets := &kubeovnv1.SubnetList{}
×
293
        return migrateFinalizers(cl, subnets, func(i int) (client.Object, client.Object) {
×
294
                if i < 0 || i >= len(subnets.Items) {
×
295
                        return nil, nil
×
296
                }
×
297
                return subnets.Items[i].DeepCopy(), subnets.Items[i].DeepCopy()
×
298
        })
299
}
300

301
func (c *Controller) handleSubnetFinalizer(subnet *kubeovnv1.Subnet) (*kubeovnv1.Subnet, bool, error) {
×
302
        if subnet.DeletionTimestamp.IsZero() && !slices.Contains(subnet.GetFinalizers(), util.KubeOVNControllerFinalizer) {
×
303
                newSubnet := subnet.DeepCopy()
×
304
                controllerutil.RemoveFinalizer(newSubnet, util.DeprecatedFinalizerName)
×
305
                controllerutil.AddFinalizer(newSubnet, util.KubeOVNControllerFinalizer)
×
306
                patch, err := util.GenerateMergePatchPayload(subnet, newSubnet)
×
307
                if err != nil {
×
308
                        klog.Errorf("failed to generate patch payload for subnet '%s', %v", subnet.Name, err)
×
309
                        return newSubnet, false, err
×
310
                }
×
311
                patchSubnet, err := c.config.KubeOvnClient.KubeovnV1().Subnets().Patch(context.Background(), subnet.Name, types.MergePatchType, patch, metav1.PatchOptions{}, "")
×
312
                if err != nil {
×
313
                        klog.Errorf("failed to add finalizer to subnet %s, %v", subnet.Name, err)
×
314
                        return patchSubnet, false, err
×
315
                }
×
316

317
                return patchSubnet, false, nil
×
318
        }
319

320
        if readyToRemoveFinalizer(subnet) {
×
321
                newSubnet := subnet.DeepCopy()
×
322
                controllerutil.RemoveFinalizer(newSubnet, util.DeprecatedFinalizerName)
×
323
                controllerutil.RemoveFinalizer(newSubnet, util.KubeOVNControllerFinalizer)
×
324
                patch, err := util.GenerateMergePatchPayload(subnet, newSubnet)
×
325
                if err != nil {
×
326
                        klog.Errorf("failed to generate patch payload for subnet '%s', %v", subnet.Name, err)
×
327
                        return newSubnet, false, err
×
328
                }
×
329
                if _, err := c.config.KubeOvnClient.KubeovnV1().Subnets().Patch(context.Background(), subnet.Name,
×
330
                        types.MergePatchType, patch, metav1.PatchOptions{}, ""); err != nil {
×
331
                        klog.Errorf("failed to remove finalizer from subnet %s, %v", subnet.Name, err)
×
332
                        return newSubnet, false, err
×
333
                }
×
334
                return newSubnet, true, nil
×
335
        }
336
        return subnet, false, nil
×
337
}
338

339
func (c *Controller) validateVpcBySubnet(subnet *kubeovnv1.Subnet) (*kubeovnv1.Vpc, error) {
×
340
        vpc, err := c.vpcsLister.Get(subnet.Spec.Vpc)
×
341
        if err != nil {
×
342
                klog.Errorf("failed to get subnet's vpc '%s', %v", subnet.Spec.Vpc, err)
×
343
                return vpc, err
×
344
        }
×
345

346
        if !vpc.Status.Standby {
×
347
                err = fmt.Errorf("the vpc '%s' not standby yet", vpc.Name)
×
348
                klog.Error(err)
×
349
                return vpc, err
×
350
        }
×
351

352
        if !vpc.Status.Default {
×
353
                for _, ns := range subnet.Spec.Namespaces {
×
354
                        if !slices.Contains(vpc.Spec.Namespaces, ns) {
×
355
                                err = fmt.Errorf("namespace '%s' is out of range to custom vpc '%s'", ns, vpc.Name)
×
356
                                klog.Error(err)
×
357
                                return vpc, err
×
358
                        }
×
359
                }
360
        } else {
×
361
                vpcs, err := c.vpcsLister.List(labels.Everything())
×
362
                if err != nil {
×
363
                        klog.Errorf("failed to list vpc, %v", err)
×
364
                        return vpc, err
×
365
                }
×
366

367
                for _, vpc := range vpcs {
×
368
                        if subnet.Spec.Vpc != vpc.Name &&
×
369
                                !vpc.Status.Default && util.IsStringsOverlap(vpc.Spec.Namespaces, subnet.Spec.Namespaces) {
×
370
                                err = fmt.Errorf("namespaces %v are overlap with vpc '%s'", subnet.Spec.Namespaces, vpc.Name)
×
371
                                klog.Error(err)
×
372
                                return vpc, err
×
373
                        }
×
374
                }
375
        }
376
        return vpc, nil
×
377
}
378

379
func (c *Controller) checkSubnetConflict(subnet *kubeovnv1.Subnet) error {
1✔
380
        subnetList, err := c.subnetsLister.List(labels.Everything())
1✔
381
        if err != nil {
1✔
382
                klog.Errorf("failed to list subnets %v", err)
×
383
                return err
×
384
        }
×
385

386
        for _, sub := range subnetList {
2✔
387
                if sub.Spec.Vpc != subnet.Spec.Vpc || sub.Spec.Vlan != subnet.Spec.Vlan || sub.Name == subnet.Name {
2✔
388
                        continue
1✔
389
                }
390

391
                if util.CIDROverlap(sub.Spec.CIDRBlock, subnet.Spec.CIDRBlock) {
2✔
392
                        conflictErr := fmt.Errorf("subnet %s cidr %s is conflict with subnet %s cidr %s", subnet.Name, subnet.Spec.CIDRBlock, sub.Name, sub.Spec.CIDRBlock)
1✔
393
                        klog.Error(conflictErr)
1✔
394
                        if patchErr := c.patchSubnetStatus(subnet, "ValidateLogicalSwitchFailed", conflictErr.Error()); patchErr != nil {
1✔
395
                                klog.Error(patchErr)
×
396
                                return errors.Join(conflictErr, patchErr)
×
397
                        }
×
398
                        return conflictErr
1✔
399
                }
400

401
                if subnet.Spec.ExternalEgressGateway != "" && sub.Spec.ExternalEgressGateway != "" &&
1✔
402
                        subnet.Spec.PolicyRoutingTableID == sub.Spec.PolicyRoutingTableID {
2✔
403
                        conflictErr := fmt.Errorf("subnet %s policy routing table ID %d is conflict with subnet %s policy routing table ID %d", subnet.Name, subnet.Spec.PolicyRoutingTableID, sub.Name, sub.Spec.PolicyRoutingTableID)
1✔
404
                        klog.Error(conflictErr)
1✔
405
                        if patchErr := c.patchSubnetStatus(subnet, "ValidateLogicalSwitchFailed", conflictErr.Error()); patchErr != nil {
1✔
406
                                klog.Error(patchErr)
×
407
                                return errors.Join(conflictErr, patchErr)
×
408
                        }
×
409
                        return conflictErr
1✔
410
                }
411
        }
412

413
        if subnet.Spec.Vlan == "" && subnet.Spec.Vpc == c.config.ClusterRouter {
2✔
414
                nodes, err := c.nodesLister.List(labels.Everything())
1✔
415
                if err != nil {
1✔
416
                        klog.Errorf("failed to list nodes: %v", err)
×
417
                        return err
×
418
                }
×
419
                for _, node := range nodes {
2✔
420
                        for _, addr := range node.Status.Addresses {
2✔
421
                                if addr.Type == v1.NodeInternalIP && util.CIDRContainIP(subnet.Spec.CIDRBlock, addr.Address) {
2✔
422
                                        conflictErr := fmt.Errorf("subnet %s cidr %s conflict with node %s address %s", subnet.Name, subnet.Spec.CIDRBlock, node.Name, addr.Address)
1✔
423
                                        klog.Error(conflictErr)
1✔
424
                                        if patchErr := c.patchSubnetStatus(subnet, "ValidateLogicalSwitchFailed", conflictErr.Error()); patchErr != nil {
1✔
425
                                                klog.Error(patchErr)
×
426
                                                return errors.Join(conflictErr, patchErr)
×
427
                                        }
×
428
                                        return conflictErr
1✔
429
                                }
430
                        }
431
                }
432
        }
433
        return nil
1✔
434
}
435

436
// getSubnetMTU returns the effective MTU for DHCP options of the given subnet.
NEW
437
func (c *Controller) getSubnetMTU(subnet *kubeovnv1.Subnet) (int, error) {
×
438
        if subnet.Spec.Mtu > 0 {
×
NEW
439
                return int(subnet.Spec.Mtu), nil
×
NEW
440
        }
×
NEW
441
        mtu := util.DefaultMTU
×
NEW
442
        if subnet.Spec.Vlan == "" {
×
NEW
443
                switch c.config.NetworkType {
×
NEW
444
                case util.NetworkTypeVlan:
×
NEW
445
                        // default to geneve
×
NEW
446
                        fallthrough
×
NEW
447
                case util.NetworkTypeGeneve:
×
NEW
448
                        mtu -= util.GeneveHeaderLength
×
NEW
449
                case util.NetworkTypeVxlan:
×
NEW
450
                        mtu -= util.VxlanHeaderLength
×
NEW
451
                case util.NetworkTypeStt:
×
NEW
452
                        mtu -= util.SttHeaderLength
×
NEW
453
                default:
×
NEW
454
                        return 0, fmt.Errorf("invalid network type: %s", c.config.NetworkType)
×
455
                }
456
        }
NEW
457
        return mtu, nil
×
458
}
459

NEW
460
func (c *Controller) updateSubnetDHCPOption(subnet *kubeovnv1.Subnet, needRouter bool) error {
×
NEW
461
        mtu, err := c.getSubnetMTU(subnet)
×
NEW
462
        if err != nil {
×
NEW
463
                return err
×
NEW
464
        }
×
465

466
        dhcpOptionsUUIDs, err := c.OVNNbClient.UpdateDHCPOptions(subnet, mtu)
×
467
        if err != nil {
×
468
                klog.Errorf("failed to update dhcp options for switch %s, %v", subnet.Name, err)
×
469
                return err
×
470
        }
×
471

472
        vpc, err := c.vpcsLister.Get(subnet.Spec.Vpc)
×
473
        if err != nil {
×
474
                klog.Errorf("failed to get subnet's vpc '%s', %v", subnet.Spec.Vpc, err)
×
475
                return err
×
476
        }
×
477

478
        if needRouter {
×
479
                lrpName := fmt.Sprintf("%s-%s", vpc.Status.Router, subnet.Name)
×
480
                if err := c.OVNNbClient.UpdateLogicalRouterPortRA(lrpName, subnet.Spec.IPv6RAConfigs, subnet.Spec.EnableIPv6RA); err != nil {
×
481
                        klog.Errorf("update ipv6 ra configs for logical router port %s, %v", lrpName, err)
×
482
                        return err
×
483
                }
×
484
        }
485

486
        if subnet.Status.DHCPv4OptionsUUID != dhcpOptionsUUIDs.DHCPv4OptionsUUID || subnet.Status.DHCPv6OptionsUUID != dhcpOptionsUUIDs.DHCPv6OptionsUUID {
×
487
                subnet.Status.DHCPv4OptionsUUID = dhcpOptionsUUIDs.DHCPv4OptionsUUID
×
488
                subnet.Status.DHCPv6OptionsUUID = dhcpOptionsUUIDs.DHCPv6OptionsUUID
×
489
                bytes, err := subnet.Status.Bytes()
×
490
                if err != nil {
×
491
                        klog.Error(err)
×
492
                        return err
×
493
                }
×
494
                if _, err := c.config.KubeOvnClient.KubeovnV1().Subnets().Patch(context.Background(), subnet.Name, types.MergePatchType, bytes, metav1.PatchOptions{}, "status"); err != nil {
×
495
                        klog.Errorf("patch subnet %s dhcp options failed: %v", subnet.Name, err)
×
496
                        return err
×
497
                }
×
498
        }
499

500
        return nil
×
501
}
502

503
func (c *Controller) handleAddOrUpdateSubnet(key string) error {
1✔
504
        c.subnetKeyMutex.LockKey(key)
1✔
505
        defer func() { _ = c.subnetKeyMutex.UnlockKey(key) }()
2✔
506

507
        cachedSubnet, err := c.subnetsLister.Get(key)
1✔
508
        if err != nil {
1✔
509
                if k8serrors.IsNotFound(err) {
×
510
                        return nil
×
511
                }
×
512
                klog.Error(err)
×
513
                return err
×
514
        }
515
        klog.V(3).Infof("handle add or update subnet %s", cachedSubnet.Name)
1✔
516
        subnet, err := c.formatSubnet(cachedSubnet)
1✔
517
        if err != nil {
1✔
518
                err := fmt.Errorf("failed to format subnet %s, %w", key, err)
×
519
                klog.Error(err)
×
520
                return err
×
521
        }
×
522

523
        err = c.validateSubnetVlan(subnet)
1✔
524
        if err != nil {
2✔
525
                if errors.Is(err, errVlanNotReady) {
1✔
526
                        // vlan hasn't been processed yet, requeue silently without
×
527
                        // marking the subnet as failed
×
528
                        klog.Infof("deferring subnet %s: %v", key, err)
×
529
                        return err
×
530
                }
×
531
                err = fmt.Errorf("failed to validate vlan for subnet %s, %w", key, err)
1✔
532
                klog.Error(err)
1✔
533
                if patchErr := c.patchSubnetStatus(subnet, "ValidateSubnetVlanFailed", err.Error()); patchErr != nil {
1✔
534
                        klog.Error(patchErr)
×
535
                        return patchErr
×
536
                }
×
537
                return err
1✔
538
        }
539

540
        if err = util.ValidateSubnet(*subnet); err != nil {
×
541
                klog.Errorf("failed to validate subnet %s, %v", subnet.Name, err)
×
542
                if patchErr := c.patchSubnetStatus(subnet, "ValidateLogicalSwitchFailed", err.Error()); patchErr != nil {
×
543
                        klog.Error(patchErr)
×
544
                        return patchErr
×
545
                }
×
546
                return err
×
547
        }
548
        if err = c.patchSubnetStatus(subnet, "ValidateLogicalSwitchSuccess", ""); err != nil {
×
549
                klog.Error(err)
×
550
                return err
×
551
        }
×
552

553
        if err := c.ipam.AddOrUpdateSubnet(subnet.Name, subnet.Spec.CIDRBlock, subnet.Spec.Gateway, subnet.Spec.ExcludeIps); err != nil {
×
554
                klog.Error(err)
×
555
                return err
×
556
        }
×
557

558
        // availableIPStr valued from ipam, so leave update subnet.status after ipam process
559
        subnet, err = c.calcSubnetStatusIP(subnet)
×
560
        if err != nil {
×
561
                klog.Errorf("calculate subnet %s used ip failed, %v", cachedSubnet.Name, err)
×
562
                return err
×
563
        }
×
564

565
        subnet, deleted, err := c.handleSubnetFinalizer(subnet)
×
566
        if err != nil {
×
567
                klog.Errorf("handle subnet finalizer failed %v", err)
×
568
                return err
×
569
        }
×
570
        if deleted {
×
571
                return nil
×
572
        }
×
573

574
        if !isOvnSubnet(subnet) {
×
575
                // subnet provider is not ovn, and vpc is empty, should not reconcile
×
576
                if err = c.patchSubnetStatus(subnet, "SetNonOvnSubnetSuccess", ""); err != nil {
×
577
                        klog.Error(err)
×
578
                        return err
×
579
                }
×
580

581
                subnet.Status.EnsureStandardConditions()
×
582
                klog.Infof("non ovn subnet %s is ready", subnet.Name)
×
583
                return nil
×
584
        }
585

586
        // This validate should be processed after isOvnSubnet, since maybe there's no vpc for subnet not managed by kube-ovn
587
        vpc, err := c.validateVpcBySubnet(subnet)
×
588
        if err != nil {
×
589
                klog.Errorf("failed to get subnet's vpc '%s', %v", subnet.Spec.Vpc, err)
×
590
                return err
×
591
        }
×
592
        _, isMcastQuerierChanged, err := c.reconcileSubnetSpecialIPs(subnet)
×
593
        if err != nil {
×
594
                klog.Errorf("failed to reconcile subnet %s Custom IPs %v", subnet.Name, err)
×
595
                return err
×
596
        }
×
597

598
        needRouter := subnet.Spec.Vlan == "" || subnet.Spec.LogicalGateway ||
×
599
                (subnet.Status.U2OInterconnectionIP != "" && subnet.Spec.U2OInterconnection)
×
600
        // 1. overlay subnet, should add lrp, lrp ip is subnet gw
×
601
        // 2. underlay subnet use logical gw, should add lrp, lrp ip is subnet gw
×
602
        randomAllocateGW := !subnet.Spec.LogicalGateway && vpc.Spec.EnableExternal && subnet.Name == c.config.ExternalGatewaySwitch
×
603
        // 3. underlay subnet use physical gw, vpc has eip, lrp managed in vpc process, lrp ip is random allocation, not subnet gw
×
604

×
605
        gateway := subnet.Spec.Gateway
×
606
        var gatewayMAC string
×
607
        if subnet.Status.U2OInterconnectionIP != "" && subnet.Spec.U2OInterconnection {
×
608
                gateway = subnet.Status.U2OInterconnectionIP
×
609
                gatewayMAC = subnet.Status.U2OInterconnectionMAC
×
610
        }
×
611

612
        if err := c.clearOldU2OResource(subnet); err != nil {
×
613
                klog.Errorf("clear subnet %s old u2o resource failed: %v", subnet.Name, err)
×
614
                return err
×
615
        }
×
616

617
        // Lock VPC to prevent CIDR conflict between concurrent subnet creations in the same VPC
618
        if err := func() error {
×
619
                c.vpcKeyMutex.LockKey(subnet.Spec.Vpc)
×
620
                defer func() { _ = c.vpcKeyMutex.UnlockKey(subnet.Spec.Vpc) }()
×
621

622
                if err := c.checkSubnetConflict(subnet); err != nil {
×
623
                        klog.Errorf("failed to check subnet %s, %v", subnet.Name, err)
×
624
                        return err
×
625
                }
×
626
                // create or update logical switch
627
                if err := c.OVNNbClient.CreateLogicalSwitch(subnet.Name, vpc.Status.Router, subnet.Spec.CIDRBlock, gateway, gatewayMAC, needRouter, randomAllocateGW); err != nil {
×
628
                        klog.Errorf("create logical switch %s: %v", subnet.Name, err)
×
629
                        return err
×
630
                }
×
631
                return nil
×
632
        }(); err != nil {
×
633
                return err
×
634
        }
×
635

636
        // Record the gateway MAC in ipam if router port exists
637
        if needRouter {
×
638
                routerPortName := ovs.LogicalRouterPortName(vpc.Status.Router, subnet.Name)
×
639
                if lrp, err := c.OVNNbClient.GetLogicalRouterPort(routerPortName, true); err == nil && lrp != nil && lrp.MAC != "" {
×
640
                        if err := c.ipam.RecordGatewayMAC(subnet.Name, lrp.MAC); err != nil {
×
641
                                klog.Warningf("failed to record gateway MAC %s for subnet %s: %v", lrp.MAC, subnet.Name, err)
×
642
                        }
×
643
                } else {
×
644
                        klog.V(3).Infof("router port %s not found or has no MAC, skipping gateway MAC record", routerPortName)
×
645
                }
×
646
        }
647

648
        if isMcastQuerierChanged {
×
649
                if err := c.handleMcastQuerierChange(subnet); err != nil {
×
650
                        klog.Errorf("failed to handle mcast querier IP change for subnet %s: %v", subnet.Name, err)
×
651
                        return err
×
652
                }
×
653
        }
654

655
        subnet.Status.EnsureStandardConditions()
×
656

×
657
        if err := c.updateSubnetDHCPOption(subnet, needRouter); err != nil {
×
658
                klog.Errorf("failed to update subnet %s dhcpOptions: %v", subnet.Name, err)
×
659
                return err
×
660
        }
×
661

662
        if c.config.EnableLb && subnet.Name != c.config.NodeSwitch {
×
663
                lbs := []string{
×
664
                        vpc.Status.TCPLoadBalancer,
×
665
                        vpc.Status.TCPSessionLoadBalancer,
×
666
                        vpc.Status.UDPLoadBalancer,
×
667
                        vpc.Status.UDPSessionLoadBalancer,
×
668
                        vpc.Status.SctpLoadBalancer,
×
669
                        vpc.Status.SctpSessionLoadBalancer,
×
670
                }
×
671
                if subnet.Spec.EnableLb != nil && *subnet.Spec.EnableLb {
×
672
                        if lbErr := c.OVNNbClient.LogicalSwitchUpdateLoadBalancers(subnet.Name, ovsdb.MutateOperationInsert, lbs...); lbErr != nil {
×
673
                                klog.Error(lbErr)
×
674
                                if patchErr := c.patchSubnetStatus(subnet, "AddLbToLogicalSwitchFailed", lbErr.Error()); patchErr != nil {
×
675
                                        klog.Error(patchErr)
×
676
                                        return errors.Join(lbErr, patchErr)
×
677
                                }
×
678
                                return lbErr
×
679
                        }
680
                } else {
×
681
                        if err := c.OVNNbClient.LogicalSwitchUpdateLoadBalancers(subnet.Name, ovsdb.MutateOperationDelete, lbs...); err != nil {
×
682
                                klog.Errorf("remove load-balancer from subnet %s failed: %v", subnet.Name, err)
×
683
                                return err
×
684
                        }
×
685
                }
686
        }
687

688
        if err := c.reconcileSubnet(subnet); err != nil {
×
689
                klog.Errorf("reconcile subnet for %s failed, %v", subnet.Name, err)
×
690
                return err
×
691
        }
×
692

693
        subnet.Status.U2OInterconnectionVPC = ""
×
694
        if subnet.Spec.U2OInterconnection {
×
695
                subnet.Status.U2OInterconnectionVPC = vpc.Status.Router
×
696
        }
×
697

698
        if err = c.updateNatOutgoingPolicyRulesStatus(subnet); err != nil {
×
699
                klog.Errorf("failed to update NAT outgoing policy status for subnet %s: %v", subnet.Name, err)
×
700
                return err
×
701
        }
×
702

703
        if subnet.Spec.Private {
×
704
                if privErr := c.OVNNbClient.SetLogicalSwitchPrivate(subnet.Name, subnet.Spec.CIDRBlock, c.config.NodeSwitchCIDR, subnet.Spec.AllowSubnets); privErr != nil {
×
705
                        klog.Error(privErr)
×
706
                        if patchErr := c.patchSubnetStatus(subnet, "SetPrivateLogicalSwitchFailed", privErr.Error()); patchErr != nil {
×
707
                                klog.Error(patchErr)
×
708
                                return errors.Join(privErr, patchErr)
×
709
                        }
×
710
                        return privErr
×
711
                }
712

713
                if err = c.patchSubnetStatus(subnet, "SetPrivateLogicalSwitchSuccess", ""); err != nil {
×
714
                        klog.Error(err)
×
715
                        return err
×
716
                }
×
717
        } else {
×
718
                // clear acl when direction is ""
×
719
                if aclErr := c.OVNNbClient.DeleteAcls(subnet.Name, logicalSwitchKey, "", nil); aclErr != nil {
×
720
                        klog.Error(aclErr)
×
721
                        if patchErr := c.patchSubnetStatus(subnet, "ResetLogicalSwitchAclFailed", aclErr.Error()); patchErr != nil {
×
722
                                klog.Error(patchErr)
×
723
                                return errors.Join(aclErr, patchErr)
×
724
                        }
×
725
                        return aclErr
×
726
                }
727

728
                if err = c.patchSubnetStatus(subnet, "ResetLogicalSwitchAclSuccess", ""); err != nil {
×
729
                        klog.Error(err)
×
730
                        return err
×
731
                }
×
732
        }
733

734
        if aclErr := c.OVNNbClient.UpdateLogicalSwitchACL(subnet.Name, subnet.Spec.CIDRBlock, subnet.Spec.Acls, subnet.Spec.AllowEWTraffic); aclErr != nil {
×
735
                klog.Error(aclErr)
×
736
                if patchErr := c.patchSubnetStatus(subnet, "SetLogicalSwitchAclsFailed", aclErr.Error()); patchErr != nil {
×
737
                        klog.Error(patchErr)
×
738
                        return errors.Join(aclErr, patchErr)
×
739
                }
×
740
                return aclErr
×
741
        }
742

743
        c.updateVpcStatusQueue.Add(subnet.Spec.Vpc)
×
744

×
745
        ippools, err := c.ippoolLister.List(labels.Everything())
×
746
        if err != nil {
×
747
                klog.Errorf("failed to list ippools: %v", err)
×
748
                return err
×
749
        }
×
750

751
        for _, p := range ippools {
×
752
                if p.Spec.Subnet == subnet.Name {
×
753
                        c.addOrUpdateIPPoolQueue.Add(p.Name)
×
754
                }
×
755
        }
756

757
        return nil
×
758
}
759

760
func (c *Controller) handleDeleteLogicalSwitch(key string) (err error) {
×
761
        c.ipam.DeleteSubnet(key)
×
762

×
763
        exist, err := c.OVNNbClient.LogicalSwitchExists(key)
×
764
        if err != nil {
×
765
                klog.Errorf("check logical switch %s exist: %v", key, err)
×
766
                return err
×
767
        }
×
768

769
        // not found, skip
770
        if !exist {
×
771
                return nil
×
772
        }
×
773

774
        // clear acl when direction is ""
775
        if err = c.OVNNbClient.DeleteAcls(key, logicalSwitchKey, "", nil); err != nil {
×
776
                klog.Errorf("clear logical switch %s acls: %v", key, err)
×
777
                return err
×
778
        }
×
779

780
        if err = c.OVNNbClient.DeleteDHCPOptions(key, kubeovnv1.ProtocolDual); err != nil {
×
781
                klog.Errorf("failed to delete dhcp options of logical switch %s %v", key, err)
×
782
                return err
×
783
        }
×
784

785
        if err = c.OVNNbClient.DeleteLogicalSwitch(key); err != nil {
×
786
                klog.Errorf("delete logical switch %s: %v", key, err)
×
787
                return err
×
788
        }
×
789

790
        nss, err := c.namespacesLister.List(labels.Everything())
×
791
        if err != nil {
×
792
                klog.Errorf("failed to list namespaces, %v", err)
×
793
                return err
×
794
        }
×
795

796
        // re-annotate namespace
797
        for _, ns := range nss {
×
798
                annotations := ns.GetAnnotations()
×
799
                if annotations == nil {
×
800
                        continue
×
801
                }
802

803
                if slices.Contains(strings.Split(annotations[util.LogicalSwitchAnnotation], ","), key) {
×
804
                        c.enqueueAddNamespace(ns)
×
805
                }
×
806
        }
807

808
        return c.delLocalnet(key)
×
809
}
810

811
func (c *Controller) handleDeleteSubnet(subnet *kubeovnv1.Subnet) error {
×
812
        c.subnetKeyMutex.LockKey(subnet.Name)
×
813
        defer func() { _ = c.subnetKeyMutex.UnlockKey(subnet.Name) }()
×
814

815
        c.updateVpcStatusQueue.Add(subnet.Spec.Vpc)
×
816
        klog.Infof("delete u2o interconnection policy route for subnet %s", subnet.Name)
×
817
        if err := c.deletePolicyRouteForU2OInterconn(subnet); err != nil {
×
818
                klog.Errorf("failed to delete policy route for underlay to overlay subnet interconnection %s, %v", subnet.Name, err)
×
819
                return err
×
820
        }
×
821
        if subnet.Spec.Vpc != c.config.ClusterRouter {
×
822
                if err := c.deleteStaticRouteForU2OInterconn(subnet); err != nil {
×
823
                        klog.Errorf("failed to delete static route for underlay to overlay subnet interconnection %s, %v", subnet.Name, err)
×
824
                        return err
×
825
                }
×
826
        }
827

828
        u2oInterconnName := fmt.Sprintf(util.U2OInterconnName, subnet.Spec.Vpc, subnet.Name)
×
829
        if err := c.config.KubeOvnClient.KubeovnV1().IPs().Delete(context.Background(), u2oInterconnName, metav1.DeleteOptions{}); err != nil {
×
830
                if !k8serrors.IsNotFound(err) {
×
831
                        klog.Errorf("failed to delete ip %s, %v", u2oInterconnName, err)
×
832
                        return err
×
833
                }
×
834
        }
835

836
        if subnet.Spec.Vpc != c.config.ClusterRouter {
×
837
                if err := c.deleteCustomVPCPolicyRoutesForSubnet(subnet); err != nil {
×
838
                        klog.Errorf("failed to delete custom vpc routes subnet %s, %v", subnet.Name, err)
×
839
                        return err
×
840
                }
×
841
        }
842

843
        klog.Infof("delete policy route for %s subnet %s", subnet.Spec.GatewayType, subnet.Name)
×
844
        if err := c.deletePolicyRouteByGatewayType(subnet, subnet.Spec.GatewayType, true); err != nil {
×
845
                klog.Errorf("failed to delete policy route for overlay subnet %s, %v", subnet.Name, err)
×
846
                return err
×
847
        }
×
848

849
        err := c.handleDeleteLogicalSwitch(subnet.Name)
×
850
        if err != nil {
×
851
                klog.Errorf("failed to delete logical switch %s %v", subnet.Name, err)
×
852
                return err
×
853
        }
×
854

855
        var router string
×
856
        vpc, err := c.vpcsLister.Get(subnet.Spec.Vpc)
×
857
        if err != nil {
×
858
                if !k8serrors.IsNotFound(err) {
×
859
                        klog.Errorf("get vpc %s: %v", subnet.Spec.Vpc, err)
×
860
                        return err
×
861
                }
×
862
                router = c.config.ClusterRouter
×
863
        } else {
×
864
                router = vpc.Status.Router
×
865
        }
×
866

867
        lspName := fmt.Sprintf("%s-%s", subnet.Name, router)
×
868
        lrpName := fmt.Sprintf("%s-%s", router, subnet.Name)
×
869
        if err = c.OVNNbClient.RemoveLogicalPatchPort(lspName, lrpName); err != nil {
×
870
                klog.Errorf("delete router port %s and %s:%v", lspName, lrpName, err)
×
871
                return err
×
872
        }
×
873

874
        vlans, err := c.vlansLister.List(labels.Everything())
×
875
        if err != nil && !k8serrors.IsNotFound(err) {
×
876
                klog.Errorf("failed to list vlans: %v", err)
×
877
                return err
×
878
        }
×
879

880
        for _, vlan := range vlans {
×
881
                if err = c.updateVlanStatusForSubnetDeletion(vlan, subnet.Name); err != nil {
×
882
                        klog.Error(err)
×
883
                        return err
×
884
                }
×
885
        }
886

887
        return nil
×
888
}
889

890
func (c *Controller) updateVlanStatusForSubnetDeletion(vlan *kubeovnv1.Vlan, subnet string) error {
×
891
        if !slices.Contains(vlan.Status.Subnets, subnet) {
×
892
                return nil
×
893
        }
×
894

895
        newVlan := vlan.DeepCopy()
×
896
        newVlan.Status.Subnets = util.RemoveString(newVlan.Status.Subnets, subnet)
×
897
        _, err := c.config.KubeOvnClient.KubeovnV1().Vlans().UpdateStatus(context.Background(), newVlan, metav1.UpdateOptions{})
×
898
        if err != nil {
×
899
                klog.Errorf("failed to update status of vlan %s: %v", vlan.Name, err)
×
900
                return err
×
901
        }
×
902

903
        return nil
×
904
}
905

906
func (c *Controller) reconcileSubnet(subnet *kubeovnv1.Subnet) error {
×
907
        if err := c.reconcileNamespaces(subnet); err != nil {
×
908
                klog.Errorf("reconcile namespaces for subnet %s failed, %v", subnet.Name, err)
×
909
                return err
×
910
        }
×
911

912
        if err := c.reconcileRouteTableForSubnet(subnet); err != nil {
×
913
                klog.Errorf("reconcile route table for subnet %s failed, %v", subnet.Name, err)
×
914
                return err
×
915
        }
×
916

917
        if subnet.Spec.Vpc == c.config.ClusterRouter {
×
918
                if err := c.reconcileOvnDefaultVpcRoute(subnet); err != nil {
×
919
                        klog.Errorf("reconcile default vpc ovn route for subnet %s failed: %v", subnet.Name, err)
×
920
                        return err
×
921
                }
×
922
        } else if err := c.reconcileCustomVpcStaticRoute(subnet); err != nil {
×
923
                klog.Errorf("reconcile custom vpc ovn route for subnet %s failed: %v", subnet.Name, err)
×
924
                return err
×
925
        }
×
926

927
        if err := c.reconcileVlan(subnet); err != nil {
×
928
                klog.Errorf("reconcile vlan for subnet %s failed, %v", subnet.Name, err)
×
929
                return err
×
930
        }
×
931

932
        if err := c.reconcileVips(subnet); err != nil {
×
933
                klog.Errorf("reconcile vips for subnet %s failed, %v", subnet.Name, err)
×
934
                return err
×
935
        }
×
936
        return nil
×
937
}
938

939
func (c *Controller) reconcileVips(subnet *kubeovnv1.Subnet) error {
1✔
940
        /* get all virtual port belongs to this logical switch */
1✔
941
        lsps, err := c.OVNNbClient.ListLogicalSwitchPorts(true, map[string]string{logicalSwitchKey: subnet.Name}, func(lsp *ovnnb.LogicalSwitchPort) bool {
1✔
942
                return lsp.Type == "virtual"
×
943
        })
×
944
        if err != nil {
1✔
945
                klog.Errorf("failed to find virtual port for subnet %s: %v", subnet.Name, err)
×
946
                return err
×
947
        }
×
948

949
        /* filter all invalid virtual port */
950
        existVips := make(map[string]string) // key is vip, value is port name
1✔
951
        for _, lsp := range lsps {
2✔
952
                vip, ok := lsp.Options["virtual-ip"]
1✔
953
                if !ok {
1✔
954
                        continue // ignore vip which is empty
×
955
                }
956

957
                if net.ParseIP(vip) == nil {
1✔
958
                        continue // ignore invalid vip
×
959
                }
960

961
                existVips[vip] = lsp.Name
1✔
962
        }
963

964
        /* filter virtual port to be added and old virtual port to be deleted */
965
        var newVips []string
1✔
966
        for _, vip := range subnet.Spec.Vips {
2✔
967
                if _, ok := existVips[vip]; !ok {
2✔
968
                        // new virtual port to be added
1✔
969
                        newVips = append(newVips, vip)
1✔
970
                } else {
2✔
971
                        // delete old virtual port that do not need to be deleted
1✔
972
                        delete(existVips, vip)
1✔
973
                }
1✔
974
        }
975

976
        // delete old virtual ports
977
        for _, lspName := range existVips {
2✔
978
                if err = c.OVNNbClient.DeleteLogicalSwitchPort(lspName); err != nil {
1✔
979
                        klog.Errorf("delete virtual port %s lspName from logical switch %s: %v", lspName, subnet.Name, err)
×
980
                        return err
×
981
                }
×
982
        }
983

984
        // add new virtual port
985
        if err = c.OVNNbClient.CreateVirtualLogicalSwitchPorts(subnet.Name, newVips...); err != nil {
1✔
986
                klog.Errorf("create virtual port with vips %v from logical switch %s: %v", newVips, subnet.Name, err)
×
987
                return err
×
988
        }
×
989

990
        c.syncVirtualPortsQueue.Add(subnet.Name)
1✔
991
        return nil
1✔
992
}
993

994
func (c *Controller) syncVirtualPort(key string) error {
1✔
995
        subnet, err := c.subnetsLister.Get(key)
1✔
996
        if err != nil {
1✔
997
                if k8serrors.IsNotFound(err) {
×
998
                        return nil
×
999
                }
×
1000
                klog.Errorf("failed to get subnet %s, %v", key, err)
×
1001
                return err
×
1002
        }
1003
        if len(subnet.Spec.Vips) == 0 {
1✔
1004
                return nil
×
1005
        }
×
1006

1007
        externalIDs := map[string]string{
1✔
1008
                logicalSwitchKey: subnet.Name,
1✔
1009
                "attach-vips":    "true",
1✔
1010
        }
1✔
1011

1✔
1012
        lsps, err := c.OVNNbClient.ListNormalLogicalSwitchPorts(true, externalIDs)
1✔
1013
        if err != nil {
1✔
1014
                klog.Errorf("list logical switch %s ports: %v", subnet.Name, err)
×
1015
                return err
×
1016
        }
×
1017

1018
        for _, vip := range subnet.Spec.Vips {
2✔
1019
                if !util.CIDRContainIP(subnet.Spec.CIDRBlock, vip) {
1✔
1020
                        klog.Errorf("vip %s is out of range to subnet %s", vip, subnet.Name)
×
1021
                        continue
×
1022
                }
1023

1024
                var virtualParents []string
1✔
1025
                for _, lsp := range lsps {
2✔
1026
                        vips, ok := lsp.ExternalIDs["vips"]
1✔
1027
                        if !ok {
1✔
1028
                                continue // ignore vips which is empty
×
1029
                        }
1030

1031
                        if slices.Contains(strings.Split(vips, ","), vip) {
2✔
1032
                                virtualParents = append(virtualParents, lsp.Name)
1✔
1033
                        }
1✔
1034
                }
1035

1036
                // logical switch port has no valid vip
1037
                if len(virtualParents) == 0 {
2✔
1038
                        continue
1✔
1039
                }
1040

1041
                if err = c.OVNNbClient.SetLogicalSwitchPortVirtualParents(subnet.Name, strings.Join(virtualParents, ","), vip); err != nil {
1✔
1042
                        klog.Errorf("set vip %s virtual parents %v: %v", vip, virtualParents, err)
×
1043
                        return err
×
1044
                }
×
1045
        }
1046

1047
        return nil
1✔
1048
}
1049

1050
func (c *Controller) reconcileNamespaces(subnet *kubeovnv1.Subnet) error {
×
1051
        var (
×
1052
                namespaces []*v1.Namespace
×
1053
                err        error
×
1054
        )
×
1055

×
1056
        // 1. get all namespaces should be updated
×
1057
        expectNss, err := c.getNamespacesBySelector(subnet.Spec.NamespaceSelectors)
×
1058
        if err != nil {
×
1059
                klog.Errorf("failed to list namespaces by selector, %v", err)
×
1060
                return err
×
1061
        }
×
1062
        for _, ns := range subnet.Spec.Namespaces {
×
1063
                if !slices.Contains(expectNss, ns) {
×
1064
                        expectNss = append(expectNss, ns)
×
1065
                }
×
1066
        }
1067

1068
        // 2. update namespaces
1069
        for _, expectNs := range expectNss {
×
1070
                checkNs, err := c.namespacesLister.Get(expectNs)
×
1071
                if err != nil {
×
1072
                        if k8serrors.IsNotFound(err) {
×
1073
                                continue
×
1074
                        }
1075
                        klog.Error(err)
×
1076
                        return err
×
1077
                }
1078
                if checkNs.Annotations != nil && slices.Contains(strings.Split(checkNs.Annotations[util.LogicalSwitchAnnotation], ","), subnet.Name) {
×
1079
                        // when subnet cidr changed, the ns annotation with the subnet should be updated
×
1080
                        if !slices.Contains(strings.Split(checkNs.Annotations[util.CidrAnnotation], ";"), subnet.Spec.CIDRBlock) {
×
1081
                                c.addNamespaceQueue.Add(checkNs.Name)
×
1082
                        }
×
1083
                        continue
×
1084
                }
1085
                c.addNamespaceQueue.Add(expectNs)
×
1086
        }
1087

1088
        // 3. update unbind namespace annotation
1089
        if namespaces, err = c.namespacesLister.List(labels.Everything()); err != nil {
×
1090
                klog.Errorf("failed to list namespaces, %v", err)
×
1091
                return err
×
1092
        }
×
1093

1094
        for _, ns := range namespaces {
×
1095
                if ns.Annotations != nil && slices.Contains(strings.Split(ns.Annotations[util.LogicalSwitchAnnotation], ","), subnet.Name) {
×
1096
                        if slices.Contains(expectNss, ns.Name) {
×
1097
                                continue
×
1098
                        }
1099
                        // ns deleted from subnet.Spec.Namespaces or subnet delete namespaceSelectors which match the checked namespace
1100
                        c.addNamespaceQueue.Add(ns.Name)
×
1101
                }
1102
        }
1103

1104
        return nil
×
1105
}
1106

1107
func (c *Controller) getNamespacesBySelector(nsSelectors []metav1.LabelSelector) ([]string, error) {
×
1108
        var expectNss []string
×
1109
        for _, nsSelector := range nsSelectors {
×
1110
                matchSelector, err := metav1.LabelSelectorAsSelector(&nsSelector)
×
1111
                if err != nil {
×
1112
                        klog.Errorf("failed to convert label selector, %v", err)
×
1113
                        return expectNss, err
×
1114
                }
×
1115

1116
                nss, err := c.namespacesLister.List(matchSelector)
×
1117
                if err != nil {
×
1118
                        klog.Errorf("failed to list namespaces by selector, %v", err)
×
1119
                        return expectNss, err
×
1120
                }
×
1121
                for _, ns := range nss {
×
1122
                        expectNss = append(expectNss, ns.Name)
×
1123
                }
×
1124
        }
1125
        return expectNss, nil
×
1126
}
1127

1128
func (c *Controller) reconcileCustomVpcBfdStaticRoute(vpcName, subnetName string) error {
×
1129
        // vpc enable bfd and subnet enable ecmp
×
1130
        // use static ecmp route with bfd
×
1131
        ovnEips, err := c.ovnEipsLister.List(labels.SelectorFromSet(labels.Set{util.OvnEipTypeLabel: util.OvnEipTypeLSP}))
×
1132
        if err != nil {
×
1133
                klog.Errorf("failed to list node external ovn eip, %v", err)
×
1134
                return err
×
1135
        }
×
1136
        if len(ovnEips) < 2 {
×
1137
                err := fmt.Errorf("ecmp route with bfd for HA, which need two %s type eips at least, has %d", util.OvnEipTypeLSP, len(ovnEips))
×
1138
                klog.Error(err)
×
1139
                return err
×
1140
        }
×
1141

1142
        subnet, err := c.subnetsLister.Get(subnetName)
×
1143
        if err != nil {
×
1144
                klog.Errorf("failed to get subnet %s, %v", subnetName, err)
×
1145
                return err
×
1146
        }
×
1147
        cachedVpc, err := c.vpcsLister.Get(vpcName)
×
1148
        if err != nil {
×
1149
                if k8serrors.IsNotFound(err) {
×
1150
                        return nil
×
1151
                }
×
1152
                klog.Errorf("failed to get vpc %s, %v", vpcName, err)
×
1153
                return err
×
1154
        }
1155

1156
        var (
×
1157
                needUpdate, v4Exist bool
×
1158
                lrpEipName          string
×
1159
        )
×
1160

×
1161
        lrpEipName = fmt.Sprintf("%s-%s", vpcName, c.config.ExternalGatewaySwitch)
×
1162
        lrpEip, err := c.ovnEipsLister.Get(lrpEipName)
×
1163
        if err != nil {
×
1164
                err := fmt.Errorf("failed to get lrp eip %s, %w", lrpEipName, err)
×
1165
                klog.Error(err)
×
1166
                return err
×
1167
        }
×
1168
        if !lrpEip.Status.Ready || lrpEip.Status.V4Ip == "" {
×
1169
                err := fmt.Errorf("lrp eip %q not ready", lrpEipName)
×
1170
                klog.Error(err)
×
1171
                return err
×
1172
        }
×
1173
        vpc := cachedVpc.DeepCopy()
×
1174

×
1175
        for _, eip := range ovnEips {
×
1176
                if !eip.Status.Ready || eip.Status.V4Ip == "" {
×
1177
                        err := fmt.Errorf("ovn eip %q not ready", eip.Name)
×
1178
                        klog.Error(err)
×
1179
                        return err
×
1180
                }
×
1181
                bfd, err := c.OVNNbClient.CreateBFD(lrpEipName, eip.Status.V4Ip, c.config.BfdMinRx, c.config.BfdMinTx, c.config.BfdDetectMult, nil)
×
1182
                if err != nil {
×
1183
                        klog.Error(err)
×
1184
                        return err
×
1185
                }
×
1186
                // TODO:// support v6
1187
                v4Exist = false
×
1188
                for _, route := range vpc.Spec.StaticRoutes {
×
1189
                        if route.Policy == kubeovnv1.PolicySrc &&
×
1190
                                route.NextHopIP == eip.Status.V4Ip &&
×
1191
                                route.ECMPMode == util.StaticRouteBfdEcmp &&
×
1192
                                route.CIDR == subnet.Spec.CIDRBlock &&
×
1193
                                route.RouteTable == subnet.Spec.RouteTable {
×
1194
                                v4Exist = true
×
1195
                                break
×
1196
                        }
1197
                }
1198
                if !v4Exist {
×
1199
                        // add ecmp type static route with bfd
×
1200
                        route := &kubeovnv1.StaticRoute{
×
1201
                                Policy:     kubeovnv1.PolicySrc,
×
1202
                                CIDR:       subnet.Spec.CIDRBlock,
×
1203
                                NextHopIP:  eip.Status.V4Ip,
×
1204
                                ECMPMode:   util.StaticRouteBfdEcmp,
×
1205
                                BfdID:      bfd.UUID,
×
1206
                                RouteTable: subnet.Spec.RouteTable,
×
1207
                        }
×
1208
                        klog.Infof("add ecmp bfd static route %v", route)
×
1209
                        vpc.Spec.StaticRoutes = append(vpc.Spec.StaticRoutes, route)
×
1210
                        needUpdate = true
×
1211
                }
×
1212
        }
1213
        if needUpdate {
×
1214
                if _, err = c.config.KubeOvnClient.KubeovnV1().Vpcs().Update(context.Background(), vpc, metav1.UpdateOptions{}); err != nil {
×
1215
                        klog.Errorf("failed to update vpc spec static route %s, %v", vpc.Name, err)
×
1216
                        return err
×
1217
                }
×
1218
                if err = c.patchVpcBfdStatus(vpc.Name); err != nil {
×
1219
                        klog.Errorf("failed to patch vpc %s, %v", vpc.Name, err)
×
1220
                        return err
×
1221
                }
×
1222
        }
1223
        return nil
×
1224
}
1225

1226
func (c *Controller) reconcileCustomVpcDelNormalStaticRoute(vpcName string) error {
×
1227
        // normal static route is prior than ecmp bfd static route
×
1228
        // if use ecmp bfd static route, normal static route should not exist
×
1229
        defaultExternalSubnet, err := c.subnetsLister.Get(c.config.ExternalGatewaySwitch)
×
1230
        if err != nil {
×
1231
                klog.Errorf("failed to get default external switch subnet %s: %v", c.config.ExternalGatewaySwitch, err)
×
1232
                return err
×
1233
        }
×
1234
        gatewayV4, gatewayV6 := util.SplitStringIP(defaultExternalSubnet.Spec.Gateway)
×
1235
        needUpdate := false
×
1236
        cachedVpc, err := c.vpcsLister.Get(vpcName)
×
1237
        if err != nil {
×
1238
                if k8serrors.IsNotFound(err) {
×
1239
                        return nil
×
1240
                }
×
1241
                klog.Errorf("failed to get vpc %s, %v", vpcName, err)
×
1242
                return err
×
1243
        }
1244
        vpc := cachedVpc.DeepCopy()
×
1245
        routeTotal := len(vpc.Spec.StaticRoutes)
×
1246
        routes := make([]*kubeovnv1.StaticRoute, 0, routeTotal)
×
1247
        for _, route := range vpc.Spec.StaticRoutes {
×
1248
                if route.Policy == kubeovnv1.PolicyDst &&
×
1249
                        (route.NextHopIP == gatewayV4 || route.NextHopIP == gatewayV6) &&
×
1250
                        (route.CIDR == "0.0.0.0/0" || route.CIDR == "::/0") {
×
1251
                        klog.Infof("in order to use ecmp bfd route, need remove normal static route %v", route)
×
1252
                        needUpdate = true
×
1253
                } else {
×
1254
                        routes = append(routes, route)
×
1255
                }
×
1256
        }
1257

1258
        if needUpdate {
×
1259
                vpc.Spec.StaticRoutes = routes
×
1260
                if _, err = c.config.KubeOvnClient.KubeovnV1().Vpcs().Update(context.Background(), vpc, metav1.UpdateOptions{}); err != nil {
×
1261
                        klog.Errorf("failed to update vpc spec static route %s, %v", vpc.Name, err)
×
1262
                        return err
×
1263
                }
×
1264
        }
1265

1266
        if err = c.patchVpcBfdStatus(vpc.Name); err != nil {
×
1267
                klog.Errorf("failed to patch vpc %s, %v", vpc.Name, err)
×
1268
                return err
×
1269
        }
×
1270

1271
        return nil
×
1272
}
1273

1274
func (c *Controller) reconcileDistributedSubnetRouteInDefaultVpc(subnet *kubeovnv1.Subnet) error {
×
1275
        if subnet.Spec.GatewayNode != "" || subnet.Status.ActivateGateway != "" {
×
1276
                klog.Infof("delete old centralized policy route for subnet %s", subnet.Name)
×
1277
                if err := c.deletePolicyRouteForCentralizedSubnet(subnet); err != nil {
×
1278
                        klog.Errorf("failed to delete policy route for subnet %s, %v", subnet.Name, err)
×
1279
                        return err
×
1280
                }
×
1281

1282
                subnet.Spec.GatewayNode = ""
×
1283
                if _, err := c.config.KubeOvnClient.KubeovnV1().Subnets().Update(context.Background(), subnet, metav1.UpdateOptions{}); err != nil {
×
1284
                        klog.Errorf("failed to remove gatewayNode or activateGateway from subnet %s, %v", subnet.Name, err)
×
1285
                        return err
×
1286
                }
×
1287
                subnet.Status.ActivateGateway = ""
×
1288
                if err := c.patchSubnetStatus(subnet, "ChangeToDistributedGw", ""); err != nil {
×
1289
                        klog.Error(err)
×
1290
                        return err
×
1291
                }
×
1292
        }
1293

1294
        nodes, err := c.nodesLister.List(labels.Everything())
×
1295
        if err != nil {
×
1296
                klog.Errorf("failed to list nodes: %v", err)
×
1297
                return err
×
1298
        }
×
1299
        for _, node := range nodes {
×
1300
                if err = c.createPortGroupForDistributedSubnet(node, subnet); err != nil {
×
1301
                        klog.Errorf("failed to create port group %v", err)
×
1302
                        return err
×
1303
                }
×
1304
                if node.Annotations[util.AllocatedAnnotation] != "true" {
×
1305
                        klog.Warningf("node %s has not been successfully initialized, skip adding policy route for subnet %s", node.Name, subnet.Name)
×
1306
                        continue
×
1307
                }
1308
                nodeIP, err := getNodeTunlIP(node)
×
1309
                if err != nil {
×
1310
                        klog.Errorf("failed to get node %s tunnel ip, %v", node.Name, err)
×
1311
                        return err
×
1312
                }
×
1313
                nextHop := getNextHopByTunnelIP(nodeIP)
×
1314
                v4IP, v6IP := util.SplitStringIP(nextHop)
×
1315
                if err = c.addPolicyRouteForDistributedSubnet(subnet, node.Name, v4IP, v6IP); err != nil {
×
1316
                        klog.Errorf("failed to add policy router for node %s and subnet %s: %v", node.Name, subnet.Name, err)
×
1317
                        return err
×
1318
                }
×
1319
        }
1320

1321
        portGroups, err := c.OVNNbClient.ListPortGroups(map[string]string{"subnet": subnet.Name, "node": "", networkPolicyKey: ""})
×
1322
        if err != nil {
×
1323
                klog.Errorf("failed to list port groups for subnet %s: %v", subnet.Name, err)
×
1324
                return err
×
1325
        }
×
1326

1327
        pods, err := c.podsLister.Pods(metav1.NamespaceAll).List(labels.Everything())
×
1328
        if err != nil {
×
1329
                klog.Errorf("failed to list pods %v", err)
×
1330
                return err
×
1331
        }
×
1332
        for _, pod := range pods {
×
1333
                if !isPodAlive(pod) || pod.Spec.NodeName == "" {
×
1334
                        continue
×
1335
                }
1336

1337
                podNets, err := c.getPodKubeovnNets(pod)
×
1338
                if err != nil {
×
1339
                        klog.Errorf("failed to get pod nets %v", err)
×
1340
                        continue
×
1341
                }
1342

1343
                podPorts := make([]string, 0, 1)
×
1344
                for _, podNet := range podNets {
×
1345
                        if !isOvnSubnet(podNet.Subnet) {
×
1346
                                continue
×
1347
                        }
1348

1349
                        if pod.Annotations[fmt.Sprintf(util.IPAddressAnnotationTemplate, podNet.ProviderName)] == "" || pod.Annotations[fmt.Sprintf(util.LogicalSwitchAnnotationTemplate, podNet.ProviderName)] != subnet.Name {
×
1350
                                continue
×
1351
                        }
1352

1353
                        podName := c.getNameByPod(pod)
×
1354
                        portName := ovs.PodNameToPortName(podName, pod.Namespace, podNet.ProviderName)
×
1355
                        podPorts = append(podPorts, portName)
×
1356
                }
1357

1358
                pgName := getOverlaySubnetsPortGroupName(subnet.Name, pod.Spec.NodeName)
×
1359
                portsToAdd := make([]string, 0, len(podPorts))
×
1360
                for _, port := range podPorts {
×
1361
                        exist, err := c.OVNNbClient.LogicalSwitchPortExists(port)
×
1362
                        if err != nil {
×
1363
                                klog.Error(err)
×
1364
                                return err
×
1365
                        }
×
1366

1367
                        if !exist {
×
1368
                                klog.Errorf("lsp does not exist for pod %v, please delete the pod and retry", port)
×
1369
                                continue
×
1370
                        }
1371

1372
                        portsToAdd = append(portsToAdd, port)
×
1373
                }
1374

1375
                // remove lsp from other port groups
1376
                // we need to do this because the pod, e.g. a sts/vm, can be rescheduled to another node
1377
                for _, pg := range portGroups {
×
1378
                        if pg.Name == pgName {
×
1379
                                continue
×
1380
                        }
1381
                        if err = c.OVNNbClient.PortGroupRemovePorts(pg.Name, podPorts...); err != nil {
×
1382
                                klog.Errorf("remove ports from port group %s: %v", pg.Name, err)
×
1383
                                return err
×
1384
                        }
×
1385
                }
1386
                // add ports to the port group
1387
                if err = c.OVNNbClient.PortGroupAddPorts(pgName, portsToAdd...); err != nil {
×
1388
                        klog.Errorf("add ports to port group %s: %v", pgName, err)
×
1389
                        return err
×
1390
                }
×
1391
        }
1392
        return nil
×
1393
}
1394

1395
func (c *Controller) reconcileDefaultCentralizedSubnetRouteInDefaultVpc(subnet *kubeovnv1.Subnet) error {
×
1396
        gatewayNodes, err := c.getGatewayNodes(subnet)
×
1397
        if err != nil {
×
1398
                klog.Errorf("failed to get gateway nodes for subnet %s: %v", subnet.Name, err)
×
1399
                return err
×
1400
        }
×
1401

1402
        // check if activateGateway still ready
1403
        if subnet.Status.ActivateGateway != "" && slices.Contains(gatewayNodes, subnet.Status.ActivateGateway) {
×
1404
                node, err := c.nodesLister.Get(subnet.Status.ActivateGateway)
×
1405
                if err == nil && nodeReady(node) {
×
1406
                        klog.Infof("subnet %s uses the old activate gw %s", subnet.Name, node.Name)
×
1407

×
1408
                        nodeTunlIPAddr, err := getNodeTunlIP(node)
×
1409
                        if err != nil {
×
1410
                                klog.Errorf("failed to get gatewayNode tunnel ip for subnet %s", subnet.Name)
×
1411
                                return err
×
1412
                        }
×
1413
                        nextHop := getNextHopByTunnelIP(nodeTunlIPAddr)
×
1414
                        if err = c.addPolicyRouteForCentralizedSubnet(subnet, subnet.Status.ActivateGateway, nil, strings.Split(nextHop, ",")); err != nil {
×
1415
                                klog.Errorf("failed to add active-backup policy route for centralized subnet %s: %v", subnet.Name, err)
×
1416
                                return err
×
1417
                        }
×
1418
                        return nil
×
1419
                }
1420
        }
1421

1422
        klog.Info("find a new activate node")
×
1423
        // need a new activate gateway
×
1424
        newActivateNode := ""
×
1425
        var nodeTunlIPAddr []net.IP
×
1426
        for _, gw := range gatewayNodes {
×
1427
                node, err := c.nodesLister.Get(gw)
×
1428
                if err == nil && nodeReady(node) {
×
1429
                        newActivateNode = node.Name
×
1430
                        nodeTunlIPAddr, err = getNodeTunlIP(node)
×
1431
                        if err != nil {
×
1432
                                klog.Error(err)
×
1433
                                return err
×
1434
                        }
×
1435
                        klog.Infof("subnet %s uses a new activate gw %s", subnet.Name, node.Name)
×
1436
                        break
×
1437
                }
1438
        }
1439
        if newActivateNode == "" {
×
1440
                klog.Warningf("all gateways of subnet %s are not ready", subnet.Name)
×
1441
                subnet.Status.ActivateGateway = newActivateNode
×
1442
                if err := c.patchSubnetStatus(subnet, "NoActiveGatewayFound", fmt.Sprintf("subnet %s gws are not ready", subnet.Name)); err != nil {
×
1443
                        klog.Error(err)
×
1444
                        return err
×
1445
                }
×
1446

1447
                return fmt.Errorf("subnet %s gws are not ready", subnet.Name)
×
1448
        }
1449

1450
        nextHop := getNextHopByTunnelIP(nodeTunlIPAddr)
×
1451
        klog.Infof("subnet %s configure new gateway node, nextHop %s", subnet.Name, nextHop)
×
1452
        if err := c.addPolicyRouteForCentralizedSubnet(subnet, newActivateNode, nil, strings.Split(nextHop, ",")); err != nil {
×
1453
                klog.Errorf("failed to add policy route for active-backup centralized subnet %s: %v", subnet.Name, err)
×
1454
                return err
×
1455
        }
×
1456
        subnet.Status.ActivateGateway = newActivateNode
×
1457
        if err := c.patchSubnetStatus(subnet, "ReconcileCentralizedGatewaySuccess", ""); err != nil {
×
1458
                klog.Error(err)
×
1459
                return err
×
1460
        }
×
1461

1462
        klog.Infof("delete old distributed policy route for subnet %s", subnet.Name)
×
1463
        if err := c.deletePolicyRouteByGatewayType(subnet, kubeovnv1.GWDistributedType, false); err != nil {
×
1464
                klog.Errorf("failed to delete policy route for overlay subnet %s, %v", subnet.Name, err)
×
1465
                return err
×
1466
        }
×
1467
        return nil
×
1468
}
1469

1470
func (c *Controller) reconcileEcmpCentralizedSubnetRouteInDefaultVpc(subnet *kubeovnv1.Subnet) error {
×
1471
        gatewayNodes, err := c.getGatewayNodes(subnet)
×
1472
        if err != nil {
×
1473
                klog.Errorf("failed to get gateway nodes for subnet %s: %v", subnet.Name, err)
×
1474
                return err
×
1475
        }
×
1476

1477
        nodeIPs := [2][]string{make([]string, 0, len(gatewayNodes)), make([]string, 0, len(gatewayNodes))}
×
1478
        nameIPMaps := [2]map[string]string{make(map[string]string, len(gatewayNodes)), make(map[string]string, len(gatewayNodes))}
×
1479

×
1480
        for _, gw := range gatewayNodes {
×
1481
                node, err := c.nodesLister.Get(gw)
×
1482
                if err != nil {
×
1483
                        klog.Errorf("failed to get gw node %s, %v", gw, err)
×
1484
                        continue
×
1485
                }
1486
                if !nodeReady(node) {
×
1487
                        klog.Errorf("gateway node %v is not ready", gw)
×
1488
                        continue
×
1489
                }
1490
                nexthopNodeIP := strings.TrimSpace(node.Annotations[util.IPAddressAnnotation])
×
1491
                if nexthopNodeIP == "" {
×
1492
                        klog.Errorf("gateway node %v has no ip annotation", node.Name)
×
1493
                        continue
×
1494
                }
1495
                nexthopV4, nexthopV6 := util.SplitStringIP(nexthopNodeIP)
×
1496
                if nexthopV4 != "" {
×
1497
                        nameIPMaps[0][node.Name] = nexthopV4
×
1498
                        nodeIPs[0] = append(nodeIPs[0], nexthopV4)
×
1499
                }
×
1500
                if nexthopV6 != "" {
×
1501
                        nameIPMaps[1][node.Name] = nexthopV6
×
1502
                        nodeIPs[1] = append(nodeIPs[1], nexthopV6)
×
1503
                }
×
1504
        }
1505

1506
        v4CIDR, v6CIDR := util.SplitStringIP(subnet.Spec.CIDRBlock)
×
1507
        cidrs := [2]string{v4CIDR, v6CIDR}
×
1508
        for i, cidr := range cidrs {
×
1509
                if len(nodeIPs[i]) == 0 || cidr == "" { // #nosec G602
×
1510
                        continue
×
1511
                }
1512
                klog.Infof("delete old distributed policy route for subnet %s", subnet.Name)
×
1513
                if err := c.deletePolicyRouteByGatewayType(subnet, kubeovnv1.GWDistributedType, false); err != nil {
×
1514
                        klog.Errorf("failed to delete policy route for overlay subnet %s, %v", subnet.Name, err)
×
1515
                        return err
×
1516
                }
×
1517
                klog.Infof("subnet %s configure ecmp policy route, nexthops %v", subnet.Name, nodeIPs[i])                     // #nosec G602
×
1518
                if err := c.updatePolicyRouteForCentralizedSubnet(subnet.Name, cidr, nodeIPs[i], nameIPMaps[i]); err != nil { // #nosec G602
×
1519
                        klog.Errorf("failed to add ecmp policy route for centralized subnet %s: %v", subnet.Name, err)
×
1520
                        return err
×
1521
                }
×
1522
        }
1523
        return nil
×
1524
}
1525

1526
func (c *Controller) reconcileOvnDefaultVpcRoute(subnet *kubeovnv1.Subnet) error {
×
1527
        if subnet.Name == c.config.NodeSwitch {
×
1528
                if err := c.addCommonRoutesForSubnet(subnet); err != nil {
×
1529
                        klog.Error(err)
×
1530
                        return err
×
1531
                }
×
1532
                return nil
×
1533
        }
1534

1535
        if subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway {
×
1536
                // physical switch provide gw for this underlay subnet
×
1537
                pods, err := c.podsLister.Pods(metav1.NamespaceAll).List(labels.Everything())
×
1538
                if err != nil {
×
1539
                        klog.Errorf("failed to list pods %v", err)
×
1540
                        return err
×
1541
                }
×
1542
                for _, pod := range pods {
×
1543
                        if pod.Annotations[util.LogicalSwitchAnnotation] == subnet.Name && pod.Annotations[util.IPAddressAnnotation] != "" {
×
1544
                                if err := c.deleteStaticRoute(
×
1545
                                        pod.Annotations[util.IPAddressAnnotation], c.config.ClusterRouter, subnet.Spec.RouteTable); err != nil {
×
1546
                                        klog.Errorf("failed to delete static route %v", err)
×
1547
                                        return err
×
1548
                                }
×
1549
                        }
1550
                }
1551

1552
                if !subnet.Spec.LogicalGateway && subnet.Name != c.config.ExternalGatewaySwitch && !subnet.Spec.U2OInterconnection {
×
1553
                        lspName := fmt.Sprintf("%s-%s", subnet.Name, c.config.ClusterRouter)
×
1554
                        klog.Infof("delete logical switch port %s", lspName)
×
1555
                        if err := c.OVNNbClient.DeleteLogicalSwitchPort(lspName); err != nil {
×
1556
                                klog.Errorf("failed to delete lsp %s-%s, %v", subnet.Name, c.config.ClusterRouter, err)
×
1557
                                return err
×
1558
                        }
×
1559
                        lrpName := fmt.Sprintf("%s-%s", c.config.ClusterRouter, subnet.Name)
×
1560
                        klog.Infof("delete logical router port %s", lrpName)
×
1561
                        if err := c.OVNNbClient.DeleteLogicalRouterPort(lrpName); err != nil {
×
1562
                                klog.Errorf("failed to delete lrp %s: %v", lrpName, err)
×
1563
                                return err
×
1564
                        }
×
1565
                }
1566

1567
                if subnet.Spec.U2OInterconnection && subnet.Status.U2OInterconnectionIP != "" {
×
1568
                        if err := c.addPolicyRouteForU2OInterconn(subnet); err != nil {
×
1569
                                klog.Errorf("failed to add policy route for underlay to overlay subnet interconnection %s %v", subnet.Name, err)
×
1570
                                return err
×
1571
                        }
×
1572
                } else {
×
1573
                        if err := c.deletePolicyRouteForU2OInterconn(subnet); err != nil {
×
1574
                                klog.Errorf("failed to delete policy route for underlay to overlay subnet interconnection %s, %v", subnet.Name, err)
×
1575
                                return err
×
1576
                        }
×
1577
                }
1578

1579
                if (!c.config.EnableLb || (subnet.Spec.EnableLb == nil || !*subnet.Spec.EnableLb)) &&
×
1580
                        subnet.Spec.U2OInterconnection && subnet.Status.U2OInterconnectionIP != "" {
×
1581
                        if err := c.addPolicyRouteForU2ONoLoadBalancer(subnet); err != nil {
×
1582
                                klog.Errorf("failed to add policy route for underlay to overlay subnet interconnection without enabling loadbalancer %s %v", subnet.Name, err)
×
1583
                                return err
×
1584
                        }
×
1585
                } else {
×
1586
                        if err := c.deletePolicyRouteForU2ONoLoadBalancer(subnet); err != nil {
×
1587
                                klog.Errorf("failed to delete policy route for underlay to overlay subnet interconnection without enabling loadbalancer %s, %v", subnet.Name, err)
×
1588
                                return err
×
1589
                        }
×
1590
                }
1591
        } else {
×
1592
                // It's difficult to update policy route when subnet cidr is changed, add check for cidr changed situation
×
1593
                if err := c.reconcilePolicyRouteForCidrChangedSubnet(subnet, true); err != nil {
×
1594
                        klog.Error(err)
×
1595
                        return err
×
1596
                }
×
1597

1598
                if err := c.addCommonRoutesForSubnet(subnet); err != nil {
×
1599
                        klog.Error(err)
×
1600
                        return err
×
1601
                }
×
1602

1603
                // distributed subnet, only add distributed policy route
1604
                if subnet.Spec.GatewayType == kubeovnv1.GWDistributedType {
×
1605
                        if err := c.reconcileDistributedSubnetRouteInDefaultVpc(subnet); err != nil {
×
1606
                                klog.Error(err)
×
1607
                                return err
×
1608
                        }
×
1609
                } else {
×
1610
                        // centralized subnet
×
1611
                        if subnet.Spec.GatewayNode == "" && len(subnet.Spec.GatewayNodeSelectors) == 0 {
×
1612
                                subnet.Status.NotReady("NoReadyGateway", "")
×
1613
                                if err := c.patchSubnetStatus(subnet, "NoReadyGateway", ""); err != nil {
×
1614
                                        klog.Error(err)
×
1615
                                        return err
×
1616
                                }
×
1617
                                err := fmt.Errorf("subnet %s Spec.GatewayNode or Spec.GatewayNodeSelectors must be specified for centralized gateway type", subnet.Name)
×
1618
                                klog.Error(err)
×
1619
                                return err
×
1620
                        }
1621

1622
                        gwNodeExists := c.checkSubnetGwNodesExist(subnet)
×
1623
                        if !gwNodeExists {
×
1624
                                klog.Errorf("failed to init centralized gateway for subnet %s, no gateway node exists", subnet.Name)
×
1625
                                return errors.New("failed to add ecmp policy route, no gateway node exists")
×
1626
                        }
×
1627

1628
                        if err := c.reconcilePolicyRouteForCidrChangedSubnet(subnet, false); err != nil {
×
1629
                                klog.Error(err)
×
1630
                                return err
×
1631
                        }
×
1632

1633
                        if subnet.Spec.EnableEcmp {
×
1634
                                if err := c.reconcileEcmpCentralizedSubnetRouteInDefaultVpc(subnet); err != nil {
×
1635
                                        klog.Error(err)
×
1636
                                        return err
×
1637
                                }
×
1638
                        } else {
×
1639
                                if err := c.reconcileDefaultCentralizedSubnetRouteInDefaultVpc(subnet); err != nil {
×
1640
                                        klog.Error(err)
×
1641
                                        return err
×
1642
                                }
×
1643
                        }
1644
                }
1645
        }
1646
        return nil
×
1647
}
1648

1649
func (c *Controller) reconcileCustomVpcStaticRoute(subnet *kubeovnv1.Subnet) error {
×
1650
        // in custom vpc, subnet gw type is unmeaning
×
1651
        // 1. vpc out to public network through vpc nat gw pod, the static route is auto managed by admin user
×
1652
        // 2. vpc out to public network through ovn nat lrp, whose nexthop rely on bfd ecmp, the vpc spec bfd static route is auto managed here
×
1653
        // 3. vpc out to public network through ovn nat lrp, without bfd ecmp, the vpc spec static route is auto managed here
×
1654

×
1655
        vpc, err := c.vpcsLister.Get(subnet.Spec.Vpc)
×
1656
        if err != nil {
×
1657
                if k8serrors.IsNotFound(err) {
×
1658
                        return nil
×
1659
                }
×
1660
                klog.Errorf("failed to get vpc %s, %v", subnet.Spec.Vpc, err)
×
1661
                return err
×
1662
        }
1663

1664
        if vpc.Spec.EnableExternal && vpc.Spec.EnableBfd && subnet.Spec.EnableEcmp {
×
1665
                klog.Infof("add bfd and external static ecmp route for vpc %s, subnet %s", vpc.Name, subnet.Name)
×
1666
                // handle vpc static route
×
1667
                // use static ecmp route with bfd
×
1668
                // bfd ecmp static route depend on subnet cidr
×
1669
                if err := c.reconcileCustomVpcBfdStaticRoute(vpc.Name, subnet.Name); err != nil {
×
1670
                        klog.Errorf("failed to reconcile vpc %q bfd static route", vpc.Name)
×
1671
                        return err
×
1672
                }
×
1673
        }
1674

1675
        if subnet.Spec.Vlan == "" || subnet.Spec.LogicalGateway || subnet.Spec.U2OInterconnection {
×
1676
                if err = c.addCustomVPCStaticRouteForSubnet(subnet); err != nil {
×
1677
                        klog.Errorf("failed to add static route for underlay to overlay subnet interconnection %s %v", subnet.Name, err)
×
1678
                        return err
×
1679
                }
×
1680
                if err = c.addCommonRoutesForSubnet(subnet); err != nil {
×
1681
                        klog.Error(err)
×
1682
                        return err
×
1683
                }
×
1684
        }
1685

1686
        if subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway && subnet.Spec.U2OInterconnection && subnet.Status.U2OInterconnectionIP != "" {
×
1687
                if err := c.addPolicyRouteForU2OInterconn(subnet); err != nil {
×
1688
                        klog.Errorf("failed to add policy route for underlay to overlay subnet interconnection %s %v", subnet.Name, err)
×
1689
                        return err
×
1690
                }
×
1691
        }
1692

1693
        return nil
×
1694
}
1695

1696
func (c *Controller) deleteStaticRoute(ip, router, routeTable string) error {
×
1697
        for ipStr := range strings.SplitSeq(ip, ",") {
×
1698
                if err := c.deleteStaticRouteFromVpc(
×
1699
                        router,
×
1700
                        routeTable,
×
1701
                        ipStr,
×
1702
                        "",
×
1703
                        kubeovnv1.PolicyDst,
×
1704
                ); err != nil {
×
1705
                        klog.Errorf("failed to delete static route %s, %v", ipStr, err)
×
1706
                        return err
×
1707
                }
×
1708
        }
1709

1710
        return nil
×
1711
}
1712

1713
func (c *Controller) reconcileVlan(subnet *kubeovnv1.Subnet) error {
×
1714
        if subnet.Spec.Vlan == "" {
×
1715
                return nil
×
1716
        }
×
1717
        klog.Infof("reconcile vlan %v", subnet.Spec.Vlan)
×
1718

×
1719
        vlan, err := c.vlansLister.Get(subnet.Spec.Vlan)
×
1720
        if err != nil {
×
1721
                klog.Errorf("failed to get vlan %s: %v", subnet.Spec.Vlan, err)
×
1722
                return err
×
1723
        }
×
1724
        if vlan.Status.Conflict {
×
1725
                err = fmt.Errorf("subnet %s has invalid conflict vlan %s", subnet.Name, vlan.Name)
×
1726
                klog.Error(err)
×
1727
                return err
×
1728
        }
×
1729

1730
        localnetPort := ovs.GetLocalnetName(subnet.Name)
×
1731
        if err := c.OVNNbClient.CreateLocalnetLogicalSwitchPort(subnet.Name, localnetPort, vlan.Spec.Provider, subnet.Spec.CIDRBlock, vlan.Spec.ID); err != nil {
×
1732
                klog.Errorf("create localnet port for subnet %s: %v", subnet.Name, err)
×
1733
                return err
×
1734
        }
×
1735

1736
        if !slices.Contains(vlan.Status.Subnets, subnet.Name) {
×
1737
                newVlan := vlan.DeepCopy()
×
1738
                newVlan.Status.Subnets = append(newVlan.Status.Subnets, subnet.Name)
×
1739
                _, err = c.config.KubeOvnClient.KubeovnV1().Vlans().UpdateStatus(context.Background(), newVlan, metav1.UpdateOptions{})
×
1740
                if err != nil {
×
1741
                        klog.Errorf("failed to update status of vlan %s: %v", vlan.Name, err)
×
1742
                        return err
×
1743
                }
×
1744
        }
1745

1746
        return nil
×
1747
}
1748

1749
func (c *Controller) reconcileSubnetSpecialIPs(subnet *kubeovnv1.Subnet) (bool, bool, error) {
×
1750
        isU2OIPChanged := false
×
1751
        isMcastQuerierIPChanged := false
×
1752
        var err error
×
1753

×
1754
        // reconcile u2o IP
×
1755
        if subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway {
×
1756
                u2oInterconnName := fmt.Sprintf(util.U2OInterconnName, subnet.Spec.Vpc, subnet.Name)
×
1757
                u2oInterconnLrpName := fmt.Sprintf("%s-%s", subnet.Spec.Vpc, subnet.Name)
×
1758
                var v4ip, v6ip string
×
1759
                if subnet.Spec.U2OInterconnection {
×
1760
                        v4ip, v6ip, _, err = c.acquireU2OIP(subnet, u2oInterconnName, u2oInterconnLrpName)
×
1761
                        if err != nil {
×
1762
                                return isU2OIPChanged, isMcastQuerierIPChanged, err
×
1763
                        }
×
1764

1765
                        if v4ip != "" || v6ip != "" {
×
1766
                                isU2OIPChanged = true
×
1767
                        }
×
1768
                } else if subnet.Status.U2OInterconnectionIP != "" {
×
1769
                        err = c.releaseU2OIP(subnet, u2oInterconnName)
×
1770
                        if err != nil {
×
1771
                                return isU2OIPChanged, isMcastQuerierIPChanged, err
×
1772
                        }
×
1773
                        isU2OIPChanged = true
×
1774
                }
1775

1776
                if isU2OIPChanged {
×
1777
                        klog.Infof("reconcile underlay subnet %s to overlay interconnection with U2OInterconnection %v U2OInterconnectionIP %s",
×
1778
                                subnet.Name, subnet.Spec.U2OInterconnection, subnet.Status.U2OInterconnectionIP)
×
1779
                }
×
1780
        }
1781

1782
        // reconcile mcast querier IP
1783
        if subnet.Spec.EnableMulticastSnoop {
×
1784
                isMcastQuerierIPChanged, err = c.acquireMcastQuerierIP(subnet)
×
1785
                if err != nil {
×
1786
                        return isU2OIPChanged, isMcastQuerierIPChanged, err
×
1787
                }
×
1788
        } else {
×
1789
                isMcastQuerierIPChanged, err = c.releaseMcastQuerierIP(subnet)
×
1790
                if err != nil {
×
1791
                        return isU2OIPChanged, isMcastQuerierIPChanged, err
×
1792
                }
×
1793
        }
1794

1795
        // calculate subnet status
1796
        if isU2OIPChanged || isMcastQuerierIPChanged {
×
1797
                if _, err := c.calcSubnetStatusIP(subnet); err != nil {
×
1798
                        klog.Error(err)
×
1799
                        return isU2OIPChanged, isMcastQuerierIPChanged, err
×
1800
                }
×
1801
        }
1802

1803
        return isU2OIPChanged, isMcastQuerierIPChanged, nil
×
1804
}
1805

1806
func (c *Controller) acquireU2OIP(subnet *kubeovnv1.Subnet, u2oInterconnName, u2oInterconnLrpName string) (string, string, string, error) {
×
1807
        var v4ip, v6ip, mac string
×
1808
        var err error
×
1809
        if subnet.Spec.U2OInterconnectionIP == "" && (subnet.Status.U2OInterconnectionIP == "" || subnet.Status.U2OInterconnectionMAC == "") {
×
1810
                v4ip, v6ip, mac, err = c.acquireIPAddress(subnet.Name, u2oInterconnName, u2oInterconnLrpName)
×
1811
                if err != nil {
×
1812
                        klog.Errorf("failed to acquire underlay to overlay interconnection ip address for subnet %s, %v", subnet.Name, err)
×
1813
                        return "", "", "", err
×
1814
                }
×
1815
        } else if subnet.Spec.U2OInterconnectionIP != "" && subnet.Status.U2OInterconnectionIP != subnet.Spec.U2OInterconnectionIP {
×
1816
                if subnet.Status.U2OInterconnectionIP != "" {
×
1817
                        klog.Infof("release underlay to overlay interconnection ip address %s for subnet %s", subnet.Status.U2OInterconnectionIP, subnet.Name)
×
1818
                        c.ipam.ReleaseAddressByPod(u2oInterconnName, subnet.Name)
×
1819
                }
×
1820
                v4ip, v6ip, mac, err = c.acquireStaticIPAddress(subnet.Name, u2oInterconnName, u2oInterconnLrpName, subnet.Spec.U2OInterconnectionIP, nil)
×
1821
                if err != nil {
×
1822
                        klog.Errorf("failed to acquire static underlay to overlay interconnection ip address for subnet %s, %v", subnet.Name, err)
×
1823
                        return "", "", "", err
×
1824
                }
×
1825
        }
1826
        if v4ip != "" || v6ip != "" {
×
1827
                switch subnet.Spec.Protocol {
×
1828
                case kubeovnv1.ProtocolIPv4:
×
1829
                        subnet.Status.U2OInterconnectionIP = v4ip
×
1830
                case kubeovnv1.ProtocolIPv6:
×
1831
                        subnet.Status.U2OInterconnectionIP = v6ip
×
1832
                case kubeovnv1.ProtocolDual:
×
1833
                        subnet.Status.U2OInterconnectionIP = fmt.Sprintf("%s,%s", v4ip, v6ip)
×
1834
                }
1835
                err = c.createOrUpdateIPCR("", u2oInterconnName, subnet.Status.U2OInterconnectionIP, mac, subnet.Name, metav1.NamespaceDefault, "", "")
×
1836
                if err != nil {
×
1837
                        klog.Errorf("failed to create or update IPs of %s : %v", u2oInterconnLrpName, err)
×
1838
                        return "", "", "", err
×
1839
                }
×
1840
                subnet.Status.U2OInterconnectionMAC = mac
×
1841
        }
1842
        return v4ip, v6ip, mac, nil
×
1843
}
1844

1845
func (c *Controller) releaseU2OIP(subnet *kubeovnv1.Subnet, u2oInterconnName string) error {
×
1846
        klog.Infof("release underlay to overlay interconnection ip address %s for subnet %s", subnet.Status.U2OInterconnectionIP, subnet.Name)
×
1847
        c.ipam.ReleaseAddressByPod(u2oInterconnName, subnet.Name)
×
1848
        subnet.Status.U2OInterconnectionIP = ""
×
1849
        subnet.Status.U2OInterconnectionMAC = ""
×
1850
        subnet.Status.U2OInterconnectionVPC = ""
×
1851

×
1852
        err := c.config.KubeOvnClient.KubeovnV1().IPs().Delete(context.Background(), u2oInterconnName, metav1.DeleteOptions{})
×
1853
        if err != nil && !k8serrors.IsNotFound(err) {
×
1854
                klog.Errorf("failed to delete ip %s, %v", u2oInterconnName, err)
×
1855
                return err
×
1856
        }
×
1857

1858
        return nil
×
1859
}
1860

1861
func (c *Controller) acquireMcastQuerierIP(subnet *kubeovnv1.Subnet) (bool, error) {
×
1862
        isMcastQuerierChanged := false
×
1863
        mcastQuerierLspName := fmt.Sprintf(util.McastQuerierName, subnet.Name)
×
1864
        var v4ip, v6ip, mac string
×
1865
        var err error
×
1866

×
1867
        if subnet.Status.McastQuerierIP == "" || subnet.Status.McastQuerierMAC == "" {
×
1868
                v4ip, v6ip, mac, err = c.acquireIPAddress(subnet.Name, mcastQuerierLspName, mcastQuerierLspName)
×
1869
                if err != nil {
×
1870
                        klog.Errorf("failed to acquire mcast querier ip address for subnet %s, %v", subnet.Name, err)
×
1871
                        return isMcastQuerierChanged, err
×
1872
                }
×
1873
        }
1874

1875
        if v4ip != "" || v6ip != "" {
×
1876
                switch subnet.Spec.Protocol {
×
1877
                case kubeovnv1.ProtocolIPv4:
×
1878
                        subnet.Status.McastQuerierIP = v4ip
×
1879
                case kubeovnv1.ProtocolIPv6:
×
1880
                        subnet.Status.McastQuerierIP = v6ip
×
1881
                case kubeovnv1.ProtocolDual:
×
1882
                        subnet.Status.McastQuerierIP = fmt.Sprintf("%s,%s", v4ip, v6ip)
×
1883
                }
1884

1885
                err := c.createOrUpdateIPCR("", mcastQuerierLspName, subnet.Status.McastQuerierIP, mac, subnet.Name, metav1.NamespaceDefault, "", "")
×
1886
                if err != nil {
×
1887
                        klog.Errorf("failed to create or update IPs of %s : %v", mcastQuerierLspName, err)
×
1888
                        return isMcastQuerierChanged, err
×
1889
                }
×
1890

1891
                subnet.Status.McastQuerierMAC = mac
×
1892
                klog.Infof("reconcile subnet %s mcast querier IP %s mac %s",
×
1893
                        subnet.Name, subnet.Status.McastQuerierIP, subnet.Status.McastQuerierMAC)
×
1894
                isMcastQuerierChanged = true
×
1895
        }
1896

1897
        return isMcastQuerierChanged, nil
×
1898
}
1899

1900
func (c *Controller) releaseMcastQuerierIP(subnet *kubeovnv1.Subnet) (bool, error) {
×
1901
        isMcastQuerierChanged := false
×
1902
        if subnet.Status.McastQuerierIP != "" {
×
1903
                mcastQuerierLspName := fmt.Sprintf(util.McastQuerierName, subnet.Name)
×
1904
                klog.Infof("release mcast querier ip address %s for subnet %s", subnet.Status.McastQuerierIP, subnet.Name)
×
1905
                c.ipam.ReleaseAddressByPod(mcastQuerierLspName, subnet.Name)
×
1906
                subnet.Status.McastQuerierIP = ""
×
1907
                subnet.Status.McastQuerierMAC = ""
×
1908

×
1909
                if err := c.config.KubeOvnClient.KubeovnV1().IPs().Delete(context.Background(), mcastQuerierLspName, metav1.DeleteOptions{}); err != nil {
×
1910
                        if !k8serrors.IsNotFound(err) {
×
1911
                                klog.Errorf("failed to delete ip %s, %v", mcastQuerierLspName, err)
×
1912
                                return isMcastQuerierChanged, err
×
1913
                        }
×
1914
                }
1915
                isMcastQuerierChanged = true
×
1916
                klog.Infof("reconcile subnet %s mcast querier IP %s mac %s",
×
1917
                        subnet.Name, subnet.Status.McastQuerierIP, subnet.Status.McastQuerierMAC)
×
1918
        }
1919
        return isMcastQuerierChanged, nil
×
1920
}
1921

1922
func isOvnSubnet(subnet *kubeovnv1.Subnet) bool {
1✔
1923
        return subnet != nil && util.IsOvnProvider(subnet.Spec.Provider)
1✔
1924
}
1✔
1925

1926
func formatExcludeIPRanges(subnet *kubeovnv1.Subnet) {
1✔
1927
        var excludeIPs []string
1✔
1928
        mapIPs := make(map[string]*ipam.IPRange, len(subnet.Spec.ExcludeIps))
1✔
1929
        for _, excludeIP := range subnet.Spec.ExcludeIps {
2✔
1930
                if _, ok := mapIPs[excludeIP]; !ok {
2✔
1931
                        ips := strings.Split(excludeIP, "..")
1✔
1932
                        start, _ := ipam.NewIP(ips[0])
1✔
1933
                        end := start
1✔
1934
                        if len(ips) != 1 {
1✔
1935
                                end, _ = ipam.NewIP(ips[1])
×
1936
                        }
×
1937
                        mapIPs[excludeIP] = ipam.NewIPRange(start, end)
1✔
1938
                }
1939
        }
1940
        newMap := filterRepeatIPRange(mapIPs)
1✔
1941
        for _, v := range newMap {
2✔
1942
                if v.Start().Equal(v.End()) {
2✔
1943
                        excludeIPs = append(excludeIPs, v.Start().String())
1✔
1944
                } else {
1✔
1945
                        excludeIPs = append(excludeIPs, v.Start().String()+".."+v.End().String())
×
1946
                }
×
1947
        }
1948
        sort.Strings(excludeIPs)
1✔
1949
        if !slices.Equal(subnet.Spec.ExcludeIps, excludeIPs) {
1✔
1950
                klog.V(3).Infof("excludeips before format is %v, after format is %v", subnet.Spec.ExcludeIps, excludeIPs)
×
1951
                subnet.Spec.ExcludeIps = excludeIPs
×
1952
        }
×
1953
}
1954

1955
func filterRepeatIPRange(mapIPs map[string]*ipam.IPRange) map[string]*ipam.IPRange {
1✔
1956
        for ka, a := range mapIPs {
2✔
1957
                for kb, b := range mapIPs {
2✔
1958
                        if ka == kb && a == b {
2✔
1959
                                continue
1✔
1960
                        }
1961

1962
                        if b.End().LessThan(a.Start()) || b.Start().GreaterThan(a.End()) {
2✔
1963
                                continue
1✔
1964
                        }
1965

1966
                        if (a.Start().Equal(b.Start()) || a.Start().GreaterThan(b.Start())) &&
×
1967
                                (a.End().Equal(b.End()) || a.End().LessThan(b.End())) {
×
1968
                                delete(mapIPs, ka)
×
1969
                                continue
×
1970
                        }
1971

1972
                        if (a.Start().Equal(b.Start()) || a.Start().GreaterThan(b.Start())) &&
×
1973
                                a.End().GreaterThan(b.End()) {
×
1974
                                delete(mapIPs, ka)
×
1975
                                mapIPs[kb] = ipam.NewIPRange(b.Start(), a.End())
×
1976
                                continue
×
1977
                        }
1978

1979
                        if (a.End().Equal(b.End()) || a.End().LessThan(b.End())) &&
×
1980
                                a.Start().LessThan(b.Start()) {
×
1981
                                delete(mapIPs, ka)
×
1982
                                mapIPs[kb] = ipam.NewIPRange(a.Start(), b.End())
×
1983
                                continue
×
1984
                        }
1985

1986
                        // a contains b
1987
                        mapIPs[kb] = a
×
1988
                        delete(mapIPs, ka)
×
1989
                }
1990
        }
1991
        return mapIPs
1✔
1992
}
1993

1994
func (c *Controller) checkGwNodeExists(gatewayNode string) bool {
×
1995
        found := false
×
1996
        for gwName := range strings.SplitSeq(gatewayNode, ",") {
×
1997
                // the format of gatewayNode can be like 'kube-ovn-worker:172.18.0.2, kube-ovn-control-plane:172.18.0.3', which consists of node name and designative egress ip
×
1998
                if strings.Contains(gwName, ":") {
×
1999
                        gwName = strings.TrimSpace(strings.Split(gwName, ":")[0])
×
2000
                } else {
×
2001
                        gwName = strings.TrimSpace(gwName)
×
2002
                }
×
2003

2004
                gwNode, err := c.nodesLister.Get(gwName)
×
2005
                if err != nil {
×
2006
                        if k8serrors.IsNotFound(err) {
×
2007
                                klog.Errorf("gw node %s does not exist, %v", gwName, err)
×
2008
                                continue
×
2009
                        }
2010
                }
2011
                if gwNode != nil {
×
2012
                        found = true
×
2013
                        break
×
2014
                }
2015
        }
2016
        return found
×
2017
}
2018

2019
func (c *Controller) getGatewayNodes(subnet *kubeovnv1.Subnet) ([]string, error) {
×
2020
        if subnet.Spec.GatewayNode != "" {
×
2021
                var nodes []string
×
2022
                for gw := range strings.SplitSeq(subnet.Spec.GatewayNode, ",") {
×
2023
                        if strings.Contains(gw, ":") {
×
2024
                                gw = strings.TrimSpace(strings.Split(gw, ":")[0])
×
2025
                        } else {
×
2026
                                gw = strings.TrimSpace(gw)
×
2027
                        }
×
2028
                        if gw != "" {
×
2029
                                nodes = append(nodes, gw)
×
2030
                        }
×
2031
                }
2032
                return nodes, nil
×
2033
        }
2034

2035
        if len(subnet.Spec.GatewayNodeSelectors) > 0 {
×
2036
                return c.getNodesBySelectors(subnet.Spec.GatewayNodeSelectors)
×
2037
        }
×
2038

2039
        return nil, nil
×
2040
}
2041

2042
func (c *Controller) getNodesBySelectors(selectors []metav1.LabelSelector) ([]string, error) {
×
2043
        nodeSet := make(map[string]struct{})
×
2044
        for _, selector := range selectors {
×
2045
                labelSelector, err := metav1.LabelSelectorAsSelector(&selector)
×
2046
                if err != nil {
×
2047
                        klog.Errorf("failed to convert label selector: %v", err)
×
2048
                        continue
×
2049
                }
2050
                nodes, err := c.nodesLister.List(labelSelector)
×
2051
                if err != nil {
×
2052
                        return nil, fmt.Errorf("failed to list nodes with selector %s: %w", labelSelector.String(), err)
×
2053
                }
×
2054
                for _, node := range nodes {
×
2055
                        nodeSet[node.Name] = struct{}{}
×
2056
                }
×
2057
        }
2058

2059
        matchedNodes := make([]string, 0, len(nodeSet))
×
2060
        for name := range nodeSet {
×
2061
                matchedNodes = append(matchedNodes, name)
×
2062
        }
×
2063
        return matchedNodes, nil
×
2064
}
2065

2066
func (c *Controller) checkSubnetGwNodesExist(subnet *kubeovnv1.Subnet) bool {
×
2067
        if subnet.Spec.GatewayNode != "" {
×
2068
                return c.checkGwNodeExists(subnet.Spec.GatewayNode)
×
2069
        }
×
2070

2071
        if len(subnet.Spec.GatewayNodeSelectors) > 0 {
×
2072
                nodes, err := c.getNodesBySelectors(subnet.Spec.GatewayNodeSelectors)
×
2073
                if err != nil {
×
2074
                        klog.Errorf("failed to get nodes by selectors: %v", err)
×
2075
                        return false
×
2076
                }
×
2077
                return len(nodes) > 0
×
2078
        }
2079

2080
        return false
×
2081
}
2082

2083
func getIPSuffix(protocol string) string {
×
2084
        if protocol == kubeovnv1.ProtocolIPv6 {
×
2085
                return "ip6"
×
2086
        }
×
2087
        return "ip4"
×
2088
}
2089

2090
func buildPolicyRouteExternalIDs(subnetName string, extraIDs map[string]string) map[string]string {
×
2091
        externalIDs := map[string]string{
×
2092
                "vendor": util.CniTypeName,
×
2093
                "subnet": subnetName,
×
2094
        }
×
2095
        maps.Copy(externalIDs, extraIDs)
×
2096
        return externalIDs
×
2097
}
×
2098

2099
func (c *Controller) logicalRouterExists(vpcName string) bool {
×
2100
        lr, err := c.OVNNbClient.GetLogicalRouter(vpcName, true)
×
2101
        if err == nil && lr == nil {
×
2102
                klog.Infof("logical router %s already deleted", vpcName)
×
2103
                return false
×
2104
        }
×
2105
        return true
×
2106
}
2107

2108
func (c *Controller) addCommonRoutesForSubnet(subnet *kubeovnv1.Subnet) error {
×
2109
        for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2110
                if cidr == "" {
×
2111
                        continue
×
2112
                }
2113

2114
                var gateway string
×
2115
                protocol := util.CheckProtocol(cidr)
×
2116
                for gw := range strings.SplitSeq(subnet.Spec.Gateway, ",") {
×
2117
                        if util.CheckProtocol(gw) == protocol {
×
2118
                                gateway = gw
×
2119
                                break
×
2120
                        }
2121
                }
2122
                if gateway == "" {
×
2123
                        return fmt.Errorf("failed to get gateway of CIDR %s", cidr)
×
2124
                }
×
2125

2126
                ipSuffix := getIPSuffix(protocol)
×
2127
                match := fmt.Sprintf("%s.dst == %s", ipSuffix, cidr)
×
2128
                action := kubeovnv1.PolicyRouteActionAllow
×
2129
                externalIDs := buildPolicyRouteExternalIDs(subnet.Name, nil)
×
2130

×
2131
                klog.Infof("add common policy route for router: %s, match %s, action %s, externalID %v", subnet.Spec.Vpc, match, action, externalIDs)
×
2132
                if err := c.addPolicyRouteToVpc(
×
2133
                        subnet.Spec.Vpc,
×
2134
                        &kubeovnv1.PolicyRoute{
×
2135
                                Priority: util.SubnetRouterPolicyPriority,
×
2136
                                Match:    match,
×
2137
                                Action:   action,
×
2138
                        },
×
2139
                        externalIDs,
×
2140
                ); err != nil {
×
2141
                        klog.Errorf("failed to add logical router policy for CIDR %s of subnet %s: %v", cidr, subnet.Name, err)
×
2142
                        return err
×
2143
                }
×
2144
        }
2145
        return nil
×
2146
}
2147

2148
func getOverlaySubnetsPortGroupName(subnetName, nodeName string) string {
×
2149
        return strings.ReplaceAll(fmt.Sprintf("%s.%s", subnetName, nodeName), "-", ".")
×
2150
}
×
2151

2152
func (c *Controller) createPortGroupForDistributedSubnet(node *v1.Node, subnet *kubeovnv1.Subnet) error {
×
2153
        if subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway {
×
2154
                return nil
×
2155
        }
×
2156
        if subnet.Spec.Vpc != c.config.ClusterRouter || subnet.Name == c.config.NodeSwitch {
×
2157
                return nil
×
2158
        }
×
2159

2160
        pgName := getOverlaySubnetsPortGroupName(subnet.Name, node.Name)
×
2161
        externalIDs := map[string]string{
×
2162
                "subnet":         subnet.Name,
×
2163
                "node":           node.Name,
×
2164
                "vendor":         util.CniTypeName,
×
2165
                networkPolicyKey: subnet.Name + "/" + node.Name,
×
2166
        }
×
2167
        if err := c.OVNNbClient.CreatePortGroup(pgName, externalIDs); err != nil {
×
2168
                klog.Errorf("create port group for subnet %s and node %s: %v", subnet.Name, node.Name, err)
×
2169
                return err
×
2170
        }
×
2171

2172
        return nil
×
2173
}
2174

2175
func (c *Controller) updatePolicyRouteForCentralizedSubnet(subnetName, cidr string, nextHops []string, nameIPMap map[string]string) error {
×
2176
        ipSuffix := getIPSuffix(util.CheckProtocol(cidr))
×
2177
        match := fmt.Sprintf("%s.src == %s", ipSuffix, cidr)
×
2178
        action := kubeovnv1.PolicyRouteActionReroute
×
2179
        externalIDs := buildPolicyRouteExternalIDs(subnetName, nameIPMap)
×
2180

×
2181
        klog.Infof("add policy route for router: %s, match %s, action %s, nexthops %v, externalID %s", c.config.ClusterRouter, match, action, nextHops, externalIDs)
×
2182
        if err := c.addPolicyRouteToVpc(
×
2183
                c.config.ClusterRouter,
×
2184
                &kubeovnv1.PolicyRoute{
×
2185
                        Priority:  util.GatewayRouterPolicyPriority,
×
2186
                        Match:     match,
×
2187
                        Action:    action,
×
2188
                        NextHopIP: strings.Join(nextHops, ","),
×
2189
                },
×
2190
                externalIDs,
×
2191
        ); err != nil {
×
2192
                klog.Errorf("failed to add policy route for centralized subnet %s: %v", subnetName, err)
×
2193
                return err
×
2194
        }
×
2195
        return nil
×
2196
}
2197

2198
func (c *Controller) addPolicyRouteForCentralizedSubnet(subnet *kubeovnv1.Subnet, nodeName string, ipNameMap map[string]string, nodeIPs []string) error {
×
2199
        for _, nodeIP := range nodeIPs {
×
2200
                // node v4ip v6ip
×
2201
                for cidrBlock := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2202
                        if util.CheckProtocol(cidrBlock) != util.CheckProtocol(nodeIP) {
×
2203
                                continue
×
2204
                        }
2205
                        // Check for repeat policy route is processed in AddPolicyRoute
2206

2207
                        var nextHops []string
×
2208
                        nameIPMap := map[string]string{}
×
2209
                        nextHops = append(nextHops, nodeIP)
×
2210
                        tmpName := nodeName
×
2211
                        if nodeName == "" {
×
2212
                                tmpName = ipNameMap[nodeIP]
×
2213
                        }
×
2214
                        nameIPMap[tmpName] = nodeIP
×
2215
                        if err := c.updatePolicyRouteForCentralizedSubnet(subnet.Name, cidrBlock, nextHops, nameIPMap); err != nil {
×
2216
                                klog.Error(err)
×
2217
                                return err
×
2218
                        }
×
2219
                }
2220
        }
2221
        return nil
×
2222
}
2223

2224
func (c *Controller) deletePolicyRouteForCentralizedSubnet(subnet *kubeovnv1.Subnet) error {
×
2225
        for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2226
                ipSuffix := getIPSuffix(util.CheckProtocol(cidr))
×
2227
                match := fmt.Sprintf("%s.src == %s", ipSuffix, cidr)
×
2228
                klog.Infof("delete policy route for router: %s, priority: %d, match %s", c.config.ClusterRouter, util.GatewayRouterPolicyPriority, match)
×
2229
                if err := c.deletePolicyRouteFromVpc(c.config.ClusterRouter, util.GatewayRouterPolicyPriority, match); err != nil {
×
2230
                        klog.Errorf("failed to delete policy route for centralized subnet %s: %v", subnet.Name, err)
×
2231
                        return err
×
2232
                }
×
2233
        }
2234
        return nil
×
2235
}
2236

2237
func (c *Controller) addPolicyRouteForDistributedSubnet(subnet *kubeovnv1.Subnet, nodeName, nodeIPv4, nodeIPv6 string) error {
×
2238
        if subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway {
×
2239
                return nil
×
2240
        }
×
2241
        if subnet.Spec.Vpc != c.config.ClusterRouter || subnet.Name == c.config.NodeSwitch {
×
2242
                return nil
×
2243
        }
×
2244

2245
        pgName := getOverlaySubnetsPortGroupName(subnet.Name, nodeName)
×
2246
        for cidrBlock := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2247
                ipSuffix := getIPSuffix(util.CheckProtocol(cidrBlock))
×
2248
                nodeIP := nodeIPv4
×
2249
                if ipSuffix == "ip6" {
×
2250
                        nodeIP = nodeIPv6
×
2251
                }
×
2252
                if nodeIP == "" {
×
2253
                        continue
×
2254
                }
2255

2256
                pgAs := fmt.Sprintf("%s_%s", pgName, ipSuffix)
×
2257
                match := fmt.Sprintf("%s.src == $%s", ipSuffix, pgAs)
×
2258
                action := kubeovnv1.PolicyRouteActionReroute
×
2259
                externalIDs := buildPolicyRouteExternalIDs(subnet.Name, map[string]string{"node": nodeName})
×
2260

×
2261
                klog.Infof("add policy route for router: %s, match %s, action %s, externalID %v", c.config.ClusterRouter, match, action, externalIDs)
×
2262
                if err := c.addPolicyRouteToVpc(
×
2263
                        c.config.ClusterRouter,
×
2264
                        &kubeovnv1.PolicyRoute{
×
2265
                                Priority:  util.GatewayRouterPolicyPriority,
×
2266
                                Match:     match,
×
2267
                                Action:    action,
×
2268
                                NextHopIP: nodeIP,
×
2269
                        },
×
2270
                        externalIDs,
×
2271
                ); err != nil {
×
2272
                        klog.Errorf("failed to add logical router policy for port-group address-set %s: %v", pgAs, err)
×
2273
                        return err
×
2274
                }
×
2275
        }
2276
        return nil
×
2277
}
2278

2279
func (c *Controller) deletePolicyRouteForDistributedSubnet(subnet *kubeovnv1.Subnet, nodeName string) error {
×
2280
        pgName := getOverlaySubnetsPortGroupName(subnet.Name, nodeName)
×
2281
        for cidrBlock := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2282
                ipSuffix := getIPSuffix(util.CheckProtocol(cidrBlock))
×
2283
                pgAs := fmt.Sprintf("%s_%s", pgName, ipSuffix)
×
2284
                match := fmt.Sprintf("%s.src == $%s", ipSuffix, pgAs)
×
2285
                klog.Infof("delete policy route for router: %s, priority: %d, match: %q", c.config.ClusterRouter, util.GatewayRouterPolicyPriority, match)
×
2286
                if err := c.deletePolicyRouteFromVpc(c.config.ClusterRouter, util.GatewayRouterPolicyPriority, match); err != nil {
×
2287
                        klog.Errorf("failed to delete policy route for subnet %s: %v", subnet.Name, err)
×
2288
                        return err
×
2289
                }
×
2290
        }
2291
        return nil
×
2292
}
2293

2294
func (c *Controller) deletePolicyRouteByGatewayType(subnet *kubeovnv1.Subnet, gatewayType string, isDelete bool) error {
×
2295
        if (subnet.Spec.Vlan != "" && !subnet.Spec.LogicalGateway) || subnet.Spec.Vpc != c.config.ClusterRouter {
×
2296
                return nil
×
2297
        }
×
2298

2299
        for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2300
                if cidr == "" || !isDelete {
×
2301
                        continue
×
2302
                }
2303

2304
                ipSuffix := getIPSuffix(util.CheckProtocol(cidr))
×
2305
                match := fmt.Sprintf("%s.dst == %s", ipSuffix, cidr)
×
2306
                klog.Infof("delete policy route for router: %s, priority: %d, match %s", c.config.ClusterRouter, util.SubnetRouterPolicyPriority, match)
×
2307
                if err := c.deletePolicyRouteFromVpc(c.config.ClusterRouter, util.SubnetRouterPolicyPriority, match); err != nil {
×
2308
                        klog.Errorf("failed to delete logical router policy for CIDR %s of subnet %s: %v", cidr, subnet.Name, err)
×
2309
                        return err
×
2310
                }
×
2311
        }
2312
        if subnet.Name == c.config.NodeSwitch {
×
2313
                return nil
×
2314
        }
×
2315

2316
        if gatewayType == kubeovnv1.GWDistributedType {
×
2317
                nodes, err := c.nodesLister.List(labels.Everything())
×
2318
                if err != nil {
×
2319
                        klog.Errorf("list nodes: %v", err)
×
2320
                        return err
×
2321
                }
×
2322
                for _, node := range nodes {
×
2323
                        pgName := getOverlaySubnetsPortGroupName(subnet.Name, node.Name)
×
2324
                        if err = c.OVNNbClient.DeletePortGroup(pgName); err != nil {
×
2325
                                klog.Errorf("delete port group for subnet %s and node %s: %v", subnet.Name, node.Name, err)
×
2326
                                return err
×
2327
                        }
×
2328

2329
                        if err = c.deletePolicyRouteForDistributedSubnet(subnet, node.Name); err != nil {
×
2330
                                klog.Errorf("delete policy route for subnet %s and node %s: %v", subnet.Name, node.Name, err)
×
2331
                                return err
×
2332
                        }
×
2333
                }
2334
        }
2335

2336
        if gatewayType == kubeovnv1.GWCentralizedType {
×
2337
                klog.Infof("delete policy route for centralized subnet %s", subnet.Name)
×
2338
                if err := c.deletePolicyRouteForCentralizedSubnet(subnet); err != nil {
×
2339
                        klog.Errorf("delete policy route for subnet %s: %v", subnet.Name, err)
×
2340
                        return err
×
2341
                }
×
2342
        }
2343

2344
        return nil
×
2345
}
2346

2347
func (c *Controller) addPolicyRouteForU2OInterconn(subnet *kubeovnv1.Subnet) error {
×
2348
        v4Gw, v6Gw := util.SplitStringIP(subnet.Spec.Gateway)
×
2349

×
2350
        externalIDs := buildPolicyRouteExternalIDs(subnet.Name, map[string]string{"isU2ORoutePolicy": "true"})
×
2351

×
2352
        nodes, err := c.nodesLister.List(labels.Everything())
×
2353
        if err != nil {
×
2354
                klog.Errorf("failed to list nodes: %v", err)
×
2355
                return err
×
2356
        }
×
2357

2358
        var nodesIPv4, nodesIPv6 []string
×
2359
        for _, node := range nodes {
×
2360
                nodeIPv4, nodeIPv6 := util.GetNodeInternalIP(*node)
×
2361

×
2362
                if nodeIPv4 != "" {
×
2363
                        nodesIPv4 = append(nodesIPv4, nodeIPv4)
×
2364
                }
×
2365
                if nodeIPv6 != "" {
×
2366
                        nodesIPv6 = append(nodesIPv6, nodeIPv6)
×
2367
                }
×
2368
        }
2369

2370
        u2oExcludeIP4Ag := strings.ReplaceAll(fmt.Sprintf(util.U2OExcludeIPAg, subnet.Name, "ip4"), "-", ".")
×
2371
        u2oExcludeIP6Ag := strings.ReplaceAll(fmt.Sprintf(util.U2OExcludeIPAg, subnet.Name, "ip6"), "-", ".")
×
2372

×
2373
        if err := c.OVNNbClient.CreateAddressSet(u2oExcludeIP4Ag, externalIDs); err != nil {
×
2374
                klog.Errorf("create address set %s: %v", u2oExcludeIP4Ag, err)
×
2375
                return err
×
2376
        }
×
2377

2378
        if err := c.OVNNbClient.CreateAddressSet(u2oExcludeIP6Ag, externalIDs); err != nil {
×
2379
                klog.Errorf("create address set %s: %v", u2oExcludeIP6Ag, err)
×
2380
                return err
×
2381
        }
×
2382

2383
        if len(nodesIPv4) > 0 {
×
2384
                if err := c.OVNNbClient.AddressSetUpdateAddress(u2oExcludeIP4Ag, nodesIPv4...); err != nil {
×
2385
                        klog.Errorf("set v4 address set %s with address %v: %v", u2oExcludeIP4Ag, nodesIPv4, err)
×
2386
                        return err
×
2387
                }
×
2388
        }
2389

2390
        if len(nodesIPv6) > 0 {
×
2391
                if err := c.OVNNbClient.AddressSetUpdateAddress(u2oExcludeIP6Ag, nodesIPv6...); err != nil {
×
2392
                        klog.Errorf("set v6 address set %s with address %v: %v", u2oExcludeIP6Ag, nodesIPv6, err)
×
2393
                        return err
×
2394
                }
×
2395
        }
2396

2397
        for cidrBlock := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2398
                ipSuffix := getIPSuffix(util.CheckProtocol(cidrBlock))
×
2399
                nextHop := v4Gw
×
2400
                U2OexcludeIPAs := u2oExcludeIP4Ag
×
2401
                if ipSuffix == "ip6" {
×
2402
                        nextHop = v6Gw
×
2403
                        U2OexcludeIPAs = u2oExcludeIP6Ag
×
2404
                }
×
2405

2406
                match1 := fmt.Sprintf("%s.dst == %s", ipSuffix, cidrBlock)
×
2407
                match2 := fmt.Sprintf("%s.dst == $%s && %s.src == %s", ipSuffix, U2OexcludeIPAs, ipSuffix, cidrBlock)
×
2408
                match3 := fmt.Sprintf("%s.src == %s", ipSuffix, cidrBlock)
×
2409

×
2410
                /*
×
2411
                        policy1:
×
2412
                        priority 29400 match: "ip4.dst == underlay subnet cidr"                         action: allow
×
2413

×
2414
                        policy2:
×
2415
                        priority 31000 match: "ip4.dst == node ips && ip4.src == underlay subnet cidr"  action: reroute physical gw
×
2416

×
2417
                        policy3:
×
2418
                        priority 29000 match: "ip4.src == underlay subnet cidr"                         action: reroute physical gw
×
2419

×
2420
                        comment:
×
2421
                        policy1 and policy2 allow overlay pod access underlay but when overlay pod access node ip, it should go join subnet,
×
2422
                        policy3: underlay pod first access u2o interconnection lrp and then reroute to physical gw
×
2423
                */
×
2424
                action := kubeovnv1.PolicyRouteActionAllow
×
2425
                if subnet.Spec.Vpc == c.config.ClusterRouter {
×
2426
                        klog.Infof("add u2o interconnection policy for router: %s, match %s, action %s", subnet.Spec.Vpc, match1, action)
×
2427
                        if err := c.addPolicyRouteToVpc(
×
2428
                                subnet.Spec.Vpc,
×
2429
                                &kubeovnv1.PolicyRoute{
×
2430
                                        Priority: util.U2OSubnetPolicyPriority,
×
2431
                                        Match:    match1,
×
2432
                                        Action:   action,
×
2433
                                },
×
2434
                                externalIDs,
×
2435
                        ); err != nil {
×
2436
                                klog.Errorf("failed to add u2o interconnection policy1 for subnet %s %v", subnet.Name, err)
×
2437
                                return err
×
2438
                        }
×
2439

2440
                        action = kubeovnv1.PolicyRouteActionReroute
×
2441
                        klog.Infof("add u2o interconnection policy for router: %s, match %s, action %s", subnet.Spec.Vpc, match2, action)
×
2442
                        if err := c.addPolicyRouteToVpc(
×
2443
                                subnet.Spec.Vpc,
×
2444
                                &kubeovnv1.PolicyRoute{
×
2445
                                        Priority:  util.SubnetRouterPolicyPriority,
×
2446
                                        Match:     match2,
×
2447
                                        Action:    action,
×
2448
                                        NextHopIP: nextHop,
×
2449
                                },
×
2450
                                externalIDs,
×
2451
                        ); err != nil {
×
2452
                                klog.Errorf("failed to add u2o interconnection policy2 for subnet %s %v", subnet.Name, err)
×
2453
                                return err
×
2454
                        }
×
2455
                }
2456

2457
                action = kubeovnv1.PolicyRouteActionReroute
×
2458
                klog.Infof("add u2o interconnection policy for router: %s, match %s, action %s, nexthop %s", subnet.Spec.Vpc, match3, action, nextHop)
×
2459
                if err := c.addPolicyRouteToVpc(
×
2460
                        subnet.Spec.Vpc,
×
2461
                        &kubeovnv1.PolicyRoute{
×
2462
                                Priority:  util.GatewayRouterPolicyPriority,
×
2463
                                Match:     match3,
×
2464
                                Action:    action,
×
2465
                                NextHopIP: nextHop,
×
2466
                        },
×
2467
                        externalIDs,
×
2468
                ); err != nil {
×
2469
                        klog.Errorf("failed to add u2o interconnection policy3 for subnet %s %v", subnet.Name, err)
×
2470
                        return err
×
2471
                }
×
2472
        }
2473
        return nil
×
2474
}
2475

2476
func (c *Controller) deletePolicyRouteForU2OInterconn(subnet *kubeovnv1.Subnet) error {
×
2477
        if !c.logicalRouterExists(subnet.Spec.Vpc) {
×
2478
                return nil
×
2479
        }
×
2480
        policies, err := c.OVNNbClient.ListLogicalRouterPolicies(subnet.Spec.Vpc, -1, map[string]string{
×
2481
                "isU2ORoutePolicy": "true",
×
2482
                "vendor":           util.CniTypeName,
×
2483
                "subnet":           subnet.Name,
×
2484
        }, true)
×
2485
        if err != nil {
×
2486
                klog.Errorf("failed to list logical router policies: %v", err)
×
2487
                return err
×
2488
        }
×
2489
        if len(policies) == 0 {
×
2490
                return nil
×
2491
        }
×
2492

2493
        lr := subnet.Status.U2OInterconnectionVPC
×
2494
        if lr == "" {
×
2495
                // old version field U2OInterconnectionVPC may be "" and then use subnet.Spec.Vpc
×
2496
                lr = subnet.Spec.Vpc
×
2497
        }
×
2498

2499
        for _, policy := range policies {
×
2500
                klog.Infof("delete u2o interconnection policy for router %s with match %s priority %d", lr, policy.Match, policy.Priority)
×
2501
                if err = c.OVNNbClient.DeleteLogicalRouterPolicyByUUID(lr, policy.UUID); err != nil {
×
2502
                        klog.Errorf("failed to delete u2o interconnection policy for subnet %s: %v", subnet.Name, err)
×
2503
                        return err
×
2504
                }
×
2505
        }
2506

2507
        u2oExcludeIP4Ag := strings.ReplaceAll(fmt.Sprintf(util.U2OExcludeIPAg, subnet.Name, "ip4"), "-", ".")
×
2508
        u2oExcludeIP6Ag := strings.ReplaceAll(fmt.Sprintf(util.U2OExcludeIPAg, subnet.Name, "ip6"), "-", ".")
×
2509

×
2510
        if err := c.OVNNbClient.DeleteAddressSet(u2oExcludeIP4Ag); err != nil {
×
2511
                klog.Errorf("delete address set %s: %v", u2oExcludeIP4Ag, err)
×
2512
                return err
×
2513
        }
×
2514

2515
        if err := c.OVNNbClient.DeleteAddressSet(u2oExcludeIP6Ag); err != nil {
×
2516
                klog.Errorf("delete address set %s: %v", u2oExcludeIP6Ag, err)
×
2517
                return err
×
2518
        }
×
2519

2520
        return nil
×
2521
}
2522

2523
func (c *Controller) addCustomVPCStaticRouteForSubnet(subnet *kubeovnv1.Subnet) error {
×
2524
        if subnet.Spec.Vpc == "" {
×
2525
                return nil
×
2526
        }
×
2527

2528
        v4Gw, v6Gw := util.SplitStringIP(subnet.Spec.Gateway)
×
2529
        v4Cidr, v6Cidr := util.SplitStringIP(subnet.Spec.CIDRBlock)
×
2530

×
2531
        if v4Gw != "" && v4Cidr != "" {
×
2532
                if err := c.addStaticRouteToVpc(
×
2533
                        subnet.Spec.Vpc,
×
2534
                        &kubeovnv1.StaticRoute{
×
2535
                                Policy:    kubeovnv1.PolicySrc,
×
2536
                                CIDR:      v4Cidr,
×
2537
                                NextHopIP: v4Gw,
×
2538
                        },
×
2539
                ); err != nil {
×
2540
                        klog.Errorf("failed to add static route, %v", err)
×
2541
                        return err
×
2542
                }
×
2543
        }
2544

2545
        if v6Gw != "" && v6Cidr != "" {
×
2546
                if err := c.addStaticRouteToVpc(
×
2547
                        subnet.Spec.Vpc,
×
2548
                        &kubeovnv1.StaticRoute{
×
2549
                                Policy:    kubeovnv1.PolicySrc,
×
2550
                                CIDR:      v6Cidr,
×
2551
                                NextHopIP: v6Gw,
×
2552
                        },
×
2553
                ); err != nil {
×
2554
                        klog.Errorf("failed to add static route, %v", err)
×
2555
                        return err
×
2556
                }
×
2557
        }
2558
        return nil
×
2559
}
2560

2561
func (c *Controller) deleteStaticRouteForU2OInterconn(subnet *kubeovnv1.Subnet) error {
×
2562
        if subnet.Spec.Vpc == "" {
×
2563
                return nil
×
2564
        }
×
2565

2566
        v4Gw, v6Gw := util.SplitStringIP(subnet.Spec.Gateway)
×
2567
        v4Cidr, v6Cidr := util.SplitStringIP(subnet.Spec.CIDRBlock)
×
2568
        if v4Gw != "" && v4Cidr != "" {
×
2569
                if err := c.deleteStaticRouteFromVpc(
×
2570
                        subnet.Spec.Vpc,
×
2571
                        subnet.Spec.RouteTable,
×
2572
                        v4Cidr,
×
2573
                        v4Gw,
×
2574
                        kubeovnv1.PolicySrc,
×
2575
                ); err != nil {
×
2576
                        klog.Errorf("failed to add static route, %v", err)
×
2577
                        return err
×
2578
                }
×
2579
        }
2580

2581
        if v6Gw != "" && v6Cidr != "" {
×
2582
                if err := c.deleteStaticRouteFromVpc(
×
2583
                        subnet.Spec.Vpc,
×
2584
                        subnet.Spec.RouteTable,
×
2585
                        v6Cidr,
×
2586
                        v6Gw,
×
2587
                        kubeovnv1.PolicySrc,
×
2588
                ); err != nil {
×
2589
                        klog.Errorf("failed to delete static route, %v", err)
×
2590
                        return err
×
2591
                }
×
2592
        }
2593
        return nil
×
2594
}
2595

2596
func (c *Controller) reconcileRouteTableForSubnet(subnet *kubeovnv1.Subnet) error {
×
2597
        if subnet.Spec.Vlan != "" && !subnet.Spec.U2OInterconnection {
×
2598
                return nil
×
2599
        }
×
2600

2601
        routerPortName := ovs.LogicalRouterPortName(subnet.Spec.Vpc, subnet.Name)
×
2602
        lrp, err := c.OVNNbClient.GetLogicalRouterPort(routerPortName, false)
×
2603
        if err != nil {
×
2604
                klog.Error(err)
×
2605
                return err
×
2606
        }
×
2607

2608
        rtb := lrp.Options["route_table"]
×
2609

×
2610
        // no need to update
×
2611
        if rtb == subnet.Spec.RouteTable {
×
2612
                return nil
×
2613
        }
×
2614

2615
        klog.Infof("reconcile route table %q for subnet %s", subnet.Spec.RouteTable, subnet.Name)
×
2616
        opt := map[string]string{"route_table": subnet.Spec.RouteTable}
×
2617
        if err = c.OVNNbClient.UpdateLogicalRouterPortOptions(routerPortName, opt); err != nil {
×
2618
                klog.Errorf("failed to set route table of logical router port %s to %s: %v", routerPortName, subnet.Spec.RouteTable, err)
×
2619
                return err
×
2620
        }
×
2621

2622
        return nil
×
2623
}
2624

2625
func (c *Controller) deleteCustomVPCPolicyRoutesForSubnet(subnet *kubeovnv1.Subnet) error {
×
2626
        if !c.logicalRouterExists(subnet.Spec.Vpc) {
×
2627
                return nil
×
2628
        }
×
2629
        for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2630
                ipSuffix := getIPSuffix(util.CheckProtocol(cidr))
×
2631
                match := fmt.Sprintf("%s.dst == %s", ipSuffix, cidr)
×
2632
                klog.Infof("delete policy route for router: %s, priority: %d, match %s", subnet.Spec.Vpc, util.SubnetRouterPolicyPriority, match)
×
2633
                if err := c.deletePolicyRouteFromVpc(subnet.Spec.Vpc, util.SubnetRouterPolicyPriority, match); err != nil {
×
2634
                        klog.Errorf("failed to delete logical router policy for CIDR %s of subnet %s: %v", cidr, subnet.Name, err)
×
2635
                        return err
×
2636
                }
×
2637
        }
2638
        return nil
×
2639
}
2640

2641
func (c *Controller) clearOldU2OResource(subnet *kubeovnv1.Subnet) error {
×
2642
        if subnet.Status.U2OInterconnectionVPC != "" &&
×
2643
                (!subnet.Spec.U2OInterconnection || (subnet.Spec.U2OInterconnection && subnet.Status.U2OInterconnectionVPC != subnet.Spec.Vpc)) {
×
2644
                // remove old u2o lsp and lrp first
×
2645
                lspName := fmt.Sprintf("%s-%s", subnet.Name, subnet.Status.U2OInterconnectionVPC)
×
2646
                lrpName := fmt.Sprintf("%s-%s", subnet.Status.U2OInterconnectionVPC, subnet.Name)
×
2647
                klog.Infof("clean subnet %s old u2o resource with lsp %s lrp %s", subnet.Name, lspName, lrpName)
×
2648
                if err := c.OVNNbClient.DeleteLogicalSwitchPort(lspName); err != nil {
×
2649
                        klog.Errorf("failed to delete u2o logical switch port %s: %v", lspName, err)
×
2650
                        return err
×
2651
                }
×
2652

2653
                if err := c.OVNNbClient.DeleteLogicalRouterPort(lrpName); err != nil {
×
2654
                        klog.Errorf("failed to delete u2o logical router port %s: %v", lrpName, err)
×
2655
                        return err
×
2656
                }
×
2657

2658
                if err := c.deletePolicyRouteForU2OInterconn(subnet); err != nil {
×
2659
                        klog.Errorf("failed to delete u2o policy route for u2o connection %s: %v", subnet.Name, err)
×
2660
                        return err
×
2661
                }
×
2662

2663
                if subnet.Status.U2OInterconnectionVPC != c.config.ClusterRouter {
×
2664
                        if err := c.deleteStaticRouteForU2OInterconn(subnet); err != nil {
×
2665
                                klog.Errorf("failed to delete u2o static route for u2o connection %s: %v", subnet.Name, err)
×
2666
                                return err
×
2667
                        }
×
2668
                }
2669
        }
2670
        return nil
×
2671
}
2672

2673
func (c *Controller) reconcilePolicyRouteForCidrChangedSubnet(subnet *kubeovnv1.Subnet, isCommonRoute bool) error {
×
2674
        var match string
×
2675
        var priority int
×
2676

×
2677
        if isCommonRoute {
×
2678
                priority = util.SubnetRouterPolicyPriority
×
2679
        } else {
×
2680
                priority = util.GatewayRouterPolicyPriority
×
2681
        }
×
2682

2683
        policies, err := c.OVNNbClient.ListLogicalRouterPolicies(subnet.Spec.Vpc, priority, map[string]string{
×
2684
                "vendor": util.CniTypeName,
×
2685
                "subnet": subnet.Name,
×
2686
        }, true)
×
2687
        if err != nil {
×
2688
                klog.Errorf("failed to list logical router policies: %v", err)
×
2689
                return err
×
2690
        }
×
2691
        if len(policies) == 0 {
×
2692
                return nil
×
2693
        }
×
2694

2695
        for _, policy := range policies {
×
2696
                policyProtocol := kubeovnv1.ProtocolIPv4
×
2697
                if strings.Contains(policy.Match, "ip6") {
×
2698
                        policyProtocol = kubeovnv1.ProtocolIPv6
×
2699
                }
×
2700

2701
                for cidr := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2702
                        if cidr == "" {
×
2703
                                continue
×
2704
                        }
2705
                        if policyProtocol != util.CheckProtocol(cidr) {
×
2706
                                continue
×
2707
                        }
2708

2709
                        ipSuffix := getIPSuffix(util.CheckProtocol(cidr))
×
2710

×
2711
                        if isCommonRoute {
×
2712
                                match = fmt.Sprintf("%s.dst == %s", ipSuffix, cidr)
×
2713
                        } else {
×
2714
                                if subnet.Spec.GatewayType == kubeovnv1.GWCentralizedType {
×
2715
                                        match = fmt.Sprintf("%s.src == %s", ipSuffix, cidr)
×
2716
                                } else {
×
2717
                                        continue
×
2718
                                }
2719
                        }
2720

2721
                        if policy.Match != match {
×
2722
                                klog.Infof("delete old policy route for subnet %s with match %s priority %d, new match %v", subnet.Name, policy.Match, policy.Priority, match)
×
2723
                                if err = c.OVNNbClient.DeleteLogicalRouterPolicyByUUID(subnet.Spec.Vpc, policy.UUID); err != nil {
×
2724
                                        klog.Errorf("failed to delete policy route for subnet %s: %v", subnet.Name, err)
×
2725
                                        return err
×
2726
                                }
×
2727
                        }
2728
                }
2729
        }
2730
        return nil
×
2731
}
2732

2733
func (c *Controller) addPolicyRouteForU2ONoLoadBalancer(subnet *kubeovnv1.Subnet) error {
×
2734
        nodes, err := c.nodesLister.List(labels.Everything())
×
2735
        if err != nil {
×
2736
                klog.Errorf("failed to list nodes: %v", err)
×
2737
                return err
×
2738
        }
×
2739
        for _, node := range nodes {
×
2740
                pgName := getOverlaySubnetsPortGroupName(subnet.Name, node.Name)
×
2741
                if err := c.OVNNbClient.CreatePortGroup(pgName, map[string]string{logicalRouterKey: subnet.Spec.Vpc, logicalSwitchKey: subnet.Name, u2oKey: "true"}); err != nil {
×
2742
                        klog.Errorf("failed to create u2o port group for subnet %s and node %s: %v", subnet.Name, node.Name, err)
×
2743
                        return err
×
2744
                }
×
2745
                key := util.NodeLspName(node.Name)
×
2746
                ip, err := c.ipsLister.Get(key)
×
2747
                if err != nil {
×
2748
                        if k8serrors.IsNotFound(err) {
×
2749
                                continue
×
2750
                        }
2751
                        klog.Error(err)
×
2752
                        return err
×
2753
                }
2754
                v4Svc, v6Svc := util.SplitStringIP(c.config.ServiceClusterIPRange)
×
2755
                for cidrBlock := range strings.SplitSeq(subnet.Spec.CIDRBlock, ",") {
×
2756
                        ipSuffix := getIPSuffix(util.CheckProtocol(cidrBlock))
×
2757
                        nodeIP := ip.Spec.V4IPAddress
×
2758
                        svcCIDR := v4Svc
×
2759
                        if ipSuffix == "ip6" {
×
2760
                                nodeIP = ip.Spec.V6IPAddress
×
2761
                                svcCIDR = v6Svc
×
2762
                        }
×
2763
                        if nodeIP == "" || svcCIDR == "" {
×
2764
                                continue
×
2765
                        }
2766

2767
                        pgAs := fmt.Sprintf("%s_%s", pgName, ipSuffix)
×
2768
                        match := fmt.Sprintf("%s.src == $%s && %s.dst == %s", ipSuffix, pgAs, ipSuffix, svcCIDR)
×
2769
                        action := kubeovnv1.PolicyRouteActionReroute
×
2770
                        externalIDs := buildPolicyRouteExternalIDs(subnet.Name, map[string]string{
×
2771
                                "isU2ORoutePolicy":     "true",
×
2772
                                "isU2ONoLBRoutePolicy": "true",
×
2773
                                "node":                 node.Name,
×
2774
                        })
×
2775

×
2776
                        klog.Infof("add u2o interconnection policy without enabling loadbalancer for router: %s, match %s, action %s, nexthop %s", subnet.Spec.Vpc, match, action, nodeIP)
×
2777
                        if err := c.addPolicyRouteToVpc(
×
2778
                                c.config.ClusterRouter,
×
2779
                                &kubeovnv1.PolicyRoute{
×
2780
                                        Priority:  util.U2OSubnetPolicyPriority,
×
2781
                                        Match:     match,
×
2782
                                        Action:    action,
×
2783
                                        NextHopIP: nodeIP,
×
2784
                                },
×
2785
                                externalIDs,
×
2786
                        ); err != nil {
×
2787
                                klog.Errorf("failed to add logical router policy for port-group address-set %s: %v", pgAs, err)
×
2788
                                return err
×
2789
                        }
×
2790
                }
2791
        }
2792
        lsps, err := c.OVNNbClient.ListNormalLogicalSwitchPorts(true, map[string]string{logicalSwitchKey: subnet.Name})
×
2793
        if err != nil {
×
2794
                klog.Errorf("failed to list normal lsps for subnet %s: %v", subnet.Name, err)
×
2795
                return err
×
2796
        }
×
2797
        for _, lsp := range lsps {
×
2798
                ip, err := c.ipsLister.Get(lsp.Name)
×
2799
                if err != nil {
×
2800
                        if k8serrors.IsNotFound(err) {
×
2801
                                continue
×
2802
                        }
2803
                        klog.Error(err)
×
2804
                        return err
×
2805
                }
2806
                pgName := getOverlaySubnetsPortGroupName(subnet.Name, ip.Spec.NodeName)
×
2807
                if err = c.OVNNbClient.PortGroupAddPorts(pgName, lsp.Name); err != nil {
×
2808
                        klog.Errorf("failed to add port to u2o port group %s: %v", pgName, err)
×
2809
                        return err
×
2810
                }
×
2811
        }
2812
        return nil
×
2813
}
2814

2815
func (c *Controller) deletePolicyRouteForU2ONoLoadBalancer(subnet *kubeovnv1.Subnet) error {
×
2816
        if !c.logicalRouterExists(subnet.Spec.Vpc) {
×
2817
                return nil
×
2818
        }
×
2819
        policies, err := c.OVNNbClient.ListLogicalRouterPolicies(subnet.Spec.Vpc, -1, map[string]string{
×
2820
                "isU2ONoLBRoutePolicy": "true",
×
2821
                "vendor":               util.CniTypeName,
×
2822
                "subnet":               subnet.Name,
×
2823
        }, true)
×
2824
        if err != nil {
×
2825
                klog.Errorf("failed to list logical router policies: %v", err)
×
2826
                return err
×
2827
        }
×
2828

2829
        lr := subnet.Status.U2OInterconnectionVPC
×
2830
        if lr == "" {
×
2831
                // old version field U2OInterconnectionVPC may be "" and then use subnet.Spec.Vpc
×
2832
                lr = subnet.Spec.Vpc
×
2833
        }
×
2834

2835
        for _, policy := range policies {
×
2836
                klog.Infof("delete u2o interconnection policy without enabling loadbalancer for router %s with match %s priority %d", lr, policy.Match, policy.Priority)
×
2837
                if err = c.OVNNbClient.DeleteLogicalRouterPolicyByUUID(lr, policy.UUID); err != nil {
×
2838
                        klog.Errorf("failed to delete u2o interconnection policy for subnet %s: %v", subnet.Name, err)
×
2839
                        return err
×
2840
                }
×
2841
        }
2842

2843
        pgs, err := c.OVNNbClient.ListPortGroups(map[string]string{logicalRouterKey: subnet.Spec.Vpc, logicalSwitchKey: subnet.Name, u2oKey: "true"})
×
2844
        if err != nil {
×
2845
                klog.Errorf("failed to list u2o port groups with u2oKey is true for subnet %s: %v", subnet.Name, err)
×
2846
                return err
×
2847
        }
×
2848
        for _, pg := range pgs {
×
2849
                klog.Infof("delete u2o port group %s for subnet %s", pg.Name, subnet.Name)
×
2850
                if err = c.OVNNbClient.DeletePortGroup(pg.Name); err != nil {
×
2851
                        klog.Errorf("failed to delete u2o port group for subnet %s: %v", subnet.Name, err)
×
2852
                        return err
×
2853
                }
×
2854
        }
2855
        return nil
×
2856
}
2857

2858
func (c *Controller) findSubnetByNetworkAttachmentDefinition(ns, name string, subnets []*kubeovnv1.Subnet) (*kubeovnv1.Subnet, error) {
×
2859
        nad, err := c.netAttachLister.NetworkAttachmentDefinitions(ns).Get(name)
×
2860
        if err != nil {
×
2861
                klog.Errorf("failed to get net-attach-def %s/%s: %v", ns, name, err)
×
2862
                return nil, err
×
2863
        }
×
2864
        netCfg, err := loadNetConf([]byte(nad.Spec.Config))
×
2865
        if err != nil {
×
2866
                klog.Errorf("failed to parse config of net-attach-def %s/%s: %v", ns, name, err)
×
2867
                return nil, err
×
2868
        }
×
2869

2870
        var provider string
×
2871
        if netCfg.Conf.Type == util.CniTypeName {
×
2872
                provider = fmt.Sprintf("%s.%s.%s", name, ns, util.OvnProvider)
×
2873
        } else {
×
2874
                provider = fmt.Sprintf("%s.%s", name, ns)
×
2875
        }
×
2876
        var subnet *kubeovnv1.Subnet
×
2877
        for _, s := range subnets {
×
2878
                if s.Spec.Provider == provider {
×
2879
                        subnet = s.DeepCopy()
×
2880
                        break
×
2881
                }
2882
        }
2883
        if subnet == nil {
×
2884
                err = fmt.Errorf("failed to get subnet for net-attach-def %s/%s", ns, name)
×
2885
                klog.Error(err)
×
2886
                return nil, err
×
2887
        }
×
2888

2889
        return subnet, nil
×
2890
}
2891

2892
func (c *Controller) handleMcastQuerierChange(subnet *kubeovnv1.Subnet) error {
×
2893
        if subnet.Spec.EnableMulticastSnoop {
×
2894
                multicastSnoopFlag := map[string]string{
×
2895
                        "mcast_snoop":   "true",
×
2896
                        "mcast_querier": "true",
×
2897
                        "mcast_ip4_src": subnet.Status.McastQuerierIP,
×
2898
                        "mcast_eth_src": subnet.Status.McastQuerierMAC,
×
2899
                }
×
2900
                mcastQuerierLspName := fmt.Sprintf(util.McastQuerierName, subnet.Name)
×
2901
                if err := c.OVNNbClient.CreateLogicalSwitchPort(subnet.Name, mcastQuerierLspName, subnet.Status.McastQuerierIP, subnet.Status.McastQuerierMAC, mcastQuerierLspName, metav1.NamespaceDefault, false, "", "", false, nil, ""); err != nil {
×
2902
                        err = fmt.Errorf("failed to create mcast querier lsp %s: %w", mcastQuerierLspName, err)
×
2903
                        klog.Error(err)
×
2904
                        return err
×
2905
                }
×
2906

2907
                if err := c.OVNNbClient.LogicalSwitchUpdateOtherConfig(subnet.Name, ovsdb.MutateOperationInsert, multicastSnoopFlag); err != nil {
×
2908
                        klog.Errorf("enable logical switch multicast snoop %s: %v", subnet.Name, err)
×
2909
                        return err
×
2910
                }
×
2911
        } else {
×
2912
                lss, err := c.OVNNbClient.ListLogicalSwitch(false, func(ls *ovnnb.LogicalSwitch) bool {
×
2913
                        return ls.Name == subnet.Name
×
2914
                })
×
2915
                if err != nil || len(lss) == 0 {
×
2916
                        klog.Errorf("failed to list logical switch %s: %v", subnet.Name, err)
×
2917
                        return err
×
2918
                }
×
2919

2920
                multicastSnoopFlag := map[string]string{
×
2921
                        "mcast_snoop":   lss[0].OtherConfig["mcast_snoop"],
×
2922
                        "mcast_querier": lss[0].OtherConfig["mcast_querier"],
×
2923
                        "mcast_ip4_src": lss[0].OtherConfig["mcast_ip4_src"],
×
2924
                        "mcast_eth_src": lss[0].OtherConfig["mcast_eth_src"],
×
2925
                }
×
2926
                mcastQuerierLspName := fmt.Sprintf(util.McastQuerierName, subnet.Name)
×
2927
                if err := c.OVNNbClient.LogicalSwitchUpdateOtherConfig(subnet.Name, ovsdb.MutateOperationDelete, multicastSnoopFlag); err != nil {
×
2928
                        klog.Errorf("disable logical switch multicast snoop %s: %v", subnet.Name, err)
×
2929
                        return err
×
2930
                }
×
2931

2932
                if err := c.OVNNbClient.DeleteLogicalSwitchPort(mcastQuerierLspName); err != nil {
×
2933
                        err = fmt.Errorf("failed to delete mcast querier lsp %s: %w", mcastQuerierLspName, err)
×
2934
                        klog.Error(err)
×
2935
                        return err
×
2936
                }
×
2937
        }
2938
        return nil
×
2939
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc