Пропадание сетевого обмена Опции

[KuvshinoF]

Программа_1 бесконечно посылает 1 раз в секунду определенный набор байтов, а программа_2 его читает, обрабатывает и визуализирует.
Чтение по udp сетевых данных в программе_2:

  QUdpSocket oUDPSocket;
  QByteArray baoBufRecv;
  unsigned short  usSendPort;
  QHostAddress haoLocalAddr, haoSenderAddr;

  baoBufRecv.resize(65535);
  haoLocalAddr.setAddress("127.0.0.1");
  oUDPSocket.bind(haoLocalAddr, 5000);
  connect(&oUDPSocket, SIGNAL(readyRead()), this, SLOT(sltReadDatagram()));
//-----------------------------------------------------------------------------

void Interaction::sltReadDatagram()
{
  vReadDatagram();
}
//-----------------------------------------------------------------------------

void Interaction::vReadDatagram()
{
  while (_oUDPSocket.hasPendingDatagrams())
  {
     long lSize = oUDPSocket.pendingDatagramSize();
     oUDPSocket.readDatagram(baoBufRecv.data(), lSize, &haoSenderAddr, &usSendPort);
    ...
  }
}

class Interaction: public QThread
{
}

Проблема в том, что программа_2 принимает всего около 10 сетевых посылок, а потом vReadDatagram перестает вызываться, как будто перестают идти данные от программы_1, но это не так (проверено индикацией данных от программы_1 в простейшей программе_3 и tcpdump-ом). Программа_2 достаточно сложна (многопоточна, gui c opengl) и что может приводить к такому "сетевому обрыву" - непонятно.

Сообщение отредактировал KuvshinoF - 20.4.2020, 11:35

[Алексей1153]

KuvshinoF, sltReadDatagram - это у тебя слот, и он по каким-то причинам перестаёт вызываться (точнее - не генерится сигнал)

его попробуй подпинывать в таймере (для теста сделай раз в секунду, чтобы чисто проверить)

//обработчик таймера

...()
{
    sltReadDatagram();
}

можете дать простейший пример

у меня сделано так:
(показано упрощённо)
в потоке, в бесконечном цикле внутри run

QByteArray part;
while(1)
{
    if(UDPServerSocket->state()==QUdpSocket::BoundState)
    {
        auto DatagramSize=UDPServerSocket->bytesAvailable();

        if(DatagramSize>0 && UDPServerSocket->hasPendingDatagrams())
        {
            //DatagramSize - тут неплохо бы ограничить на некий максимальный размер, чтобы не словить краш от нехватки памяти
            //DatagramSize=qMin<decltype(DatagramSize)>(20000,DatagramSize);

            part.resize(DatagramSize);
            const auto readsize=UDPServerSocket->readDatagram(part.data(), part.size(),&host, &port);
            if(readsize>=0)
            {
                part.resize(readsize);
            }
        }
    }

    //part - прочитанные данные
}