- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 105 for addUint32 (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)