Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 987 for deltas (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/sync/atomic/type.go

    func (x *Int32) CompareAndSwap(old, new int32) (swapped bool) {
    	return CompareAndSwapInt32(&x.v, old, new)
    }
    
    // Add atomically adds delta to x and returns the new value.
    func (x *Int32) Add(delta int32) (new int32) { return AddInt32(&x.v, delta) }
    
    // And atomically performs a bitwise AND operation on x using the bitmask
    // provided as mask and returns the old value.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:37:29 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tf2xla/internal/legalize_tf_to_hlo_test.cc

      ASSERT_THAT(result, IsOkOrFiltered());
      EXPECT_EQ(mlir_bridge_legalize_count.Delta("tf.Acos"), 0);
      EXPECT_THAT(result,
                  IncrementedOrFiltered(counts.Delta(kMlirCombinedMlirSuccess), 1));
      EXPECT_THAT(result,
                  IncrementedOrFiltered(counts.Delta(kMlirCombinedOldSuccess), 1));
    }
    
    TEST(LegalizeWithCombinedBridge,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sun Apr 14 20:29:34 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top