Function writeTracks

lib/algorithms/readerwriter.cc:433–509

}

void writeTracks(const DiskLayout& diskLayout,

    FluxSinkFactory& fluxSinkFactory,
    std::function<std::unique_ptr<const Fluxmap>(
        const std::shared_ptr<const LogicalTrackLayout>&)> producer,
    std::function<bool(const std::shared_ptr<const LogicalTrackLayout>&)>
        verifier,
    const std::vector<CylinderHead>& logicalLocations)
{
    log(BeginOperationLogMessage{"Encoding and writing to disk"});

    if (fluxSinkFactory.isHardware())
        measureDiskRotation();
    {
        auto fluxSink = fluxSinkFactory.create();
        int index = 0;
        for (auto& ch : logicalLocations)
        {
            log(OperationProgressLogMessage{
                index * 100 / (unsigned)logicalLocations.size()});
            index++;

            testForEmergencyStop();

            const auto& ltl = diskLayout.layoutByLogicalLocation.at(ch);
            int retriesRemaining = globalConfig()->decoder().retries();
            for (;;)
            {
                for (int offset = 0; offset < ltl->groupSize;
                    offset += diskLayout.headWidth)
                {
                    unsigned physicalCylinder = ltl->physicalCylinder + offset;
                    unsigned physicalHead = ltl->physicalHead;

                    log(BeginWriteOperationLogMessage{
                        physicalCylinder, ltl->physicalHead});

                    if (offset == globalConfig()->drive().group_offset())
                    {
                        auto fluxmap = producer(ltl);
                        if (!fluxmap)
                            goto erase;

                        fluxSink->addFlux(
                            physicalCylinder, physicalHead, *fluxmap);
                        log("writing {0} ms in {1} bytes",
                            int(fluxmap->duration() / 1e6),
                            fluxmap->bytes());
                    }
                    else
                    {
                    erase:
                        /* Erase this track rather than writing. */

                        Fluxmap blank;
                        fluxSink->addFlux(
                            physicalCylinder, physicalHead, blank);
                        log("erased");