| Index: android_webview/browser/net/android_stream_reader_url_request_job.h
|
| diff --git a/android_webview/browser/net/android_stream_reader_url_request_job.h b/android_webview/browser/net/android_stream_reader_url_request_job.h
|
| index e2049edc3b8665a0d31f8ec531493c2648d00f28..87a6c8cce70a38e0234564f97e7079ce338db006 100644
|
| --- a/android_webview/browser/net/android_stream_reader_url_request_job.h
|
| +++ b/android_webview/browser/net/android_stream_reader_url_request_job.h
|
| @@ -2,12 +2,13 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#ifndef ANDROID_WEBVIEW_NATIVE_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
| -#define ANDROID_WEBVIEW_NATIVE_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
| +#ifndef ANDROID_WEBVIEW_BROWSER_NET_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
| +#define ANDROID_WEBVIEW_BROWSER_NET_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
|
|
| #include <string>
|
|
|
| #include "base/android/scoped_java_ref.h"
|
| +#include "base/callback_forward.h"
|
| #include "base/location.h"
|
| #include "base/memory/ref_counted.h"
|
| #include "base/memory/scoped_ptr.h"
|
| @@ -28,6 +29,7 @@ class URLRequest;
|
|
|
| namespace android_webview {
|
|
|
| +class AwWebResourceResponse;
|
| class InputStream;
|
| class InputStreamReader;
|
| class InputStreamReaderWrapper;
|
| @@ -74,8 +76,13 @@ class AndroidStreamReaderURLRequestJob : public net::URLRequestJob {
|
|
|
| AndroidStreamReaderURLRequestJob(
|
| net::URLRequest* request,
|
| + net::NetworkDelegate* network_delegate);
|
| + AndroidStreamReaderURLRequestJob(
|
| + net::URLRequest* request,
|
| net::NetworkDelegate* network_delegate,
|
| scoped_ptr<Delegate> delegate);
|
| + base::Callback<void(scoped_ptr<AwWebResourceResponse>)>
|
| + GetWebResourceResponseCallback();
|
|
|
| // URLRequestJob:
|
| void Start() override;
|
| @@ -100,6 +107,9 @@ class AndroidStreamReaderURLRequestJob : public net::URLRequestJob {
|
| CreateStreamReader(android_webview::InputStream* stream);
|
|
|
| private:
|
| + void WebResourceResponseObtained(scoped_ptr<AwWebResourceResponse> response);
|
| + void MaybeStart();
|
| +
|
| void HeadersComplete(int status_code, const std::string& status_text);
|
|
|
| void OnInputStreamOpened(
|
| @@ -108,11 +118,16 @@ class AndroidStreamReaderURLRequestJob : public net::URLRequestJob {
|
| void OnReaderSeekCompleted(int content_size);
|
| void OnReaderReadCompleted(int bytes_read);
|
|
|
| + bool has_been_started() { return has_been_started_; }
|
| + bool has_been_killed() { return has_been_killed_; }
|
| +
|
| net::HttpByteRange byte_range_;
|
| scoped_ptr<net::HttpResponseInfo> response_info_;
|
| scoped_ptr<Delegate> delegate_;
|
| scoped_refptr<InputStreamReaderWrapper> input_stream_reader_wrapper_;
|
| base::ThreadChecker thread_checker_;
|
| + bool has_been_started_;
|
| + bool has_been_killed_;
|
|
|
| base::WeakPtrFactory<AndroidStreamReaderURLRequestJob> weak_factory_;
|
|
|
| @@ -121,4 +136,4 @@ class AndroidStreamReaderURLRequestJob : public net::URLRequestJob {
|
|
|
| } // namespace android_webview
|
|
|
| -#endif // ANDROID_WEBVIEW_NATIVE_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
| +#endif // ANDROID_WEBVIEW_BROWSER_NET_ANDROID_STREAM_READER_URL_REQUEST_JOB_H_
|
|
|