blob: a35aadc77b958422ab267bb478df1fac03fb6fcb (
plain)
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
|
// Copyright (C) 2012 Denis Shienkov <denis.shienkov@gmail.com>
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause
#include "receiverthread.h"
#include <QSerialPort>
#include <QTime>
ReceiverThread::ReceiverThread(QObject *parent) :
QThread(parent)
{
}
//! [0]
ReceiverThread::~ReceiverThread()
{
m_mutex.lock();
m_quit = true;
m_mutex.unlock();
wait();
}
//! [0]
//! [1] //! [2]
void ReceiverThread::startReceiver(const QString &portName, int waitTimeout, const QString &response)
{
//! [1]
const QMutexLocker locker(&m_mutex);
m_portName = portName;
m_waitTimeout = waitTimeout;
m_response = response;
//! [3]
if (!isRunning())
start();
}
//! [2] //! [3]
//! [4]
void ReceiverThread::run()
{
bool currentPortNameChanged = false;
m_mutex.lock();
//! [4] //! [5]
QString currentPortName;
if (currentPortName != m_portName) {
currentPortName = m_portName;
currentPortNameChanged = true;
}
int currentWaitTimeout = m_waitTimeout;
QString currentRespone = m_response;
m_mutex.unlock();
//! [5] //! [6]
QSerialPort serial;
while (!m_quit) {
//![6] //! [7]
if (currentPortName.isEmpty()) {
emit error(tr("Port not set"));
return;
} else if (currentPortNameChanged) {
serial.close();
serial.setPortName(currentPortName);
if (!serial.open(QIODevice::ReadWrite)) {
emit error(tr("Can't open %1, error code %2")
.arg(m_portName).arg(serial.error()));
return;
}
}
if (serial.waitForReadyRead(currentWaitTimeout)) {
//! [7] //! [8]
// read request
QByteArray requestData = serial.readAll();
while (serial.waitForReadyRead(10))
requestData += serial.readAll();
//! [8] //! [10]
// write response
const QByteArray responseData = currentRespone.toUtf8();
serial.write(responseData);
if (serial.waitForBytesWritten(m_waitTimeout)) {
const QString request = QString::fromUtf8(requestData);
//! [12]
emit this->request(request);
//! [10] //! [11] //! [12]
} else {
emit timeout(tr("Wait write response timeout %1")
.arg(QTime::currentTime().toString()));
}
//! [9] //! [11]
} else {
emit timeout(tr("Wait read request timeout %1")
.arg(QTime::currentTime().toString()));
}
//! [9] //! [13]
m_mutex.lock();
if (currentPortName != m_portName) {
currentPortName = m_portName;
currentPortNameChanged = true;
} else {
currentPortNameChanged = false;
}
currentWaitTimeout = m_waitTimeout;
currentRespone = m_response;
m_mutex.unlock();
}
//! [13]
}
|
