- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 92 for Loadint32 (0.15 sec)
-
src/runtime/testdata/testprogcgo/threadprof.go
// before we make any cgo call will not abort the whole process, so // we cannot make any cgo call here. See https://golang.org/issue/9456. atomic.StoreInt32((*int32)(unsafe.Pointer(&C.spinlock)), 1) for atomic.LoadInt32((*int32)(unsafe.Pointer(&C.spinlock))) == 1 { runtime.Gosched() } println("OK") } func CgoExternalThreadSignal() { if len(os.Args) > 2 && os.Args[2] == "crash" { i := C.start_crashing_thread()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 22:43:54 UTC 2023 - 2.4K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
t.Helper() err := retry.UntilSuccess(func() error { select { case err := <-errCh: t.Error(err) return err default: partial := atomic.LoadInt32(&partialPushes) full := atomic.LoadInt32(&fullPushes) if partial != expectedPartial || full != expectedFull { return fmt.Errorf("got %v full and %v partial, expected %v full and %v partial", full, partial, expectedFull, expectedPartial)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
internal/rest/client.go
// Call - make a REST call with context. func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed: // client closed, this is usually a manual process // so return a local error as client is closed return nil, &NetworkError{Err: ErrClientClosed} case offline:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade.go
// read. type connWrapper struct { net.Conn closed int32 bufReader *bufio.Reader } func (w *connWrapper) Read(b []byte) (n int, err error) { if atomic.LoadInt32(&w.closed) == 1 { return 0, io.EOF } return w.bufReader.Read(b) } func (w *connWrapper) Close() error { err := w.Conn.Close() atomic.StoreInt32(&w.closed, 1) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:02:09 UTC 2022 - 4K bytes - Viewed (0) -
src/sync/waitgroup_test.go
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") } } } func TestWaitGroupAlign(t *testing.T) { type X struct { x byte wg WaitGroup } var x X x.wg.Add(1) go func(x *X) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 14 17:38:39 UTC 2021 - 3K bytes - Viewed (0) -
src/sync/atomic/doc.go
// Consider using the more ergonomic and less error-prone [Uintptr.Or] instead. func OrUintptr(addr *uintptr, mask uintptr) (old uintptr) // LoadInt32 atomically loads *addr. // Consider using the more ergonomic and less error-prone [Int32.Load] instead. func LoadInt32(addr *int32) (val int32) // LoadInt64 atomically loads *addr. // Consider using the more ergonomic and less error-prone [Int64.Load] instead
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/http-stats.go
totalS34xxErrors HTTPAPIStats totalS35xxErrors HTTPAPIStats totalS3Canceled HTTPAPIStats } func (st *HTTPStats) loadRequestsInQueue() int32 { return atomic.LoadInt32(&st.s3RequestsInQueue) } func (st *HTTPStats) addRequestsInQueue(i int32) { atomic.AddInt32(&st.s3RequestsInQueue, i) } func (st *HTTPStats) incS3RequestsIncoming() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object_test.go
buffer.Reset() if err := object.CacheEncode(encoder.identifier, encoder.encode, buffer); err != nil { t.Errorf("unexpected error: %v", err) } if callsNumber := atomic.LoadInt32(&encoder.callsNumber); callsNumber != 1 { t.Errorf("unexpected number of serializations: %d", callsNumber) } } accessor, err := meta.Accessor(object.GetObject()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 15:26:38 UTC 2022 - 5.1K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_arm.s
TEXT ·Casint64(SB),NOSPLIT,$-4-21 B ·Cas64(SB) TEXT ·Casuintptr(SB),NOSPLIT,$0-13 B ·Cas(SB) TEXT ·Casp1(SB),NOSPLIT,$0-13 B ·Cas(SB) TEXT ·CasRel(SB),NOSPLIT,$0-13 B ·Cas(SB) TEXT ·Loadint32(SB),NOSPLIT,$0-8 B ·Load(SB) TEXT ·Loadint64(SB),NOSPLIT,$-4-12 B ·Load64(SB) TEXT ·Loaduintptr(SB),NOSPLIT,$0-8 B ·Load(SB) TEXT ·Loaduint(SB),NOSPLIT,$0-8 B ·Load(SB)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.7K bytes - Viewed (0) -
src/runtime/debuglog_test.go
skipDebugLog(t) runtime.ResetDebugLog() var wg sync.WaitGroup done := int32(0) wg.Add(1) go func() { // Encourage main goroutine to move around to // different Ms and Ps. for atomic.LoadInt32(&done) == 0 { runtime.Gosched() } wg.Done() }() var want strings.Builder for i := 0; i < 1000; i++ { runtime.Dlog().I(i).End() fmt.Fprintf(&want, "[] %d\n", i) runtime.Gosched() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 18 16:59:26 UTC 2022 - 4.9K bytes - Viewed (0)