Administrace komentářů

Ano, má to číst postupně. Šlo mi o to, aby se uživateli zobrazily první řádky prvních tabulek, hned jak přijdou jejich data, a uživatel s nimi mohl pracovat, i když se ještě průběžně načítají další.

Pouštěl jsem si to přes:

(for x in `seq 5`; do sleep 1; relpipe-in-fstab; done) | pv --quiet --rate-limit 50 | relpipe-out-chart.qt

a tam je hezky vidět, jak data postupně naskakují v jednotlivých buňkách a dá se s tím GUI současně pracovat.

Nakonec jsem to vyřešil tím, že jsem proxy zjednodušil:

class QtRelationalReaderStringHadler : public QObject, public RelationalReaderStringHadler {

	Q_OBJECT
public:
	QtRelationalReaderStringHadler(QObject* parent) : QObject(parent) {
	}

	virtual ~QtRelationalReaderStringHadler() {
	}

	virtual void startRelation(string_t name, std::vector<AttributeMetadata> attributes) override {
		emit startRelationReceived(name, attributes);
	}

	virtual void attribute(const string_t& value) override {
		emit attributeReceived(value);
	};

	virtual void endOfPipe() override {
		emit endOfPipeReceived();
	};

signals:
	void startRelationReceived(const string_t name, std::vector<AttributeMetadata> attributes);
	void attributeReceived(const string_t value);
	void endOfPipeReceived();
};

Napojení signálů a slotů dělám v hlavním vlákně (původně to bylo v té proxy):

QObject::connect(&handler, &QtRelationalReaderStringHadler::startRelationReceived, &window, &RelpipeChartMainWindow::startRelation, Qt::ConnectionType::QueuedConnection);
QObject::connect(&handler, &QtRelationalReaderStringHadler::attributeReceived, &window, &RelpipeChartMainWindow::attribute, Qt::ConnectionType::QueuedConnection);
QObject::connect(&handler, &QtRelationalReaderStringHadler::endOfPipeReceived, &window, &RelpipeChartMainWindow::endOfPipe, Qt::ConnectionType::QueuedConnection);

A v GUI třídě implementuji sloty:

void RelpipeChartMainWindow::startRelation(const string_t name, std::vector<AttributeMetadata> attributes) {
	setStatusMessage(L"Reading relation: " + name);
	attributeCounter = 0;
	QSplitter* splitter = new QSplitter(Qt::Orientation::Vertical, tabs);

	currentTable = new QTableWidget(0, attributes.size(), splitter);
	QStringList headers;
	for (AttributeMetadata a : attributes) headers << QString::fromWCharArray(a.getAttributeName().c_str());
	currentTable->setHorizontalHeaderLabels(headers);
	currentTable->horizontalHeader()->setSectionResizeMode(QHeaderView::ResizeMode::ResizeToContents);

	// TODO: chart
	splitter->addWidget(new QPushButton("here will be the chart", splitter));
	splitter->addWidget(currentTable);
	int index = tabs->addTab(splitter, QString::fromWCharArray(name.c_str()));
	if (tabs->count() == 2) tabs->setCurrentIndex(index); // switch to the first relation (first tab is Options tab)
	tabs->setTabIcon(index, QIcon::fromTheme("application-vnd.oasis.opendocument.spreadsheet"));
}

void RelpipeChartMainWindow::attribute(const string_t value) {
	// TODO: draw chart
	integer_t column = attributeCounter % currentTable->columnCount();
	integer_t row = attributeCounter / currentTable->columnCount();
	if (row >= currentTable->rowCount()) currentTable->insertRow(currentTable->rowCount());
	currentTable->setItem(row, column, new QTableWidgetItem(QString::fromWCharArray(value.c_str())));
	attributeCounter++;
}

void RelpipeChartMainWindow::setStatusMessage(string_t message) {
	status->setText(QString::fromWCharArray(message.c_str()));
}

void RelpipeChartMainWindow::endOfPipe() {
	setStatusMessage(L"Reading successfully finished.");
}

Tu proxy bych nejradši zredukoval ještě víc, ale ty metody dané rozhraním RelationalReaderStringHadler jsou virtuální a nešlo mi je použít jako signály, takže jsou to normální metody a signál se z nich jen emituje, místo aby sama ta metoda byla signálem. Ale to už není tolik kódu navíc, takže jsem s tím už víceméně spokojený.

Nedokáži posoudit, jestli by to přes QFuture bylo jednodušší/lepší...