Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 707 for Allocate (0.46 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top