| 518 | } |
| 519 | |
| 520 | void Datastore::beginRead(bool rereadBadSectors) |
| 521 | { |
| 522 | Events::OperationStart::post("fluxengine.view.status.readDevice"_lang); |
| 523 | Datastore::runOnWorkerThread( |
| 524 | [=] |
| 525 | { |
| 526 | busy = true; |
| 527 | failed = false; |
| 528 | DEFER(wtOperationStop()); |
| 529 | |
| 530 | try |
| 531 | { |
| 532 | wtRebuildConfiguration(true); |
| 533 | if (!rereadBadSectors) |
| 534 | wtClearDiskData(); |
| 535 | |
| 536 | std::shared_ptr<Disk> disk; |
| 537 | wtRunSynchronouslyOnUiThread((std::function<void()>)[&] { |
| 538 | if (::disk) |
| 539 | disk = std::make_shared<Disk>(*::disk); |
| 540 | else |
| 541 | disk = std::make_shared<Disk>(); |
| 542 | }); |
| 543 | auto fluxSource = FluxSource::create(globalConfig()); |
| 544 | auto decoder = Arch::createDecoder(globalConfig()); |
| 545 | |
| 546 | readDiskCommand(*diskLayout, *fluxSource, *decoder, *disk); |
| 547 | } |
| 548 | catch (...) |
| 549 | { |
| 550 | failed = true; |
| 551 | throw; |
| 552 | } |
| 553 | }); |
| 554 | } |
| 555 | |
| 556 | void Datastore::beginWrite() |
| 557 | { |
nothing calls this directly
no test coverage detected