2016-11-23 21:54:29 +01:00
|
|
|
diff --git net/base/network_delegate.h net/base/network_delegate.h
|
|
|
|
index 0fccae1..73e33ad 100644
|
|
|
|
--- net/base/network_delegate.h
|
|
|
|
+++ net/base/network_delegate.h
|
|
|
|
@@ -16,6 +16,7 @@
|
|
|
|
#include "net/base/completion_callback.h"
|
|
|
|
#include "net/base/net_export.h"
|
|
|
|
#include "net/cookies/canonical_cookie.h"
|
|
|
|
+#include "net/filter/source_stream.h"
|
|
|
|
#include "net/proxy/proxy_retry_info.h"
|
|
|
|
|
|
|
|
class GURL;
|
|
|
|
@@ -116,6 +117,10 @@ class NET_EXPORT NetworkDelegate : public base::NonThreadSafe {
|
2015-12-05 03:58:56 +01:00
|
|
|
const GURL& target_url,
|
|
|
|
const GURL& referrer_url) const;
|
|
|
|
|
2016-11-23 21:54:29 +01:00
|
|
|
+ virtual std::unique_ptr<SourceStream> CreateSourceStream(
|
|
|
|
+ net::URLRequest* request,
|
|
|
|
+ std::unique_ptr<SourceStream> upstream) { return upstream; }
|
2015-12-05 03:58:56 +01:00
|
|
|
+
|
|
|
|
private:
|
|
|
|
// This is the interface for subclasses of NetworkDelegate to implement. These
|
|
|
|
// member functions will be called by the respective public notification
|
2016-11-23 21:54:29 +01:00
|
|
|
diff --git net/url_request/url_request_job.cc net/url_request/url_request_job.cc
|
2017-01-23 18:36:54 +01:00
|
|
|
index cdf60f8..d6dd4bf 100644
|
2016-11-23 21:54:29 +01:00
|
|
|
--- net/url_request/url_request_job.cc
|
|
|
|
+++ net/url_request/url_request_job.cc
|
2017-01-23 18:36:54 +01:00
|
|
|
@@ -497,6 +497,12 @@ void URLRequestJob::NotifyHeadersComplete() {
|
2016-11-23 21:54:29 +01:00
|
|
|
DCHECK(!source_stream_);
|
|
|
|
source_stream_ = SetUpSourceStream();
|
2015-12-05 03:58:56 +01:00
|
|
|
|
2016-11-23 21:54:29 +01:00
|
|
|
+ // Allow the delegate to add a downstream SourceStream for filtering.
|
|
|
|
+ if (network_delegate_ && source_stream_) {
|
|
|
|
+ source_stream_ = network_delegate_->CreateSourceStream(
|
|
|
|
+ request_, std::move(source_stream_));
|
|
|
|
+ }
|
2015-12-05 03:58:56 +01:00
|
|
|
+
|
2016-11-23 21:54:29 +01:00
|
|
|
if (!source_stream_) {
|
2017-01-23 18:36:54 +01:00
|
|
|
OnDone(URLRequestStatus(URLRequestStatus::FAILED,
|
|
|
|
ERR_CONTENT_DECODING_INIT_FAILED),
|