Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 920 for deltas (0.11 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. 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)
  4. 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)
  5. 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)
  6. src/encoding/gob/debug.go

    	deb.consumed(nb)
    	return string(b)
    }
    
    // delta returns the field delta at the input point. The expect argument,
    // if non-negative, identifies what the value should be.
    func (deb *debugger) delta(expect int) int {
    	delta := int(deb.uint64())
    	if delta < 0 || (expect >= 0 && delta != expect) {
    		errorf("decode: corrupted type: delta %d expected %d", delta, expect)
    	}
    	return delta
    }
    
    // TypeDefinition:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jan 20 09:34:41 UTC 2023
    - 18.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. src/runtime/netpoll.go

    //     Disable notifications for fd. Return an errno value.
    //
    // func netpoll(delta int64) (gList, int32)
    //     Poll the network. If delta < 0, block indefinitely. If delta == 0,
    //     poll without blocking. If delta > 0, block for up to delta nanoseconds.
    //     Return a list of goroutines built by calling netpollready,
    //     and a delta to add to netpollWaiters when all goroutines are ready.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.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