Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 121 for addUint32 (0.22 sec)

  1. 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)
  2. test/deferfin.go

    			f := func() {
    				if *v != "" {
    					panic("oops")
    				}
    			}
    			if *v != "" {
    				// let the compiler think f escapes
    				sink = f
    			}
    			runtime.SetFinalizer(v, func(p *string) {
    				atomic.AddInt32(&count, -1)
    			})
    			defer f()
    		}()
    	}
    	wg.Wait()
    	for i := 0; i < 3; i++ {
    		time.Sleep(10 * time.Millisecond)
    		runtime.GC()
    	}
    	if count != 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 05 21:11:31 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top