Firmware/ThreadX4TGFS
8
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

applies clang--format

Browse Source
This commit is contained in:
Eyck Jentzsch
2026-02-06 19:31:29 +01:00
parent 28c14404d2
commit 47588180b9
14 changed files with 3355 additions and 2877 deletions
Download Patch File Download Diff File Expand all files Collapse all files

146
src/tcp_demo/main.c
View File

@@ -7,9 +7,9 @@
#include "tx_api.h"
#include <stdio.h>
#define DEMO_STACK_SIZE 2048
#define DEMO_DATA "ABCDEFGHIJKLMNOPQRSTUVWXYZ "
#define PACKET_SIZE 1536
#define POOL_SIZE ((sizeof(NX_PACKET) + PACKET_SIZE) * 8)
#define DEMO_DATA "ABCDEFGHIJKLMNOPQRSTUVWXYZ "
#define PACKET_SIZE 1536
#define POOL_SIZE ((sizeof(NX_PACKET) + PACKET_SIZE) * 8)
#define NX_DISABLE_IPV6
/* Define the ThreadX and NetX object control blocks... */
@@ -44,13 +44,15 @@ void _nx_mnrs_network_driver(struct NX_IP_DRIVER_STRUCT* driver_req);
/* Define main entry point. */
int main() {
/* Enter the ThreadX kernel. */
int main()
{
/* Enter the ThreadX kernel. */
tx_kernel_enter();
}
/* Define what the initial system looks like. */
void tx_application_define(void* first_unused_memory) {
void tx_application_define(void* first_unused_memory)
{
CHAR* pointer;
UINT status;
puts("Setting up application");
@@ -58,12 +60,14 @@ void tx_application_define(void* first_unused_memory) {
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);
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);
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;
@@ -73,24 +77,28 @@ void tx_application_define(void* first_unused_memory) {
/* Create a packet pool. */
status = nx_packet_pool_create(&pool_0, "packet_pool0", PACKET_SIZE, pool_buffer, POOL_SIZE);
if(status) {
if (status)
{
error_counter++;
}
/* Create an IP instance. */
status = nx_ip_create(&ip_0, "eth0", IP_ADDRESS(1, 2, 3, 4), 0xFFFFFF00UL, &pool_0, NETWORK_DRIVER, pointer, 2048, 1);
status =
nx_ip_create(&ip_0, "eth0", IP_ADDRESS(1, 2, 3, 4), 0xFFFFFF00UL, &pool_0, NETWORK_DRIVER, pointer, 2048, 1);
pointer = pointer + 2048;
/* Create another IP instance. */
status += nx_ip_create(&ip_1, "eth1", IP_ADDRESS(1, 2, 3, 5), 0xFFFFFF00UL, &pool_0, NETWORK_DRIVER, pointer, 2048, 1);
status +=
nx_ip_create(&ip_1, "eth1", IP_ADDRESS(1, 2, 3, 5), 0xFFFFFF00UL, &pool_0, NETWORK_DRIVER, pointer, 2048, 1);
pointer = pointer + 2048;
if(status) {
if (status)
{
error_counter++;
}
/* Enable ARP and supply ARP cache memory for IP Instance 0. */
status = nx_arp_enable(&ip_0, (void*)pointer, 1024);
status = nx_arp_enable(&ip_0, (void*)pointer, 1024);
pointer = pointer + 1024;
/* Enable ARP and supply ARP cache memory for IP Instance 1. */
@@ -98,18 +106,21 @@ void tx_application_define(void* first_unused_memory) {
pointer = pointer + 1024;
/* Check ARP enable status. */
if(status) {
if (status)
{
error_counter++;
}
/* Enable ICMP */
status = nxd_icmp_enable(&ip_0);
if(status) {
if (status)
{
error_counter++;
}
status = nxd_icmp_enable(&ip_1);
if(status) {
if (status)
{
error_counter++;
}
@@ -122,7 +133,8 @@ void tx_application_define(void* first_unused_memory) {
/* Define the test threads. */
void thread_0_entry(ULONG thread_input) {
void thread_0_entry(ULONG thread_input)
{
UINT status;
NX_PACKET* my_packet;
@@ -138,18 +150,27 @@ void thread_0_entry(ULONG thread_input) {
tx_thread_sleep(/* NX_IP_PERIODIC_RATE */ 10);
/* set the TCP server addresses. */
server_ipv4_address.nxd_ip_version = NX_IP_VERSION_V4;
server_ipv4_address.nxd_ip_version = NX_IP_VERSION_V4;
server_ipv4_address.nxd_ip_address.v4 = IP_ADDRESS(1, 2, 3, 5);
/* Loop to repeat things over and over again! */
puts("Entering client loop");
while(1) {
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);
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) {
if (status)
{
error_counter++;
}
@@ -157,7 +178,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_tcp_client_socket_bind(&client_socket, 12, NX_WAIT_FOREVER);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -165,7 +187,8 @@ void thread_0_entry(ULONG thread_input) {
status = nxd_tcp_client_socket_connect(&client_socket, &server_ipv4_address, 12, NX_IP_PERIODIC_RATE);
/* Check for error. */
if(status) {
if (status)
{
printf("Error with socket connect: 0x%x\n", status);
return;
}
@@ -176,7 +199,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_packet_allocate(&pool_0, &my_packet, NX_TCP_PACKET, NX_WAIT_FOREVER);
/* Check status. */
if(status != NX_SUCCESS) {
if (status != NX_SUCCESS)
{
break;
}
@@ -184,7 +208,8 @@ void thread_0_entry(ULONG thread_input) {
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))) {
if ((status) || (length != sizeof(DEMO_DATA)))
{
error_counter++;
}
@@ -192,7 +217,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_tcp_socket_send(&client_socket, my_packet, NX_IP_PERIODIC_RATE);
/* Determine if the status is valid. */
if(status) {
if (status)
{
error_counter++;
nx_packet_release(my_packet);
}
@@ -201,7 +227,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_tcp_socket_disconnect(&client_socket, NX_IP_PERIODIC_RATE);
/* Determine if the status is valid. */
if(status) {
if (status)
{
error_counter++;
}
@@ -209,7 +236,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_tcp_client_socket_unbind(&client_socket);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -217,7 +245,8 @@ void thread_0_entry(ULONG thread_input) {
status = nx_tcp_socket_delete(&client_socket);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -226,7 +255,8 @@ void thread_0_entry(ULONG thread_input) {
}
}
void thread_1_entry(ULONG thread_input) {
void thread_1_entry(ULONG thread_input)
{
UINT status;
NX_PACKET* packet_ptr;
@@ -241,18 +271,27 @@ void thread_1_entry(ULONG thread_input) {
status = nx_ip_status_check(&ip_1, NX_IP_INITIALIZE_DONE, &actual_status, NX_IP_PERIODIC_RATE);
/* Check status... */
if(status != NX_SUCCESS) {
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);
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) {
if (status)
{
error_counter++;
}
@@ -260,13 +299,15 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_server_socket_listen(&ip_1, 12, &server_socket, 5, thread_1_connect_received);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
/* Loop to create and establish server connections. */
puts("Entering server loop");
while(1) {
while (1)
{
/* Increment thread 1's counter. */
thread_1_counter++;
@@ -275,7 +316,8 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_server_socket_accept(&server_socket, NX_WAIT_FOREVER);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -283,9 +325,12 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_socket_receive(&server_socket, &packet_ptr, NX_IP_PERIODIC_RATE);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
} else {
}
else
{
char buffer[64];
ULONG size;
nx_packet_data_extract_offset(packet_ptr, 0, buffer, 64, &size);
@@ -299,7 +344,8 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_socket_disconnect(&server_socket, NX_IP_PERIODIC_RATE);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -307,7 +353,8 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_server_socket_unaccept(&server_socket);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
@@ -315,24 +362,29 @@ void thread_1_entry(ULONG thread_input) {
status = nx_tcp_server_socket_relisten(&ip_1, 12, &server_socket);
/* Check for error. */
if(status) {
if (status)
{
error_counter++;
}
}
}
void thread_1_connect_received(NX_TCP_SOCKET* socket_ptr, UINT port) {
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)) {
if ((socket_ptr != &server_socket) || (port != 12))
{
error_counter++;
}
}
void thread_1_disconnect_received(NX_TCP_SOCKET* socket) {
void thread_1_disconnect_received(NX_TCP_SOCKET* socket)
{
/* Check for proper disconnected socket. */
if(socket != &server_socket) {
if (socket != &server_socket)
{
error_counter++;
}
}

122
src/thread_demo/main.c
View File

@@ -5,10 +5,10 @@
#include "tx_api.h"
#include <stdio.h>
#define DEMO_STACK_SIZE 1024
#define DEMO_BYTE_POOL_SIZE 9120
#define DEMO_STACK_SIZE 1024
#define DEMO_BYTE_POOL_SIZE 9120
#define DEMO_BLOCK_POOL_SIZE 100
#define DEMO_QUEUE_SIZE 50
#define DEMO_QUEUE_SIZE 50
/* Define the ThreadX object control blocks... */
@@ -51,14 +51,16 @@ void thread_5_entry(ULONG thread_input);
void thread_6_and_7_entry(ULONG thread_input);
/* Define main entry point. */
int main() {
int main()
{
/* Enter the ThreadX kernel. */
tx_kernel_enter();
}
/* Define what the initial system looks like. */
void tx_application_define(void* first_unused_memory) {
void tx_application_define(void* first_unused_memory)
{
CHAR* pointer = TX_NULL;
@@ -72,7 +74,8 @@ void tx_application_define(void* first_unused_memory) {
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
/* Create the main thread. */
tx_thread_create(&thread_0, "thread 0", thread_0_entry, 0, pointer, DEMO_STACK_SIZE, 1, 1, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(
&thread_0, "thread 0", thread_0_entry, 0, pointer, DEMO_STACK_SIZE, 1, 1, TX_NO_TIME_SLICE, TX_AUTO_START);
/* Allocate the stack for thread 1. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
@@ -93,30 +96,67 @@ void tx_application_define(void* first_unused_memory) {
/* Create threads 3 and 4. These threads compete for a ThreadX counting
semaphore. An interesting thing here is that both threads share the same
instruction area. */
tx_thread_create(&thread_3, "thread 3", thread_3_and_4_entry, 3, pointer, DEMO_STACK_SIZE, 8, 8, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(&thread_3,
"thread 3",
thread_3_and_4_entry,
3,
pointer,
DEMO_STACK_SIZE,
8,
8,
TX_NO_TIME_SLICE,
TX_AUTO_START);
/* Allocate the stack for thread 4. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
tx_thread_create(&thread_4, "thread 4", thread_3_and_4_entry, 4, pointer, DEMO_STACK_SIZE, 8, 8, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(&thread_4,
"thread 4",
thread_3_and_4_entry,
4,
pointer,
DEMO_STACK_SIZE,
8,
8,
TX_NO_TIME_SLICE,
TX_AUTO_START);
/* Allocate the stack for thread 5. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
/* Create thread 5. This thread simply pends on an event flag which will be
set by thread_0. */
tx_thread_create(&thread_5, "thread 5", thread_5_entry, 5, pointer, DEMO_STACK_SIZE, 4, 4, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(
&thread_5, "thread 5", thread_5_entry, 5, pointer, DEMO_STACK_SIZE, 4, 4, TX_NO_TIME_SLICE, TX_AUTO_START);
/* Allocate the stack for thread 6. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
/* Create threads 6 and 7. These threads compete for a ThreadX mutex. */
tx_thread_create(&thread_6, "thread 6", thread_6_and_7_entry, 6, pointer, DEMO_STACK_SIZE, 8, 8, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(&thread_6,
"thread 6",
thread_6_and_7_entry,
6,
pointer,
DEMO_STACK_SIZE,
8,
8,
TX_NO_TIME_SLICE,
TX_AUTO_START);
/* Allocate the stack for thread 7. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_STACK_SIZE, TX_NO_WAIT);
tx_thread_create(&thread_7, "thread 7", thread_6_and_7_entry, 7, pointer, DEMO_STACK_SIZE, 8, 8, TX_NO_TIME_SLICE, TX_AUTO_START);
tx_thread_create(&thread_7,
"thread 7",
thread_6_and_7_entry,
7,
pointer,
DEMO_STACK_SIZE,
8,
8,
TX_NO_TIME_SLICE,
TX_AUTO_START);
/* Allocate the message queue. */
tx_byte_allocate(&byte_pool_0, (VOID**)&pointer, DEMO_QUEUE_SIZE * sizeof(ULONG), TX_NO_WAIT);
@@ -148,12 +188,14 @@ void tx_application_define(void* first_unused_memory) {
/* Define the test threads. */
void thread_0_entry(ULONG thread_input) {
void thread_0_entry(ULONG thread_input)
{
UINT status;
/* This thread simply sits in while-forever-sleep loop. */
while(1) {
while (1)
{
puts("[Thread] : thread_0_entry is here!");
/* Increment the thread counter. */
thread_0_counter++;
@@ -165,17 +207,19 @@ void thread_0_entry(ULONG thread_input) {
status = tx_event_flags_set(&event_flags_0, 0x1, TX_OR);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
}
}
void thread_1_entry(ULONG thread_input) {
void thread_1_entry(ULONG thread_input)
{
UINT status;
/* This thread simply sends messages to a queue shared by thread 2. */
while(1) {
while (1)
{
/* Increment the thread counter. */
thread_1_counter++;
@@ -183,7 +227,7 @@ void thread_1_entry(ULONG thread_input) {
status = tx_queue_send(&queue_0, &thread_1_messages_sent, TX_WAIT_FOREVER);
/* Check completion status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
/* Increment the message sent. */
@@ -192,13 +236,15 @@ void thread_1_entry(ULONG thread_input) {
}
}
void thread_2_entry(ULONG thread_input) {
void thread_2_entry(ULONG thread_input)
{
ULONG received_message;
UINT status;
/* This thread retrieves messages placed on the queue by thread 1. */
while(1) {
while (1)
{
/* Increment the thread counter. */
thread_2_counter++;
@@ -208,7 +254,7 @@ void thread_2_entry(ULONG thread_input) {
/* Check completion status and make sure the message is what we
expected. */
if((status != TX_SUCCESS) || (received_message != thread_2_messages_received))
if ((status != TX_SUCCESS) || (received_message != thread_2_messages_received))
break;
/* Otherwise, all is okay. Increment the received message count. */
@@ -216,17 +262,19 @@ void thread_2_entry(ULONG thread_input) {
}
}
void thread_3_and_4_entry(ULONG thread_input) {
void thread_3_and_4_entry(ULONG thread_input)
{
UINT status;
/* This function is executed from thread 3 and thread 4. As the loop
below shows, these function compete for ownership of semaphore_0. */
while(1) {
while (1)
{
puts("[Thread] : thread_3_and_4_entry is here!");
/* Increment the thread counter. */
if(thread_input == 3)
if (thread_input == 3)
thread_3_counter++;
else
thread_4_counter++;
@@ -235,7 +283,7 @@ void thread_3_and_4_entry(ULONG thread_input) {
status = tx_semaphore_get(&semaphore_0, TX_WAIT_FOREVER);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
/* Sleep for 2 ticks to hold the semaphore. */
@@ -245,18 +293,20 @@ void thread_3_and_4_entry(ULONG thread_input) {
status = tx_semaphore_put(&semaphore_0);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
}
}
void thread_5_entry(ULONG thread_input) {
void thread_5_entry(ULONG thread_input)
{
UINT status;
ULONG actual_flags;
/* This thread simply waits for an event in a forever loop. */
while(1) {
while (1)
{
puts("[Thread] : thread_5_entry is here!");
/* Increment the thread counter. */
thread_5_counter++;
@@ -265,21 +315,23 @@ void thread_5_entry(ULONG thread_input) {
status = tx_event_flags_get(&event_flags_0, 0x1, TX_OR_CLEAR, &actual_flags, TX_WAIT_FOREVER);
/* Check status. */
if((status != TX_SUCCESS) || (actual_flags != 0x1))
if ((status != TX_SUCCESS) || (actual_flags != 0x1))
break;
}
}
void thread_6_and_7_entry(ULONG thread_input) {
void thread_6_and_7_entry(ULONG thread_input)
{
UINT status;
/* This function is executed from thread 6 and thread 7. As the loop
below shows, these function compete for ownership of mutex_0. */
while(1) {
while (1)
{
puts("[Thread] : thread_6_and_7_entry is here!");
/* Increment the thread counter. */
if(thread_input == 6)
if (thread_input == 6)
thread_6_counter++;
else
thread_7_counter++;
@@ -288,7 +340,7 @@ void thread_6_and_7_entry(ULONG thread_input) {
status = tx_mutex_get(&mutex_0, TX_WAIT_FOREVER);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
/* Get the mutex again with suspension. This shows
@@ -297,7 +349,7 @@ void thread_6_and_7_entry(ULONG thread_input) {
status = tx_mutex_get(&mutex_0, TX_WAIT_FOREVER);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
/* Sleep for 2 ticks to hold the mutex. */
@@ -307,7 +359,7 @@ void thread_6_and_7_entry(ULONG thread_input) {
status = tx_mutex_put(&mutex_0);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
/* Release the mutex again. This will actually
@@ -315,7 +367,7 @@ void thread_6_and_7_entry(ULONG thread_input) {
status = tx_mutex_put(&mutex_0);
/* Check status. */
if(status != TX_SUCCESS)
if (status != TX_SUCCESS)
break;
}
}