/* This test is designed to test event flag suspension and resumption of two threads
waiting on the same event flag set with the consumption. */
#include <stdio.h>
#include "tx_api.h"
static unsigned long thread_0_counter = 0;
static TX_THREAD thread_0;
static unsigned long thread_1_counter = 0;
static TX_THREAD thread_1;
static unsigned long thread_2_counter = 0;
static TX_THREAD thread_2;
static unsigned long thread_3_counter = 0;
static TX_THREAD thread_3;
static TX_EVENT_FLAGS_GROUP group_0;
/* Define thread prototypes. */
static void thread_0_entry(ULONG thread_input);
static void thread_1_entry(ULONG thread_input);
static void thread_2_entry(ULONG thread_input);
static void thread_3_entry(ULONG thread_input);
/* Prototype for test control return. */
void test_control_return(UINT status);
static void event_set_notify(TX_EVENT_FLAGS_GROUP *group)
{
/* Not necessary to do anything in this function. */
}
/* Define what the initial system looks like. */
#ifdef CTEST
void test_application_define(void *first_unused_memory)
#else
void threadx_event_flag_suspension_consume_application_define(void *first_unused_memory)
#endif
{
UINT status;
CHAR *pointer;
/* Put first available memory address into a character pointer. */
pointer = (CHAR *) first_unused_memory;
/* Put system definition stuff in here, e.g. thread creates and other assorted
create information. */
status = tx_thread_create(&thread_0, "thread 0", thread_0_entry, 1,
pointer, TEST_STACK_SIZE_PRINTF,
17, 17, 100, TX_AUTO_START);
pointer = pointer + TEST_STACK_SIZE_PRINTF;
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #1\n");
test_control_return(1);
}
status = tx_thread_create(&thread_1, "thread 1", thread_1_entry, 1,
pointer, TEST_STACK_SIZE_PRINTF,
16, 16, 100, TX_AUTO_START);
pointer = pointer + TEST_STACK_SIZE_PRINTF;
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #2\n");
test_control_return(1);
}
status = tx_thread_create(&thread_2, "thread 2", thread_2_entry, 1,
pointer, TEST_STACK_SIZE_PRINTF,
16, 16, 100, TX_AUTO_START);
pointer = pointer + TEST_STACK_SIZE_PRINTF;
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #3\n");
test_control_return(1);
}
status = tx_thread_create(&thread_3, "thread 3", thread_3_entry, 1,
pointer, TEST_STACK_SIZE_PRINTF,
16, 16, 100, TX_AUTO_START);
pointer = pointer + TEST_STACK_SIZE_PRINTF;
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #4\n");
test_control_return(1);
}
/* Create event flag group 0. */
status = tx_event_flags_create(&group_0, "group 0");
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #5\n");
test_control_return(1);
}
/* Register the event set notify function. */
status = tx_event_flags_set_notify(&group_0, event_set_notify);
#ifndef TX_DISABLE_NOTIFY_CALLBACKS
/* Check status. */
if (status != TX_SUCCESS)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #6\n");
test_control_return(1);
}
#else
/* Check status. */
if (status != TX_FEATURE_NOT_ENABLED)
{
printf("Running Event Flag Suspension/Consumption Test...................... ERROR #7\n");
test_control_return(1);
}
#endif
}
/* Define the test threads. */
static void thread_0_entry(ULONG thread_input)
{
UINT status;
ULONG event_flag = 1;
int i;
/* Inform user. */
printf("Running Event Flag Suspension/Consumption Test...................... ");
/* Set all event flags. */
for (i = 0; i < 32; i++)
{
/* Increment run counter. */
thread_0_counter++;
/* Set event flag. */
status = tx_event_flags_set(&group_0, event_flag, TX_OR);
/* Check status. */
if (status != TX_SUCCESS)
{
/* Event flag error. */
printf("ERROR #8\n");
test_control_return(1);
}
/* Check the thread counters... */
if ((i < 31) && ((thread_1_counter != 1) || (thread_2_counter != 1) || (thread_3_counter != 1)))
{
/* Event flag error. */
printf("ERROR #9\n");
test_control_return(1);
}
if ((i == 31) && ((thread_1_counter != 2) || (thread_2_counter != 2) || (thread_3_counter != 2)))
{
/* Event flag error. */
printf("ERROR #10\n");
test_control_return(1);
}
/* Shift event flag up one bit. */
event_flag = event_flag << 1;
/* Check for 0. */
if (event_flag == 0)
event_flag = 1;
}
/* Successful test. */
printf("SUCCESS!\n");
test_control_return(0);
}
static void thread_1_entry(ULONG thread_input)
{
UINT status;
//ULONG event_flag = 1;
ULONG actual_events;
/* Wait for event flags. */
while(1)
{
/* Increment run counter. */
thread_1_counter++;
/* Attempt to get events from event flag group. AND option. */
status = tx_event_flags_get(&group_0, 0x80008000, TX_AND_CLEAR, &actual_events, TX_WAIT_FOREVER);
/* Check status. */
if ((status != TX_SUCCESS) || (actual_events != 0xFFFFFFFFUL))
return;
}
}
static void thread_2_entry(ULONG thread_input)
{
UINT status;
//ULONG event_flag = 1;
ULONG actual_events;
/* Wait for event flags. */
while(1)
{
/* Increment run counter. */
thread_2_counter++;
/* Attempt to get events from event flag group. AND option. */
status = tx_event_flags_get(&group_0, 0x80008000, TX_AND, &actual_events, TX_WAIT_FOREVER);
/* Check status. */
if ((status != TX_SUCCESS) || (actual_events != 0xFFFFFFFFUL))
return;
}
}
static void thread_3_entry(ULONG thread_input)
{
UINT status;
//ULONG event_flag = 1;
ULONG actual_events;
/* Wait for event flags. */
while(1)
{
/* Increment run counter. */
thread_3_counter++;
/* Attempt to get events from event flag group. AND option. */
status = tx_event_flags_get(&group_0, 0x80008000, TX_AND, &actual_events, TX_WAIT_FOREVER);
/* Check status. */
if ((status != TX_SUCCESS) || (actual_events != 0xFFFFFFFFUL))
return;
}
}