Function readDiskCommand

lib/algorithms/readerwriter.cc:701–848

}

void readDiskCommand(const DiskLayout& diskLayout,
    FluxSource& fluxSource,
    Decoder& decoder,
    Disk& disk)
{
    std::unique_ptr<FluxSinkFactory> outputFluxSinkFactory;
    if (globalConfig()->decoder().has_copy_flux_to())
        outputFluxSinkFactory =
            FluxSinkFactory::create(globalConfig()->decoder().copy_flux_to());

    std::map<CylinderHead, std::vector<std::shared_ptr<const Track>>>
        tracksByLogicalLocation;
    for (auto& [ch, track] : disk.tracksByPhysicalLocation)
        tracksByLogicalLocation[CylinderHead(track->ltl->logicalCylinder,
                                    track->ltl->logicalHead)]
            .push_back(track);

    log(BeginOperationLogMessage{"Reading and decoding disk"});

    if (fluxSource.isHardware())
        disk.rotationalPeriod = measureDiskRotation();
    else
        disk.rotationalPeriod = getRotationalPeriodFromConfig();

    {
        std::unique_ptr<FluxSink> outputFluxSink;
        if (outputFluxSinkFactory)
            outputFluxSink = outputFluxSinkFactory->create();
        unsigned index = 0;
        for (auto& [logicalLocation, ltl] : diskLayout.layoutByLogicalLocation)
        {
            log(OperationProgressLogMessage{
                index * 100 /
                (unsigned)diskLayout.layoutByLogicalLocation.size()});
            index++;

            testForEmergencyStop();

            auto& trackFluxes = tracksByLogicalLocation[logicalLocation];
            std::vector<std::shared_ptr<const Sector>> trackSectors;
            readAndDecodeTrack(diskLayout,
                fluxSource,
                decoder,
                ltl,
                trackFluxes,
                trackSectors);

            /* Replace all tracks on the disk by the new combined set. */

            for (const auto& flux : trackFluxes)
                disk.tracksByPhysicalLocation.erase(CylinderHead{
                    flux->ptl->physicalCylinder, flux->ptl->physicalHead});
            for (const auto& flux : trackFluxes)
                disk.tracksByPhysicalLocation.emplace(
                    CylinderHead{
                        flux->ptl->physicalCylinder, flux->ptl->physicalHead},
                    flux);