- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for Loadint64 (0.28 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) -
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) -
cmd/http-stats.go
serverStats.TotalS3RejectedAuth = atomic.LoadUint64(&st.rejectedRequestsAuth) serverStats.TotalS3RejectedTime = atomic.LoadUint64(&st.rejectedRequestsTime) serverStats.TotalS3RejectedHeader = atomic.LoadUint64(&st.rejectedRequestsHeader) serverStats.TotalS3RejectedInvalid = atomic.LoadUint64(&st.rejectedRequestsInvalid) serverStats.CurrentS3Requests = ServerHTTPAPIStats{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/last-minute_gen.go
return } switch msgp.UnsafeString(field) { case "Total": z.Total, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Total") return } case "Size": z.Size, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Size") return } case "N": z.N, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "N") return } default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jul 05 21:45:49 UTC 2022 - 17.2K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
return } case "ob": z.Objects, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Objects") return } case "dm": z.DeleteMarkers, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "DeleteMarkers") return } case "obf": z.ObjectsFailed, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "ObjectsFailed")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 18.6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
return } case "ss": z.StartSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "StartSize") return } case "ts": z.TotalSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "TotalSize") return } case "cs": z.CurrentSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "CurrentSize") return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jul 04 21:02:54 UTC 2022 - 26.7K bytes - Viewed (0)