VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2025-10-31 13:00:26 -04:00
Code Issues Projects Releases Wiki Activity

RemoteTCPSink: Handle client disconnecting immediately.

Browse Source
This commit is contained in:
Jon Beniston 2024-12-24 13:25:14 +00:00
parent c5efd73f6b
commit d3584f6af2
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugins/channelrx/remotetcpsink/remotetcpsinksink.cpp
View File

@ -881,8 +881,8 @@ RemoteTCPProtocol::Device RemoteTCPSinkSink::getDevice()
void RemoteTCPSinkSink::acceptWebConnection() void RemoteTCPSinkSink::acceptWebConnection()
{ {
QMutexLocker mutexLocker(&m_mutex); QMutexLocker mutexLocker(&m_mutex);
QWebSocket *client = m_webSocketServer->nextPendingConnection(); QWebSocket *client = m_webSocketServer->nextPendingConnection();
connect(client, &QWebSocket::binaryMessageReceived, this, &RemoteTCPSinkSink::processCommand); connect(client, &QWebSocket::binaryMessageReceived, this, &RemoteTCPSinkSink::processCommand);
connect(client, &QWebSocket::disconnected, this, &RemoteTCPSinkSink::disconnected); connect(client, &QWebSocket::disconnected, this, &RemoteTCPSinkSink::disconnected);
@ -891,8 +891,11 @@ void RemoteTCPSinkSink::acceptWebConnection()
// https://bugreports.qt.io/browse/QTBUG-125874 // https://bugreports.qt.io/browse/QTBUG-125874
QTimer::singleShot(200, this, [this, client] () { QTimer::singleShot(200, this, [this, client] () {
QMutexLocker mutexLocker(&m_mutex); QMutexLocker mutexLocker(&m_mutex);
m_clients.append(new WebSocket(client)); if (client->isValid())
acceptConnection(m_clients.last()); {
m_clients.append(new WebSocket(client));
acceptConnection(m_clients.last());
}
}); });
} }
@ -912,8 +915,11 @@ void RemoteTCPSinkSink::acceptTCPConnection()
QTimer::singleShot(200, this, [this, client] () { QTimer::singleShot(200, this, [this, client] () {
QMutexLocker mutexLocker(&m_mutex); QMutexLocker mutexLocker(&m_mutex);
m_clients.append(new TCPSocket(client)); if (client->isValid())
acceptConnection(m_clients.last()); {
m_clients.append(new TCPSocket(client));
acceptConnection(m_clients.last());
}
}); });
} }