Function morse_data_handler_stop

src/rig.c:8603–8655

}

static int morse_data_handler_stop(RIG *rig)
{
    struct rig_state *rs = STATE(rig);
    morse_data_handler_priv_data *morse_data_handler_priv;

    ENTERFUNC;

    rs->morse_data_handler_thread_run = 0;

    morse_data_handler_priv = (morse_data_handler_priv_data *)
                              rs->morse_data_handler_priv_data;

    // wait until fifo queue is flushed
    //HAMLIB_TRACE;
    hl_usleep(100 * 1000);

    //HAMLIB_TRACE;
    while (hl_peek(rs->fifo_morse) >= 0)
    {
        HAMLIB_TRACE;
        rig_debug(RIG_DEBUG_TRACE, "%s: waiting for fifo queue to flush\n", __func__);
        hl_usleep(100 * 1000);
    }

    //HAMLIB_TRACE;
    hl_usleep(100 * 1000);

    //HAMLIB_TRACE;
    if (morse_data_handler_priv != NULL)
    {
        if (morse_data_handler_priv->thread_id != 0)
        {
            // all cleanup is done in this function so we can kill thread
            // Windows was taking 30 seconds to stop without this
            pthread_cancel(morse_data_handler_priv->thread_id);
            int err = pthread_join(morse_data_handler_priv->thread_id, NULL);

            if (err)
            {
                rig_debug(RIG_DEBUG_ERR, "%s: pthread_join error: %s\n", __func__,
                          strerror(errno));
                // just ignore the error
            }

            morse_data_handler_priv->thread_id = 0;
        }

        free(rs->morse_data_handler_priv_data);
        rs->morse_data_handler_priv_data = NULL;
    }

    RETURNFUNC(RIG_OK);
}

static void *async_data_handler(void *arg)
{