- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 704 for Deallocate (0.16 sec)
-
pkg/kubelet/cm/devicemanager/endpoint.go
AllocationSize: int32(size), }, }, }) } // allocate issues Allocate gRPC call to the device plugin. func (e *endpointImpl) allocate(devs []string) (*pluginapi.AllocateResponse, error) { if e.isStopped() { return nil, fmt.Errorf(errEndpointStopped, e) } return e.api.Allocate(context.Background(), &pluginapi.AllocateRequest{ ContainerRequests: []*pluginapi.ContainerAllocateRequest{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 11:05:20 UTC 2022 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/allocator.go
}, } // 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) -
pkg/kubelet/cm/cpumanager/cpu_assignment_test.go
1, "", cpuset.New(2), }, { "allocate 4 full cores with 3 coming from the first NUMA node (filling it up) and 1 coming from the second NUMA node", topoDualSocketHT, mustParseCPUSet(t, "0-11"), 8, "", mustParseCPUSet(t, "0,6,2,8,4,10,1,7"), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 17:31:37 UTC 2023 - 22.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel.go
} func (c *Controller) NodeIsSuitable(ctx context.Context, model Model) (bool, error) { indices, err := c.allocate(ctx, model) return len(indices) == len(c.requests), err } func (c *Controller) Allocate(ctx context.Context, model Model) ([]*resourceapi.NamedResourcesAllocationResult, error) { indices, err := c.allocate(ctx, model) if err != nil { return nil, err } if len(indices) != len(c.requests) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:26:16 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/bitmap.go
const dryRunFalse = false // Allocate attempts to reserve the provided IP. ErrNotInRange or // ErrAllocated will be returned if the IP is not valid for this range // or has already been reserved. ErrFull will be returned if there // are no addresses left. func (r *Range) Allocate(ip net.IP) error { return r.allocate(ip, dryRunFalse) } func (r *Range) allocate(ip net.IP, dryRun bool) error { label := r.CIDR()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 10.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator_test.go
t.Errorf("expected %d free addresses, got %d", dynamicOffset, f) } // allocate all addresses on the static block for i := 0; i < dynamicOffset; i++ { ip := fmt.Sprintf("192.168.1.%d", i+1) if err := r.Allocate(netutils.ParseIPSloppy(ip)); err != nil { t.Errorf("Unexpected error trying to allocate IP %s: %v", ip, err) } } if f := r.Free(); f != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jun 25 13:14:46 UTC 2023 - 24.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
AddContainer(p *v1.Pod, c *v1.Container, containerID string) // Allocate is called to pre-allocate memory resources during Pod admission. // This must be called at some point prior to the AddContainer() call for a container, e.g. at pod admission time. Allocate(pod *v1.Pod, container *v1.Container) error // RemoveContainer is called after Kubelet decides to kill or delete a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
defaultCPUSet: testCase.stDefaultCPUSet, } pod := testCase.pod // allocate for _, container := range append(pod.Spec.InitContainers, pod.Spec.Containers...) { policy.Allocate(st, pod, &container) } if !reflect.DeepEqual(st.defaultCPUSet, testCase.expCSetAfterAlloc) { t.Errorf("StaticPolicy Allocate() error (%v). expected default cpuset %v but got %v",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
src/cmd/link/internal/ld/outbuf_mmap.go
func (out *OutBuf) Mmap(filesize uint64) (err error) { oldlen := len(out.buf) if oldlen != 0 { out.munmap() } for { if err = out.fallocate(filesize); err != syscall.EINTR { break } } if err != nil { // Some file systems do not support fallocate. We ignore that error as linking // can still take place, but you might SIGBUS when you write to the mmapped // area.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:20:31 UTC 2024 - 1.4K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
} @Override public HashCode hashInt(int input) { return hashBytes(ByteBuffer.allocate(4).order(ByteOrder.LITTLE_ENDIAN).putInt(input).array()); } @Override public HashCode hashLong(long input) { return hashBytes(ByteBuffer.allocate(8).order(ByteOrder.LITTLE_ENDIAN).putLong(input).array()); } @Override public HashCode hashUnencodedChars(CharSequence input) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 3.8K bytes - Viewed (0)