- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 84 for Loadint64 (0.38 sec)
-
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) -
cmd/metrics-v3-cluster-iam.go
lastSyncTime := atomic.LoadUint64(&globalIAMSys.LastRefreshTimeUnixNano) if lastSyncTime != 0 { m.Set(sinceLastSyncMillis, float64((uint64(time.Now().UnixNano())-lastSyncTime)/uint64(time.Millisecond))) } m.Set(syncFailures, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshFailures))) m.Set(syncSuccesses, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshSuccesses))) return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K 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/data-scanner-metric.go
}) return i } // lifetime returns the lifetime count of the specified metric. func (p *scannerMetrics) lifetime(m scannerMetric) uint64 { if m >= scannerMetricLast { return 0 } val := atomic.LoadUint64(&p.operations[m]) return val } // lastMinute returns the last minute statistics of a metric. // m should be < scannerMetricLastRealtime func (p *scannerMetrics) lastMinute(m scannerMetric) AccElem {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K 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) -
src/internal/poll/fd_mutex.go
// // Close operations must do increfAndClose/decref. // incref adds a reference to mu. // It reports whether mu is available for reading or writing. func (mu *fdMutex) incref() bool { for { old := atomic.LoadUint64(&mu.state) if old&mutexClosed != 0 { return false } new := old + mutexRef if new&mutexRefMask == 0 { panic(overflowMsg) } if atomic.CompareAndSwapUint64(&mu.state, old, new) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
test/fixedbugs/issue19182.go
go func() { for { atomic.AddUint64(&a, uint64(1)) } }() time.Sleep(10 * time.Millisecond) // Short sleep is enough in passing case i, val := 0, atomic.LoadUint64(&a) for ; val == 0 && i < 100; val, i = atomic.LoadUint64(&a), i+1 { time.Sleep(100 * time.Millisecond) } if val == 0 { fmt.Printf("Failed to observe atomic increment after %d tries\n", i) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 737 bytes - Viewed (0) -
pilot/pkg/model/test/mockopenidserver.go
atomic.AddUint64(&ms.PubKeyHitNum, 1) if ms.ReturnSuccessAfterFirstNumHits > 0 && atomic.LoadUint64(&ms.PubKeyHitNum) >= ms.ReturnSuccessAfterFirstNumHits { fmt.Fprintf(w, "%v", JwtPubKey1) return } if ms.ReturnErrorAfterFirstNumHits != 0 && atomic.LoadUint64(&ms.PubKeyHitNum) > ms.ReturnErrorAfterFirstNumHits { w.WriteHeader(http.StatusForbidden)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 9.4K 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) -
internal/pubsub/pubsub.go
} ps.Lock() defer ps.Unlock() sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter} ps.subs = append(ps.subs, sub) // We hold a lock, so we are safe to update combined := Mask(atomic.LoadUint64(&ps.types)) combined.Merge(Mask(mask.Mask())) atomic.StoreUint64(&ps.types, uint64(combined)) go func() { <-doneCh ps.Lock() defer ps.Unlock() var remainTypes Mask
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0)