mirror/SDRPlusPlus
0
0
Fork 0
mirror of https://github.com/AlexandreRouma/SDRPlusPlus.git synced 2025-03-22 16:09:53 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

stream fixes

Browse Source
This commit is contained in:
AlexandreRouma 2022-12-06 16:10:11 +01:00
parent 5eba556605
commit 643d47fe47
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
source_modules/spectran_source/src/main.cpp
View File

@ -36,7 +36,7 @@ public:
return; return;
} }
sampleRate = 122000000.0/1.0; sampleRate = 245760000.0/1.0;
handler.ctx = this; handler.ctx = this;
handler.selectHandler = menuSelected; handler.selectHandler = menuSelected;
@ -161,7 +161,7 @@ private:
AARTSAAPI_ConfigSetString(&_this->dev, &config, L"iq"); AARTSAAPI_ConfigSetString(&_this->dev, &config, L"iq");
AARTSAAPI_ConfigFind(&_this->dev, &_this->croot, &config, L"device/receiverclock"); AARTSAAPI_ConfigFind(&_this->dev, &_this->croot, &config, L"device/receiverclock");
AARTSAAPI_ConfigSetString(&_this->dev, &config, L"122MHz"); AARTSAAPI_ConfigSetString(&_this->dev, &config, L"245MHz");
AARTSAAPI_ConfigFind(&_this->dev, &_this->croot, &config, L"main/decimation"); AARTSAAPI_ConfigFind(&_this->dev, &_this->croot, &config, L"main/decimation");
AARTSAAPI_ConfigSetString(&_this->dev, &config, L"Full"); AARTSAAPI_ConfigSetString(&_this->dev, &config, L"Full");
@ -285,18 +285,30 @@ private:
while (true) { while (true) {
// Get next packet // Get next packet
while ((res = AARTSAAPI_GetPacket(&dev, 0, 0, &pkt)) == AARTSAAPI_EMPTY) { while ((res = AARTSAAPI_GetPacket(&dev, 0, 0, &pkt)) == AARTSAAPI_EMPTY) {
std::this_thread::sleep_for(std::chrono::microseconds(100)); #ifdef _WIN32
Sleep(1);
#else
usleep(1000);
#endif
} }
// If there was an error, return // If there was an error, return
if (res != AARTSAAPI_OK) { break; } if (res != AARTSAAPI_OK) { break; }
// Consume packet if (pkt.num > STREAM_BUFFER_SIZE) {
AARTSAAPI_ConsumePackets(&dev, 0, 1); spdlog::error("Buffer too big!!!!");
continue;
}
// Write data // Write data
memcpy(stream.writeBuf, pkt.fp32, pkt.num * sizeof(dsp::complex_t)); memcpy(stream.writeBuf, pkt.fp32, pkt.num * sizeof(dsp::complex_t));
if (!stream.swap(pkt.num)) { break; } if (!stream.swap(pkt.num)) {
AARTSAAPI_ConsumePackets(&dev, 0, 1);
break;
}
// Consume packet
AARTSAAPI_ConsumePackets(&dev, 0, 1);
} }
} }