PerfProvider: Run a randomly selected perf command

chrome/browser/metrics/perf/perf_provider_chromeos.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/metrics/perf/perf_provider_chromeos.h"
 
+#include <algorithm>
 #include <string>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/metrics/histogram.h"
 #include "base/rand_util.h"
+#include "base/strings/string_split.h"
 #include "base/threading/sequenced_worker_pool.h"
 #include "chrome/browser/metrics/perf/windowed_incognito_observer.h"
 #include "chrome/browser/ui/browser_list.h"
 #include "chromeos/dbus/dbus_thread_manager.h"
 #include "chromeos/dbus/debug_daemon_client.h"
 
 namespace metrics {
 
 namespace {
 
@@ skipping 35 matching lines @@
 bool IsNormalUserLoggedIn() {
   return chromeos::LoginState::Get()->IsUserAuthenticated();
 }
 
 // Returns a random TimeDelta between zero and |max|.
 base::TimeDelta RandomTimeDelta(base::TimeDelta max) {
   return base::TimeDelta::FromMicroseconds(
       base::RandGenerator(max.InMicroseconds()));
 }
 
+// Hopefully we never need a space in a command argument.
+const char kPerfCommandDelimiter[] = " ";
+
+const char kPerfRecordCyclesCmd[] =
+  "perf record -a -e cycles -c 1000003";
+
+const char kPerfRecordCallgraphCmd[] =
+  "perf record -a -e cycles -g -c 4000037";
+
+const char kPerfRecordLBRCmd[] =
+  "perf record -a -e r2c4 -b -c 20011";
+
+const char kPerfRecordInstructionTLBMissesCmd[] =
+  "perf record -a -e iTLB-misses -c 2003";
+
+const char kPerfRecordDataTLBMissesCmd[] =
+  "perf record -a -e dTLB-misses -c 2003";
+
+const char kPerfStatMemoryBandwidthCmd[] =
+  "perf stat -a -e cycles -e instructions "
+  "-e uncore_imc/data_reads/ -e uncore_imc/data_writes/ "
+  "-e cpu/event=0xD0,umask=0x11,name=MEM_UOPS_RETIRED-STLB_MISS_LOADS/ "
+  "-e cpu/event=0xD0,umask=0x12,name=MEM_UOPS_RETIRED-STLB_MISS_STORES/";
+
+const std::vector<RandomSelector::WeightAndValue> GetDefaultCommands_x86_64(
+    const CPUIdentity& cpuid) {
+  using WeightAndValue = RandomSelector::WeightAndValue;
+  std::vector<WeightAndValue> cmds;
+  DCHECK_EQ(cpuid.arch, "x86_64");
+  const std::string intel_uarch = GetIntelUarch(cpuid);
+  if (intel_uarch == "IvyBridge" ||
+      intel_uarch == "Haswell" ||
+      intel_uarch == "Broadwell") {
+    cmds.push_back(WeightAndValue(60.0, kPerfRecordCyclesCmd));
+    cmds.push_back(WeightAndValue(20.0, kPerfRecordCallgraphCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordLBRCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordInstructionTLBMissesCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordDataTLBMissesCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfStatMemoryBandwidthCmd));
+    return cmds;
+  }
+  if (intel_uarch == "SandyBridge") {
+    cmds.push_back(WeightAndValue(65.0, kPerfRecordCyclesCmd));
+    cmds.push_back(WeightAndValue(20.0, kPerfRecordCallgraphCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordLBRCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordInstructionTLBMissesCmd));
+    cmds.push_back(WeightAndValue(5.0, kPerfRecordDataTLBMissesCmd));
+    return cmds;
+  }
+  // Other 64-bit x86
+  cmds.push_back(WeightAndValue(70.0, kPerfRecordCyclesCmd));
+  cmds.push_back(WeightAndValue(20.0, kPerfRecordCallgraphCmd));
+  cmds.push_back(WeightAndValue(5.0, kPerfRecordInstructionTLBMissesCmd));
+  cmds.push_back(WeightAndValue(5.0, kPerfRecordDataTLBMissesCmd));
+  return cmds;
+}
+
 }  // namespace
 
+namespace internal {
+
+std::vector<RandomSelector::WeightAndValue> GetDefaultCommandsForCpu(
+    const CPUIdentity& cpuid) {
+  using WeightAndValue = RandomSelector::WeightAndValue;
+
+  if (cpuid.arch == "x86_64")  // 64-bit x86
+    return GetDefaultCommands_x86_64(cpuid);
+
+  std::vector<WeightAndValue> cmds;
+  if (cpuid.arch == "x86" ||     // 32-bit x86, or...
+      cpuid.arch == "armv7l") {  // ARM
+    cmds.push_back(WeightAndValue(80.0, kPerfRecordCyclesCmd));
+    cmds.push_back(WeightAndValue(20.0, kPerfRecordCallgraphCmd));
+    return cmds;
+  }
+
+  // Unknown CPUs
+  cmds.push_back(WeightAndValue(1.0, kPerfRecordCyclesCmd));
+  return cmds;
+}
+
+}  // namespace internal
+
 PerfProvider::CollectionParams::CollectionParams(
     base::TimeDelta collection_duration,
     base::TimeDelta periodic_interval,
     TriggerParams resume_from_suspend,
     TriggerParams restore_session)
     : collection_duration_(collection_duration.ToInternalValue()),
       periodic_interval_(periodic_interval.ToInternalValue()),
       resume_from_suspend_(resume_from_suspend),
       restore_session_(restore_session) {
 }
@@ skipping 13 matching lines @@
       /* max_collection_delay = */ base::TimeDelta::FromSeconds(5)),
   /* restore_session = */ PerfProvider::CollectionParams::TriggerParams(
       /* sampling_factor = */ 10,
       /* max_collection_delay = */ base::TimeDelta::FromSeconds(10)));
 
 PerfProvider::PerfProvider()
     : collection_params_(kDefaultParameters),
       login_observer_(this),
       next_profiling_interval_start_(base::TimeTicks::Now()),
       weak_factory_(this) {
+  command_selector_.SetOdds(
+      internal::GetDefaultCommandsForCpu(GetCPUIdentity())),
+
   // Register the login observer with LoginState.
   chromeos::LoginState::Get()->AddObserver(&login_observer_);
 
   // Register as an observer of power manager events.
   chromeos::DBusThreadManager::Get()->GetPowerManagerClient()->
       AddObserver(this);
 
   // Register as an observer of session restore.
   on_session_restored_callback_subscription_ =
       SessionRestore::RegisterOnSessionRestoredCallback(
@@ skipping 219 matching lines @@
     AddToPerfHistogram(INCOGNITO_ACTIVE);
     return;
   }
 
   scoped_ptr<WindowedIncognitoObserver> incognito_observer(
       new WindowedIncognitoObserver);
 
   chromeos::DebugDaemonClient* client =
       chromeos::DBusThreadManager::Get()->GetDebugDaemonClient();
 
+  std::vector<std::string> command = base::SplitString(
+      command_selector_.Select(), kPerfCommandDelimiter,
+      base::KEEP_WHITESPACE, base::SPLIT_WANT_ALL);
   client->GetPerfOutput(
-      collection_params_.collection_duration().InSeconds(),
+      collection_params_.collection_duration().InSeconds(), command,
       base::Bind(&PerfProvider::ParseOutputProtoIfValid,
                  weak_factory_.GetWeakPtr(), base::Passed(&incognito_observer),
                  base::Passed(&sampled_profile)));
 }
 
 void PerfProvider::DoPeriodicCollection() {
   scoped_ptr<SampledProfile> sampled_profile(new SampledProfile);
   sampled_profile->set_trigger_event(SampledProfile::PERIODIC_COLLECTION);
 
   CollectIfNecessary(sampled_profile.Pass());
@@ skipping 18 matching lines @@
   scoped_ptr<SampledProfile> sampled_profile(new SampledProfile);
   sampled_profile->set_trigger_event(SampledProfile::RESTORE_SESSION);
   sampled_profile->set_ms_after_restore(time_after_restore.InMilliseconds());
   sampled_profile->set_num_tabs_restored(num_tabs_restored);
 
   CollectIfNecessary(sampled_profile.Pass());
   last_session_restore_collection_time_ = base::TimeTicks::Now();
 }
 
 }  // namespace metrics