fluxengine/lib/fluxsink/hardwarefluxsink.cc

#include "globals.h"
#include "flags.h"
#include "fluxmap.h"
#include "logger.h"
#include "proto.h"
#include "usb/usb.h"
#include "fluxsink/fluxsink.h"
#include "lib/fluxsink/fluxsink.pb.h"
#include "lib/readerwriter.h"

class HardwareFluxSink : public FluxSink
{
public:
    HardwareFluxSink(const HardwareFluxSinkProto& conf): _config(conf)
    {
        nanoseconds_t oneRevolution;
        measureDiskRotation(oneRevolution, _hardSectorThreshold);
    }

    ~HardwareFluxSink() {}

public:
    void writeFlux(int track, int side, const Fluxmap& fluxmap) override
    {
        usbSetDrive(globalConfig()->drive().drive(),
            globalConfig()->drive().high_density(),
            globalConfig()->drive().index_mode());
#if 0
		if (fluxSourceSinkFortyTrack)
		{
			if (track & 1)
				error("cannot write to odd physical tracks in 40-track mode");
			usbSeek(track / 2);
		}
		else
#endif
        usbSeek(track);

        return usbWrite(side, fluxmap.rawBytes(), _hardSectorThreshold);
    }

    operator std::string() const
    {
        return fmt::format("drive {}", globalConfig()->drive().drive());
    }

private:
    const HardwareFluxSinkProto& _config;
    nanoseconds_t _hardSectorThreshold;
};

std::unique_ptr<FluxSink> FluxSink::createHardwareFluxSink(
    const HardwareFluxSinkProto& config)
{
    return std::unique_ptr<FluxSink>(new HardwareFluxSink(config));
}