Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 85 for Loadint32 (0.24 sec)

  1. src/sync/atomic/doc.go

    // Consider using the more ergonomic and less error-prone [Uintptr.Or] instead.
    func OrUintptr(addr *uintptr, mask uintptr) (old uintptr)
    
    // LoadInt32 atomically loads *addr.
    // Consider using the more ergonomic and less error-prone [Int32.Load] instead.
    func LoadInt32(addr *int32) (val int32)
    
    // LoadInt64 atomically loads *addr.
    // Consider using the more ergonomic and less error-prone [Int64.Load] instead
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	totalS34xxErrors        HTTPAPIStats
    	totalS35xxErrors        HTTPAPIStats
    	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() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 06:25:13 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object_test.go

    				buffer.Reset()
    				if err := object.CacheEncode(encoder.identifier, encoder.encode, buffer); err != nil {
    					t.Errorf("unexpected error: %v", err)
    				}
    				if callsNumber := atomic.LoadInt32(&encoder.callsNumber); callsNumber != 1 {
    					t.Errorf("unexpected number of serializations: %d", callsNumber)
    				}
    			}
    			accessor, err := meta.Accessor(object.GetObject())
    			if err != nil {
    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/runtime/debuglog_test.go

    	skipDebugLog(t)
    	runtime.ResetDebugLog()
    	var wg sync.WaitGroup
    	done := int32(0)
    	wg.Add(1)
    	go func() {
    		// Encourage main goroutine to move around to
    		// different Ms and Ps.
    		for atomic.LoadInt32(&done) == 0 {
    			runtime.Gosched()
    		}
    		wg.Done()
    	}()
    	var want strings.Builder
    	for i := 0; i < 1000; i++ {
    		runtime.Dlog().I(i).End()
    		fmt.Fprintf(&want, "[] %d\n", i)
    		runtime.Gosched()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 18 16:59:26 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  5. src/internal/runtime/atomic/atomic_arm.s

    TEXT ·Casint64(SB),NOSPLIT,$-4-21
    	B	·Cas64(SB)
    
    TEXT ·Casuintptr(SB),NOSPLIT,$0-13
    	B	·Cas(SB)
    
    TEXT ·Casp1(SB),NOSPLIT,$0-13
    	B	·Cas(SB)
    
    TEXT ·CasRel(SB),NOSPLIT,$0-13
    	B	·Cas(SB)
    
    TEXT ·Loadint32(SB),NOSPLIT,$0-8
    	B	·Load(SB)
    
    TEXT ·Loadint64(SB),NOSPLIT,$-4-12
    	B	·Load64(SB)
    
    TEXT ·Loaduintptr(SB),NOSPLIT,$0-8
    	B	·Load(SB)
    
    TEXT ·Loaduint(SB),NOSPLIT,$0-8
    	B	·Load(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)
  6. src/internal/runtime/atomic/atomic_mipsx.s

    	JMP	·Store(SB)
    
    TEXT ·Storeint64(SB),NOSPLIT,$0-12
    	JMP	·Store64(SB)
    
    TEXT ·Storeuintptr(SB),NOSPLIT,$0-8
    	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)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 11 21:29:34 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. internal/logger/target/http/http.go

    }
    
    func (h *Target) String() string {
    	return h.config.Name
    }
    
    // IsOnline returns true if the target is reachable using a cached value
    func (h *Target) IsOnline(ctx context.Context) bool {
    	return atomic.LoadInt32(&h.status) == statusOnline
    }
    
    // Stats returns the target statistics.
    func (h *Target) Stats() types.TargetStats {
    	h.logChMu.RLock()
    	queueLength := len(h.logCh)
    	h.logChMu.RUnlock()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  8. src/sync/atomic/atomic_test.go

    		go func(me int) {
    			he := 1 - me
    			for i := int32(1); i < N; i++ {
    				StoreInt32(&X[me], i)
    				my := LoadInt32(&X[he])
    				StoreInt32(&ack[me][i%3], my)
    				for w := 1; LoadInt32(&ack[he][i%3]) == -1; w++ {
    					if w%1000 == 0 {
    						runtime.Gosched()
    					}
    				}
    				his := LoadInt32(&ack[he][i%3])
    				if (my != i && my != i-1) || (his != i && his != i-1) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:37:29 UTC 2024
    - 71.4K bytes
    - Viewed (0)
  9. src/internal/runtime/atomic/atomic_amd64.s

    // by the compiler (in src/cmd/compile/internal/gc/ssa.go).
    
    #include "textflag.h"
    
    TEXT ·Loaduintptr(SB), NOSPLIT, $0-16
    	JMP	·Load64(SB)
    
    TEXT ·Loaduint(SB), NOSPLIT, $0-16
    	JMP	·Load64(SB)
    
    TEXT ·Loadint32(SB), NOSPLIT, $0-12
    	JMP	·Load(SB)
    
    TEXT ·Loadint64(SB), NOSPLIT, $0-16
    	JMP	·Load64(SB)
    
    // bool Cas(int32 *val, int32 old, int32 new)
    // Atomically:
    //	if(*val == old){
    //		*val = new;
    //		return 1;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. src/time/sleep_test.go

    				if late > stats[j].max {
    					stats[j].max = late
    				}
    				atomic.AddInt32(&count, 1)
    				for atomic.LoadInt32(&count) < int32(timerCount) {
    					// spin until all timers fired
    				}
    				wg.Done()
    			})
    		}
    
    		for atomic.LoadInt32(&count) < int32(timerCount) {
    			// spin until all timers fired
    		}
    		wg.Wait()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
Back to top