demo_netx_duo_multihome_udp.c

/* This is a small demo of the high-performance NetX Duo TCP/IP
   IPv4/IPv6 dual stack.  This demo concentrates on UDP datagram
   send/receive in IPv4 and IPv6 network in a simulated Ethernet
   driver in a multihome environment.  */


/*
   IP_0 has two simulated phyiscal interfaces.
   The primary interface is 1.2.3.4/255.255.255.0
   the secondary interface is 2.2.3.4/255.255.255.0

   IP_1 has two simulated physical interface.
   The primary interface is 1.2.3.5/255.255.255.0
   the secondary interface is 2.2.3.5/255.255.255.0

   Each interface has an IPv6 link local address and
   an IPv6 global address.  The following table lists the IPv6
   configuration:

   IP_0 primary interface Link Local Address:  FE80::
   IP_0 primary interface Global Address:

   IP_0 secondary interface Link Local Address:  FE80::
   IP_0 secondary interface Global Address:

   IP_1 primary interface Link Local Address:  FE80::
   IP_1 primary interface Global Address:

   IP_1 secondary interface Link Local Address:  FE80::
   IP_1 secondary interface Global Address:





   These four simulated interfaces are connected to the same channel.



       ---------  Primary                         Primary   ---------
       |       |  Interface                       Interface |       |
       | IP_0  |----------------------     |----------------| IP_1  |
       |       | 1.2.3.4             |     |       1.2.3.5  |       |
       |       | 2001::4             |     |       2001::5  |       |
       |       |                     |     |                |       |
       |       |                     |     |                |       |
       |       |-------------------  |     |  --------------|       |
       |       | Secondary        |  |     |  |   Secondary |       |
       --------- Interface        |  |     |  |   Interface ---------
                 2.2.3.4          |  |     |  |     2.2.3.5
                 2002::4          |  |     |  |     2002::5
                               ------------------
                               |                |
                               |   Switch Box   |
                               |                |
                               ------------------


*/

#include   "tx_api.h"
#include   "nx_api.h"

#if (NX_MAX_PHYSICAL_INTERFACES > 1)

#define     DEMO_STACK_SIZE 2048
#define     DEMO_DATA       "ABCDEFGHIJKLMNOPQRSTUVWXYZ "
#define     PACKET_SIZE     1536
#define     POOL_SIZE       ((sizeof(NX_PACKET) + PACKET_SIZE) * 16)

/* Define the ThreadX and NetX object control blocks...  */

TX_THREAD               thread_0;
TX_THREAD               thread_1;

NX_PACKET_POOL          pool_0;
NX_IP                   ip_0;
NX_IP                   ip_1;

NX_UDP_SOCKET           socket_0;
NX_UDP_SOCKET           socket_1;
UCHAR                   pool_buffer[POOL_SIZE];



/* Define the counters used in the demo application...  */

ULONG                   thread_0_counter;
ULONG                   thread_1_counter;
ULONG                   error_counter;


/* Define thread prototypes.  */

void thread_0_entry(ULONG thread_input);
void thread_1_entry(ULONG thread_input);

void _nx_ram_network_driver(struct NX_IP_DRIVER_STRUCT *driver_req);


#define PRIMARY_INTERFACE   0
#define SECONDARY_INTERFACE 1

#ifndef NX_DISABLE_IPV4
NXD_ADDRESS ip1_primary_ipv4_address;
NXD_ADDRESS ip1_secondary_ipv4_address;
#endif /* NX_DISABLE_IPV4 */

#ifndef NX_DISABLE_IPV6

UINT ip0_primary_linklocal_address_index;
UINT ip0_primary_global_address_index;
UINT ip0_secondary_linklocal_address_index;
UINT ip0_secondary_global_address_index;

UINT ip1_primary_linklocal_address_index;
UINT ip1_primary_global_address_index;
UINT ip1_secondary_linklocal_address_index;
UINT ip1_secondary_global_address_index;


NXD_ADDRESS ip1_primary_linklocal_address;
NXD_ADDRESS ip1_primary_global_address;
NXD_ADDRESS ip1_secondary_linklocal_address;
NXD_ADDRESS ip1_secondary_global_address;
#endif /* NX_DISABLE_IPV6 */

#ifndef NX_DISABLE_IPV4

#ifndef NX_DISABLE_IPV6
/*
   Define the number of UDP tests.  If IPv6 is enabled, there are 6 tests:
   (1) UDP packet tranmisssion to the IPv4 address of the primary interface on ip_1;
   (2) UDP packet transmission to the IPv4 address of the secondary interface on ip_1;
   (3) UDP packet transmission to the IPv6 link local address of the primary interface on ip_1;
   (4) UDP packet transmission to the IPv6 link local address of the secondary interface on ip_1;
   (5) UDP packet transmission to the IPv6 global address of the primary interface on ip_1;
   (6) UDP packet transmission to the IPv6 global address of the secondary interface on ip_1;
*/
#define NUMBER_OF_TESTS 8


#else  /* !NX_DISABLE_IPV6 */
/*
   Define the number of UDP tests.  If IPv6 is enabled, there are 6 tests:
   (1) UDP packet tranmisssion to the IPv4 address of the primary interface on ip_1;
   (2) UDP packet transmission to the IPv4 address of the secondary interface on ip_1;

*/
#define NUMBER_OF_TESTS 2
#endif /* !NX_DISABLE_IPV6 */

#else  /* !NX_DISABLE_IPV4 */
/*
   Define the number of UDP tests.  If IPv6 is enabled, there are 6 tests:
   (1) UDP packet tranmisssion to the IPv4 address of the primary interface on ip_1;
   (2) UDP packet transmission to the IPv4 address of the secondary interface on ip_1;
   (3) UDP packet transmission to the IPv6 link local address of the primary interface on ip_1;
   (4) UDP packet transmission to the IPv6 link local address of the secondary interface on ip_1;
   (5) UDP packet transmission to the IPv6 global address of the primary interface on ip_1;
   (6) UDP packet transmission to the IPv6 global address of the secondary interface on ip_1;
*/
#define NUMBER_OF_TESTS 6
#endif /* !NX_DISABLE_IPV4 */

/* Define main entry point.  */

int main()
{

    /* Enter the ThreadX kernel.  */
    tx_kernel_enter();
}


/* Define what the initial system looks like.  */

void    tx_application_define(void *first_unused_memory)
{

CHAR *pointer;
UINT  status;


    /* Setup the working pointer.  */
    pointer =  (CHAR *)first_unused_memory;

    /* Create the main thread.  */
    tx_thread_create(&thread_0, "thread 0", thread_0_entry, 0,
                     pointer, DEMO_STACK_SIZE,
                     4, 4, TX_NO_TIME_SLICE, TX_AUTO_START);

    pointer =  pointer + DEMO_STACK_SIZE;

    /* Create the main thread.  */
    tx_thread_create(&thread_1, "thread 1", thread_1_entry, 0,
                     pointer, DEMO_STACK_SIZE,
                     3, 3, TX_NO_TIME_SLICE, TX_AUTO_START);

    pointer =  pointer + DEMO_STACK_SIZE;


    /* Initialize the NetX system.  */
    nx_system_initialize();

    /* Create a packet pool.  */
    status =  nx_packet_pool_create(&pool_0, "NetX Main Packet Pool", PACKET_SIZE, pool_buffer, POOL_SIZE);

    if (status)
    {
        error_counter++;
    }

    /* Create an IP instance.  */
    status = nx_ip_create(&ip_0, "NetX IP Instance 0", IP_ADDRESS(1, 2, 3, 4), 0xFFFFFF00UL, &pool_0, _nx_ram_network_driver,
                          pointer, 2048, 1);
    pointer =  pointer + 2048;

    /* Create another IP instance.  */
    status += nx_ip_create(&ip_1, "NetX IP Instance 1", IP_ADDRESS(1, 2, 3, 5), 0xFFFFFF00UL, &pool_0, _nx_ram_network_driver,
                           pointer, 2048, 1);
    pointer =  pointer + 2048;

    if (status)
    {
        error_counter++;
    }

#ifndef NX_DISABLE_IPV4
    /* Set the server IP address to ip_1 primary IPv4 address. */
    ip1_primary_ipv4_address.nxd_ip_version = NX_IP_VERSION_V4;
    ip1_primary_ipv4_address.nxd_ip_address.v4 = IP_ADDRESS(1, 2, 3, 5);
#endif /* NX_DISABLE_IPV4 */


    /* Attach the second interface to IP_0. Note that this interface is attached during initialization time.
       Alternatively the second interface may also be attached in thread context, as illustrated below
       in thead_0_entry function. */
    status = nx_ip_interface_attach(&ip_0, "IP_0 Secondary Interface", IP_ADDRESS(2, 2, 3, 4), 0xFFFFFF00, _nx_ram_network_driver);

    if (status)
    {
        error_counter++;
    }

#ifndef NX_DISABLE_IPV4
    /* Enable ARP and supply ARP cache memory for IP Instance 0.  */
    status =  nx_arp_enable(&ip_0, (void *)pointer, 1024);
    pointer = pointer + 1024;

    /* Enable ARP and supply ARP cache memory for IP Instance 1.  */
    status +=  nx_arp_enable(&ip_1, (void *)pointer, 1024);
    pointer = pointer + 1024;

    /* Check ARP enable status.  */
    if (status)
    {
        error_counter++;
    }
#endif /* NX_DISABLE_IPV4 */
#ifndef NX_DISABLE_IPV6

    /* Enable IPv6 */
    status = nxd_ipv6_enable(&ip_0);
    if (status)
    {
        error_counter++;
    }

    status = nxd_ipv6_enable(&ip_1);
    if (status)
    {
        error_counter++;
    }
#endif /* !NX_DISABLE_IPV6 */

    /* Enable ICMP */
    status = nxd_icmp_enable(&ip_0);
    if (status)
    {
        error_counter++;
    }

    status = nxd_icmp_enable(&ip_1);
    if (status)
    {
        error_counter++;
    }


    /* Enable UDP processing for both IP instances.  */
    status =  nx_udp_enable(&ip_0);
    status += nx_udp_enable(&ip_1);

    if (status)
    {
        error_counter++;
    }
}



/* Define the test threads.  */

void    thread_0_entry(ULONG thread_input)
{

UINT       status;
NX_PACKET *my_packet;


#ifndef NX_DISABLE_IPV6
NXD_ADDRESS       ip_address;
NXD_IPV6_ADDRESS *server_ipv6_ptr;
#endif /* !NX_DISABLE_IPV6 */

    NX_PARAMETER_NOT_USED(thread_input);

    /*
       At this point, IP_0 already has two interfaces attached during the system initialization phase.
       Here is a demonstration of attaching a secondary interface to an IP instance (ip_1 in this case)
       after the IP instance has been created and already started.
     */

    /*
       Attch the second interface to IP_1.  Note that this interface is attached in thread context.
       Alternatively the second interface may also be attached during system initilization, as illustrated
       above in tx_application_define.
     */

    /* Attach the 2nd interface to IP_1 */
    status = nx_ip_interface_attach(&ip_1, "IP_1 Secondary Interface", IP_ADDRESS(2, 2, 3, 5), 0xFFFFFF00, _nx_ram_network_driver);

    /* Check for error.  */
    if (status)
    {
        error_counter++;
    }


#ifndef NX_DISABLE_IPV4
    /* Set the server IP address to ip_1 primary IPv4 address. */
    ip1_secondary_ipv4_address.nxd_ip_version = NX_IP_VERSION_V4;
    ip1_secondary_ipv4_address.nxd_ip_address.v4 = IP_ADDRESS(2, 2, 3, 5);
#endif /* NX_DISABLE_IPV4 */

#ifndef NX_DISABLE_IPV6


    /* Set ip_0 primary link local address. */
    status = nxd_ipv6_address_set(&ip_0, PRIMARY_INTERFACE, NX_NULL, 10, &ip0_primary_linklocal_address_index);
    if (status)
    {
        error_counter++;
    }

    /* Set ip_1 primary link local address. */
    status = nxd_ipv6_address_set(&ip_1, PRIMARY_INTERFACE, NX_NULL, 10, &ip1_primary_linklocal_address_index);
    if (status)
    {
        error_counter++;
    }



    /* Set ip_0 primary interface global address. */
    ip_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip_address.nxd_ip_address.v6[0] = 0x20010000;
    ip_address.nxd_ip_address.v6[1] = 0;
    ip_address.nxd_ip_address.v6[2] = 0;
    ip_address.nxd_ip_address.v6[3] = 4;

    status = nxd_ipv6_address_set(&ip_0, PRIMARY_INTERFACE, &ip_address, 64, &ip0_primary_global_address_index);

    if (status)
    {
        error_counter++;
    }

    /* Set ip_1 primary interface global address. */
    ip_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip_address.nxd_ip_address.v6[0] = 0x20010000;
    ip_address.nxd_ip_address.v6[1] = 0;
    ip_address.nxd_ip_address.v6[2] = 0;
    ip_address.nxd_ip_address.v6[3] = 5;

    status = nxd_ipv6_address_set(&ip_1, PRIMARY_INTERFACE, &ip_address, 64, &ip1_primary_global_address_index);

    if (status)
    {
        error_counter++;
    }



    /* Set ip_0 secondary link local address. */
    status = nxd_ipv6_address_set(&ip_0, SECONDARY_INTERFACE, NX_NULL, 10, &ip0_secondary_linklocal_address_index);
    if (status)
    {
        error_counter++;
    }

    /* Set ip_1 secondary link local address. */
    status = nxd_ipv6_address_set(&ip_1, SECONDARY_INTERFACE, NX_NULL, 10, &ip1_secondary_linklocal_address_index);
    if (status)
    {
        error_counter++;
    }



    /* Set ip_0 secondary interface global address. */
    ip_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip_address.nxd_ip_address.v6[0] = 0x20020000;
    ip_address.nxd_ip_address.v6[1] = 0;
    ip_address.nxd_ip_address.v6[2] = 0;
    ip_address.nxd_ip_address.v6[3] = 4;

    status = nxd_ipv6_address_set(&ip_0, SECONDARY_INTERFACE, &ip_address, 64, &ip0_secondary_global_address_index);

    if (status)
    {
        error_counter++;
    }

    /* Set ip_1 primary interface global address. */
    ip_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip_address.nxd_ip_address.v6[0] = 0x20020000;
    ip_address.nxd_ip_address.v6[1] = 0;
    ip_address.nxd_ip_address.v6[2] = 0;
    ip_address.nxd_ip_address.v6[3] = 5;

    status = nxd_ipv6_address_set(&ip_1, SECONDARY_INTERFACE, &ip_address, 64, &ip1_secondary_global_address_index);

    if (status)
    {
        error_counter++;
    }

    /* Set the server IP address to ip_1 primary IPv6 link local address. */
    server_ipv6_ptr = &ip_1.nx_ipv6_address[ip1_primary_linklocal_address_index];
    ip1_primary_linklocal_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip1_primary_linklocal_address.nxd_ip_address.v6[0] = server_ipv6_ptr -> nxd_ipv6_address[0];
    ip1_primary_linklocal_address.nxd_ip_address.v6[1] = server_ipv6_ptr -> nxd_ipv6_address[1];
    ip1_primary_linklocal_address.nxd_ip_address.v6[2] = server_ipv6_ptr -> nxd_ipv6_address[2];
    ip1_primary_linklocal_address.nxd_ip_address.v6[3] = server_ipv6_ptr -> nxd_ipv6_address[3];

    /* Set the server IP address to ip_1 primary IPv6 global address. */
    server_ipv6_ptr = &ip_1.nx_ipv6_address[ip1_primary_global_address_index];
    ip1_primary_global_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip1_primary_global_address.nxd_ip_address.v6[0] = server_ipv6_ptr -> nxd_ipv6_address[0];
    ip1_primary_global_address.nxd_ip_address.v6[1] = server_ipv6_ptr -> nxd_ipv6_address[1];
    ip1_primary_global_address.nxd_ip_address.v6[2] = server_ipv6_ptr -> nxd_ipv6_address[2];
    ip1_primary_global_address.nxd_ip_address.v6[3] = server_ipv6_ptr -> nxd_ipv6_address[3];

    /* Set the server IP address to ip_1 secondary IPv6 link local address. */
    server_ipv6_ptr = &ip_1.nx_ipv6_address[ip1_secondary_linklocal_address_index];
    ip1_secondary_linklocal_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip1_secondary_linklocal_address.nxd_ip_address.v6[0] = server_ipv6_ptr -> nxd_ipv6_address[0];
    ip1_secondary_linklocal_address.nxd_ip_address.v6[1] = server_ipv6_ptr -> nxd_ipv6_address[1];
    ip1_secondary_linklocal_address.nxd_ip_address.v6[2] = server_ipv6_ptr -> nxd_ipv6_address[2];
    ip1_secondary_linklocal_address.nxd_ip_address.v6[3] = server_ipv6_ptr -> nxd_ipv6_address[3];

    /* Set the server IP address to ip_1 secondary IPv6 global address. */
    server_ipv6_ptr = &ip_1.nx_ipv6_address[ip1_secondary_global_address_index];
    ip1_secondary_global_address.nxd_ip_version = NX_IP_VERSION_V6;
    ip1_secondary_global_address.nxd_ip_address.v6[0] = server_ipv6_ptr -> nxd_ipv6_address[0];
    ip1_secondary_global_address.nxd_ip_address.v6[1] = server_ipv6_ptr -> nxd_ipv6_address[1];
    ip1_secondary_global_address.nxd_ip_address.v6[2] = server_ipv6_ptr -> nxd_ipv6_address[2];
    ip1_secondary_global_address.nxd_ip_address.v6[3] = server_ipv6_ptr -> nxd_ipv6_address[3];

#endif /* !NX_DISABLE_IPV6 */


    /* Wait 5 seconds for the IP thread to finish its initilization and
       for the IPv6 stack to finish DAD process. */
    tx_thread_sleep(5 * NX_IP_PERIODIC_RATE);

    /* Create a UDP socket.  */
    status = nx_udp_socket_create(&ip_0, &socket_0, "Socket 0", NX_IP_NORMAL, NX_FRAGMENT_OKAY, 0x80, 5);

    /* Check status.  */
    if (status)
    {
        error_counter++;
    }

    /* Bind the UDP socket to the IP port.  */
    status =  nx_udp_socket_bind(&socket_0, 0x88, TX_WAIT_FOREVER);

    /* Check status.  */
    if (status)
    {
        error_counter++;
    }


    /* Loop to repeat things over and over again!  */
    while (1)
    {


        /* Allocate a packet.  */
        status =  nx_packet_allocate(&pool_0, &my_packet, NX_UDP_PACKET, TX_WAIT_FOREVER);

        /* Check status.  */
        if (status != NX_SUCCESS)
        {
            break;
        }

        /* Write ABCs into the packet payload!  */
        nx_packet_data_append(my_packet, DEMO_DATA, sizeof(DEMO_DATA), &pool_0, TX_WAIT_FOREVER);

        /* Attempt to send the data. */
        /* In this demo, we alternate between IPv4 connections and IPv6 connections. */
        switch (thread_0_counter & (NUMBER_OF_TESTS - 1))
        {
#ifndef NX_DISABLE_IPV4
        case 0:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_primary_ipv4_address, 0x89, PRIMARY_INTERFACE);
            break;
        case 1:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_secondary_ipv4_address, 0x89, SECONDARY_INTERFACE);
            break;
#ifndef NX_DISABLE_IPV6
        case 2:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_primary_linklocal_address, 0x89, ip0_primary_linklocal_address_index);
            break;
        case 3:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_secondary_linklocal_address, 0x89, ip0_secondary_linklocal_address_index);
            break;
        case 4:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_primary_global_address, 0x89, ip0_primary_global_address_index);
            break;
        case 5:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_secondary_global_address, 0x89, ip0_secondary_global_address_index);
            break;
        case 6:
            status =  nxd_udp_socket_send(&socket_0, my_packet, &ip1_primary_global_address, 0x89);
            break;
        case 7:
            status =  nxd_udp_socket_send(&socket_0, my_packet, &ip1_secondary_global_address, 0x89);
            break;
#endif /* !NX_DISABLE_IPV6 */
#else /* !NX_DISABLE_IPV4  */
#ifndef NX_DISABLE_IPV6
        case 0:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_primary_linklocal_address, 0x89, ip0_primary_linklocal_address_index);
            break;
        case 1:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_secondary_linklocal_address, 0x89, ip0_secondary_linklocal_address_index);
            break;
        case 2:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_primary_global_address, 0x89, ip0_primary_global_address_index);
            break;
        case 3:
            status =  nxd_udp_socket_source_send(&socket_0, my_packet, &ip1_secondary_global_address, 0x89, ip0_secondary_global_address_index);
            break;
        case 4:
            status =  nxd_udp_socket_send(&socket_0, my_packet, &ip1_primary_global_address, 0x89);
            break;
        case 5:
            status =  nxd_udp_socket_send(&socket_0, my_packet, &ip1_secondary_global_address, 0x89);
            break;
#endif /* !NX_DISABLE_IPV6 */
#endif /* NX_DISABLE_IPV4 */
        default:
            break;
        }
        /* Check for error.  */
        if (status)
        {
            nx_packet_release(my_packet);
            error_counter++;
        }

        /* Increment thread 0's counter.  */
        thread_0_counter++;



        /* Relinquish to thread 1.  */
        tx_thread_relinquish();
    }
}


void    thread_1_entry(ULONG thread_input)
{

UINT       status;
NX_PACKET *my_packet;
ULONG      actual_status;

    NX_PARAMETER_NOT_USED(thread_input);

    /* Wait 5 seconds for the IP thread to finish its initilization and
       for the IPv6 stack to finish DAD process. */
    tx_thread_sleep(5 * NX_IP_PERIODIC_RATE);


    /* Ensure the IP instance has been initialized.  */
    status =  nx_ip_status_check(&ip_1, NX_IP_INITIALIZE_DONE, &actual_status, NX_IP_PERIODIC_RATE);

    /* Check status...  */
    if (status != NX_SUCCESS)
    {

        error_counter++;
    }



    /* Create a UDP socket.  */
    status = nx_udp_socket_create(&ip_1, &socket_1, "Socket 1", NX_IP_NORMAL, NX_FRAGMENT_OKAY, 0x80, 5);

    /* Check status.  */
    if (status)
    {
        error_counter++;
    }

    /* Bind the UDP socket to the IP port.  */
    status =  nx_udp_socket_bind(&socket_1, 0x89, TX_WAIT_FOREVER);

    /* Check status.  */
    if (status)
    {
        error_counter++;
    }

    /* Loop to create and establish server connections.  */
    while (1)
    {


        /* Receive a UDP packet.  */
        status =  nx_udp_socket_receive(&socket_1, &my_packet, TX_WAIT_FOREVER);

        /* Check status.  */
        if (status != NX_SUCCESS)
        {
            break;
        }

        /* Release the packet.  */
        status =  nx_packet_release(my_packet);

        /* Check status.  */
        if (status != NX_SUCCESS)
        {
            break;
        }

        /* Increment thread 1's counter.  */
        thread_1_counter++;
    }
}
#endif