- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 920 for deltas (0.11 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) -
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) -
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) -
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/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)