- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for InsertPrefix (0.21 sec)
-
pkg/util/iptree/iptree_test.go
if _, ok := tree.GetPrefix(ipnet2); ok { t.Errorf("CIDR %s not expected", ipnet2) } // check insert existing prefix updates the value ok = tree.InsertPrefix(ipnet2, 2) if ok { t.Errorf("should not exist: %s", ipnet2) } ok = tree.InsertPrefix(ipnet2, 3) if !ok { t.Errorf("should be updated: %s", ipnet2) } if v, ok := tree.GetPrefix(ipnet2); !ok || v != 3 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17.8K bytes - Viewed (0) -
pkg/util/iptree/iptree.go
} if n != nil && n.public && n.prefix == prefix { return n.prefix, n.val, true } return netip.Prefix{}, zeroT, false } // InsertPrefix is used to add a new entry or update // an existing entry. Returns true if updated. func (t *Tree[T]) InsertPrefix(prefix netip.Prefix, v T) bool { n := t.rootV4 if prefix.Addr().Is6() { n = t.rootV6 } var parent *node[T]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
return nil, ErrMismatchedNetwork } return allocator, nil } func (c *MetaAllocator) addAllocator(cidr netip.Prefix, allocator *Allocator) { c.muTree.Lock() defer c.muTree.Unlock() c.tree.InsertPrefix(cidr, allocator) } func (c *MetaAllocator) deleteAllocator(cidr netip.Prefix) { c.muTree.Lock() defer c.muTree.Unlock() ok := c.tree.DeletePrefix(cidr) if ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
// if the prefix already exist append the new ServiceCIDR name v, ok := tree.GetPrefix(prefix) if !ok { v = sets.Set[string]{} } v.Insert(serviceCIDR.Name) tree.InsertPrefix(prefix, v) } } } c.muTree.Lock() defer c.muTree.Unlock() c.tree = tree return nil } func (c *Controller) sync(ctx context.Context, key string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
for _, serviceCIDR := range serviceCIDRList { for _, cidr := range serviceCIDR.Spec.CIDRs { if prefix, err := netip.ParsePrefix(cidr); err == nil { // it can not fail since is already validated tree.InsertPrefix(prefix, serviceCIDR.Name) } } } r.muTree.Lock() defer r.muTree.Unlock() r.tree = tree return nil } func newIPAddress(name string, svc *v1.Service) *networkingv1alpha1.IPAddress {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0)