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 |