Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(199)

Side by Side Diff: mojo/shell/ui_service_loader_android.cc

Issue 423963004: First cut at "content handling" support in Mojo. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Use URLResponse with ContentHandler interface instead of data pipe Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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/ui_service_loader_android.h" 5 #include "mojo/shell/ui_service_loader_android.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "mojo/service_manager/service_manager.h" 8 #include "mojo/service_manager/service_manager.h"
9 #include "mojo/shell/context.h" 9 #include "mojo/shell/context.h"
10 10
11 namespace mojo { 11 namespace mojo {
12 12
13 class UIServiceLoader::UILoader { 13 class UIServiceLoader::UILoader {
14 public: 14 public:
15 explicit UILoader(ServiceLoader* loader) : loader_(loader) {} 15 explicit UILoader(ServiceLoader* loader) : loader_(loader) {}
16 ~UILoader() {} 16 ~UILoader() {}
17 17
18 void LoadService(ServiceManager* manager, 18 void LoadService(ServiceManager* manager,
19 const GURL& url, 19 const GURL& url,
20 ScopedMessagePipeHandle shell_handle) { 20 ScopedMessagePipeHandle shell_handle) {
21 loader_->LoadService(manager, url, shell_handle.Pass()); 21 scoped_refptr<LoadServiceCallbacks> callbacks(
22 new ServiceLoader::SimpleLoadServiceCallbacks(shell_handle.Pass()));
23 loader_->LoadService(manager, url, callbacks);
22 } 24 }
23 25
24 void OnServiceError(ServiceManager* manager, const GURL& url) { 26 void OnServiceError(ServiceManager* manager, const GURL& url) {
25 loader_->OnServiceError(manager, url); 27 loader_->OnServiceError(manager, url);
26 } 28 }
27 29
28 private: 30 private:
29 ServiceLoader* loader_; // Owned by UIServiceLoader 31 ServiceLoader* loader_; // Owned by UIServiceLoader
30 32
31 DISALLOW_COPY_AND_ASSIGN(UILoader); 33 DISALLOW_COPY_AND_ASSIGN(UILoader);
32 }; 34 };
33 35
34 UIServiceLoader::UIServiceLoader(scoped_ptr<ServiceLoader> real_loader, 36 UIServiceLoader::UIServiceLoader(scoped_ptr<ServiceLoader> real_loader,
35 shell::Context* context) 37 shell::Context* context)
36 : loader_(real_loader.Pass()), context_(context) { 38 : loader_(real_loader.Pass()), context_(context) {
37 } 39 }
38 40
39 UIServiceLoader::~UIServiceLoader() { 41 UIServiceLoader::~UIServiceLoader() {
40 context_->ui_loop()->PostTask( 42 context_->ui_loop()->PostTask(
41 FROM_HERE, 43 FROM_HERE,
42 base::Bind(&UIServiceLoader::ShutdownOnUIThread, base::Unretained(this))); 44 base::Bind(&UIServiceLoader::ShutdownOnUIThread, base::Unretained(this)));
43 } 45 }
44 46
45 void UIServiceLoader::LoadService(ServiceManager* manager, 47 void UIServiceLoader::LoadService(
46 const GURL& url, 48 ServiceManager* manager,
47 ScopedMessagePipeHandle shell_handle) { 49 const GURL& url,
50 scoped_refptr<LoadServiceCallbacks> callbacks) {
51 ScopedMessagePipeHandle shell_handle = callbacks->RegisterApplication();
52 if (!shell_handle.is_valid()) {
DaveMoore 2014/08/04 21:50:52 Nit: no braces
Aaron Boodman 2014/08/05 05:44:55 Done.
53 return;
54 }
48 context_->ui_loop()->PostTask( 55 context_->ui_loop()->PostTask(
49 FROM_HERE, 56 FROM_HERE,
50 base::Bind( 57 base::Bind(
51 &UIServiceLoader::LoadServiceOnUIThread, 58 &UIServiceLoader::LoadServiceOnUIThread,
52 base::Unretained(this), 59 base::Unretained(this),
53 manager, 60 manager,
54 url, 61 url,
55 base::Owned(new ScopedMessagePipeHandle(shell_handle.Pass())))); 62 shell_handle.Pass()));
56 } 63 }
57 64
58 void UIServiceLoader::OnServiceError(ServiceManager* manager, const GURL& url) { 65 void UIServiceLoader::OnServiceError(ServiceManager* manager, const GURL& url) {
59 context_->ui_loop()->PostTask( 66 context_->ui_loop()->PostTask(
60 FROM_HERE, 67 FROM_HERE,
61 base::Bind(&UIServiceLoader::OnServiceErrorOnUIThread, 68 base::Bind(&UIServiceLoader::OnServiceErrorOnUIThread,
62 base::Unretained(this), 69 base::Unretained(this),
63 manager, 70 manager,
64 url)); 71 url));
65 } 72 }
66 73
67 void UIServiceLoader::LoadServiceOnUIThread( 74 void UIServiceLoader::LoadServiceOnUIThread(
68 ServiceManager* manager, 75 ServiceManager* manager,
69 const GURL& url, 76 const GURL& url,
70 ScopedMessagePipeHandle* shell_handle) { 77 ScopedMessagePipeHandle shell_handle) {
71 if (!ui_loader_) 78 if (!ui_loader_)
72 ui_loader_ = new UILoader(loader_.get()); 79 ui_loader_ = new UILoader(loader_.get());
73 ui_loader_->LoadService(manager, url, shell_handle->Pass()); 80 ui_loader_->LoadService(manager, url, shell_handle.Pass());
74 } 81 }
75 82
76 void UIServiceLoader::OnServiceErrorOnUIThread(ServiceManager* manager, 83 void UIServiceLoader::OnServiceErrorOnUIThread(ServiceManager* manager,
77 const GURL& url) { 84 const GURL& url) {
78 if (!ui_loader_) 85 if (!ui_loader_)
79 ui_loader_ = new UILoader(loader_.get()); 86 ui_loader_ = new UILoader(loader_.get());
80 ui_loader_->OnServiceError(manager, url); 87 ui_loader_->OnServiceError(manager, url);
81 } 88 }
82 89
83 void UIServiceLoader::ShutdownOnUIThread() { 90 void UIServiceLoader::ShutdownOnUIThread() {
84 delete ui_loader_; 91 delete ui_loader_;
85 // Destroy |loader_| on the thread it's actually used on. 92 // Destroy |loader_| on the thread it's actually used on.
86 loader_.reset(); 93 loader_.reset();
87 } 94 }
88 95
89 } // namespace mojo 96 } // namespace mojo
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698