Function morse_data_handler

src/rig.c:8751–8892

}

static void *morse_data_handler(void *arg)
{
    struct morse_data_handler_args_s *args =
        (struct morse_data_handler_args_s *) arg;
    RIG *rig = args->rig;
    const struct rig_state *rs = STATE(rig);
    int result;

    rig_debug(RIG_DEBUG_VERBOSE, "%s: Starting morse data handler thread\n",
              __func__);

    if (STATE(rig)->fifo_morse == NULL)
    {
        // Can't use rs-> 'cuz it's const
        STATE(rig)->fifo_morse = calloc(1, sizeof(FIFO_RIG));
    }

    initFIFO(rs->fifo_morse);

    char *c;
    int qsize = rig->caps->morse_qsize; // if backend overrides qsize

    if (qsize == 0) { qsize = 20; } // shortest length of any rig's CW morse capability

    c = calloc(1, qsize + 1);

    while (rs->morse_data_handler_thread_run || (hl_peek(rs->fifo_morse) >= 0))
    {
        int n = 0;
        memset(c, 0, qsize);

        for (n = 0; n < qsize; n++)
        {
            int d = hl_peek(rs->fifo_morse);

            if (d < 0)
            {
                break;
            }

            d = hl_pop(rs->fifo_morse);
            c[n] = (char) d;
        }

        if (n > 0)
        {
#if 0
// this does not work well at all -- rigs do not queue keyspd so any change is immediate
// don't know if we can ever implement this
            char *p;
            // if we have + or - we will adjust speed and send before/speed/after which hopefully works
            // I suspect some rigs will change speed immediately and not wait for queued character to flush
            morse_data_handler_priv_data *morse_data_handler_priv =
                (morse_data_handler_priv_data *) rs->morse_data_handler_priv_data;
            value_t keyspd;
            keyspd.i = morse_data_handler_priv->keyspd;
            rig_debug(RIG_DEBUG_VERBOSE, "%s(%d): keyspd=%d\n", __func__, __LINE__,
                      keyspd.i);