propellermanager.h

#pragma once

#include <QTimer>
#include <QStringList>
#include <QHash>

#include "../device/propellerdevice.h"
#include "../session/propellersession.h"
#include "../session/readbuffer.h"

class PropellerSession;


class PropellerManager : public QObject
{
    Q_OBJECT

private:
    QTimer portMonitor;
    QStringList _ports;
    QHash<QString, PropellerDevice *> _devices;
    QHash<PropellerDevice *, quint32> _active_sessions;
    QHash<PropellerDevice *, PropellerSession *> _busy;
    QHash<PropellerSession *, PropellerSession *> _paused;
    QHash<PropellerSession *, PropellerSession *> _sessions;

    QHash<PropellerSession *, PropellerDevice *> _connections;
    QHash<PropellerSession *, PropellerDevice *> _saved_connections;

    QHash<PropellerSession *, ReadBuffer *> _buffers;
    
    void attach(PropellerSession * session, PropellerDevice * device);
    void attachByName(PropellerSession * session, const QString & port);
    void detach(PropellerSession * session, PropellerDevice * device);
    bool portIsBusy(PropellerSession * session, const QString & name);

    PropellerDevice * getDevice(const QString & port, bool open = true);
    void deleteDevice(const QString & port);

private slots:
    void readyBuffer();
    void checkPorts();

public:
    PropellerManager(QObject *parent = 0);
    ~PropellerManager();

    const QStringList & listPorts();
    void enablePortMonitor(bool enabled);


    bool        beginSession(PropellerSession * session);
    void        endSession(PropellerSession * session);

    bool        isOpen(PropellerSession * session, const QString & port);
    bool        clear(PropellerSession * session, const QString & port);

    bool        setBaudRate(PropellerSession * session, const QString & port, quint32 baudRate);

    qint64      bytesToWrite(PropellerSession * session, const QString & port);
    qint64      bytesAvailable(PropellerSession * session, const QString & port);

    QByteArray  read(PropellerSession * session, const QString & port, qint64 maxSize);
    QByteArray  readAll(PropellerSession * session, const QString & port);

    bool        putChar(PropellerSession * session, const QString & port, char c);
    qint64      write(PropellerSession * session, const QString & port, const QByteArray & byteArray);
    QString     errorString(PropellerSession * session, const QString & port);
    int         error(PropellerSession * session, const QString & port);

    quint32     minimumTimeout(PropellerSession * session, const QString & port);
    void        setMinimumTimeout(PropellerSession * session, const QString & port, quint32 milliseconds);
    quint32     calculateTimeout(PropellerSession * session, const QString & port, quint32 bytes);
    void        useReset(PropellerSession * session, const QString & port, const QString & name, int pin);
    void        useDefaultReset(PropellerSession * session, const QString & port);
    bool        reset(PropellerSession * session, const QString & port);
    quint32     resetPeriod(PropellerSession * session, const QString & port);

    bool        reserve(PropellerSession * session, const QString & port);
    bool        isReserved(PropellerSession * session, const QString & port);
    void        release(PropellerSession * session, const QString & port);

    void        pause(PropellerSession * session);
    bool        isPaused(PropellerSession * session);
    void        unpause(PropellerSession * session);


signals:
    void portListChanged();
};