Lower the priority of shared workers

content/browser/worker_host/worker_process_host.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.
 
 #include "content/browser/worker_host/worker_process_host.h"
 
 #include <set>
 #include <string>
 #include <vector>
 
@@ skipping 96 matching lines @@
   RenderViewHostImpl* host =
       RenderViewHostImpl::FromID(render_process_unique_id, render_view_id);
   if (host)
     host->GetDelegate()->WorkerCrashed();
 }
 
 WorkerProcessHost::WorkerProcessHost(
     ResourceContext* resource_context,
     const WorkerStoragePartition& partition)
     : resource_context_(resource_context),
-      partition_(partition) {
+      partition_(partition),
+      process_launched_(false) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   DCHECK(resource_context_);
   process_.reset(
       new BrowserChildProcessHostImpl(PROCESS_TYPE_WORKER, this));
 }
 
 WorkerProcessHost::~WorkerProcessHost() {
   // If we crashed, tell the RenderViewHosts.
   for (Instances::iterator i = instances_.begin(); i != instances_.end(); ++i) {
     const WorkerDocumentSet::DocumentInfoSet& parents =
@@ skipping 183 matching lines @@
     if (!i->closed() && i->HasFilter(filter, message.routing_id())) {
       RelayMessage(message, worker_message_filter_, i->worker_route_id());
       return true;
     }
   }
 
   return false;
 }
 
 void WorkerProcessHost::OnProcessLaunched() {
+  process_launched_ = true;
+
+  WorkerServiceImpl::GetInstance()->NotifyWorkerProcessCreated();
 }
 
 bool WorkerProcessHost::OnMessageReceived(const IPC::Message& message) {
   bool msg_is_ok = true;
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP_EX(WorkerProcessHost, message, msg_is_ok)
     IPC_MESSAGE_HANDLER(WorkerHostMsg_WorkerContextClosed,
                         OnWorkerContextClosed)
     IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowDatabase, OnAllowDatabase)
     IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowFileSystem, OnAllowFileSystem)
@@ skipping 200 matching lines @@
     } else {
       ++i;
     }
   }
 }
 
 void WorkerProcessHost::TerminateWorker(int worker_route_id) {
   Send(new WorkerMsg_TerminateWorkerContext(worker_route_id));
 }
 
+void WorkerProcessHost::SetBackgrounded(bool backgrounded) {
+  process_->SetBackgrounded(backgrounded);
+}
+
 const ChildProcessData& WorkerProcessHost::GetData() {
   return process_->GetData();
 }
 
+bool WorkerProcessHost::process_launched() const {
+  return process_launched_;
+}
+
 std::vector<std::pair<int, int> > WorkerProcessHost::GetRenderViewIDsForWorker(
     int worker_route_id) {
   std::vector<std::pair<int, int> > result;
   WorkerProcessHost::Instances::const_iterator i;
   for (i = instances_.begin(); i != instances_.end(); ++i) {
     if (i->worker_route_id() != worker_route_id)
       continue;
     const WorkerDocumentSet::DocumentInfoSet& documents =
         i->worker_document_set()->documents();
     for (WorkerDocumentSet::DocumentInfoSet::const_iterator doc =
@@ skipping 136 matching lines @@
   return false;
 }
 
 WorkerProcessHost::WorkerInstance::FilterInfo
 WorkerProcessHost::WorkerInstance::GetFilter() const {
   DCHECK(NumFilters() == 1);
   return *filters_.begin();
 }
 
 }  // namespace content