Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 503 for allocators (0.32 sec)

  1. cmd/kube-proxy/app/server_linux.go

    	"k8s.io/kubernetes/pkg/proxy/nftables"
    	proxyutil "k8s.io/kubernetes/pkg/proxy/util"
    	utiliptables "k8s.io/kubernetes/pkg/util/iptables"
    	"k8s.io/utils/exec"
    )
    
    // timeoutForNodePodCIDR is the time to wait for allocators to assign a PodCIDR to the
    // node after it is registered.
    var timeoutForNodePodCIDR = 5 * time.Minute
    
    // platformApplyDefaults is called after parsing command-line flags and/or reading the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/controller/repair.go

    	err := wait.PollImmediate(time.Second, 10*time.Second, func() (bool, error) {
    		for family, allocator := range c.allocatorByFamily {
    			// get snapshot if it is not there
    			if _, ok := snapshotByFamily[family]; !ok {
    				snapshot, err := allocator.Get()
    				if err != nil {
    					return false, err
    				}
    
    				snapshotByFamily[family] = snapshot
    			}
    		}
    		return true, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  3. pkg/controlplane/instance.go

    				c.Extra.ServiceIPRange,
    				c.Extra.SecondaryServiceIPRange,
    				client,
    			)
    			// The default serviceCIDR must exist before the apiserver is healthy
    			// otherwise the allocators for Services will not work.
    			controller.Start(hookContext)
    			return nil
    		})
    	}
    
    	return s, nil
    
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  4. pkg/util/iptree/iptree.go

    }
    
    // prefixContainIP returns true if the given IP is contained with the prefix,
    // is not the network address and also, if IPv4, is not the broadcast address.
    // This is required because the Kubernetes allocators reserve these addresses
    // so IPAddresses can not block deletion of this ranges.
    func prefixContainIP(prefix netip.Prefix, ip netip.Addr) bool {
    	// if the IP is the network address is not contained
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 17.7K bytes
    - Viewed (0)
  5. pkg/registry/core/service/storage/storage.go

    	rest.GracefulDeleter
    }
    
    type PodStorage interface {
    	rest.Getter
    }
    
    type REST struct {
    	*genericregistry.Store
    	primaryIPFamily   api.IPFamily
    	secondaryIPFamily api.IPFamily
    	alloc             Allocators
    	endpoints         EndpointsStorage
    	pods              PodStorage
    	proxyTransport    http.RoundTripper
    }
    
    var (
    	_ rest.CategoriesProvider     = &REST{}
    	_ rest.ShortNamesProvider     = &REST{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/runtime/allocator.go

    var AllocatorPool = sync.Pool{
    	New: func() interface{} {
    		return &Allocator{}
    	},
    }
    
    // Allocator knows how to allocate memory
    // It exists to make the cost of object serialization cheaper.
    // In some cases, it allows for allocating memory only once and then reusing it.
    // This approach puts less load on GC and leads to less fragmented memory in general.
    type Allocator struct {
    	buf []byte
    }
    
    var _ MemoryAllocator = &Allocator{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 27 03:17:50 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  7. src/cmd/internal/obj/link.go

    // specified by Pos.Line().
    // Every Prog has a Ctxt field that defines its context.
    // For performance reasons, Progs are usually bulk allocated, cached, and reused;
    // those bulk allocators should always be used, rather than new(Prog).
    //
    // The other fields not yet mentioned are for use by the back ends and should
    // be left zeroed by creators of Prog lists.
    type Prog struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  8. src/runtime/malloc.go

    // Any free page of memory can be split into a set of objects
    // of one size class, which are then managed using a free bitmap.
    //
    // The allocator's data structures are:
    //
    //	fixalloc: a free-list allocator for fixed-size off-heap objects,
    //		used to manage storage used by the allocator.
    //	mheap: the malloc heap, managed at page (8192-byte) granularity.
    //	mspan: a run of in-use pages managed by the mheap.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  9. pkg/registry/core/service/portallocator/allocator.go

    	}
    
    	return a, err
    }
    
    // NewInMemory creates an in-memory allocator.
    func NewInMemory(pr net.PortRange) (*PortAllocator, error) {
    	return New(pr, func(max int, rangeSpec string, offset int) (allocator.Interface, error) {
    		return allocator.NewAllocationMapWithOffset(max, rangeSpec, offset), nil
    	})
    }
    
    // NewFromSnapshot allocates a PortAllocator and initializes it from a snapshot.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  10. src/runtime/mheap.go

    	}
    
    	spanalloc              fixalloc // allocator for span*
    	cachealloc             fixalloc // allocator for mcache*
    	specialfinalizeralloc  fixalloc // allocator for specialfinalizer*
    	specialprofilealloc    fixalloc // allocator for specialprofile*
    	specialReachableAlloc  fixalloc // allocator for specialReachable
    	specialPinCounterAlloc fixalloc // allocator for specialPinCounter
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
Back to top