| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 #ifndef CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ | 5 #ifndef CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ |
| 6 #define CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ | 6 #define CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 // when LoadingWithMojo runtime flag is enabled. | 45 // when LoadingWithMojo runtime flag is enabled. |
| 46 // | 46 // |
| 47 // TODO(yhirano): Add histograms. | 47 // TODO(yhirano): Add histograms. |
| 48 // TODO(yhirano): Send cached metadata. | 48 // TODO(yhirano): Send cached metadata. |
| 49 // | 49 // |
| 50 // This class can be inherited only for tests. | 50 // This class can be inherited only for tests. |
| 51 class CONTENT_EXPORT MojoAsyncResourceHandler | 51 class CONTENT_EXPORT MojoAsyncResourceHandler |
| 52 : public ResourceHandler, | 52 : public ResourceHandler, |
| 53 public NON_EXPORTED_BASE(mojom::URLLoader) { | 53 public NON_EXPORTED_BASE(mojom::URLLoader) { |
| 54 public: | 54 public: |
| 55 MojoAsyncResourceHandler( | 55 MojoAsyncResourceHandler(net::URLRequest* request, |
| 56 net::URLRequest* request, | 56 ResourceDispatcherHostImpl* rdh, |
| 57 ResourceDispatcherHostImpl* rdh, | 57 mojom::URLLoaderAssociatedRequest mojo_request, |
| 58 mojom::URLLoaderAssociatedRequest mojo_request, | 58 mojom::URLLoaderClientPtr url_loader_client, |
| 59 mojom::URLLoaderClientAssociatedPtr url_loader_client, | 59 ResourceType resource_type); |
| 60 ResourceType resource_type); | |
| 61 ~MojoAsyncResourceHandler() override; | 60 ~MojoAsyncResourceHandler() override; |
| 62 | 61 |
| 63 // ResourceHandler implementation: | 62 // ResourceHandler implementation: |
| 64 void OnRequestRedirected( | 63 void OnRequestRedirected( |
| 65 const net::RedirectInfo& redirect_info, | 64 const net::RedirectInfo& redirect_info, |
| 66 ResourceResponse* response, | 65 ResourceResponse* response, |
| 67 std::unique_ptr<ResourceController> controller) override; | 66 std::unique_ptr<ResourceController> controller) override; |
| 68 void OnResponseStarted( | 67 void OnResponseStarted( |
| 69 ResourceResponse* response, | 68 ResourceResponse* response, |
| 70 std::unique_ptr<ResourceController> controller) override; | 69 std::unique_ptr<ResourceController> controller) override; |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 115 // |reported_total_received_bytes_|. | 114 // |reported_total_received_bytes_|. |
| 116 int64_t CalculateRecentlyReceivedBytes(); | 115 int64_t CalculateRecentlyReceivedBytes(); |
| 117 | 116 |
| 118 // These functions can be overriden only for tests. | 117 // These functions can be overriden only for tests. |
| 119 virtual void ReportBadMessage(const std::string& error); | 118 virtual void ReportBadMessage(const std::string& error); |
| 120 virtual std::unique_ptr<UploadProgressTracker> CreateUploadProgressTracker( | 119 virtual std::unique_ptr<UploadProgressTracker> CreateUploadProgressTracker( |
| 121 const tracked_objects::Location& from_here, | 120 const tracked_objects::Location& from_here, |
| 122 UploadProgressTracker::UploadProgressReportCallback callback); | 121 UploadProgressTracker::UploadProgressReportCallback callback); |
| 123 | 122 |
| 124 void OnTransfer(mojom::URLLoaderAssociatedRequest mojo_request, | 123 void OnTransfer(mojom::URLLoaderAssociatedRequest mojo_request, |
| 125 mojom::URLLoaderClientAssociatedPtr url_loader_client); | 124 mojom::URLLoaderClientPtr url_loader_client); |
| 126 void SendUploadProgress(const net::UploadProgress& progress); | 125 void SendUploadProgress(const net::UploadProgress& progress); |
| 127 void OnUploadProgressACK(); | 126 void OnUploadProgressACK(); |
| 128 | 127 |
| 129 ResourceDispatcherHostImpl* rdh_; | 128 ResourceDispatcherHostImpl* rdh_; |
| 130 mojo::AssociatedBinding<mojom::URLLoader> binding_; | 129 mojo::AssociatedBinding<mojom::URLLoader> binding_; |
| 131 | 130 |
| 132 bool has_checked_for_sufficient_resources_ = false; | 131 bool has_checked_for_sufficient_resources_ = false; |
| 133 bool sent_received_response_message_ = false; | 132 bool sent_received_response_message_ = false; |
| 134 bool is_using_io_buffer_not_from_writer_ = false; | 133 bool is_using_io_buffer_not_from_writer_ = false; |
| 135 bool did_defer_on_writing_ = false; | 134 bool did_defer_on_writing_ = false; |
| 136 bool did_defer_on_redirect_ = false; | 135 bool did_defer_on_redirect_ = false; |
| 137 base::TimeTicks response_started_ticks_; | 136 base::TimeTicks response_started_ticks_; |
| 138 int64_t reported_total_received_bytes_ = 0; | 137 int64_t reported_total_received_bytes_ = 0; |
| 139 | 138 |
| 140 mojo::Watcher handle_watcher_; | 139 mojo::Watcher handle_watcher_; |
| 141 std::unique_ptr<mojom::URLLoader> url_loader_; | 140 std::unique_ptr<mojom::URLLoader> url_loader_; |
| 142 mojom::URLLoaderClientAssociatedPtr url_loader_client_; | 141 mojom::URLLoaderClientPtr url_loader_client_; |
| 143 scoped_refptr<net::IOBufferWithSize> buffer_; | 142 scoped_refptr<net::IOBufferWithSize> buffer_; |
| 144 size_t buffer_offset_ = 0; | 143 size_t buffer_offset_ = 0; |
| 145 size_t buffer_bytes_read_ = 0; | 144 size_t buffer_bytes_read_ = 0; |
| 146 scoped_refptr<SharedWriter> shared_writer_; | 145 scoped_refptr<SharedWriter> shared_writer_; |
| 147 mojo::ScopedDataPipeConsumerHandle response_body_consumer_handle_; | 146 mojo::ScopedDataPipeConsumerHandle response_body_consumer_handle_; |
| 148 | 147 |
| 149 std::unique_ptr<UploadProgressTracker> upload_progress_tracker_; | 148 std::unique_ptr<UploadProgressTracker> upload_progress_tracker_; |
| 150 | 149 |
| 151 base::WeakPtrFactory<MojoAsyncResourceHandler> weak_factory_; | 150 base::WeakPtrFactory<MojoAsyncResourceHandler> weak_factory_; |
| 152 DISALLOW_COPY_AND_ASSIGN(MojoAsyncResourceHandler); | 151 DISALLOW_COPY_AND_ASSIGN(MojoAsyncResourceHandler); |
| 153 }; | 152 }; |
| 154 | 153 |
| 155 } // namespace content | 154 } // namespace content |
| 156 | 155 |
| 157 #endif // CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ | 156 #endif // CONTENT_BROWSER_LOADER_MOJO_ASYNC_RESOURCE_HANDLER_H_ |
| OLD | NEW |