Chromium Code Reviews| Index: mojo/services/html_viewer/html_viewer.cc |
| diff --git a/mojo/services/html_viewer/html_viewer.cc b/mojo/services/html_viewer/html_viewer.cc |
| index 4db44ad3714ae35c56049a7c11b65d0a054a8b09..265d2e357795e1c17b70e1739f9951328367908f 100644 |
| --- a/mojo/services/html_viewer/html_viewer.cc |
| +++ b/mojo/services/html_viewer/html_viewer.cc |
| @@ -13,11 +13,13 @@ |
| #include "mojo/public/cpp/application/application_connection.h" |
| #include "mojo/public/cpp/application/application_delegate.h" |
| #include "mojo/public/cpp/application/application_impl.h" |
| +#include "mojo/public/cpp/application/connect.h" |
| #include "mojo/public/cpp/application/interface_factory_impl.h" |
| #include "mojo/services/html_viewer/html_document_view.h" |
| #include "mojo/services/html_viewer/mojo_blink_platform_impl.h" |
| #include "mojo/services/html_viewer/webmediaplayer_factory.h" |
| #include "mojo/services/public/interfaces/content_handler/content_handler.mojom.h" |
| +#include "mojo/services/public/interfaces/network/network_service.mojom.h" |
| #include "third_party/WebKit/public/web/WebKit.h" |
| #if !defined(COMPONENT_BUILD) |
| @@ -32,12 +34,84 @@ namespace mojo { |
| // Switches for html_viewer to be used with "--args-for". For example: |
| // --args-for='mojo:html_viewer --enable-mojo-media-renderer' |
| -// Enable mojo::MediaRenderer in media pipeline instead of using the internal |
| +// Enable MediaRenderer in media pipeline instead of using the internal |
| // media::Renderer implementation. |
| const char kEnableMojoMediaRenderer[] = "enable-mojo-media-renderer"; |
| class HTMLViewer; |
| +class HTMLViewerApplication : public Application { |
| + public: |
| + HTMLViewerApplication(ShellPtr shell, |
| + URLResponsePtr response, |
| + scoped_refptr<base::MessageLoopProxy> compositor_thread, |
| + WebMediaPlayerFactory* web_media_player_factory) |
| + : url_(response->url), |
| + shell_(shell.Pass()), |
| + initial_response_(response.Pass()), |
| + compositor_thread_(compositor_thread), |
| + web_media_player_factory_(web_media_player_factory), |
| + view_count_(0) { |
| + shell_.set_client(this); |
| + ServiceProviderPtr service_provider; |
| + shell_->ConnectToApplication("mojo:network_service", |
| + GetProxy(&service_provider)); |
| + ConnectToService(service_provider.get(), &network_service_); |
| + } |
| + |
| + void Initialize(Array<String> args) override {} |
| + |
| + void AcceptConnection(const String& requestor_url, |
| + ServiceProviderPtr provider) override { |
| + ++view_count_; |
| + if (initial_response_) { |
| + OnResponseReceived(URLLoaderPtr(), provider.Pass(), |
| + initial_response_.Pass()); |
| + } else { |
| + URLLoaderPtr loader; |
| + network_service_->CreateURLLoader(GetProxy(&loader)); |
| + URLRequestPtr request(URLRequest::New()); |
| + request->url = url_; |
| + request->auto_follow_redirects = true; |
| + |
| + // |loader| will be pass to the OnResponseReceived method through a |
| + // callback. Because order of evaluation is undefined, a reference to the |
| + // raw pointer is needed. |
| + URLLoader* raw_loader = loader.get(); |
| + raw_loader->Start( |
| + request.Pass(), |
| + base::Bind(&HTMLViewerApplication::OnResponseReceived, |
| + base::Unretained(this), base::Passed(&loader), |
| + base::Passed(&provider))); |
| + } |
| + } |
| + |
| + private: |
| + void OnViewDestroyed() { |
| + --view_count_; |
| + if (view_count_ == 0) { |
| + delete this; |
| + } |
| + } |
| + |
| + void OnResponseReceived(URLLoaderPtr loader, |
| + ServiceProviderPtr provider, |
| + URLResponsePtr response) { |
| + new HTMLDocumentView(base::Bind(&HTMLViewerApplication::OnViewDestroyed, |
|
Aaron Boodman
2014/12/03 16:42:11
I know this already existed, but naming nit: this
qsr
2014/12/03 16:56:53
Done.
|
| + base::Unretained(this)), |
|
Aaron Boodman
2014/12/03 16:42:11
Won't the application crash if HTMLViewerApplicati
qsr
2014/12/03 16:56:53
HTMLViewerApplication is self owned. It can only d
Aaron Boodman
2014/12/03 17:32:37
Ah, true.
|
| + provider.Pass(), response.Pass(), shell_.get(), |
| + compositor_thread_, web_media_player_factory_); |
| + } |
| + |
| + String url_; |
| + ShellPtr shell_; |
| + NetworkServicePtr network_service_; |
| + URLResponsePtr initial_response_; |
| + scoped_refptr<base::MessageLoopProxy> compositor_thread_; |
| + WebMediaPlayerFactory* web_media_player_factory_; |
| + uint32_t view_count_; |
| +}; |
| + |
| class ContentHandlerImpl : public InterfaceImpl<ContentHandler> { |
| public: |
| ContentHandlerImpl(scoped_refptr<base::MessageLoopProxy> compositor_thread, |
| @@ -49,10 +123,8 @@ class ContentHandlerImpl : public InterfaceImpl<ContentHandler> { |
| private: |
| // Overridden from ContentHandler: |
| void StartApplication(ShellPtr shell, URLResponsePtr response) override { |
| - new HTMLDocumentView(response.Pass(), |
| - shell.Pass(), |
| - compositor_thread_, |
| - web_media_player_factory_); |
| + new HTMLViewerApplication(shell.Pass(), response.Pass(), compositor_thread_, |
| + web_media_player_factory_); |
| } |
| scoped_refptr<base::MessageLoopProxy> compositor_thread_; |