- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 765 for allocable (0.23 sec)
-
pkg/registry/core/service/portallocator/operation_test.go
if err != nil { t.Errorf("expected no error but got: %v", err) } // Try to allocate the returned port using the same operation if e, a := ErrAllocated, op.Allocate(port); e != a { t.Errorf("expected %v but got: %v", e, a) } // AllocateNext with a previously used dry run operation op = StartOperation(r, true) _ = op.Allocate(12345) port, err = op.AllocateNext() if port == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Aug 15 23:44:12 UTC 2021 - 3.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/storage/storage_test.go
defer destroyFunc() if err := storage.Allocate(netutils.ParseIPSloppy("192.168.1.2")); !strings.Contains(err.Error(), "cannot allocate resources of type serviceipallocations at this time") { t.Fatal(err) } } func TestErrors(t *testing.T) { _, storage, _, _, destroyFunc := newStorage(t) defer destroyFunc() err := storage.Allocate(netutils.ParseIPSloppy("192.168.0.0"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/registry/core/service/allocator/bitmap_test.go
// Allocate all possible values except the reserved for i := dynamicOffset; i < max; i++ { if ok, _ := m.Allocate(i); !ok { t.Errorf("error allocate i %v", i) } else { allocated++ } } // Allocate all the values of the reserved block except one for i := 0; i < dynamicOffset-1; i++ { if ok, _ := m.Allocate(i); !ok { t.Errorf("error allocate i %v", i)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 10 08:56:31 UTC 2022 - 13.3K bytes - Viewed (0) -
pkg/kubelet/eviction/memory_threshold_notifier.go
} func (m *memoryThresholdNotifier) Description() string { var hard, allocatable string if isHardEvictionThreshold(m.threshold) { hard = "hard " } else { hard = "soft " } if isAllocatableEvictionThreshold(m.threshold) { allocatable = "allocatable " } return fmt.Sprintf("%s%smemory eviction threshold", hard, allocatable) } var _ NotifierFactory = &CgroupNotifierFactory{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 21 00:36:14 UTC 2021 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/allocator_test.go
iterations := rand.Intn(10000) + 10 target := &Allocator{} for i := 0; i < iterations; i++ { bytesToAllocate := rand.Intn(maxBytes) buff := target.Allocate(uint64(bytesToAllocate)) if cap(buff) < bytesToAllocate { t.Fatalf("expected the buffer to allocate: %v bytes whereas it allocated: %v bytes", bytesToAllocate, cap(buff)) } if len(buff) != bytesToAllocate {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 13:38:29 UTC 2022 - 2.4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_checkpoint_test.go
"", &stateMemory{}, }, { "Restore valid checkpoint", `{ "policyName":"static", "machineState":{"0":{"numberOfAssignments":0,"memoryMap":{"memory":{"total":2048,"systemReserved":512,"allocatable":1536,"reserved":512,"free":1024}},"cells":[]}}, "entries":{"pod":{"container1":[{"numaAffinity":[0],"type":"memory","size":512}]}}, "checksum": 4215593881 }`, "", &stateMemory{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 10.6K bytes - Viewed (0) -
pkg/kubelet/apis/config/types.go
KubeReservedCgroup string // This flag specifies the various Node Allocatable enforcements that Kubelet needs to perform. // This flag accepts a list of options. Acceptable options are `pods`, `system-reserved` & `kube-reserved`. // Refer to [Node Allocatable](https://kubernetes.io/docs/tasks/administer-cluster/reserve-compute-resources/#node-allocatable) doc for more information.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 35.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) -
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/registry/core/service/portallocator/operation.go
limitations under the License. */ package portallocator // Encapsulates the semantics of a port allocation 'transaction': // It is better to leak ports than to double-allocate them, // so we allocate immediately, but defer release. // On commit we best-effort release the deferred releases. // On rollback we best-effort release any allocations we did. // // Pattern for use: //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 4.2K bytes - Viewed (0)