OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/logging.h" | 5 #include "base/logging.h" |
| 6 #include "chrome/browser/browser_process.h" |
6 #include "chrome/browser/prerender/prerender_manager.h" | 7 #include "chrome/browser/prerender/prerender_manager.h" |
7 #include "chrome/browser/prerender/prerender_tracker.h" | 8 #include "chrome/browser/prerender/prerender_tracker.h" |
8 #include "content/browser/browser_thread.h" | 9 #include "content/browser/browser_thread.h" |
| 10 #include "content/browser/resource_context.h" |
| 11 #include "content/common/resource_messages.h" |
| 12 #include "net/base/load_flags.h" |
9 | 13 |
10 namespace prerender { | 14 namespace prerender { |
11 | 15 |
12 namespace { | 16 PrerenderTracker::RenderViewInfo::RenderViewInfo( |
13 | 17 PrerenderManager* prerender_manager) |
14 void DestroyPreloadForRenderView( | 18 : final_status(FINAL_STATUS_MAX), |
15 const base::WeakPtr<PrerenderManager>& prerender_manager_weak_ptr, | 19 prerender_manager(prerender_manager->AsWeakPtr()) { |
16 int child_id, | |
17 int route_id, | |
18 FinalStatus final_status) { | |
19 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
20 PrerenderManager* prerender_manager = prerender_manager_weak_ptr.get(); | |
21 if (!prerender_manager) | |
22 return; | |
23 | |
24 prerender_manager->DestroyPreloadForChildRouteIdPair( | |
25 std::make_pair(child_id, route_id), | |
26 final_status); | |
27 } | 20 } |
28 | 21 |
29 } // namespace | 22 PrerenderTracker::RenderViewInfo::~RenderViewInfo() { |
| 23 } |
30 | 24 |
31 struct RenderViewInfo { | 25 PrerenderTracker::PrerenderTracker() { |
32 explicit RenderViewInfo(PrerenderManager* prerender_manager) | 26 } |
33 : final_status(FINAL_STATUS_MAX), | |
34 prerender_manager(prerender_manager->AsWeakPtr()) { | |
35 } | |
36 | 27 |
37 FinalStatus final_status; | 28 PrerenderTracker::~PrerenderTracker() { |
38 base::WeakPtr<PrerenderManager> prerender_manager; | |
39 }; | |
40 | |
41 // static | |
42 PrerenderTracker* PrerenderTracker::GetInstance() { | |
43 return Singleton<PrerenderTracker>::get(); | |
44 } | 29 } |
45 | 30 |
46 bool PrerenderTracker::TryUse(int child_id, int route_id) { | 31 bool PrerenderTracker::TryUse(int child_id, int route_id) { |
47 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 32 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
48 | 33 |
49 return SetFinalStatus(child_id, route_id, FINAL_STATUS_USED, NULL); | 34 return SetFinalStatus(child_id, route_id, FINAL_STATUS_USED, NULL); |
50 } | 35 } |
51 | 36 |
52 bool PrerenderTracker::TryCancel( | 37 bool PrerenderTracker::TryCancel( |
53 int child_id, | 38 int child_id, |
(...skipping 13 matching lines...) Expand all Loading... |
67 int route_id, | 52 int route_id, |
68 FinalStatus final_status) { | 53 FinalStatus final_status) { |
69 DCHECK_NE(FINAL_STATUS_USED, final_status); | 54 DCHECK_NE(FINAL_STATUS_USED, final_status); |
70 DCHECK(final_status >= 0 && final_status < FINAL_STATUS_MAX); | 55 DCHECK(final_status >= 0 && final_status < FINAL_STATUS_MAX); |
71 | 56 |
72 if (!IsPrerenderingOnIOThread(child_id, route_id)) | 57 if (!IsPrerenderingOnIOThread(child_id, route_id)) |
73 return false; | 58 return false; |
74 return TryCancel(child_id, route_id, final_status); | 59 return TryCancel(child_id, route_id, final_status); |
75 } | 60 } |
76 | 61 |
77 bool PrerenderTracker::IsPrerenderingOnIOThread(int child_id, | |
78 int route_id) const { | |
79 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | |
80 | |
81 ChildRouteIdPair child_route_id_pair(child_id, route_id); | |
82 return possibly_prerendering_io_thread_set_.end() != | |
83 possibly_prerendering_io_thread_set_.find(child_route_id_pair); | |
84 } | |
85 | |
86 bool PrerenderTracker::GetFinalStatus(int child_id, int route_id, | 62 bool PrerenderTracker::GetFinalStatus(int child_id, int route_id, |
87 FinalStatus* final_status) const { | 63 FinalStatus* final_status) const { |
88 ChildRouteIdPair child_route_id_pair(child_id, route_id); | 64 ChildRouteIdPair child_route_id_pair(child_id, route_id); |
89 | 65 |
90 base::AutoLock lock(final_status_map_lock_); | 66 base::AutoLock lock(final_status_map_lock_); |
91 FinalStatusMap::const_iterator final_status_it = | 67 FinalStatusMap::const_iterator final_status_it = |
92 final_status_map_.find(child_route_id_pair); | 68 final_status_map_.find(child_route_id_pair); |
93 if (final_status_map_.end() == final_status_map_.find(child_route_id_pair)) | 69 if (final_status_map_.end() == final_status_map_.find(child_route_id_pair)) |
94 return false; | 70 return false; |
95 *final_status = final_status_it->second.final_status; | 71 *final_status = final_status_it->second.final_status; |
(...skipping 15 matching lines...) Expand all Loading... |
111 BrowserThread::PostTask( | 87 BrowserThread::PostTask( |
112 BrowserThread::IO, FROM_HERE, | 88 BrowserThread::IO, FROM_HERE, |
113 NewRunnableFunction(&AddPrerenderOnIOThreadTask, child_route_id_pair)); | 89 NewRunnableFunction(&AddPrerenderOnIOThreadTask, child_route_id_pair)); |
114 | 90 |
115 base::AutoLock lock(final_status_map_lock_); | 91 base::AutoLock lock(final_status_map_lock_); |
116 | 92 |
117 final_status_map_.insert( | 93 final_status_map_.insert( |
118 std::make_pair(child_route_id_pair, RenderViewInfo(prerender_manager))); | 94 std::make_pair(child_route_id_pair, RenderViewInfo(prerender_manager))); |
119 } | 95 } |
120 | 96 |
121 PrerenderTracker::PrerenderTracker() { | |
122 } | |
123 | |
124 PrerenderTracker::~PrerenderTracker() { | |
125 } | |
126 | |
127 void PrerenderTracker::OnPrerenderingFinished(int child_id, int route_id) { | 97 void PrerenderTracker::OnPrerenderingFinished(int child_id, int route_id) { |
128 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 98 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
129 DCHECK_GE(child_id, 0); | 99 DCHECK_GE(child_id, 0); |
130 DCHECK_GE(route_id, 0); | 100 DCHECK_GE(route_id, 0); |
131 | 101 |
132 ChildRouteIdPair child_route_id_pair(child_id, route_id); | 102 ChildRouteIdPair child_route_id_pair(child_id, route_id); |
133 | 103 |
134 BrowserThread::PostTask( | 104 BrowserThread::PostTask( |
135 BrowserThread::IO, FROM_HERE, | 105 BrowserThread::IO, FROM_HERE, |
136 NewRunnableFunction(&RemovePrerenderOnIOThreadTask, child_route_id_pair)); | 106 NewRunnableFunction(&RemovePrerenderOnIOThreadTask, child_route_id_pair)); |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
173 if (actual_final_status) | 143 if (actual_final_status) |
174 *actual_final_status = desired_final_status; | 144 *actual_final_status = desired_final_status; |
175 return true; | 145 return true; |
176 } | 146 } |
177 | 147 |
178 if (actual_final_status) | 148 if (actual_final_status) |
179 *actual_final_status = final_status_it->second.final_status; | 149 *actual_final_status = final_status_it->second.final_status; |
180 return false; | 150 return false; |
181 } | 151 } |
182 | 152 |
| 153 bool PrerenderTracker::IsPrerenderingOnIOThread(int child_id, |
| 154 int route_id) const { |
| 155 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 156 |
| 157 ChildRouteIdPair child_route_id_pair(child_id, route_id); |
| 158 return possibly_prerendering_io_thread_set_.end() != |
| 159 possibly_prerendering_io_thread_set_.find(child_route_id_pair); |
| 160 } |
| 161 |
183 void PrerenderTracker::AddPrerenderOnIOThread( | 162 void PrerenderTracker::AddPrerenderOnIOThread( |
184 const ChildRouteIdPair& child_route_id_pair) { | 163 const ChildRouteIdPair& child_route_id_pair) { |
185 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 164 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
186 DCHECK(!IsPrerenderingOnIOThread(child_route_id_pair.first, | 165 DCHECK(!IsPrerenderingOnIOThread(child_route_id_pair.first, |
187 child_route_id_pair.second)); | 166 child_route_id_pair.second)); |
188 | 167 |
189 possibly_prerendering_io_thread_set_.insert(child_route_id_pair); | 168 possibly_prerendering_io_thread_set_.insert(child_route_id_pair); |
190 } | 169 } |
191 | 170 |
192 void PrerenderTracker::RemovePrerenderOnIOThread( | 171 void PrerenderTracker::RemovePrerenderOnIOThread( |
193 const ChildRouteIdPair& child_route_id_pair) { | 172 const ChildRouteIdPair& child_route_id_pair) { |
194 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 173 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
195 DCHECK(IsPrerenderingOnIOThread(child_route_id_pair.first, | 174 DCHECK(IsPrerenderingOnIOThread(child_route_id_pair.first, |
196 child_route_id_pair.second)); | 175 child_route_id_pair.second)); |
197 | 176 |
198 possibly_prerendering_io_thread_set_.erase(child_route_id_pair); | 177 possibly_prerendering_io_thread_set_.erase(child_route_id_pair); |
199 } | 178 } |
200 | 179 |
201 // static | 180 // static |
202 void PrerenderTracker::AddPrerenderOnIOThreadTask( | 181 void PrerenderTracker::AddPrerenderOnIOThreadTask( |
203 const ChildRouteIdPair& child_route_id_pair) { | 182 const ChildRouteIdPair& child_route_id_pair) { |
204 GetInstance()->AddPrerenderOnIOThread(child_route_id_pair); | 183 g_browser_process->prerender_tracker()->AddPrerenderOnIOThread( |
| 184 child_route_id_pair); |
205 } | 185 } |
206 | 186 |
207 // static | 187 // static |
208 void PrerenderTracker::RemovePrerenderOnIOThreadTask( | 188 void PrerenderTracker::RemovePrerenderOnIOThreadTask( |
209 const ChildRouteIdPair& child_route_id_pair) { | 189 const ChildRouteIdPair& child_route_id_pair) { |
210 GetInstance()->RemovePrerenderOnIOThread(child_route_id_pair); | 190 g_browser_process->prerender_tracker()->RemovePrerenderOnIOThread( |
| 191 child_route_id_pair); |
211 } | 192 } |
212 | 193 |
213 } // namespace prerender | 194 } // namespace prerender |
OLD | NEW |