/* This is a small demo of the high-performance NetX Duo TCP/IP IPv4/IPv6 dual stack. This demo concentrates on TCP connection, disconnection, sending, and receiving 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_TCP_SOCKET client_socket; NX_TCP_SOCKET server_socket; 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 thread_1_connect_received(NX_TCP_SOCKET *server_socket, UINT port); void thread_1_disconnect_received(NX_TCP_SOCKET *server_socket); 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_global_address; NXD_ADDRESS ip1_secondary_global_address; #endif /* NX_DISABLE_IPV6 */ #ifndef NX_DISABLE_IPV4 #ifndef NX_DISABLE_IPV6 /* Define the number of TCP tests. If IPv6 is enabled, there are 4 tests: (1) TCP connection to the IPv4 address of the primary interface on ip_1; (2) TCP connection to the IPv4 address of the secondary interface on ip_1; (3) TCP connection to the IPv6 global address of the primary interface on ip_1; (4) TCP connection to the IPv6 global address of the secondary interface on ip_1; */ #define NUMBER_OF_TESTS 4 #else /* !NX_DISABLE_IPV6 */ /* Define the number of TCP tests. If IPv6 is enabled, there are 2 tests: (1) TCP connection to the IPv4 address of the primary interface on ip_1; (2) TCP connection 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 TCP tests. If IPv6 is enabled, there are 4 tests: (1) TCP connection to the IPv6 global address of the primary interface on ip_1; (2) TCP connection to the IPv6 global address of the secondary interface on ip_1; */ #define NUMBER_OF_TESTS 2 #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 TCP processing for both IP instances. */ status = nx_tcp_enable(&ip_0); status += nx_tcp_enable(&ip_1); if (status) { error_counter++; } } /* Define the test threads. */ void thread_0_entry(ULONG thread_input) { UINT status; NX_PACKET *my_packet; ULONG length; #ifndef NX_DISABLE_IPV6 NXD_ADDRESS ip_address; NXD_IPV6_ADDRESS *server_ipv6_ptr; #endif /* !NX_DISABLE_IPV6 */ NXD_ADDRESS peer_address; ULONG peer_port; 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 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 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); /* Loop to repeat things over and over again! */ while (1) { /* Create a socket. */ status = nx_tcp_socket_create(&ip_0, &client_socket, "Client Socket", NX_IP_NORMAL, NX_FRAGMENT_OKAY, NX_IP_TIME_TO_LIVE, 200, NX_NULL, NX_NULL); /* Check for error. */ if (status) { error_counter++; } /* Bind the socket. */ status = nx_tcp_client_socket_bind(&client_socket, 12, NX_WAIT_FOREVER); /* Check for error. */ if (status) { error_counter++; } /* Attempt to connect the socket. */ /* 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_tcp_client_socket_connect(&client_socket, &ip1_primary_ipv4_address, 12, NX_IP_PERIODIC_RATE); break; case 1: status = nxd_tcp_client_socket_connect(&client_socket, &ip1_secondary_ipv4_address, 12, NX_IP_PERIODIC_RATE); break; #ifndef NX_DISABLE_IPV6 case 2: status = nxd_tcp_client_socket_connect(&client_socket, &ip1_primary_global_address, 12, NX_IP_PERIODIC_RATE); break; case 3: status = nxd_tcp_client_socket_connect(&client_socket, &ip1_secondary_global_address, 12, NX_IP_PERIODIC_RATE); break; #endif /* !NX_DISABLE_IPV6 */ #else /* !NX_DISABLE_IPV4 */ #ifndef NX_DISABLE_IPV6 case 0: status = nxd_tcp_client_socket_connect(&client_socket, &ip1_primary_global_address, 12, NX_IP_PERIODIC_RATE); break; case 1: status = nxd_tcp_client_socket_connect(&client_socket, &ip1_secondary_global_address, 12, NX_IP_PERIODIC_RATE); break; #endif /* !NX_DISABLE_IPV6 */ #endif /* NX_DISABLE_IPV4 */ default: break; } /* Check for error. */ if (status) { printf("Error with socket connect: 0x%x\n", status); error_counter++; } status = nxd_tcp_socket_peer_info_get(&client_socket, &peer_address, &peer_port); /* Allocate a packet. */ status = nx_packet_allocate(&pool_0, &my_packet, NX_TCP_PACKET, NX_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); status = nx_packet_length_get(my_packet, &length); if ((status) || (length != sizeof(DEMO_DATA))) { error_counter++; } /* Send the packet out! */ status = nx_tcp_socket_send(&client_socket, my_packet, NX_IP_PERIODIC_RATE); /* Determine if the status is valid. */ if (status) { error_counter++; nx_packet_release(my_packet); } /* Disconnect this socket. */ status = nx_tcp_socket_disconnect(&client_socket, NX_IP_PERIODIC_RATE); /* Determine if the status is valid. */ if (status) { error_counter++; } /* Unbind the socket. */ status = nx_tcp_client_socket_unbind(&client_socket); /* Check for error. */ if (status) { error_counter++; } /* Delete the socket. */ status = nx_tcp_socket_delete(&client_socket); /* Check for error. */ if (status) { error_counter++; } /* Increment thread 0's counter. */ thread_0_counter++; } } void thread_1_entry(ULONG thread_input) { UINT status; NX_PACKET *packet_ptr; ULONG actual_status; NX_PARAMETER_NOT_USED(thread_input); #ifndef 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); #else /* !NX_DISABLE_IPV6 */ /* Wait 1 second for the IP thread to finish its initilization. */ tx_thread_sleep(NX_IP_PERIODIC_RATE); #endif /* !NX_DISABLE_IPV6 */ /* 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++; return; } /* Create a socket. */ status = nx_tcp_socket_create(&ip_1, &server_socket, "Server Socket", NX_IP_NORMAL, NX_FRAGMENT_OKAY, NX_IP_TIME_TO_LIVE, 100, NX_NULL, thread_1_disconnect_received); /* Check for error. */ if (status) { error_counter++; } /* Setup this thread to listen. */ status = nx_tcp_server_socket_listen(&ip_1, 12, &server_socket, 5, thread_1_connect_received); /* Check for error. */ if (status) { error_counter++; } /* Loop to create and establish server connections. */ while (1) { /* Increment thread 1's counter. */ thread_1_counter++; /* Accept a client socket connection. */ status = nx_tcp_server_socket_accept(&server_socket, NX_WAIT_FOREVER); /* Check for error. */ if (status) { error_counter++; } /* Receive a TCP message from the socket. */ status = nx_tcp_socket_receive(&server_socket, &packet_ptr, NX_IP_PERIODIC_RATE); /* Check for error. */ if (status) { error_counter++; } else { /* Release the packet. */ nx_packet_release(packet_ptr); } /* Disconnect the server socket. */ status = nx_tcp_socket_disconnect(&server_socket, NX_IP_PERIODIC_RATE); /* Check for error. */ if (status) { error_counter++; } /* Unaccept the server socket. */ status = nx_tcp_server_socket_unaccept(&server_socket); /* Check for error. */ if (status) { error_counter++; } /* Setup server socket for listening again. */ status = nx_tcp_server_socket_relisten(&ip_1, 12, &server_socket); /* Check for error. */ if (status) { error_counter++; } } } void thread_1_connect_received(NX_TCP_SOCKET *socket_ptr, UINT port) { /* Check for the proper socket and port. */ if ((socket_ptr != &server_socket) || (port != 12)) { error_counter++; } } void thread_1_disconnect_received(NX_TCP_SOCKET *socket) { /* Check for proper disconnected socket. */ if (socket != &server_socket) { error_counter++; } } #endif