summaryrefslogtreecommitdiffstats
path: root/testsuites/psxtests/psxmsgq01/init.c
diff options
context:
space:
mode:
authorSebastian Huber <sebastian.huber@embedded-brains.de>2016-05-24 07:40:18 +0200
committerSebastian Huber <sebastian.huber@embedded-brains.de>2016-05-24 15:37:10 +0200
commit4b623d655bb4f4853a6ce385ae17e505dddbe7ce (patch)
tree2c10939f3fe13e31f37c842e9f73eef7a384b293 /testsuites/psxtests/psxmsgq01/init.c
parent7088340957bbdc288016a98234a78993614e95d6 (diff)
downloadrtems-4b623d655bb4f4853a6ce385ae17e505dddbe7ce.tar.bz2
score: Fix blocking _CORE_message_queue_Submit()
Close #2718.
Diffstat (limited to 'testsuites/psxtests/psxmsgq01/init.c')
-rw-r--r--testsuites/psxtests/psxmsgq01/init.c77
1 files changed, 77 insertions, 0 deletions
diff --git a/testsuites/psxtests/psxmsgq01/init.c b/testsuites/psxtests/psxmsgq01/init.c
index 0c34cd972b..3243a40c3c 100644
--- a/testsuites/psxtests/psxmsgq01/init.c
+++ b/testsuites/psxtests/psxmsgq01/init.c
@@ -1259,6 +1259,82 @@ void verify_mq_send(void)
}
}
+static void *receive_maxmsg_plus_one( void *arg )
+{
+ mqd_t mq;
+ const Test_Message_t *m;
+ int i;
+
+ mq = Test_q[ BLOCKING ].mq;
+ m = &Predefined_Msgs[ 0 ];
+
+ for ( i = 0; i < MAXMSG + 1; ++i ) {
+ Test_Message_t a;
+ unsigned prio;
+ ssize_t n;
+
+ n = mq_receive( mq, &a.msg[0], sizeof(a.msg), &prio);
+ rtems_test_assert( n == m->size );
+ rtems_test_assert( prio == m->priority );
+ rtems_test_assert( memcmp( &a.msg[0], &m->msg[0], (size_t) n ) == 0 );
+ }
+
+ return arg;
+}
+
+static void verify_blocking_mq_timedsend( void )
+{
+ mqd_t mq;
+ const Test_Message_t *m;
+ int status;
+ struct timespec timeout;
+ pthread_t thread;
+ void *exit_value;
+ rtems_status_code sc;
+
+ Start_Test( "verify_blocking_mq_timedsend" );
+
+ mq = Test_q[ BLOCKING ].mq;
+ m = &Predefined_Msgs[ 0 ];
+
+ /*
+ * Create and suspend the receive thread early so that we don't overwrite the
+ * ETIMEDOUT in executing->Wait.return_code. This verifies the succesful
+ * mq_timedreceive() later.
+ */
+
+ status = pthread_create( &thread, NULL, receive_maxmsg_plus_one, &thread );
+ fatal_posix_service_status( status, 0, "pthread_create" );
+
+ sc = rtems_task_suspend( thread );
+ fatal_directive_status( sc, RTEMS_SUCCESSFUL, "rtems_task_suspend" );
+
+ do {
+ status = clock_gettime( CLOCK_REALTIME, &timeout );
+ fatal_posix_service_status( status, 0, "clock_gettime" );
+ ++timeout.tv_sec;
+
+ status = mq_timedsend( mq, m->msg, m->size , m->priority, &timeout );
+ } while ( status == 0 );
+
+ fatal_posix_service_status_errno( status, ETIMEDOUT, "mq_timedsend");
+
+ sc = rtems_task_resume( thread );
+ fatal_directive_status( sc, RTEMS_SUCCESSFUL, "rtems_task_restart" );
+
+ status = clock_gettime( CLOCK_REALTIME, &timeout );
+ fatal_posix_service_status( status, 0, "clock_gettime" );
+ ++timeout.tv_sec;
+
+ status = mq_timedsend( mq, m->msg, m->size , m->priority, &timeout );
+ fatal_posix_service_status( status, 0, "mq_timedsend" );
+
+ exit_value = NULL;
+ status = pthread_join( thread, &exit_value );
+ fatal_posix_service_status( status, 0, "pthread_join" );
+ rtems_test_assert( exit_value == &thread );
+}
+
void *POSIX_Init(
void *argument
)
@@ -1267,6 +1343,7 @@ void *POSIX_Init(
validate_mq_open_error_codes( );
open_test_queues();
+ verify_blocking_mq_timedsend();
validate_mq_unlink_error_codes();
validate_mq_close_error_codes();
verify_unlink_functionality();