69 lines
1.6 KiB
C++
69 lines
1.6 KiB
C++
|
#include "CommandParser.h"
|
||
|
|
|
||
|
|
#include <QIODevice>
|
||
|
|
|
||
|
|
CommandParser::CommandParser(QIODevice *device, QObject *parent) :
|
||
|
|
QObject(parent) {
|
||
|
|
m_device = device;
|
||
|
|
m_expectingDataSize = -1;
|
||
|
|
connect(m_device, SIGNAL(readyRead()), this, SLOT(checkNext()));
|
||
|
|
}
|
||
|
|
|
||
|
|
void CommandParser::checkNext() {
|
||
|
|
if (m_expectingDataSize == -1) {
|
||
|
|
if (m_device->canReadLine()) {
|
||
|
|
readLine();
|
||
|
|
checkNext();
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
if (m_device->bytesAvailable() >= m_expectingDataSize) {
|
||
|
|
readDataBlock();
|
||
|
|
checkNext();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void CommandParser::readLine() {
|
||
|
|
char buffer[128];
|
||
|
|
qint64 lineLength = m_device->readLine(buffer, 128);
|
||
|
|
if (lineLength != -1) {
|
||
|
|
buffer[lineLength - 1] = 0;
|
||
|
|
processNext(buffer);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void CommandParser::readDataBlock() {
|
||
|
|
char *buffer = new char[m_expectingDataSize + 1];
|
||
|
|
m_device->read(buffer, m_expectingDataSize);
|
||
|
|
buffer[m_expectingDataSize] = 0;
|
||
|
|
processNext(buffer);
|
||
|
|
m_expectingDataSize = -1;
|
||
|
|
delete[] buffer;
|
||
|
|
}
|
||
|
|
|
||
|
|
void CommandParser::processNext(const char *data) {
|
||
|
|
if (m_commandName.isNull()) {
|
||
|
|
m_commandName = data;
|
||
|
|
m_argumentsExpected = -1;
|
||
|
|
} else {
|
||
|
|
processArgument(data);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void CommandParser::processArgument(const char *data) {
|
||
|
|
if (m_argumentsExpected == -1) {
|
||
|
|
m_argumentsExpected = QString(data).toInt();
|
||
|
|
} else if (m_expectingDataSize == -1) {
|
||
|
|
m_expectingDataSize = QString(data).toInt();
|
||
|
|
} else {
|
||
|
|
m_arguments.append(QString::fromUtf8(data));
|
||
|
|
}
|
||
|
|
|
||
|
|
if (m_arguments.length() == m_argumentsExpected) {
|
||
|
|
emit commandReady(m_commandName, m_arguments);
|
||
|
|
m_commandName = QString();
|
||
|
|
m_arguments.clear();
|
||
|
|
m_argumentsExpected = -1;
|
||
|
|
}
|
||
|
|
}
|