RAPPOR implementation

chrome/browser/metrics/metrics_log.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/metrics_log.h"
 
 #include <algorithm>
 #include <string>
 #include <vector>
 
@@ skipping 11 matching lines @@
 #include "base/sys_info.h"
 #include "base/third_party/nspr/prtime.h"
 #include "base/time/time.h"
 #include "base/tracked_objects.h"
 #include "chrome/browser/autocomplete/autocomplete_input.h"
 #include "chrome/browser/autocomplete/autocomplete_match.h"
 #include "chrome/browser/autocomplete/autocomplete_provider.h"
 #include "chrome/browser/autocomplete/autocomplete_result.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/google/google_util.h"
+#include "chrome/browser/metrics/rappord.h"
 #include "chrome/browser/omnibox/omnibox_log.h"
 #include "chrome/browser/plugins/plugin_prefs.h"
 #include "chrome/browser/profiles/profile_manager.h"
 #include "chrome/common/chrome_version_info.h"
 #include "chrome/common/logging_chrome.h"
 #include "chrome/common/metrics/proto/omnibox_event.pb.h"
 #include "chrome/common/metrics/proto/profiler_event.pb.h"
 #include "chrome/common/metrics/proto/system_profile.pb.h"
 #include "chrome/common/metrics/variations/variations_util.h"
 #include "chrome/common/pref_names.h"
@@ skipping 735 matching lines @@
 #endif
 
   WriteGoogleUpdateProto(google_update_metrics);
 
   WritePluginList(plugin_list);
 
   std::vector<ActiveGroupId> field_trial_ids;
   GetFieldTrialIds(&field_trial_ids);
   WriteFieldTrials(field_trial_ids, system_profile);
 
+  std::string bloom_filter_bits;
+  GetBloomFilterBits(&bloom_filter_bits);
+  WriteBloomFilterBits(bloom_filter_bits, system_profile);
+
 #if defined(OS_CHROMEOS)
   PerfDataProto perf_data_proto;
   if (perf_provider_.GetPerfData(&perf_data_proto))
     uma_proto()->add_perf_data()->Swap(&perf_data_proto);
 
   // BluetoothAdapterFactory::GetAdapter is synchronous on Chrome OS; if that
   // changes this will fail at the DCHECK().
   device::BluetoothAdapterFactory::GetAdapter(
       base::Bind(&MetricsLog::SetBluetoothAdapter,
                  base::Unretained(this)));
   DCHECK(adapter_.get());
   WriteBluetoothProto(hardware);
   UpdateMultiProfileUserCount();
 #endif
 }
 
+void MetricsLog::GetBloomFilterBits(std::string* bloom_filter_bits) {

[Steven Holte, 2013/10/28 21:02:44]

This should probably be split into 4 parts:

A function for adding a collected value to the PPRR, a function for encoding the
PPRRs into the proto buf, a utility for breaking the URLs into bits for the
PPRR, and the actual collection of homepage.  Any suggestions about where each
of those should live?

[Ilya Sherman, 2013/10/29 00:32:31]

If you're intending to provide something of a parallel architecture to the
histograms architecture, then you'll probably want the code for "adding a
collected value to the PPRR" to live in //base/metrics.  Encoding the collected
values into the protocol buffer makes sense to keep in metrics_log.cc, most
likely in the anonymous namespace.  Breaking URLs into bits should probably be
an internal implementation detail for logging values to the code that lives in
//base/metrics.  The collection of the homepage should be done by whatever
feature code interacts with setting the homepage, though depending on when this
is meant to be recorded, there might need to be a call into that code from the
MetricsLog or from the MetricsService.

+  PrefService* pref_service = GetPrefService();
+
+  typedef RappordBloomFilter<128, 4, -4, 2, -4> rappord_t;
+  rappord_t rap(1, pref_service->GetString(prefs::kMetricsSecretClientID));
+
+  // std::string homepageurl = pref_service->GetString(prefs::kHomePage);
+  std::string homepageurl = "http://www.google.com/foo?bar";
+  std::vector<std::string> strs;
+  GURL gurl(homepageurl);
+
+  strs.push_back(homepageurl);
+  strs.push_back(gurl.spec());
+  strs.push_back(gurl.host());
+  // TODO(holte) break up host more
+  strs.push_back(gurl.query());
+  strs.push_back(gurl.path());
+  // strs.push_back(gurl.ref());
+
+  const rappord_t::bitmap_t bits = rap.get(strs);
+  *bloom_filter_bits = bits.to_string();
+}
+
+void MetricsLog::WriteBloomFilterBits(
+      const std::string& bloom_filter_bits,
+                            SystemProfileProto* system_profile) {
+  system_profile->set_bloom_filter_bits(bloom_filter_bits);
+}
+
 void MetricsLog::RecordProfilerData(
     const tracked_objects::ProcessDataSnapshot& process_data,
     int process_type) {
   DCHECK(!locked());
 
   if (tracked_objects::GetTimeSourceType() !=
           tracked_objects::TIME_SOURCE_TYPE_WALL_TIME) {
     // We currently only support the default time source, wall clock time.
     return;
   }
@@ skipping 150 matching lines @@
 
     // We invalidate the user count if it changed while the log was open.
     if (system_profile->has_multi_profile_user_count() &&
         user_count != system_profile->multi_profile_user_count())
       user_count = 0;
 
     system_profile->set_multi_profile_user_count(user_count);
   }
 }
 #endif