VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2024-12-23 01:55:48 -05:00
Code Issues Projects Releases Wiki Activity

Remove tabs.

Browse Source
This commit is contained in:
srcejon 2023-12-06 10:53:28 +00:00
parent c30af7f39f
commit 720630c2fb
5 changed files with 326 additions and 326 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
plugins/samplesource/airspyhf/airspyhfworker.cpp
View File

@ -77,27 +77,27 @@ void AirspyHFWorker::setLog2Decimation(unsigned int log2_decim)
// Decimate according to specified log2 (ex: log2=4 => decim=16) // Decimate according to specified log2 (ex: log2=4 => decim=16)
void AirspyHFWorker::callbackIQ(const float* inBuf, qint32 len) void AirspyHFWorker::callbackIQ(const float* inBuf, qint32 len)
{ {
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const float* buf = inBuf; const float* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
switch (m_log2Decim) switch (m_log2Decim)
{ {
@ -135,32 +135,32 @@ void AirspyHFWorker::callbackIQ(const float* inBuf, qint32 len)
m_replayBuffer->unlock(); m_replayBuffer->unlock();
m_sampleFifo->write(m_convertBuffer.begin(), it); m_sampleFifo->write(m_convertBuffer.begin(), it);
} }
void AirspyHFWorker::callbackQI(const float* inBuf, qint32 len) void AirspyHFWorker::callbackQI(const float* inBuf, qint32 len)
{ {
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const float* buf = inBuf; const float* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
switch (m_log2Decim) switch (m_log2Decim)
{ {
@ -198,7 +198,7 @@ void AirspyHFWorker::callbackQI(const float* inBuf, qint32 len)
m_replayBuffer->unlock(); m_replayBuffer->unlock();
m_sampleFifo->write(m_convertBuffer.begin(), it); m_sampleFifo->write(m_convertBuffer.begin(), it);
} }
int AirspyHFWorker::rx_callback(airspyhf_transfer_t* transfer) int AirspyHFWorker::rx_callback(airspyhf_transfer_t* transfer)

62
plugins/samplesource/limesdrinput/limesdrinputthread.cpp
View File

@ -114,24 +114,24 @@ void LimeSDRInputThread::callbackIQ(const qint16* inBuf, qint32 len)
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const qint16* buf = inBuf; const qint16* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
switch (m_log2Decim) switch (m_log2Decim)
{ {
@ -171,24 +171,24 @@ void LimeSDRInputThread::callbackQI(const qint16* inBuf, qint32 len)
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const qint16* buf = inBuf; const qint16* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
switch (m_log2Decim) switch (m_log2Decim)
{ {
@ -216,7 +216,7 @@ void LimeSDRInputThread::callbackQI(const qint16* inBuf, qint32 len)
default: default:
break; break;
} }
} }
m_replayBuffer->unlock(); m_replayBuffer->unlock();

432
plugins/samplesource/rtlsdr/rtlsdrthread.cpp
View File

@ -98,240 +98,240 @@ void RTLSDRThread::run()
// Len is total samples (i.e. one I and Q pair will have len=2) // Len is total samples (i.e. one I and Q pair will have len=2)
void RTLSDRThread::callbackIQ(const quint8* inBuf, qint32 len) void RTLSDRThread::callbackIQ(const quint8* inBuf, qint32 len)
{ {
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const quint8* buf = inBuf; const quint8* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
if (m_log2Decim == 0) if (m_log2Decim == 0)
{ {
m_decimatorsIQ.decimate1(&it, buf, len); m_decimatorsIQ.decimate1(&it, buf, len);
} }
else else
{ {
if (m_fcPos == 0) // Infradyne if (m_fcPos == 0) // Infradyne
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsIQ.decimate2_inf(&it, buf, len); m_decimatorsIQ.decimate2_inf(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsIQ.decimate4_inf(&it, buf, len); m_decimatorsIQ.decimate4_inf(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsIQ.decimate8_inf(&it, buf, len); m_decimatorsIQ.decimate8_inf(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsIQ.decimate16_inf(&it, buf, len); m_decimatorsIQ.decimate16_inf(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsIQ.decimate32_inf(&it, buf, len); m_decimatorsIQ.decimate32_inf(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsIQ.decimate64_inf(&it, buf, len); m_decimatorsIQ.decimate64_inf(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
else if (m_fcPos == 1) // Supradyne else if (m_fcPos == 1) // Supradyne
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsIQ.decimate2_sup(&it, buf, len); m_decimatorsIQ.decimate2_sup(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsIQ.decimate4_sup(&it, buf, len); m_decimatorsIQ.decimate4_sup(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsIQ.decimate8_sup(&it, buf, len); m_decimatorsIQ.decimate8_sup(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsIQ.decimate16_sup(&it, buf, len); m_decimatorsIQ.decimate16_sup(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsIQ.decimate32_sup(&it, buf, len); m_decimatorsIQ.decimate32_sup(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsIQ.decimate64_sup(&it, buf, len); m_decimatorsIQ.decimate64_sup(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
else // Centered else // Centered
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsIQ.decimate2_cen(&it, buf, len); m_decimatorsIQ.decimate2_cen(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsIQ.decimate4_cen(&it, buf, len); m_decimatorsIQ.decimate4_cen(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsIQ.decimate8_cen(&it, buf, len); m_decimatorsIQ.decimate8_cen(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsIQ.decimate16_cen(&it, buf, len); m_decimatorsIQ.decimate16_cen(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsIQ.decimate32_cen(&it, buf, len); m_decimatorsIQ.decimate32_cen(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsIQ.decimate64_cen(&it, buf, len); m_decimatorsIQ.decimate64_cen(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
} }
} }
m_replayBuffer->unlock(); m_replayBuffer->unlock();
m_sampleFifo->write(m_convertBuffer.begin(), it); m_sampleFifo->write(m_convertBuffer.begin(), it);
if(!m_running) if(!m_running)
rtlsdr_cancel_async(m_dev); rtlsdr_cancel_async(m_dev);
} }
void RTLSDRThread::callbackQI(const quint8* inBuf, qint32 len) void RTLSDRThread::callbackQI(const quint8* inBuf, qint32 len)
{ {
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const quint8* buf = inBuf; const quint8* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
if (m_log2Decim == 0) if (m_log2Decim == 0)
{ {
m_decimatorsQI.decimate1(&it, buf, len); m_decimatorsQI.decimate1(&it, buf, len);
} }
else else
{ {
if (m_fcPos == 0) // Infradyne if (m_fcPos == 0) // Infradyne
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsQI.decimate2_inf(&it, buf, len); m_decimatorsQI.decimate2_inf(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsQI.decimate4_inf(&it, buf, len); m_decimatorsQI.decimate4_inf(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsQI.decimate8_inf(&it, buf, len); m_decimatorsQI.decimate8_inf(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsQI.decimate16_inf(&it, buf, len); m_decimatorsQI.decimate16_inf(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsQI.decimate32_inf(&it, buf, len); m_decimatorsQI.decimate32_inf(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsQI.decimate64_inf(&it, buf, len); m_decimatorsQI.decimate64_inf(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
else if (m_fcPos == 1) // Supradyne else if (m_fcPos == 1) // Supradyne
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsQI.decimate2_sup(&it, buf, len); m_decimatorsQI.decimate2_sup(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsQI.decimate4_sup(&it, buf, len); m_decimatorsQI.decimate4_sup(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsQI.decimate8_sup(&it, buf, len); m_decimatorsQI.decimate8_sup(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsQI.decimate16_sup(&it, buf, len); m_decimatorsQI.decimate16_sup(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsQI.decimate32_sup(&it, buf, len); m_decimatorsQI.decimate32_sup(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsQI.decimate64_sup(&it, buf, len); m_decimatorsQI.decimate64_sup(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
else // Centered else // Centered
{ {
switch (m_log2Decim) switch (m_log2Decim)
{ {
case 1: case 1:
m_decimatorsQI.decimate2_cen(&it, buf, len); m_decimatorsQI.decimate2_cen(&it, buf, len);
break; break;
case 2: case 2:
m_decimatorsQI.decimate4_cen(&it, buf, len); m_decimatorsQI.decimate4_cen(&it, buf, len);
break; break;
case 3: case 3:
m_decimatorsQI.decimate8_cen(&it, buf, len); m_decimatorsQI.decimate8_cen(&it, buf, len);
break; break;
case 4: case 4:
m_decimatorsQI.decimate16_cen(&it, buf, len); m_decimatorsQI.decimate16_cen(&it, buf, len);
break; break;
case 5: case 5:
m_decimatorsQI.decimate32_cen(&it, buf, len); m_decimatorsQI.decimate32_cen(&it, buf, len);
break; break;
case 6: case 6:
m_decimatorsQI.decimate64_cen(&it, buf, len); m_decimatorsQI.decimate64_cen(&it, buf, len);
break; break;
default: default:
break; break;
} }
} }
} }
} }
m_replayBuffer->unlock(); m_replayBuffer->unlock();
m_sampleFifo->write(m_convertBuffer.begin(), it); m_sampleFifo->write(m_convertBuffer.begin(), it);
if(!m_running) if(!m_running)
rtlsdr_cancel_async(m_dev); rtlsdr_cancel_async(m_dev);
} }
void RTLSDRThread::callbackHelper(unsigned char* buf, uint32_t len, void* ctx) void RTLSDRThread::callbackHelper(unsigned char* buf, uint32_t len, void* ctx)

60
plugins/samplesource/sdrplayv3/sdrplayv3thread.cpp
View File

@ -177,24 +177,24 @@ void SDRPlayV3Thread::callbackIQ(const qint16* inBuf, qint32 len)
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const qint16* buf = inBuf; const qint16* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
if (m_log2Decim == 0) if (m_log2Decim == 0)
{ {
@ -293,24 +293,24 @@ void SDRPlayV3Thread::callbackQI(const qint16* inBuf, qint32 len)
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const qint16* buf = inBuf; const qint16* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
if (m_log2Decim == 0) if (m_log2Decim == 0)
{ {

30
plugins/samplesource/usrpinput/usrpinputthread.cpp
View File

@ -198,24 +198,24 @@ void USRPInputThread::callbackIQ(const qint16* inBuf, qint32 len)
SampleVector::iterator it = m_convertBuffer.begin(); SampleVector::iterator it = m_convertBuffer.begin();
// Save data to replay buffer // Save data to replay buffer
m_replayBuffer->lock(); m_replayBuffer->lock();
bool replayEnabled = m_replayBuffer->getSize() > 0; bool replayEnabled = m_replayBuffer->getSize() > 0;
if (replayEnabled) { if (replayEnabled) {
m_replayBuffer->write(inBuf, len); m_replayBuffer->write(inBuf, len);
} }
const qint16* buf = inBuf; const qint16* buf = inBuf;
qint32 remaining = len; qint32 remaining = len;
while (remaining > 0) while (remaining > 0)
{ {
// Choose between live data or replayed data // Choose between live data or replayed data
if (replayEnabled && m_replayBuffer->useReplay()) { if (replayEnabled && m_replayBuffer->useReplay()) {
len = m_replayBuffer->read(remaining, buf); len = m_replayBuffer->read(remaining, buf);
} else { } else {
len = remaining; len = remaining;
} }
remaining -= len; remaining -= len;
switch (m_log2Decim) switch (m_log2Decim)
{ {