Rename FIFO to FIFO_RIG to avoid collision with freedv FIFO

pull/1332/head
Mike Black W9MDB 2023-07-10 06:57:11 -05:00
rodzic 04c65d9d7e
commit fdc074e1b8
4 zmienionych plików z 21 dodań i 21 usunięć

Wyświetl plik

@ -137,7 +137,7 @@ typedef struct
int head;
int tail;
int flush; // flush flag for stop_morse
} FIFO;
} FIFO_RIG;
/**
@ -2694,7 +2694,7 @@ struct rig_state {
int spectrum_attenuator[HAMLIB_MAXDBLSTSIZ]; /*!< Spectrum attenuator list in dB, 0 terminated */
volatile int morse_data_handler_thread_run;
void *morse_data_handler_priv_data;
FIFO *fifo;
FIFO_RIG *fifo_morse;
};
/**

Wyświetl plik

@ -3,13 +3,13 @@
#include "fifo.h"
void initFIFO(FIFO *fifo)
void initFIFO(FIFO_RIG *fifo)
{
fifo->head = 0;
fifo->tail = 0;
}
void resetFIFO(FIFO *fifo)
void resetFIFO(FIFO_RIG *fifo)
{
fifo->head = fifo->tail;
fifo->flush = 1;
@ -17,7 +17,7 @@ void resetFIFO(FIFO *fifo)
// returns RIG_OK if added
// return -RIG error if overflow
int push(FIFO *fifo, const char *msg)
int push(FIFO_RIG *fifo, const char *msg)
{
int len = strlen(msg);
@ -35,7 +35,7 @@ int push(FIFO *fifo, const char *msg)
return RIG_OK;
}
char pop(FIFO *fifo)
char pop(FIFO_RIG *fifo)
{
if (fifo->tail == fifo->head) { return -1; }
@ -49,7 +49,7 @@ char pop(FIFO *fifo)
#ifdef TEST
int main()
{
FIFO fifo;
FIFO_RIG fifo;
initFIFO(&fifo);
const char *str = "Hello, World!\n";

Wyświetl plik

@ -1,4 +1,4 @@
void initFIFO(FIFO *fifo);
void resetFIFO(FIFO *fifo);
int push(FIFO *fifo, const char *msg);
char pop(FIFO *fifo);
void initFIFO(FIFO_RIG *fifo);
void resetFIFO(FIFO_RIG *fifo);
int push(FIFO_RIG *fifo, const char *msg);
char pop(FIFO_RIG *fifo);

Wyświetl plik

@ -250,7 +250,7 @@ typedef struct morse_data_handler_priv_data_s
{
pthread_t thread_id;
morse_data_handler_args args;
FIFO fifo;
FIFO_RIG fifo_morse;
} morse_data_handler_priv_data;
static int morse_data_handler_start(RIG *rig);
@ -6848,7 +6848,7 @@ int HAMLIB_API rig_send_morse(RIG *rig, vfo_t vfo, const char *msg)
retcode = caps->send_morse(rig, vfo, msg);
LOCK(0);
#endif
push(rig->state.fifo, msg);
push(rig->state.fifo_morse, msg);
RETURNFUNC(RIG_OK);
}
@ -6912,7 +6912,7 @@ int HAMLIB_API rig_stop_morse(RIG *rig, vfo_t vfo)
RETURNFUNC(-RIG_ENAVAIL);
}
resetFIFO(rig->state.fifo); // clear out the CW queue
resetFIFO(rig->state.fifo_morse); // clear out the CW queue
if (vfo == RIG_VFO_CURR
|| vfo == rig->state.current_vfo)
{
@ -7988,16 +7988,16 @@ void *morse_data_handler(void *arg)
rig_debug(RIG_DEBUG_VERBOSE, "%s: Starting morse data handler thread\n",
__func__);
if (rig->state.fifo == NULL) rig->state.fifo = calloc(1,sizeof(FIFO));
initFIFO(rig->state.fifo);
if (rig->state.fifo_morse == NULL) rig->state.fifo_morse = calloc(1,sizeof(FIFO_RIG));
initFIFO(rig->state.fifo_morse);
while (rs->morse_data_handler_thread_run)
{
char c[11]; // up to 10 chars to be sent
memset(c,0,sizeof(c));
int n=0;
for(n=0;n<sizeof(c)-1 && (c[n]=pop(rig->state.fifo))!=-1;++n);
for(n=0;n<sizeof(c)-1 && (c[n]=pop(rig->state.fifo_morse))!=-1;++n);
//while((c[0]=pop(rig->state.fifo))!=-1)
//while((c[0]=pop(rig->state.fifo_morse))!=-1)
if (n > 0)
{
do
@ -8008,11 +8008,11 @@ void *morse_data_handler(void *arg)
rig_debug(RIG_DEBUG_ERR, "%s: error: %s\n", __func__, rigerror(result));
hl_usleep(100*1000);
}
} while (result != RIG_OK && rig->state.fifo->flush==0);
} while (result != RIG_OK && rig->state.fifo_morse->flush==0);
}
rig->state.fifo->flush = 0; // reset flush flag
rig->state.fifo_morse->flush = 0; // reset flush flag
}
free(rig->state.fifo);
free(rig->state.fifo_morse);
pthread_exit(NULL);
return NULL;
}