Fix an issue that we didn't clean url request properly.

content/browser/download/download_file_impl.h

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef CONTENT_BROWSER_DOWNLOAD_DOWNLOAD_FILE_IMPL_H_
 #define CONTENT_BROWSER_DOWNLOAD_DOWNLOAD_FILE_IMPL_H_
 
 #include "content/browser/download/download_file.h"
 
 #include <stddef.h>
@@ skipping 35 matching lines @@
   DownloadFileImpl(
       std::unique_ptr<DownloadSaveInfo> save_info,
       const base::FilePath& default_downloads_directory,
       std::unique_ptr<ByteStreamReader> stream_reader,
       const net::NetLogWithSource& net_log,
       base::WeakPtr<DownloadDestinationObserver> observer);
 
   ~DownloadFileImpl() override;
 
   // DownloadFile functions.
-  void Initialize(const InitializeCallback& callback,
+  void Initialize(const InitializeCallback& initialize_callback,
+                  const CancelRequestCallback& cancel_request_callback,
                   const DownloadItem::ReceivedSlices& received_slices) override;
 
   void AddByteStream(std::unique_ptr<ByteStreamReader> stream_reader,
                      int64_t offset,
                      int64_t length) override;
 
   void RenameAndUniquify(const base::FilePath& full_path,
                          const RenameCompletionCallback& callback) override;
   void RenameAndAnnotate(const base::FilePath& full_path,
                          const std::string& client_guid,
@@ skipping 40 matching lines @@
     void OnWriteBytesToDisk(int64_t bytes_write);
 
     // Given a data block that is already written, truncate the length of this
     // object to avoid overwriting that block.
     void TruncateLengthWithWrittenDataBlock(int64_t offset,
                                             int64_t bytes_written);
 
     ByteStreamReader* stream_reader() const { return stream_reader_.get(); }
     int64_t offset() const { return offset_; }
     int64_t length() const { return length_; }
-    void set_length(int64_t length) { length_ = length; }
     int64_t bytes_written() const { return bytes_written_; }
     bool is_finished() const { return finished_; }
     void set_finished(bool finish) { finished_ = finish; }
     size_t index() { return index_; }
     void set_index(size_t index) { index_ = index; }
 
    private:
     // Starting position for the stream to write to disk.
     int64_t offset_;
 
@@ skipping 94 matching lines @@
   void HandleStreamError(SourceStream* source_stream,
                          DownloadInterruptReason reason);
 
   // Check whether this file is potentially sparse.
   bool IsSparseFile() const;
 
   // Given a SourceStream object, returns its neighbor that preceds it if
   // SourceStreams are ordered by their offsets
   SourceStream* FindPrecedingNeighbor(SourceStream* source_stream);
 
+  // See |cancel_request_callback_|.
+  void CancelRequestOnUIThread(int64_t offset);
+
   // Print the internal states for debugging.
   void DebugStates() const;
 
   net::NetLogWithSource net_log_;
 
   // The base file instance.
   BaseFile file_;
 
   // DownloadSaveInfo provided during construction. Since the DownloadFileImpl
   // can be created on any thread, this holds the save_info_ until it can be
   // used to initialize file_ on the FILE thread.
   std::unique_ptr<DownloadSaveInfo> save_info_;
 
   // The default directory for creating the download file.
   base::FilePath default_download_directory_;
 
   // Map of the offset and the source stream that represents the slice
   // starting from offset.
   SourceStreams source_streams_;
 
+  // Used to cancel the request on UI thread, since the ByteStreamReader can't
+  // close the underlying resource writing to the pipe.
+  CancelRequestCallback cancel_request_callback_;
+
   // Used to trigger progress updates.
   std::unique_ptr<base::RepeatingTimer> update_timer_;
 
   // Potential file length. A range request with an offset larger than this
   // value will fail. So the actual file length cannot be larger than this.
   int64_t potential_file_length_;
 
   // Statistics
   size_t bytes_seen_;
   base::TimeDelta disk_writes_time_;
@@ skipping 11 matching lines @@
 
   base::WeakPtr<DownloadDestinationObserver> observer_;
   base::WeakPtrFactory<DownloadFileImpl> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(DownloadFileImpl);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_DOWNLOAD_DOWNLOAD_FILE_IMPL_H_