summaryrefslogtreecommitdiffhomepage
path: root/tracker-hatire
diff options
context:
space:
mode:
Diffstat (limited to 'tracker-hatire')
-rwxr-xr-xtracker-hatire/ftnoir_tracker_hat.cpp12
-rwxr-xr-xtracker-hatire/thread.cpp5
-rwxr-xr-xtracker-hatire/thread.hpp2
3 files changed, 6 insertions, 13 deletions
diff --git a/tracker-hatire/ftnoir_tracker_hat.cpp b/tracker-hatire/ftnoir_tracker_hat.cpp
index 1ac0a1ad..25f0b903 100755
--- a/tracker-hatire/ftnoir_tracker_hat.cpp
+++ b/tracker-hatire/ftnoir_tracker_hat.cpp
@@ -10,6 +10,7 @@
*/
#include <QDebug>
#include "ftnoir_tracker_hat.h"
+#include <algorithm>
hatire::hatire()
{
@@ -93,7 +94,6 @@ void hatire::data(double *data)
if (ok)
{
-
while (data_read.length() >= 30)
{
//t.Log(data_read.toHex());
@@ -120,28 +120,28 @@ void hatire::data(double *data)
}
else
{
- bool ok = true;
// resync frame
int index = data_read.indexOf(Begin, 1);
if (index == -1)
{
- ok = false;
index = data_read.length();
}
emit t.serial_debug_info(data_read.mid(0,index));
if (!ok)
+ {
data_read.clear();
+ }
else
+ {
data_read.remove(0, index);
+ }
CptError++;
- qDebug() << QTime::currentTime() << "hatire resync stream" << "index" << index << "ok" << ok;
+ qDebug() << QTime::currentTime() << "hatire resync stream" << "index" << index << "remaining" << data_read.size();
}
}
-
- t.replace_data_nolock(std::move(data_read));
}
}
diff --git a/tracker-hatire/thread.cpp b/tracker-hatire/thread.cpp
index a33d58e0..40648c9f 100755
--- a/tracker-hatire/thread.cpp
+++ b/tracker-hatire/thread.cpp
@@ -276,11 +276,6 @@ void hatire_thread::on_serial_read()
portable::sleep(ms);
}
-void hatire_thread::replace_data_nolock(QByteArray&& data)
-{
- data_read = std::move(data);
-}
-
QByteArray& hatire_thread::send_data_read_nolock(bool& ret)
{
constexpr int packet_len = 30;
diff --git a/tracker-hatire/thread.hpp b/tracker-hatire/thread.hpp
index b1861bac..39719ef8 100755
--- a/tracker-hatire/thread.hpp
+++ b/tracker-hatire/thread.hpp
@@ -165,8 +165,6 @@ public:
~hatire_thread() override;
hatire_thread();
- void replace_data_nolock(QByteArray&& data);
-
QByteArray& send_data_read_nolock(bool& ret);
void Log(const QString& message);