| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "mojo/data_pipe_utils/data_pipe_utils.h" | 5 #include "mojo/data_pipe_utils/data_pipe_utils.h" |
| 6 | 6 |
| 7 #include <stdio.h> | 7 #include <stdio.h> |
| 8 | 8 |
| 9 #include <limits> | 9 #include <limits> |
| 10 #include <memory> |
| 10 | 11 |
| 11 #include "base/files/file.h" | 12 #include "base/files/file.h" |
| 12 #include "base/files/file_path.h" | 13 #include "base/files/file_path.h" |
| 13 #include "base/files/file_util.h" | 14 #include "base/files/file_util.h" |
| 14 #include "base/files/scoped_file.h" | 15 #include "base/files/scoped_file.h" |
| 15 #include "base/location.h" | 16 #include "base/location.h" |
| 16 #include "base/trace_event/trace_event.h" | 17 #include "base/trace_event/trace_event.h" |
| 17 #include "mojo/data_pipe_utils/data_pipe_utils_internal.h" | 18 #include "mojo/data_pipe_utils/data_pipe_utils_internal.h" |
| 18 #include "mojo/public/cpp/environment/async_waiter.h" | 19 #include "mojo/public/cpp/environment/async_waiter.h" |
| 19 | 20 |
| (...skipping 14 matching lines...) Expand all Loading... |
| 34 void SendCallback(bool value); | 35 void SendCallback(bool value); |
| 35 void OpenFile(); | 36 void OpenFile(); |
| 36 void OnHandleReady(MojoResult result); | 37 void OnHandleReady(MojoResult result); |
| 37 void WriteToFile(); | 38 void WriteToFile(); |
| 38 | 39 |
| 39 ScopedDataPipeConsumerHandle source_; | 40 ScopedDataPipeConsumerHandle source_; |
| 40 const base::FilePath destination_; | 41 const base::FilePath destination_; |
| 41 base::TaskRunner* file_task_runner_; | 42 base::TaskRunner* file_task_runner_; |
| 42 base::Callback<void(bool)> callback_; | 43 base::Callback<void(bool)> callback_; |
| 43 base::File file_; | 44 base::File file_; |
| 44 scoped_ptr<AsyncWaiter> waiter_; | 45 std::unique_ptr<AsyncWaiter> waiter_; |
| 45 const void* buffer_; | 46 const void* buffer_; |
| 46 uint32_t buffer_size_; | 47 uint32_t buffer_size_; |
| 47 scoped_refptr<base::SingleThreadTaskRunner> main_runner_; | 48 scoped_refptr<base::SingleThreadTaskRunner> main_runner_; |
| 48 | 49 |
| 49 DISALLOW_COPY_AND_ASSIGN(CopyToFileHandler); | 50 DISALLOW_COPY_AND_ASSIGN(CopyToFileHandler); |
| 50 }; | 51 }; |
| 51 | 52 |
| 52 CopyToFileHandler::CopyToFileHandler(ScopedDataPipeConsumerHandle source, | 53 CopyToFileHandler::CopyToFileHandler(ScopedDataPipeConsumerHandle source, |
| 53 const base::FilePath& destination, | 54 const base::FilePath& destination, |
| 54 base::TaskRunner* task_runner, | 55 base::TaskRunner* task_runner, |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 171 void OpenFile(); | 172 void OpenFile(); |
| 172 void OnHandleReady(MojoResult result); | 173 void OnHandleReady(MojoResult result); |
| 173 void ReadFromFile(); | 174 void ReadFromFile(); |
| 174 | 175 |
| 175 const base::FilePath source_; | 176 const base::FilePath source_; |
| 176 ScopedDataPipeProducerHandle destination_; | 177 ScopedDataPipeProducerHandle destination_; |
| 177 uint32_t skip_; | 178 uint32_t skip_; |
| 178 base::TaskRunner* file_task_runner_; | 179 base::TaskRunner* file_task_runner_; |
| 179 base::Callback<void(bool)> callback_; | 180 base::Callback<void(bool)> callback_; |
| 180 base::File file_; | 181 base::File file_; |
| 181 scoped_ptr<AsyncWaiter> waiter_; | 182 std::unique_ptr<AsyncWaiter> waiter_; |
| 182 void* buffer_; | 183 void* buffer_; |
| 183 uint32_t buffer_size_; | 184 uint32_t buffer_size_; |
| 184 scoped_refptr<base::SingleThreadTaskRunner> main_runner_; | 185 scoped_refptr<base::SingleThreadTaskRunner> main_runner_; |
| 185 | 186 |
| 186 DISALLOW_COPY_AND_ASSIGN(CopyFromFileHandler); | 187 DISALLOW_COPY_AND_ASSIGN(CopyFromFileHandler); |
| 187 }; | 188 }; |
| 188 | 189 |
| 189 CopyFromFileHandler::CopyFromFileHandler( | 190 CopyFromFileHandler::CopyFromFileHandler( |
| 190 const base::FilePath& source, | 191 const base::FilePath& source, |
| 191 ScopedDataPipeProducerHandle destination, | 192 ScopedDataPipeProducerHandle destination, |
| (...skipping 163 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 355 ScopedDataPipeProducerHandle destination, | 356 ScopedDataPipeProducerHandle destination, |
| 356 uint32_t skip, | 357 uint32_t skip, |
| 357 base::TaskRunner* task_runner, | 358 base::TaskRunner* task_runner, |
| 358 const base::Callback<void(bool)>& callback) { | 359 const base::Callback<void(bool)>& callback) { |
| 359 new CopyFromFileHandler(source, destination.Pass(), skip, task_runner, | 360 new CopyFromFileHandler(source, destination.Pass(), skip, task_runner, |
| 360 callback); | 361 callback); |
| 361 } | 362 } |
| 362 | 363 |
| 363 } // namespace common | 364 } // namespace common |
| 364 } // namespace mojo | 365 } // namespace mojo |
| OLD | NEW |