SerialGPSTransport.h

Go to the documentation of this file.

#pragma once
 
#include <chrono>
#include <cstdint>
#include <memory>
 
#include <QtCore/QString>
 
#include "GPSDeviceTransport.h"
 
class QSerialPort;
 
class SerialGPSTransport : public GPSDeviceTransport
{
public:
    static constexpr std::chrono::milliseconds OPEN_TIMEOUT{30000};
 
    SerialGPSTransport(QString device, GPSCancelToken cancelToken,
                       std::chrono::milliseconds openTimeout = OPEN_TIMEOUT);
    ~SerialGPSTransport() override;
 
    GPSOpenResult open() override;
 
    bool fatalError() const override;
 
    bool setBaudrate(unsigned baudrate) override;
 
protected:
    QIODevice* device() const override;
    bool readUnavailable() const override;
    bool waitReadable(QDeadlineTimer deadline) override;
    GPSReadResult readFailure() const override;
    void waitWritten(QDeadlineTimer& deadline) override;
    qint64 confirmedWritten(int accepted, qint64 drained) override;
 
private:
    static constexpr std::chrono::milliseconds CANCELLATION_POLL{50};
    static constexpr std::chrono::milliseconds OPEN_RETRY{500};
 
    QString _errorDetail() const;
    bool _inputBudgetExhausted() const;
 
    QString _device;
    std::chrono::milliseconds _openTimeout;
    std::unique_ptr<QSerialPort> _serial;
    bool _inputOverflow = false;
    qint64 _acceptedTotal = 0;
    qint64 _writtenTotal = 0;
};