| // Copyright 2017 The Fuchsia 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 <utility> |
| #include <vector> |
| |
| #include <blobfs/writeback.h> |
| #include <fbl/vector.h> |
| #include <fs/block-txn.h> |
| |
| namespace blobfs { |
| |
| zx_status_t FlushWriteRequests(fs::TransactionHandler* transaction_handler, |
| const fbl::Vector<BufferedOperation>& operations) { |
| if (operations.is_empty()) { |
| return ZX_OK; |
| } |
| |
| // Update all the outgoing transactions to be in disk blocks. |
| std::vector<block_fifo_request_t> blk_reqs; |
| blk_reqs.resize(operations.size()); |
| const uint32_t kDiskBlocksPerBlobfsBlock = |
| transaction_handler->FsBlockSize() / transaction_handler->DeviceBlockSize(); |
| for (size_t i = 0; i < operations.size(); i++) { |
| blk_reqs[i].group = transaction_handler->BlockGroupID(); |
| blk_reqs[i].vmoid = operations[i].vmoid; |
| blk_reqs[i].opcode = BLOCKIO_WRITE; |
| blk_reqs[i].vmo_offset = operations[i].op.vmo_offset * kDiskBlocksPerBlobfsBlock; |
| blk_reqs[i].dev_offset = operations[i].op.dev_offset * kDiskBlocksPerBlobfsBlock; |
| uint64_t length = operations[i].op.length * kDiskBlocksPerBlobfsBlock; |
| // TODO(ZX-2253): Requests this long, although unlikely, should be |
| // handled more gracefully. |
| ZX_ASSERT_MSG(length < UINT32_MAX, "Request size too large"); |
| blk_reqs[i].length = static_cast<uint32_t>(length); |
| } |
| |
| // Actually send the operations to the underlying block device. |
| return transaction_handler->Transaction(&blk_reqs[0], operations.size()); |
| } |
| |
| } // namespace blobfs |
