Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/base/upload_file_element_reader.h" | 5 #include "net/base/upload_file_element_reader.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
| 9 #include "base/location.h" | 9 #include "base/location.h" |
| 10 #include "base/task_runner_util.h" | 10 #include "base/task_runner_util.h" |
| 11 #include "net/base/file_stream.h" | 11 #include "net/base/file_stream.h" |
| 12 #include "net/base/io_buffer.h" | 12 #include "net/base/io_buffer.h" |
| 13 #include "net/base/net_errors.h" | 13 #include "net/base/net_errors.h" |
| 14 | 14 |
| 15 #if defined(OS_ANDROID) | |
| 16 #include "net/android/content_uri_utils.h" | |
| 17 #endif | |
| 18 | |
| 15 namespace net { | 19 namespace net { |
| 16 | 20 |
| 17 namespace { | 21 namespace { |
| 18 | 22 |
| 19 // In tests, this value is used to override the return value of | 23 // In tests, this value is used to override the return value of |
| 20 // UploadFileElementReader::GetContentLength() when set to non-zero. | 24 // UploadFileElementReader::GetContentLength() when set to non-zero. |
| 21 uint64 overriding_content_length = 0; | 25 uint64 overriding_content_length = 0; |
| 22 | 26 |
| 23 // This function is used to implement Init(). | 27 // This function is used to implement Init(). |
| 24 template<typename FileStreamDeleter> | 28 template<typename FileStreamDeleter> |
| (...skipping 13 matching lines...) Expand all Loading... | |
| 38 file_stream.reset(); | 42 file_stream.reset(); |
| 39 } else if (range_offset) { | 43 } else if (range_offset) { |
| 40 rv = file_stream->SeekSync(FROM_BEGIN, range_offset); | 44 rv = file_stream->SeekSync(FROM_BEGIN, range_offset); |
| 41 if (rv < 0) { | 45 if (rv < 0) { |
| 42 DLOG(WARNING) << "Failed to seek \"" << path.value() | 46 DLOG(WARNING) << "Failed to seek \"" << path.value() |
| 43 << "\" to offset: " << range_offset << " (" << rv << ")"; | 47 << "\" to offset: " << range_offset << " (" << rv << ")"; |
| 44 file_stream.reset(); | 48 file_stream.reset(); |
| 45 } | 49 } |
| 46 } | 50 } |
| 47 | 51 |
| 52 #if defined(OS_ANDROID) | |
| 53 int64 length = std::max(0ll, GetContentUrlLengthSync(path)); | |
|
kinuko
2013/10/31 06:10:51
Can this part be factored out as a separate static
joth
2013/10/31 06:42:39
+1
Maybe even, bundling this logic into file_util
qinmin
2013/11/05 01:41:31
Done. GetFileInfo() should work for content url no
| |
| 54 if (file_stream.get() && length > 0 && | |
| 55 range_offset < static_cast<uint64>(length)) { | |
|
mmenke
2013/10/31 15:07:06
This class is being modified to handle errors diff
qinmin
2013/11/05 01:41:31
Done.
| |
| 56 // Compensate for the offset. | |
| 57 length = std::min(length - range_offset, range_length); | |
| 58 } | |
| 59 #else | |
| 48 int64 length = 0; | 60 int64 length = 0; |
| 49 if (file_stream.get() && | 61 if (file_stream.get() && |
| 50 file_util::GetFileSize(path, &length) && | 62 file_util::GetFileSize(path, &length) && |
| 51 range_offset < static_cast<uint64>(length)) { | 63 range_offset < static_cast<uint64>(length)) { |
| 52 // Compensate for the offset. | 64 // Compensate for the offset. |
| 53 length = std::min(length - range_offset, range_length); | 65 length = std::min(length - range_offset, range_length); |
| 54 } | 66 } |
| 67 #endif | |
| 55 *out_content_length = length; | 68 *out_content_length = length; |
| 56 out_file_stream->reset(file_stream.release()); | 69 out_file_stream->reset(file_stream.release()); |
| 57 | 70 |
| 58 // If the underlying file has been changed and the expected file modification | 71 // If the underlying file has been changed and the expected file modification |
| 59 // time is set, treat it as error. Note that the expected modification time | 72 // time is set, treat it as error. Note that the expected modification time |
| 60 // from WebKit is based on time_t precision. So we have to convert both to | 73 // from WebKit is based on time_t precision. So we have to convert both to |
| 61 // time_t to compare. This check is used for sliced files. | 74 // time_t to compare. This check is used for sliced files. |
| 62 if (!expected_modification_time.is_null()) { | 75 if (!expected_modification_time.is_null()) { |
| 63 base::PlatformFileInfo info; | 76 base::PlatformFileInfo info; |
| 64 if (file_util::GetFileInfo(path, &info) && | 77 if (file_util::GetFileInfo(path, &info) && |
| (...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 281 const int result = ReadInternal(buf, buf_length, BytesRemaining(), | 294 const int result = ReadInternal(buf, buf_length, BytesRemaining(), |
| 282 file_stream_.get()); | 295 file_stream_.get()); |
| 283 if (result > 0) { | 296 if (result > 0) { |
| 284 DCHECK_GE(bytes_remaining_, static_cast<uint64>(result)); | 297 DCHECK_GE(bytes_remaining_, static_cast<uint64>(result)); |
| 285 bytes_remaining_ -= result; | 298 bytes_remaining_ -= result; |
| 286 } | 299 } |
| 287 return result; | 300 return result; |
| 288 } | 301 } |
| 289 | 302 |
| 290 } // namespace net | 303 } // namespace net |
| OLD | NEW |