#include "tx_api.h" #include "nx_api.h" #include "netxtestcontrol.h" extern void test_control_return(UINT); #if !defined(NX_DISABLE_IPV4) && defined(__PRODUCT_NETXDUO__) && !defined(NX_DISABLE_PACKET_CHAIN) #include "nx_rtp_sender.h" #define DEMO_STACK_SIZE 4096 #define NUM_PACKETS 24 #define PACKET_SIZE 1536 #define PACKET_POOL_SIZE (NUM_PACKETS * (PACKET_SIZE + sizeof(NX_PACKET))) #define RTP_SERVER_ADDRESS IP_ADDRESS(1,2,3,4) #define RTP_CLIENT_ADDRESS IP_ADDRESS(1,2,3,5) #define RTP_CLIENT_RTP_PORT 6002 #define RTP_CLIENT_RTCP_PORT 6003 #define RTP_PAYLOAD_TYPE_VIDEO 96 #define CNAME "AzureRTOS@microsoft.com" /* Define test data. */ #define TEST_TIMESTAMP 1234 #define TEST_MSW 123 #define TEST_LSW 456 static UCHAR test_rtp_packet_data[] = "test rtp packet data"; static UCHAR test_rtcp_packet_data[] = {0x80, 0xc8, 0x0, 0x6, 0x0, 0x0, 0x2c, 0xd6, 0x0, 0x0, 0x0, 0x7b, 0x0, 0x0, 0x1, 0xc8, 0x0, 0x0, 0x4, 0xd2, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x81, 0xca, 0x0, 0x8, 0x0, 0x0, 0x2c, 0xd6, 0x1, 0x17, 0x41, 0x7a, 0x75, 0x72, 0x65, 0x52, 0x54, 0x4f, 0x53, 0x40, 0x6d, 0x69, 0x63, 0x72, 0x6f, 0x73, 0x6f, 0x66, 0x74, 0x2e, 0x63, 0x6f, 0x6d, 0x0, 0x0, 0x0}; /* Define the ThreadX object control blocks... */ static TX_THREAD ntest_0; static TX_THREAD ntest_1; static NX_PACKET_POOL pool_0; static NX_IP ip_0; static NX_IP ip_1; static NX_UDP_SOCKET rtcp_client_socket; /* Define rtp sender control block. */ static NX_RTP_SENDER rtp_0; static NX_RTP_SESSION rtp_session_0; /* Define the counters used in the test application... */ static TX_SEMAPHORE semaphore_test_done; /* Define thread prototypes. */ static void ntest_0_entry(ULONG thread_input); static void ntest_1_entry(ULONG thread_input); extern void _nx_ram_network_driver(struct NX_IP_DRIVER_STRUCT *driver_req); extern void test_control_return(UINT status); #ifdef CTEST VOID test_application_define(void *first_unused_memory) #else void netx_rtcp_packet_send_test_application_define(void *first_unused_memory) #endif { CHAR *pointer; UINT status; /* Print out test information banner. */ printf("NetX Test: RTCP Packet Send Test............................................"); /* Setup the working pointer. */ pointer = (CHAR *) first_unused_memory; /* Create the server thread. */ tx_thread_create(&ntest_0, "thread 0", ntest_0_entry, 0, pointer, DEMO_STACK_SIZE, 4, 4, TX_NO_TIME_SLICE, TX_AUTO_START); pointer = pointer + DEMO_STACK_SIZE; /* Create the client thread. */ tx_thread_create(&ntest_1, "thread 1", ntest_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, pointer, PACKET_POOL_SIZE); pointer = pointer + PACKET_POOL_SIZE; CHECK_STATUS(0, status); /* Create server IP instance. */ status = nx_ip_create(&ip_0, "NetX IP Instance 0", RTP_SERVER_ADDRESS, 0xFFFFFF00UL, &pool_0, _nx_ram_network_driver, pointer, 2048, 1); pointer = pointer + 2048; CHECK_STATUS(0, status); /* Create client IP instance. */ status = nx_ip_create(&ip_1, "NetX IP Instance 1", RTP_CLIENT_ADDRESS, 0xFFFFFF00UL, &pool_0, _nx_ram_network_driver, pointer, 2048, 1); pointer = pointer + 2048; CHECK_STATUS(0, status); /* Enable ARP and supply ARP cache memory for IP Instance 0. */ status = nx_arp_enable(&ip_0, (void *) pointer, 1024); pointer = pointer + 1024; CHECK_STATUS(0, status); /* Enable ARP and supply ARP cache memory for IP Instance 1. */ status = nx_arp_enable(&ip_1, (void *) pointer, 1024); pointer = pointer + 1024; CHECK_STATUS(0, status); /* Enable UDP processing for both IP instances. */ status = nx_udp_enable(&ip_0); CHECK_STATUS(0, status); status = nx_udp_enable(&ip_1); CHECK_STATUS(0, status); tx_semaphore_create(&semaphore_test_done, "semaphore test done", 0); } /* Define server threads. */ static void ntest_0_entry(ULONG thread_input) { UINT status; NXD_ADDRESS client_ip_address; NX_PACKET *send_packet; /* Create RTP sender. */ status = nx_rtp_sender_create(&rtp_0, &ip_0, &pool_0, CNAME, sizeof(CNAME) - 1); CHECK_STATUS(0, status); /* Setup rtp sender session. */ client_ip_address.nxd_ip_version = NX_IP_VERSION_V4; client_ip_address.nxd_ip_address.v4 = RTP_CLIENT_ADDRESS; status = nx_rtp_sender_session_create(&rtp_0, &rtp_session_0, RTP_PAYLOAD_TYPE_VIDEO, 0, &client_ip_address, RTP_CLIENT_RTP_PORT, RTP_CLIENT_RTCP_PORT); rtp_session_0.nx_rtp_session_ssrc = 11478; /* Allocate a packet */ status = nx_rtp_sender_session_packet_allocate(&rtp_session_0, &send_packet, 5 * NX_IP_PERIODIC_RATE); CHECK_STATUS(0, status); /* Copy payload data into the packet. */ status = nx_packet_data_append(send_packet, (void*)test_rtp_packet_data, sizeof(test_rtp_packet_data), rtp_0.nx_rtp_sender_ip_ptr->nx_ip_default_packet_pool, 5 * NX_IP_PERIODIC_RATE); CHECK_STATUS(0, status); status = nx_rtp_sender_session_packet_send(&rtp_session_0, send_packet, TEST_TIMESTAMP, TEST_MSW, TEST_LSW, 1); CHECK_STATUS(0, status); status = tx_semaphore_get(&semaphore_test_done, 5 * NX_IP_PERIODIC_RATE); CHECK_STATUS(0, status); /* Return the test result. */ printf("SUCCESS!\n"); test_control_return(0); } /* Define the client threads. */ static void ntest_1_entry(ULONG thread_input) { NX_PACKET *received_packet; UINT status; /* Create the rtp client socket. */ status = nx_udp_socket_create(&ip_1, &rtcp_client_socket, "RTCP Client Socket", NX_IP_NORMAL, NX_FRAGMENT_OKAY, 0x80, 5); CHECK_STATUS(0, status); status = nx_udp_socket_bind(&rtcp_client_socket, RTP_CLIENT_RTCP_PORT, NX_IP_PERIODIC_RATE); CHECK_STATUS(0, status); status = nx_udp_socket_receive(&rtcp_client_socket, &received_packet, 5 * NX_IP_PERIODIC_RATE); if ((status == NX_SUCCESS) && (received_packet->nx_packet_length == sizeof(test_rtcp_packet_data)) && (memcmp(received_packet->nx_packet_prepend_ptr, test_rtcp_packet_data, sizeof(test_rtcp_packet_data)) == 0)) { tx_semaphore_put(&semaphore_test_done); } } #else #ifdef CTEST VOID test_application_define(void *first_unused_memory) #else void netx_rtcp_packet_send_test_application_define(void *first_unused_memory) #endif { /* Print out test information banner. */ printf("NetX Test: RTCP Packet Send Test............................................N/A\n"); test_control_return(3); } #endif