Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 54 for addUint32 (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top