- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for total_us (0.11 sec)
-
tensorflow/compiler/aot/benchmark.cc
// Collect stats and decide whether to stop. stats->per_iter_us.push_back(end_us - iter_start_us); const int64_t total_us = end_us - start_us; ++iters; if ((max_us > 0 && total_us >= max_us) || (options.max_iters > 0 && iters >= options.max_iters)) { stats->total_us = total_us; break; } } } } // namespace benchmark } // namespace tfcompile
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 12 19:45:29 UTC 2023 - 4.5K bytes - Viewed (0) -
tests/integration/telemetry/api/istioctl_metrics_test.go
return errors.New("unexpected output (incorrect workload)") } totalRPS, fErr := strconv.ParseFloat(fields[1], 32) if fErr != nil { t.Logf("Expected column 2 to show totalRPS, got %#v", fields) return fErr } if totalRPS <= 0.001 { t.Logf("Expected column 2 to show totalRPS more than 0.001, got %#v", fields) return errors.New("unexpected output (incorrect RPS)") } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.8K bytes - Viewed (0) -
internal/pubsub/pubsub.go
} } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1) return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers) } ps.Lock() defer ps.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
cmd/speedtest.go
results := globalNotificationSys.SpeedTest(ctx, sopts) sort.Slice(results, func(i, j int) bool { return results[i].Endpoint < results[j].Endpoint }) totalPut := uint64(0) totalGet := uint64(0) for _, result := range results { totalPut += result.Uploads totalGet += result.Downloads } if totalGet < throughputHighestGet { // Following check is for situations
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/metrics-v3-bucket-replication.go
m.Set(bucketReplSentCount, float64(stat.ReplicatedCount), labels...) m.Set(bucketReplTotalFailedBytes, float64(stat.Failed.Totals.Bytes), labels...) m.Set(bucketReplTotalFailedCount, float64(stat.Failed.Totals.Count), labels...) m.Set(bucketReplProxiedDeleteTaggingRequestsFailures, float64(s.ProxyStats.RmvTagFailedTotal), labels...)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} func (rt *RTimedMetrics) String() string { s := rt.toMetric() return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count) } func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats { if rt == nil { return madmin.TimedErrStats{} } errCounts := make(map[string]int) for k, v := range rt.ErrCounts { errCounts[k] = v
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0)