mirror of
https://github.com/saitohirga/WSJT-X.git
synced 2024-09-09 06:46:39 -04:00
bc99eb2061
48kHz to 12kHz down sampler routine. Added assert to disallow stereo processing of i/p samples until fil4.f90 can deal with interleaved stereo streams. Added QProcess error to jt9 error handler, not that anything is done with the error code yet but at least it can be examined in the debugger if required. git-svn-id: svn+ssh://svn.code.sf.net/p/wsjt/wsjt/branches/wsjtx@3583 ab8295b8-cf94-4d9e-aec4-7959e3be5d79
112 lines
3.2 KiB
C++
112 lines
3.2 KiB
C++
#include "Detector.hpp"
|
|
|
|
#include <QDateTime>
|
|
#include <QtAlgorithms>
|
|
#include <QDebug>
|
|
|
|
#include "commons.h"
|
|
|
|
extern "C" {
|
|
void fil4_(qint16*, qint32*, qint16*, qint32*);
|
|
}
|
|
|
|
Detector::Detector (unsigned frameRate, unsigned periodLengthInSeconds, unsigned framesPerSignal, QObject * parent)
|
|
: AudioDevice (parent)
|
|
, m_frameRate (frameRate)
|
|
, m_period (periodLengthInSeconds)
|
|
, m_framesPerSignal (framesPerSignal)
|
|
, m_monitoring (false)
|
|
, m_starting (false)
|
|
{
|
|
clear ();
|
|
}
|
|
|
|
bool Detector::reset ()
|
|
{
|
|
clear ();
|
|
return QIODevice::reset ();
|
|
}
|
|
|
|
void Detector::clear ()
|
|
{
|
|
// set index to roughly where we are in time (1ms resolution)
|
|
// qint64 now (QDateTime::currentMSecsSinceEpoch ());
|
|
// unsigned msInPeriod ((now % 86400000LL) % (m_period * 1000));
|
|
// jt9com_.kin = qMin ((msInPeriod * m_frameRate) / 1000, static_cast<unsigned> (sizeof (jt9com_.d2) / sizeof (jt9com_.d2[0])));
|
|
jt9com_.kin = 0;
|
|
|
|
// fill buffer with zeros (G4WJS commented out because it might cause decoder hangs)
|
|
// qFill (jt9com_.d2, jt9com_.d2 + sizeof (jt9com_.d2) / sizeof (jt9com_.d2[0]), 0);
|
|
}
|
|
|
|
qint64 Detector::writeData (char const * data, qint64 maxSize)
|
|
{
|
|
bool overrun (false);
|
|
int excess (0);
|
|
if (m_monitoring)
|
|
{
|
|
Q_ASSERT (!(maxSize % static_cast<qint64> (bytesPerFrame ()))); // no torn frames
|
|
|
|
qint64 framesAcceptable (sizeof (jt9com_.d2) / sizeof (jt9com_.d2[0]) - jt9com_.kin);
|
|
qint64 framesAccepted (qMin (static_cast<qint64> (maxSize / bytesPerFrame ()), framesAcceptable));
|
|
|
|
overrun = framesAccepted < static_cast<qint64> (maxSize / bytesPerFrame ());
|
|
if (overrun)
|
|
{
|
|
qDebug () << "dropped " << maxSize / sizeof (jt9com_.d2[0]) - framesAccepted << " frames of data on the floor!";
|
|
}
|
|
|
|
Q_ASSERT (2 == bytesPerFrame ()); // only mono until fil4 can do stereo
|
|
excess = framesAccepted % 4;
|
|
qint32 m_n1,m_n2;
|
|
m_n1 = framesAccepted - excess;
|
|
fil4_((qint16 *)data, &m_n1, m_translate, &m_n2);
|
|
store ((char const *) m_translate, m_n2, &jt9com_.d2[jt9com_.kin]);
|
|
|
|
unsigned lastSignalIndex (jt9com_.kin / m_framesPerSignal);
|
|
jt9com_.kin += m_n2;
|
|
unsigned currentSignalIndex (jt9com_.kin / m_framesPerSignal);
|
|
|
|
if (currentSignalIndex != lastSignalIndex && m_monitoring)
|
|
{
|
|
Q_EMIT framesWritten (currentSignalIndex * m_framesPerSignal);
|
|
}
|
|
|
|
if (!secondInPeriod ())
|
|
{
|
|
if (!m_starting)
|
|
{
|
|
// next samples will be in new period so wrap around to
|
|
// start of buffer
|
|
//
|
|
// we don't bother calling reset () since we expect to fill
|
|
// the whole buffer and don't need to waste cycles zeroing
|
|
jt9com_.kin = 0;
|
|
m_starting = true;
|
|
}
|
|
}
|
|
else if (m_starting)
|
|
{
|
|
m_starting = false;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
jt9com_.kin = 0;
|
|
}
|
|
|
|
return maxSize - (overrun ? 0 : excess * bytesPerFrame ());
|
|
// we drop any data past the end of the buffer on
|
|
// the floor until the next period starts
|
|
}
|
|
|
|
unsigned Detector::secondInPeriod () const
|
|
{
|
|
// we take the time of the data as the following assuming no latency
|
|
// delivering it to us (not true but close enough for us)
|
|
qint64 now (QDateTime::currentMSecsSinceEpoch ());
|
|
|
|
unsigned secondInToday ((now % 86400000LL) / 1000);
|
|
return secondInToday % m_period;
|
|
}
|