- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for addUint32 (0.16 sec)
-
src/internal/runtime/atomic/atomic_s390x.s
TEXT ·Loadint64(SB), NOSPLIT, $0-16 BR ·Load64(SB) // func Xadduintptr(ptr *uintptr, delta uintptr) uintptr TEXT ·Xadduintptr(SB), NOSPLIT, $0-24 BR ·Xadd64(SB) // func Xaddint32(ptr *int32, delta int32) int32 TEXT ·Xaddint32(SB), NOSPLIT, $0-20 BR ·Xadd(SB) // func Xaddint64(ptr *int64, delta int64) int64 TEXT ·Xaddint64(SB), NOSPLIT, $0-24 BR ·Xadd64(SB)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.1K bytes - Viewed (0) -
src/sync/mutex.go
// Starvation mode is so inefficient, that two goroutines // can go lock-step infinitely once they switch mutex // to starvation mode. delta -= mutexStarving } atomic.AddInt32(&m.state, delta) break } awoke = true iter = 0 } else { old = m.state } } if race.Enabled { race.Acquire(unsafe.Pointer(m)) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object_test.go
return &mockEncoder{ identifier: runtime.Identifier(id), expectedResult: result, expectedError: err, } } func (e *mockEncoder) encode(_ runtime.Object, w io.Writer) error { atomic.AddInt32(&e.callsNumber, 1) if e.expectedError != nil { return e.expectedError } _, err := w.Write([]byte(e.expectedResult)) return err } func TestCachingObject(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 15:26:38 UTC 2022 - 5.1K bytes - Viewed (0) -
src/sync/rwmutex.go
// - RUnlock -> Lock: writerSem // // The methods below temporarily disable handling of race synchronization // events in order to provide the more precise model above to the race // detector. // // For example, atomic.AddInt32 in RLock should not appear to provide // acquire-release semantics, which would incorrectly synchronize racing // readers, thus potentially missing races. // RLock locks rw for reading. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_mipsx.s
JMP ·Store(SB) TEXT ·Xadduintptr(SB),NOSPLIT,$0-12 JMP ·Xadd(SB) TEXT ·Loadint32(SB),NOSPLIT,$0-8 JMP ·Load(SB) TEXT ·Loadint64(SB),NOSPLIT,$0-12 JMP ·Load64(SB) TEXT ·Xaddint32(SB),NOSPLIT,$0-12 JMP ·Xadd(SB) TEXT ·Xaddint64(SB),NOSPLIT,$0-20 JMP ·Xadd64(SB) TEXT ·Casp1(SB),NOSPLIT,$0-13 JMP ·Cas(SB) TEXT ·Xchgint32(SB),NOSPLIT,$0-12 JMP ·Xchg(SB)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 21:29:34 UTC 2024 - 4.9K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_arm.s
B ·Store(SB) TEXT ·StorepNoWB(SB),NOSPLIT,$0-8 B ·Store(SB) TEXT ·StoreRel(SB),NOSPLIT,$0-8 B ·Store(SB) TEXT ·StoreReluintptr(SB),NOSPLIT,$0-8 B ·Store(SB) TEXT ·Xaddint32(SB),NOSPLIT,$0-12 B ·Xadd(SB) TEXT ·Xaddint64(SB),NOSPLIT,$-4-20 B ·Xadd64(SB) TEXT ·Xadduintptr(SB),NOSPLIT,$0-12 B ·Xadd(SB) TEXT ·Xchgint32(SB),NOSPLIT,$0-12 B ·Xchg(SB)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.7K bytes - Viewed (0) -
cmd/erasure-decode.go
case errors.Is(err, errFileNotFound): atomic.StoreInt32(&missingPartsHeal, 1) case errors.Is(err, errFileCorrupt): atomic.StoreInt32(&bitrotHeal, 1) case errors.Is(err, errDiskNotFound): atomic.AddInt32(&disksNotFound, 1) } // This will be communicated upstream. p.orgReaders[bufIdx] = nil if br, ok := p.readers[i].(io.Closer); ok { br.Close() } p.readers[i] = nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_amd64.s
// return *val; TEXT ·Xadd64(SB), NOSPLIT, $0-24 MOVQ ptr+0(FP), BX MOVQ delta+8(FP), AX MOVQ AX, CX LOCK XADDQ AX, 0(BX) ADDQ CX, AX MOVQ AX, ret+16(FP) RET TEXT ·Xaddint32(SB), NOSPLIT, $0-20 JMP ·Xadd(SB) TEXT ·Xaddint64(SB), NOSPLIT, $0-24 JMP ·Xadd64(SB) TEXT ·Xadduintptr(SB), NOSPLIT, $0-24 JMP ·Xadd64(SB) // uint32 Xchg(ptr *uint32, new uint32)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_plugins.go
return "FakeFilter" } // Filter invoked at the filter extension point. func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { atomic.AddInt32(&pl.NumFilterCalled, 1) if returnCode, ok := pl.FailedNodeReturnCodeMap[nodeInfo.Node().Name]; ok { return framework.NewStatus(returnCode, fmt.Sprintf("injecting failure for pod %v", pod.Name)) } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_mips64x.s
JMP ·Store64(SB) TEXT ·Xadduintptr(SB), NOSPLIT, $0-24 JMP ·Xadd64(SB) TEXT ·Loadint32(SB), NOSPLIT, $0-12 JMP ·Load(SB) TEXT ·Loadint64(SB), NOSPLIT, $0-16 JMP ·Load64(SB) TEXT ·Xaddint32(SB), NOSPLIT, $0-20 JMP ·Xadd(SB) TEXT ·Xaddint64(SB), NOSPLIT, $0-24 JMP ·Xadd64(SB) // bool casp(void **val, void *old, void *new) // Atomically: // if(*val == old){ // *val = new;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 21:29:34 UTC 2024 - 7.2K bytes - Viewed (0)