прием/отправка по rs232 в реалтайм

[lenovo2014]

всем привет. появилась задача приема/отправки сообщений по последовательному порту. Интрефейс rs232 является асинхронным, следовательно нужно посадить порт на прослушку. Данные приходят почти что непрерывно. В данный момент реализовал это вот так:
конектим сигнал

Код:

serialportthread_2::serialportthread_2(QObject *parent) :
    QThread(parent)
{
    connect(&this->port,SIGNAL(readyRead()),this,SLOT(receive()));

}

Код:

void serialportthread_2::run(){
    if(open()){
        while(1){
        port.waitForReadyRead(100);
        this->msleep(100);
        }
       }
    exec();
}

Код:

bool serialportthread_2::receive(){
    port.read(&data[0],30);
    // далее вытаскиваю данные
   port.reset(); // если без этой строчки - через некоторое время программа виснет на строках   [b]exec()[/b] либо [b]port.read(&data[0],30)[/b]
}

вроде все работает, но мне кажется, что это криворукий способ.
может кто подскажет как пограмотнее решить задачу?
зы: также пробовал такой вариант:

Код:

void serialportthread_2::run(){
    if(open()){
        port.waitForReadyRead(-1);

       }
    exec();
}

в этом случае программа вешается через некоторое время

[Fregloin]

ну во первых зачем использовать одновременно waitFor... и сигнал readyRead()?
Первые функции следует использовать при блокирующих вызовах, а сигнал при асинхронной работе.
Во вторых вы не проверяете bytesAvailable(). Ну и не помешало бы вам глянуть простые примеры при работе с сокетами. Хотя с ком портом не работал в Qt, так что конкретно сказать не могу.
Если вы работаете в linux, то наверное проще будет работать через стандартные файловые функции.

[kuzulis]

1. В корне неверная работа с тредами (если они действительно нужны). Поэтому все и виснет. Погугли.
2. Достаточно и желательно только использовать связку readyRead() && receive() без всяких waitForXX() и msleep(100)..
3. Треды не нужны. Использовать нужно только если слишком долго осуществляется парсинг данных.

В итоге - колбаса

[lenovo2014]

1. В корне неверная работа с тредами (если они действительно нужны). Поэтому все и виснет. Погугли.
2. Достаточно и желательно только использовать связку readyRead() && receive() без всяких waitForXX() и msleep(100)..
3. Треды не нужны. Использовать нужно только если слишком долго осуществляется парсинг данных.

В итоге - колбаса

сделал используя связку readyRead() && receive() ; все работает, но через некоторе время, когда число port.bytesAvailable() превышает некий порог, и ,я так понимаю, из-за переполнения буфера , программа виснет. Существует ли способ сбросить буфер ?

[kuzulis]

По умолчанию нет никакого ограничения на размер буфера (по умолчанию он бесконечный ).
Если нужно ограничение, то нужно установить setReadBufferSize(size > 0).

Скорее всего что-то делаешь не так. Приведи код.

[lenovo2014]

По умолчанию нет никакого ограничения на размер буфера (по умолчанию он бесконечный ).
Если нужно ограничение, то нужно установить setReadBufferSize(size > 0).

Скорее всего что-то делаешь не так. Приведи код.

Код:

#include "serialportthread_2.h"
#include "mainwidget.h"

serialportthread_2::serialportthread_2(QObject *parent) :
    QThread(parent)
{
    connect(&this->port,SIGNAL(readyRead()),this,SLOT(receive()));

}
void serialportthread_2::run(){

    if(open()){

        }
    else{
        emit response_2("can't open serial port");
    }
    exec();

}
bool serialportthread_2::open(){
    //port.setPortName("/dev/ttyMI3");
    port.setPortName("/dev/ttyUSB0");
    if(port.open(QIODevice::ReadWrite)){
    port.setBaudRate(QSerialPort::Baud19200);
    port.setDataBits(QSerialPort::Data8);
    //port.setParity(QSerialPort::NoParity);
    port.setStopBits(QSerialPort::OneStop);
    return true;
    }
    else{
        return false;
    }

}
bool serialportthread_2::close(){
    port.close();
}
bool serialportthread_2::receive(){
            port.read(&data[0],30); // зависает на этой строчке
            ...
            QByteArray b;
            b.append(&data[i],12); 
            QString msg = b.toHex();
            emit response_2(msg);
}
bool serialportthread_2::send(){
    if(port.write(komanda,n_k))

}

зы : это происходит только при непрерывном потоке данных от устройства. в режиме одиночных команд все нормально работает

[Mikhail]

Не увидел где определена data и ее размер. Может быть переполнение.
Где проверка количества пришедших байт?

[kuzulis]

lenovo2014,

Да елки зеленые, почитай про работу с QThread уже. Или не используй QThread если не умеешь.

[lenovo2014]

Не увидел где определена data и ее размер. Может быть переполнение.
Где проверка количества пришедших байт?

char data[100]; // это объявление массива
port.read(&data[0],30); // считываю 30 байт, проверял в дебаг режиме

[lenovo2014]

lenovo2014,

Да елки зеленые, почитай про работу с QThread уже. Или не используй QThread если не умеешь.

ты конкретно скажи что не так, все же по документации я сделал

[kuzulis]

ты конкретно скажи что не так, все же по документации я сделал

Не хочу. Я уже посоветовал все что нужно.

[Fregloin]

во первых каждый раз при вызове слота чтения данных с сокета/порта следует проверить сколько данных в буфере. достаточно ли их для чтения или стоит еще подождать.
очевидно что у тебя зависает на функции read, потому что в буфере скорее всего недостаточно данных (нет 30 байт). поэтому если известен за ранее объем ожидаемых данных, стоит дождаться его.
например так

Код:

void MyObject::connected()
{
 offset = 0LL;
}

void MyObject::readyData()
{
 QTcpSocket * s = qobject_cast<QTcpSocket*>(sender()); //при условии что один поток, можно вообще напрямую обращаться к внутренним данным если сокет/порт один на объект
 qint64 bytesCount = s->bytesAvailable();
 if(bytesAvailable<neededSize) //needed size - размер ожидаемых данных, как его получить вам решать (константа или получать как то в заголовках пакетов)
  return;
 qint64 readBytes = s->read(&data[offset],neededSize);
 if(readBytes<0LL)
 {
 //обработка ошибки чтения
 }
 else
 if(readBytes==0LL)
 {
 //сокет был закрыт на удаленной стороне, на счёт ком порта не знаю но лучше проверить
 }
 else
 offset += readBytes //если у вас буфер на несколько пакетов или читаете частями
 if(offset==desiredPacketSize) //получены данные целиком
 {
 emit dataReady(&data[0]); //сигналим о полном приеме пакета с адресом буфера, или передавать QByteArray(data);
 }
}

Это не полный код, но суть такая.
Если у вас данные всегда одного размера все намного проще. Если размер данных палвающий, то каким то образом следует сначала передать размер пакета, а потом сами данные.
Как это сделать решать вам, я для этого в начале данных всегда передаю фиксированную структуру данных типа

Код:

struct Header {
quint32 signature;
quint32 packetSize;
... //прочие полезные данные
};

И данные будут идти тогда так

Код:

[Header][Data .....][Header][Data ...]...