- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 308 for deltas (0.1 sec)
-
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) -
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) -
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) -
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) -
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/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) -
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) -
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)