TMS320C6678: c6678 multicast Rx not working

Hi Jim,

I apologize for the inconvenience. I would like to give some clarification.

The "Multicast" project which was derived from the PDK source is a custom project. I intended to give information regarding the NIMU example client which uses the NDK library (Same as the "Multicast" project). This NIMU example project comes with the PDK.

I am working on the Multicast query that you have posted, and I am trying to give information about example projects in PDK that might help you.

Thanks

Rajarajan U

Hi James Conway,

char *MulticastAddr = "224.1.2.3"; // Multicast group address
struct ip_mreq mc_group; // Socket configuration structure for the multicast group membership
SOCKET recv = INVALID_SOCKET; // Receiver socket

mc_group.imr_multiaddr.s_addr = inet_addr(MulticastAddr);
mc_group.imr_interface.s_addr = NA.IPAddr;
setsockopt (recv, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&mc_group, sizeof(mc_group));

And the explanation for this has been given on (page 68) of the NDK 1.94 Programmer's Guide (SPRU524E) and on the NDK Wiki page (PDF).

/* Is it a standard ethernet type? */
if (protocol != ETHERTYPE_IP && protocol != ETHERTYPE_IPv6 && protocol != ETHERTYPE_VLAN
&& protocol != ETHERTYPE_PPPOECTL && protocol != ETHERTYPE_PPPOEDATA )
{
/* This is a raw packet, enqueue in Raw Rx Queue */
PBMQ_enq( &ptr_pvt_data->pdi.PBMQ_rawrx, (PBM_Handle) hPkt); //-------------- BUT IT ACTUALLY GOES HERE
}
else
{ /* This is a normal IP packet. Enqueue in Rx Queue */
PBMQ_enq( &ptr_pvt_data->pdi.PBMQ_rx, (PBM_Handle) hPkt );  // -------------- SETs BREAKPOINT HERE
}

The following URL, helped me

https://en.wikipedia.org/wiki/Internet_Protocol_version_4#Options

https://en.wikipedia.org/wiki/EtherType

Thanks & Regards,

Rajarajan U

Hi James,

Please refer to the Multicast test code which uses Multicast send and receive functions ("contest.c"),

/*---------------------------------------------------------------------- */
/* MulticastTest() */
/* Test the Multicast socket API. */
/*---------------------------------------------------------------------- */
static void MulticastTest (void)
{
    SOCKET          sudp1 = INVALID_SOCKET;
    SOCKET          sudp2 = INVALID_SOCKET;
    struct sockaddr_in sin1;
    char            buffer[1000];
    int             reuse = 1;
    struct ip_mreq  group;
    NDK_fd_set      msockets;
    int             iterations = 0;
    int             cnt;
    CI_IPNET        NA;

    ConPrintf ("=== Executing Multicast Test on Interface 1 ===\n");

    /* Create our UDP Multicast socket1 */
    sudp1 = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if( sudp1 == INVALID_SOCKET )
    {
        ConPrintf ("Error: Unable to create socket\n");
        return;
    }

    /* Create our UDP Multicast socket1 */
    sudp2 = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if( sudp2 == INVALID_SOCKET )
    {
        ConPrintf ("Error: Unable to create socket\n");
        return;
    }

    /* Set Port = 4040, leaving IP address = Any */
    memset( &sin1, 0, sizeof(struct sockaddr_in) );
    sin1.sin_family = AF_INET;
    sin1.sin_port   = NDK_htons(4040);

    /* Print the IP address information only if one is present. */
    if (CfgGetImmediate( 0, CFGTAG_IPNET, 1, 1, sizeof(NA), (unsigned char *)&NA) != sizeof(NA))
    {
        ConPrintf ("Error: Unable to get IP Address Information\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }

    /* Set the Reuse Ports Socket Option for both the sockets.  */
    if (setsockopt(sudp1, SOL_SOCKET, SO_REUSEPORT, (char *)&reuse, sizeof(reuse)) < 0)
    {
        ConPrintf ("Error: Unable to set the reuse port socket option\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    /* Reuse the ports; since multiple multicast clients will be executing. */
    if (setsockopt(sudp2, SOL_SOCKET, SO_REUSEPORT, (char *)&reuse, sizeof(reuse)) < 0)
    {
        ConPrintf ("Error: Unable to set the reuse port socket option\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }

    /* Now bind both the sockets. */
    if (bind (sudp1, (struct sockaddr *) &sin1, sizeof(sin1)) < 0)
    {
        ConPrintf ("Error: Unable to bind the socket.\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    if (bind (sudp2, (struct sockaddr *) &sin1, sizeof(sin1)) < 0)
    {
        ConPrintf ("Error: Unable to bind the socket.\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }

    /* Now we join the groups for socket1
     *  Group: 224.1.2.4
     *  Group: 224.1.2.5 */
    group.imr_multiaddr.s_addr = inet_addr("224.1.2.4");
    group.imr_interface.s_addr = NA.IPAddr;
    if (setsockopt (sudp1, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&group, sizeof(group)) < 0)
    {
        ConPrintf ("Error: Unable to join multicast group\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    group.imr_multiaddr.s_addr = inet_addr("224.1.2.5");
    group.imr_interface.s_addr = NA.IPAddr;
    if (setsockopt (sudp1, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&group, sizeof(group)) < 0)
    {
        ConPrintf ("Error: Unable to join multicast group\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    ConPrintf ("-----------------------------------------\n");
    ConPrintf ("Socket Identifier %d has joined the following:-\n", sudp1);
    ConPrintf (" - Group 224.1.2.4\n");
    ConPrintf (" - Group 224.1.2.5\n");
    ConPrintf ("-----------------------------------------\n");

    /* Now we join the groups for socket2
     *  Group: 224.1.2.5
     *  Group: 224.1.2.6 */
    group.imr_multiaddr.s_addr = inet_addr("224.1.2.5");
    group.imr_interface.s_addr = NA.IPAddr;
    if (setsockopt (sudp2, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&group, sizeof(group)) < 0)
    {
        ConPrintf ("Error: Unable to join multicast group\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    group.imr_multiaddr.s_addr = inet_addr("224.1.2.6");
    group.imr_interface.s_addr = NA.IPAddr;
    if (setsockopt (sudp2, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&group, sizeof(group)) < 0)
    {
        ConPrintf ("Error: Unable to join multicast group\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }
    ConPrintf ("-----------------------------------------\n");
    ConPrintf ("Socket Identifier %d has joined the following:-\n", sudp2);
    ConPrintf (" - Group 224.1.2.5\n");
    ConPrintf (" - Group 224.1.2.6\n");
    ConPrintf ("-----------------------------------------\n");

    while (iterations < 4)
    {
        /* Initialize the FD Set. */
        NDK_FD_ZERO(&msockets);
        NDK_FD_SET(sudp1, &msockets);
        NDK_FD_SET(sudp2, &msockets);

        /* Wait for the multicast packets to arrive. */
        /* fdSelect 1st arg is a don't care, pass 0 64-bit compatibility */
        cnt = fdSelect( 0, &msockets, 0, 0 , 0);

        if(NDK_FD_ISSET(sudp1, &msockets))
        {
            cnt = (int)recv (sudp1, (void *)&buffer, sizeof(buffer), 0);
            if( cnt >= 0 )
                ConPrintf ("Socket Identifier %d received %d bytes of multicast data\n", sudp1, cnt);
            else
                ConPrintf ("Error: Unable to receive data\n");

            /* Increment the iterations. */
            iterations++;
        }
        if(NDK_FD_ISSET(sudp2, &msockets))
        {
            cnt = (int)recv (sudp2, (void *)&buffer, sizeof(buffer), 0);
            if( cnt >= 0 )
                ConPrintf ("Socket Identifier %d received %d bytes of multicast data\n", sudp2, cnt);
            else
                ConPrintf ("Error: Unable to receive data\n");

            /* Increment the iterations. */
            iterations++;
        }
    }

    /* Once the packet has been received. Leave the Multicast group! */
    if (setsockopt (sudp2, IPPROTO_IP, IP_DROP_MEMBERSHIP, (void *)&group, sizeof(group)) < 0)
    {
        ConPrintf ("Error: Unable to leave multicast group\n");
        fdClose (sudp1);
        fdClose (sudp2);
        return;
    }

    /* Leave only one of the multicast groups through the proper API. */
    NtIPN2Str (group.imr_multiaddr.s_addr, &buffer[0]);
    ConPrintf ("Leaving group %s through IP_DROP_MEMBERSHIP\n", buffer);

    /* Once we get out of the loop close socket2; this should internally leave all the groups. */
    fdClose (sudp1);
    fdClose (sudp2);
    ConPrintf("== End Multicast Test ==\n\n");
}

 The File is located in "C:\ti\ndk_3_61_01_01\packages\ti\ndk\tools\console".

Further NDK API reference for Multicast has been mentioned in the API guide, NDK API guide. Using "NDK_setsockopt()" we can set the option as "SO_REUSEPORT" for UDP Multicast send and receive. Please use "NDK_recvfrom()" (NDK API function) to receive multicast and triggered by Interrupt.

Also, There is an option to enable Multicast replies on,

1. Icmp.xml 

       /*!
        *  Enable or disable replies to multicast.
        *  
        *  When enabled, the stack *does not* reply to ICMP echo request packets
        *  sent to multicast addresses.
        */ 
       config Bool icmpDontReplyToMcast = defaultIcmpMcastReply;

2. Ip.xdc 

   <tr>
            <td colspan="2"><control type="checkbox" 
                label="Disable multicast replies"
                value="value:ti.ndk.config.Ip.icmpDontReplyToMcast" 
                tooltip="value:ti.ndk.config.Ip.icmpDontReplyToMcast.$summary"/></td>
         </tr>

Files are located in the "C:\ti\ndk_3_61_01_01\packages\ti\ndk\config" folder. There as no Multicast example project available in Processor SDK, Please try these examples and provide your feedback.

Thanks,

Rajarajan U

The path of the PA unit test example project after installing Processor SDK (https://www.ti.com/tool/PROCESSOR-SDK-C667X) and generating the PDK example (https://e2e.ti.com/support/processors-group/processors/f/processors-forum/1082251/faq-tms320c6678-how-to-generate-the-ccs-pdk-examples-for-c6678).