- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 987 for deltas (0.11 sec)
-
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) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)