VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2025-09-04 14:17:50 -04:00
Code Issues Projects Releases Wiki Activity

WDSP: Nose blanker: replaced static methods

Browse Source
This commit is contained in:
f4exb 2024-07-23 08:06:13 +02:00
parent 994898d9fc
commit b975658758
6 changed files with 511 additions and 554 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
plugins/channelrx/wdsprx/wdsprxsink.cpp
View File

@ -591,18 +591,18 @@ void WDSPRxSink::applySettings(const WDSPRxSettings& settings, bool force)
if ((m_settings.m_dnb != settings.m_dnb) if ((m_settings.m_dnb != settings.m_dnb)
|| (m_settings.m_nbScheme != settings.m_nbScheme) || force) || (m_settings.m_nbScheme != settings.m_nbScheme) || force)
{ {
WDSP::ANB::SetANBRun(*m_rxa, 0); m_rxa->anb->setRun(0);
WDSP::NOB::SetNOBRun(*m_rxa, 0); m_rxa->nob->setRun(0);
if (settings.m_dnb) if (settings.m_dnb)
{ {
switch(settings.m_nbScheme) switch(settings.m_nbScheme)
{ {
case WDSPRxProfile::NBSchemeNB: case WDSPRxProfile::NBSchemeNB:
WDSP::ANB::SetANBRun(*m_rxa, 1); m_rxa->anb->setRun(1);
break; break;
case WDSPRxProfile::NBSchemeNB2: case WDSPRxProfile::NBSchemeNB2:
WDSP::NOB::SetNOBRun(*m_rxa, 1); m_rxa->nob->setRun(1);
break; break;
default: default:
break; break;
@ -612,32 +612,32 @@ void WDSPRxSink::applySettings(const WDSPRxSettings& settings, bool force)
if ((m_settings.m_nbSlewTime != settings.m_nbSlewTime) || force) if ((m_settings.m_nbSlewTime != settings.m_nbSlewTime) || force)
{ {
WDSP::ANB::SetANBTau(*m_rxa, settings.m_nbSlewTime * 0.001); m_rxa->anb->setTau(settings.m_nbSlewTime * 0.001);
WDSP::NOB::SetNOBTau(*m_rxa, settings.m_nbSlewTime * 0.001); m_rxa->nob->setTau(settings.m_nbSlewTime * 0.001);
} }
if ((m_settings.m_nbLeadTime != settings.m_nbLeadTime) || force) if ((m_settings.m_nbLeadTime != settings.m_nbLeadTime) || force)
{ {
WDSP::ANB::SetANBAdvtime(*m_rxa, settings.m_nbLeadTime * 0.001); m_rxa->anb->setAdvtime(settings.m_nbLeadTime * 0.001);
WDSP::NOB::SetNOBAdvtime(*m_rxa, settings.m_nbLeadTime * 0.001); m_rxa->nob->setAdvtime(settings.m_nbLeadTime * 0.001);
} }
if ((m_settings.m_nbLagTime != settings.m_nbLagTime) || force) if ((m_settings.m_nbLagTime != settings.m_nbLagTime) || force)
{ {
WDSP::ANB::SetANBHangtime(*m_rxa, settings.m_nbLagTime * 0.001); m_rxa->anb->setHangtime(settings.m_nbLagTime * 0.001);
WDSP::NOB::SetNOBHangtime(*m_rxa, settings.m_nbLagTime * 0.001); m_rxa->nob->setHangtime(settings.m_nbLagTime * 0.001);
} }
if ((m_settings.m_nbThreshold != settings.m_nbThreshold) || force) if ((m_settings.m_nbThreshold != settings.m_nbThreshold) || force)
{ {
WDSP::ANB::SetANBThreshold(*m_rxa, settings.m_nbThreshold); m_rxa->anb->setThreshold(settings.m_nbThreshold);
WDSP::NOB::SetNOBThreshold(*m_rxa, settings.m_nbThreshold); m_rxa->nob->setThreshold(settings.m_nbThreshold);
} }
if ((m_settings.m_nbAvgTime != settings.m_nbAvgTime) || force) if ((m_settings.m_nbAvgTime != settings.m_nbAvgTime) || force)
{ {
WDSP::ANB::SetANBBacktau(*m_rxa, settings.m_nbAvgTime * 0.001); m_rxa->anb->setBacktau(settings.m_nbAvgTime * 0.001);
WDSP::NOB::SetNOBBacktau(*m_rxa, settings.m_nbAvgTime * 0.001); m_rxa->nob->setBacktau(settings.m_nbAvgTime * 0.001);
} }
// AM option // AM option

44
wdsp/RXA.cpp
View File

@ -89,7 +89,7 @@ RXA* RXA::create_rxa (
std::fill(rxa->meter, rxa->meter + RXA_METERTYPE_LAST, 0); std::fill(rxa->meter, rxa->meter + RXA_METERTYPE_LAST, 0);
// Noise blanker (ANB or "NB") // Noise blanker (ANB or "NB")
rxa->anb = ANB::create_anb( rxa->anb = new ANB(
0, // run 0, // run
rxa->dsp_insize, // input buffer size rxa->dsp_insize, // input buffer size
rxa->inbuff, // pointer to input buffer rxa->inbuff, // pointer to input buffer
@ -102,7 +102,7 @@ RXA* RXA::create_rxa (
30 // thershold 30 // thershold
); );
// Noise blanker (NOB or "NB2") // Noise blanker (NOB or "NB2")
rxa->nob = NOB::create_nob( rxa->nob = new NOB(
0, // run 0, // run
rxa->dsp_insize, // input buffer size rxa->dsp_insize, // input buffer size
rxa->inbuff, // pointer to input buffer rxa->inbuff, // pointer to input buffer
@ -601,8 +601,8 @@ void RXA::destroy_rxa (RXA *rxa)
GEN::destroy_gen (rxa->gen0); GEN::destroy_gen (rxa->gen0);
RESAMPLE::destroy_resample (rxa->rsmpin); RESAMPLE::destroy_resample (rxa->rsmpin);
SHIFT::destroy_shift (rxa->shift); SHIFT::destroy_shift (rxa->shift);
NOB::destroy_nob(rxa->nob); delete (rxa->nob);
ANB::destroy_anb(rxa->anb); delete (rxa->anb);
delete[] (rxa->midbuff); delete[] (rxa->midbuff);
delete[] (rxa->outbuff); delete[] (rxa->outbuff);
delete[] (rxa->inbuff); delete[] (rxa->inbuff);
@ -614,8 +614,8 @@ void RXA::flush_rxa (RXA *rxa)
std::fill(rxa->inbuff, rxa->inbuff + 1 * rxa->dsp_insize * 2, 0); std::fill(rxa->inbuff, rxa->inbuff + 1 * rxa->dsp_insize * 2, 0);
std::fill(rxa->outbuff, rxa->outbuff + 1 * rxa->dsp_outsize * 2, 0); std::fill(rxa->outbuff, rxa->outbuff + 1 * rxa->dsp_outsize * 2, 0);
std::fill(rxa->midbuff, rxa->midbuff + 2 * rxa->dsp_size * 2, 0); std::fill(rxa->midbuff, rxa->midbuff + 2 * rxa->dsp_size * 2, 0);
ANB::flush_anb (rxa->anb); rxa->anb->flush();
NOB::flush_nob(rxa->nob); rxa->nob->flush();
SHIFT::flush_shift (rxa->shift); SHIFT::flush_shift (rxa->shift);
RESAMPLE::flush_resample (rxa->rsmpin); RESAMPLE::flush_resample (rxa->rsmpin);
GEN::flush_gen (rxa->gen0); GEN::flush_gen (rxa->gen0);
@ -647,8 +647,8 @@ void RXA::flush_rxa (RXA *rxa)
void RXA::xrxa (RXA *rxa) void RXA::xrxa (RXA *rxa)
{ {
ANB::xanb (rxa->anb); rxa->anb->x();
NOB::xnob (rxa->nob); rxa->nob->x();
SHIFT::xshift (rxa->shift); SHIFT::xshift (rxa->shift);
RESAMPLE::xresample (rxa->rsmpin); RESAMPLE::xresample (rxa->rsmpin);
GEN::xgen (rxa->gen0); GEN::xgen (rxa->gen0);
@ -698,13 +698,13 @@ void RXA::setInputSamplerate (RXA *rxa, int in_rate)
delete[] (rxa->inbuff); delete[] (rxa->inbuff);
rxa->inbuff = new float[1 * rxa->dsp_insize * 2]; // (float *)malloc0(1 * ch.dsp_insize * sizeof(complex)); rxa->inbuff = new float[1 * rxa->dsp_insize * 2]; // (float *)malloc0(1 * ch.dsp_insize * sizeof(complex));
// anb // anb
ANB::setBuffers_anb(rxa->anb, rxa->inbuff, rxa->inbuff); rxa->anb->setBuffers(rxa->inbuff, rxa->inbuff);
ANB::setSize_anb(rxa->anb, rxa->dsp_insize); rxa->anb->setSize(rxa->dsp_insize);
ANB::setSamplerate_anb(rxa->anb, rxa->in_rate); rxa->anb->setSamplerate(rxa->in_rate);
// nob // nob
NOB::setBuffers_nob(rxa->nob, rxa->inbuff, rxa->inbuff); rxa->nob->setBuffers(rxa->inbuff, rxa->inbuff);
NOB::setSize_nob(rxa->nob, rxa->dsp_insize); rxa->nob->setSize(rxa->dsp_insize);
NOB::setSamplerate_nob(rxa->nob, rxa->in_rate); rxa->nob->setSamplerate(rxa->in_rate);
// shift // shift
SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff); SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff);
SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize); SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize);
@ -752,11 +752,11 @@ void RXA::setDSPSamplerate (RXA *rxa, int dsp_rate)
delete[] (rxa->outbuff); delete[] (rxa->outbuff);
rxa->outbuff = new float[1 * rxa->dsp_outsize * 2]; // (float *)malloc0(1 * rxa->dsp_outsize * sizeof(complex)); rxa->outbuff = new float[1 * rxa->dsp_outsize * 2]; // (float *)malloc0(1 * rxa->dsp_outsize * sizeof(complex));
// anb // anb
ANB::setBuffers_anb (rxa->anb, rxa->inbuff, rxa->inbuff); rxa->anb->setBuffers(rxa->inbuff, rxa->inbuff);
ANB::setSize_anb(rxa->anb, rxa->dsp_insize); rxa->anb->setSize(rxa->dsp_insize);
// nob // nob
NOB::setBuffers_nob(rxa->nob, rxa->inbuff, rxa->inbuff); rxa->nob->setBuffers(rxa->inbuff, rxa->inbuff);
NOB::setSize_nob(rxa->nob, rxa->dsp_insize); rxa->nob->setSize(rxa->dsp_insize);
// shift // shift
SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff); SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff);
SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize); SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize);
@ -817,11 +817,11 @@ void RXA::setDSPBuffsize (RXA *rxa, int dsp_size)
delete[] (rxa->outbuff); delete[] (rxa->outbuff);
rxa->outbuff = new float[1 * rxa->dsp_outsize * 2]; // (float *)malloc0(1 * rxa->dsp_outsize * sizeof(complex)); rxa->outbuff = new float[1 * rxa->dsp_outsize * 2]; // (float *)malloc0(1 * rxa->dsp_outsize * sizeof(complex));
// anb // anb
ANB::setBuffers_anb (rxa->anb, rxa->inbuff, rxa->inbuff); rxa->anb->setBuffers(rxa->inbuff, rxa->inbuff);
ANB::setSize_anb (rxa->anb, rxa->dsp_insize); rxa->anb->setSize(rxa->dsp_insize);
// nob // nob
NOB::setBuffers_nob(rxa->nob, rxa->inbuff, rxa->inbuff); rxa->nob->setBuffers(rxa->inbuff, rxa->inbuff);
NOB::setSize_nob(rxa->nob, rxa->dsp_insize); rxa->nob->setSize(rxa->dsp_insize);
// shift // shift
SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff); SHIFT::setBuffers_shift (rxa->shift, rxa->inbuff, rxa->inbuff);
SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize); SHIFT::setSize_shift (rxa->shift, rxa->dsp_insize);

277
wdsp/anb.cpp
View File

@ -35,261 +35,238 @@ warren@wpratt.com
namespace WDSP { namespace WDSP {
void ANB::initBlanker(ANB *a) void ANB::initBlanker()
{ {
int i; int i;
a->trans_count = (int)(a->tau * a->samplerate); trans_count = (int)(tau * samplerate);
if (a->trans_count < 2) if (trans_count < 2)
a->trans_count = 2; trans_count = 2;
a->hang_count = (int)(a->hangtime * a->samplerate); hang_count = (int)(hangtime * samplerate);
a->adv_count = (int)(a->advtime * a->samplerate); adv_count = (int)(advtime * samplerate);
a->count = 0; count = 0;
a->in_idx = a->trans_count + a->adv_count; in_idx = trans_count + adv_count;
a->out_idx = 0; out_idx = 0;
a->coef = PI / a->trans_count; coef = PI / trans_count;
a->state = 0; state = 0;
a->avg = 1.0; avg = 1.0;
a->power = 1.0; power = 1.0;
a->backmult = exp(-1.0 / (a->samplerate * a->backtau)); backmult = exp(-1.0 / (samplerate * backtau));
a->ombackmult = 1.0 - a->backmult; ombackmult = 1.0 - backmult;
for (i = 0; i <= a->trans_count; i++) for (i = 0; i <= trans_count; i++)
a->wave[i] = 0.5 * cos(i * a->coef); wave[i] = 0.5 * cos(i * coef);
std::fill(a->dline, a->dline + a->dline_size * 2, 0); std::fill(dline, dline + dline_size * 2, 0);
} }
ANB* ANB::create_anb ( ANB::ANB (
int run, int _run,
int buffsize, int _buffsize,
float* in, float* _in,
float* out, float* _out,
double samplerate, double _samplerate,
double tau, double _tau,
double hangtime, double _hangtime,
double advtime, double _advtime,
double backtau, double _backtau,
double threshold double _threshold
) )
{ {
ANB *a; run = _run;
a = new ANB; buffsize = _buffsize;
a->run = run; in = _in;
a->buffsize = buffsize; out = _out;
a->in = in; samplerate = _samplerate;
a->out = out; tau = _tau;
a->samplerate = samplerate; hangtime = _hangtime;
a->tau = tau; advtime = _advtime;
a->hangtime = hangtime; backtau = _backtau;
a->advtime = advtime; threshold = _threshold;
a->backtau = backtau; wave = new double[((int)(MAX_SAMPLERATE * MAX_TAU) + 1)];
a->threshold = threshold; dline_size = (int)((MAX_TAU + MAX_ADVTIME) * MAX_SAMPLERATE) + 1;
a->wave = new double[((int)(MAX_SAMPLERATE * MAX_TAU) + 1)]; dline = new float[dline_size * 2];
a->dline_size = (int)((MAX_TAU + MAX_ADVTIME) * MAX_SAMPLERATE) + 1; initBlanker();
a->dline = new float[a->dline_size * 2]; legacy = new float[2048 * 2]; /////////////// legacy interface - remove
initBlanker(a);
a->legacy = new float[2048 * 2]; /////////////// legacy interface - remove
return a;
} }
void ANB::destroy_anb (ANB *a) ANB::~ANB()
{ {
delete[] (a->legacy); /////////////// legacy interface - remove delete[] legacy; /////////////// legacy interface - remove
delete[] (a->dline); delete[] dline;
delete[] (a->wave); delete[] wave;
delete (a);
} }
void ANB::flush_anb (ANB *a) void ANB::x()
{
initBlanker (a);
}
void ANB::xanb (ANB *a)
{ {
double scale; double scale;
double mag; double mag;
int i; int i;
if (a->run) if (run)
{ {
for (i = 0; i < a->buffsize; i++) for (i = 0; i < buffsize; i++)
{ {
double xr = a->in[2 * i + 0]; double xr = in[2 * i + 0];
double xi = a->in[2 * i + 1]; double xi = in[2 * i + 1];
mag = sqrt(xr*xr + xi*xi); mag = sqrt(xr*xr + xi*xi);
a->avg = a->backmult * a->avg + a->ombackmult * mag; avg = backmult * avg + ombackmult * mag;
a->dline[2 * a->in_idx + 0] = a->in[2 * i + 0]; dline[2 * in_idx + 0] = in[2 * i + 0];
a->dline[2 * a->in_idx + 1] = a->in[2 * i + 1]; dline[2 * in_idx + 1] = in[2 * i + 1];
if (mag > (a->avg * a->threshold)) if (mag > (avg * threshold))
a->count = a->trans_count + a->adv_count; count = trans_count + adv_count;
switch (a->state) switch (state)
{ {
case 0: case 0:
a->out[2 * i + 0] = a->dline[2 * a->out_idx + 0]; out[2 * i + 0] = dline[2 * out_idx + 0];
a->out[2 * i + 1] = a->dline[2 * a->out_idx + 1]; out[2 * i + 1] = dline[2 * out_idx + 1];
if (a->count > 0) if (count > 0)
{ {
a->state = 1; state = 1;
a->dtime = 0; dtime = 0;
a->power = 1.0; power = 1.0;
} }
break; break;
case 1: case 1:
scale = a->power * (0.5 + a->wave[a->dtime]); scale = power * (0.5 + wave[dtime]);
a->out[2 * i + 0] = a->dline[2 * a->out_idx + 0] * scale; out[2 * i + 0] = dline[2 * out_idx + 0] * scale;
a->out[2 * i + 1] = a->dline[2 * a->out_idx + 1] * scale; out[2 * i + 1] = dline[2 * out_idx + 1] * scale;
if (++a->dtime > a->trans_count) if (++dtime > trans_count)
{ {
a->state = 2; state = 2;
a->atime = 0; atime = 0;
} }
break; break;
case 2: case 2:
a->out[2 * i + 0] = 0.0; out[2 * i + 0] = 0.0;
a->out[2 * i + 1] = 0.0; out[2 * i + 1] = 0.0;
if (++a->atime > a->adv_count) if (++atime > adv_count)
a->state = 3; state = 3;
break; break;
case 3: case 3:
if (a->count > 0) if (count > 0)
a->htime = -a->count; htime = -count;
a->out[2 * i + 0] = 0.0; out[2 * i + 0] = 0.0;
a->out[2 * i + 1] = 0.0; out[2 * i + 1] = 0.0;
if (++a->htime > a->hang_count) if (++htime > hang_count)
{ {
a->state = 4; state = 4;
a->itime = 0; itime = 0;
} }
break; break;
case 4: case 4:
scale = 0.5 - a->wave[a->itime]; scale = 0.5 - wave[itime];
a->out[2 * i + 0] = a->dline[2 * a->out_idx + 0] * scale; out[2 * i + 0] = dline[2 * out_idx + 0] * scale;
a->out[2 * i + 1] = a->dline[2 * a->out_idx + 1] * scale; out[2 * i + 1] = dline[2 * out_idx + 1] * scale;
if (a->count > 0) if (count > 0)
{ {
a->state = 1; state = 1;
a->dtime = 0; dtime = 0;
a->power = scale; power = scale;
} }
else if (++a->itime > a->trans_count) else if (++itime > trans_count)
{ {
a->state = 0; state = 0;
} }
break; break;
} }
if (a->count > 0) if (count > 0)
a->count--; count--;
if (++a->in_idx == a->dline_size) if (++in_idx == dline_size)
a->in_idx = 0; in_idx = 0;
if (++a->out_idx == a->dline_size) if (++out_idx == dline_size)
a->out_idx = 0; out_idx = 0;
} }
} }
else if (a->in != a->out) else if (in != out)
{ {
std::copy(a->in, a->in + a->buffsize * 2, a->out); std::copy(in, in + buffsize * 2, out);
} }
} }
void ANB::setBuffers_anb (ANB *a, float* in, float* out) void ANB::setBuffers(float* in, float* out)
{ {
a->in = in; in = in;
a->out = out; out = out;
} }
void ANB::setSamplerate_anb (ANB *a, int rate) void ANB::setSize(int size)
{ {
a->samplerate = rate; buffsize = size;
initBlanker (a); initBlanker();
}
void ANB::setSize_anb (ANB *a, int size)
{
a->buffsize = size;
initBlanker (a);
} }
/******************************************************************************************************** /********************************************************************************************************
* * * *
* RXA PROPERTIES * * Common interface *
* * * *
********************************************************************************************************/ ********************************************************************************************************/
void ANB::SetANBRun (RXA& rxa, int run) void ANB::setRun (int _run)
{ {
ANB *a = rxa.anb; run = _run;
a->run = run;
} }
void ANB::SetANBBuffsize (RXA& rxa, int size) void ANB::setBuffsize (int size)
{ {
ANB *a = rxa.anb; buffsize = size;
a->buffsize = size;
} }
void ANB::SetANBSamplerate (RXA& rxa, int rate) void ANB::setSamplerate (int rate)
{ {
ANB *a = rxa.anb; samplerate = (double) rate;
a->samplerate = (double) rate; initBlanker();
initBlanker (a);
} }
void ANB::SetANBTau (RXA& rxa, double tau) void ANB::setTau (double _tau)
{ {
ANB *a = rxa.anb; tau = _tau;
a->tau = tau; initBlanker();
initBlanker (a);
} }
void ANB::SetANBHangtime (RXA& rxa, double time) void ANB::setHangtime (double time)
{ {
ANB *a = rxa.anb; hangtime = time;
a->hangtime = time; initBlanker();
initBlanker (a);
} }
void ANB::SetANBAdvtime (RXA& rxa, double time) void ANB::setAdvtime (double time)
{ {
ANB *a = rxa.anb; advtime = time;
a->advtime = time; initBlanker();
initBlanker (a);
} }
void ANB::SetANBBacktau (RXA& rxa, double tau) void ANB::setBacktau (double tau)
{ {
ANB *a = rxa.anb; backtau = tau;
a->backtau = tau; initBlanker();
initBlanker (a);
} }
void ANB::SetANBThreshold (RXA& rxa, double thresh) void ANB::setThreshold (double thresh)
{ {
ANB *a = rxa.anb; threshold = thresh;
a->threshold = thresh;
} }
} }

33
wdsp/anb.hpp
View File

@ -66,7 +66,7 @@ public:
double ombackmult; // multiplier for waveform averaging double ombackmult; // multiplier for waveform averaging
float *legacy; float *legacy;
static ANB* create_anb ( ANB(
int run, int run,
int buffsize, int buffsize,
float* in, float* in,
@ -78,25 +78,24 @@ public:
double backtau, double backtau,
double threshold double threshold
); );
~ANB();
static void destroy_anb (ANB *a); void flush();
static void flush_anb (ANB *a); void x();
static void xanb (ANB *a); void setBuffers(float* in, float* out);
static void setBuffers_anb (ANB *a, float* in, float* out); void setSize(int size);
static void setSamplerate_anb (ANB *a, int rate); // Common interface
static void setSize_anb (ANB *a, int size); void setRun (int run);
// RXA void setBuffsize (int size);
static void SetANBRun (RXA& rxa, int run); void setSamplerate (int rate);
static void SetANBBuffsize (RXA& rxa, int size); void setTau (double tau);
static void SetANBSamplerate (RXA& rxa, int rate); void setHangtime (double time);
static void SetANBTau (RXA& rxa, double tau); void setAdvtime (double time);
static void SetANBHangtime (RXA& rxa, double time); void setBacktau (double tau);
static void SetANBAdvtime (RXA& rxa, double time); void setThreshold (double thresh);
static void SetANBBacktau (RXA& rxa, double tau);
static void SetANBThreshold (RXA& rxa, double thresh);
private: private:
static void initBlanker(ANB *a); //////////// legacy interface - remove void initBlanker();
}; };

645
wdsp/nob.cpp
View File

@ -39,129 +39,127 @@ warren@wpratt.com
namespace WDSP { namespace WDSP {
void NOB::init_nob (NOB *a) void NOB::init_nob()
{ {
int i; int i;
double coef; double coef;
a->adv_slew_count = (int)(a->advslewtime * a->samplerate); adv_slew_count = (int)(advslewtime * samplerate);
a->adv_count = (int)(a->advtime * a->samplerate); adv_count = (int)(advtime * samplerate);
a->hang_count = (int)(a->hangtime * a->samplerate); hang_count = (int)(hangtime * samplerate);
a->hang_slew_count = (int)(a->hangslewtime * a->samplerate); hang_slew_count = (int)(hangslewtime * samplerate);
a->max_imp_seq = (int)(a->max_imp_seq_time * a->samplerate); max_imp_seq = (int)(max_imp_seq_time * samplerate);
a->backmult = exp (-1.0 / (a->samplerate * a->backtau)); backmult = exp (-1.0 / (samplerate * backtau));
a->ombackmult = 1.0 - a->backmult; ombackmult = 1.0 - backmult;
if (a->adv_slew_count > 0) if (adv_slew_count > 0)
{ {
coef = PI / (a->adv_slew_count + 1); coef = PI / (adv_slew_count + 1);
for (i = 0; i < a->adv_slew_count; i++) for (i = 0; i < adv_slew_count; i++)
a->awave[i] = 0.5 * cos ((i + 1) * coef); awave[i] = 0.5 * cos ((i + 1) * coef);
} }
if (a->hang_slew_count > 0) if (hang_slew_count > 0)
{ {
coef = PI / a->hang_slew_count; coef = PI / hang_slew_count;
for (i = 0; i < a->hang_slew_count; i++) for (i = 0; i < hang_slew_count; i++)
a->hwave[i] = 0.5 * cos (i * coef); hwave[i] = 0.5 * cos (i * coef);
} }
flush_nob (a); flush();
} }
NOB* NOB::create_nob ( NOB::NOB (
int run, int _run,
int buffsize, int _buffsize,
float* in, float* _in,
float* out, float* _out,
double samplerate, double _samplerate,
int mode, int _mode,
double advslewtime, double _advslewtime,
double advtime, double _advtime,
double hangslewtime, double _hangslewtime,
double hangtime, double _hangtime,
double max_imp_seq_time, double _max_imp_seq_time,
double backtau, double _backtau,
double threshold double _threshold
) )
{ {
NOB *a = new NOB; run = _run;
a->run = run; buffsize = _buffsize;
a->buffsize = buffsize; in = _in;
a->in = in; out = _out;
a->out = out; samplerate = _samplerate;
a->samplerate = samplerate; mode = _mode;
a->mode = mode; advslewtime = _advslewtime;
a->advslewtime = advslewtime; advtime = _advtime;
a->advtime = advtime; hangslewtime = _hangslewtime;
a->hangslewtime = hangslewtime; hangtime = _hangtime;
a->hangtime = hangtime; max_imp_seq_time = _max_imp_seq_time;
a->max_imp_seq_time = max_imp_seq_time; backtau = _backtau;
a->backtau = backtau; threshold = _threshold;
a->threshold = threshold; dline_size = (int)(MAX_SAMPLERATE * (
a->dline_size = (int)(MAX_SAMPLERATE * (MAX_ADV_SLEW_TIME + MAX_ADV_SLEW_TIME +
MAX_ADV_TIME + MAX_ADV_TIME +
MAX_HANG_SLEW_TIME + MAX_HANG_SLEW_TIME +
MAX_HANG_TIME + MAX_HANG_TIME +
MAX_SEQ_TIME ) + 2); MAX_SEQ_TIME ) + 2);
a->dline = new double[a->dline_size * 2]; dline = new double[dline_size * 2];
a->imp = new int[a->dline_size]; imp = new int[dline_size];
a->awave = new double[(int)(MAX_ADV_SLEW_TIME * MAX_SAMPLERATE + 1)]; awave = new double[(int)(MAX_ADV_SLEW_TIME * MAX_SAMPLERATE + 1)];
a->hwave = new double[(int)(MAX_HANG_SLEW_TIME * MAX_SAMPLERATE + 1)]; hwave = new double[(int)(MAX_HANG_SLEW_TIME * MAX_SAMPLERATE + 1)];
a->filterlen = 10; filterlen = 10;
a->bfbuff = new double[a->filterlen * 2]; bfbuff = new double[filterlen * 2];
a->ffbuff = new double[a->filterlen * 2]; ffbuff = new double[filterlen * 2];
a->fcoefs = new double[a->filterlen]; fcoefs = new double[filterlen];
a->fcoefs[0] = 0.308720593; fcoefs[0] = 0.308720593;
a->fcoefs[1] = 0.216104415; fcoefs[1] = 0.216104415;
a->fcoefs[2] = 0.151273090; fcoefs[2] = 0.151273090;
a->fcoefs[3] = 0.105891163; fcoefs[3] = 0.105891163;
a->fcoefs[4] = 0.074123814; fcoefs[4] = 0.074123814;
a->fcoefs[5] = 0.051886670; fcoefs[5] = 0.051886670;
a->fcoefs[6] = 0.036320669; fcoefs[6] = 0.036320669;
a->fcoefs[7] = 0.025424468; fcoefs[7] = 0.025424468;
a->fcoefs[8] = 0.017797128; fcoefs[8] = 0.017797128;
a->fcoefs[9] = 0.012457989; fcoefs[9] = 0.012457989;
init_nob (a); init_nob();
a->legacy = new double[2048 * 2]; /////////////// legacy interface - remove legacy = new double[2048 * 2]; /////////////// legacy interface - remove
return a;
} }
void NOB::destroy_nob (NOB *a) NOB::~NOB()
{ {
delete[] (a->legacy); /////////////// remove delete[] (legacy); /////////////// remove
delete[] (a->fcoefs); delete[] (fcoefs);
delete[] (a->ffbuff); delete[] (ffbuff);
delete[] (a->bfbuff); delete[] (bfbuff);
delete[] (a->hwave); delete[] (hwave);
delete[] (a->awave); delete[] (awave);
delete[] (a->imp); delete[] (imp);
delete[] (a->dline); delete[] (dline);
delete (a);
} }
void NOB::flush_nob (NOB *a) void NOB::flush()
{ {
a->out_idx = 0; out_idx = 0;
a->scan_idx = a->out_idx + a->adv_slew_count + a->adv_count + 1; scan_idx = out_idx + adv_slew_count + adv_count + 1;
a->in_idx = a->scan_idx + a->max_imp_seq + a->hang_count + a->hang_slew_count + a->filterlen; in_idx = scan_idx + max_imp_seq + hang_count + hang_slew_count + filterlen;
a->state = 0; state = 0;
a->overflow = 0; overflow = 0;
a->avg = 1.0; avg = 1.0;
a->bfb_in_idx = a->filterlen - 1; bfb_in_idx = filterlen - 1;
a->ffb_in_idx = a->filterlen - 1; ffb_in_idx = filterlen - 1;
std::fill(a->dline, a->dline + a->dline_size * 2, 0); std::fill(dline, dline + dline_size * 2, 0);
std::fill(a->imp, a->imp + a->dline_size, 0); std::fill(imp, imp + dline_size, 0);
std::fill(a->bfbuff, a->bfbuff + a->filterlen * 2, 0); std::fill(bfbuff, bfbuff + filterlen * 2, 0);
std::fill(a->ffbuff, a->ffbuff + a->filterlen * 2, 0); std::fill(ffbuff, ffbuff + filterlen * 2, 0);
} }
void NOB::xnob (NOB *a) void NOB::x()
{ {
double scale; double scale;
double mag; double mag;
@ -176,204 +174,204 @@ void NOB::xnob (NOB *a)
int ffcount; int ffcount;
int staydown; int staydown;
if (a->run) if (run)
{ {
for (i = 0; i < a->buffsize; i++) for (i = 0; i < buffsize; i++)
{ {
a->dline[2 * a->in_idx + 0] = a->in[2 * i + 0]; dline[2 * in_idx + 0] = in[2 * i + 0];
a->dline[2 * a->in_idx + 1] = a->in[2 * i + 1]; dline[2 * in_idx + 1] = in[2 * i + 1];
mag = sqrt(a->dline[2 * a->in_idx + 0] * a->dline[2 * a->in_idx + 0] + a->dline[2 * a->in_idx + 1] * a->dline[2 * a->in_idx + 1]); mag = sqrt(dline[2 * in_idx + 0] * dline[2 * in_idx + 0] + dline[2 * in_idx + 1] * dline[2 * in_idx + 1]);
a->avg = a->backmult * a->avg + a->ombackmult * mag; avg = backmult * avg + ombackmult * mag;
if (mag > (a->avg * a->threshold)) if (mag > (avg * threshold))
a->imp[a->in_idx] = 1; imp[in_idx] = 1;
else else
a->imp[a->in_idx] = 0; imp[in_idx] = 0;
if ((bf_idx = a->out_idx + a->adv_slew_count) >= a->dline_size) if ((bf_idx = out_idx + adv_slew_count) >= dline_size)
bf_idx -= a->dline_size; bf_idx -= dline_size;
if (a->imp[bf_idx] == 0) if (imp[bf_idx] == 0)
{ {
if (++a->bfb_in_idx == a->filterlen) if (++bfb_in_idx == filterlen)
a->bfb_in_idx -= a->filterlen; bfb_in_idx -= filterlen;
a->bfbuff[2 * a->bfb_in_idx + 0] = a->dline[2 * bf_idx + 0]; bfbuff[2 * bfb_in_idx + 0] = dline[2 * bf_idx + 0];
a->bfbuff[2 * a->bfb_in_idx + 1] = a->dline[2 * bf_idx + 1]; bfbuff[2 * bfb_in_idx + 1] = dline[2 * bf_idx + 1];
} }
switch (a->state) switch (state)
{ {
case 0: // normal output & impulse setup case 0: // normal output & impulse setup
{ {
a->out[2 * i + 0] = a->dline[2 * a->out_idx + 0]; out[2 * i + 0] = dline[2 * out_idx + 0];
a->out[2 * i + 1] = a->dline[2 * a->out_idx + 1]; out[2 * i + 1] = dline[2 * out_idx + 1];
a->Ilast = a->dline[2 * a->out_idx + 0]; Ilast = dline[2 * out_idx + 0];
a->Qlast = a->dline[2 * a->out_idx + 1]; Qlast = dline[2 * out_idx + 1];
if (a->imp[a->scan_idx] > 0) if (imp[scan_idx] > 0)
{ {
a->time = 0; time = 0;
if (a->adv_slew_count > 0) if (adv_slew_count > 0)
a->state = 1; state = 1;
else if (a->adv_count > 0) else if (adv_count > 0)
a->state = 2; state = 2;
else else
a->state = 3; state = 3;
tidx = a->scan_idx; tidx = scan_idx;
a->blank_count = 0; blank_count = 0;
do do
{ {
len = 0; len = 0;
hcount = 0; hcount = 0;
while ((a->imp[tidx] > 0 || hcount > 0) && a->blank_count < a->max_imp_seq) while ((imp[tidx] > 0 || hcount > 0) && blank_count < max_imp_seq)
{ {
a->blank_count++; blank_count++;
if (hcount > 0) if (hcount > 0)
hcount--; hcount--;
if (a->imp[tidx] > 0) if (imp[tidx] > 0)
hcount = a->hang_count + a->hang_slew_count; hcount = hang_count + hang_slew_count;
if (++tidx >= a->dline_size) if (++tidx >= dline_size)
tidx -= a->dline_size; tidx -= dline_size;
} }
j = 1; j = 1;
len = 0; len = 0;
lidx = tidx; lidx = tidx;
while (j <= a->adv_slew_count + a->adv_count && len == 0) while (j <= adv_slew_count + adv_count && len == 0)
{ {
if (a->imp[lidx] == 1) if (imp[lidx] == 1)
{ {
len = j; len = j;
tidx = lidx; tidx = lidx;
} }
if (++lidx >= a->dline_size) if (++lidx >= dline_size)
lidx -= a->dline_size; lidx -= dline_size;
j++; j++;
} }
if((a->blank_count += len) > a->max_imp_seq) if((blank_count += len) > max_imp_seq)
{ {
a->blank_count = a->max_imp_seq; blank_count = max_imp_seq;
a->overflow = 1; overflow = 1;
break; break;
} }
} }
while (len != 0); while (len != 0);
if (a->overflow == 0) if (overflow == 0)
{ {
a->blank_count -= a->hang_slew_count; blank_count -= hang_slew_count;
a->Inext = a->dline[2 * tidx + 0]; Inext = dline[2 * tidx + 0];
a->Qnext = a->dline[2 * tidx + 1]; Qnext = dline[2 * tidx + 1];
if (a->mode == 1 || a->mode == 2 || a->mode == 4) if (mode == 1 || mode == 2 || mode == 4)
{ {
bfboutidx = a->bfb_in_idx; bfboutidx = bfb_in_idx;
a->I1 = 0.0; I1 = 0.0;
a->Q1 = 0.0; Q1 = 0.0;
for (k = 0; k < a->filterlen; k++) for (k = 0; k < filterlen; k++)
{ {
a->I1 += a->fcoefs[k] * a->bfbuff[2 * bfboutidx + 0]; I1 += fcoefs[k] * bfbuff[2 * bfboutidx + 0];
a->Q1 += a->fcoefs[k] * a->bfbuff[2 * bfboutidx + 1]; Q1 += fcoefs[k] * bfbuff[2 * bfboutidx + 1];
if (--bfboutidx < 0) if (--bfboutidx < 0)
bfboutidx += a->filterlen; bfboutidx += filterlen;
} }
} }
if (a->mode == 2 || a->mode == 3 || a->mode == 4) if (mode == 2 || mode == 3 || mode == 4)
{ {
if ((ff_idx = a->scan_idx + a->blank_count) >= a->dline_size) if ((ff_idx = scan_idx + blank_count) >= dline_size)
ff_idx -= a->dline_size; ff_idx -= dline_size;
ffcount = 0; ffcount = 0;
while (ffcount < a->filterlen) while (ffcount < filterlen)
{ {
if (a->imp[ff_idx] == 0) if (imp[ff_idx] == 0)
{ {
if (++a->ffb_in_idx == a->filterlen) if (++ffb_in_idx == filterlen)
a->ffb_in_idx -= a->filterlen; ffb_in_idx -= filterlen;
a->ffbuff[2 * a->ffb_in_idx + 0] = a->dline[2 * ff_idx + 0]; ffbuff[2 * ffb_in_idx + 0] = dline[2 * ff_idx + 0];
a->ffbuff[2 * a->ffb_in_idx + 1] = a->dline[2 * ff_idx + 1]; ffbuff[2 * ffb_in_idx + 1] = dline[2 * ff_idx + 1];
++ffcount; ++ffcount;
} }
if (++ff_idx >= a->dline_size) if (++ff_idx >= dline_size)
ff_idx -= a->dline_size; ff_idx -= dline_size;
} }
if ((ffboutidx = a->ffb_in_idx + 1) >= a->filterlen) if ((ffboutidx = ffb_in_idx + 1) >= filterlen)
ffboutidx -= a->filterlen; ffboutidx -= filterlen;
a->I2 = 0.0; I2 = 0.0;
a->Q2 = 0.0; Q2 = 0.0;
for (k = 0; k < a->filterlen; k++) for (k = 0; k < filterlen; k++)
{ {
a->I2 += a->fcoefs[k] * a->ffbuff[2 * ffboutidx + 0]; I2 += fcoefs[k] * ffbuff[2 * ffboutidx + 0];
a->Q2 += a->fcoefs[k] * a->ffbuff[2 * ffboutidx + 1]; Q2 += fcoefs[k] * ffbuff[2 * ffboutidx + 1];
if (++ffboutidx >= a->filterlen) if (++ffboutidx >= filterlen)
ffboutidx -= a->filterlen; ffboutidx -= filterlen;
} }
} }
switch (a->mode) switch (mode)
{ {
case 0: // zero case 0: // zero
a->deltaI = 0.0; deltaI = 0.0;
a->deltaQ = 0.0; deltaQ = 0.0;
a->I = 0.0; I = 0.0;
a->Q = 0.0; Q = 0.0;
break; break;
case 1: // sample-hold case 1: // sample-hold
a->deltaI = 0.0; deltaI = 0.0;
a->deltaQ = 0.0; deltaQ = 0.0;
a->I = a->I1; I = I1;
a->Q = a->Q1; Q = Q1;
break; break;
case 2: // mean-hold case 2: // mean-hold
a->deltaI = 0.0; deltaI = 0.0;
a->deltaQ = 0.0; deltaQ = 0.0;
a->I = 0.5 * (a->I1 + a->I2); I = 0.5 * (I1 + I2);
a->Q = 0.5 * (a->Q1 + a->Q2); Q = 0.5 * (Q1 + Q2);
break; break;
case 3: // hold-sample case 3: // hold-sample
a->deltaI = 0.0; deltaI = 0.0;
a->deltaQ = 0.0; deltaQ = 0.0;
a->I = a->I2; I = I2;
a->Q = a->Q2; Q = Q2;
break; break;
case 4: // linear interpolation case 4: // linear interpolation
a->deltaI = (a->I2 - a->I1) / (a->adv_count + a->blank_count); deltaI = (I2 - I1) / (adv_count + blank_count);
a->deltaQ = (a->Q2 - a->Q1) / (a->adv_count + a->blank_count); deltaQ = (Q2 - Q1) / (adv_count + blank_count);
a->I = a->I1; I = I1;
a->Q = a->Q1; Q = Q1;
break; break;
} }
} }
else else
{ {
if (a->adv_slew_count > 0) if (adv_slew_count > 0)
{ {
a->state = 5; state = 5;
} }
else else
{ {
a->state = 6; state = 6;
a->time = 0; time = 0;
a->blank_count += a->adv_count + a->filterlen; blank_count += adv_count + filterlen;
} }
} }
} }
@ -383,18 +381,18 @@ void NOB::xnob (NOB *a)
case 1: // slew output in advance of blanking period case 1: // slew output in advance of blanking period
{ {
scale = 0.5 + a->awave[a->time]; scale = 0.5 + awave[time];
a->out[2 * i + 0] = a->Ilast * scale + (1.0 - scale) * a->I; out[2 * i + 0] = Ilast * scale + (1.0 - scale) * I;
a->out[2 * i + 1] = a->Qlast * scale + (1.0 - scale) * a->Q; out[2 * i + 1] = Qlast * scale + (1.0 - scale) * Q;
if (++a->time == a->adv_slew_count) if (++time == adv_slew_count)
{ {
a->time = 0; time = 0;
if (a->adv_count > 0) if (adv_count > 0)
a->state = 2; state = 2;
else else
a->state = 3; state = 3;
} }
break; break;
@ -402,15 +400,15 @@ void NOB::xnob (NOB *a)
case 2: // initial advance period case 2: // initial advance period
{ {
a->out[2 * i + 0] = a->I; out[2 * i + 0] = I;
a->out[2 * i + 1] = a->Q; out[2 * i + 1] = Q;
a->I += a->deltaI; I += deltaI;
a->Q += a->deltaQ; Q += deltaQ;
if (++a->time == a->adv_count) if (++time == adv_count)
{ {
a->state = 3; state = 3;
a->time = 0; time = 0;
} }
break; break;
@ -418,21 +416,21 @@ void NOB::xnob (NOB *a)
case 3: // impulse & hang period case 3: // impulse & hang period
{ {
a->out[2 * i + 0] = a->I; out[2 * i + 0] = I;
a->out[2 * i + 1] = a->Q; out[2 * i + 1] = Q;
a->I += a->deltaI; I += deltaI;
a->Q += a->deltaQ; Q += deltaQ;
if (++a->time == a->blank_count) if (++time == blank_count)
{ {
if (a->hang_slew_count > 0) if (hang_slew_count > 0)
{ {
a->state = 4; state = 4;
a->time = 0; time = 0;
} }
else else
{ {
a->state = 0; state = 0;
} }
} }
@ -441,27 +439,27 @@ void NOB::xnob (NOB *a)
case 4: // slew output after blanking period case 4: // slew output after blanking period
{ {
scale = 0.5 - a->hwave[a->time]; scale = 0.5 - hwave[time];
a->out[2 * i + 0] = a->Inext * scale + (1.0 - scale) * a->I; out[2 * i + 0] = Inext * scale + (1.0 - scale) * I;
a->out[2 * i + 1] = a->Qnext * scale + (1.0 - scale) * a->Q; out[2 * i + 1] = Qnext * scale + (1.0 - scale) * Q;
if (++a->time == a->hang_slew_count) if (++time == hang_slew_count)
a->state = 0; state = 0;
break; break;
} }
case 5: case 5:
{ {
scale = 0.5 + a->awave[a->time]; scale = 0.5 + awave[time];
a->out[2 * i + 0] = a->Ilast * scale; out[2 * i + 0] = Ilast * scale;
a->out[2 * i + 1] = a->Qlast * scale; out[2 * i + 1] = Qlast * scale;
if (++a->time == a->adv_slew_count) if (++time == adv_slew_count)
{ {
a->state = 6; state = 6;
a->time = 0; time = 0;
a->blank_count += a->adv_count + a->filterlen; blank_count += adv_count + filterlen;
} }
break; break;
@ -469,56 +467,56 @@ void NOB::xnob (NOB *a)
case 6: case 6:
{ {
a->out[2 * i + 0] = 0.0; out[2 * i + 0] = 0.0;
a->out[2 * i + 1] = 0.0; out[2 * i + 1] = 0.0;
if (++a->time == a->blank_count) if (++time == blank_count)
a->state = 7; state = 7;
break; break;
} }
case 7: case 7:
{ {
a->out[2 * i + 0] = 0.0; out[2 * i + 0] = 0.0;
a->out[2 * i + 1] = 0.0; out[2 * i + 1] = 0.0;
staydown = 0; staydown = 0;
a->time = 0; time = 0;
if ((tidx = a->scan_idx + a->hang_slew_count + a->hang_count) >= a->dline_size) if ((tidx = scan_idx + hang_slew_count + hang_count) >= dline_size)
tidx -= a->dline_size; tidx -= dline_size;
while (a->time++ <= a->adv_count + a->adv_slew_count + a->hang_slew_count + a->hang_count) // CHECK EXACT COUNTS!!!!!!!!!!!!!!!!!!!!!!! while (time++ <= adv_count + adv_slew_count + hang_slew_count + hang_count) // CHECK EXACT COUNTS!!!!!!!!!!!!!!!!!!!!!!!
{ {
if (a->imp[tidx] == 1) staydown = 1; if (imp[tidx] == 1) staydown = 1;
if (--tidx < 0) tidx += a->dline_size; if (--tidx < 0) tidx += dline_size;
} }
if (staydown == 0) if (staydown == 0)
{ {
if (a->hang_count > 0) if (hang_count > 0)
{ {
a->state = 8; state = 8;
a->time = 0; time = 0;
} }
else if (a->hang_slew_count > 0) else if (hang_slew_count > 0)
{ {
a->state = 9; state = 9;
a->time = 0; time = 0;
if ((tidx = a->scan_idx + a->hang_slew_count + a->hang_count - a->adv_count - a->adv_slew_count) >= a->dline_size) if ((tidx = scan_idx + hang_slew_count + hang_count - adv_count - adv_slew_count) >= dline_size)
tidx -= a->dline_size; tidx -= dline_size;
if (tidx < 0) if (tidx < 0)
tidx += a->dline_size; tidx += dline_size;
a->Inext = a->dline[2 * tidx + 0]; Inext = dline[2 * tidx + 0];
a->Qnext = a->dline[2 * tidx + 1]; Qnext = dline[2 * tidx + 1];
} }
else else
{ {
a->state = 0; state = 0;
a->overflow = 0; overflow = 0;
} }
} }
@ -527,29 +525,29 @@ void NOB::xnob (NOB *a)
case 8: case 8:
{ {
a->out[2 * i + 0] = 0.0; out[2 * i + 0] = 0.0;
a->out[2 * i + 1] = 0.0; out[2 * i + 1] = 0.0;
if (++a->time == a->hang_count) if (++time == hang_count)
{ {
if (a->hang_slew_count > 0) if (hang_slew_count > 0)
{ {
a->state = 9; state = 9;
a->time = 0; time = 0;
if ((tidx = a->scan_idx + a->hang_slew_count - a->adv_count - a->adv_slew_count) >= a->dline_size) if ((tidx = scan_idx + hang_slew_count - adv_count - adv_slew_count) >= dline_size)
tidx -= a->dline_size; tidx -= dline_size;
if (tidx < 0) if (tidx < 0)
tidx += a->dline_size; tidx += dline_size;
a->Inext = a->dline[2 * tidx + 0]; Inext = dline[2 * tidx + 0];
a->Qnext = a->dline[2 * tidx + 1]; Qnext = dline[2 * tidx + 1];
} }
else else
{ {
a->state = 0; state = 0;
a->overflow = 0; overflow = 0;
} }
} }
@ -558,118 +556,103 @@ void NOB::xnob (NOB *a)
case 9: case 9:
{ {
scale = 0.5 - a->hwave[a->time]; scale = 0.5 - hwave[time];
a->out[2 * i + 0] = a->Inext * scale; out[2 * i + 0] = Inext * scale;
a->out[2 * i + 1] = a->Qnext * scale; out[2 * i + 1] = Qnext * scale;
if (++a->time >= a->hang_slew_count) if (++time >= hang_slew_count)
{ {
a->state = 0; state = 0;
a->overflow = 0; overflow = 0;
} }
break; break;
} }
} }
if (++a->in_idx == a->dline_size) if (++in_idx == dline_size)
a->in_idx = 0; in_idx = 0;
if (++a->scan_idx == a->dline_size) if (++scan_idx == dline_size)
a->scan_idx = 0; scan_idx = 0;
if (++a->out_idx == a->dline_size) if (++out_idx == dline_size)
a->out_idx = 0; out_idx = 0;
} }
} }
else if (a->in != a->out) else if (in != out)
{ {
std::copy(a->in, a->in + a->buffsize * 2, a->out); std::copy(in, in + buffsize * 2, out);
} }
} }
void NOB::setBuffers_nob (NOB *a, float* in, float* out) void NOB::setBuffers(float* in, float* out)
{ {
a->in = in; in = in;
a->out = out; out = out;
} }
void NOB::setSamplerate_nob (NOB *a, int rate) void NOB::setSize(int size)
{ {
a->samplerate = rate; buffsize = size;
init_nob (a); flush();
}
void NOB::setSize_nob (NOB *a, int size)
{
a->buffsize = size;
flush_nob (a);
} }
/******************************************************************************************************** /********************************************************************************************************
* * * *
* RXA PROPERTIES * * Common interface *
* * * *
********************************************************************************************************/ ********************************************************************************************************/
void NOB::SetNOBRun (RXA& rxa, int run) void NOB::setRun(int _run)
{ {
NOB *a = rxa.nob; run = _run;
a->run = run;
} }
void NOB::SetNOBMode (RXA& rxa, int mode) void NOB::setMode(int _mode)
{ {
NOB *a = rxa.nob; mode = _mode;
a->mode = mode;
} }
void NOB::SetNOBBuffsize (RXA& rxa, int size) void NOB::setBuffsize(int size)
{ {
NOB *a = rxa.nob; buffsize = size;
a->buffsize = size;
} }
void NOB::SetNOBSamplerate (RXA& rxa, int rate) void NOB::setSamplerate(int rate)
{ {
NOB *a = rxa.nob; samplerate = (double) rate;
a->samplerate = (double) rate; init_nob();
init_nob (a);
} }
void NOB::SetNOBTau (RXA& rxa, double tau) void NOB::setTau(double tau)
{ {
NOB *a = rxa.nob; advslewtime = tau;
a->advslewtime = tau; hangslewtime = tau;
a->hangslewtime = tau; init_nob();
init_nob (a);
} }
void NOB::SetNOBHangtime (RXA& rxa, double time) void NOB::setHangtime(double time)
{ {
NOB *a = rxa.nob; hangtime = time;
a->hangtime = time; init_nob();
init_nob (a);
} }
void NOB::SetNOBAdvtime (RXA& rxa, double time) void NOB::setAdvtime(double time)
{ {
NOB *a = rxa.nob; advtime = time;
a->advtime = time; init_nob();
init_nob (a);
} }
void NOB::SetNOBBacktau (RXA& rxa, double tau) void NOB::setBacktau(double tau)
{ {
NOB *a = rxa.nob; backtau = tau;
a->backtau = tau; init_nob();
init_nob (a);
} }
void NOB::SetNOBThreshold (RXA& rxa, double thresh) void NOB::setThreshold(double thresh)
{ {
NOB *a = rxa.nob; threshold = thresh;
a->threshold = thresh;
} }
} // namespace } // namespace

38
wdsp/nob.hpp
View File

@ -82,8 +82,7 @@ public:
int overflow; int overflow;
double *legacy; double *legacy;
//////////// legacy interface - remove NOB(
static NOB* create_nob (
int run, int run,
int buffsize, int buffsize,
float* in, float* in,
@ -98,26 +97,25 @@ public:
double backtau, double backtau,
double threshold double threshold
); );
~NOB();
static void destroy_nob (NOB* a); //////////// legacy interface - remove
static void flush_nob (NOB* a); void flush();
static void xnob (NOB* a); void x();
static void setBuffers_nob (NOB *a, float* in, float* out); void setBuffers(float* in, float* out);
static void setSamplerate_nob (NOB *a, int rate); void setSize(int size);
static void setSize_nob (NOB *a, int size); // Common interface
// RXA void setRun (int run);
static void SetNOBRun (RXA& rxa, int run); void setMode (int mode);
static void SetNOBMode (RXA& rxa, int mode); void setBuffsize (int size);
static void SetNOBBuffsize (RXA& rxa, int size); void setSamplerate (int size);
static void SetNOBSamplerate (RXA& rxa, int size); void setTau (double tau);
static void SetNOBTau (RXA& rxa, double tau); void setHangtime (double time);
static void SetNOBHangtime (RXA& rxa, double time); void setAdvtime (double time);
static void SetNOBAdvtime (RXA& rxa, double time); void setBacktau (double tau);
static void SetNOBBacktau (RXA& rxa, double tau); void setThreshold (double thresh);
static void SetNOBThreshold (RXA& rxa, double thresh);
private: private:
static void init_nob (NOB *a); void init_nob();
}; };