[PATCH] RMS scheduler overrun handling example

Kuan-Hsun Chen c0066c at gmail.com
Fri Dec 9 16:40:04 UTC 2016


---
 testsuites/sptests/Makefile.am                 |   2 +
 testsuites/sptests/configure.ac                |   1 +
 testsuites/sptests/sprmsched01/Makefile.am     |  21 +++++
 testsuites/sptests/sprmsched01/init.c          |  69 ++++++++++++++++
 testsuites/sptests/sprmsched01/sprmsched01.doc |  33 ++++++++
 testsuites/sptests/sprmsched01/sprmsched01.scn |  48 ++++++++++++
 testsuites/sptests/sprmsched01/system.h        |  64 +++++++++++++++
 testsuites/sptests/sprmsched01/tasks.c         | 104 +++++++++++++++++++++++++
 8 files changed, 342 insertions(+)
 create mode 100644 testsuites/sptests/sprmsched01/Makefile.am
 create mode 100644 testsuites/sptests/sprmsched01/init.c
 create mode 100644 testsuites/sptests/sprmsched01/sprmsched01.doc
 create mode 100644 testsuites/sptests/sprmsched01/sprmsched01.scn
 create mode 100644 testsuites/sptests/sprmsched01/system.h
 create mode 100644 testsuites/sptests/sprmsched01/tasks.c

diff --git a/testsuites/sptests/Makefile.am b/testsuites/sptests/Makefile.am
index 54a4de7..4281abb 100644
--- a/testsuites/sptests/Makefile.am
+++ b/testsuites/sptests/Makefile.am
@@ -37,6 +37,7 @@ _SUBDIRS += spfatal29
 _SUBDIRS += spmutex01
 _SUBDIRS += spextensions01
 _SUBDIRS += spsysinit01
+_SUBDIRS += sprmsched01
 if HAS_SMP
 else
 _SUBDIRS += sp29
@@ -56,6 +57,7 @@ _SUBDIRS += sptimecounter03
 _SUBDIRS += spatomic01
 _SUBDIRS += spintrcritical22
 _SUBDIRS += spsem03
+_SUBDIRS += spresource01
 _SUBDIRS += spmrsp01
 _SUBDIRS += spscheduler01
 _SUBDIRS += spprofiling01
diff --git a/testsuites/sptests/configure.ac b/testsuites/sptests/configure.ac
index 76d60e3..8a55aef 100644
--- a/testsuites/sptests/configure.ac
+++ b/testsuites/sptests/configure.ac
@@ -255,5 +255,6 @@ sptimer_err02/Makefile
 spcpuset01/Makefile
 spregion_err01/Makefile
 sppartition_err01/Makefile
+sprmsched01/Makefile
 ])
 AC_OUTPUT
diff --git a/testsuites/sptests/sprmsched01/Makefile.am b/testsuites/sptests/sprmsched01/Makefile.am
new file mode 100644
index 0000000..f837b52
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/Makefile.am
@@ -0,0 +1,21 @@
+
+rtems_tests_PROGRAMS = sprmsched01
+sprmsched01_SOURCES = init.c tasks.c system.h
+	
+dist_rtems_tests_DATA = sprmsched01.scn 
+dist_rtems_tests_DATA += sprmsched01.doc
+
+include $(RTEMS_ROOT)/make/custom/@RTEMS_BSP at .cfg
+include $(top_srcdir)/../automake/compile.am
+include $(top_srcdir)/../automake/leaf.am
+
+AM_CPPFLAGS += -I$(top_srcdir)/../support/include
+
+LINK_OBJS = $(sprmsched01_OBJECTS)
+LINK_LIBS = $(sprmsched01_LDLIBS)
+
+sprmsched01$(EXEEXT): $(sprmsched01_OBJECTS) $(sprmsched01_DEPENDENCIES)
+	@rm -f sprmsched01$(EXEEXT)
+	$(make-exe)
+
+include $(top_srcdir)/../automake/local.am
diff --git a/testsuites/sptests/sprmsched01/init.c b/testsuites/sptests/sprmsched01/init.c
new file mode 100644
index 0000000..7fd3e87
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/init.c
@@ -0,0 +1,69 @@
+/**
+ * @file sprmsched01/init.c
+ *
+ * @brief A init task body for sprmsched01 example.
+ *
+ */
+
+/*
+ *  COPYRIGHT (c) 2016 Kuan-Hsun Chen, TU Dortmund University (TUDo).
+ *
+ *  The license and distribution terms for this file may be
+ *  found in the file LICENSE in this distribution or at
+ *  http://www.rtems.com/license/LICENSE.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#define CONFIGURE_INIT
+#include "system.h"
+
+#include <rtems/rtems/tasksimpl.h>
+#include <rtems/test.h>
+#include <rtems/status-checks.h>
+
+const char rtems_test_name[] = "Rate Monotonic 01";
+
+/* Global variables */
+rtems_id   Task_id[ 2 ];         /* array of task ids */
+rtems_name Task_name[ 2 ];       /* array of task names */
+uint32_t tick_per_second;        /* time reference */
+int testnumber = 11;                  /* stop condition */
+
+rtems_task_priority Prio[3] = {0, 2, 5};
+
+rtems_task Init(
+	rtems_task_argument argument
+)
+{
+  rtems_status_code status;
+  TEST_BEGIN();
+
+
+  tick_per_second = rtems_clock_get_ticks_per_second();
+  printf("\nTicks per second in your system: %" PRIu32 "\n", tick_per_second);
+
+  Task_name[ 1 ] = rtems_build_name( 'T', 'A', '1', ' ' );
+  Task_name[ 2 ] = rtems_build_name( 'T', 'A', '2', ' ' );
+
+  /* Create two tasks */
+  for ( int index = 1; index <= 2; index++){
+    status = rtems_task_create(
+      Task_name[ index ], Prio[index], RTEMS_MINIMUM_STACK_SIZE, RTEMS_DEFAULT_MODES,
+      RTEMS_DEFAULT_ATTRIBUTES, &Task_id[ index ]
+    );
+    directive_failed( status, "rtems_task_create loop");
+  }
+
+
+  /* After creating the periods for tasks, start to run them sequencially. */
+  for ( int index = 1; index <= 2; index++){
+    status = rtems_task_start( Task_id[ index ], Task_1, index);
+    directive_failed( status, "rtems_task_start loop");
+  }
+  status = rtems_task_delete( RTEMS_SELF );
+  directive_failed( status, "rtems_task_delete of RTEMS_SELF" );
+}
+
diff --git a/testsuites/sptests/sprmsched01/sprmsched01.doc b/testsuites/sptests/sprmsched01/sprmsched01.doc
new file mode 100644
index 0000000..7153af8
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/sprmsched01.doc
@@ -0,0 +1,33 @@
+#
+#   COPYRIGHT (c) 2016 Kuan-Hsun Chen, TU Dortmund University (TUDo).
+# 
+#   The license and distribution terms for this file may be
+#   found in the file LICENSE in this distribution or at
+#   http://www.rtems.com/license/LICENSE.
+#
+
+This file describes the directives and concepts tested by this test set.
+
+test set name: sprmsched01
+
+directives:
+
+  - rtems_rate_monotonic_report_statistics()
+  - rtems_rate_monotonic_period()
+  - rtems_rate_monotonic_Postponed_num()
+  - _Rate_monotonic_Timeout()
+  - _Rate_monotonic_Renew_deadline()
+  - _Rate_monotonic_Release_postponedjob()
+  - _Rate_monotonic_Block_while_expired()
+
+
+concepts:
+
+  - Verify that watchdog deadline is renewed on time without shift via
+    _Rate_monotonic_Renew_deadline().
+  - Verify that postponed jobs are released with a correct number via
+    _Rate_monotonic_Release_postponedjob().
+  - Verify that rtems_rate_monotonic_report_statistics() reports correct number 
+    of deadline misses.
+  - Verify that rtems_rate_monotonic_period() and 
+    _Rate_monotonic_Block_while_expired() are operational.
diff --git a/testsuites/sptests/sprmsched01/sprmsched01.scn b/testsuites/sptests/sprmsched01/sprmsched01.scn
new file mode 100644
index 0000000..3d3d2d9
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/sprmsched01.scn
@@ -0,0 +1,48 @@
+
+
+*** BEGIN OF TEST Rate Monotonic 01 ***
+
+Ticks per second in your system: 1000
+Job 1 Task 1 starts at tick 13.
+                                        Job 1 Task 1 ends at tick 6021.
+Job 1 Task 2 starts at tick 6022.
+                                        Job 1 Task 2 ends at tick 7024.
+Job 2 Task 2 starts at tick 8022.
+                                        Job 2 Task 2 ends at tick 9023.
+Job 2 Task 1 starts at tick 10013.
+                                        Job 2 Task 1 ends at tick 16021.
+Job 3 Task 2 starts at tick 16023.
+                                        Job 3 Task 2 ends at tick 17024.
+Job 4 Task 2 starts at tick 17025.
+                                        Job 4 Task 2 ends at tick 18026.
+Job 5 Task 2 starts at tick 18026.
+                                        Job 5 Task 2 ends at tick 19027.
+Job 6 Task 2 starts at tick 19028.
+                                        Job 6 Task 2 ends at tick 20029.
+Job 7 Task 2 starts at tick 20029.
+                                        Job 7 Task 2 ends at tick 21031.
+Job 8 Task 2 starts at tick 21031.
+                                        Job 8 Task 2 ends at tick 22033.
+Job 9 Task 2 starts at tick 22033.
+                                        Job 9 Task 2 ends at tick 23035.
+Job 10 Task 2 starts at tick 24022.
+                                        Job 10 Task 2 ends at tick 25023.
+Job 11 Task 2 starts at tick 26022.
+                                        Job 11 Task 2 ends at tick 27024.
+Job 12 Task 2 starts at tick 28022.
+                                        Job 12 Task 2 ends at tick 29024.
+Job 13 Task 2 starts at tick 30022.
+                                        Job 13 Task 2 ends at tick 31023.
+Job 14 Task 2 starts at tick 32022.
+                                        Job 14 Task 2 ends at tick 33023.
+Job 15 Task 2 starts at tick 34022.
+                                        Job 15 Task 2 ends at tick 35023.
+Job 16 Task 2 starts at tick 36022.
+                                        Job 16 Task 2 ends at tick 37023.
+Period information by period
+--- CPU times are in seconds ---
+--- Wall times are in seconds ---
+   ID     OWNER COUNT MISSED          CPU TIME                  WALL TIME
+                                    MIN/MAX/AVG                MIN/MAX/AVG
+0x42010002 TA2     15      6 1.001686/7.012146/2.404131 1.001698/13.013378/5.204723
+*** END OF TEST Rate Monotonic 01 ***
diff --git a/testsuites/sptests/sprmsched01/system.h b/testsuites/sptests/sprmsched01/system.h
new file mode 100644
index 0000000..e4c6ade
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/system.h
@@ -0,0 +1,64 @@
+/**
+ * @file sprmsched01/system.h
+ *
+ * @brief sprmsched01 example header
+ */
+
+/*
+ *  COPYRIGHT (c) 1989-2007.
+ *  On-Line Applications Research Corporation (OAR).
+ *
+ *  COPYRIGHT (c) 2016 Kuan-Hsun Chen, TU Dortmund University (TUDo).
+ *
+ *  The license and distribution terms for this file may be
+ *  found in the file LICENSE in this distribution or at
+ *  http://www.rtems.com/license/LICENSE.
+ */
+
+ 
+#include <inttypes.h>
+#include <rtems.h>
+
+#include <tmacros.h>
+
+/* function prototypes */
+
+rtems_task Init(
+  rtems_task_argument argument
+);
+
+rtems_task Task_1(
+  rtems_task_argument argument
+);
+
+rtems_task Task_2(
+  rtems_task_argument argument
+);
+
+/*
+ *  Keep the names and IDs in global variables so another task can use them.
+ */ 
+
+extern rtems_id   Task_id[ 2 ];         /* array of task ids */
+extern rtems_name Task_name[ 2 ];       /* array of task names */
+extern uint32_t tick_per_second;        /* time reference */
+extern int testnumber;                  /* stop condition */
+
+/* configuration information */
+
+#include <bsp.h> /* for device driver prototypes */
+
+#define CONFIGURE_APPLICATION_NEEDS_CONSOLE_DRIVER
+#define CONFIGURE_APPLICATION_NEEDS_CLOCK_DRIVER
+#define CONFIGURE_MICROSECONDS_PER_TICK     1000   // NB: 10 and lower gives system failure for erc32 simulator
+#define CONFIGURE_MAXIMUM_TASKS             3
+#define CONFIGURE_MAXIMUM_SEMAPHORES        1
+#define CONFIGURE_MAXIMUM_PRIORITY          15
+#define CONFIGURE_EXTRA_TASK_STACKS         (20 * RTEMS_MINIMUM_STACK_SIZE)
+#define CONFIGURE_MAXIMUM_PERIODS           3
+
+#define CONFIGURE_RTEMS_INIT_TASKS_TABLE
+
+#include <rtems/confdefs.h>
+
+/* end of include file */
diff --git a/testsuites/sptests/sprmsched01/tasks.c b/testsuites/sptests/sprmsched01/tasks.c
new file mode 100644
index 0000000..8cb06e6
--- /dev/null
+++ b/testsuites/sptests/sprmsched01/tasks.c
@@ -0,0 +1,104 @@
+/**
+ * @file sprmsched01/tasks.c
+ *
+ * @brief A heuristic example to demonstrate how the postponed jobs are handled.
+ *
+ * Given two tasks with implicit deadline under fixed-priority scheudling. 
+ * Task 1 has (6, 10) and task 2 has (1, 2), where (execution time, deadline/period).
+ * To force deadline misses, we reverse the rate-monotonic priority assignment 
+ * and only execute the highest priority task twice. 
+ * In the original implementation in v4.11, no matter how many periods are 
+ * expired, RMS manager only releases a job with a shifted deadline assignment 
+ * in the watchdog.
+ *
+ */
+
+/*
+ *  COPYRIGHT (c) 2016 Kuan-Hsun Chen, TU Dortmund University (TUDo).
+ *
+ *  The license and distribution terms for this file may be
+ *  found in the file LICENSE in this distribution or at
+ *  http://www.rtems.com/license/LICENSE.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "system.h"
+
+/* CPU usage and Rate monotonic manger statistics */
+#include "rtems/cpuuse.h"
+#include "rtems/counter.h"
+
+/* Periods for the various tasks [ticks] */
+uint32_t Periods[3] = {0, 10000, 2000};
+uint32_t Iterations[3] = {0, 6000, 1000};
+uint32_t tsk_counter[3] = {0, 0, 0};
+
+/**
+ * @brief Task 1 body
+ */
+rtems_task Task_1(
+  rtems_task_argument argument
+)
+{
+  rtems_status_code status;
+  rtems_id          RM_period;
+  rtems_id          selfid=rtems_task_self();
+  int               start, end, flag=0;
+  rtems_counter_ticks t0;
+  t0 = rtems_counter_nanoseconds_to_ticks(1000000); //1ms ticks counter
+  /*create period*/
+  status = rtems_rate_monotonic_create( argument, &RM_period );
+  directive_failed( status, "rtems_rate_monotonic_create" );
+
+  switch ( argument ) {    
+    case 1:
+    case 2:
+      while ( FOREVER ) {
+        status = rtems_rate_monotonic_period( RM_period, Periods[argument]);
+        //directive_failed( status, "rtems_rate_monotonic_period" ); let TIMEOUT pass
+        if(argument == 2 && flag == 0 && status == RTEMS_TIMEOUT){
+          flag = 1;
+          printf("RTEMS_TIMEOUT\n");
+        }else if(flag == 1 && status == RTEMS_SUCCESSFUL){
+          flag = 0;
+          printf("RTEMS_SUCCESSFUL\n");
+        }
+                
+        start = rtems_clock_get_ticks_since_boot();    
+        if (argument == 2)
+          printf("Job %d Task %d starts at tick %d.\n", tsk_counter[argument]+1, argument, start);
+        else
+          printf("Task %d starts at tick %d.\n", argument, start);
+        for(int i=0; i<Iterations[argument]; i++){
+          rtems_counter_delay_ticks(t0);
+        }
+        end = rtems_clock_get_ticks_since_boot();
+        printf("					Job %d Task %d ends at tick %d.\n", tsk_counter[argument]+1, argument, end);
+        if( argument == 2 ){
+          if(tsk_counter[ argument ] == testnumber){
+            //rtems_rate_monotonic_report_statistics();
+            TEST_END();
+            status = rtems_rate_monotonic_delete(RM_period);
+            directive_failed( status, "rtems_rate_monotonic_delete" );
+            rtems_test_exit(0);
+          }
+        }             
+
+        tsk_counter[ argument ]+=1;
+        if ( argument == 1 ){
+          if( tsk_counter[ argument ] == 2 ){
+				    status = rtems_rate_monotonic_delete(RM_period);
+            directive_failed( status, "rtems_rate_monotonic_delete" );
+            status = rtems_task_delete(selfid);
+            directive_failed( status, "rtems_task_delete" );
+          }    
+        }
+      }
+      break;
+    
+  }
+}
+
-- 
1.9.1



More information about the devel mailing list