Sergio
/
sdrangelove
forked from sdr/sdrangelove
1
0
Fork 0
Code Pull Requests Actions Packages Projects Releases Activity

OsmoSDRSource: add privisional sample verification for FPGA test mode

This commit is contained in:
Christian Daniel 2013-02-07 19:31:48 +01:00
parent 9664d736f3
commit 7d9cd43d3b
3 changed files with 44 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hardware/osmosdrinput.cpp
View File

@ -165,7 +165,7 @@ bool OsmoSDRInput::startInput(int device)
char serial[256];
int res;
if(!m_sampleFifo.setSize(2 * 500000)) {
if(!m_sampleFifo.setSize(524288)) {
qCritical("Could not allocate SampleFifo");
return false;
}

37
hardware/osmosdrthread.cpp
View File

@ -67,18 +67,45 @@ void OsmoSDRThread::run()
m_running = false;
}
void OsmoSDRThread::callback(quint8* buf, qint32 len)
void OsmoSDRThread::checkData(const quint8* buf, qint32 len)
{
const Sample* s = (const Sample*)buf;
len /= sizeof(Sample);
while(len) {
if((s->i != m_nextI) || (s->q != m_nextQ)) {
qDebug("continuity error after %llu samples", m_samplePos);
m_samplePos = 0;
m_nextI = s->i - 1;
m_nextQ = s->q + 1;
} else {
m_nextI--;
m_nextQ++;
m_samplePos++;
}
len--;
s++;
}
}
int cntr;
void OsmoSDRThread::callback(const quint8* buf, qint32 len)
{
/*
qDebug("%d", len);
*/
/*
for(int i = 0; i < len / 2; i += 2) {
((qint16*)buf)[i] = sin((float)(cntr) * 16384* 2.0 * M_PI / 65536.0) * 5000.0;
((qint16*)buf)[i + 1] = -cos((float)(cntr++) * 16384*2.0 * M_PI / 65536.0) * 5000.0;
}*/
((qint16*)buf)[i] = sin((float)(cntr) * 1024* 2.0 * M_PI / 65536.0) * 32000.0;
((qint16*)buf)[i + 1] = -cos((float)(cntr++) * 1024*2.0 * M_PI / 65536.0) * 32000.0;
}
*/
//m_sampleFifo->write((SampleVector::const_iterator)((Sample*)buf), (SampleVector::const_iterator)((Sample*)(buf + len)));
//fwrite(buf, 1, len, m_f);
//checkData(buf, len);
m_sampleFifo->write(buf, len);
if(!m_running)
osmosdr_cancel_async(m_dev);

12
hardware/osmosdrthread.h
View File

@ -36,6 +36,14 @@ public:
void stop();
private:
struct Sample {
qint16 i;
qint16 q;
} __attribute__((packed));
qint16 m_nextI;
qint16 m_nextQ;
quint64 m_samplePos;
QMutex m_startWaitMutex;
QWaitCondition m_startWaiter;
bool m_running;
@ -46,7 +54,9 @@ private:
void run();
void callback(quint8* buf, qint32 len);
void checkData(const quint8* buf, qint32 len);
void callback(const quint8* buf, qint32 len);
static void callbackHelper(unsigned char* buf, uint32_t len, void* ctx);
};