uapp/iochk/iochk.cpp

14 #include <fbl/atomic.h>
15 #include <fbl/auto_lock.h>
16 #include <fbl/macros.h>
17 #include <fbl/mutex.h>
18 #include <fbl/unique_fd.h>
19 #include <fbl/unique_ptr.h>
96     WorkContext(fbl::unique_fd fd, ProgressBar progress)
97         : fd(fbl::move(fd)), progress(progress) {}
103     fbl::unique_fd fd;
113     fbl::Mutex lock;
185     static zx_status_t Initialize(const fbl::unique_fd& fd, block_info_t info,
187                                   fbl::unique_ptr<Checker>* checker) {
188         fbl::unique_ptr<fzl::MappedVmo> mapped_vmo;
212         checker->reset(new BlockChecker(fbl::move(mapped_vmo), info, client, vmoid, group));
277     BlockChecker(fbl::unique_ptr<fzl::MappedVmo> mapped_vmo, block_info_t info,
279         : Checker(mapped_vmo->GetData()), mapped_vmo_(fbl::move(mapped_vmo)), info_(info),
283     static fbl::atomic<uint16_t> next_txid_;
285     fbl::unique_ptr<fzl::MappedVmo> mapped_vmo_;
292 fbl::atomic<uint16_t> BlockChecker::next_txid_;
296     static zx_status_t Initialize(fbl::unique_fd& fd, skip_block_partition_info_t info,
297                                   fbl::unique_ptr<Checker>* checker) {
298         fbl::unique_ptr<fzl::MappedVmo> mapped_vmo;
305         checker->reset(new SkipBlockChecker(fbl::move(mapped_vmo), fd, info));
377     SkipBlockChecker(fbl::unique_ptr<fzl::MappedVmo> mapped_vmo, fbl::unique_fd& fd,
379         : Checker(mapped_vmo->GetData()), mapped_vmo_(fbl::move(mapped_vmo)), fd_(fd), info_(info) {}
382     fbl::unique_ptr<fzl::MappedVmo> mapped_vmo_;
383     fbl::unique_fd& fd_;
387 zx_status_t InitializeChecker(WorkContext& ctx, fbl::unique_ptr<Checker>* checker) {
393     fbl::unique_ptr<Checker> checker;
422     fbl::unique_ptr<Checker> checker;
452         fbl::AutoLock al(&ctx->lock);
495     fbl::unique_fd fd(open(device, O_RDONLY));
564     WorkContext ctx(fbl::move(fd), ProgressBar());
649         if (block_client::Client::Create(fbl::move(fifo), &ctx.block.client) != ZX_OK) {
696         fbl::unique_ptr<Checker> checker;