Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 7,667 for reserves (0.43 sec)

  1. platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/WorkerDaemonClientsManagerTest.groovy

        def "does not reserve idle client when no clients"() {
            expect:
            manager.reserveIdleClient(options) == null
        }
    
        def "does not reserve idle client when no matching client found"() {
            def noMatch = Stub(WorkerDaemonClient) {
                isCompatibleWith(_) >> false
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Mar 21 14:56:11 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       */
      @CanIgnoreReturnValue
      public double acquire(int permits) {
        long microsToWait = reserve(permits);
        stopwatch.sleepMicrosUninterruptibly(microsToWait);
        return 1.0 * microsToWait / SECONDS.toMicros(1L);
      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_container_windows.go

    	resources := runtimeapi.WindowsContainerResources{}
    
    	memLimit := memoryLimit.Value()
    
    	if !cpuLimit.IsZero() {
    		// Since Kubernetes doesn't have any notion of weight in the Pod/Container API, only limits/reserves, then applying CpuMaximum only
    		// will better follow the intent of the user. At one point CpuWeights were set, but this prevented limits from having any effect.
    
    		// There are 3 parts to how this works:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/RateLimiter.java

       */
      @CanIgnoreReturnValue
      public double acquire(int permits) {
        long microsToWait = reserve(permits);
        stopwatch.sleepMicrosUninterruptibly(microsToWait);
        return 1.0 * microsToWait / SECONDS.toMicros(1L);
      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  5. src/runtime/tracebuf.go

    		if v < 0x80 {
    			pos += i + 1
    			arr[i] = byte(v)
    			break
    		}
    		arr[i] = 0x80 | byte(v)
    		v >>= 7
    	}
    	buf.pos = pos
    }
    
    // varintReserve reserves enough space in buf to hold any varint.
    //
    // Space reserved this way can be filled in with the varintAt method.
    func (buf *traceBuf) varintReserve() int {
    	p := buf.pos
    	buf.pos += traceBytesPerNumber
    	return p
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/DetachedConfigurationsIntegrationTest.groovy

                contextualLabel == 'The detachedConfiguration1 configuration has been deprecated for consumption.'
            }
        }
    
        def "configurations container reserves name #name for detached configurations"() {
            given:
            buildFile << """
                configurations {
                    $name
                }
            """
    
            expect:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Mar 28 15:16:47 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  7. pkg/registry/core/service/allocator/bitmap.go

    	}
    	if r.allocated.Bit(offset) == 1 {
    		return false, nil
    	}
    	r.allocated = r.allocated.SetBit(r.allocated, offset, 1)
    	r.count++
    	return true, nil
    }
    
    // AllocateNext reserves one of the items from the pool.
    // (0, false, nil) may be returned if there are no items left.
    func (r *AllocationBitmap) AllocateNext() (int, bool, error) {
    	r.lock.Lock()
    	defer r.lock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 25 20:32:40 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  8. src/runtime/mem.go

    // that elides the Ready state accounting.
    func sysFault(v unsafe.Pointer, n uintptr) {
    	gcController.mappedReady.Add(-int64(n))
    	sysFaultOS(v, n)
    }
    
    // sysReserve transitions a memory region from None to Reserved. It reserves
    // address space in such a way that it would cause a fatal fault upon access
    // (either via permissions or not committing the memory). Such a reservation is
    // thus never backed by physical memory.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 22 19:05:10 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  9. src/runtime/sys_aix_ppc64.s

    // asmsyscall6 calls a library function with a function descriptor
    // stored in libcall_fn and store the results in libcall structure
    // Up to 6 arguments can be passed to this C function
    // Called by runtime.asmcgocall
    // It reserves a stack of 288 bytes for the C function. It must
    // follow AIX convention, thus the first local variable must
    // be stored at the offset 112, after the linker area (48 bytes)
    // and the argument area (64).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 21 19:29:00 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  10. pkg/registry/core/service/portallocator/allocator.go

    func (r *PortAllocator) Used() int {
    	return r.portRange.Size - r.alloc.Free()
    }
    
    // Allocate attempts to reserve the provided port. ErrNotInRange or
    // ErrAllocated will be returned if the port is not valid for this range
    // or has already been reserved.  ErrFull will be returned if there
    // are no ports left.
    func (r *PortAllocator) Allocate(port int) error {
    	ok, offset := r.contains(port)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 7.4K bytes
    - Viewed (0)
Back to top