diff options
Diffstat (limited to 'testsuites/tmtests/tm09/task1.c')
-rw-r--r-- | testsuites/tmtests/tm09/task1.c | 226 |
1 files changed, 226 insertions, 0 deletions
diff --git a/testsuites/tmtests/tm09/task1.c b/testsuites/tmtests/tm09/task1.c new file mode 100644 index 0000000000..90d454b3d4 --- /dev/null +++ b/testsuites/tmtests/tm09/task1.c @@ -0,0 +1,226 @@ +/* + * + * COPYRIGHT (c) 1989-1997. + * On-Line Applications Research Corporation (OAR). + * Copyright assigned to U.S. Government, 1994. + * + * The license and distribution terms for this file may in + * the file LICENSE in this distribution or at + * http://www.OARcorp.com/rtems/license.html. + * + * $Id$ + */ + +#define TEST_INIT +#include "system.h" + +rtems_id Queue_id; + +rtems_task Test_task( + rtems_task_argument argument +); +void queue_test(); + +rtems_task Init( + rtems_task_argument argument +) +{ + rtems_status_code status; + + Print_Warning(); + + puts( "\n\n*** TIME TEST 9 ***" ); + + status = rtems_task_create( + 1, + 128, + RTEMS_MINIMUM_STACK_SIZE, + RTEMS_DEFAULT_MODES, + RTEMS_DEFAULT_ATTRIBUTES, + &Task_id[ 1 ] + ); + directive_failed( status, "rtems_task_create" ); + + status = rtems_task_start( Task_id[ 1 ], Test_task, 0 ); + directive_failed( status, "rtems_task_start" ); + + status = rtems_task_delete( RTEMS_SELF ); + directive_failed( status, "rtems_task_delete of RTEMS_SELF" ); +} + +rtems_task Test_task ( + rtems_task_argument argument +) +{ + Timer_initialize(); + rtems_message_queue_create( + 1, + OPERATION_COUNT, + 16, + RTEMS_DEFAULT_ATTRIBUTES, + &Queue_id + ); + end_time = Read_timer(); + + put_time( + "rtems_message_queue_create", + end_time, + 1, + 0, + CALLING_OVERHEAD_MESSAGE_QUEUE_CREATE + ); + + queue_test(); + + Timer_initialize(); + rtems_message_queue_delete( Queue_id ); + end_time = Read_timer(); + + put_time( + "rtems_message_queue_delete", + end_time, + 1, + 0, + CALLING_OVERHEAD_MESSAGE_QUEUE_DELETE + ); + + puts( "*** END OF TEST 9 ***" ); + exit( 0 ); +} + +void queue_test() +{ + rtems_unsigned32 send_loop_time; + rtems_unsigned32 urgent_loop_time; + rtems_unsigned32 receive_loop_time; + rtems_unsigned32 send_time; + rtems_unsigned32 urgent_time; + rtems_unsigned32 receive_time; + rtems_unsigned32 empty_flush_time; + rtems_unsigned32 flush_time; + rtems_unsigned32 empty_flush_count; + rtems_unsigned32 flush_count; + rtems_unsigned32 index; + rtems_unsigned32 iterations; + long buffer[4]; + rtems_status_code status; + rtems_unsigned32 size; + + send_loop_time = 0; + urgent_loop_time = 0; + receive_loop_time = 0; + send_time = 0; + urgent_time = 0; + receive_time = 0; + empty_flush_time = 0; + flush_time = 0; + flush_count = 0; + empty_flush_count = 0; + + for ( iterations = 1 ; iterations <= OPERATION_COUNT ; iterations++ ) { + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) Empty_function(); + send_loop_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) Empty_function(); + urgent_loop_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) Empty_function(); + receive_loop_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) rtems_message_queue_send( Queue_id, (long (*)[4])buffer, 16 ); + send_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) rtems_message_queue_receive( + Queue_id, + (long (*)[4])buffer, + &size, + RTEMS_DEFAULT_OPTIONS, + RTEMS_NO_TIMEOUT + ); + receive_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) rtems_message_queue_urgent( Queue_id, (long (*)[4])buffer, 16 ); + urgent_time += Read_timer(); + + Timer_initialize(); + for ( index=1 ; index <= OPERATION_COUNT ; index++ ) + (void) rtems_message_queue_receive( + Queue_id, + (long (*)[4])buffer, + &size, + RTEMS_DEFAULT_OPTIONS, + RTEMS_NO_TIMEOUT + ); + receive_time += Read_timer(); + + Timer_initialize(); + rtems_message_queue_flush( Queue_id, &empty_flush_count ); + empty_flush_time += Read_timer(); + + /* send one message to flush */ + status = rtems_message_queue_send( + Queue_id, + (long (*)[4])buffer, + 16 + ); + directive_failed( status, "rtems_message_queue_send" ); + + Timer_initialize(); + rtems_message_queue_flush( Queue_id, &flush_count ); + flush_time += Read_timer(); + } + + put_time( + "rtems_message_queue_send: no waiting tasks", + send_time, + OPERATION_COUNT * OPERATION_COUNT, + send_loop_time, + CALLING_OVERHEAD_MESSAGE_QUEUE_SEND + ); + + put_time( + "rtems_message_queue_urgent: no waiting tasks", + urgent_time, + OPERATION_COUNT * OPERATION_COUNT, + urgent_loop_time, + CALLING_OVERHEAD_MESSAGE_QUEUE_URGENT + ); + + put_time( + "rtems_message_queue_receive: available", + receive_time, + OPERATION_COUNT * OPERATION_COUNT * 2, + receive_loop_time * 2, + CALLING_OVERHEAD_MESSAGE_QUEUE_RECEIVE + ); + + put_time( + "rtems_message_queue_flush: no messages flushed", + empty_flush_time, + OPERATION_COUNT, + 0, + CALLING_OVERHEAD_MESSAGE_QUEUE_FLUSH + ); + + put_time( + "rtems_message_queue_flush: messages flushed", + flush_time, + OPERATION_COUNT, + 0, + CALLING_OVERHEAD_MESSAGE_QUEUE_FLUSH + ); + +} |