- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 121 for addUint32 (0.22 sec)
-
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) -
test/deferfin.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 05 21:11:31 UTC 2021 - 1.1K bytes - Viewed (0) -
src/sync/waitgroup_test.go
for i := 0; i < 1000; i++ { wg := &WaitGroup{} n := new(int32) // spawn goroutine 1 wg.Add(1) go func() { atomic.AddInt32(n, 1) wg.Done() }() // spawn goroutine 2 wg.Add(1) go func() { atomic.AddInt32(n, 1) wg.Done() }() // Wait for goroutine 1 and 2 wg.Wait() if atomic.LoadInt32(n) != 2 { t.Fatal("Spurious wakeup from Wait") } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 14 17:38:39 UTC 2021 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/eventclock/real_event_clock_test.go
var numDone int32 now := ec.Now() const batchSize = 100 times := make(chan time.Time, batchSize+1) try := func(abs bool, d time.Duration) { f := func(u time.Time) { realD := ec.Since(now) atomic.AddInt32(&numDone, 1) times <- u if realD < d { t.Errorf("Asked for %v, got %v", d, realD) } } if abs { ec.EventAfterTime(f, now.Add(d)) } else { ec.EventAfterDuration(f, d) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 07 04:07:31 UTC 2021 - 1.6K 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)