Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 121 for addUint32 (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    		}
    
    		topoScore := make(scoreMap)
    		for _, existingPod := range podsToProcess {
    			pl.processExistingPod(state, existingPod, nodeInfo, pod, topoScore)
    		}
    		if len(topoScore) > 0 {
    			topoScores[atomic.AddInt32(&index, 1)] = topoScore
    		}
    	}
    	pl.parallelizer.Until(pCtx, len(allNodes), processNode, pl.Name())
    
    	if index == -1 {
    		return framework.NewStatus(framework.Skip)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/ssagen/ssa.go

    	alias("sync/atomic", "CompareAndSwapUintptr", "internal/runtime/atomic", "Cas64", p8...)
    
    	alias("sync/atomic", "AddInt32", "internal/runtime/atomic", "Xadd", all...)
    	alias("sync/atomic", "AddInt64", "internal/runtime/atomic", "Xadd64", all...)
    	alias("sync/atomic", "AddUint32", "internal/runtime/atomic", "Xadd", all...)
    	alias("sync/atomic", "AddUint64", "internal/runtime/atomic", "Xadd64", all...)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
  7. 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)
  8. cmd/http-stats.go

    	totalS3Canceled         HTTPAPIStats
    }
    
    func (st *HTTPStats) loadRequestsInQueue() int32 {
    	return atomic.LoadInt32(&st.s3RequestsInQueue)
    }
    
    func (st *HTTPStats) addRequestsInQueue(i int32) {
    	atomic.AddInt32(&st.s3RequestsInQueue, i)
    }
    
    func (st *HTTPStats) incS3RequestsIncoming() {
    	// Golang automatically resets to zero if this overflows
    	atomic.AddUint64(&st.s3RequestsIncoming, 1)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 06:25:13 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. src/internal/runtime/atomic/atomic_386.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)
    
    // bool ·Cas64(uint64 *val, uint64 old, uint64 new)
    // Atomically:
    //	if(*val == old){
    //		*val = new;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. pkg/wasm/cache_test.go

    	tsNumRequest := int32(0)
    
    	httpData := append(wasmHeader, []byte("data")...)
    	invalidHTTPData := []byte("invalid binary")
    	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		atomic.AddInt32(&tsNumRequest, 1)
    
    		if r.URL.Path == "/different-url" {
    			w.Write(append(httpData, []byte("different data")...))
    		} else if r.URL.Path == "/invalid-wasm-header" {
    			w.Write(invalidHTTPData)
    		} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 33.9K bytes
    - Viewed (0)
Back to top