ulib/blobfs/blobfs.cpp

20 #include <fs/block-txn.h>
21 #include <fs/ticker.h>
151     fs::Ticker ticker(blobfs_->CollectingMetrics());
224     fs::Ticker ticker(blobfs_->CollectingMetrics());
225     fs::ReadTxn txn(blobfs_);
263     fs::Duration read_time = ticker.End();
287     fs::Ticker ticker(blobfs_->CollectingMetrics());
288     fs::ReadTxn txn(blobfs_);
333     fs::Ticker ticker(blobfs_->CollectingMetrics());
410     return fs::GetBlock(kBlobfsBlockSize, blob_->GetData(), MerkleTreeBlocks(inode_));
524         fs::Duration generation_time;
529             fs::Ticker ticker(blobfs_->CollectingMetrics()); // Tracking generation time.
553         fs::Ticker ticker(blobfs_->CollectingMetrics()); // Tracking enqueue time.
920 void Blobfs::Shutdown(fs::Vfs::ShutdownCallback cb) {
946                     fs::WriteTxn sync_txn(this);
1082 static_assert(sizeof(dircookie_t) <= sizeof(fs::vdircookie_t),
1085 zx_status_t Blobfs::Readdir(fs::vdircookie_t* cookie, void* dirents, size_t len,
1088     fs::DirentFiller df(dirents, len);
1312 void Blobfs::UpdateAllocationMetrics(uint64_t size_data, const fs::Duration& duration) {
1328                                       const fs::Duration& enqueue_duration,
1329                                       const fs::Duration& generate_duration) {
1338 void Blobfs::UpdateWritebackMetrics(uint64_t size, const fs::Duration& duration) {
1345 void Blobfs::UpdateMerkleDiskReadMetrics(uint64_t size, const fs::Duration& duration) {
1354                                            const fs::Duration& read_duration,
1355                                            const fs::Duration& decompress_duration) {
1365                                        const fs::Duration& duration) {
1400     auto fs = fbl::unique_ptr<Blobfs>(new Blobfs(fbl::move(fd), info));
1404     if ((r = ioctl_block_get_info(fs->Fd(), &fs->block_info_)) < 0) {
1406     } else if (kBlobfsBlockSize % fs->block_info_.block_size != 0) {
1408     } else if ((r = ioctl_block_get_fifos(fs->Fd(), fifo.reset_and_get_address())) < 0) {
1413     if ((status = block_client::Client::Create(fbl::move(fifo), &fs->fifo_client_)) != ZX_OK) {
1418     if ((status = fs->block_map_.Reset(BlockMapBlocks(fs->info_) * kBlobfsBlockBits)) < 0) {
1421     } else if ((status = fs->block_map_.Shrink(fs->info_.block_count)) < 0) {
1426     size_t nodemap_size = kBlobfsInodeSize * fs->info_.inode_count;
1428     ZX_DEBUG_ASSERT(nodemap_size / kBlobfsBlockSize == NodeMapBlocks(fs->info_));
1429     if ((status = fzl::MappedVmo::Create(nodemap_size, "nodemap", &fs->node_map_)) != ZX_OK) {
1431     } else if ((status = fs->AttachVmo(fs->block_map_.StorageUnsafe()->GetVmo(),
1432                                        &fs->block_map_vmoid_)) != ZX_OK) {
1434     } else if ((status = fs->AttachVmo(fs->node_map_->GetVmo(),
1435                                        &fs->node_map_vmoid_)) != ZX_OK) {
1437     } else if ((status = fs->LoadBitmaps()) < 0) {
1441                                                &fs->info_vmo_)) != ZX_OK) {
1444     } else if ((status = fs->AttachVmo(fs->info_vmo_->GetVmo(),
1445                                        &fs->info_vmoid_)) != ZX_OK) {
1448     } else if ((status = fs->CreateFsId()) != ZX_OK) {
1451     } else if ((status = fs->InitializeVnodes() != ZX_OK)) {
1456     *out = fbl::move(fs);
1548     fs::ReadTxn txn(this);
1593     fbl::unique_ptr<Blobfs> fs;
1595     if ((status = blobfs_create(&fs, fbl::move(blockfd))) != ZX_OK) {
1599     if ((status = fs->InitializeWriteback()) != ZX_OK) {
1603     fs->SetDispatcher(dispatcher);
1604     fs->SetReadonly(options->readonly);
1606         fs->CollectMetrics();
1608     fs->SetUnmountCallback(fbl::move(on_unmount));
1611     if ((status = fs->OpenRootNode(&vn)) != ZX_OK) {
1616     if ((status = fs->ServeDirectory(fbl::move(vn), fbl::move(root))) != ZX_OK) {
1622     __UNUSED auto r = fs.release();