- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 85 for Loadint32 (0.29 sec)
-
src/cmd/cgo/internal/testcarchive/testdata/libgo8/a.go
// Start a goroutine that loops forever. func init() { runtime.GOMAXPROCS(1) go func() { for { atomic.StoreInt32(&started, 1) } }() } //export GoFunction8 func GoFunction8() { for atomic.LoadInt32(&started) == 0 { runtime.Gosched() } os.Exit(0) } func main() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 529 bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers_test.go
queue.AddWork(context.TODO(), NewWorkArgs("3", "3"), now, now) queue.AddWork(context.TODO(), NewWorkArgs("4", "4"), now, now) queue.AddWork(context.TODO(), NewWorkArgs("5", "5"), now, now) wg.Wait() lastVal := atomic.LoadInt32(&testVal) if lastVal != 5 { t.Errorf("Expected testVal = 5, got %v", lastVal) } } func TestExecuteDelayed(t *testing.T) { testVal := int32(0) wg := sync.WaitGroup{} wg.Add(5)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 5.6K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400/gccgo.go
// without writing more assembly code, which we haven't bothered to // do. So this is not much of a test. var Baton int32 func RewindAndSetgid() { atomic.StoreInt32(&Baton, 1) for atomic.LoadInt32(&Baton) != 0 { runtime.Gosched() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 612 bytes - Viewed (0) -
internal/http/server.go
requestCount int32 // counter holds no. of request in progress. } // GetRequestCount - returns number of request in progress. func (srv *Server) GetRequestCount() int { return int(atomic.LoadInt32(&srv.requestCount)) } // Init - init HTTP server func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) { // Take a copy of server fields.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
src/internal/runtime/atomic/stubs.go
//go:noescape func Loaduintptr(ptr *uintptr) uintptr //go:noescape func Loaduint(ptr *uint) uint // 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
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.2K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/libgo4/libgo4.go
// //export GoRaiseSIGIO func GoRaiseSIGIO(p *C.pthread_t) { C.CRaiseSIGIO(p) } // Return the number of SIGIO signals seen. // //export SIGIOCount func SIGIOCount() C.int { return C.int(atomic.LoadInt32(&sigioCount)) } func main() {
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
t.Fatalf("expected request context to not have any deadline") } recorder := httptest.NewRecorder() handler.ServeHTTP(recorder, request) if atomic.LoadInt32(&invokedGot) != 1 { t.Errorf("expected collection deleter to be invoked") } if atomic.LoadInt32(&hasDeadlineGot) > 0 { t.Errorf("expected context to not have any deadline") } }
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/atomic_wasm.go
// See https://github.com/WebAssembly/design/issues/1073 // Export some functions via linkname to assembly in sync/atomic. // //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
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/issue9400_linux.go
defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(2)) // Start signaller atomic.StoreInt32(&issue9400.Baton, 0) go func() { // Wait for RewindAndSetgid for atomic.LoadInt32(&issue9400.Baton) == 0 { runtime.Gosched() } // Broadcast SIGSETXID runtime.LockOSThread() C.setgid(0) // Indicate that signalling is done atomic.StoreInt32(&issue9400.Baton, 0) }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 1.7K bytes - Viewed (0) -
pilot/pkg/config/memory/controller_test.go
} func TestControllerHashSynced(t *testing.T) { store := memory.Make(collections.Mocks) var v int32 ctl := memory.NewController(store) ctl.RegisterHasSyncedHandler(func() bool { return atomic.LoadInt32(&v) > 0 }) if ctl.HasSynced() { t.Error("has synced but should not") } atomic.StoreInt32(&v, 1) if !ctl.HasSynced() { t.Error("has not synced but should") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 18 15:37:45 UTC 2021 - 1.8K bytes - Viewed (0)