[PATCH 4/5] score: Get rid of mp_id parameter
Sebastian Huber
sebastian.huber at embedded-brains.de
Tue May 24 12:07:14 UTC 2016
Get rid of the mp_id parameter used for some thread queue methods. Use
THREAD_QUEUE_QUEUE_TO_OBJECT() instead.
---
cpukit/libnetworking/rtems/rtems_glue.c | 1 -
cpukit/posix/src/condsignalsupp.c | 1 -
cpukit/posix/src/condwaitsupp.c | 1 -
cpukit/posix/src/mqueuedeletesupp.c | 1 -
cpukit/posix/src/mqueuesendsupp.c | 1 -
cpukit/posix/src/mutexsetprioceiling.c | 1 -
cpukit/posix/src/mutexunlock.c | 1 -
cpukit/posix/src/pbarrierwait.c | 1 -
cpukit/posix/src/semaphoredeletesupp.c | 1 -
cpukit/posix/src/sempost.c | 1 -
cpukit/rtems/src/barrierdelete.c | 2 +-
cpukit/rtems/src/barrierrelease.c | 1 -
cpukit/rtems/src/barrierwait.c | 1 -
cpukit/rtems/src/msgqbroadcast.c | 1 -
cpukit/rtems/src/msgqdelete.c | 1 -
cpukit/rtems/src/msgqsend.c | 1 -
cpukit/rtems/src/msgqurgent.c | 1 -
cpukit/rtems/src/semdelete.c | 2 --
cpukit/rtems/src/semflush.c | 2 --
cpukit/rtems/src/semrelease.c | 2 --
cpukit/score/include/rtems/score/corebarrierimpl.h | 13 --------
cpukit/score/include/rtems/score/coremsgimpl.h | 26 ---------------
cpukit/score/include/rtems/score/coremuteximpl.h | 6 ----
cpukit/score/include/rtems/score/coresemimpl.h | 11 -------
cpukit/score/include/rtems/score/thread.h | 6 ----
cpukit/score/include/rtems/score/threadqimpl.h | 38 +++++-----------------
cpukit/score/src/apimutexunlock.c | 1 -
cpukit/score/src/condition.c | 1 -
cpukit/score/src/corebarrierrelease.c | 2 --
cpukit/score/src/corebarrierwait.c | 3 +-
cpukit/score/src/coremsgbroadcast.c | 2 --
cpukit/score/src/coremsgclose.c | 2 --
cpukit/score/src/coremsgseize.c | 1 -
cpukit/score/src/coremsgsubmit.c | 2 --
cpukit/score/src/coremutexsurrender.c | 4 +--
cpukit/score/src/corerwlockrelease.c | 1 -
cpukit/score/src/futex.c | 1 -
cpukit/score/src/mpci.c | 2 +-
cpukit/score/src/mutex.c | 3 +-
cpukit/score/src/semaphore.c | 1 -
cpukit/score/src/threadqenqueue.c | 24 +++++---------
cpukit/score/src/threadqflush.c | 4 +--
cpukit/score/src/threadrestart.c | 1 -
43 files changed, 23 insertions(+), 156 deletions(-)
diff --git a/cpukit/libnetworking/rtems/rtems_glue.c b/cpukit/libnetworking/rtems/rtems_glue.c
index b360b07..9ece2b1 100644
--- a/cpukit/libnetworking/rtems/rtems_glue.c
+++ b/cpukit/libnetworking/rtems/rtems_glue.c
@@ -413,7 +413,6 @@ rtems_bsdnet_semaphore_release (void)
status = _CORE_mutex_Surrender (
&the_networkSemaphore->Core_control.mutex,
NULL,
- 0,
&lock_context
);
if (status != CORE_MUTEX_STATUS_SUCCESSFUL)
diff --git a/cpukit/posix/src/condsignalsupp.c b/cpukit/posix/src/condsignalsupp.c
index c625b3a..38aa053 100644
--- a/cpukit/posix/src/condsignalsupp.c
+++ b/cpukit/posix/src/condsignalsupp.c
@@ -57,7 +57,6 @@ int _POSIX_Condition_variables_Signal_support(
POSIX_CONDITION_VARIABLES_TQ_OPERATIONS,
the_thread,
NULL,
- 0,
&lock_context
);
} else {
diff --git a/cpukit/posix/src/condwaitsupp.c b/cpukit/posix/src/condwaitsupp.c
index 4f0ac3c..11b0587 100644
--- a/cpukit/posix/src/condwaitsupp.c
+++ b/cpukit/posix/src/condwaitsupp.c
@@ -103,7 +103,6 @@ int _POSIX_Condition_variables_Wait_support(
core_mutex_status = _CORE_mutex_Surrender(
&the_mutex->Mutex,
NULL,
- 0,
&lock_context
);
_Assert( core_mutex_status == CORE_MUTEX_STATUS_SUCCESSFUL );
diff --git a/cpukit/posix/src/mqueuedeletesupp.c b/cpukit/posix/src/mqueuedeletesupp.c
index 61f330a..485136c 100644
--- a/cpukit/posix/src/mqueuedeletesupp.c
+++ b/cpukit/posix/src/mqueuedeletesupp.c
@@ -29,7 +29,6 @@ void _POSIX_Message_queue_Delete(
_CORE_message_queue_Close(
&the_mq->Message_queue,
NULL, /* no MP support */
- 0,
lock_context
);
_POSIX_Message_queue_Free( the_mq );
diff --git a/cpukit/posix/src/mqueuesendsupp.c b/cpukit/posix/src/mqueuesendsupp.c
index 0d9974a..1053df9 100644
--- a/cpukit/posix/src/mqueuesendsupp.c
+++ b/cpukit/posix/src/mqueuesendsupp.c
@@ -98,7 +98,6 @@ int _POSIX_Message_queue_Send_support(
msg_ptr,
msg_len,
NULL,
- 0,
_POSIX_Message_queue_Priority_to_core( msg_prio ),
do_wait,
timeout,
diff --git a/cpukit/posix/src/mutexsetprioceiling.c b/cpukit/posix/src/mutexsetprioceiling.c
index 40b970d..f29c0ad 100644
--- a/cpukit/posix/src/mutexsetprioceiling.c
+++ b/cpukit/posix/src/mutexsetprioceiling.c
@@ -74,7 +74,6 @@ int pthread_mutex_setprioceiling(
_CORE_mutex_Surrender(
&the_mutex->Mutex,
NULL,
- 0,
&lock_context
);
return 0;
diff --git a/cpukit/posix/src/mutexunlock.c b/cpukit/posix/src/mutexunlock.c
index f9dec82..94fcc63 100644
--- a/cpukit/posix/src/mutexunlock.c
+++ b/cpukit/posix/src/mutexunlock.c
@@ -43,7 +43,6 @@ int pthread_mutex_unlock(
status = _CORE_mutex_Surrender(
&the_mutex->Mutex,
NULL,
- 0,
&lock_context
);
return _POSIX_Mutex_Translate_core_mutex_return_code( status );
diff --git a/cpukit/posix/src/pbarrierwait.c b/cpukit/posix/src/pbarrierwait.c
index 150ece7..adfd40d 100644
--- a/cpukit/posix/src/pbarrierwait.c
+++ b/cpukit/posix/src/pbarrierwait.c
@@ -57,7 +57,6 @@ int pthread_barrier_wait(
true,
0,
NULL,
- 0,
&lock_context
);
return _POSIX_Barrier_Translate_core_barrier_return_code(
diff --git a/cpukit/posix/src/semaphoredeletesupp.c b/cpukit/posix/src/semaphoredeletesupp.c
index 7c23bb8..c205b12 100644
--- a/cpukit/posix/src/semaphoredeletesupp.c
+++ b/cpukit/posix/src/semaphoredeletesupp.c
@@ -30,7 +30,6 @@ void _POSIX_Semaphore_Delete(
_CORE_semaphore_Destroy(
&the_semaphore->Semaphore,
NULL,
- 0,
lock_context
);
_POSIX_Semaphore_Free( the_semaphore );
diff --git a/cpukit/posix/src/sempost.c b/cpukit/posix/src/sempost.c
index 13c0132..313ff3c 100644
--- a/cpukit/posix/src/sempost.c
+++ b/cpukit/posix/src/sempost.c
@@ -38,7 +38,6 @@ int sem_post(
_CORE_semaphore_Surrender(
&the_semaphore->Semaphore,
NULL,
- 0,
&lock_context
);
return 0;
diff --git a/cpukit/rtems/src/barrierdelete.c b/cpukit/rtems/src/barrierdelete.c
index d742327..05d6a3f 100644
--- a/cpukit/rtems/src/barrierdelete.c
+++ b/cpukit/rtems/src/barrierdelete.c
@@ -37,7 +37,7 @@ rtems_status_code rtems_barrier_delete(
_CORE_barrier_Acquire_critical( &the_barrier->Barrier, &lock_context );
_Objects_Close( &_Barrier_Information, &the_barrier->Object );
- _CORE_barrier_Flush( &the_barrier->Barrier, NULL, 0, &lock_context );
+ _CORE_barrier_Flush( &the_barrier->Barrier, NULL, &lock_context );
_Barrier_Free( the_barrier );
_Objects_Allocator_unlock();
return RTEMS_SUCCESSFUL;
diff --git a/cpukit/rtems/src/barrierrelease.c b/cpukit/rtems/src/barrierrelease.c
index a60ea89..2c7d222 100644
--- a/cpukit/rtems/src/barrierrelease.c
+++ b/cpukit/rtems/src/barrierrelease.c
@@ -42,7 +42,6 @@ rtems_status_code rtems_barrier_release(
*released = _CORE_barrier_Surrender(
&the_barrier->Barrier,
NULL,
- 0,
&lock_context
);
return RTEMS_SUCCESSFUL;
diff --git a/cpukit/rtems/src/barrierwait.c b/cpukit/rtems/src/barrierwait.c
index d9d3869..7f463aa 100644
--- a/cpukit/rtems/src/barrierwait.c
+++ b/cpukit/rtems/src/barrierwait.c
@@ -44,7 +44,6 @@ rtems_status_code rtems_barrier_wait(
true,
timeout,
NULL,
- 0,
&lock_context
);
return _Barrier_Translate_core_barrier_return_code(
diff --git a/cpukit/rtems/src/msgqbroadcast.c b/cpukit/rtems/src/msgqbroadcast.c
index c5cc3ec..45d9097 100644
--- a/cpukit/rtems/src/msgqbroadcast.c
+++ b/cpukit/rtems/src/msgqbroadcast.c
@@ -54,7 +54,6 @@ rtems_status_code rtems_message_queue_broadcast(
buffer,
size,
_Message_queue_Core_message_queue_mp_support,
- id,
count,
&lock_context
);
diff --git a/cpukit/rtems/src/msgqdelete.c b/cpukit/rtems/src/msgqdelete.c
index ecf7dab..c39cfea 100644
--- a/cpukit/rtems/src/msgqdelete.c
+++ b/cpukit/rtems/src/msgqdelete.c
@@ -53,7 +53,6 @@ rtems_status_code rtems_message_queue_delete(
_CORE_message_queue_Close(
&the_message_queue->message_queue,
_Message_queue_MP_Send_object_was_deleted,
- id,
&lock_context
);
diff --git a/cpukit/rtems/src/msgqsend.c b/cpukit/rtems/src/msgqsend.c
index bc8a673..c306deb 100644
--- a/cpukit/rtems/src/msgqsend.c
+++ b/cpukit/rtems/src/msgqsend.c
@@ -53,7 +53,6 @@ rtems_status_code rtems_message_queue_send(
buffer,
size,
_Message_queue_Core_message_queue_mp_support,
- id,
false, /* sender does not block */
0, /* no timeout */
&lock_context
diff --git a/cpukit/rtems/src/msgqurgent.c b/cpukit/rtems/src/msgqurgent.c
index 2d9cea2..56522a1 100644
--- a/cpukit/rtems/src/msgqurgent.c
+++ b/cpukit/rtems/src/msgqurgent.c
@@ -53,7 +53,6 @@ rtems_status_code rtems_message_queue_urgent(
buffer,
size,
_Message_queue_Core_message_queue_mp_support,
- id,
false, /* sender does not block */
0, /* no timeout */
&lock_context
diff --git a/cpukit/rtems/src/semdelete.c b/cpukit/rtems/src/semdelete.c
index ac8f2dd..cf22838 100644
--- a/cpukit/rtems/src/semdelete.c
+++ b/cpukit/rtems/src/semdelete.c
@@ -101,7 +101,6 @@ rtems_status_code rtems_semaphore_delete(
&the_semaphore->Core_control.mutex,
_CORE_mutex_Was_deleted,
_Semaphore_MP_Send_object_was_deleted,
- id,
&lock_context
);
_CORE_mutex_Destroy( &the_semaphore->Core_control.mutex );
@@ -109,7 +108,6 @@ rtems_status_code rtems_semaphore_delete(
_CORE_semaphore_Destroy(
&the_semaphore->Core_control.semaphore,
_Semaphore_MP_Send_object_was_deleted,
- id,
&lock_context
);
}
diff --git a/cpukit/rtems/src/semflush.c b/cpukit/rtems/src/semflush.c
index c6c294c..73e9ad0 100644
--- a/cpukit/rtems/src/semflush.c
+++ b/cpukit/rtems/src/semflush.c
@@ -56,7 +56,6 @@ rtems_status_code rtems_semaphore_flush( rtems_id id )
&the_semaphore->Core_control.mutex,
_CORE_mutex_Unsatisfied_nowait,
_Semaphore_MP_Send_object_was_deleted,
- id,
&lock_context
);
} else {
@@ -67,7 +66,6 @@ rtems_status_code rtems_semaphore_flush( rtems_id id )
_CORE_semaphore_Flush(
&the_semaphore->Core_control.semaphore,
_Semaphore_MP_Send_object_was_deleted,
- id,
&lock_context
);
}
diff --git a/cpukit/rtems/src/semrelease.c b/cpukit/rtems/src/semrelease.c
index 64d3ae8..c39455c 100644
--- a/cpukit/rtems/src/semrelease.c
+++ b/cpukit/rtems/src/semrelease.c
@@ -59,7 +59,6 @@ rtems_status_code rtems_semaphore_release( rtems_id id )
mutex_status = _CORE_mutex_Surrender(
&the_semaphore->Core_control.mutex,
_Semaphore_Core_mutex_mp_support,
- id,
&lock_context
);
return _Semaphore_Translate_core_mutex_return_code( mutex_status );
@@ -67,7 +66,6 @@ rtems_status_code rtems_semaphore_release( rtems_id id )
semaphore_status = _CORE_semaphore_Surrender(
&the_semaphore->Core_control.semaphore,
_Semaphore_Core_mutex_mp_support,
- id,
&lock_context
);
return _Semaphore_Translate_core_semaphore_return_code( semaphore_status );
diff --git a/cpukit/score/include/rtems/score/corebarrierimpl.h b/cpukit/score/include/rtems/score/corebarrierimpl.h
index cd253b3..d5133cd 100644
--- a/cpukit/score/include/rtems/score/corebarrierimpl.h
+++ b/cpukit/score/include/rtems/score/corebarrierimpl.h
@@ -105,7 +105,6 @@ void _CORE_barrier_Do_seize(
Watchdog_Interval timeout,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -125,7 +124,6 @@ void _CORE_barrier_Do_seize(
* to wait if @a wait is true.
* @param[in] mp_callout is the routine to invoke if the
* thread unblocked is remote
- * @param[in] mp_id is the id of the object being waited upon
*
* @note Status is returned via the thread control block.
*/
@@ -136,7 +134,6 @@ void _CORE_barrier_Do_seize(
wait, \
timeout, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_seize( \
@@ -145,7 +142,6 @@ void _CORE_barrier_Do_seize(
wait, \
timeout, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
@@ -155,7 +151,6 @@ void _CORE_barrier_Do_seize(
wait, \
timeout, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_seize( \
@@ -172,7 +167,6 @@ uint32_t _CORE_barrier_Do_surrender(
Thread_queue_Flush_filter filter,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -186,7 +180,6 @@ uint32_t _CORE_barrier_Do_surrender(
* @param[in] the_barrier is the barrier to surrender
* @param[in] mp_callout is the routine to invoke if the
* thread unblocked is remote
- * @param[in] mp_id is the id of the object for a remote unblock
*
* @retval the number of unblocked threads
*/
@@ -194,21 +187,18 @@ uint32_t _CORE_barrier_Do_surrender(
#define _CORE_barrier_Surrender( \
the_barrier, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_surrender( \
the_barrier, \
_Thread_queue_Flush_default_filter, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
#define _CORE_barrier_Surrender( \
the_barrier, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_surrender( \
@@ -229,21 +219,18 @@ Thread_Control *_CORE_barrier_Was_deleted(
#define _CORE_barrier_Flush( \
the_barrier, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_surrender( \
the_barrier, \
_CORE_barrier_Was_deleted, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
#define _CORE_barrier_Flush( \
the_barrier, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_barrier_Do_surrender( \
diff --git a/cpukit/score/include/rtems/score/coremsgimpl.h b/cpukit/score/include/rtems/score/coremsgimpl.h
index 34f214d..a93da03 100644
--- a/cpukit/score/include/rtems/score/coremsgimpl.h
+++ b/cpukit/score/include/rtems/score/coremsgimpl.h
@@ -132,7 +132,6 @@ void _CORE_message_queue_Do_close(
CORE_message_queue_Control *the_message_queue,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -150,7 +149,6 @@ void _CORE_message_queue_Do_close(
* @param[in] the_message_queue points to the message queue to close
* @param[in] mp_callout is the routine to call for each thread
* that is extracted from the set of waiting threads
- * @param[in] mp_id the object identifier of the message queue object
* @param[in] lock_context The lock context of the
* _CORE_message_queue_Acquire() or _CORE_message_queue_Acquire_critical().
*/
@@ -158,20 +156,17 @@ void _CORE_message_queue_Do_close(
#define _CORE_message_queue_Close( \
the_message_queue, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_message_queue_Do_close( \
the_message_queue, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
#define _CORE_message_queue_Close( \
the_message_queue, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_message_queue_Do_close( \
@@ -223,7 +218,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
size_t size,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
uint32_t *count,
ISR_lock_Context *lock_context
@@ -244,8 +238,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
* @param[in] size is the size of the message being broadcast
* @param[in] mp_callout is the routine to invoke if
* a thread that is unblocked is actually a remote thread.
- * @param[in] mp_id is the RTEMS object Id associated with this message queue.
- * It is used when unblocking a remote thread.
* @param[out] count points to the variable that will contain the
* number of tasks that are sent this message
* @param[in] lock_context The lock context of the interrupt disable.
@@ -258,7 +250,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
buffer, \
size, \
mp_callout, \
- mp_id, \
count, \
lock_context \
) \
@@ -267,7 +258,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
buffer, \
size, \
mp_callout, \
- mp_id, \
count, \
lock_context \
)
@@ -277,7 +267,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
buffer, \
size, \
mp_callout, \
- mp_id, \
count, \
lock_context \
) \
@@ -297,7 +286,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
size_t size,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
CORE_message_queue_Submit_types submit_type,
bool wait,
@@ -320,8 +308,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
* @param[in] size is the size of the message being send
* @param[in] mp_callout is the routine to invoke if
* a thread that is unblocked is actually a remote thread.
- * @param[in] mp_id is the RTEMS object Id associated with this message queue.
- * It is used when unblocking a remote thread.
* @param[in] submit_type determines whether the message is prepended,
* appended, or enqueued in priority order.
* @param[in] wait indicates whether the calling thread is willing to block
@@ -338,7 +324,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
wait, \
timeout, \
@@ -350,7 +335,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
wait, \
timeout, \
@@ -363,7 +347,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
wait, \
timeout, \
@@ -453,7 +436,6 @@ void _CORE_message_queue_Insert_message(
buffer, \
size, \
mp_callout, \
- mp_id, \
wait, \
timeout, \
lock_context \
@@ -464,7 +446,6 @@ void _CORE_message_queue_Insert_message(
buffer, \
size, \
mp_callout, \
- mp_id, \
CORE_MESSAGE_QUEUE_SEND_REQUEST, \
wait, \
timeout, \
@@ -479,7 +460,6 @@ void _CORE_message_queue_Insert_message(
buffer, \
size, \
mp_callout, \
- mp_id, \
wait, \
timeout, \
lock_context \
@@ -490,7 +470,6 @@ void _CORE_message_queue_Insert_message(
buffer, \
size, \
mp_callout, \
- mp_id, \
CORE_MESSAGE_QUEUE_URGENT_REQUEST, \
wait,\
timeout, \
@@ -626,7 +605,6 @@ RTEMS_INLINE_ROUTINE Thread_Control *_CORE_message_queue_Do_dequeue_receiver(
size_t size,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
CORE_message_queue_Submit_types submit_type,
ISR_lock_Context *lock_context
@@ -672,7 +650,6 @@ RTEMS_INLINE_ROUTINE Thread_Control *_CORE_message_queue_Do_dequeue_receiver(
the_message_queue->operations,
the_thread,
mp_callout,
- mp_id,
lock_context
);
@@ -685,7 +662,6 @@ RTEMS_INLINE_ROUTINE Thread_Control *_CORE_message_queue_Do_dequeue_receiver(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
lock_context \
) \
@@ -694,7 +670,6 @@ RTEMS_INLINE_ROUTINE Thread_Control *_CORE_message_queue_Do_dequeue_receiver(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
lock_context \
)
@@ -704,7 +679,6 @@ RTEMS_INLINE_ROUTINE Thread_Control *_CORE_message_queue_Do_dequeue_receiver(
buffer, \
size, \
mp_callout, \
- mp_id, \
submit_type, \
lock_context \
) \
diff --git a/cpukit/score/include/rtems/score/coremuteximpl.h b/cpukit/score/include/rtems/score/coremuteximpl.h
index 34a9972..4531e46 100644
--- a/cpukit/score/include/rtems/score/coremuteximpl.h
+++ b/cpukit/score/include/rtems/score/coremuteximpl.h
@@ -374,7 +374,6 @@ CORE_mutex_Status _CORE_mutex_Do_surrender(
CORE_mutex_Control *the_mutex,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -383,20 +382,17 @@ CORE_mutex_Status _CORE_mutex_Do_surrender(
#define _CORE_mutex_Surrender( \
the_mutex, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_mutex_Do_surrender( \
the_mutex, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
#define _CORE_mutex_Surrender( \
the_mutex, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_mutex_Do_surrender( \
@@ -422,7 +418,6 @@ Thread_Control *_CORE_mutex_Unsatisfied_nowait(
the_mutex, \
filter, \
mp_callout, \
- mp_id, \
lock_context \
) \
_Thread_queue_Flush_critical( \
@@ -430,7 +425,6 @@ Thread_Control *_CORE_mutex_Unsatisfied_nowait(
( the_mutex )->operations, \
filter, \
mp_callout, \
- mp_id, \
lock_context \
)
diff --git a/cpukit/score/include/rtems/score/coresemimpl.h b/cpukit/score/include/rtems/score/coresemimpl.h
index a06fcb5..0e04cc9 100644
--- a/cpukit/score/include/rtems/score/coresemimpl.h
+++ b/cpukit/score/include/rtems/score/coresemimpl.h
@@ -117,7 +117,6 @@ Thread_Control *_CORE_semaphore_Unsatisfied_nowait(
#define _CORE_semaphore_Destroy( \
the_semaphore, \
mp_callout, \
- mp_id, \
lock_context \
) \
do { \
@@ -126,7 +125,6 @@ Thread_Control *_CORE_semaphore_Unsatisfied_nowait(
( the_semaphore )->operations, \
_CORE_semaphore_Was_deleted, \
mp_callout, \
- mp_id, \
lock_context \
); \
_Thread_queue_Destroy( &( the_semaphore )->Wait_queue ); \
@@ -136,7 +134,6 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
CORE_semaphore_Control *the_semaphore,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -158,7 +155,6 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
the_semaphore->operations,
the_thread,
mp_callout,
- mp_id,
lock_context
);
} else {
@@ -183,8 +179,6 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
* @param[in] the_semaphore is the semaphore to surrender
* @param[in] mp_callout is the routine to invoke if the
* thread unblocked is remote
- * @param[in] mp_id is the Id of the API level Semaphore object associated
- * with this instance of a SuperCore Semaphore
* @param[in] lock_context is a temporary variable used to contain the ISR
* disable level cookie
*
@@ -194,20 +188,17 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
#define _CORE_semaphore_Surrender( \
the_semaphore, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_semaphore_Do_surrender( \
the_semaphore, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
#define _CORE_semaphore_Surrender( \
the_semaphore, \
mp_callout, \
- mp_id, \
lock_context \
) \
_CORE_semaphore_Do_surrender( \
@@ -220,7 +211,6 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
#define _CORE_semaphore_Flush( \
the_semaphore, \
mp_callout, \
- mp_id, \
lock_context \
) \
do { \
@@ -229,7 +219,6 @@ RTEMS_INLINE_ROUTINE CORE_semaphore_Status _CORE_semaphore_Do_surrender(
( the_semaphore )->operations, \
_CORE_semaphore_Unsatisfied_nowait, \
mp_callout, \
- mp_id, \
lock_context \
); \
} while ( 0 )
diff --git a/cpukit/score/include/rtems/score/thread.h b/cpukit/score/include/rtems/score/thread.h
index 8672fdd..ee19c04 100644
--- a/cpukit/score/include/rtems/score/thread.h
+++ b/cpukit/score/include/rtems/score/thread.h
@@ -404,12 +404,6 @@ typedef struct {
Thread_queue_MP_callout thread_queue_callout;
/**
- * @brief Thread queue object identifier for
- * _Thread_queue_Enqueue_critical().
- */
- Objects_Id thread_queue_id;
-
- /**
* @brief This field is used to manage the set of active proxies in the system.
*/
RBTree_Node Active;
diff --git a/cpukit/score/include/rtems/score/threadqimpl.h b/cpukit/score/include/rtems/score/threadqimpl.h
index f24e48c..011c410 100644
--- a/cpukit/score/include/rtems/score/threadqimpl.h
+++ b/cpukit/score/include/rtems/score/threadqimpl.h
@@ -201,8 +201,7 @@ Thread_Control *_Thread_queue_Do_dequeue(
const Thread_queue_Operations *operations
#if defined(RTEMS_MULTIPROCESSING)
,
- Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id
+ Thread_queue_MP_callout mp_callout
#endif
);
@@ -221,21 +220,18 @@ Thread_Control *_Thread_queue_Do_dequeue(
#define _Thread_queue_Dequeue( \
the_thread_queue, \
operations, \
- mp_callout, \
- mp_id \
+ mp_callout \
) \
_Thread_queue_Do_dequeue( \
the_thread_queue, \
operations, \
- mp_callout, \
- mp_id \
+ mp_callout \
)
#else
#define _Thread_queue_Dequeue( \
the_thread_queue, \
operations, \
- mp_callout, \
- mp_id \
+ mp_callout \
) \
_Thread_queue_Do_dequeue( \
the_thread_queue, \
@@ -348,8 +344,7 @@ bool _Thread_queue_Do_extract_locked(
Thread_Control *the_thread
#if defined(RTEMS_MULTIPROCESSING)
,
- Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id
+ Thread_queue_MP_callout mp_callout
#endif
);
@@ -366,8 +361,6 @@ bool _Thread_queue_Do_extract_locked(
* @param[in] mp_callout Callout to unblock the thread in case it is actually a
* thread proxy. This parameter is only used on multiprocessing
* configurations.
- * @param[in] mp_id Object identifier of the object containing the thread
- * queue. This parameter is only used on multiprocessing configurations.
*
* @return Returns the unblock indicator for _Thread_queue_Unblock_critical().
* True indicates, that this thread must be unblocked by the scheduler later in
@@ -382,23 +375,20 @@ bool _Thread_queue_Do_extract_locked(
unblock, \
queue, \
the_thread, \
- mp_callout, \
- mp_id \
+ mp_callout \
) \
_Thread_queue_Do_extract_locked( \
unblock, \
queue, \
the_thread, \
- mp_callout, \
- mp_id \
+ mp_callout \
)
#else
#define _Thread_queue_Extract_locked( \
unblock, \
queue, \
the_thread, \
- mp_callout, \
- mp_id \
+ mp_callout \
) \
_Thread_queue_Do_extract_locked( \
unblock, \
@@ -434,7 +424,6 @@ void _Thread_queue_Do_extract_critical(
Thread_Control *the_thread,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -487,8 +476,6 @@ void _Thread_queue_Do_extract_critical(
* @param[in] mp_callout Callout to unblock the thread in case it is actually a
* thread proxy. This parameter is only used on multiprocessing
* configurations.
- * @param[in] mp_id Object identifier of the object containing the thread
- * queue. This parameter is only used on multiprocessing configurations.
* @param[in] lock_context The lock context of the lock acquire.
*/
#if defined(RTEMS_MULTIPROCESSING)
@@ -497,7 +484,6 @@ void _Thread_queue_Do_extract_critical(
operations, \
the_thread, \
mp_callout, \
- mp_id, \
lock_context \
) \
_Thread_queue_Do_extract_critical( \
@@ -505,7 +491,6 @@ void _Thread_queue_Do_extract_critical(
operations, \
the_thread, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
@@ -514,7 +499,6 @@ void _Thread_queue_Do_extract_critical(
operations, \
the_thread, \
mp_callout, \
- mp_id, \
lock_context \
) \
_Thread_queue_Do_extract_critical( \
@@ -644,7 +628,6 @@ size_t _Thread_queue_Do_flush_critical(
Thread_queue_Flush_filter filter,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
);
@@ -666,8 +649,6 @@ size_t _Thread_queue_Do_flush_critical(
* operation should stop or continue.
* @param mp_callout Callout to extract the proxy of a remote thread. This
* parameter is only used on multiprocessing configurations.
- * @param mp_id Object identifier of the object containing the thread queue.
- * This parameter is only used on multiprocessing configurations.
*
* @return The count of extracted threads.
*/
@@ -677,7 +658,6 @@ size_t _Thread_queue_Do_flush_critical(
operations, \
filter, \
mp_callout, \
- mp_id, \
lock_context \
) \
_Thread_queue_Do_flush_critical( \
@@ -685,7 +665,6 @@ size_t _Thread_queue_Do_flush_critical(
operations, \
filter, \
mp_callout, \
- mp_id, \
lock_context \
)
#else
@@ -694,7 +673,6 @@ size_t _Thread_queue_Do_flush_critical(
operations, \
filter, \
mp_callout, \
- mp_id, \
lock_context \
) \
_Thread_queue_Do_flush_critical( \
diff --git a/cpukit/score/src/apimutexunlock.c b/cpukit/score/src/apimutexunlock.c
index e129dd2..082961f 100644
--- a/cpukit/score/src/apimutexunlock.c
+++ b/cpukit/score/src/apimutexunlock.c
@@ -35,7 +35,6 @@ void _API_Mutex_Unlock( API_Mutex_Control *the_mutex )
_CORE_mutex_Surrender(
&the_mutex->Mutex,
NULL,
- 0,
&lock_context
);
diff --git a/cpukit/score/src/condition.c b/cpukit/score/src/condition.c
index ba255fc..fcd93b2 100644
--- a/cpukit/score/src/condition.c
+++ b/cpukit/score/src/condition.c
@@ -267,7 +267,6 @@ static void _Condition_Wake( struct _Condition_Control *_condition, int count )
CONDITION_TQ_OPERATIONS,
_Condition_Flush_filter,
NULL,
- 0,
&lock_context.Base
);
}
diff --git a/cpukit/score/src/corebarrierrelease.c b/cpukit/score/src/corebarrierrelease.c
index e6ef335..c9c80f4 100644
--- a/cpukit/score/src/corebarrierrelease.c
+++ b/cpukit/score/src/corebarrierrelease.c
@@ -26,7 +26,6 @@ uint32_t _CORE_barrier_Do_surrender(
Thread_queue_Flush_filter filter,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -37,7 +36,6 @@ uint32_t _CORE_barrier_Do_surrender(
CORE_BARRIER_TQ_OPERATIONS,
filter,
mp_callout,
- mp_id,
lock_context
);
}
diff --git a/cpukit/score/src/corebarrierwait.c b/cpukit/score/src/corebarrierwait.c
index 4a924b2..54e9096 100644
--- a/cpukit/score/src/corebarrierwait.c
+++ b/cpukit/score/src/corebarrierwait.c
@@ -28,7 +28,6 @@ void _CORE_barrier_Do_seize(
Watchdog_Interval timeout,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -47,7 +46,7 @@ void _CORE_barrier_Do_seize(
&& number_of_waiting_threads == the_barrier->Attributes.maximum_count
) {
executing->Wait.return_code = CORE_BARRIER_STATUS_AUTOMATICALLY_RELEASED;
- _CORE_barrier_Surrender( the_barrier, mp_callout, mp_id, lock_context );
+ _CORE_barrier_Surrender( the_barrier, mp_callout, lock_context );
} else {
the_barrier->number_of_waiting_threads = number_of_waiting_threads;
_Thread_queue_Enqueue_critical(
diff --git a/cpukit/score/src/coremsgbroadcast.c b/cpukit/score/src/coremsgbroadcast.c
index 9a863ff..a7a962f 100644
--- a/cpukit/score/src/coremsgbroadcast.c
+++ b/cpukit/score/src/coremsgbroadcast.c
@@ -27,7 +27,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
size_t size,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
uint32_t *count,
ISR_lock_Context *lock_context
@@ -52,7 +51,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_broadcast(
buffer,
size,
mp_callout,
- mp_id,
0,
lock_context
)
diff --git a/cpukit/score/src/coremsgclose.c b/cpukit/score/src/coremsgclose.c
index 5b53431..1951e9f 100644
--- a/cpukit/score/src/coremsgclose.c
+++ b/cpukit/score/src/coremsgclose.c
@@ -36,7 +36,6 @@ void _CORE_message_queue_Do_close(
CORE_message_queue_Control *the_message_queue,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -52,7 +51,6 @@ void _CORE_message_queue_Do_close(
the_message_queue->operations,
_CORE_message_queue_Was_deleted,
mp_callout,
- mp_id,
lock_context
);
diff --git a/cpukit/score/src/coremsgseize.c b/cpukit/score/src/coremsgseize.c
index c9a2473..fcc95a7 100644
--- a/cpukit/score/src/coremsgseize.c
+++ b/cpukit/score/src/coremsgseize.c
@@ -101,7 +101,6 @@ void _CORE_message_queue_Seize(
the_message_queue->operations,
the_thread,
NULL,
- 0,
lock_context
);
return;
diff --git a/cpukit/score/src/coremsgsubmit.c b/cpukit/score/src/coremsgsubmit.c
index 7e589e7..82cfa1a 100644
--- a/cpukit/score/src/coremsgsubmit.c
+++ b/cpukit/score/src/coremsgsubmit.c
@@ -32,7 +32,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
size_t size,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
CORE_message_queue_Submit_types submit_type,
bool wait,
@@ -57,7 +56,6 @@ CORE_message_queue_Status _CORE_message_queue_Do_submit(
buffer,
size,
mp_callout,
- mp_id,
submit_type,
lock_context
);
diff --git a/cpukit/score/src/coremutexsurrender.c b/cpukit/score/src/coremutexsurrender.c
index 6fcbc43..746fee1 100644
--- a/cpukit/score/src/coremutexsurrender.c
+++ b/cpukit/score/src/coremutexsurrender.c
@@ -27,7 +27,6 @@ CORE_mutex_Status _CORE_mutex_Do_surrender(
CORE_mutex_Control *the_mutex,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -127,8 +126,7 @@ CORE_mutex_Status _CORE_mutex_Do_surrender(
&the_mutex->Wait_queue.Queue,
the_mutex->operations,
the_thread,
- mp_callout,
- mp_id
+ mp_callout
);
#if defined(RTEMS_MULTIPROCESSING)
diff --git a/cpukit/score/src/corerwlockrelease.c b/cpukit/score/src/corerwlockrelease.c
index 3ace00d..6f76aad 100644
--- a/cpukit/score/src/corerwlockrelease.c
+++ b/cpukit/score/src/corerwlockrelease.c
@@ -120,7 +120,6 @@ CORE_RWLock_Status _CORE_RWLock_Surrender(
CORE_RWLOCK_TQ_OPERATIONS,
_CORE_RWLock_Flush_filter,
NULL,
- 0,
lock_context
);
return CORE_RWLOCK_SUCCESSFUL;
diff --git a/cpukit/score/src/futex.c b/cpukit/score/src/futex.c
index 59a625c..66085a8 100644
--- a/cpukit/score/src/futex.c
+++ b/cpukit/score/src/futex.c
@@ -151,7 +151,6 @@ int _Futex_Wake( struct _Futex_Control *_futex, int count )
FUTEX_TQ_OPERATIONS,
_Futex_Flush_filter,
NULL,
- 0,
&lock_context.Base
);
}
diff --git a/cpukit/score/src/mpci.c b/cpukit/score/src/mpci.c
index d5ba1e5..0b51e38 100644
--- a/cpukit/score/src/mpci.c
+++ b/cpukit/score/src/mpci.c
@@ -373,7 +373,7 @@ void _MPCI_Announce ( void )
ISR_lock_Context lock_context;
_ISR_lock_ISR_disable( &lock_context );
- (void) _CORE_semaphore_Surrender( &_MPCI_Semaphore, 0, 0, &lock_context );
+ (void) _CORE_semaphore_Surrender( &_MPCI_Semaphore, 0, &lock_context );
}
void _MPCI_Internal_packets_Send_process_packet (
diff --git a/cpukit/score/src/mutex.c b/cpukit/score/src/mutex.c
index b28964d..e27075e 100644
--- a/cpukit/score/src/mutex.c
+++ b/cpukit/score/src/mutex.c
@@ -146,8 +146,7 @@ static void _Mutex_Release_slow(
&mutex->Queue.Queue,
operations,
first,
- NULL,
- 0
+ NULL
);
_Thread_queue_Boost_priority( &mutex->Queue.Queue, first );
_Thread_queue_Unblock_critical(
diff --git a/cpukit/score/src/semaphore.c b/cpukit/score/src/semaphore.c
index ae1b5c7..4e70b79 100644
--- a/cpukit/score/src/semaphore.c
+++ b/cpukit/score/src/semaphore.c
@@ -134,7 +134,6 @@ void _Semaphore_Post( struct _Semaphore_Control *_sem )
operations,
first,
NULL,
- 0,
&lock_context
);
}
diff --git a/cpukit/score/src/threadqenqueue.c b/cpukit/score/src/threadqenqueue.c
index 84de11e..cda7c86 100644
--- a/cpukit/score/src/threadqenqueue.c
+++ b/cpukit/score/src/threadqenqueue.c
@@ -99,8 +99,7 @@ bool _Thread_queue_Do_extract_locked(
Thread_Control *the_thread
#if defined(RTEMS_MULTIPROCESSING)
,
- Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id
+ Thread_queue_MP_callout mp_callout
#endif
)
{
@@ -115,7 +114,6 @@ bool _Thread_queue_Do_extract_locked(
the_proxy = (Thread_Proxy_control *) the_thread;
the_proxy->thread_queue_callout = mp_callout;
- the_proxy->thread_queue_id = mp_id;
}
#endif
@@ -172,7 +170,6 @@ void _Thread_queue_Do_extract_critical(
Thread_Control *the_thread,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -183,8 +180,7 @@ void _Thread_queue_Do_extract_critical(
queue,
operations,
the_thread,
- mp_callout,
- mp_id
+ mp_callout
);
_Thread_queue_Unblock_critical(
@@ -213,7 +209,6 @@ void _Thread_queue_Extract( Thread_Control *the_thread )
the_thread->Wait.operations,
the_thread,
_Thread_queue_MP_callout_do_nothing,
- 0,
&lock_context
);
} else {
@@ -226,8 +221,7 @@ Thread_Control *_Thread_queue_Do_dequeue(
const Thread_queue_Operations *operations
#if defined(RTEMS_MULTIPROCESSING)
,
- Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id
+ Thread_queue_MP_callout mp_callout
#endif
)
{
@@ -246,7 +240,6 @@ Thread_Control *_Thread_queue_Do_dequeue(
operations,
the_thread,
mp_callout,
- mp_id,
&lock_context
);
} else {
@@ -262,13 +255,14 @@ void _Thread_queue_Unblock_proxy(
Thread_Control *the_thread
)
{
- Thread_Proxy_control *the_proxy;
+ const Thread_queue_Object *the_queue_object;
+ Thread_Proxy_control *the_proxy;
+ Thread_queue_MP_callout mp_callout;
+ the_queue_object = THREAD_QUEUE_QUEUE_TO_OBJECT( queue );
the_proxy = (Thread_Proxy_control *) the_thread;
- ( *the_proxy->thread_queue_callout )(
- the_thread,
- the_proxy->thread_queue_id
- );
+ mp_callout = the_proxy->thread_queue_callout;
+ ( *mp_callout )( the_thread, the_queue_object->Object.id );
_Thread_MP_Free_proxy( the_thread );
}
diff --git a/cpukit/score/src/threadqflush.c b/cpukit/score/src/threadqflush.c
index a67f354..0413388 100644
--- a/cpukit/score/src/threadqflush.c
+++ b/cpukit/score/src/threadqflush.c
@@ -37,7 +37,6 @@ size_t _Thread_queue_Do_flush_critical(
Thread_queue_Flush_filter filter,
#if defined(RTEMS_MULTIPROCESSING)
Thread_queue_MP_callout mp_callout,
- Objects_Id mp_id,
#endif
ISR_lock_Context *lock_context
)
@@ -70,8 +69,7 @@ size_t _Thread_queue_Do_flush_critical(
queue,
operations,
first,
- mp_callout,
- mp_id
+ mp_callout
);
if ( do_unblock ) {
_Chain_Append_unprotected( &unblock, &first->Wait.Node.Chain );
diff --git a/cpukit/score/src/threadrestart.c b/cpukit/score/src/threadrestart.c
index 33c56e0..30536f7 100644
--- a/cpukit/score/src/threadrestart.c
+++ b/cpukit/score/src/threadrestart.c
@@ -128,7 +128,6 @@ static void _Thread_Wake_up_joining_threads( Thread_Control *the_thread )
_Thread_queue_Flush_default_filter,
#endif
NULL,
- 0,
&join_lock_context.Base
);
}
--
1.8.4.5
More information about the devel
mailing list