nand_programmer

/*  Copyright (C) 2020 NANDO authors
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License version 3.
 */

#ifndef READER_H
#define READER_H

#include <QObject>
#include "sync_buffer.h"
#include "serial_port.h"

class Reader : public QObject
{
    Q_OBJECT

    static const uint32_t bufSize = 4096;

    SerialPort *serialPort = nullptr;
    QString portName;
    qint32 baudRate;
    SyncBuffer *rbuf;
    quint64 rlen;
    const uint8_t *wbuf;
    uint32_t wlen;
    quint64 readOffset;
    quint64 bytesRead;
    quint64 bytesReadNotified;
    int offset;
    bool isSkipBB;
    bool isReadLess;
    char pbuf[bufSize];

    int serialPortCreate();
    void serialPortDestroy();
    int write(const uint8_t *data, uint32_t len);
    int readStart();
    int read(char *pbuf, uint32_t len);
    void readCb(int size);
    int handleError(char *pbuf, uint32_t len);
    int handleProgress(char *pbuf, uint32_t len);
    int handleBadBlock(char *pbuf, uint32_t len, bool isSkipped);
    int handleStatus(char *pbuf, uint32_t len);
    int handleData(char *pbuf, uint32_t len);
    int handlePacket(char *pbuf, uint32_t len);
    int handlePackets(char *pbuf, uint32_t len);
    void logErr(const QString& msg);
    void logInfo(const QString& msg);
public:
    explicit Reader();
    ~Reader();

    void init(const QString &portName, qint32 baudRate, SyncBuffer *rbuf,
        quint64 rlen, const uint8_t *wbuf, uint32_t wlen, bool isSkipBB,
        bool isReadLess);
    void start();
    void stop();
signals:
    void result(quint64 ret);
    void progress(quint64 progress);
    void log(QtMsgType msgType, QString msg);
};

#endif // READER_H