1 files changed, 28 insertions, 28 deletions

diff --git a/os/rt/src/chschd.c b/os/rt/src/chschd.c
index 82a38941c..fbc84e000 100644
--- a/os/rt/src/chschd.c
+++ b/os/rt/src/chschd.c
@@ -87,12 +87,12 @@ void queue_prio_insert(thread_t *tp, threads_queue_t *tqp) {
 

   thread_t *cp = (thread_t *)tqp;

   do {

-    cp = cp->next;

+    cp = cp->queue.next;

   } while ((cp != (thread_t *)tqp) && (cp->prio >= tp->prio));

-  tp->next = cp;

-  tp->prev = cp->prev;

-  tp->prev->next = tp;

-  cp->prev = tp;

+  tp->queue.next             = cp;

+  tp->queue.prev             = cp->queue.prev;

+  tp->queue.prev->queue.next = tp;

+  cp->queue.prev             = tp;

 }

 

 /**

@@ -105,10 +105,10 @@ void queue_prio_insert(thread_t *tp, threads_queue_t *tqp) {
  */

 void queue_insert(thread_t *tp, threads_queue_t *tqp) {

 

-  tp->next = (thread_t *)tqp;

-  tp->prev = tqp->prev;

-  tp->prev->next = tp;

-  tqp->prev = tp;

+  tp->queue.next             = (thread_t *)tqp;

+  tp->queue.prev             = tqp->prev;

+  tp->queue.prev->queue.next = tp;

+  tqp->prev                  = tp;

 }

 

 /**

@@ -124,8 +124,8 @@ void queue_insert(thread_t *tp, threads_queue_t *tqp) {
 thread_t *queue_fifo_remove(threads_queue_t *tqp) {

   thread_t *tp = tqp->next;

 

-  tqp->next = tp->next;

-  tqp->next->prev = (thread_t *)tqp;

+  tqp->next             = tp->queue.next;

+  tqp->next->queue.prev = (thread_t *)tqp;

 

   return tp;

 }

@@ -143,8 +143,8 @@ thread_t *queue_fifo_remove(threads_queue_t *tqp) {
 thread_t *queue_lifo_remove(threads_queue_t *tqp) {

   thread_t *tp = tqp->prev;

 

-  tqp->prev = tp->prev;

-  tqp->prev->next = (thread_t *)tqp;

+  tqp->prev             = tp->queue.prev;

+  tqp->prev->queue.next = (thread_t *)tqp;

 

   return tp;

 }

@@ -161,8 +161,8 @@ thread_t *queue_lifo_remove(threads_queue_t *tqp) {
  */

 thread_t *queue_dequeue(thread_t *tp) {

 

-  tp->prev->next = tp->next;

-  tp->next->prev = tp->prev;

+  tp->queue.prev->queue.next = tp->queue.next;

+  tp->queue.next->queue.prev = tp->queue.prev;

 

   return tp;

 }

@@ -177,8 +177,8 @@ thread_t *queue_dequeue(thread_t *tp) {
  */

 void list_insert(thread_t *tp, threads_list_t *tlp) {

 

-  tp->next = tlp->next;

-  tlp->next = tp;

+  tp->queue.next = tlp->next;

+  tlp->next      = tp;

 }

 

 /**

@@ -193,7 +193,7 @@ void list_insert(thread_t *tp, threads_list_t *tlp) {
 thread_t *list_remove(threads_list_t *tlp) {

 

   thread_t *tp = tlp->next;

-  tlp->next = tp->next;

+  tlp->next = tp->queue.next;

 

   return tp;

 }

@@ -227,13 +227,13 @@ thread_t *chSchReadyI(thread_t *tp) {
   tp->state = CH_STATE_READY;

   cp = (thread_t *)&ch.rlist.queue;

   do {

-    cp = cp->next;

+    cp = cp->queue.next;

   } while (cp->prio >= tp->prio);

   /* Insertion on prev.*/

-  tp->next = cp;

-  tp->prev = cp->prev;

-  tp->prev->next = tp;

-  cp->prev = tp;

+  tp->queue.next             = cp;

+  tp->queue.prev             = cp->queue.prev;

+  tp->queue.prev->queue.next = tp;

+  cp->queue.prev             = tp;

 

   return tp;

 }

@@ -266,13 +266,13 @@ thread_t *chSchReadyAheadI(thread_t *tp) {
   tp->state = CH_STATE_READY;

   cp = (thread_t *)&ch.rlist.queue;

   do {

-    cp = cp->next;

+    cp = cp->queue.next;

   } while (cp->prio > tp->prio);

   /* Insertion on prev.*/

-  tp->next = cp;

-  tp->prev = cp->prev;

-  tp->prev->next = tp;

-  cp->prev = tp;

+  tp->queue.next             = cp;

+  tp->queue.prev             = cp->queue.prev;

+  tp->queue.prev->queue.next = tp;

+  cp->queue.prev             = tp;

 

   return tp;

 }