Files
@ 3ea2936f9c86
Branch filter:
Location: tempo-plotter/tests/test_readers.cpp
3ea2936f9c86
4.8 KiB
text/x-c++hdr
add doc comment
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 | /*
Copyright © 2018 Hasan Yavuz Özderya
This file is part of serialplot.
serialplot is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
serialplot is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with serialplot. If not, see <http://www.gnu.org/licenses/>.
*/
// This tells Catch to provide a main() - only do this in one cpp file per executable
#define CATCH_CONFIG_RUNNER
#include "catch.hpp"
#include <QSignalSpy>
#include <QBuffer>
#include "binarystreamreader.h"
#include "asciireader.h"
#include "framedreader.h"
#include "test_helpers.h"
static const int READYREAD_TIMEOUT = 10; // milliseconds
TEST_CASE("reading data with BinaryStreamReader", "[reader]")
{
QBuffer bufferDev;
BinaryStreamReader bs(&bufferDev);
bs.enable(true);
TestSink sink;
bs.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
bufferDev.open(QIODevice::ReadWrite);
const char data[] = {0x01, 0x02, 0x03, 0x04};
bufferDev.write(data, 4);
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
REQUIRE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink.totalFed == 4);
}
TEST_CASE("disabled BinaryStreamReader shouldn't read", "[reader]")
{
QBuffer bufferDev;
BinaryStreamReader bs(&bufferDev); // disabled by default
TestSink sink;
bs.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
bufferDev.open(QIODevice::ReadWrite);
const char data[] = {0x01, 0x02, 0x03, 0x04};
bufferDev.write(data, 4);
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
// readyRead isn't signaled because there are no connections to it
REQUIRE_FALSE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink.totalFed == 0);
}
TEST_CASE("reading data with AsciiReader", "[reader, ascii]")
{
QBuffer bufferDev;
AsciiReader reader(&bufferDev);
reader.enable(true);
TestSink sink;
reader.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
// inject data to the buffer
bufferDev.open(QIODevice::ReadWrite);
bufferDev.write("0,1,3\n0,1,3\n0,1,3\n0,1,3\n");
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
REQUIRE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink._numChannels == 3);
REQUIRE(sink._hasX == false);
REQUIRE(sink.totalFed == 3);
}
TEST_CASE("AsciiReader shouldn't read when disabled", "[reader, ascii]")
{
QBuffer bufferDev;
AsciiReader reader(&bufferDev); // disabled by default
TestSink sink;
reader.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
// inject data to the buffer
bufferDev.open(QIODevice::ReadWrite);
bufferDev.write("0,1,3\n0,1,3\n0,1,3\n0,1,3\n");
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
REQUIRE_FALSE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
REQUIRE(sink.totalFed == 0);
}
TEST_CASE("reading data with FramedReader", "[reader]")
{
QBuffer bufferDev;
FramedReader reader(&bufferDev);
reader.enable(true);
TestSink sink;
reader.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
bufferDev.open(QIODevice::ReadWrite);
const uint8_t data[] = {0xAA, 0xBB, 4, 0x01, 0x02, 0x03, 0x04};
bufferDev.write((const char*) data, 7);
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
REQUIRE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink.totalFed == 4);
}
TEST_CASE("FramedReader shouldn't read when disabled", "[reader]")
{
QBuffer bufferDev;
FramedReader reader(&bufferDev);
TestSink sink;
reader.connectSink(&sink);
REQUIRE(sink._numChannels == 1);
REQUIRE(sink._hasX == false);
bufferDev.open(QIODevice::ReadWrite);
const uint8_t data[] = {0xAA, 0xBB, 4, 0x01, 0x02, 0x03, 0x04};
bufferDev.write((const char*) data, 7);
bufferDev.seek(0);
QSignalSpy spy(&bufferDev, SIGNAL(readyRead()));
REQUIRE_FALSE(spy.wait(READYREAD_TIMEOUT));
REQUIRE(sink.totalFed == 0);
}
// Note: this is added because `QApplication` must be created for widgets
#include <QApplication>
int main(int argc, char* argv[])
{
QApplication a(argc, argv);
int result = Catch::Session().run( argc, argv );
return result;
}
|