Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 35 for Loadint64 (0.23 sec)

  1. pkg/cache/ttlCache_test.go

    }
    
    func TestTTLEvictionCallback(t *testing.T) {
    	c := &callbackRecorder{callbacks: 0}
    	ttl := NewTTLWithCallback(50*time.Millisecond, time.Millisecond, c.callback)
    	testCacheEvicter(ttl)
    	if atomic.LoadInt64(&c.callbacks) != 1 {
    		t.Errorf("evictExpired() => failed to invoke EvictionCallback: got %d callbacks, wanted 1", c.callbacks)
    	}
    }
    
    func TestTTLFinalizer(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  2. src/internal/runtime/atomic/atomic_test.go

    	up64 := (*uint64)(u) // misaligned
    	p64 := (*int64)(u)   // misaligned
    
    	shouldPanic(t, "Load64", func() { atomic.Load64(up64) })
    	shouldPanic(t, "Loadint64", func() { atomic.Loadint64(p64) })
    	shouldPanic(t, "Store64", func() { atomic.Store64(up64, 0) })
    	shouldPanic(t, "Xadd64", func() { atomic.Xadd64(up64, 1) })
    	shouldPanic(t, "Xchg64", func() { atomic.Xchg64(up64, 1) })
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/util.go

    // for some quantity.
    type HighWaterMark int64
    
    // Update returns true if and only if 'current' is the highest value ever seen.
    func (hwm *HighWaterMark) Update(current int64) bool {
    	for {
    		old := atomic.LoadInt64((*int64)(hwm))
    		if current <= old {
    			return false
    		}
    		if atomic.CompareAndSwapInt64((*int64)(hwm), old, current) {
    			return true
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:05:06 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. src/internal/runtime/atomic/atomic_arm.s

    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)
    
    TEXT ·Storeint32(SB),NOSPLIT,$0-8
    	B	·Store(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)
  5. pkg/cache/ttlCache.go

    		return true
    	})
    }
    
    func (c *ttlCache) Stats() Stats {
    	return Stats{
    		Evictions: atomic.LoadUint64(&c.stats.Evictions),
    		Hits:      atomic.LoadUint64(&c.stats.Hits),
    		Misses:    atomic.LoadUint64(&c.stats.Misses),
    		Writes:    atomic.LoadUint64(&c.stats.Writes),
    		Removals:  atomic.LoadUint64(&c.stats.Removals),
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  6. src/internal/runtime/atomic/atomic_amd64.s

    #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;
    //	} else
    //		return 0;
    TEXT ·Cas(SB),NOSPLIT,$0-17
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. src/internal/runtime/atomic/atomic_loong64.s

    	JMP	·Load64(SB)
    
    TEXT ·Loaduint(SB), NOSPLIT|NOFRAME, $0-16
    	JMP	·Load64(SB)
    
    TEXT ·Storeuintptr(SB), NOSPLIT, $0-16
    	JMP	·Store64(SB)
    
    TEXT ·Xadduintptr(SB), NOSPLIT, $0-24
    	JMP	·Xadd64(SB)
    
    TEXT ·Loadint64(SB), NOSPLIT, $0-16
    	JMP	·Load64(SB)
    
    TEXT ·Xaddint64(SB), NOSPLIT, $0-24
    	JMP	·Xadd64(SB)
    
    // bool casp(void **val, void *old, void *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
    - 6.3K bytes
    - Viewed (0)
  8. src/internal/runtime/atomic/atomic_mipsx.s

    	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)
    
    TEXT ·Casp1(SB),NOSPLIT,$0-13
    	JMP	·Cas(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)
  9. src/internal/runtime/atomic/atomic_386.s

    	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)
    
    // bool ·Cas64(uint64 *val, uint64 old, uint64 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. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go

    		case <-timeout:
    			srvErr <- fmt.Errorf("server: timeout waiting for connection to close")
    			return
    		case <-srvSPDYConn.CloseChan():
    		}
    
    		// Count pings sent by the server.
    		gotPings := atomic.LoadInt64(&pingsSent)
    		if gotPings < 1 {
    			t.Errorf("server: failed to send any pings (check logs)")
    		}
    	}()
    
    	// Set up client connection.
    	clConn, err := net.Dial("tcp4", listener.Addr().String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 11:58:57 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top