net: Implement canceling of all async operations in FileStream.

net/base/upload_file_element_reader.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 "net/base/upload_file_element_reader.h"
 
 #include "base/bind.h"
 #include "base/file_util.h"
 #include "base/location.h"
 #include "base/threading/thread_restrictions.h"
@@ skipping 23 matching lines @@
   if (rv != OK) {
     // If the file can't be opened, we'll just upload an empty file.
     DLOG(WARNING) << "Failed to open \"" << path.value()
                   << "\" for reading: " << rv;
     file_stream.reset();
   } else if (range_offset) {
     rv = file_stream->SeekSync(FROM_BEGIN, range_offset);
     if (rv < 0) {
       DLOG(WARNING) << "Failed to seek \"" << path.value()
                     << "\" to offset: " << range_offset << " (" << rv << ")";
-      file_stream->CloseSync();
       file_stream.reset();
     }
   }
 
   int64 length = 0;
   if (file_stream.get() &&
       file_util::GetFileSize(path, &length) &&
       range_offset < static_cast<uint64>(length)) {
     // Compensate for the offset.
     length = std::min(length - range_offset, range_length);
@@ skipping 29 matching lines @@
       range_length_(range_length),
       expected_modification_time_(expected_modification_time),
       content_length_(0),
       bytes_remaining_(0),
       weak_ptr_factory_(this) {
 }
 
 UploadFileElementReader::~UploadFileElementReader() {
   // Temporarily allow until fix: http://crbug.com/72001.
   base::ThreadRestrictions::ScopedAllowIO allow_io;
-  if (file_stream_.get())
-    file_stream_->CloseSync();
+  file_stream_.reset();
 }
 
 int UploadFileElementReader::Init(const CompletionCallback& callback) {
   scoped_ptr<FileStream>* file_stream = new scoped_ptr<FileStream>;
   uint64* content_length = new uint64;
   int* result = new int;
   const bool posted = base::WorkerPool::PostTaskAndReply(
       FROM_HERE,
       base::Bind(&InitInternal,
                  path_,
@@ skipping 81 matching lines @@
 ScopedOverridingContentLengthForTests(uint64 value) {
   overriding_content_length = value;
 }
 
 UploadFileElementReader::ScopedOverridingContentLengthForTests::
 ~ScopedOverridingContentLengthForTests() {
   overriding_content_length = 0;
 }
 
 }  // namespace net