- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 66 for Loadint64 (0.21 sec)
-
src/runtime/race.go
//go:linkname abigen_sync_atomic_LoadInt64 sync/atomic.LoadInt64 func abigen_sync_atomic_LoadInt64(addr *int64) (val int64) //go:linkname abigen_sync_atomic_LoadUint32 sync/atomic.LoadUint32 func abigen_sync_atomic_LoadUint32(addr *uint32) (val uint32) //go:linkname abigen_sync_atomic_LoadUint64 sync/atomic.LoadUint64 func abigen_sync_atomic_LoadUint64(addr *uint64) (val uint64)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 20.4K bytes - Viewed (0) -
internal/rest/client.go
func (c *Client) IsOnline() bool { return atomic.LoadInt32(&c.connected) == online } // LastConn returns when the disk was (re-)connected func (c *Client) LastConn() time.Time { return time.Unix(0, atomic.LoadInt64(&c.lastConn)) } // LastError returns previous error func (c *Client) LastError() error { c.RLock() defer c.RUnlock() return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
internal/grid/muxclient.go
// Already closed. This is not an error state; // we may just be delivering the last responses. return true } // Only check ping when not closed. if got := time.Since(time.Unix(0, atomic.LoadInt64(&m.LastPong))); got > m.clientPingInterval*2 { m.respMu.Unlock() if debugPrint { fmt.Printf("Mux %d: last pong %v ago, disconnecting\n", m.MuxID, got) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/internal/runtime/atomic/types.go
type Int64 struct { noCopy noCopy _ align64 value int64 } // Load accesses and returns the value atomically. // //go:nosplit func (i *Int64) Load() int64 { return Loadint64(&i.value) } // Store updates the value atomically. // //go:nosplit func (i *Int64) Store(value int64) { Storeint64(&i.value, value) } // CompareAndSwap atomically compares i's value with old,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 14.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
s.AggregatedLegacyDiscoveryGroupManager = discoveryendpoint.NewResourceManager("api") } for { if c.JSONPatchMaxCopyBytes <= 0 { break } existing := atomic.LoadInt64(&jsonpatch.AccumulatedCopySizeLimit) if existing > 0 && existing < c.JSONPatchMaxCopyBytes { break } if atomic.CompareAndSwapInt64(&jsonpatch.AccumulatedCopySizeLimit, existing, c.JSONPatchMaxCopyBytes) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
// should have attempted multiple times if actualAttempts := atomic.LoadInt64(&attempts); actualAttempts < nodeStatusUpdateRetry { t.Errorf("Expected at least %d attempts, got %d", nodeStatusUpdateRetry, actualAttempts) } // should have gotten multiple failure callbacks if actualFailureCallbacks := atomic.LoadInt64(&failureCallbacks); actualFailureCallbacks < (nodeStatusUpdateRetry - 1) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
internal/grid/connection.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
cmd/admin-handlers.go
objectAPI, _ := validateAdminReq(ctx, w, r, policy.BandwidthMonitorAction) if objectAPI == nil { return } enc := json.NewEncoder(w) if err := enc.Encode(madmin.ClientPerfExtraTime{TimeSpent: atomic.LoadInt64(&globalLastClientPerfExtraTime)}); err != nil { return } } // ClientDevNull - everything goes to io.Discard // [POST] /minio/admin/v3/speedtest/client/devnull
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
t.Errorf("Unexpected number of pods deleted: %d, expected: %d", len(deletedPods.Items), numPods) } expectedCalls := (int64(numPods) + deleteCollectionPageSize - 1) / deleteCollectionPageSize if listCalls := atomic.LoadInt64(&storeWithCounter.listCounter); listCalls != expectedCalls { t.Errorf("Unexpected number of list calls: %d, expected: %d", listCalls, expectedCalls) } for i := 0; i < numPods; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0)