net: Implement canceling of all async operations in FileStream.

chrome/browser/chromeos/drive/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/drive/drive_protocol_handler.h"
 
 #include <algorithm>
 #include <string>
 #include <vector>
 
@@ skipping 59 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 extracts and unescapes resource_id from drive urls
 // (drive:<resource_id>).
 bool ParseDriveUrl(const std::string& path, std::string* resource_id) {
   const std::string drive_schema(chrome::kDriveScheme + std::string(":"));
   if (!StartsWithASCII(path, drive_schema, false) ||
       path.size() <= drive_schema.size()) {
     return false;
   }
 
   std::string id = path.substr(drive_schema.size());
@@ skipping 732 matching lines @@
   // Subtract the remaining bytes.
   remaining_bytes_ -= bytes_read;
   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);
+  stream_.reset();
 }
 
 void DriveURLRequestJob::NotifySuccess() {
   HeadersCompleted(kHTTPOk, kHTTPOkText);
 }
 
 void DriveURLRequestJob::NotifyFailure(int error_code) {
   error_ = true;
 
   // If we already return the headers on success, we can't change the headers
@@ skipping 72 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 drive