Function network_multicast_receiver_start

src/network.c:1790–1892

* \brief Start multicast receiver * * Start multicast receiver. * * \param multicast_addr UDP address * \param multicast_port UDP socket port * \return RIG_OK or < 0 if error */

 * \return RIG_OK or < 0 if error
 */
int network_multicast_receiver_start(RIG *rig, const char *multicast_addr,
                                     int multicast_port)
{
    struct rig_state *rs = STATE(rig);
    multicast_receiver_priv_data *mcast_receiver_priv;
    int socket_fd;
    int status;

    ENTERFUNC;

    if (rs->multicast_receiver_priv_data != NULL)
    {
        rig_debug(RIG_DEBUG_ERR, "%s(%d): multicast receiver already running\n",
                  __FILE__,
                  __LINE__);
        RETURNFUNC(-RIG_EINVAL);
    }

    rig_debug(RIG_DEBUG_VERBOSE, "%s(%d): multicast receiver address=%s, port=%d\n",
              __FILE__,
              __LINE__,
              multicast_addr, multicast_port);

    if (multicast_addr == NULL || strcmp(multicast_addr, "0.0.0.0") == 0)
    {
        rig_debug(RIG_DEBUG_TRACE, "%s(%d): not starting multicast receiver\n",
                  __FILE__, __LINE__);
        RETURNFUNC(RIG_OK);
    }

    status = network_init();

    if (status != RIG_OK)
    {
        RETURNFUNC(status);
    }

    socket_fd = socket(AF_INET, SOCK_DGRAM, 0);

    if (socket_fd < 0)
    {
        rig_debug(RIG_DEBUG_ERR, "%s: error opening new UDP socket: %s", __func__,
                  strerror(errno));
        RETURNFUNC(-RIG_EIO);
    }

    // Enable non-blocking mode
    u_long mode = 1;
#ifdef __MINGW32__

    if (ioctlsocket(socket_fd, FIONBIO, &mode) == SOCKET_ERROR)
    {
        rig_debug(RIG_DEBUG_ERR, "%s: error enabling non-blocking mode for socket: %s",
                  __func__,
                  strerror(errno));
        RETURNFUNC(-RIG_EIO);
    }