acars.c

/*
 *  Copyright (c) 2015 Thierry Leconte
 *
 *   
 *   This code is free software; you can redistribute it and/or modify
 *   it under the terms of the GNU Library General Public License version 2
 *   published by the Free Software Foundation.
 *
 *   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 Library General Public License for more details.
 *
 *
 */
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <math.h>
#include "acarsdec.h"

#define SYN 0x16
#define SOH 0x01
#define STX 0x02
#define ETX 0x83
#define ETB 0x97
#define DLE 0x7f

#include "syndrom.h"

static int fixprerr(msgblk_t * blk, const unsigned short crc, int *pr, int pn)
{
	int i;

	if (pn > 0) {
		/* try to recursievly fix parity error */
		for (i = 0; i < 8; i++) {
			if (fixprerr(blk, crc ^ syndrom[i + 8 * (blk->len - *pr + 1)], pr + 1, pn - 1)) {
				blk->txt[*pr] ^= (1 << i);
				return 1;
			}
		}
		return 0;
	} else {
		/* end of recursion : no more parity error */
		if (crc == 0)
			return 1;

		/* test remainding error in crc */
		for (i = 0; i < 2 * 8; i++)
			if (syndrom[i] == crc) {
				return 1;
			}
		return 0;
	}
}

static int fixdberr(msgblk_t * blk, const unsigned short crc)
{
	int i,j,k;

	/* test remainding error in crc */
	for (i = 0; i < 2 * 8; i++)
		if (syndrom[i] == crc) {
			return 1;
		}

	/* test double error in bytes */
	for (k = 0; k < blk->len ; k++) {
	  int bo=8*(blk->len-k+1);
	  for (i = 0; i < 8; i++)
	   for (j = 0; j < 8; j++) {
		   if(i==j) continue;
		   if((crc^syndrom[i+bo]^syndrom[j+bo])==0) {
			   blk->txt[k] ^= (1 << i);
			   blk->txt[k] ^= (1 << j);
			   return 1;
		   }
	   }
	}
	return 0;
}

#define MAXPERR 3
static void *blk_thread(void *arg)
{
	channel_t* ch = (channel_t*)arg;
	do {
		msgblk_t *blk;
		int i, pn;
		unsigned short crc;
		int pr[MAXPERR];

		pthread_mutex_lock(&ch->blkmtx);
		while ((ch->blkq_e == NULL)&&!ch->acars_shutdown)
			pthread_cond_wait(&ch->blkwcd, &ch->blkmtx);

		if (ch->acars_shutdown) {
			pthread_mutex_unlock(&ch->blkmtx);
			break;
		}
		blk = ch->blkq_e;
		ch->blkq_e = blk->prev;
		if (ch->blkq_e == NULL)
			ch->blkq_s = NULL;
		pthread_mutex_unlock(&ch->blkmtx);

		if (blk->len < 13) {
			if (verbose)
				fprintf(stderr, "#%d too short\n",
					blk->chn + 1);
			free(blk);
			continue;
		}

		/* force STX/ETX */
		blk->txt[12] &= (ETX | STX);
		blk->txt[12] |= (ETX & STX);

		/* parity check */
		pn = 0;
		for (i = 0; i < blk->len; i++) {
			if ((numbits[blk->txt[i]] & 1) == 0) {
				if (pn < MAXPERR) {
					pr[pn] = i;
				}
				pn++;
			}
		}
		if (pn > MAXPERR) {
			if (verbose)
				fprintf(stderr,
					"#%d too many parity errors: %d\n",
					blk->chn + 1, pn);
			free(blk);
			continue;
		}
		if (pn > 0 && verbose)
			fprintf(stderr, "#%d parity error(s): %d\n",
				blk->chn + 1, pn);
		blk->err = pn;

		/* crc check */
		crc = 0;
		for (i = 0; i < blk->len; i++) {
			update_crc(crc, blk->txt[i]);

		}
		update_crc(crc, blk->crc[0]);
		update_crc(crc, blk->crc[1]);
		if (crc && verbose)
			fprintf(stderr, "#%d crc error\n", blk->chn + 1);

		/* try to fix error */
		if(pn) {
		  if (fixprerr(blk, crc, pr, pn) == 0) {
			if (verbose)
				fprintf(stderr, "#%d not able to fix errors\n", blk->chn + 1);
			free(blk);
			continue;
		  }
			if (verbose)
				fprintf(stderr, "#%d errors fixed\n", blk->chn + 1);
		} else {
		

		  if (crc) {
			 if(fixdberr(blk, crc) == 0) {
				if (verbose)
					fprintf(stderr, "#%d not able to fix errors\n", blk->chn + 1);
				free(blk);
				continue;
		  	}
		  	if (verbose)
				fprintf(stderr, "#%d errors fixed\n", blk->chn + 1);
		  }
		}

		/* redo parity checking and removing */
		pn = 0;
		for (i = 0; i < blk->len; i++) {
			if ((numbits[blk->txt[i]] & 1) == 0) {
				pn++;
			}
			blk->txt[i] &= 0x7f;
		}
		if (pn) {
			fprintf(stderr, "#%d parity check problem\n",
				blk->chn + 1);
			free(blk);
			continue;
		}

		outputmsg(blk);

		free(blk);

	} while (1);
	return NULL;
}

int initAcars(channel_t * ch)
{
	ch->outbits = 0;
	ch->nbits = 8;
	ch->Acarsstate = WSYN;

	ch->blkq_s = NULL;
	ch->blkq_e = NULL;
	ch->acars_shutdown = 0;

	ch->blk = malloc(sizeof(msgblk_t));
	ch->blk->chn = ch->chn;

	pthread_mutex_init(&ch->blkmtx, NULL);
	pthread_cond_init(&ch->blkwcd, NULL);

	pthread_create(&ch->th, NULL, blk_thread, ch);

	return 0;
}

void decodeAcars(channel_t * ch)
{
	unsigned char r = ch->outbits;

	switch (ch->Acarsstate) {

	case WSYN:
		if (r == SYN) {
			ch->Acarsstate = SYN2;
			ch->nbits = 8;
			return;
		}
		if (r == (unsigned char)~SYN) {
			ch->MskS ^= 2;
			ch->Acarsstate = SYN2;
			ch->nbits = 8;
			return;
		}
		ch->nbits = 1;
		return;

	case SYN2:
		if (r == SYN) {
			ch->Acarsstate = SOH1;
			ch->nbits = 8;
			return;
		}
		if (r == (unsigned char)~SYN) {
			ch->MskS ^= 2;
			ch->nbits = 8;
			return;
		}
		ch->Acarsstate = WSYN;
		ch->MskDf = 0;
		ch->nbits = 1;
		return;

	case SOH1:
		if (r == SOH) {
			time(&(ch->blk->tm));
			ch->Acarsstate = TXT;
			ch->blk->len = 0;
			ch->blk->err = 0;
			ch->nbits = 8;
			ch->Msklvl = 0;
			return;
		}
		ch->Acarsstate = WSYN;
		ch->MskDf = 0;
		ch->nbits = 1;
		return;

	case TXT:
		ch->blk->txt[ch->blk->len] = r;
		ch->blk->len++;
		if ((numbits[r] & 1) == 0) {
			ch->blk->err++;

			if (ch->blk->err > MAXPERR + 1) {
				if (verbose)
					fprintf(stderr,
						"#%d too many parity errors\n",
						ch->chn + 1);
				ch->Acarsstate = WSYN;
				ch->MskDf = 0;
				ch->nbits = 1;
				return;
			}
		}
		if (r == ETX || r == ETB) {
			ch->Acarsstate = CRC1;
			ch->nbits = 8;
			return;
		}
		if (ch->blk->len > 20 && r == DLE) {
			if (verbose)
				fprintf(stderr, "#%d miss txt end\n",
					ch->chn + 1);
			ch->blk->len -= 3;
			ch->blk->crc[0] = ch->blk->txt[ch->blk->len];
			ch->blk->crc[1] = ch->blk->txt[ch->blk->len + 1];
			ch->Acarsstate = CRC2;
			goto putmsg_lbl;
		}
		if (ch->blk->len > 240) {
			if (verbose)
				fprintf(stderr, "#%d too long\n", ch->chn + 1);
			ch->Acarsstate = WSYN;
			ch->MskDf = 0;
			ch->nbits = 1;
			return;
		}
		ch->nbits = 8;
		return;

	case CRC1:
		ch->blk->crc[0] = r;
		ch->Acarsstate = CRC2;
		ch->nbits = 8;
		return;
	case CRC2:
		ch->blk->crc[1] = r;
 putmsg_lbl:
		ch->blk->lvl = 10*log10(ch->Msklvl);

		pthread_mutex_lock(&ch->blkmtx);
		ch->blk->prev = NULL;
		if (ch->blkq_s)
			ch->blkq_s->prev = ch->blk;
		ch->blkq_s = ch->blk;
		if (ch->blkq_e == NULL)
			ch->blkq_e = ch->blkq_s;
		pthread_cond_signal(&ch->blkwcd);
		pthread_mutex_unlock(&ch->blkmtx);

		ch->blk = malloc(sizeof(msgblk_t));
		ch->blk->chn = ch->chn;

		ch->Acarsstate = END;
		ch->nbits = 8;
		return;
	case END:
		ch->Acarsstate = WSYN;
		ch->MskDf = 0;
		ch->nbits = 8;
		return;
	}
}


int deinitAcars(channel_t * ch)
{
	pthread_mutex_lock(&ch->blkmtx);
	ch->acars_shutdown = 1;
	pthread_cond_signal(&ch->blkwcd);
	pthread_mutex_unlock(&ch->blkmtx);

	pthread_join(ch->th, NULL);

	return 0;
}