Seculative resource prefetching for URLs CL.

chrome/browser/net/resource_prefetch_predictor_observer.cc

Index: chrome/browser/net/resource_prefetch_predictor_observer.cc
diff --git a/chrome/browser/net/resource_prefetch_predictor_observer.cc b/chrome/browser/net/resource_prefetch_predictor_observer.cc
new file mode 100644
index 0000000000000000000000000000000000000000..d47c379bea6399bd8bdc693bf2736515c8be2dbf
--- /dev/null
+++ b/chrome/browser/net/resource_prefetch_predictor_observer.cc
@@ -0,0 +1,84 @@
+// 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/net/resource_prefetch_predictor_observer.h"
+
+#include "content/public/browser/browser_thread.h"
+#include "net/url_request/url_request.h"
+
+using content::BrowserThread;
+using predictors::ResourcePrefetchPredictor;
+
+namespace chrome_browser_net {
+
+ResourcePrefetchPredictorObserver::ResourcePrefetchPredictorObserver(
+    ResourcePrefetchPredictor* predictor)
+        : predictor_(predictor->AsWeakPtr()) {

[willchan no longer on Chromium, 2012/05/31 02:08:58]

This needs to happen on the UI thread, right? Can you add the appropriate
assertion here?

[Shishir, 2012/06/02 01:19:29]

Done.

+}
+
+ResourcePrefetchPredictorObserver::~ResourcePrefetchPredictorObserver() {

[willchan no longer on Chromium, 2012/05/31 02:08:58]

This needs to happen on the IO thread, right? If so, can you add the appropriate
assertion here?

[Shishir, 2012/06/02 01:19:29]

Done.

+}
+
+void ResourcePrefetchPredictorObserver::OnRequestStarted(
+    net::URLRequest* request,
+    ResourceType::Type resource_type,
+    int child_id,
+    int route_id) {
+  CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));

[willchan no longer on Chromium, 2012/05/31 02:08:58]

Can we use DCHECK instead? I'd prefer to avoid the binary bloat.

[Shishir, 2012/06/02 01:19:29]

Done.

+
+  if (!ResourcePrefetchPredictor::ShouldRecordRequest(request, resource_type))
+    return;
+
+  ResourcePrefetchPredictor::URLRequestSummary summary;
+  summary.navigation_id_.render_process_id_ = child_id;
+  summary.navigation_id_.render_view_id_ = route_id;
+  summary.navigation_id_.main_frame_url_ = request->first_party_for_cookies();
+  summary.resource_url_ = request->original_url();
+  summary.resource_type_ = resource_type;
+
+  BrowserThread::PostTask(
+      BrowserThread::UI,
+      FROM_HERE,
+      base::Bind(&ResourcePrefetchPredictor::RecordURLRequest,
+                 predictor_,
+                 summary));
+}
+
+void ResourcePrefetchPredictorObserver::OnRequestRedirected(
+    net::URLRequest* request) {
+  CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+  if (!ResourcePrefetchPredictor::ShouldRecordRedirect(request))
+    return;
+  ResourcePrefetchPredictor::URLRequestSummary summary;
+  if (!summary.InitFromURLRequest(request, true))
+    return;
+
+  BrowserThread::PostTask(
+      BrowserThread::UI,
+      FROM_HERE,
+      base::Bind(&ResourcePrefetchPredictor::RecordUrlRedirect,
+                 predictor_,
+                 summary));
+}
+
+void ResourcePrefetchPredictorObserver::OnResponseStarted(
+    net::URLRequest* request) {
+  CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+  if (!ResourcePrefetchPredictor::ShouldRecordResponse(request))
+    return;
+  ResourcePrefetchPredictor::URLRequestSummary summary;
+  if (!summary.InitFromURLRequest(request, true))
+    return;
+
+  BrowserThread::PostTask(
+      BrowserThread::UI,
+      FROM_HERE,
+      base::Bind(&ResourcePrefetchPredictor::RecordUrlResponse,
+                 predictor_,
+                 summary));
+}
+
+}  // namespace chrome_browser_net