Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 105 for addUint32 (0.17 sec)

  1. src/cmd/internal/bio/buf_mmap.go

    	// mapping, especially since we have no way to unmap it.
    	const threshold = 16 << 10
    	if length < threshold {
    		return nil, false
    	}
    
    	// Have we reached the mmap limit?
    	if atomic.AddInt32(&mmapLimit, -1) < 0 {
    		atomic.AddInt32(&mmapLimit, 1)
    		return nil, false
    	}
    
    	// Page-align the offset.
    	off := r.Offset()
    	align := syscall.Getpagesize()
    	aoff := off &^ int64(align-1)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 11:20:31 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. src/cmd/link/internal/ld/data.go

    			target.Arch.ByteOrder.PutUint64(P[off:], uint64(o))
    		}
    	}
    	if target.IsExternal() {
    		// We'll stream out the external relocations in asmb2 (e.g. elfrelocsect)
    		// and we only need the count here.
    		atomic.AddUint32(&ldr.SymSect(s).Relcount, uint32(nExtReloc))
    	}
    }
    
    // Convert a Go relocation to an external relocation.
    func extreloc(ctxt *Link, ldr *loader.Loader, s loader.Sym, r loader.Reloc) (loader.ExtReloc, bool) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 12 15:10:50 UTC 2024
    - 100.5K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex_test.go

    	for i := 0; i < numIterations; i++ {
    		if rwm.GetRLock(context.Background(), nil, id, source, Options{Timeout: time.Second}) {
    			n := atomic.AddInt32(activity, 1)
    			if n < 1 || n >= 10000 {
    				panic(fmt.Sprintf("wlock(%d)\n", n))
    			}
    			for i := 0; i < 100; i++ {
    			}
    			atomic.AddInt32(activity, -1)
    			rwm.RUnlock(context.Background())
    		}
    	}
    	cdone <- true
    }
    
    // Borrowed from rwmutex_test.go
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/testcarchive/testdata/libgo4/libgo4.go

    )
    
    var sigioCount int32
    
    // Catch SIGIO.
    //
    //export GoCatchSIGIO
    func GoCatchSIGIO() {
    	c := make(chan os.Signal, 1)
    	signal.Notify(c, syscall.SIGIO)
    	go func() {
    		for range c {
    			atomic.AddInt32(&sigioCount, 1)
    		}
    	}()
    }
    
    // Raise SIGIO.
    //
    //export GoRaiseSIGIO
    func GoRaiseSIGIO(p *C.pthread_t) {
    	C.CRaiseSIGIO(p)
    }
    
    // Return the number of SIGIO signals seen.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 854 bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete_test.go

    		// we expect CollectionDeleter to be executed once
    		atomic.AddInt32(&invokedGot, 1)
    
    		// we don't expect any context deadline to be set
    		if _, hasDeadline := ctx.Deadline(); hasDeadline {
    			atomic.AddInt32(&hasDeadlineGot, 1)
    		}
    		return nil, nil
    	}
    
    	// do the minimum setup to ensure that it gets as far as CollectionDeleter
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  6. src/internal/runtime/atomic/stubs.go

    // TODO(matloob): Should these functions have the go:noescape annotation?
    
    //go:noescape
    func Loadint32(ptr *int32) int32
    
    //go:noescape
    func Loadint64(ptr *int64) int64
    
    //go:noescape
    func Xaddint32(ptr *int32, delta int32) int32
    
    //go:noescape
    func Xaddint64(ptr *int64, delta int64) int64
    
    //go:noescape
    func Xchgint32(ptr *int32, new int32) int32
    
    //go:noescape
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go

    			watermark.recordMutating(int(atomic.AddInt32(&atomicMutatingExecuting, delta)))
    		} else {
    			watermark.recordReadOnly(int(atomic.AddInt32(&atomicReadOnlyExecuting, delta)))
    		}
    	}
    	noteWaitingDelta := func(delta int32) {
    		if isMutatingRequest {
    			waitingMark.recordMutating(int(atomic.AddInt32(&atomicMutatingWaiting, delta)))
    		} else {
    			waitingMark.recordReadOnly(int(atomic.AddInt32(&atomicReadOnlyWaiting, delta)))
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  8. api/go1.23.txt

    pkg structs, type HostLayout struct #66408
    pkg sync, method (*Map) Clear() #61696
    pkg sync/atomic, func AndInt32(*int32, int32) int32 #61395
    pkg sync/atomic, func AndInt64(*int64, int64) int64 #61395
    pkg sync/atomic, func AndUint32(*uint32, uint32) uint32 #61395
    pkg sync/atomic, func AndUint64(*uint64, uint64) uint64 #61395
    pkg sync/atomic, func AndUintptr(*uintptr, uintptr) uintptr #61395
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 05 20:48:49 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. src/internal/runtime/atomic/atomic_wasm.go

    //
    //go:linkname Load
    //go:linkname Loadp
    //go:linkname Load64
    //go:linkname Loadint32
    //go:linkname Loadint64
    //go:linkname Loaduintptr
    //go:linkname LoadAcquintptr
    //go:linkname Xadd
    //go:linkname Xaddint32
    //go:linkname Xaddint64
    //go:linkname Xadd64
    //go:linkname Xadduintptr
    //go:linkname Xchg
    //go:linkname Xchg64
    //go:linkname Xchgint32
    //go:linkname Xchgint64
    //go:linkname Xchguintptr
    //go:linkname Cas
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. src/cmd/cgo/internal/test/testx.go

    	for atomic.LoadInt32(&issue1560) != 1 {
    		runtime.Gosched()
    	}
    	atomic.AddInt32(&issue1560, 1)
    	for atomic.LoadInt32(&issue1560) != 3 {
    		runtime.Gosched()
    	}
    	issue1560Ch <- true
    }
    
    func Issue1560FromGo() {
    	atomic.AddInt32(&issue1560, 1)
    	for atomic.LoadInt32(&issue1560) != 2 {
    		runtime.Gosched()
    	}
    	atomic.AddInt32(&issue1560, 1)
    	issue1560Ch <- true
    }
    
    func test1560(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 17 21:53:11 UTC 2023
    - 10.6K bytes
    - Viewed (0)
Back to top