Method testTcpReadContinuousFixed00

tests/livedata/LiveDataTest.cpp:1417–1455

}

void LiveDataTest::testTcpReadContinuousFixed00() {
	// initialize the live data source
	LiveDataSource dataSource(QStringLiteral("test"), false);
	dataSource.setSourceType(LiveDataSource::SourceType::NetworkTCPSocket);
	dataSource.setFileType(AbstractFileFilter::FileType::Ascii);
	dataSource.setHost(hostname);
	dataSource.setPort(TCP_PORT);
	dataSource.setReadingType(LiveDataSource::ReadingType::ContinuousFixed);
	dataSource.setSampleSize(100); // big number of samples, more then the new data has, meaning we read all new data
	dataSource.setUpdateType(LiveDataSource::UpdateType::TimeInterval);
	dataSource.setRowCount(0);

	// initialize the ASCII filter
	auto* filter = new AsciiFilter();
	auto properties = filter->defaultProperties();
	properties.headerEnabled = false;
	properties.automaticSeparatorDetection = false;
	properties.separator = QStringLiteral(",");
	filter->setProperties(properties);
	dataSource.setFilter(filter);

	dataSource.setUpdateInterval(updateIntervalMs); // Start

	// wait until livedata update time is finished and triggers a read
	wait(updateIntervalMs * 3);
	dataSource.pauseReading();

	QCOMPARE(dataSource.columnCount(), 2);
	QVERIFY(dataSource.rowCount() > 0);

	QCOMPARE(dataSource.column(0)->columnMode(), AbstractColumn::ColumnMode::Double);
	QCOMPARE(dataSource.column(1)->columnMode(), AbstractColumn::ColumnMode::Double);

	QCOMPARE(dataSource.column(0)->valueAt(0), 1.);
	QCOMPARE(dataSource.column(1)->valueAt(0), 2.);

	QCOMPARE(dataSource.column(0)->valueAt(dataSource.rowCount() - 1), 1.);
	QCOMPARE(dataSource.column(1)->valueAt(dataSource.rowCount() - 1), 2.);
}

// ##############################################################################
// ##################################  UDP ######################################