1091 lines
36 KiB
C
1091 lines
36 KiB
C
/*
|
||
* Copyright (C) 2010 DSD Author
|
||
* GPG Key ID: 0x3F1D7FD0 (74EF 430D F7F2 0A48 FCE6 F630 FAA2 635D 3F1D 7FD0)
|
||
*
|
||
* Permission to use, copy, modify, and/or distribute this software for any
|
||
* purpose with or without fee is hereby granted, provided that the above
|
||
* copyright notice and this permission notice appear in all copies.
|
||
*
|
||
* THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
|
||
* REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
|
||
* AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
|
||
* INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
|
||
* LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
|
||
* OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
|
||
* PERFORMANCE OF THIS SOFTWARE.
|
||
*/
|
||
|
||
#define _MAIN
|
||
|
||
#include "dsd.h"
|
||
#include "p25p1_const.h"
|
||
#include "x2tdma_const.h"
|
||
#include "dstar_const.h"
|
||
#include "nxdn_const.h"
|
||
#include "dmr_const.h"
|
||
#include "provoice_const.h"
|
||
#include "git_ver.h"
|
||
|
||
//pretty pretty colors
|
||
|
||
#define KNRM "\x1B[0m"
|
||
#define KRED "\x1B[31m"
|
||
#define KGRN "\x1B[32m"
|
||
#define KYEL "\x1B[33m"
|
||
#define KBLU "\x1B[34m"
|
||
#define KMAG "\x1B[35m"
|
||
#define KCYN "\x1B[36m"
|
||
#define KWHT "\x1B[37m"
|
||
|
||
int pretty_colors()
|
||
{
|
||
fprintf (stderr,"%sred\n", KRED);
|
||
fprintf (stderr,"%sgreen\n", KGRN);
|
||
fprintf (stderr,"%syellow\n", KYEL);
|
||
fprintf (stderr,"%sblue\n", KBLU);
|
||
fprintf (stderr,"%smagenta\n", KMAG);
|
||
fprintf (stderr,"%scyan\n", KCYN);
|
||
fprintf (stderr,"%swhite\n", KWHT);
|
||
fprintf (stderr,"%snormal\n", KNRM);
|
||
|
||
return 0;
|
||
}
|
||
|
||
|
||
#include "p25p1_heuristics.h"
|
||
#include "pa_devs.h"
|
||
short int butt = 1;
|
||
|
||
char * FM_banner[9] = {
|
||
" CTRL + C twice to exit",
|
||
" ██████╗ ██████╗██████╗ ███████╗███╗ ███╗███████╗",
|
||
" ██╔══██╗██╔════╝██╔══██╗ ██╔════╝████╗ ████║██╔════╝",
|
||
" ██║ ██║╚█████╗ ██║ ██║ █████╗ ██╔████╔██║█████╗ ",
|
||
" ██║ ██║ ╚═══██╗██║ ██║ ██╔══╝ ██║╚██╔╝██║██╔══╝ ",
|
||
" ██████╔╝██████╔╝██████╔╝ ██║ ██║ ╚═╝ ██║███████╗",
|
||
" ╚═════╝ ╚═════╝ ╚═════╝ ╚═╝ ╚═╝ ╚═╝╚══════╝",
|
||
"https://github.com/lwvmobile/dsd-fme/tree/pulseaudio "
|
||
};
|
||
|
||
|
||
int
|
||
comp (const void *a, const void *b)
|
||
{
|
||
if (*((const int *) a) == *((const int *) b))
|
||
return 0;
|
||
else if (*((const int *) a) < *((const int *) b))
|
||
return -1;
|
||
else
|
||
return 1;
|
||
}
|
||
|
||
void
|
||
noCarrier (dsd_opts * opts, dsd_state * state)
|
||
{
|
||
state->dibit_buf_p = state->dibit_buf + 200;
|
||
memset (state->dibit_buf, 0, sizeof (int) * 200);
|
||
if (opts->mbe_out_f != NULL)
|
||
{
|
||
closeMbeOutFile (opts, state);
|
||
}
|
||
state->jitter = -1;
|
||
state->lastsynctype = -1;
|
||
state->carrier = 0;
|
||
state->max = 15000;
|
||
state->min = -15000;
|
||
state->center = 0;
|
||
state->err_str[0] = 0;
|
||
sprintf (state->fsubtype, " ");
|
||
sprintf (state->ftype, " ");
|
||
state->errs = 0;
|
||
state->errs2 = 0;
|
||
state->lasttg = 0;
|
||
state->lastsrc = 0;
|
||
state->lastp25type = 0;
|
||
state->repeat = 0;
|
||
state->nac = 0;
|
||
state->numtdulc = 0;
|
||
sprintf (state->slot0light, " slot0 ");
|
||
sprintf (state->slot1light, " slot1 ");
|
||
state->firstframe = 0;
|
||
if (opts->audio_gain == (float) 0)
|
||
{
|
||
state->aout_gain = 25;
|
||
}
|
||
memset (state->aout_max_buf, 0, sizeof (float) * 200);
|
||
state->aout_max_buf_p = state->aout_max_buf;
|
||
state->aout_max_buf_idx = 0;
|
||
sprintf (state->algid, "________");
|
||
sprintf (state->keyid, "________________");
|
||
mbe_initMbeParms (state->cur_mp, state->prev_mp, state->prev_mp_enhanced);
|
||
}
|
||
|
||
void
|
||
initOpts (dsd_opts * opts)
|
||
{
|
||
|
||
opts->onesymbol = 10;
|
||
opts->mbe_in_file[0] = 0;
|
||
opts->mbe_in_f = NULL;
|
||
opts->errorbars = 1;
|
||
opts->datascope = 0;
|
||
opts->symboltiming = 0;
|
||
opts->verbose = 2;
|
||
opts->p25enc = 0;
|
||
opts->p25lc = 0;
|
||
opts->p25status = 0;
|
||
opts->p25tg = 0;
|
||
opts->scoperate = 15;
|
||
//sprintf (opts->audio_in_dev, "/dev/audio");
|
||
sprintf (opts->audio_in_dev, "pulse");
|
||
opts->audio_in_fd = -1;
|
||
#ifdef USE_PORTAUDIO
|
||
opts->audio_in_pa_stream = NULL;
|
||
#endif
|
||
//sprintf (opts->audio_out_dev, "/dev/audio");
|
||
sprintf (opts->audio_out_dev, "pulse");
|
||
opts->audio_out_fd = -1;
|
||
#ifdef USE_PORTAUDIO
|
||
opts->audio_out_pa_stream = NULL;
|
||
#endif
|
||
opts->split = 0;
|
||
opts->playoffset = 0;
|
||
opts->mbe_out_dir[0] = 0;
|
||
opts->mbe_out_file[0] = 0;
|
||
opts->mbe_out_path[0] = 0;
|
||
opts->mbe_out_f = NULL;
|
||
opts->audio_gain = 0;
|
||
opts->audio_out = 1;
|
||
opts->wav_out_file[0] = 0;
|
||
opts->wav_out_f = NULL;
|
||
//opts->wav_out_fd = -1;
|
||
opts->serial_baud = 115200;
|
||
sprintf (opts->serial_dev, "/dev/ttyUSB0");
|
||
opts->resume = 0;
|
||
opts->frame_dstar = 0;
|
||
opts->frame_x2tdma = 1;
|
||
opts->frame_p25p1 = 1;
|
||
opts->frame_nxdn48 = 0;
|
||
opts->frame_nxdn96 = 0;
|
||
opts->frame_dmr = 1;
|
||
opts->frame_provoice = 0;
|
||
opts->mod_c4fm = 1;
|
||
opts->mod_qpsk = 1;
|
||
opts->mod_gfsk = 1;
|
||
opts->uvquality = 3;
|
||
opts->inverted_x2tdma = 1; // most transmitter + scanner + sound card combinations show inverted signals for this
|
||
opts->inverted_dmr = 0; // most transmitter + scanner + sound card combinations show non-inverted signals for this
|
||
opts->mod_threshold = 26;
|
||
opts->ssize = 36;
|
||
opts->msize = 15;
|
||
opts->playfiles = 0;
|
||
opts->delay = 0;
|
||
opts->use_cosine_filter = 1;
|
||
opts->unmute_encrypted_p25 = 0;
|
||
opts->rtl_dev_index = 0; //choose which device we want by index number
|
||
opts->rtl_gain_value = 0; //set actual gain and not automatic gain
|
||
opts->rtl_squelch_level = 0; //fully open by default, want to specify level for things like NXDN with false positives
|
||
opts->rtl_volume_multiplier = 1; //set multipler from rtl sample to 'boost volume'
|
||
opts->rtl_udp_port = 6020; //set UDP port for RTL remote
|
||
opts->rtl_bandwidth = 12; //changed recommended default to 12, 24 for ProVoice
|
||
opts->pulse_raw_rate_in = 48000;
|
||
opts->pulse_raw_rate_out = 48000; //doing tests with 2 channels at 24000 for 48000 audio default in pulse
|
||
opts->pulse_digi_rate_in = 24000;
|
||
opts->pulse_digi_rate_out = 24000; //need to copy this to rtl type in and change rate out to 8000
|
||
opts->pulse_raw_in_channels = 1;
|
||
opts->pulse_raw_out_channels = 1;
|
||
opts->pulse_digi_in_channels = 2;
|
||
opts->pulse_digi_out_channels = 2;
|
||
|
||
opts->pulse_flush = 1; //set 0 to flush, 1 for flushed
|
||
opts->use_ncurses_terminal = 0; //ncurses terminal disabled by default, call with -N
|
||
}
|
||
|
||
void
|
||
initState (dsd_state * state)
|
||
{
|
||
|
||
int i, j;
|
||
|
||
state->dibit_buf = malloc (sizeof (int) * 1000000);
|
||
state->dibit_buf_p = state->dibit_buf + 200;
|
||
memset (state->dibit_buf, 0, sizeof (int) * 200);
|
||
state->repeat = 0;
|
||
state->audio_out_buf = malloc (sizeof (short) * 1000000);
|
||
memset (state->audio_out_buf, 0, 100 * sizeof (short));
|
||
state->audio_out_buf_p = state->audio_out_buf + 100;
|
||
state->audio_out_float_buf = malloc (sizeof (float) * 1000000);
|
||
memset (state->audio_out_float_buf, 0, 100 * sizeof (float));
|
||
state->audio_out_float_buf_p = state->audio_out_float_buf + 100;
|
||
state->audio_out_idx = 0;
|
||
state->audio_out_idx2 = 0;
|
||
state->audio_out_temp_buf_p = state->audio_out_temp_buf;
|
||
//state->wav_out_bytes = 0;
|
||
state->center = 0;
|
||
state->jitter = -1;
|
||
state->synctype = -1;
|
||
state->min = -15000;
|
||
state->max = 15000;
|
||
state->lmid = 0;
|
||
state->umid = 0;
|
||
state->minref = -12000;
|
||
state->maxref = 12000;
|
||
state->lastsample = 0;
|
||
for (i = 0; i < 128; i++)
|
||
{
|
||
state->sbuf[i] = 0;
|
||
}
|
||
state->sidx = 0;
|
||
for (i = 0; i < 1024; i++)
|
||
{
|
||
state->maxbuf[i] = 15000;
|
||
}
|
||
for (i = 0; i < 1024; i++)
|
||
{
|
||
state->minbuf[i] = -15000;
|
||
}
|
||
state->midx = 0;
|
||
state->err_str[0] = 0;
|
||
sprintf (state->fsubtype, " ");
|
||
sprintf (state->ftype, " ");
|
||
state->symbolcnt = 0;
|
||
state->rf_mod = 0;
|
||
state->numflips = 0;
|
||
state->lastsynctype = -1;
|
||
state->lastp25type = 0;
|
||
state->offset = 0;
|
||
state->carrier = 0;
|
||
for (i = 0; i < 25; i++)
|
||
{
|
||
for (j = 0; j < 16; j++)
|
||
{
|
||
state->tg[i][j] = 48;
|
||
}
|
||
}
|
||
state->tgcount = 0;
|
||
state->lasttg = 0;
|
||
state->lastsrc = 0;
|
||
state->nac = 0;
|
||
state->errs = 0;
|
||
state->errs2 = 0;
|
||
state->mbe_file_type = -1;
|
||
state->optind = 0;
|
||
state->numtdulc = 0;
|
||
state->firstframe = 0;
|
||
sprintf (state->slot0light, " slot0 ");
|
||
sprintf (state->slot1light, " slot1 ");
|
||
state->aout_gain = 25;
|
||
memset (state->aout_max_buf, 0, sizeof (float) * 200);
|
||
state->aout_max_buf_p = state->aout_max_buf;
|
||
state->aout_max_buf_idx = 0;
|
||
state->samplesPerSymbol = 10;
|
||
state->symbolCenter = 4;
|
||
sprintf (state->algid, "________");
|
||
sprintf (state->keyid, "________________");
|
||
state->currentslot = 0;
|
||
state->cur_mp = malloc (sizeof (mbe_parms));
|
||
state->prev_mp = malloc (sizeof (mbe_parms));
|
||
state->prev_mp_enhanced = malloc (sizeof (mbe_parms));
|
||
mbe_initMbeParms (state->cur_mp, state->prev_mp, state->prev_mp_enhanced);
|
||
state->p25kid = 0;
|
||
|
||
state->debug_audio_errors = 0;
|
||
state->debug_header_errors = 0;
|
||
state->debug_header_critical_errors = 0;
|
||
|
||
#ifdef TRACE_DSD
|
||
state->debug_sample_index = 0;
|
||
state->debug_label_file = NULL;
|
||
state->debug_label_dibit_file = NULL;
|
||
state->debug_label_imbe_file = NULL;
|
||
#endif
|
||
|
||
initialize_p25_heuristics(&state->p25_heuristics);
|
||
}
|
||
|
||
void
|
||
usage ()
|
||
{
|
||
fprintf (stderr, "Github Build Version: %s \n", GIT_TAG);
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Usage: dsd [options] Live scanner mode\n");
|
||
fprintf (stderr," or: dsd [options] -r <files> Read/Play saved mbe data from file(s)\n");
|
||
fprintf (stderr," or: dsd -h Show help\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Display Options:\n");
|
||
fprintf (stderr," -e Show Frame Info and errorbars (default)\n");
|
||
fprintf (stderr," -pe Show P25 encryption sync bits\n");
|
||
fprintf (stderr," -pl Show P25 link control bits\n");
|
||
fprintf (stderr," -ps Show P25 status bits and low speed data\n");
|
||
fprintf (stderr," -pt Show P25 talkgroup info\n");
|
||
fprintf (stderr," -q Don't show Frame Info/errorbars\n");
|
||
fprintf (stderr," -s Datascope (disables other display options)\n");
|
||
fprintf (stderr," -t Show symbol timing during sync\n");
|
||
fprintf (stderr," -v <num> Frame information Verbosity\n");
|
||
fprintf (stderr," -z <num> Frame rate for datascope\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Input/Output options:\n");
|
||
//fprintf (stderr," -i <device> Audio input device (default is /dev/audio, - for piped stdin, rtl for rtl device)\n");
|
||
fprintf (stderr," -i <device> Audio input device (default is pulse audio, - for piped stdin, rtl for rtl device)\n");
|
||
//fprintf (stderr," -o <device> Audio output device (default is /dev/audio)\n");
|
||
fprintf (stderr," -o <device> Audio output device (default is pulse audio)\n");
|
||
fprintf (stderr," -d <dir> Create mbe data files, use this directory\n");
|
||
fprintf (stderr," -r <files> Read/Play saved mbe data from file(s)\n");
|
||
fprintf (stderr," -g <num> Audio output gain (default = 0 = auto, disable = -1)\n");
|
||
fprintf (stderr," -n Do not send synthesized speech to audio output device\n");
|
||
fprintf (stderr," -w <file> Output synthesized speech to a .wav file\n");
|
||
fprintf (stderr," -a Display port audio devices\n");
|
||
fprintf (stderr," -W Monitor Source Audio When No Sync Detected (WIP!)\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"RTL-SDR options:\n");
|
||
fprintf (stderr," -c <hertz> RTL-SDR Frequency\n");
|
||
fprintf (stderr," -P <num> RTL-SDR PPM Error (default = 0)\n");
|
||
fprintf (stderr," -D <num> RTL-SDR Device Index Number\n");
|
||
fprintf (stderr," -G <num> RTL-SDR Device Gain (0-49) (default = 0 Auto Gain)\n");
|
||
fprintf (stderr," -L <num> RTL-SDR Squelch Level (0 - Open, 25 - Little, 50 - Higher)(Just have to guess really...)\n");
|
||
fprintf (stderr," -V <num> RTL-SDR Sample Gain Multiplier (default = 1)(1-3 recommended, still testing) \n");
|
||
fprintf (stderr," -Y <num> RTL-SDR VFO Bandwidth kHz (default = 48)(6, 8, 12, 16, 24, 48) \n");
|
||
fprintf (stderr," -U <num> RTL-SDR UDP Remote Port (default = 6020)\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Scanner control options:\n");
|
||
fprintf (stderr," -B <num> Serial port baud rate (default=115200)\n");
|
||
fprintf (stderr," -C <device> Serial port for scanner control (default=/dev/ttyUSB0)\n");
|
||
fprintf (stderr," -R <num> Resume scan after <num> TDULC frames or any PDU or TSDU\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Decoder options:\n");
|
||
fprintf (stderr," -fa Auto-detect frame type (default)\n");
|
||
fprintf (stderr," -f1 Decode only P25 Phase 1\n");
|
||
fprintf (stderr," -fd Decode only D-STAR\n");
|
||
fprintf (stderr," -fi Decode only NXDN48* (6.25 kHz) / IDAS*\n");
|
||
fprintf (stderr," -fn Decode only NXDN96* (12.5 kHz)\n");
|
||
fprintf (stderr," -fp Decode only ProVoice*\n");
|
||
fprintf (stderr," -fr Decode only DMR/MOTOTRBO\n");
|
||
fprintf (stderr," -fx Decode only X2-TDMA\n");
|
||
fprintf (stderr," -l Disable DMR/MOTOTRBO and NXDN input filtering\n");
|
||
fprintf (stderr," -ma Auto-select modulation optimizations (default)\n");
|
||
fprintf (stderr," -mc Use only C4FM modulation optimizations\n");
|
||
fprintf (stderr," -mg Use only GFSK modulation optimizations\n");
|
||
fprintf (stderr," -mq Use only QPSK modulation optimizations\n");
|
||
fprintf (stderr," -pu Unmute Encrypted P25\n");
|
||
fprintf (stderr," -u <num> Unvoiced speech quality (default=3)\n");
|
||
fprintf (stderr," -xx Expect non-inverted X2-TDMA signal\n");
|
||
fprintf (stderr," -xr Expect inverted DMR/MOTOTRBO signal\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr," * denotes frame types that cannot be auto-detected.\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Advanced decoder options:\n");
|
||
fprintf (stderr," -A <num> QPSK modulation auto detection threshold (default=26)\n");
|
||
fprintf (stderr," -S <num> Symbol buffer size for QPSK decision point tracking\n");
|
||
fprintf (stderr," (default=36)\n");
|
||
fprintf (stderr," -M <num> Min/Max buffer size for QPSK decision point tracking\n");
|
||
fprintf (stderr," (default=15)\n");
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Report bugs to: https://github.com/lwvmobile/dsd-fme/issues \n");
|
||
exit (0);
|
||
}
|
||
|
||
void
|
||
liveScanner (dsd_opts * opts, dsd_state * state)
|
||
{
|
||
//need to use this area to configure audio rates for different sources if not pulse
|
||
if (opts->audio_in_type == 1) //if stdin, switch to 8000 and single channel audio
|
||
{
|
||
opts->pulse_digi_rate_out = 8000; //stdin needs 8000 output, could have sworn this was working with 48000
|
||
opts->pulse_digi_out_channels = 1;
|
||
opts->pulse_raw_rate_out = 8000;
|
||
opts->pulse_raw_out_channels = 1;
|
||
fprintf (stderr, "STDIN Audio Rate Out set to 8000 Khz/1 Channel \n");
|
||
}
|
||
#ifdef USE_PORTAUDIO
|
||
if(opts->audio_in_type == 2)
|
||
{
|
||
PaError err = Pa_StartStream( opts->audio_in_pa_stream );
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while starting the portaudio input stream\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
return;
|
||
}
|
||
}
|
||
#endif
|
||
#ifdef USE_RTLSDR
|
||
if(opts->audio_in_type == 3)
|
||
{
|
||
opts->pulse_digi_rate_out = 8000; //if rtl, switch to 8000 and 1 channel
|
||
opts->pulse_digi_out_channels = 1;
|
||
opts->pulse_raw_rate_out = 8000;
|
||
opts->pulse_raw_out_channels = 1;
|
||
fprintf (stderr, "RTL Audio Rate Out set to 8000 Khz/1 Channel \n");
|
||
open_rtlsdr_stream(opts);
|
||
}
|
||
#endif
|
||
if (opts->audio_in_type == 0){
|
||
openPulseInput(opts);
|
||
}
|
||
if (opts->audio_out_type == 0){
|
||
openPulseOutput(opts);
|
||
}
|
||
//openPulse(opts);
|
||
|
||
while (1)
|
||
{
|
||
noCarrier (opts, state);
|
||
state->synctype = getFrameSync (opts, state);
|
||
// recalibrate center/umid/lmid
|
||
state->center = ((state->max) + (state->min)) / 2;
|
||
state->umid = (((state->max) - state->center) * 5 / 8) + state->center;
|
||
state->lmid = (((state->min) - state->center) * 5 / 8) + state->center;
|
||
while (state->synctype != -1)
|
||
{
|
||
processFrame (opts, state);
|
||
|
||
#ifdef TRACE_DSD
|
||
state->debug_prefix = 'S';
|
||
#endif
|
||
|
||
state->synctype = getFrameSync (opts, state);
|
||
|
||
#ifdef TRACE_DSD
|
||
state->debug_prefix = '\0';
|
||
#endif
|
||
|
||
// recalibrate center/umid/lmid
|
||
state->center = ((state->max) + (state->min)) / 2;
|
||
state->umid = (((state->max) - state->center) * 5 / 8) + state->center;
|
||
state->lmid = (((state->min) - state->center) * 5 / 8) + state->center;
|
||
}
|
||
}
|
||
}
|
||
|
||
void
|
||
cleanupAndExit (dsd_opts * opts, dsd_state * state)
|
||
{
|
||
noCarrier (opts, state);
|
||
if (opts->wav_out_f != NULL)
|
||
{
|
||
closeWavOutFile (opts, state);
|
||
}
|
||
|
||
#ifdef USE_PORTAUDIO
|
||
if((opts->audio_in_type == 2) || (opts->audio_out_type == 2))
|
||
{
|
||
fprintf (stderr,"Terminating portaudio.\n");
|
||
PaError err = paNoError;
|
||
if(opts->audio_in_pa_stream != NULL)
|
||
{
|
||
err = Pa_CloseStream( opts->audio_in_pa_stream );
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while closing the portaudio input stream\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
}
|
||
}
|
||
if(opts->audio_out_pa_stream != NULL)
|
||
{
|
||
err = Pa_IsStreamActive( opts->audio_out_pa_stream );
|
||
if(err == 1)
|
||
err = Pa_StopStream( opts->audio_out_pa_stream );
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while closing the portaudio output stream\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
}
|
||
err = Pa_CloseStream( opts->audio_out_pa_stream );
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while closing the portaudio output stream\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
}
|
||
}
|
||
err = Pa_Terminate();
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while terminating portaudio\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
}
|
||
}
|
||
#endif
|
||
|
||
#ifdef USE_RTLSDR
|
||
if(opts->audio_in_type == 3)
|
||
{
|
||
// TODO: cleanup demod threads
|
||
cleanup_rtlsdr_stream();
|
||
}
|
||
#endif
|
||
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"Total audio errors: %i\n", state->debug_audio_errors);
|
||
fprintf (stderr,"Total header errors: %i\n", state->debug_header_errors);
|
||
fprintf (stderr,"Total irrecoverable header errors: %i\n", state->debug_header_critical_errors);
|
||
|
||
//debug_print_heuristics(&(state->p25_heuristics));
|
||
|
||
fprintf (stderr,"\n");
|
||
fprintf (stderr,"+P25 BER estimate: %.2f%%\n", get_P25_BER_estimate(&state->p25_heuristics));
|
||
fprintf (stderr,"-P25 BER estimate: %.2f%%\n", get_P25_BER_estimate(&state->inv_p25_heuristics));
|
||
fprintf (stderr,"\n");
|
||
|
||
#ifdef TRACE_DSD
|
||
if (state->debug_label_file != NULL) {
|
||
fclose(state->debug_label_file);
|
||
state->debug_label_file = NULL;
|
||
}
|
||
if(state->debug_label_dibit_file != NULL) {
|
||
fclose(state->debug_label_dibit_file);
|
||
state->debug_label_dibit_file = NULL;
|
||
}
|
||
if(state->debug_label_imbe_file != NULL) {
|
||
fclose(state->debug_label_imbe_file);
|
||
state->debug_label_imbe_file = NULL;
|
||
}
|
||
#endif
|
||
|
||
fprintf (stderr,"Exiting.\n");
|
||
exit (0);
|
||
}
|
||
|
||
void
|
||
sigfun (int sig)
|
||
{
|
||
exitflag = 1;
|
||
signal (SIGINT, SIG_DFL);
|
||
#ifdef USE_RTLSDR
|
||
rtlsdr_sighandler();
|
||
#endif
|
||
}
|
||
|
||
double atofs(char *s)
|
||
{
|
||
char last;
|
||
int len;
|
||
double suff = 1.0;
|
||
len = strlen(s);
|
||
last = s[len-1];
|
||
s[len-1] = '\0';
|
||
switch (last) {
|
||
case 'g':
|
||
case 'G':
|
||
suff *= 1e3;
|
||
case 'm':
|
||
case 'M':
|
||
suff *= 1e3;
|
||
case 'k':
|
||
case 'K':
|
||
suff *= 1e3;
|
||
suff *= atof(s);
|
||
s[len-1] = last;
|
||
return suff;
|
||
}
|
||
s[len-1] = last;
|
||
return atof(s);
|
||
}
|
||
|
||
int
|
||
main (int argc, char **argv)
|
||
{
|
||
int c;
|
||
extern char *optarg;
|
||
extern int optind, opterr, optopt;
|
||
dsd_opts opts;
|
||
dsd_state state;
|
||
char versionstr[25];
|
||
mbe_printVersion (versionstr);
|
||
|
||
|
||
for (short int i = 0; i < 7; i++) {
|
||
fprintf (stderr,"%s%s \n", FM_banner[i], KCYN);
|
||
}
|
||
fprintf (stderr,"%s", KNRM); //change back to normal
|
||
fprintf (stderr, "%s \n", FM_banner[7]);
|
||
//pretty_colors();
|
||
//fprintf (stderr,"Digital Speech Decoder 1.7.0-dev (build:%s)\n", GIT_TAG);
|
||
fprintf (stderr,"Digital Speech Decoder: Florida Man Edition\n");
|
||
fprintf (stderr, "Github Build Version: %s \n", GIT_TAG);
|
||
fprintf (stderr,"mbelib version %s\n", versionstr);
|
||
|
||
initOpts (&opts);
|
||
initState (&state);
|
||
|
||
exitflag = 0;
|
||
signal (SIGINT, sigfun);
|
||
|
||
while ((c = getopt (argc, argv, "haep:P:qstv:z:i:o:d:c:g:nw:B:C:R:f:m:u:x:A:S:M:G:D:L:V:U:Y:NWrl")) != -1)
|
||
{
|
||
opterr = 0;
|
||
switch (c)
|
||
{
|
||
case 'h':
|
||
usage ();
|
||
exit (0);
|
||
case 'a':
|
||
printPortAudioDevices();
|
||
exit(0);
|
||
case 'e':
|
||
opts.errorbars = 1;
|
||
opts.datascope = 0;
|
||
break;
|
||
case 'p':
|
||
if (optarg[0] == 'e')
|
||
{
|
||
opts.p25enc = 1;
|
||
}
|
||
else if (optarg[0] == 'l')
|
||
{
|
||
opts.p25lc = 1;
|
||
}
|
||
else if (optarg[0] == 's')
|
||
{
|
||
opts.p25status = 1;
|
||
}
|
||
else if (optarg[0] == 't')
|
||
{
|
||
opts.p25tg = 1;
|
||
}
|
||
else if (optarg[0] == 'u')
|
||
{
|
||
opts.unmute_encrypted_p25 = 1;
|
||
}
|
||
break;
|
||
case 'P':
|
||
sscanf (optarg, "%i", &opts.rtlsdr_ppm_error);
|
||
break;
|
||
case 'q':
|
||
opts.errorbars = 0;
|
||
opts.verbose = 0;
|
||
break;
|
||
case 's':
|
||
opts.errorbars = 0;
|
||
opts.p25enc = 0;
|
||
opts.p25lc = 0;
|
||
opts.p25status = 0;
|
||
opts.p25tg = 0;
|
||
opts.datascope = 1;
|
||
opts.symboltiming = 0;
|
||
break;
|
||
case 't':
|
||
opts.symboltiming = 1;
|
||
opts.errorbars = 1;
|
||
opts.datascope = 0;
|
||
break;
|
||
case 'v':
|
||
sscanf (optarg, "%d", &opts.verbose);
|
||
break;
|
||
|
||
case 'G': //Set rtl device gain
|
||
sscanf (optarg, "%d", &opts.rtl_gain_value); //multiple value by ten to make it consitent with the way rtl_fm really works
|
||
break;
|
||
|
||
case 'L': //Set rtl squelch level
|
||
sscanf (optarg, "%d", &opts.rtl_squelch_level); //set squelch by user to prevent false positives on NXDN and others
|
||
break;
|
||
|
||
case 'V': //Set rtl squelch level
|
||
sscanf (optarg, "%d", &opts.rtl_volume_multiplier); //set 'volume' multiplier for rtl-sdr samples
|
||
break;
|
||
|
||
case 'U': //Set rtl squelch level
|
||
sscanf (optarg, "%d", &opts.rtl_udp_port); //set udp port number for RTL remote
|
||
break;
|
||
|
||
case 'D': //Set rtl device index number
|
||
sscanf (optarg, "%d", &opts.rtl_dev_index);
|
||
break;
|
||
|
||
case 'Y': //Set rtl VFO bandwidth --recommend 6, 12, 24, 36, 48, default 48? or 12?
|
||
sscanf (optarg, "%d", &opts.rtl_bandwidth);
|
||
break;
|
||
|
||
case 'W': //monitor_input_audio if no sync
|
||
opts.monitor_input_audio = 0;
|
||
//fprintf (stderr,"Monitor Source Audio Enabled (WIP!) Sounds bad.\n");
|
||
//fprintf (stderr,"Monitor Source Audio may cause decoding issues.\n");
|
||
fprintf (stderr,"Monitor Source Audio currently disabled in Pulse Audio Builds.\n");
|
||
break;
|
||
|
||
case 'N':
|
||
opts.use_ncurses_terminal = 1;
|
||
fprintf (stderr,"Enabling NCurses Terminal.\n");
|
||
break;
|
||
|
||
case 'z':
|
||
sscanf (optarg, "%d", &opts.scoperate);
|
||
opts.errorbars = 0;
|
||
opts.p25enc = 0;
|
||
opts.p25lc = 0;
|
||
opts.p25status = 0;
|
||
opts.p25tg = 0;
|
||
opts.datascope = 1;
|
||
opts.symboltiming = 0;
|
||
fprintf (stderr,"Setting datascope frame rate to %i frame per second.\n", opts.scoperate);
|
||
break;
|
||
case 'i':
|
||
strncpy(opts.audio_in_dev, optarg, 1023);
|
||
opts.audio_in_dev[1023] = '\0';
|
||
//fprintf (stderr,"audio_in_dev = %s\n", opts.audio_in_dev);
|
||
break;
|
||
case 'o':
|
||
strncpy(opts.audio_out_dev, optarg, 1023);
|
||
opts.audio_out_dev[1023] = '\0';
|
||
break;
|
||
case 'd':
|
||
strncpy(opts.mbe_out_dir, optarg, 1023);
|
||
opts.mbe_out_dir[1023] = '\0';
|
||
fprintf (stderr,"Writing mbe data files to directory %s\n", opts.mbe_out_dir);
|
||
break;
|
||
case 'c':
|
||
opts.rtlsdr_center_freq = (uint32_t)atofs(optarg);
|
||
fprintf (stderr,"Tuning to frequency: %i Hz\n", opts.rtlsdr_center_freq);
|
||
break;
|
||
case 'g':
|
||
sscanf (optarg, "%f", &opts.audio_gain);
|
||
if (opts.audio_gain < (float) 0 )
|
||
{
|
||
fprintf (stderr,"Disabling audio out gain setting\n");
|
||
}
|
||
else if (opts.audio_gain == (float) 0)
|
||
{
|
||
opts.audio_gain = (float) 0;
|
||
fprintf (stderr,"Enabling audio out auto-gain\n");
|
||
}
|
||
else
|
||
{
|
||
fprintf (stderr,"Setting audio out gain to %f\n", opts.audio_gain);
|
||
state.aout_gain = opts.audio_gain;
|
||
}
|
||
break;
|
||
case 'n':
|
||
opts.audio_out = 0;
|
||
fprintf (stderr,"Disabling audio output to soundcard.\n");
|
||
break;
|
||
case 'w':
|
||
strncpy(opts.wav_out_file, optarg, 1023);
|
||
opts.wav_out_file[1023] = '\0';
|
||
fprintf (stderr,"Writing audio to file %s\n", opts.wav_out_file);
|
||
openWavOutFile (&opts, &state);
|
||
break;
|
||
case 'B':
|
||
sscanf (optarg, "%d", &opts.serial_baud);
|
||
break;
|
||
case 'C':
|
||
strncpy(opts.serial_dev, optarg, 1023);
|
||
opts.serial_dev[1023] = '\0';
|
||
break;
|
||
case 'R':
|
||
sscanf (optarg, "%d", &opts.resume);
|
||
fprintf (stderr,"Enabling scan resume after %i TDULC frames\n", opts.resume);
|
||
break;
|
||
case 'f':
|
||
if (optarg[0] == 'a')
|
||
{
|
||
opts.frame_dstar = 1;
|
||
opts.frame_x2tdma = 1;
|
||
opts.frame_p25p1 = 1;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 1;
|
||
opts.frame_provoice = 0; //turn it on, doesn't work due to symbol rate difference
|
||
}
|
||
else if (optarg[0] == 'd')
|
||
{
|
||
opts.frame_dstar = 1;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 0;
|
||
fprintf (stderr,"Decoding only D-STAR frames.\n");
|
||
}
|
||
else if (optarg[0] == 'x')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 1;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 0;
|
||
fprintf (stderr,"Decoding only X2-TDMA frames.\n");
|
||
}
|
||
else if (optarg[0] == 'p')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 1;
|
||
state.samplesPerSymbol = 5;
|
||
state.symbolCenter = 2;
|
||
opts.mod_c4fm = 0;
|
||
opts.mod_qpsk = 0;
|
||
opts.mod_gfsk = 1;
|
||
state.rf_mod = 2;
|
||
fprintf (stderr,"Setting symbol rate to 9600 / second\n");
|
||
fprintf (stderr,"Enabling only GFSK modulation optimizations.\n");
|
||
fprintf (stderr,"Decoding only ProVoice frames.\n");
|
||
}
|
||
else if (optarg[0] == '1')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 1;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 0;
|
||
fprintf (stderr,"Decoding only P25 Phase 1 frames.\n");
|
||
}
|
||
else if (optarg[0] == 'i')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 1;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 0;
|
||
state.samplesPerSymbol = 20;
|
||
state.symbolCenter = 10;
|
||
opts.mod_c4fm = 0;
|
||
opts.mod_qpsk = 0;
|
||
opts.mod_gfsk = 1; //was 1 with others on zero
|
||
state.rf_mod = 2; //was 2
|
||
//opts.symboltiming = 2400; //NXDN48 uses 2400 symbol rate
|
||
fprintf (stderr,"Setting symbol rate to 2400 / second\n");
|
||
fprintf (stderr,"Decoding only NXDN 4800 baud frames.\n");
|
||
}
|
||
else if (optarg[0] == 'n')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 1;
|
||
opts.frame_dmr = 0;
|
||
opts.frame_provoice = 0;
|
||
opts.mod_c4fm = 0;
|
||
opts.mod_qpsk = 0;
|
||
opts.mod_gfsk = 1;
|
||
state.rf_mod = 2;
|
||
fprintf (stderr,"Enabling only GFSK modulation optimizations.\n");
|
||
fprintf (stderr,"Decoding only NXDN 9600 baud frames.\n");
|
||
}
|
||
else if (optarg[0] == 'r')
|
||
{
|
||
opts.frame_dstar = 0;
|
||
opts.frame_x2tdma = 0;
|
||
opts.frame_p25p1 = 0;
|
||
opts.frame_nxdn48 = 0;
|
||
opts.frame_nxdn96 = 0;
|
||
opts.frame_dmr = 1;
|
||
opts.frame_provoice = 0;
|
||
fprintf (stderr,"Decoding only DMR/MOTOTRBO frames.\n");
|
||
}
|
||
break;
|
||
case 'm':
|
||
if (optarg[0] == 'a')
|
||
{
|
||
opts.mod_c4fm = 1;
|
||
opts.mod_qpsk = 1;
|
||
opts.mod_gfsk = 1;
|
||
state.rf_mod = 0;
|
||
}
|
||
else if (optarg[0] == 'c')
|
||
{
|
||
opts.mod_c4fm = 1;
|
||
opts.mod_qpsk = 0;
|
||
opts.mod_gfsk = 0;
|
||
state.rf_mod = 0;
|
||
fprintf (stderr,"Enabling only C4FM modulation optimizations.\n");
|
||
}
|
||
else if (optarg[0] == 'g')
|
||
{
|
||
opts.mod_c4fm = 0;
|
||
opts.mod_qpsk = 0;
|
||
opts.mod_gfsk = 1;
|
||
state.rf_mod = 2;
|
||
fprintf (stderr,"Enabling only GFSK modulation optimizations.\n");
|
||
}
|
||
else if (optarg[0] == 'q')
|
||
{
|
||
opts.mod_c4fm = 0;
|
||
opts.mod_qpsk = 1;
|
||
opts.mod_gfsk = 0;
|
||
state.rf_mod = 1;
|
||
fprintf (stderr,"Enabling only QPSK modulation optimizations.\n");
|
||
}
|
||
break;
|
||
case 'u':
|
||
sscanf (optarg, "%i", &opts.uvquality);
|
||
if (opts.uvquality < 1)
|
||
{
|
||
opts.uvquality = 1;
|
||
}
|
||
else if (opts.uvquality > 64)
|
||
{
|
||
opts.uvquality = 64;
|
||
}
|
||
fprintf (stderr,"Setting unvoice speech quality to %i waves per band.\n", opts.uvquality);
|
||
break;
|
||
case 'x':
|
||
if (optarg[0] == 'x')
|
||
{
|
||
opts.inverted_x2tdma = 0;
|
||
fprintf (stderr,"Expecting non-inverted X2-TDMA signals.\n");
|
||
}
|
||
else if (optarg[0] == 'r')
|
||
{
|
||
opts.inverted_dmr = 1;
|
||
fprintf (stderr,"Expecting inverted DMR/MOTOTRBO signals.\n");
|
||
}
|
||
break;
|
||
case 'A':
|
||
sscanf (optarg, "%i", &opts.mod_threshold);
|
||
fprintf (stderr,"Setting C4FM/QPSK auto detection threshold to %i\n", opts.mod_threshold);
|
||
break;
|
||
case 'S':
|
||
sscanf (optarg, "%i", &opts.ssize);
|
||
if (opts.ssize > 128)
|
||
{
|
||
opts.ssize = 128;
|
||
}
|
||
else if (opts.ssize < 1)
|
||
{
|
||
opts.ssize = 1;
|
||
}
|
||
fprintf (stderr,"Setting QPSK symbol buffer to %i\n", opts.ssize);
|
||
break;
|
||
case 'M':
|
||
sscanf (optarg, "%i", &opts.msize);
|
||
if (opts.msize > 1024)
|
||
{
|
||
opts.msize = 1024;
|
||
}
|
||
else if (opts.msize < 1)
|
||
{
|
||
opts.msize = 1;
|
||
}
|
||
fprintf (stderr,"Setting QPSK Min/Max buffer to %i\n", opts.msize);
|
||
break;
|
||
case 'r':
|
||
opts.playfiles = 1;
|
||
opts.errorbars = 0;
|
||
opts.datascope = 0;
|
||
state.optind = optind;
|
||
break;
|
||
case 'l':
|
||
opts.use_cosine_filter = 0;
|
||
break;
|
||
default:
|
||
usage ();
|
||
exit (0);
|
||
}
|
||
}
|
||
|
||
if (opts.use_ncurses_terminal == 1)
|
||
{
|
||
ncursesOpen();
|
||
ncursesPrinter(&opts, &state);
|
||
}
|
||
|
||
if (opts.resume > 0)
|
||
{
|
||
openSerial (&opts, &state);
|
||
}
|
||
|
||
if((strncmp(opts.audio_in_dev, "pulse", 5) == 0))
|
||
{
|
||
opts.audio_in_type == 0;
|
||
}
|
||
|
||
if((strncmp(opts.audio_out_dev, "pulse", 5) == 0))
|
||
{
|
||
opts.audio_out_type == 0;
|
||
}
|
||
|
||
#ifdef USE_PORTAUDIO
|
||
if((strncmp(opts.audio_in_dev, "pa:", 3) == 0)
|
||
|| (strncmp(opts.audio_out_dev, "pa:", 3) == 0))
|
||
{
|
||
fprintf (stderr,"Initializing portaudio.\n");
|
||
PaError err = Pa_Initialize();
|
||
if( err != paNoError )
|
||
{
|
||
//fprintf (stderr, "An error occured while initializing portaudio\n" );
|
||
//fprintf (stderr, "Error number: %d\n", err );
|
||
//fprintf (stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
|
||
exit(err);
|
||
}
|
||
}
|
||
#endif
|
||
|
||
if (opts.playfiles == 1)
|
||
{
|
||
opts.split = 1;
|
||
opts.playoffset = 0;
|
||
opts.delay = 0;
|
||
if (strlen(opts.wav_out_file) > 0)
|
||
{
|
||
openWavOutFile (&opts, &state);
|
||
}
|
||
else
|
||
{
|
||
openAudioOutDevice (&opts, SAMPLE_RATE_OUT);
|
||
}
|
||
}
|
||
else if (strcmp (opts.audio_in_dev, opts.audio_out_dev) != 0)
|
||
{
|
||
opts.split = 1;
|
||
opts.playoffset = 0;
|
||
opts.delay = 0;
|
||
if (strlen(opts.wav_out_file) > 0)
|
||
{
|
||
openWavOutFile (&opts, &state);
|
||
}
|
||
else
|
||
{
|
||
openAudioOutDevice (&opts, SAMPLE_RATE_OUT);
|
||
}
|
||
openAudioInDevice (&opts);
|
||
|
||
|
||
fprintf (stderr,"Press CTRL + C twice to close.\n"); //Kindly remind user to double tap CTRL + C
|
||
}
|
||
|
||
else
|
||
{
|
||
opts.split = 0;
|
||
opts.playoffset = 25; // 38
|
||
opts.delay = 0;
|
||
openAudioInDevice (&opts); //disabled all four instances of openAudio devices, in and out for now
|
||
opts.audio_out_fd = opts.audio_in_fd;
|
||
}
|
||
|
||
if (opts.playfiles == 1)
|
||
{
|
||
opts.pulse_digi_rate_out = 8000; //need set to 8000 for amb/imb playback
|
||
opts.pulse_digi_out_channels = 1;
|
||
openPulseOutput(&opts); //need to open it up for output
|
||
playMbeFiles (&opts, &state, argc, argv);
|
||
}
|
||
|
||
else
|
||
{
|
||
liveScanner (&opts, &state);
|
||
}
|
||
if (opts.use_ncurses_terminal == 1){
|
||
ncursesClose ();
|
||
}
|
||
cleanupAndExit (&opts, &state);
|
||
|
||
return (0);
|
||
}
|