From 78606e49f3817d6d2877e47273be65a3aeda18b5 Mon Sep 17 00:00:00 2001 From: Denis Shienkov Date: Fri, 9 Nov 2012 22:24:58 +0000 Subject: Added new examples BlockingMaster and BlockingSlave These examples show how to work with I/O in a blocking mode without using signals/slots. Note: For these examples, the documentation is not yet done, must be done on future. Change-Id: I0029e8dd43f935629eb77529b2df5bb75d31e091 Reviewed-by: Denis Shienkov --- examples/blockingslave/transactionthread.cpp | 167 +++++++++++++++++++++++++++ 1 file changed, 167 insertions(+) create mode 100644 examples/blockingslave/transactionthread.cpp (limited to 'examples/blockingslave/transactionthread.cpp') diff --git a/examples/blockingslave/transactionthread.cpp b/examples/blockingslave/transactionthread.cpp new file mode 100644 index 0000000..6e158c8 --- /dev/null +++ b/examples/blockingslave/transactionthread.cpp @@ -0,0 +1,167 @@ +/**************************************************************************** +** +** Copyright (C) 2012 Denis Shienkov +** Contact: http://www.qt-project.org/ +** +** This file is part of the QtSerialPort module of the Qt Toolkit. +** +** $QT_BEGIN_LICENSE:LGPL$ +** GNU Lesser General Public License Usage +** This file may be used under the terms of the GNU Lesser General Public +** License version 2.1 as published by the Free Software Foundation and +** appearing in the file LICENSE.LGPL included in the packaging of this +** file. Please review the following information to ensure the GNU Lesser +** General Public License version 2.1 requirements will be met: +** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Nokia gives you certain additional +** rights. These rights are described in the Nokia Qt LGPL Exception +** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU General +** Public License version 3.0 as published by the Free Software Foundation +** and appearing in the file LICENSE.GPL included in the packaging of this +** file. Please review the following information to ensure the GNU General +** Public License version 3.0 requirements will be met: +** http://www.gnu.org/copyleft/gpl.html. +** +** Other Usage +** Alternatively, this file may be used in accordance with the terms and +** conditions contained in a signed written agreement between you and Nokia. +** +** +** +** +** +** +** $QT_END_LICENSE$ +** +****************************************************************************/ + +#include "transactionthread.h" + +#include + +#include + +QT_USE_NAMESPACE_SERIALPORT + +TransactionThread::TransactionThread(QObject *parent) + : QThread(parent), waitTimeout(0), quit(false) +{ +} + +TransactionThread::~TransactionThread() +{ + mutex.lock(); + quit = true; + mutex.unlock(); + wait(); +} + +void TransactionThread::startNewSlave(const QString &port, int transactionWaitTimeout, const QString &response) +{ + QMutexLocker locker(&mutex); + portName = port; + waitTimeout = transactionWaitTimeout; + responseText = response; + + if (!isRunning()) + start(); +} + +void TransactionThread::run() +{ + bool currentSerialPortNameChanged = false; + + mutex.lock(); + QString currentSerialPortName; + if (currentSerialPortName != portName) { + currentSerialPortName = portName; + currentSerialPortNameChanged = true; + } + + int currentTransactionWaitTimeout = waitTimeout; + QString currentResponseText = responseText; + mutex.unlock(); + + SerialPort serial; + + while (!quit) { + + if (currentSerialPortNameChanged) { + serial.close(); + serial.setPort(currentSerialPortName); + + if (!serial.open(QIODevice::ReadWrite)) { + emit error(tr("Can't open %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + + if (!serial.setRate(9600)) { + emit error(tr("Can't set rate 9600 baud to port %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + + if (!serial.setDataBits(SerialPort::Data8)) { + emit error(tr("Can't set 8 data bits to port %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + + if (!serial.setParity(SerialPort::NoParity)) { + emit error(tr("Can't set no patity to port %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + + if (!serial.setStopBits(SerialPort::OneStop)) { + emit error(tr("Can't set 1 stop bit to port %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + + if (!serial.setFlowControl(SerialPort::NoFlowControl)) { + emit error(tr("Can't set no flow control to port %1, error code %2") + .arg(portName).arg(serial.error())); + return; + } + } + + if (serial.waitForReadyRead(currentTransactionWaitTimeout)) { + + // read all request + QByteArray requestData = serial.readAll(); + while (serial.waitForReadyRead(10)) + requestData += serial.readAll(); + + // write all response + QByteArray responseData = currentResponseText.toLocal8Bit(); + serial.write(responseData); + if (serial.waitForBytesWritten(waitTimeout)) { + QString requestText(requestData); + emit request(requestText); + } else { + emit timeout(tr("Wait write response timeout %1") + .arg(QTime::currentTime().toString())); + } + } else { + emit timeout(tr("Wait read request timeout %1") + .arg(QTime::currentTime().toString())); + } + + mutex.lock(); + if (currentSerialPortName != portName) { + currentSerialPortName = portName; + currentSerialPortNameChanged = true; + } else { + currentSerialPortNameChanged = false; + } + currentTransactionWaitTimeout = waitTimeout; + currentResponseText = responseText; + mutex.unlock(); + } +} -- cgit v1.2.1