| OLD | NEW |
| 1 // Copyright (c) 2008 The Chromium Authors. All rights reserved. Use of this | 1 // Copyright (c) 2008 The Chromium Authors. All rights reserved. Use of this |
| 2 // source code is governed by a BSD-style license that can be found in the | 2 // source code is governed by a BSD-style license that can be found in the |
| 3 // LICENSE file. | 3 // LICENSE file. |
| 4 | 4 |
| 5 #include "net/base/file_stream.h" | 5 #include "net/base/file_stream.h" |
| 6 | 6 |
| 7 #include <windows.h> | 7 #include <windows.h> |
| 8 | 8 |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 118 if (file_ != INVALID_HANDLE_VALUE) | 118 if (file_ != INVALID_HANDLE_VALUE) |
| 119 CancelIo(file_); | 119 CancelIo(file_); |
| 120 | 120 |
| 121 async_context_.reset(); | 121 async_context_.reset(); |
| 122 if (file_ != INVALID_HANDLE_VALUE) { | 122 if (file_ != INVALID_HANDLE_VALUE) { |
| 123 CloseHandle(file_); | 123 CloseHandle(file_); |
| 124 file_ = INVALID_HANDLE_VALUE; | 124 file_ = INVALID_HANDLE_VALUE; |
| 125 } | 125 } |
| 126 } | 126 } |
| 127 | 127 |
| 128 int FileStream::Open(const std::wstring& path, int open_flags) { | 128 int FileStream::Open(const FilePath& path, int open_flags) { |
| 129 if (IsOpen()) { | 129 if (IsOpen()) { |
| 130 DLOG(FATAL) << "File is already open!"; | 130 DLOG(FATAL) << "File is already open!"; |
| 131 return ERR_UNEXPECTED; | 131 return ERR_UNEXPECTED; |
| 132 } | 132 } |
| 133 | 133 |
| 134 open_flags_ = open_flags; | 134 open_flags_ = open_flags; |
| 135 file_ = base::CreatePlatformFile(path, open_flags_, NULL); | 135 file_ = base::CreatePlatformFile(path.value(), open_flags_, NULL); |
| 136 if (file_ == INVALID_HANDLE_VALUE) { | 136 if (file_ == INVALID_HANDLE_VALUE) { |
| 137 DWORD error = GetLastError(); | 137 DWORD error = GetLastError(); |
| 138 LOG(WARNING) << "Failed to open file: " << error; | 138 LOG(WARNING) << "Failed to open file: " << error; |
| 139 return MapErrorCode(error); | 139 return MapErrorCode(error); |
| 140 } | 140 } |
| 141 | 141 |
| 142 if (open_flags_ & base::PLATFORM_FILE_ASYNC) { | 142 if (open_flags_ & base::PLATFORM_FILE_ASYNC) { |
| 143 async_context_.reset(new AsyncContext(this)); | 143 async_context_.reset(new AsyncContext(this)); |
| 144 MessageLoopForIO::current()->RegisterIOHandler(file_, | 144 MessageLoopForIO::current()->RegisterIOHandler(file_, |
| 145 async_context_.get()); | 145 async_context_.get()); |
| (...skipping 104 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 250 async_context_->IOCompletionIsPending(callback); | 250 async_context_->IOCompletionIsPending(callback); |
| 251 rv = ERR_IO_PENDING; | 251 rv = ERR_IO_PENDING; |
| 252 } else { | 252 } else { |
| 253 rv = static_cast<int>(bytes_written); | 253 rv = static_cast<int>(bytes_written); |
| 254 } | 254 } |
| 255 return rv; | 255 return rv; |
| 256 } | 256 } |
| 257 | 257 |
| 258 } // namespace net | 258 } // namespace net |
| 259 | 259 |
| OLD | NEW |