Function network_multicast_receiver_stop

src/network.c:1901–1952

* \brief Stop multicast receiver * * Stop multicast receiver * * \return RIG_OK or < 0 if error */

 * \return RIG_OK or < 0 if error
 */
int network_multicast_receiver_stop(RIG *rig)
{
    struct rig_state *rs = STATE(rig);
    multicast_receiver_priv_data *mcast_receiver_priv;

    ENTERFUNC;

    rs->multicast_receiver_run = 0;

    mcast_receiver_priv = (multicast_receiver_priv_data *)
                          rs->multicast_receiver_priv_data;

    if (mcast_receiver_priv == NULL)
    {
        RETURNFUNC(RIG_OK);
    }

    // Close the socket first to stop the routine
    if (mcast_receiver_priv->args.socket_fd >= 0)
    {
#ifdef __MINGW32__
        shutdown(mcast_receiver_priv->args.socket_fd, SD_BOTH);
#else
        shutdown(mcast_receiver_priv->args.socket_fd, SHUT_RDWR);
#endif
        close(mcast_receiver_priv->args.socket_fd);
    }

    if (mcast_receiver_priv->thread_id != 0)
    {
        int err = pthread_join(mcast_receiver_priv->thread_id, NULL);

        if (err)
        {
            rig_debug(RIG_DEBUG_ERR, "%s(%d): pthread_join error %s\n", __FILE__, __LINE__,
                      strerror(errno));
            // just ignore it
        }

        mcast_receiver_priv->thread_id = 0;
    }

    if (mcast_receiver_priv->args.socket_fd >= 0)
    {
        mcast_receiver_priv->args.socket_fd = -1;
    }

    free(rs->multicast_receiver_priv_data);
    rs->multicast_receiver_priv_data = NULL;

    RETURNFUNC(RIG_OK);
}

/** @} */