Mirrors/direwolf
1
0
Fork 0
mirror of https://agent.ghink.cloud/wb2osz/direwolf synced 2025-04-06 20:58:30 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity
direwolf/redecode.c
WB2OSZ 8978f2de6c Version 1.0 - Initial commit 
Changes to be committed:
	new file:   .gitattributes
	new file:   .gitignore
	new file:   APRStt-Implementation-Notes.pdf
	new file:   CHANGES.txt
	new file:   LICENSE-dire-wolf.txt
	new file:   LICENSE-other.txt
	new file:   Makefile.linux
	new file:   Makefile.win
	new file:   Quick-Start-Guide-Windows.pdf
	new file:   Raspberry-Pi-APRS.pdf
	new file:   User-Guide.pdf
	new file:   aclients.c
	new file:   aprs_tt.c
	new file:   aprs_tt.h
	new file:   atest.c
	new file:   audio.c
	new file:   audio.h
	new file:   audio_win.c
	new file:   ax25_pad.c
	new file:   ax25_pad.h
	new file:   beacon.c
	new file:   beacon.h
	new file:   config.c
	new file:   config.h
	new file:   decode_aprs.c
	new file:   decode_aprs.h
	new file:   dedupe.c
	new file:   dedupe.h
	new file:   demod.c
	new file:   demod.h
	new file:   demod_9600.c
	new file:   demod_9600.h
	new file:   demod_afsk.c
	new file:   demod_afsk.h
	new file:   digipeater.c
	new file:   digipeater.h
	new file:   direwolf.c
	new file:   direwolf.conf
	new file:   direwolf.desktop
	new file:   direwolf.h
	new file:   dsp.c
	new file:   dsp.h
	new file:   dtmf.c
	new file:   dtmf.h
	new file:   dw-icon.ico
	new file:   dw-icon.png
	new file:   dw-icon.rc
	new file:   dw-start.sh
	new file:   dwgps.c
	new file:   dwgps.h
	new file:   encode_aprs.c
	new file:   encode_aprs.h
	new file:   fcs_calc.c
	new file:   fcs_calc.h
	new file:   fsk_demod_agc.h
	new file:   fsk_demod_state.h
	new file:   fsk_filters.h
	new file:   fsk_gen_filter.h
	new file:   gen_packets.c
	new file:   gen_tone.c
	new file:   gen_tone.h
	new file:   hdlc_rec.c
	new file:   hdlc_rec.h
	new file:   hdlc_rec2.c
	new file:   hdlc_rec2.h
	new file:   hdlc_send.c
	new file:   hdlc_send.h
	new file:   igate.c
	new file:   igate.h
	new file:   kiss.c
	new file:   kiss.h
	new file:   kiss_frame.c
	new file:   kiss_frame.h
	new file:   kissnet.c
	new file:   kissnet.h
	new file:   latlong.c
	new file:   latlong.h
	new file:   ll2utm.c
	new file:   misc/README-dire-wolf.txt
	new file:   misc/strcasestr.c
	new file:   misc/strsep.c
	new file:   misc/strtok_r.c
	new file:   morse.c
	new file:   multi_modem.c
	new file:   multi_modem.h
	new file:   ptt.c
	new file:   ptt.h
	new file:   pttest.c
	new file:   rdq.c
	new file:   rdq.h
	new file:   redecode.c
	new file:   redecode.h
	new file:   regex/COPYING
	new file:   regex/INSTALL
	new file:   regex/LICENSES
	new file:   regex/NEWS
	new file:   regex/README
	new file:   regex/README-dire-wolf.txt
	new file:   regex/re_comp.h
	new file:   regex/regcomp.c
	new file:   regex/regex.c
	new file:   regex/regex.h
	new file:   regex/regex_internal.c
	new file:   regex/regex_internal.h
	new file:   regex/regexec.c
	new file:   rrbb.c
	new file:   rrbb.h
	new file:   server.c
	new file:   server.h
	new file:   symbols-new.txt
	new file:   symbols.c
	new file:   symbols.h
	new file:   symbolsX.txt
	new file:   textcolor.c
	new file:   textcolor.h
	new file:   tocalls.txt
	new file:   tq.c
	new file:   tq.h
	new file:   tt_text.c
	new file:   tt_text.h
	new file:   tt_user.c
	new file:   tt_user.h
	new file:   tune.h
	new file:   udp_test.c
	new file:   utm/LatLong-UTMconversion.c
	new file:   utm/LatLong-UTMconversion.h
	new file:   utm/README.txt
	new file:   utm/SwissGrid.cpp
	new file:   utm/UTMConversions.cpp
	new file:   utm/constants.h
	new file:   utm2ll.c
	new file:   version.h
	new file:   xmit.c
	new file:   xmit.h
2015-07-26 20:35:07 -04:00

253 lines
5.2 KiB
C
Raw Permalink Blame History

//
// This file is part of Dire Wolf, an amateur radio packet TNC.
//
// Copyright (C) 2011,2012,2013 John Langner, WB2OSZ
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 2 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
//
/*------------------------------------------------------------------
*
* Module: redecode.c
*
* Purpose: Retry decoding frames that have a bad FCS.
*
* Description:
*
*
* Usage: (1) The main application calls redecode_init.
*
* This will initialize the retry decoding queue
* and create a thread to work on contents of the queue.
*
* (2) The application queues up frames by calling rdq_append.
*
*
* (3) redecode_thread removes raw frames from the queue and
* tries to recover from errors.
*
*---------------------------------------------------------------*/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <assert.h>
#include <string.h>
//#include <sys/time.h>
#include <time.h>
#if __WIN32__
#include <windows.h>
#endif
#include "direwolf.h"
#include "ax25_pad.h"
#include "textcolor.h"
#include "audio.h"
#include "rdq.h"
#include "redecode.h"
#include "hdlc_send.h"
#include "hdlc_rec2.h"
#include "ptt.h"
#if __WIN32__
static unsigned redecode_thread (void *arg);
#else
static void * redecode_thread (void *arg);
#endif
/*-------------------------------------------------------------------
*
* Name: redecode_init
*
* Purpose: Initialize the process to try fixing bits in frames with bad FCS.
*
* Inputs: none.
*
* Outputs: none.
*
* Description: Initialize the queue to be empty and set up other
* mechanisms for sharing it between different threads.
*
* Start up redecode_thread to actually process the
* raw frames from the queue.
*
*--------------------------------------------------------------------*/
void redecode_init (void)
{
//int j;
#if __WIN32__
HANDLE redecode_th;
#else
pthread_t redecode_tid;
int e;
#endif
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_init ( ... )\n");
#endif
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_init: about to call rdq_init \n");
#endif
rdq_init ();
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_init: about to create thread \n");
#endif
#if __WIN32__
redecode_th = _beginthreadex (NULL, 0, redecode_thread, NULL, 0, NULL);
if (redecode_th == NULL) {
text_color_set(DW_COLOR_ERROR);
dw_printf ("Could not create redecode thread\n");
return;
}
#else
//TODO: Give thread lower priority.
e = pthread_create (&redecode_tid, NULL, redecode_thread, (void *)0);
if (e != 0) {
text_color_set(DW_COLOR_ERROR);
perror("Could not create redecode thread");
return;
}
#endif
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_init: finished \n");
#endif
} /* end redecode_init */
/*-------------------------------------------------------------------
*
* Name: redecode_thread
*
* Purpose: Try to decode frames with a bad FCS.
*
* Inputs: None.
*
* Outputs:
*
* Description: Initialize the queue to be empty and set up other
* mechanisms for sharing it between different threads.
*
*
*--------------------------------------------------------------------*/
#if __WIN32__
static unsigned redecode_thread (void *arg)
#else
static void * redecode_thread (void *arg)
#endif
{
rrbb_t block;
int blen;
int chan, subchan;
int alevel;
#if __WIN32__
HANDLE tid = GetCurrentThread();
//int tp;
//tp = GetThreadPriority (tid);
//text_color_set(DW_COLOR_DEBUG);
//dw_printf ("Starting redecode thread priority=%d\n", tp);
SetThreadPriority (tid, THREAD_PRIORITY_LOWEST);
//tp = GetThreadPriority (tid);
//dw_printf ("New redecode thread priority=%d\n", tp);
#endif
while (1) {
rdq_wait_while_empty ();
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_thread: woke up\n");
#endif
block = rdq_remove ();
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_thread: rdq_remove() returned %p\n", block);
#endif
/* Don't expect null ever but be safe. */
if (block != NULL) {
chan = rrbb_get_chan(block);
subchan = rrbb_get_subchan(block);
alevel = rrbb_get_audio_level(block);
blen = rrbb_get_len(block);
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_thread: begin processing %p, from channel %d, blen=%d\n", block, chan, blen);
#endif
hdlc_rec2_try_to_fix_later (block, chan, subchan, alevel);
#if DEBUG
text_color_set(DW_COLOR_DEBUG);
dw_printf ("redecode_thread: finished processing %p\n", block);
#endif
rrbb_delete (block);
}
}
return 0;
} /* end redecode_thread */
/* end redecode.c */
Reference in New Issue View Git Blame Copy Permalink