net: Implement canceling of all async operations in FileStream.

chrome/browser/chromeos/gdata/drive_protocol_handler.cc

 // 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.
 
 #include "chrome/browser/chromeos/gdata/drive_protocol_handler.h"
 
 #include <algorithm>
 #include <string>
 #include <vector>
 
@@ skipping 61 matching lines @@
 };
 
 std::string FixupMimeType(const std::string& type) {
   for (size_t i = 0; i < arraysize(kMimeTypeReplacements); i++) {
     if (type == kMimeTypeReplacements[i].original_type)
       return kMimeTypeReplacements[i].new_type;
   }
   return type;
 }
 
-// Empty callback for net::FileStream::Close().
-void EmptyCompletionCallback(int) {
-}
-
 // Helper function that reads file size.
 void GetFileSizeOnBlockingPool(const FilePath& file_path,
                                int64* file_size) {
   if (!file_util::GetFileSize(file_path, file_size))
     *file_size = kInvalidFileSize;
 }
 
 // Helper function that extracts and unescapes resource_id from drive urls
 // (drive:<resource_id>).
 bool ParseDriveUrl(const std::string& path, std::string* resource_id) {
@@ skipping 742 matching lines @@
   DCHECK_GE(remaining_bytes_, 0);
 
   // Adjust the read buffer.
   read_buf_->DidConsume(bytes_read);
   DCHECK_GE(read_buf_->BytesRemaining(), 0);
 }
 
 void DriveURLRequestJob::CloseFileStream() {
   if (!stream_.get())
     return;
-  stream_->Close(base::Bind(&EmptyCompletionCallback));
-  // net::FileStream::Close blocks until stream is closed, so it's safe to
-  // release the pointer here.
   stream_.reset(NULL);
 }
 
 void DriveURLRequestJob::NotifySuccess() {
   HeadersCompleted(kHTTPOk, kHTTPOkText);
 }
 
 void DriveURLRequestJob::NotifyFailure(int error_code) {
   error_ = true;
 
@@ skipping 73 matching lines @@
 DriveProtocolHandler::~DriveProtocolHandler() {
 }
 
 net::URLRequestJob* DriveProtocolHandler::MaybeCreateJob(
     net::URLRequest* request, net::NetworkDelegate* network_delegate) const {
   DVLOG(1) << "Handling url: " << request->url().spec();
   return new DriveURLRequestJob(request, network_delegate);
 }
 
 }  // namespace gdata