Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 308 for deltas (0.1 sec)

  1. pkg/apis/core/v1/helper/qos/qos.go

    			if !isSupportedQoSComputeResource(name) {
    				continue
    			}
    			if quantity.Cmp(zeroQuantity) == 1 {
    				delta := quantity.DeepCopy()
    				if _, exists := requests[name]; !exists {
    					requests[name] = delta
    				} else {
    					delta.Add(requests[name])
    					requests[name] = delta
    				}
    			}
    		}
    		// process limits
    		qosLimitsFound := sets.NewString()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 04:01:46 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental_reader_test.cc

    TFE_MonitoringCounter1* CreateCounter1(const char* counter_name,
                                           const char* label);
    void IncrementCounter0(TFE_MonitoringCounter0* counter, int64_t delta = 1);
    void IncrementCounter1(TFE_MonitoringCounter1* counter, const char* label,
                           int64_t delta = 1);
    
    TEST(CAPI, MonitoringCellReader0) {
      auto counter_name = "test/counter0";
      auto* counter = CreateCounter0(counter_name);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go

    	// then any Add with positive delta will return error.
    	wait bool
    }
    
    // Add adds delta, which may be negative, similar to sync.WaitGroup.
    // If Add with a positive delta happens after Wait, it will return error,
    // which prevent unsafe Add.
    func (wg *SafeWaitGroup) Add(delta int) error {
    	wg.mu.RLock()
    	defer wg.mu.RUnlock()
    	if wg.wait && delta > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 11 03:04:14 UTC 2018
    - 1.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                            break;
                          case 5:
                            map.getAndAdd(key, delta);
                            threadSum += delta;
                            break;
                          case 6:
                            long oldValue = map.put(key, delta);
                            threadSum += delta - oldValue;
                            break;
                          case 7:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                            break;
                          case 5:
                            map.getAndAdd(key, delta);
                            threadSum += delta;
                            break;
                          case 6:
                            long oldValue = map.put(key, delta);
                            threadSum += delta - oldValue;
                            break;
                          case 7:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. src/internal/runtime/atomic/atomic_wasm.go

    //go:nosplit
    //go:noinline
    func Xadd(ptr *uint32, delta int32) uint32 {
    	new := *ptr + uint32(delta)
    	*ptr = new
    	return new
    }
    
    //go:nosplit
    //go:noinline
    func Xadd64(ptr *uint64, delta int64) uint64 {
    	new := *ptr + uint64(delta)
    	*ptr = new
    	return new
    }
    
    //go:nosplit
    //go:noinline
    func Xadduintptr(ptr *uintptr, delta uintptr) uintptr {
    	new := *ptr + delta
    	*ptr = new
    	return new
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. releasenotes/notes/delay-app-start.yaml

    Brian Avery <******@****.***> 1597180858 -0400
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 11 21:20:58 UTC 2020
    - 242 bytes
    - Viewed (0)
  8. src/sync/waitgroup.go

    // See the WaitGroup example.
    func (wg *WaitGroup) Add(delta int) {
    	if race.Enabled {
    		if delta < 0 {
    			// Synchronize decrements with Wait.
    			race.ReleaseMerge(unsafe.Pointer(wg))
    		}
    		race.Disable()
    		defer race.Enable()
    	}
    	state := wg.state.Add(uint64(delta) << 32)
    	v := int32(state >> 32)
    	w := uint32(state)
    	if race.Enabled && delta > 0 && v == int32(delta) {
    		// The first increment must be synchronized with Wait.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. pkg/apis/core/helper/qos/qos.go

    			if !isSupportedQoSComputeResource(name) {
    				continue
    			}
    			if quantity.Cmp(zeroQuantity) == 1 {
    				delta := quantity.DeepCopy()
    				if _, exists := requests[name]; !exists {
    					requests[name] = delta
    				} else {
    					delta.Add(requests[name])
    					requests[name] = delta
    				}
    			}
    		}
    		// process limits
    		qosLimitsFound := sets.NewString()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 04:01:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup.go

    	// then any Add with positive delta will return error.
    	wait bool
    	// number of request(s) currently using the wait group
    	count int
    }
    
    // Add adds delta, which may be negative, similar to sync.WaitGroup.
    // If Add with a positive delta happens after Wait, it will return error,
    // which prevent unsafe Add.
    func (wg *RateLimitedSafeWaitGroup) Add(delta int) error {
    	wg.mu.Lock()
    	defer wg.mu.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 21 14:08:00 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top