ulib/blobfs/blobfs.cpp

359         fbl::unique_ptr<WritebackWork> wb;
360         if ((status = blobfs_->CreateWork(&wb, this)) != ZX_OK) {
362         } else if ((status = WriteMetadata(fbl::move(wb))) != ZX_OK) {
417 zx_status_t VnodeBlob::WriteMetadata(fbl::unique_ptr<WritebackWork> wb) {
438         blobfs_->PersistBlocks(wb.get(), inode_.num_blocks, inode_.start_block);
441     blobfs_->PersistNode(wb.get(), map_index_, inode_);
442     wb->SetSyncComplete();
443     blobfs_->EnqueueWork(fbl::move(wb));
485         fbl::unique_ptr<WritebackWork> wb;
486         if ((status = blobfs_->CreateWork(&wb, this)) != ZX_OK) {
501             if ((status = EnqueuePaginated(&wb, blobfs_, this,
514             if ((status = EnqueuePaginated(&wb, blobfs_, this, blob_->GetVmo(),
542             wb->Enqueue(blob_->GetVmo(), 0, dev_offset, merkle_blocks);
554         if ((status = WriteMetadata(fbl::move(wb))) != ZX_OK) {
777 void Blobfs::PersistBlocks(WritebackWork* wb, size_t num_blocks, size_t block_index) {
798     WriteBitmap(wb, num_blocks, block_index);
799     WriteInfo(wb);
803 void Blobfs::FreeBlocks(WritebackWork* wb, size_t num_blocks, size_t block_index) {
813         WriteBitmap(wb, num_blocks, block_index);
814         WriteInfo(wb);
865 void Blobfs::PersistNode(WritebackWork* wb, size_t node_index, const blobfs_inode_t& inode) {
881     WriteNode(wb, node_index);
882     WriteInfo(wb);
885 void Blobfs::FreeNode(WritebackWork* wb, size_t node_index) {
891         ZX_DEBUG_ASSERT(wb != nullptr);
894         WriteNode(wb, node_index);
895         WriteInfo(wb);
975 void Blobfs::WriteBitmap(WritebackWork* wb, uint64_t nblocks, uint64_t start_block) {
984     wb->Enqueue(block_map_.StorageUnsafe()->GetVmo(), bbm_start_block,
988 void Blobfs::WriteNode(WritebackWork* wb, size_t map_index) {
991     wb->Enqueue(node_map_->GetVmo(), b, NodeMapStartBlock(info_) + b, 1);
1036         fbl::unique_ptr<WritebackWork> wb;
1037         if ((status = CreateWork(&wb, vn)) != ZX_OK) {
1041         FreeNode(wb.get(), node_index);
1042         FreeBlocks(wb.get(), nblocks, start_block);
1044         EnqueueWork(fbl::move(wb));
1054 void Blobfs::WriteInfo(WritebackWork* wb) {
1057     wb->Enqueue(info_vmo_->GetVmo(), 0, 0, 1);
1225     fbl::unique_ptr<WritebackWork> wb;
1226     if ((status = CreateWork(&wb, nullptr)) != ZX_OK) {
1230     WriteInfo(wb.get());
1231     wb.get()->Enqueue(node_map_->GetVmo(), inoblks_old, NodeMapStartBlock(info_) + inoblks_old,
1233     EnqueueWork(fbl::move(wb));
1277     fbl::unique_ptr<WritebackWork> wb;
1278     if ((status = CreateWork(&wb, nullptr)) != ZX_OK) {
1288         wb.get()->Enqueue(block_map_.StorageUnsafe()->GetVmo(), vmo_offset, dev_offset, length);
1295     WriteInfo(wb.get());
1296     EnqueueWork(fbl::move(wb));
1302     fbl::unique_ptr<WritebackWork> wb;
1303     if ((status = CreateWork(&wb, nullptr)) != ZX_OK) {
1308     wb->SetClosure(fbl::move(closure));
1309     EnqueueWork(fbl::move(wb));