[Not for review] record detailed time breakdown of SW related requests.

third_party/WebKit/Source/core/loader/WorkerThreadableLoader.cpp

 /*
  * Copyright (C) 2009, 2010 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 12 matching lines @@
  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
 #include "core/loader/WorkerThreadableLoader.h"
 
+#include <memory>
 #include "core/dom/Document.h"
 #include "core/dom/ExecutionContextTask.h"
 #include "core/loader/DocumentThreadableLoader.h"
 #include "core/timing/WorkerGlobalScopePerformance.h"
 #include "core/workers/WorkerGlobalScope.h"
 #include "core/workers/WorkerLoaderProxy.h"
 #include "platform/CrossThreadFunctional.h"
+#include "platform/Histogram.h"
 #include "platform/heap/SafePoint.h"
 #include "platform/network/ResourceError.h"
 #include "platform/network/ResourceRequest.h"
 #include "platform/network/ResourceResponse.h"
 #include "platform/network/ResourceTimingInfo.h"
 #include "platform/weborigin/KURL.h"
 #include "platform/weborigin/SecurityPolicy.h"
+#include "wtf/CurrentTime.h"
 #include "wtf/Functional.h"
 #include "wtf/debug/Alias.h"
-#include <memory>
 
 namespace blink {
 
 namespace {
 
 std::unique_ptr<Vector<char>> createVectorFromMemoryRegion(
     const char* data,
     unsigned dataLength) {
   std::unique_ptr<Vector<char>> buffer =
       WTF::makeUnique<Vector<char>>(dataLength);
@@ skipping 134 matching lines @@
     WorkerGlobalScope& workerGlobalScope,
     ThreadableLoaderClient* client,
     const ThreadableLoaderOptions& options,
     const ResourceLoaderOptions& resourceLoaderOptions,
     BlockingBehavior blockingBehavior)
     : m_workerGlobalScope(&workerGlobalScope),
       m_workerLoaderProxy(workerGlobalScope.thread()->workerLoaderProxy()),
       m_client(client),
       m_threadableLoaderOptions(options),
       m_resourceLoaderOptions(resourceLoaderOptions),
-      m_blockingBehavior(blockingBehavior) {
+      m_blockingBehavior(blockingBehavior),
+      m_isServiceWorker(workerGlobalScope.isServiceWorkerGlobalScope()) {
   DCHECK(client);
 }
 
 void WorkerThreadableLoader::loadResourceSynchronously(
     WorkerGlobalScope& workerGlobalScope,
     const ResourceRequest& request,
     ThreadableLoaderClient& client,
     const ThreadableLoaderOptions& options,
     const ResourceLoaderOptions& resourceLoaderOptions) {
   (new WorkerThreadableLoader(workerGlobalScope, &client, options,
@@ skipping 20 matching lines @@
     eventWithTasks = WaitableEventWithTasks::create();
 
   m_workerLoaderProxy->postTaskToLoader(
       BLINK_FROM_HERE,
       createCrossThreadTask(
           &MainThreadLoaderHolder::createAndStart,
           wrapCrossThreadPersistent(this), m_workerLoaderProxy,
           wrapCrossThreadPersistent(
               m_workerGlobalScope->thread()->getWorkerThreadLifecycleContext()),
           request, m_threadableLoaderOptions, m_resourceLoaderOptions,
-          eventWithTasks));
+          eventWithTasks, monotonicallyIncreasingTime(), m_isServiceWorker));
 
   if (m_blockingBehavior == LoadAsynchronously)
     return;
 
   eventWithTasks->wait();
 
   if (eventWithTasks->isAborted()) {
     // This thread is going to terminate.
     cancel();
     return;
@@ skipping 71 matching lines @@
 void WorkerThreadableLoader::didReceiveRedirectTo(const KURL& url) {
   DCHECK(!isMainThread());
   if (!m_client)
     return;
   m_client->didReceiveRedirectTo(url);
 }
 
 void WorkerThreadableLoader::didReceiveResponse(
     unsigned long identifier,
     std::unique_ptr<CrossThreadResourceResponseData> responseData,
-    std::unique_ptr<WebDataConsumerHandle> handle) {
+    std::unique_ptr<WebDataConsumerHandle> handle,
+    double postTaskTime) {
+  int value =
+      static_cast<int>((monotonicallyIncreasingTime() - postTaskTime) * 1000);
+  DEFINE_STATIC_LOCAL(
+      CustomCountHistogram, hist,
+      ("SWF.C2.Response.RendererMainToWorker", 0, 10000000, 50));
+  if (m_isServiceWorker)
+    hist.count(value);
   DCHECK(!isMainThread());
   if (!m_client)
     return;
   ResourceResponse response(responseData.get());
   m_client->didReceiveResponse(identifier, response, std::move(handle));
 }
 
 void WorkerThreadableLoader::didReceiveData(
     std::unique_ptr<Vector<char>> data) {
   DCHECK(!isMainThread());
@@ skipping 78 matching lines @@
 }
 
 void WorkerThreadableLoader::MainThreadLoaderHolder::createAndStart(
     WorkerThreadableLoader* workerLoader,
     PassRefPtr<WorkerLoaderProxy> passLoaderProxy,
     WorkerThreadLifecycleContext* workerThreadLifecycleContext,
     std::unique_ptr<CrossThreadResourceRequestData> request,
     const ThreadableLoaderOptions& options,
     const ResourceLoaderOptions& resourceLoaderOptions,
     PassRefPtr<WaitableEventWithTasks> eventWithTasks,
+    double postTaskTime,
+    bool isServiceWorker,
     ExecutionContext* executionContext) {
+  int value =
+      static_cast<int>((monotonicallyIncreasingTime() - postTaskTime) * 1000);
+  DEFINE_STATIC_LOCAL(CustomCountHistogram, hist,
+                      ("SWF.B1.Request.WorkerToRendererMain", 0, 10000000, 50));
+  if (isServiceWorker)
+    hist.count(value);
+
   DCHECK(isMainThread());
   TaskForwarder* forwarder;
   RefPtr<WorkerLoaderProxy> loaderProxy = passLoaderProxy;
   if (eventWithTasks)
     forwarder = new SyncTaskForwarder(std::move(eventWithTasks));
   else
     forwarder = new AsyncTaskForwarder(loaderProxy);
 
   MainThreadLoaderHolder* mainThreadLoaderHolder =
       new MainThreadLoaderHolder(forwarder, workerThreadLifecycleContext);
+  mainThreadLoaderHolder->m_isServiceWorker = isServiceWorker;
   if (mainThreadLoaderHolder->wasContextDestroyedBeforeObserverCreation()) {
     // The thread is already terminating.
     forwarder->abort();
     mainThreadLoaderHolder->m_forwarder = nullptr;
     return;
   }
   mainThreadLoaderHolder->m_workerLoader = workerLoader;
   forwarder->forwardTask(
       BLINK_FROM_HERE,
       crossThreadBind(&WorkerThreadableLoader::didStart,
@@ skipping 51 matching lines @@
       BLINK_FROM_HERE,
       crossThreadBind(&WorkerThreadableLoader::didReceiveRedirectTo,
                       workerLoader, url));
 }
 
 void WorkerThreadableLoader::MainThreadLoaderHolder::didReceiveResponse(
     unsigned long identifier,
     const ResourceResponse& response,
     std::unique_ptr<WebDataConsumerHandle> handle) {
   DCHECK(isMainThread());
+  double now(monotonicallyIncreasingTime());
+  int value = static_cast<int>((now * 1000 - response.responseStart() / 1000));
+  DEFINE_STATIC_LOCAL(
+      CustomCountHistogram, hist,
+      ("SWF.C1.Response.BrowserToRendererMain", 0, 10000000, 50));
+  if (m_isServiceWorker)
+    hist.count(value);
+
   CrossThreadPersistent<WorkerThreadableLoader> workerLoader =
       m_workerLoader.get();
   if (!workerLoader || !m_forwarder)
     return;
   m_forwarder->forwardTask(
       BLINK_FROM_HERE,
       crossThreadBind(&WorkerThreadableLoader::didReceiveResponse, workerLoader,
-                      identifier, response, WTF::passed(std::move(handle))));
+                      identifier, response, WTF::passed(std::move(handle)),
+                      now));
 }
 
 void WorkerThreadableLoader::MainThreadLoaderHolder::didReceiveData(
     const char* data,
     unsigned dataLength) {
   DCHECK(isMainThread());
   CrossThreadPersistent<WorkerThreadableLoader> workerLoader =
       m_workerLoader.get();
   if (!workerLoader || !m_forwarder)
     return;
@@ skipping 129 matching lines @@
     const ResourceLoaderOptions& originalResourceLoaderOptions) {
   DCHECK(isMainThread());
   ResourceLoaderOptions resourceLoaderOptions = originalResourceLoaderOptions;
   resourceLoaderOptions.requestInitiatorContext = WorkerContext;
   m_mainThreadLoader = DocumentThreadableLoader::create(document, this, options,
                                                         resourceLoaderOptions);
   m_mainThreadLoader->start(ResourceRequest(request.get()));
 }
 
 }  // namespace blink