| /system/ulib/blobfs/test/ |
| A D | journal-test.cpp | 23 fbl::unique_ptr<blobfs::WritebackWork> CreateDefaultWork() { in CreateDefaultWork()
27 fbl::unique_ptr<WritebackWork> CreateBufferedWork(size_t block_count) { in CreateBufferedWork()
28 fbl::unique_ptr<WritebackWork> work = CreateWork(); in CreateBufferedWork()
46 fbl::unique_ptr<WritebackWork> CreateWork() final { in CreateWork()
47 return fbl::make_unique<blobfs::WritebackWork>(nullptr, nullptr); in CreateWork()
53 void PrepareDelete(JournalEntry* entry, WritebackWork* work) final {} in PrepareDelete()
54 zx_status_t EnqueueEntryWork(fbl::unique_ptr<WritebackWork> work) final { in EnqueueEntryWork()
73 fbl::unique_ptr<blobfs::WritebackWork> first_work = journal.CreateDefaultWork(); in JournalEntryLifetimeTest()
80 fbl::unique_ptr<blobfs::WritebackWork> second_work = journal.CreateDefaultWork(); in JournalEntryLifetimeTest()
|
| /system/ulib/minfs/include/minfs/ |
| A D | writeback.h | 41 class WritebackWork : public WriteTxn,
42 public fbl::SinglyLinkedListable<fbl::unique_ptr<WritebackWork>> {
44 WritebackWork(Bcache* bc);
89 Transaction(fbl::unique_ptr<WritebackWork> work, in Transaction()
106 void SetWork(fbl::unique_ptr<WritebackWork> work) { in SetWork()
110 WritebackWork* GetWork() { in GetWork()
115 fbl::unique_ptr<WritebackWork> RemoveWork() { in RemoveWork()
121 fbl::unique_ptr<WritebackWork> work_;
145 void Enqueue(fbl::unique_ptr<WritebackWork> work) __TA_EXCLUDES(writeback_lock_);
173 using WorkQueue = fs::Queue<fbl::unique_ptr<WritebackWork>>;
|
| /system/ulib/blobfs/include/blobfs/ |
| A D | journal.h | 25 using ReadyCallback = blobfs::WritebackWork::ReadyCallback;
53 uint64_t commit_index, fbl::unique_ptr<WritebackWork> work);
77 fbl::unique_ptr<WritebackWork> TakeWork();
129 fbl::unique_ptr<WritebackWork> work_;
153 virtual void PrepareDelete(JournalEntry* entry, WritebackWork* work) = 0;
156 virtual fbl::unique_ptr<WritebackWork> CreateWork() = 0;
225 zx_status_t Enqueue(fbl::unique_ptr<WritebackWork> work);
255 fbl::unique_ptr<WritebackWork> CreateWork() final;
259 zx_status_t EnqueueEntryWork(fbl::unique_ptr<WritebackWork> work) final;
328 void AddEntryTransaction(size_t start, size_t length, WritebackWork* work);
[all …]
|
| A D | blobfs.h | 64 class WritebackWork; variable
196 zx_status_t CreateWork(fbl::unique_ptr<WritebackWork>* out, VnodeBlob* vnode);
201 zx_status_t EnqueueWork(fbl::unique_ptr<WritebackWork> work,
207 void FreeInode(WritebackWork* wb, uint32_t node_index);
218 void PersistNode(WritebackWork* wb, uint32_t node_index);
221 void PersistBlocks(WritebackWork* wb, const ReservedExtent& extent);
235 void FreeExtent(WritebackWork* wb, const Extent& extent);
239 void FreeNode(WritebackWork* wb, uint32_t node_index);
244 void WriteBitmap(WritebackWork* wb, uint64_t nblocks, uint64_t start_block);
248 void WriteNode(WritebackWork* wb, uint32_t map_index);
[all …]
|
| A D | writeback.h | 116 class WritebackWork : public WriteTxn,
117 public fbl::SinglyLinkedListable<fbl::unique_ptr<WritebackWork>> {
124 WritebackWork(Blobfs* bs, fbl::RefPtr<VnodeBlob> vnode);
125 ~WritebackWork() = default;
202 void AddTransaction(size_t start, size_t disk_start, size_t length, WritebackWork* work);
263 zx_status_t Enqueue(fbl::unique_ptr<WritebackWork> work);
274 using WorkQueue = fs::Queue<fbl::unique_ptr<WritebackWork>>;
|
| /system/ulib/blobfs/ |
| A D | writeback.cpp | 104 void WritebackWork::Reset(zx_status_t reason) { in Reset()
110 bool WritebackWork::IsReady() { in IsReady()
123 void WritebackWork::SetReadyCallback(ReadyCallback callback) { in SetReadyCallback()
128 void WritebackWork::SetSyncCallback(SyncCallback callback) { in SetSyncCallback()
133 void WritebackWork::SetSyncComplete() { in SetSyncComplete()
139 zx_status_t WritebackWork::Complete() { in Complete()
151 WritebackWork::WritebackWork(Blobfs* bs, fbl::RefPtr<VnodeBlob> vn) : in WritebackWork() function in blobfs::WritebackWork
154 void WritebackWork::InvokeSyncCallback(zx_status_t status) { in InvokeSyncCallback()
160 void WritebackWork::ResetInternal() { in ResetInternal()
290 void Buffer::AddTransaction(size_t start, size_t disk_start, size_t length, WritebackWork* work) { in AddTransaction()
[all …]
|
| A D | journal.cpp | 59 fbl::unique_ptr<WritebackWork> JournalEntry::TakeWork() { in TakeWork()
270 zx_status_t Journal::Enqueue(fbl::unique_ptr<WritebackWork> work) { in Enqueue()
392 fbl::unique_ptr<WritebackWork> work = CreateWork(); in PrepareWork()
432 void Journal::PrepareDelete(JournalEntry* entry, WritebackWork* work) { in PrepareDelete()
455 fbl::unique_ptr<WritebackWork> Journal::CreateWork() { in CreateWork()
456 fbl::unique_ptr<WritebackWork> work; in CreateWork()
524 fbl::unique_ptr<WritebackWork> work = CreateWork(); in ReplayEntry()
551 fbl::unique_ptr<WritebackWork> work = CreateWork(); in CommitReplay()
597 fbl::unique_ptr<WritebackWork> work; in WriteInfo()
975 fbl::unique_ptr<WritebackWork> work = entry->TakeWork(); in ProcessWaitDefault()
[all …]
|
| A D | blobfs.cpp | 155 void Blobfs::PersistBlocks(WritebackWork* wb, const ReservedExtent& reserved_extent) { in PersistBlocks()
168 void Blobfs::FreeExtent(WritebackWork* wb, const Extent& extent) { in FreeExtent()
184 void Blobfs::FreeNode(WritebackWork* wb, uint32_t node_index) { in FreeNode()
190 void Blobfs::FreeInode(WritebackWork* wb, uint32_t node_index) { in FreeInode()
217 void Blobfs::PersistNode(WritebackWork* wb, uint32_t node_index) { in PersistNode()
320 void Blobfs::WriteNode(WritebackWork* wb, uint32_t map_index) { in WriteNode()
326 void Blobfs::WriteInfo(WritebackWork* wb) { in WriteInfo()
449 fbl::unique_ptr<WritebackWork> wb; in AddInodes()
500 fbl::unique_ptr<WritebackWork> wb; in AddBlocks()
524 fbl::unique_ptr<WritebackWork> wb; in Sync()
[all …]
|
| A D | vnode.cpp | 76 zx_status_t EnqueuePaginated(fbl::unique_ptr<WritebackWork>* work, Blobfs* blobfs, VnodeBlob* vn, in EnqueuePaginated()
88 fbl::unique_ptr<WritebackWork> tmp; in EnqueuePaginated()
431 fbl::unique_ptr<WritebackWork> wb; in WriteMetadata()
546 fbl::unique_ptr<WritebackWork> wb; in WriteInternal()
1110 fbl::unique_ptr<WritebackWork> wb; in Purge()
|
| /system/ulib/minfs/ |
| A D | writeback.cpp | 102 WritebackWork::WritebackWork(Bcache* bc) : WriteTxn(bc), in WritebackWork() function in minfs::WritebackWork
108 void WritebackWork::Reset() { in Reset()
121 size_t WritebackWork::Complete(zx_handle_t vmo, vmoid_t vmoid) { in Complete()
131 void WritebackWork::SetClosure(SyncCallback closure) { in SetClosure()
136 void WritebackWork::Complete() { in Complete()
144 void WritebackWork::PinVnode(fbl::RefPtr<VnodeMinfs> vn) { in PinVnode()
281 void WritebackBuffer::Enqueue(fbl::unique_ptr<WritebackWork> work) { in Enqueue()
|
| A D | minfs-private.h | 167 zx_status_t InoFree(VnodeMinfs* vn, WritebackWork* wb);
170 void AddUnlinked(WritebackWork* wb, VnodeMinfs* vn);
173 void RemoveUnlinked(WritebackWork* wb, VnodeMinfs* vn);
394 friend zx_status_t Minfs::InoFree(VnodeMinfs* vn, WritebackWork* wb);
395 friend void Minfs::AddUnlinked(WritebackWork* wb, VnodeMinfs* vn);
396 friend void Minfs::RemoveUnlinked(WritebackWork* wb, VnodeMinfs* vn);
469 void RemoveInodeLink(WritebackWork* wb);
628 void InodeSync(WritebackWork* wb, uint32_t flags);
635 void Purge(WritebackWork* wb);
|
| A D | minfs.cpp | 285 fbl::unique_ptr<WritebackWork> work(new WritebackWork(bc_.get())); in BeginTransaction()
355 zx_status_t Minfs::InoFree(VnodeMinfs* vn, WritebackWork* wb) { in InoFree()
463 void Minfs::AddUnlinked(WritebackWork* wb, VnodeMinfs* vn) { in AddUnlinked()
492 void Minfs::RemoveUnlinked(WritebackWork* wb, VnodeMinfs* vn) { in RemoveUnlinked()
|
| A D | vnode.cpp | 120 void VnodeMinfs::InodeSync(WritebackWork* wb, uint32_t flags) { in InodeSync()
841 void VnodeMinfs::RemoveInodeLink(WritebackWork* wb) { in RemoveInodeLink()
1158 void VnodeMinfs::Purge(WritebackWork* wb) { in Purge()
|