Try to fix server

merge-requests/9/merge
Phil Taylor 2022-01-04 19:50:38 +00:00
rodzic 8ec82e7406
commit fce3a3d6be
5 zmienionych plików z 13 dodań i 29 usunięć

Wyświetl plik

@ -63,6 +63,7 @@ bool audioHandler::init(audioSetup setupIn)
if (isInitialized) {
return false;
}
qInfo(logAudio()) << (setup.isinput ? "Input" : "Output") << "audio handler starting:" << setup.name;
/*
0x01 uLaw 1ch 8bit

Wyświetl plik

@ -1,17 +1,16 @@
#include "udpserver.h"
#include "logcategories.h"
udpServer::udpServer(SERVERCONFIG config, audioSetup outAudio, audioSetup inAudio) :
config(config),
outAudio(outAudio),
inAudio(inAudio)
udpServer::udpServer()
{
qInfo(logUdpServer()) << "Starting udp server";
}
void udpServer::init()
void udpServer::init(SERVERCONFIG conf, audioSetup out, audioSetup in)
{
this->config = conf;
this->outAudio = out;
this->inAudio = in;
srand(time(NULL)); // Generate random key
timeStarted.start();
// Convoluted way to find the external IP address, there must be a better way????
@ -95,20 +94,6 @@ udpServer::~udpServer()
delete udpAudio;
}
if (rxAudioThread != Q_NULLPTR) {
rxAudioThread->quit();
rxAudioThread->wait();
rxaudio = Q_NULLPTR;
rxAudioThread = Q_NULLPTR;
}
if (txAudioThread != Q_NULLPTR) {
txAudioThread->quit();
txAudioThread->wait();
txaudio = Q_NULLPTR;
txAudioThread = Q_NULLPTR;
}
emit haveNetworkStatus(QString(""));
}

Wyświetl plik

@ -60,11 +60,11 @@ class udpServer : public QObject
Q_OBJECT
public:
udpServer(SERVERCONFIG config,audioSetup outAudio, audioSetup inAudio);
udpServer();
~udpServer();
public slots:
void init();
void init(SERVERCONFIG sc, audioSetup ai, audioSetup ao);
void dataForServer(QByteArray);
void receiveAudioData(const audioPacket &data);
void receiveRigCaps(rigCapabilities caps);

Wyświetl plik

@ -964,13 +964,13 @@ void wfmain::setServerToPrefs()
if (serverConfig.enabled) {
serverConfig.lan = prefs.enableLAN;
udp = new udpServer(serverConfig,serverTxSetup,serverRxSetup);
udp = new udpServer();
serverThread = new QThread(this);
udp->moveToThread(serverThread);
connect(this, SIGNAL(initServer()), udp, SLOT(init()));
connect(this, SIGNAL(initServer(SERVERCONFIG, audioSetup, audioSetup)), udp, SLOT(init(SERVERCONFIG, audioSetup, audioSetup)));
connect(serverThread, SIGNAL(finished()), udp, SLOT(deleteLater()));
if (!prefs.enableLAN && udp != Q_NULLPTR) {
@ -979,7 +979,7 @@ void wfmain::setServerToPrefs()
serverThread->start();
emit initServer();
emit initServer(serverConfig, serverTxSetup, serverRxSetup);
connect(this, SIGNAL(sendRigCaps(rigCapabilities)), udp, SLOT(receiveRigCaps(rigCapabilities)));
ui->statusBar->showMessage(QString("Server enabled"), 1000);
@ -1638,8 +1638,7 @@ void wfmain::loadSettings()
}
ui->serverRXAudioInputCombo->blockSignals(false);
serverRxSetup.resampleQuality = settings->value("ResampleQuality", "4").toInt();
serverRxSetup.resampleQuality = rxSetup.resampleQuality;
serverTxSetup.resampleQuality = settings->value("ResampleQuality", "4").toInt();
ui->serverTXAudioOutputCombo->blockSignals(true);
serverTxSetup.name = settings->value("ServerAudioOutput", "").toString();
@ -1659,7 +1658,6 @@ void wfmain::loadSettings()
ui->serverTXAudioOutputCombo->blockSignals(false);
serverTxSetup.resampleQuality = settings->value("ResampleQuality", "4").toInt();
serverTxSetup.resampleQuality = rxSetup.resampleQuality;
int row = 0;
ui->serverUsersTable->setRowCount(0);

Wyświetl plik

@ -162,7 +162,7 @@ signals:
void sendCommSetup(unsigned char rigCivAddr, udpPreferences prefs, audioSetup rxSetup, audioSetup txSetup, QString vsp);
void sendCloseComm();
void sendChangeLatency(quint16 latency);
void initServer();
void initServer(SERVERCONFIG sc, audioSetup ai, audioSetup ao);
void sendRigCaps(rigCapabilities caps);
void requestRigState();
void stateUpdated();