From 12f93fbb13d37e6cc16149c4bbac1590e9b29a29 Mon Sep 17 00:00:00 2001 From: Sebastian Huber Date: Mon, 27 Jul 2015 13:19:17 +0200 Subject: score: Add thread queue for self-contained objects --- cpukit/score/src/threadq.c | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) (limited to 'cpukit/score/src/threadq.c') diff --git a/cpukit/score/src/threadq.c b/cpukit/score/src/threadq.c index fc81409924..372a07d64c 100644 --- a/cpukit/score/src/threadq.c +++ b/cpukit/score/src/threadq.c @@ -22,6 +22,42 @@ #include #include +#if HAVE_STRUCT__THREAD_QUEUE_QUEUE + +RTEMS_STATIC_ASSERT( + offsetof( Thread_queue_Syslock_queue, Queue.heads ) + == offsetof( struct _Thread_queue_Queue, _heads ), + THREAD_QUEUE_SYSLOCK_QUEUE_HEADS +); + +RTEMS_STATIC_ASSERT( +#if defined(RTEMS_SMP) + offsetof( Thread_queue_Syslock_queue, Queue.Lock.next_ticket ) +#else + offsetof( Thread_queue_Syslock_queue, reserved[ 0 ] ) +#endif + == offsetof( struct _Thread_queue_Queue, _Lock._next_ticket ), + THREAD_QUEUE_SYSLOCK_QUEUE_NEXT_TICKET +); + +RTEMS_STATIC_ASSERT( +#if defined(RTEMS_SMP) + offsetof( Thread_queue_Syslock_queue, Queue.Lock.now_serving ) +#else + offsetof( Thread_queue_Syslock_queue, reserved[ 1 ] ) +#endif + == offsetof( struct _Thread_queue_Queue, _Lock._now_serving ), + THREAD_QUEUE_SYSLOCK_QUEUE_NOW_SERVING +); + +RTEMS_STATIC_ASSERT( + sizeof( Thread_queue_Syslock_queue ) + == sizeof( struct _Thread_queue_Queue ), + THREAD_QUEUE_SYSLOCK_QUEUE_SIZE +); + +#endif /* HAVE_STRUCT__THREAD_QUEUE_QUEUE */ + RBTree_Compare_result _Thread_queue_Compare_priority( const RBTree_Node *left, const RBTree_Node *right -- cgit v1.2.3