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 "content/browser/appcache/appcache_dispatcher_host.h" | 5 #include "content/browser/appcache/appcache_dispatcher_host.h" |
6 | 6 |
7 #include "base/callback.h" | 7 #include "base/callback.h" |
8 #include "chrome/browser/metrics/user_metrics.h" | 8 #include "chrome/browser/metrics/user_metrics.h" |
9 #include "chrome/browser/net/chrome_url_request_context.h" | 9 #include "chrome/browser/net/chrome_url_request_context.h" |
10 #include "chrome/browser/renderer_host/browser_render_process_host.h" | 10 #include "chrome/browser/renderer_host/browser_render_process_host.h" |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
56 NewCallback(this, &AppCacheDispatcherHost::SwapCacheCallback)); | 56 NewCallback(this, &AppCacheDispatcherHost::SwapCacheCallback)); |
57 } | 57 } |
58 } | 58 } |
59 | 59 |
60 bool AppCacheDispatcherHost::OnMessageReceived(const IPC::Message& message, | 60 bool AppCacheDispatcherHost::OnMessageReceived(const IPC::Message& message, |
61 bool* message_was_ok) { | 61 bool* message_was_ok) { |
62 bool handled = true; | 62 bool handled = true; |
63 IPC_BEGIN_MESSAGE_MAP_EX(AppCacheDispatcherHost, message, *message_was_ok) | 63 IPC_BEGIN_MESSAGE_MAP_EX(AppCacheDispatcherHost, message, *message_was_ok) |
64 IPC_MESSAGE_HANDLER(AppCacheHostMsg_RegisterHost, OnRegisterHost) | 64 IPC_MESSAGE_HANDLER(AppCacheHostMsg_RegisterHost, OnRegisterHost) |
65 IPC_MESSAGE_HANDLER(AppCacheHostMsg_UnregisterHost, OnUnregisterHost) | 65 IPC_MESSAGE_HANDLER(AppCacheHostMsg_UnregisterHost, OnUnregisterHost) |
| 66 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SetSpawningHostId, OnSetSpawningHostId) |
66 IPC_MESSAGE_HANDLER(AppCacheHostMsg_GetResourceList, OnGetResourceList) | 67 IPC_MESSAGE_HANDLER(AppCacheHostMsg_GetResourceList, OnGetResourceList) |
67 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCache, OnSelectCache) | 68 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCache, OnSelectCache) |
68 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCacheForWorker, | 69 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCacheForWorker, |
69 OnSelectCacheForWorker) | 70 OnSelectCacheForWorker) |
70 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCacheForSharedWorker, | 71 IPC_MESSAGE_HANDLER(AppCacheHostMsg_SelectCacheForSharedWorker, |
71 OnSelectCacheForSharedWorker) | 72 OnSelectCacheForSharedWorker) |
72 IPC_MESSAGE_HANDLER(AppCacheHostMsg_MarkAsForeignEntry, | 73 IPC_MESSAGE_HANDLER(AppCacheHostMsg_MarkAsForeignEntry, |
73 OnMarkAsForeignEntry) | 74 OnMarkAsForeignEntry) |
74 IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheHostMsg_GetStatus, OnGetStatus) | 75 IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheHostMsg_GetStatus, OnGetStatus) |
75 IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheHostMsg_StartUpdate, OnStartUpdate) | 76 IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheHostMsg_StartUpdate, OnStartUpdate) |
(...skipping 18 matching lines...) Expand all Loading... |
94 } | 95 } |
95 | 96 |
96 void AppCacheDispatcherHost::OnUnregisterHost(int host_id) { | 97 void AppCacheDispatcherHost::OnUnregisterHost(int host_id) { |
97 if (appcache_service_.get()) { | 98 if (appcache_service_.get()) { |
98 if (!backend_impl_.UnregisterHost(host_id)) { | 99 if (!backend_impl_.UnregisterHost(host_id)) { |
99 BadMessageReceived(); | 100 BadMessageReceived(); |
100 } | 101 } |
101 } | 102 } |
102 } | 103 } |
103 | 104 |
| 105 void AppCacheDispatcherHost::OnSetSpawningHostId( |
| 106 int host_id, int spawning_host_id) { |
| 107 if (appcache_service_.get()) { |
| 108 if (!backend_impl_.SetSpawningHostId(host_id, spawning_host_id)) |
| 109 BadMessageReceived(); |
| 110 } |
| 111 } |
| 112 |
104 void AppCacheDispatcherHost::OnSelectCache( | 113 void AppCacheDispatcherHost::OnSelectCache( |
105 int host_id, const GURL& document_url, | 114 int host_id, const GURL& document_url, |
106 int64 cache_document_was_loaded_from, | 115 int64 cache_document_was_loaded_from, |
107 const GURL& opt_manifest_url) { | 116 const GURL& opt_manifest_url) { |
108 if (appcache_service_.get()) { | 117 if (appcache_service_.get()) { |
109 if (!backend_impl_.SelectCache(host_id, document_url, | 118 if (!backend_impl_.SelectCache(host_id, document_url, |
110 cache_document_was_loaded_from, | 119 cache_document_was_loaded_from, |
111 opt_manifest_url)) { | 120 opt_manifest_url)) { |
112 BadMessageReceived(); | 121 BadMessageReceived(); |
113 } | 122 } |
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
229 AppCacheHostMsg_StartUpdate::WriteReplyParams(reply_msg, result); | 238 AppCacheHostMsg_StartUpdate::WriteReplyParams(reply_msg, result); |
230 Send(pending_reply_msg_.release()); | 239 Send(pending_reply_msg_.release()); |
231 } | 240 } |
232 | 241 |
233 void AppCacheDispatcherHost::SwapCacheCallback(bool result, void* param) { | 242 void AppCacheDispatcherHost::SwapCacheCallback(bool result, void* param) { |
234 IPC::Message* reply_msg = reinterpret_cast<IPC::Message*>(param); | 243 IPC::Message* reply_msg = reinterpret_cast<IPC::Message*>(param); |
235 DCHECK_EQ(pending_reply_msg_.get(), reply_msg); | 244 DCHECK_EQ(pending_reply_msg_.get(), reply_msg); |
236 AppCacheHostMsg_SwapCache::WriteReplyParams(reply_msg, result); | 245 AppCacheHostMsg_SwapCache::WriteReplyParams(reply_msg, result); |
237 Send(pending_reply_msg_.release()); | 246 Send(pending_reply_msg_.release()); |
238 } | 247 } |
OLD | NEW |