| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 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 | 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 "mojo/shell/context.h" | 5 #include "mojo/shell/context.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
| (...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 152 &request); | 152 &request); |
| 153 } | 153 } |
| 154 | 154 |
| 155 scoped_refptr<gfx::GLShareGroup> share_group_; | 155 scoped_refptr<gfx::GLShareGroup> share_group_; |
| 156 scoped_refptr<gpu::gles2::MailboxManager> mailbox_manager_; | 156 scoped_refptr<gpu::gles2::MailboxManager> mailbox_manager_; |
| 157 scoped_ptr<ApplicationImpl> app_; | 157 scoped_ptr<ApplicationImpl> app_; |
| 158 DISALLOW_COPY_AND_ASSIGN(NativeViewportApplicationLoader); | 158 DISALLOW_COPY_AND_ASSIGN(NativeViewportApplicationLoader); |
| 159 }; | 159 }; |
| 160 #endif | 160 #endif |
| 161 | 161 |
| 162 Context::Context() { | 162 Context::Context() : application_manager_(this) { |
| 163 DCHECK(!base::MessageLoop::current()); | 163 DCHECK(!base::MessageLoop::current()); |
| 164 } | 164 } |
| 165 | 165 |
| 166 Context::~Context() { | 166 Context::~Context() { |
| 167 DCHECK(!base::MessageLoop::current()); | 167 DCHECK(!base::MessageLoop::current()); |
| 168 } | 168 } |
| 169 | 169 |
| 170 void Context::Init() { | 170 void Context::Init() { |
| 171 application_manager_.set_delegate(this); | |
| 172 setup.Get(); | 171 setup.Get(); |
| 173 task_runners_.reset( | 172 task_runners_.reset( |
| 174 new TaskRunners(base::MessageLoop::current()->message_loop_proxy())); | 173 new TaskRunners(base::MessageLoop::current()->message_loop_proxy())); |
| 175 | 174 |
| 176 for (size_t i = 0; i < arraysize(kLocalMojoURLs); ++i) | 175 for (size_t i = 0; i < arraysize(kLocalMojoURLs); ++i) |
| 177 mojo_url_resolver_.AddLocalFileMapping(GURL(kLocalMojoURLs[i])); | 176 mojo_url_resolver_.AddLocalFileMapping(GURL(kLocalMojoURLs[i])); |
| 178 | 177 |
| 179 base::CommandLine* command_line = base::CommandLine::ForCurrentProcess(); | 178 base::CommandLine* command_line = base::CommandLine::ForCurrentProcess(); |
| 180 | 179 |
| 181 if (command_line->HasSwitch(switches::kEnableExternalApplications)) { | 180 if (command_line->HasSwitch(switches::kEnableExternalApplications)) { |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 235 base::MessageLoop::TYPE_IO)); | 234 base::MessageLoop::TYPE_IO)); |
| 236 application_manager_.SetLoaderForURL(loader.Pass(), | 235 application_manager_.SetLoaderForURL(loader.Pass(), |
| 237 GURL("mojo:network_service")); | 236 GURL("mojo:network_service")); |
| 238 } | 237 } |
| 239 #endif | 238 #endif |
| 240 | 239 |
| 241 if (listener_) | 240 if (listener_) |
| 242 listener_->WaitForListening(); | 241 listener_->WaitForListening(); |
| 243 } | 242 } |
| 244 | 243 |
| 245 void Context::OnApplicationError(const GURL& gurl) { | 244 void Context::OnApplicationError(const GURL& url) { |
| 246 if (app_urls_.find(gurl) != app_urls_.end()) { | 245 if (app_urls_.find(url) != app_urls_.end()) { |
| 247 app_urls_.erase(gurl); | 246 app_urls_.erase(url); |
| 248 if (app_urls_.empty() && base::MessageLoop::current()->is_running()) | 247 if (app_urls_.empty() && base::MessageLoop::current()->is_running()) |
| 249 base::MessageLoop::current()->Quit(); | 248 base::MessageLoop::current()->Quit(); |
| 250 } | 249 } |
| 251 } | 250 } |
| 252 | 251 |
| 252 GURL Context::ResolveURL(const GURL& url) { |
| 253 return mojo_url_resolver_.Resolve(url); |
| 254 } |
| 255 |
| 253 void Context::Run(const GURL& url) { | 256 void Context::Run(const GURL& url) { |
| 254 EmptyServiceProvider* sp = new EmptyServiceProvider; | 257 EmptyServiceProvider* sp = new EmptyServiceProvider; |
| 255 ServiceProviderPtr spp; | 258 ServiceProviderPtr spp; |
| 256 BindToProxy(sp, &spp); | 259 BindToProxy(sp, &spp); |
| 257 | 260 |
| 258 app_urls_.insert(url); | 261 app_urls_.insert(url); |
| 259 application_manager_.ConnectToApplication(url, GURL(), spp.Pass()); | 262 application_manager_.ConnectToApplication(url, GURL(), spp.Pass()); |
| 260 } | 263 } |
| 261 | 264 |
| 262 ScopedMessagePipeHandle Context::ConnectToServiceByName( | 265 ScopedMessagePipeHandle Context::ConnectToServiceByName( |
| 263 const GURL& application_url, | 266 const GURL& application_url, |
| 264 const std::string& service_name) { | 267 const std::string& service_name) { |
| 265 app_urls_.insert(application_url); | 268 app_urls_.insert(application_url); |
| 266 return application_manager_.ConnectToServiceByName( | 269 return application_manager_.ConnectToServiceByName( |
| 267 application_url, service_name).Pass(); | 270 application_url, service_name).Pass(); |
| 268 } | 271 } |
| 269 | 272 |
| 270 } // namespace shell | 273 } // namespace shell |
| 271 } // namespace mojo | 274 } // namespace mojo |
| OLD | NEW |