- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 707 for Allocate (0.46 sec)
-
pkg/registry/core/service/portallocator/storage/storage_test.go
t.Fatalf("unexpected error: %v", err) } // Allocate a port inside the valid port range if err := storage.Allocate(30100); err != nil { t.Fatal(err) } // Try to allocate the same port in the local bitmap // The local bitmap stores the offset of the port // offset = port - base (30100 - 30000 = 100) ok, err := backing.Allocate(100) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/allocator_test.go
if err := r.Release(released); err != nil { t.Fatal(err) } err = r.Allocate(1) if _, ok := err.(*ErrNotInRange); !ok { t.Fatal(err) } if err := r.Allocate(10001); err != ErrAllocated { t.Fatal(err) } err = r.Allocate(20000) if _, ok := err.(*ErrNotInRange); !ok { t.Fatal(err) } err = r.Allocate(10201) if _, ok := err.(*ErrNotInRange); !ok { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 14K 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) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
val address = factory.newHttpsAddress() proxySelector.proxies.add(proxyA) proxySelector.proxies.add(proxyB) var routeSelector = newRouteSelector(address) dns[PROXY_A_HOST] = dns.allocate(1) dns[PROXY_B_HOST] = dns.allocate(1) // Mark the ProxyA route as failed. val selection = routeSelector.next() dns.assertRequests(PROXY_A_HOST) val route = selection.next()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 20.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
// If we can allocate all remaining devices from the set of aligned ones, then // give the plugin the chance to influence which ones to allocate from that set. if needed < aligned.Len() { // First allocate from the preferred devices list (if available). preferred, err := m.callGetPreferredAllocationIfAvailable(podUID, contName, resource, aligned.Union(allocated), allocated, required) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
src/runtime/traceregion.go
} // Add the existing block to the full list. block.next = a.full a.full = block } // Allocate a new block. block = (*traceRegionAllocBlock)(sysAlloc(unsafe.Sizeof(traceRegionAllocBlock{}), &memstats.other_sys)) if block == nil { throw("traceRegion: out of memory") } // Allocate space for our current request, so we always make // progress. block.off.Store(n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/allocator.go
// include valid port range in error validPorts := r.portRange.String() return &ErrNotInRange{validPorts} } allocated, err := r.alloc.Allocate(offset) if err != nil { // update metrics r.metrics.incrementAllocationErrors("static") return err } if !allocated { // update metrics r.metrics.incrementAllocationErrors("static") return ErrAllocated } // update metrics
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 7.4K bytes - Viewed (0) -
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) -
pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel_test.go
} allocation, createErr := controller.Allocate(tCtx, tc.model) if createErr != nil { if !tc.expectAllocateErr { tCtx.Fatalf("unexpected allocate error: %v", createErr) } return } if tc.expectAllocateErr { tCtx.Fatalf("did not get expected allocate error") } expectAllocation := []*resourceapi.NamedResourcesAllocationResult{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 09:27:01 UTC 2024 - 7.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
.put(Buffer.class, ByteBuffer.allocate(0)) .put(CharBuffer.class, CharBuffer.allocate(0)) .put(ByteBuffer.class, ByteBuffer.allocate(0)) .put(ShortBuffer.class, ShortBuffer.allocate(0)) .put(IntBuffer.class, IntBuffer.allocate(0)) .put(LongBuffer.class, LongBuffer.allocate(0)) .put(FloatBuffer.class, FloatBuffer.allocate(0))
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 17 16:33:44 UTC 2024 - 20.5K bytes - Viewed (0)