- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Loadint64 (0.16 sec)
-
internal/grid/benchmark_test.go
spent := time.Since(t) if spent > 0 && n > 0 { // Since we are benchmarking n parallel servers we need to multiply by n. // This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
} return ProxyMetric{ PutTagTotal: atomic.LoadUint64(&v.PutTagTotal), GetTagTotal: atomic.LoadUint64(&v.GetTagTotal), RmvTagTotal: atomic.LoadUint64(&v.RmvTagTotal), HeadTotal: atomic.LoadUint64(&v.HeadTotal), GetTotal: atomic.LoadUint64(&v.GetTotal), PutTagFailedTotal: atomic.LoadUint64(&v.PutTagFailedTotal), GetTagFailedTotal: atomic.LoadUint64(&v.GetTagFailedTotal),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() stats := types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } return stats } // AssignMigrateTarget assigns a target // which will eventually replace the current target.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } } // Init initialize kafka target func (h *Target) Init(ctx context.Context) error { if !h.kconfig.Enabled {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
acc := e.cached.Load() if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t { // Check if lastT was changed by someone else. if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) { // Now we swap in a new. newAcc := &AccElem{} old := e.cached.Swap(newAcc) var a AccElem a.Size = atomic.LoadInt64(&old.Size) a.Total = atomic.LoadInt64(&old.Total) a.N = atomic.LoadInt64(&old.N) e.mu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
Queued: r.qCache.getSiteStats(), ActiveWorkers: r.ActiveWorkers(), Metrics: r.srStats.get(), Proxied: r.pCache.getSiteStats(), ReplicaSize: atomic.LoadInt64(&r.srStats.ReplicaSize), ReplicaCount: atomic.LoadInt64(&r.srStats.ReplicaCount), } return m } // Get replication metrics for a bucket from this node since this node came up.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
src/sync/atomic/doc.go
// 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 // (particularly if you target 32-bit platforms; see the bugs section). func LoadInt64(addr *int64) (val int64) // LoadUint32 atomically loads *addr.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 11.7K bytes - Viewed (0) -
src/runtime/testdata/testprog/gc.go
// and check again. time.Sleep(30 * time.Millisecond) var fail bool for i := range count { if atomic.LoadInt64(&count[i]) == 0 { fail = true } } if fail { time.Sleep(1 * time.Second) for i := range count { if atomic.LoadInt64(&count[i]) == 0 { fmt.Printf("goroutine %d did not run\n", i) return } } } fmt.Println("OK") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 12.1K bytes - Viewed (0) -
pkg/controller/controller_utils.go
// TODO: think about why this line being atomic doesn't matter return atomic.LoadInt64(&e.add) <= 0 && atomic.LoadInt64(&e.del) <= 0 } // GetExpectations returns the add and del expectations of the controllee. func (e *ControlleeExpectations) GetExpectations() (int64, int64) { return atomic.LoadInt64(&e.add), atomic.LoadInt64(&e.del) } // MarshalLog makes a thread-safe copy of the values of the expectations that
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
internal/s3select/message.go
// indicate finish with success quitFlag = true if !writer.flushRecords() { break } // Write Stats message, then End message bytesReturned := atomic.LoadInt64(&writer.bytesReturned) if !writer.write(newStatsMessage(writer.finBytesScanned, writer.finBytesProcessed, bytesReturned)) { break } writer.write(endMessage) } else { for payload.Len() > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0)