blob: 46b62f44de4515194d0841c818468eece0f5728b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
// Copyright (c) 2009 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 "chrome/browser/in_process_webkit/webkit_thread.h"
#include "base/command_line.h"
#include "chrome/browser/in_process_webkit/browser_webkitclient_impl.h"
#include "chrome/common/chrome_switches.h"
#include "webkit/api/public/WebKit.h"
// This happens on the UI thread before the IO thread has been shut down.
WebKitThread::WebKitThread()
: io_message_loop_(ChromeThread::GetMessageLoop(ChromeThread::IO)) {
// The thread is started lazily by InitializeThread() on the IO thread.
}
// This happens on the UI thread after the IO thread has been shut down.
WebKitThread::~WebKitThread() {
// There's no good way to see if we're on the UI thread.
DCHECK(!ChromeThread::CurrentlyOn(ChromeThread::WEBKIT));
DCHECK(!ChromeThread::CurrentlyOn(ChromeThread::IO));
DCHECK(!io_message_loop_);
}
void WebKitThread::Shutdown() {
DCHECK(ChromeThread::CurrentlyOn(ChromeThread::IO));
DCHECK(io_message_loop_);
AutoLock lock(io_message_loop_lock_);
io_message_loop_ = NULL;
}
bool WebKitThread::PostIOThreadTask(
const tracked_objects::Location& from_here, Task* task) {
DCHECK(ChromeThread::CurrentlyOn(ChromeThread::WEBKIT));
{
AutoLock lock(io_message_loop_lock_);
if (io_message_loop_) {
io_message_loop_->PostTask(from_here, task);
return true;
}
}
delete task;
return false;
}
WebKitThread::InternalWebKitThread::InternalWebKitThread()
: ChromeThread(ChromeThread::WEBKIT) {
}
WebKitThread::InternalWebKitThread::~InternalWebKitThread() {
}
void WebKitThread::InternalWebKitThread::Init() {
DCHECK(!webkit_client_.get());
webkit_client_.reset(new BrowserWebKitClientImpl);
WebKit::initialize(webkit_client_.get());
// If possible, post initialization tasks to this thread (rather than doing
// them now) so we don't block the IO thread any longer than we have to.
}
void WebKitThread::InternalWebKitThread::CleanUp() {
DCHECK(webkit_client_.get());
WebKit::shutdown();
}
MessageLoop* WebKitThread::InitializeThread() {
if (CommandLine::ForCurrentProcess()->HasSwitch(switches::kSingleProcess))
return NULL;
DCHECK(io_message_loop_);
DCHECK(!webkit_thread_.get());
webkit_thread_.reset(new InternalWebKitThread);
bool started = webkit_thread_->Start();
DCHECK(started);
return webkit_thread_->message_loop();
}
|