Plumbing devtools agent host id and request id between processes

content/browser/loader/resource_dispatcher_host_impl.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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "content/browser/loader/resource_dispatcher_host_impl.h"
 
 #include <stddef.h>
 
@@ skipping 52 matching lines @@
 #include "content/browser/loader/upload_data_stream_builder.h"
 #include "content/browser/resource_context_impl.h"
 #include "content/browser/service_worker/foreign_fetch_request_handler.h"
 #include "content/browser/service_worker/link_header_support.h"
 #include "content/browser/service_worker/service_worker_context_wrapper.h"
 #include "content/browser/service_worker/service_worker_navigation_handle_core.h"
 #include "content/browser/service_worker/service_worker_request_handler.h"
 #include "content/browser/streams/stream.h"
 #include "content/browser/streams/stream_context.h"
 #include "content/browser/streams/stream_registry.h"
+#include "content/common/net/url_request_devtools_user_data.h"
 #include "content/common/net/url_request_service_worker_data.h"
 #include "content/common/resource_messages.h"
 #include "content/common/resource_request.h"
 #include "content/common/resource_request_body_impl.h"
 #include "content/common/resource_request_completion_status.h"
 #include "content/common/view_messages.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/global_request_id.h"
 #include "content/public/browser/navigation_ui_data.h"
 #include "content/public/browser/plugin_service.h"
@@ skipping 1277 matching lines @@
   // Request takes ownership.
   extra_info->AssociateWithRequest(new_request.get());
 
   if (new_request->url().SchemeIs(url::kBlobScheme)) {
     // Hang on to a reference to ensure the blob is not released prior
     // to the job being started.
     storage::BlobProtocolHandler::SetRequestedBlobDataHandle(
         new_request.get(), requester_info->blob_storage_context()
                                ->context()
                                ->GetBlobDataFromPublicURL(new_request->url()));
+  } else if (!request_data.devtools_agent_host_id.empty()) {
+    new_request->SetUserData(URLRequestDevtoolsUserData::kUserDataKey,
+                             base::MakeUnique<URLRequestDevtoolsUserData>(
+                                 request_data.devtools_agent_host_id,
+                                 request_data.devtools_request_id));
   }
 
   // Initialize the service worker handler for the request. We don't use
   // ServiceWorker for synchronous loads to avoid renderer deadlocks.
   const ServiceWorkerMode service_worker_mode =
       is_sync_load ? ServiceWorkerMode::NONE : request_data.service_worker_mode;
   ServiceWorkerRequestHandler::InitializeHandler(
       new_request.get(), requester_info->service_worker_context(), blob_context,
       child_id, request_data.service_worker_provider_id,
       service_worker_mode != ServiceWorkerMode::ALL,
@@ skipping 665 matching lines @@
 
   // Request takes ownership.
   extra_info->AssociateWithRequest(new_request.get());
 
   if (new_request->url().SchemeIs(url::kBlobScheme)) {
     // Hang on to a reference to ensure the blob is not released prior
     // to the job being started.
     storage::BlobProtocolHandler::SetRequestedBlobDataHandle(
         new_request.get(),
         blob_context->GetBlobDataFromPublicURL(new_request->url()));
+  } else if (!info.devtools_agent_host_id.empty()) {
+    // Keep in sync with IdentifiersFactory::requestId. We don't necessarily
+    // know the browser PID yet so just specify zero.

[Sami, 2017/03/29 16:41:42]

Do you mean the renderer pid?

[alex clarke (OOO till 29th), 2017/03/30 16:56:55]

Done.

+    std::string devtools_request_id =
+        base::StringPrintf("0.%u\n", info.devtools_request_id);
+    new_request->SetUserData(
+        URLRequestDevtoolsUserData::kUserDataKey,
+        base::MakeUnique<URLRequestDevtoolsUserData>(
+            info.devtools_agent_host_id, devtools_request_id));
   }
 
   RequestContextFrameType frame_type =
       info.is_main_frame ? REQUEST_CONTEXT_FRAME_TYPE_TOP_LEVEL
                          : REQUEST_CONTEXT_FRAME_TYPE_NESTED;
   ServiceWorkerRequestHandler::InitializeForNavigation(
       new_request.get(), service_worker_handle_core, blob_context,
       info.begin_params.skip_service_worker, resource_type,
       info.begin_params.request_context_type, frame_type,
       info.are_ancestors_secure, info.common_params.post_data,
@@ skipping 548 matching lines @@
                                  &throttles);
     if (!throttles.empty()) {
       handler.reset(new ThrottlingResourceHandler(std::move(handler), request,
                                                   std::move(throttles)));
     }
   }
   return handler;
 }
 
 }  // namespace content