Mirror/aicodix___modem
1
0
Fork 0
mirror of https://github.com/aicodix/modem.git synced 2026-04-27 14:30:34 +00:00
Code Issues Projects Releases Packages Wiki Activity

added next_sample()

Browse source
This commit is contained in:
Ahmet Inan 2021-09-06 12:12:13 +02:00
commit ba102a5799
1 changed files with 15 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

30
decode.cc
View file

@ -308,6 +308,14 @@ struct Decoder
break; break;
} }
} }
const cmplx *next_sample()
{
cmplx tmp;
pcm->read(reinterpret_cast<value *>(&tmp), 1);
if (pcm->channels() == 1)
tmp = hilbert(blockdc(tmp.real()));
return input_hist(tmp);
}
Decoder(uint8_t *out, DSP::ReadPCM<value> *pcm, int skip_count) : Decoder(uint8_t *out, DSP::ReadPCM<value> *pcm, int skip_count) :
pcm(pcm), correlator(mls0_seq()), crc0(0xA8F4), crc1(0xD419CC15) pcm(pcm), correlator(mls0_seq()), crc0(0xA8F4), crc1(0xD419CC15)
{ {
@ -319,7 +327,6 @@ struct Decoder
0b101011111, 0b111111001, 0b111000011, 0b100111001, 0b101011111, 0b111111001, 0b111000011, 0b100111001,
0b110101001, 0b000011111, 0b110000111, 0b110110001}); 0b110101001, 0b000011111, 0b110000111, 0b110110001});
bool real = pcm->channels() == 1;
blockdc.samples(2*(symbol_len+guard_len)); blockdc.samples(2*(symbol_len+guard_len));
DSP::Phasor<cmplx> osc; DSP::Phasor<cmplx> osc;
const cmplx *buf; const cmplx *buf;
@ -329,11 +336,7 @@ struct Decoder
do { do {
if (!pcm->good()) if (!pcm->good())
return; return;
cmplx tmp; buf = next_sample();
pcm->read(reinterpret_cast<value *>(&tmp), 1);
if (real)
tmp = hilbert(blockdc(tmp.real()));
buf = input_hist(tmp);
} while (!correlator(buf)); } while (!correlator(buf));
symbol_pos = correlator.symbol_pos; symbol_pos = correlator.symbol_pos;
@ -460,21 +463,18 @@ struct Decoder
int cons_rows = cons_cnt / cons_cols; int cons_rows = cons_cnt / cons_cols;
int code_off = - cons_cols / 2; int code_off = - cons_cols / 2;
for (int i = 0; i < symbol_pos+2*(symbol_len+guard_len); ++i)
buf = next_sample();
for (int i = 0; i < symbol_len; ++i) for (int i = 0; i < symbol_len; ++i)
tdom[i] = buf[i+symbol_pos+2*(symbol_len+guard_len)] * osc(); tdom[i] = buf[i] * osc();
for (int i = 0; i < guard_len; ++i) for (int i = 0; i < guard_len; ++i)
osc(); osc();
fwd(fdom, tdom); fwd(fdom, tdom);
for (int j = 0; j < cons_rows; ++j) { for (int j = 0; j < cons_rows; ++j) {
for (int i = 0; i < symbol_len+guard_len; ++i) { for (int i = 0; i < symbol_len+guard_len; ++i)
cmplx tmp; buf = next_sample();
pcm->read(reinterpret_cast<value *>(&tmp), 1);
if (real)
tmp = hilbert(blockdc(tmp.real()));
buf = input_hist(tmp);
}
for (int i = 0; i < symbol_len; ++i) for (int i = 0; i < symbol_len; ++i)
tdom[i] = buf[i+symbol_pos+2*(symbol_len+guard_len)] * osc(); tdom[i] = buf[i] * osc();
for (int i = 0; i < guard_len; ++i) for (int i = 0; i < guard_len; ++i)
osc(); osc();
for (int i = 0; i < cons_cols; ++i) for (int i = 0; i < cons_cols; ++i)