Adds enableVirtualTime and setVirtualTimePolicy To Emulation domain.

third_party/WebKit/Source/core/fetch/ResourceLoader.cpp

 /*
  * Copyright (C) 2006, 2007, 2010, 2011 Apple Inc. All rights reserved.
  *           (C) 2007 Graham Dennis (graham.dennis@gmail.com)
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
@@ skipping 24 matching lines @@
 #include "platform/Logging.h"
 #include "platform/SharedBuffer.h"
 #include "platform/exported/WrappedResourceRequest.h"
 #include "platform/exported/WrappedResourceResponse.h"
 #include "platform/network/ResourceError.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebData.h"
 #include "public/platform/WebURLError.h"
 #include "public/platform/WebURLRequest.h"
 #include "public/platform/WebURLResponse.h"
+#include "public/platform/WebViewScheduler.h"
 #include "wtf/Assertions.h"
 #include "wtf/CurrentTime.h"
 #include "wtf/PtrUtil.h"
 #include <memory>
 
 namespace blink {
 
 ResourceLoader* ResourceLoader::create(ResourceFetcher* fetcher, Resource* resource)
 {
     return new ResourceLoader(fetcher, resource);
 }
 
 ResourceLoader::ResourceLoader(ResourceFetcher* fetcher, Resource* resource)
     : m_fetcher(fetcher)
-    , m_resource(resource)
+    , m_resource(resource),
+    m_webViewScheduler(nullptr)
 {
     ASSERT(m_resource);
     ASSERT(m_fetcher);
     m_resource->setLoader(this);
 }
 
 ResourceLoader::~ResourceLoader()
 {
     DCHECK(!m_loader);
 }
 
 DEFINE_TRACE(ResourceLoader)
 {
     visitor->trace(m_fetcher);
     visitor->trace(m_resource);
 }
 
-void ResourceLoader::start(const ResourceRequest& request, WebTaskRunner* loadingTaskRunner, bool defersLoading)
+void ResourceLoader::start(const ResourceRequest& request, WebTaskRunner* loadingTaskRunner, WeakPtr<WebViewScheduler> webViewScheduler, bool defersLoading)
 {
     ASSERT(!m_loader);
     if (m_resource->options().synchronousPolicy == RequestSynchronously && defersLoading) {
         cancel();
         return;
     }
 
+    m_webViewScheduler = std::move(webViewScheduler);
+
     m_loader = wrapUnique(Platform::current()->createURLLoader());
     m_loader->setDefersLoading(defersLoading);
     ASSERT(m_loader);
     m_loader->setLoadingTaskRunner(loadingTaskRunner);
 
+    if (m_webViewScheduler)
+        m_webViewScheduler->incrementPendingResourceLoadCount();
+
     if (m_resource->options().synchronousPolicy == RequestSynchronously)
         requestSynchronously(request);
     else
         m_loader->loadAsynchronously(WrappedResourceRequest(request), this);
 }
 
 void ResourceLoader::setDefersLoading(bool defers)
 {
     ASSERT(m_loader);
     m_loader->setDefersLoading(defers);
@@ skipping 107 matching lines @@
 
 void ResourceLoader::didFinishLoadingFirstPartInMultipart()
 {
     m_fetcher->didFinishLoading(m_resource.get(), 0, WebURLLoaderClient::kUnknownEncodedDataLength, ResourceFetcher::DidFinishFirstPartInMultipart);
 }
 
 void ResourceLoader::didFinishLoading(WebURLLoader*, double finishTime, int64_t encodedDataLength)
 {
     m_loader.reset();
     m_fetcher->didFinishLoading(m_resource.get(), finishTime, encodedDataLength, ResourceFetcher::DidFinishLoading);
+
+    if (m_webViewScheduler)
+        m_webViewScheduler->decrementPendingResourceLoadCount();
 }
 
 void ResourceLoader::didFail(WebURLLoader*, const WebURLError& error)
 {
     m_loader.reset();
     m_fetcher->didFailLoading(m_resource.get(), error);
+
+    if (m_webViewScheduler)
+        m_webViewScheduler->decrementPendingResourceLoadCount();
 }
 
 void ResourceLoader::requestSynchronously(const ResourceRequest& request)
 {
     // downloadToFile is not supported for synchronous requests.
     ASSERT(!request.downloadToFile());
     ASSERT(m_loader);
     DCHECK(request.priority() == ResourceLoadPriorityHighest);
 
     WrappedResourceRequest requestIn(request);
@@ skipping 22 matching lines @@
     // empty buffer is a noop in most cases, but is destructive in the case of
     // a 304, where it will overwrite the cached data we should be reusing.
     if (dataOut.size()) {
         m_fetcher->didReceiveData(m_resource.get(), dataOut.data(), dataOut.size(), encodedDataLength);
         m_resource->setResourceBuffer(dataOut);
     }
     didFinishLoading(0, monotonicallyIncreasingTime(), encodedDataLength);
 }
 
 } // namespace blink