[Mojo-Loading] Implement "Site Isolation Stats Gathering" feature

content/child/url_response_body_consumer.cc

 // Copyright 2016 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 "content/child/url_response_body_consumer.h"
 
 #include "base/auto_reset.h"
 #include "base/bind.h"
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
 #include "content/child/resource_dispatcher.h"
+#include "content/child/site_isolation_stats_gatherer.h"
 #include "content/common/resource_messages.h"
 #include "content/common/resource_request_completion_status.h"
 #include "content/public/child/request_peer.h"
 
 namespace content {
 
 class URLResponseBodyConsumer::ReceivedData final
     : public RequestPeer::ReceivedData {
  public:
   ReceivedData(const char* payload,
@@ skipping 114 matching lines @@
       DCHECK_EQ(result, MOJO_RESULT_OK);
       task_runner_->PostTask(FROM_HERE,
                              base::Bind(&URLResponseBodyConsumer::OnReadable,
                                         AsWeakPtr(), MOJO_RESULT_OK));
       return;
     }
     num_bytes_consumed += available;
     ResourceDispatcher::PendingRequestInfo* request_info =
         resource_dispatcher_->GetPendingRequestInfo(request_id_);
     DCHECK(request_info);
+
+    // Check whether this response data is compliant with our cross-site

[yhirano, 2017/01/19 10:35:55]

This code is copied from ResourceDispatcher::OnReceivedData.

+    // document blocking policy. We only do this for the first chunk of data.
+    if (request_info->site_isolation_metadata.get()) {
+      SiteIsolationStatsGatherer::OnReceivedFirstChunk(
+          request_info->site_isolation_metadata,
+          static_cast<const char*>(buffer), available);
+      request_info->site_isolation_metadata.reset();
+    }
+
     request_info->peer->OnReceivedData(base::MakeUnique<ReceivedData>(
         static_cast<const char*>(buffer), available, this));
   }
 }
 
 void URLResponseBodyConsumer::NotifyCompletionIfAppropriate() {
   if (has_been_cancelled_)
     return;
   if (!has_received_completion_ || !has_seen_end_of_data_)
     return;
   // Cancel this instance in order not to notify twice.
   Cancel();
 
   resource_dispatcher_->DispatchMessage(
       ResourceMsg_RequestComplete(request_id_, completion_status_));
   // |this| may be deleted.
 }
 
 }  // namespace content