From f9c0574793e6e7f01bec7818bd58695150b0f00f Mon Sep 17 00:00:00 2001 From: Joel Sherrill Date: Fri, 19 May 2000 19:13:09 +0000 Subject: [PATCH] This is an update of all Classic API Message Manager tests to eliminate code which assumes that 4 * sizeof(unsigned32) == 16) and that a 16 byte message can be assumed to be 4 unsigned32's. These assumptions are invalid on target processors that are not byte-addressable. --- c/src/tests/sptests/sp09/screen07.c | 20 ++++++++++-------- c/src/tests/sptests/sp09/screen08.c | 22 +++++++++++--------- c/src/tests/sptests/sp13/fillbuff.c | 16 +++++++++++++++ c/src/tests/sptests/sp13/init.c | 8 +++++--- c/src/tests/sptests/sp13/putbuff.c | 12 +++++++++++ c/src/tests/sptests/sp13/task1.c | 32 +++++++++++++++-------------- c/src/tests/sptests/sp13/task2.c | 16 ++++++++------- c/src/tests/tmtests/tm09/task1.c | 10 +++++---- c/src/tests/tmtests/tm11/task1.c | 6 ++++-- c/src/tests/tmtests/tm12/task1.c | 5 +++-- c/src/tests/tmtests/tm13/task1.c | 6 ++++-- c/src/tests/tmtests/tm14/task1.c | 5 +++-- c/src/tests/tmtests/tm21/task1.c | 4 +++- c/src/tests/tmtests/tm22/task1.c | 16 ++++++++------- 14 files changed, 114 insertions(+), 64 deletions(-) diff --git a/c/src/tests/sptests/sp09/screen07.c b/c/src/tests/sptests/sp09/screen07.c index 26dab852d5..737ba70a1f 100644 --- a/c/src/tests/sptests/sp09/screen07.c +++ b/c/src/tests/sptests/sp09/screen07.c @@ -18,6 +18,8 @@ #include "system.h" +#define MESSAGE_SIZE (sizeof(long) * 4) + void Screen7() { long buffer[ 4 ]; @@ -25,7 +27,7 @@ void Screen7() rtems_unsigned32 count; rtems_status_code status; - status = rtems_message_queue_broadcast( 100, (long (*)[4]) buffer, 16, &count ); + status = rtems_message_queue_broadcast( 100, buffer, MESSAGE_SIZE, &count ); fatal_directive_status( status, RTEMS_INVALID_ID, @@ -36,7 +38,7 @@ void Screen7() status = rtems_message_queue_create( 0, 3, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Junk_id ); @@ -56,7 +58,7 @@ void Screen7() status = rtems_message_queue_create( Queue_name[ 1 ], 1, - 16, + MESSAGE_SIZE, RTEMS_GLOBAL, &Junk_id ); @@ -71,7 +73,7 @@ void Screen7() status = rtems_message_queue_create( Queue_name[ 1 ], 2, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id[ 1 ] ); @@ -83,7 +85,7 @@ void Screen7() status = rtems_message_queue_create( Queue_name[ 2 ], 1, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Junk_id ); @@ -180,7 +182,7 @@ void Screen7() "TA1 - rtems_message_queue_receive - Q 1 - woke up with RTEMS_TIMEOUT" ); - status = rtems_message_queue_send( 100, (long (*)[4]) buffer, 16 ); + status = rtems_message_queue_send( 100, buffer, MESSAGE_SIZE ); fatal_directive_status( status, RTEMS_INVALID_ID, @@ -188,15 +190,15 @@ void Screen7() ); puts( "TA1 - rtems_message_queue_send - RTEMS_INVALID_ID" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4]) buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4]) buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4]) buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); fatal_directive_status( status, RTEMS_TOO_MANY, diff --git a/c/src/tests/sptests/sp09/screen08.c b/c/src/tests/sptests/sp09/screen08.c index dd0a9afba4..76af9e8bb9 100644 --- a/c/src/tests/sptests/sp09/screen08.c +++ b/c/src/tests/sptests/sp09/screen08.c @@ -18,6 +18,8 @@ #include "system.h" +#define MESSAGE_SIZE (sizeof(long) * 4) + void Screen8() { long buffer[ 4 ]; @@ -30,7 +32,7 @@ void Screen8() status = rtems_message_queue_create( Queue_name[ 1 ], 2, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id[ 1 ] ); @@ -39,15 +41,15 @@ void Screen8() "TA1 - rtems_message_queue_create - Q 1 - 2 DEEP - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send successful" ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send successful" ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); fatal_directive_status( status, RTEMS_TOO_MANY, @@ -62,7 +64,7 @@ void Screen8() status = rtems_message_queue_create( Queue_name[ 1 ], 3, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id[ 1 ] ); @@ -71,19 +73,19 @@ void Screen8() "TA1 - rtems_message_queue_create - Q 1 - 3 DEEP - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send successful" ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send successful" ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send successful" ); puts( "TA1 - rtems_message_queue_send - BUFFER 3 TO Q 1 - RTEMS_SUCCESSFUL" ); - status = rtems_message_queue_send( Queue_id[ 1 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); fatal_directive_status( status, RTEMS_TOO_MANY, @@ -100,7 +102,7 @@ void Screen8() status = rtems_message_queue_create( Queue_name[ 1 ], 3, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id[ 1 ] ); diff --git a/c/src/tests/sptests/sp13/fillbuff.c b/c/src/tests/sptests/sp13/fillbuff.c index 728606e5bb..6930913d3d 100644 --- a/c/src/tests/sptests/sp13/fillbuff.c +++ b/c/src/tests/sptests/sp13/fillbuff.c @@ -21,10 +21,26 @@ #include "system.h" +#define MESSAGE_SIZE (sizeof(long) * 4) + void Fill_buffer( char *source, long *buffer ) { + char *p; + int i; +/* memcpy( buffer, source, 16 ); +*/ + p = source; + for ( i=0 ; i> 24), + (char) (buffer[i] >> 16 & 0xff), + (char) (buffer[i] >> 8 & 0xff), + (char) (buffer[i] >> 0 & 0xff) ); + } + } diff --git a/c/src/tests/sptests/sp13/task1.c b/c/src/tests/sptests/sp13/task1.c index 859c3d46ab..015259b0f0 100644 --- a/c/src/tests/sptests/sp13/task1.c +++ b/c/src/tests/sptests/sp13/task1.c @@ -25,6 +25,8 @@ char big_receive_buffer[2048]; long buffer[ 4 ]; +#define MESSAGE_SIZE (sizeof(long) * 4) + void dope_buffer(unsigned char *buff, int buff_size, unsigned32 v) @@ -64,12 +66,12 @@ rtems_task Task_1( Fill_buffer( "BUFFER 1 TO Q 1", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 1" ); - status = rtems_message_queue_send( Queue_id[ 1 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); Fill_buffer( "BUFFER 2 TO Q 1", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 1" ); - status = rtems_message_queue_send( Queue_id[ 1 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_task_wake_after - sleep 5 seconds" ); @@ -78,7 +80,7 @@ rtems_task Task_1( Fill_buffer( "BUFFER 3 TO Q 1", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 3 TO Q 1" ); - status = rtems_message_queue_send( Queue_id[ 1 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 1 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_task_wake_after - sleep 5 seconds" ); @@ -89,7 +91,7 @@ rtems_test_pause(); Fill_buffer( "BUFFER 1 TO Q 2", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 2" ); - status = rtems_message_queue_send( Queue_id[ 2 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 2 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts_nocr( "TA1 - rtems_message_queue_receive - receive from queue 1 - " ); @@ -112,7 +114,7 @@ rtems_test_pause(); Fill_buffer( "BUFFER 1 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_task_wake_after - sleep 5 seconds" ); @@ -123,22 +125,22 @@ rtems_test_pause(); Fill_buffer( "BUFFER 2 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); Fill_buffer( "BUFFER 3 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 3 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); Fill_buffer( "BUFFER 4 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 4 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); Fill_buffer( "BUFFER 5 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_urgent - BUFFER 5 TO Q 3" ); - status = rtems_message_queue_urgent( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_urgent( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_urgent" ); for ( index = 1 ; index <= 4 ; index++ ) { @@ -161,7 +163,7 @@ rtems_test_pause(); Fill_buffer( "BUFFER 3 TO Q 2", buffer ); puts( "TA1 - rtems_message_queue_urgent - BUFFER 3 TO Q 2" ); - status = rtems_message_queue_urgent( Queue_id[ 2 ], buffer, 16 ); + status = rtems_message_queue_urgent( Queue_id[ 2 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_urgent" ); puts( @@ -188,7 +190,7 @@ rtems_test_pause(); Fill_buffer( "BUFFER 3 TO Q 2", buffer ); puts( "TA1 - rtems_message_queue_urgent - BUFFER 3 TO Q 2" ); - status = rtems_message_queue_urgent( Queue_id[ 2 ], buffer, 16 ); + status = rtems_message_queue_urgent( Queue_id[ 2 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_urgent" ); puts( "TA1 - rtems_message_queue_delete - delete queue 2" ); @@ -205,12 +207,12 @@ rtems_test_pause(); Fill_buffer( "BUFFER 1 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 1 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); Fill_buffer( "BUFFER 2 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 2 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); /* this broadcast should have no effect on the queue */ @@ -231,7 +233,7 @@ rtems_test_pause(); Fill_buffer( "BUFFER 3 TO Q 3", buffer ); puts( "TA1 - rtems_message_queue_send - BUFFER 3 TO Q 3" ); - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( "TA1 - rtems_message_queue_flush - Q 3" ); @@ -240,7 +242,7 @@ rtems_test_pause(); puts( "TA1 - rtems_message_queue_send until all message buffers consumed" ); while ( FOREVER ) { - status = rtems_message_queue_send( Queue_id[ 3 ], buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 3 ], buffer, MESSAGE_SIZE ); if ( status == RTEMS_TOO_MANY ) break; directive_failed( status, "rtems_message_queue_send loop" ); } diff --git a/c/src/tests/sptests/sp13/task2.c b/c/src/tests/sptests/sp13/task2.c index c3e117fae3..258a036f8c 100644 --- a/c/src/tests/sptests/sp13/task2.c +++ b/c/src/tests/sptests/sp13/task2.c @@ -20,6 +20,8 @@ #include "system.h" +#define MESSAGE_SIZE (sizeof(long) * 4) + rtems_task Task_2( rtems_task_argument argument ) @@ -34,7 +36,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 1 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_NO_WAIT, RTEMS_NO_TIMEOUT @@ -50,7 +52,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 1 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_DEFAULT_OPTIONS, RTEMS_NO_TIMEOUT @@ -66,7 +68,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 1 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_DEFAULT_OPTIONS, RTEMS_NO_TIMEOUT @@ -86,7 +88,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 2 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_DEFAULT_OPTIONS, RTEMS_NO_TIMEOUT @@ -100,7 +102,7 @@ rtems_task Task_2( puts( "TA2 - rtems_message_queue_send - BUFFER 2 TO Q 2" ); directive_failed( status, "rtems_message_queue_send" ); - status = rtems_message_queue_send( Queue_id[ 2 ], (long (*)[4])buffer, 16 ); + status = rtems_message_queue_send( Queue_id[ 2 ], buffer, MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); puts( @@ -109,7 +111,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 1 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_DEFAULT_OPTIONS, 10 * TICKS_PER_SECOND @@ -125,7 +127,7 @@ rtems_task Task_2( ); status = rtems_message_queue_receive( Queue_id[ 3 ], - (long (*)[4])buffer, + buffer, &size, RTEMS_DEFAULT_OPTIONS, RTEMS_NO_TIMEOUT diff --git a/c/src/tests/tmtests/tm09/task1.c b/c/src/tests/tmtests/tm09/task1.c index 27bbc0931e..34ce8b5a11 100644 --- a/c/src/tests/tmtests/tm09/task1.c +++ b/c/src/tests/tmtests/tm09/task1.c @@ -47,6 +47,8 @@ rtems_task Init( directive_failed( status, "rtems_task_delete of RTEMS_SELF" ); } +#define MESSAGE_SIZE (sizeof(long) * 4) + rtems_task Test_task ( rtems_task_argument argument ) @@ -55,7 +57,7 @@ rtems_task Test_task ( rtems_message_queue_create( 1, OPERATION_COUNT, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -135,7 +137,7 @@ void queue_test() Timer_initialize(); for ( index=1 ; index <= OPERATION_COUNT ; index++ ) - (void) rtems_message_queue_send( Queue_id, (long (*)[4])buffer, 16 ); + (void) rtems_message_queue_send( Queue_id, buffer, MESSAGE_SIZE ); send_time += Read_timer(); Timer_initialize(); @@ -151,7 +153,7 @@ void queue_test() Timer_initialize(); for ( index=1 ; index <= OPERATION_COUNT ; index++ ) - (void) rtems_message_queue_urgent( Queue_id, (long (*)[4])buffer, 16 ); + (void) rtems_message_queue_urgent( Queue_id, buffer, MESSAGE_SIZE ); urgent_time += Read_timer(); Timer_initialize(); @@ -173,7 +175,7 @@ void queue_test() status = rtems_message_queue_send( Queue_id, (long (*)[4])buffer, - 16 + MESSAGE_SIZE ); directive_failed( status, "rtems_message_queue_send" ); diff --git a/c/src/tests/tmtests/tm11/task1.c b/c/src/tests/tmtests/tm11/task1.c index 0afc1b9590..0ff58e4c87 100644 --- a/c/src/tests/tmtests/tm11/task1.c +++ b/c/src/tests/tmtests/tm11/task1.c @@ -58,6 +58,8 @@ void Init( directive_failed( status, "rtems_task_delete of RTEMS_SELF" ); } +#define MESSAGE_SIZE (sizeof(long) * 4) + rtems_task test_init( rtems_task_argument argument ) @@ -76,7 +78,7 @@ rtems_task test_init( status = rtems_message_queue_create( rtems_build_name( 'M', 'Q', '1', ' ' ), OPERATION_COUNT, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -105,7 +107,7 @@ rtems_task test_init( } Timer_initialize(); - (void) rtems_message_queue_send( Queue_id, (long (*)[4]) Buffer, 16 ); + (void) rtems_message_queue_send( Queue_id, Buffer, MESSAGE_SIZE ); } rtems_task Middle_tasks( diff --git a/c/src/tests/tmtests/tm12/task1.c b/c/src/tests/tmtests/tm12/task1.c index 7e57b29f12..5b67e59a19 100644 --- a/c/src/tests/tmtests/tm12/task1.c +++ b/c/src/tests/tmtests/tm12/task1.c @@ -29,6 +29,7 @@ rtems_task Low_tasks( rtems_task_argument argument ); +#define MESSAGE_SIZE (sizeof(long) * 4) rtems_task Init( rtems_task_argument argument @@ -72,7 +73,7 @@ rtems_task test_init( status = rtems_message_queue_create( rtems_build_name( 'M', 'Q', '1', ' ' ), OPERATION_COUNT, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -114,7 +115,7 @@ rtems_task High_task( Timer_initialize(); for ( index=1 ; index <= OPERATION_COUNT ; index++ ) - (void) rtems_message_queue_send( Queue_id, (long (*)[4]) Buffer, 16 ); + (void) rtems_message_queue_send( Queue_id, Buffer, MESSAGE_SIZE ); end_time = Read_timer(); put_time( diff --git a/c/src/tests/tmtests/tm13/task1.c b/c/src/tests/tmtests/tm13/task1.c index 317b1f1805..0b2afc8571 100644 --- a/c/src/tests/tmtests/tm13/task1.c +++ b/c/src/tests/tmtests/tm13/task1.c @@ -29,6 +29,8 @@ rtems_task High_task( rtems_task_argument argument ); +#define MESSAGE_SIZE (sizeof(long) * 4) + void Init( rtems_task_argument argument ) @@ -75,7 +77,7 @@ rtems_task test_init( status = rtems_message_queue_create( rtems_build_name( 'M', 'Q', '1', ' ' ), OPERATION_COUNT, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -104,7 +106,7 @@ rtems_task test_init( } Timer_initialize(); - (void) rtems_message_queue_urgent( Queue_id, (long (*)[4]) Buffer, 16 ); + (void) rtems_message_queue_urgent( Queue_id, Buffer, MESSAGE_SIZE ); } rtems_task Middle_tasks( diff --git a/c/src/tests/tmtests/tm14/task1.c b/c/src/tests/tmtests/tm14/task1.c index fc84f6c19e..c368ca15be 100644 --- a/c/src/tests/tmtests/tm14/task1.c +++ b/c/src/tests/tmtests/tm14/task1.c @@ -29,6 +29,7 @@ rtems_task Low_tasks( rtems_task_argument argument ); +#define MESSAGE_SIZE (sizeof(long) * 4) rtems_task Init( rtems_task_argument argument @@ -72,7 +73,7 @@ rtems_task test_init( status = rtems_message_queue_create( rtems_build_name( 'M', 'Q', '1', ' ' ), OPERATION_COUNT, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -114,7 +115,7 @@ rtems_task High_task( Timer_initialize(); for ( index=1 ; index <= OPERATION_COUNT ; index++ ) - (void) rtems_message_queue_urgent( Queue_id, (long (*)[4]) Buffer, 16 ); + (void) rtems_message_queue_urgent( Queue_id, Buffer, MESSAGE_SIZE ); end_time = Read_timer(); put_time( diff --git a/c/src/tests/tmtests/tm21/task1.c b/c/src/tests/tmtests/tm21/task1.c index 6b0086eb24..42591316f3 100644 --- a/c/src/tests/tmtests/tm21/task1.c +++ b/c/src/tests/tmtests/tm21/task1.c @@ -48,6 +48,8 @@ rtems_task Init( directive_failed( status, "rtems_task_delete of RTEMS_SELF" ); } +#define MESSAGE_SIZE (sizeof(long) * 4) + rtems_task Task_1( rtems_task_argument argument ) @@ -70,7 +72,7 @@ rtems_task Task_1( status = rtems_message_queue_create( index, 1, /* only going to ident this queue */ - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &id ); diff --git a/c/src/tests/tmtests/tm22/task1.c b/c/src/tests/tmtests/tm22/task1.c index f5d577d2bf..3abb4cd22d 100644 --- a/c/src/tests/tmtests/tm22/task1.c +++ b/c/src/tests/tmtests/tm22/task1.c @@ -29,6 +29,8 @@ rtems_task Preempt_task( rtems_task_argument argument ); +#define MESSAGE_SIZE (sizeof(long) * 4) + rtems_task Init( rtems_task_argument argument ) @@ -43,7 +45,7 @@ rtems_task Init( status = rtems_message_queue_create( rtems_build_name( 'M', 'Q', '1', ' '), 100, - 16, + MESSAGE_SIZE, RTEMS_DEFAULT_ATTRIBUTES, &Queue_id ); @@ -89,8 +91,8 @@ rtems_task High_task( Timer_initialize(); (void) rtems_message_queue_broadcast( Queue_id, - (long (*)[4]) Buffer, - 16, + Buffer, + MESSAGE_SIZE, &count ); end_time = Read_timer(); @@ -143,8 +145,8 @@ rtems_task Low_task( for ( index=1 ; index <= OPERATION_COUNT ; index++ ) (void) rtems_message_queue_broadcast( Queue_id, - (long (*)[4]) Buffer, - 16, + Buffer, + MESSAGE_SIZE, &count ); end_time = Read_timer(); @@ -190,8 +192,8 @@ rtems_task Preempt_task( Timer_initialize(); (void) rtems_message_queue_broadcast( Queue_id, - (long (*)[4]) Buffer, - 16, + Buffer, + MESSAGE_SIZE, &count );