content/utility/in_process_utility_thread.cc

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/utility/in_process_utility_thread.h"
   6
   7 #include "content/child/child_process.h"
   8 #include "content/utility/utility_thread_impl.h"
   9
  10 namespace content {
  11
  12 // We want to ensure there's only one utility thread running at a time, as there
  13 // are many globals used in the utility process.
  14 static base::LazyInstance<base::Lock> g_one_utility_thread_lock;
  15
  16 InProcessUtilityThread::InProcessUtilityThread(
  17     const InProcessChildThreadParams& params)
  18     : Thread("Chrome_InProcUtilityThread"), params_(params) {
  19 }
  20
  21 InProcessUtilityThread::~InProcessUtilityThread() {
  22   // Wait till in-process utility thread finishes clean up.
  23   bool previous_value = base::ThreadRestrictions::SetIOAllowed(true);
  24   Stop();
  25   base::ThreadRestrictions::SetIOAllowed(previous_value);
  26 }
  27
  28 void InProcessUtilityThread::Init() {
  29   // We need to return right away or else the main thread that started us will
  30   // hang.
  31   base::MessageLoop::current()->PostTask(
  32       FROM_HERE,
  33       base::Bind(&InProcessUtilityThread::InitInternal,
  34                  base::Unretained(this)));
  35 }
  36
  37 void InProcessUtilityThread::CleanUp() {
  38   child_process_.reset();
  39
  40   // See comment in RendererMainThread.
  41   SetThreadWasQuitProperly(true);
  42   g_one_utility_thread_lock.Get().Release();
  43 }
  44
  45 void InProcessUtilityThread::InitInternal() {
  46   g_one_utility_thread_lock.Get().Acquire();
  47   child_process_.reset(new ChildProcess());
  48   child_process_->set_main_thread(new UtilityThreadImpl(params_));
  49 }
  50
  51 base::Thread* CreateInProcessUtilityThread(
  52     const InProcessChildThreadParams& params) {
  53   return new InProcessUtilityThread(params);
  54 }
  55
  56 }  // namespace content