- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for LoadInt64 (0.19 sec)
-
internal/rest/rpc-stats.go
if err == nil { atomic.StoreInt64(&dialEnd, time.Now().UnixNano()) } }, } return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() { if ds := atomic.LoadInt64(&dialStart); ds > 0 { if de := atomic.LoadInt64(&dialEnd); de == 0 { atomic.AddUint64(&globalStats.tcpDialErrs, 1) } else if de >= ds { atomic.AddUint64(&globalStats.tcpDialCount, 1)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
} return &dynamicTimeout{timeout: int64(timeout), minimum: int64(minimum)} } // Timeout returns the current timeout value func (dt *dynamicTimeout) Timeout() time.Duration { return time.Duration(atomic.LoadInt64(&dt.timeout)) } func (dt *dynamicTimeout) RetryInterval() time.Duration { return dt.retryInterval } // LogSuccess logs the duration of a successful action that // did not hit the timeout
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
func (l *lockServer) Refresh(args *LockArgs) (reply bool, err error) { if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) } l.mutex.Lock() defer l.mutex.Unlock() reply = !l.lockNotFound return reply, nil } func (l *lockServer) ForceUnlock(args *LockArgs) (reply bool, err error) { if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/consolelogger.go
} // Stats returns the target statistics. func (sys *HTTPConsoleLoggerSys) Stats() types.TargetStats { return types.TargetStats{ TotalMessages: atomic.LoadInt64(&sys.totalMessages), FailedMessages: atomic.LoadInt64(&sys.failedMessages), QueueLength: 0, } } // Content returns the console stdout log func (sys *HTTPConsoleLoggerSys) Content() (logs []log.Entry) { sys.RLock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
// failed functions. func (target *WebhookTarget) Stat() event.TargetStat { return event.TargetStat{ ID: target.id, ActiveRequests: atomic.LoadInt64(&target.activeRequests), TotalRequests: atomic.LoadInt64(&target.totalRequests), FailedRequests: atomic.LoadInt64(&target.failedRequests), } } // Send - sends an event to the webhook.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} rt.ErrCounts["AccessDenied"]++ } } func (rt *RTimedMetrics) merge(o RTimedMetrics) (n RTimedMetrics) { n.SinceUptime.Bytes = atomic.LoadInt64(&rt.SinceUptime.Bytes) + atomic.LoadInt64(&o.SinceUptime.Bytes) n.SinceUptime.Count = atomic.LoadInt64(&rt.SinceUptime.Count) + atomic.LoadInt64(&o.SinceUptime.Count) n.LastMinute = n.LastMinute.merge(rt.LastMinute) n.LastMinute = n.LastMinute.merge(o.LastMinute)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
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") } }) } })
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K 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.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K 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.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K 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()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 32.7K bytes - Viewed (0)