score: Use atomic operations for SMP messages

This commit is contained in:
Sebastian Huber
2014-05-02 15:47:57 +02:00
parent 145becf075
commit 4d906bdac2
3 changed files with 15 additions and 19 deletions

View File

@@ -302,11 +302,12 @@ typedef struct Per_CPU_Control {
SMP_lock_Context Giant_lock_context; SMP_lock_Context Giant_lock_context;
/** /**
* This is the request for the interrupt. * @brief Bit field for SMP messages.
* *
* @note This may become a chain protected by atomic instructions. * This bit field is not protected locks. Atomic operations are used to
* set and get the message bits.
*/ */
uint32_t message; Atomic_Ulong message;
/** /**
* @brief Indicates the current state of the CPU. * @brief Indicates the current state of the CPU.

View File

@@ -41,14 +41,14 @@ extern "C" {
* *
* @see _SMP_Send_message(). * @see _SMP_Send_message().
*/ */
#define SMP_MESSAGE_SHUTDOWN UINT32_C(0x1) #define SMP_MESSAGE_SHUTDOWN 0x1UL
/** /**
* @brief SMP message to request a test handler invocation. * @brief SMP message to request a test handler invocation.
* *
* @see _SMP_Send_message(). * @see _SMP_Send_message().
*/ */
#define SMP_MESSAGE_TEST UINT32_C(0x2) #define SMP_MESSAGE_TEST 0x2UL
/** /**
* @brief SMP fatal codes. * @brief SMP fatal codes.
@@ -132,14 +132,12 @@ static inline void _SMP_Inter_processor_interrupt_handler( void )
{ {
Per_CPU_Control *cpu_self = _Per_CPU_Get(); Per_CPU_Control *cpu_self = _Per_CPU_Get();
if ( cpu_self->message != 0 ) { if ( _Atomic_Load_ulong( &cpu_self->message, ATOMIC_ORDER_RELAXED ) != 0 ) {
uint32_t message; unsigned long message = _Atomic_Exchange_ulong(
ISR_Level level; &cpu_self->message,
0UL,
_Per_CPU_ISR_disable_and_acquire( cpu_self, level ); ATOMIC_ORDER_RELAXED
message = cpu_self->message; );
cpu_self->message = 0;
_Per_CPU_Release_and_ISR_enable( cpu_self, level );
if ( ( message & SMP_MESSAGE_SHUTDOWN ) != 0 ) { if ( ( message & SMP_MESSAGE_SHUTDOWN ) != 0 ) {
rtems_fatal( RTEMS_FATAL_SOURCE_SMP, SMP_FATAL_SHUTDOWN ); rtems_fatal( RTEMS_FATAL_SOURCE_SMP, SMP_FATAL_SHUTDOWN );
@@ -160,7 +158,7 @@ static inline void _SMP_Inter_processor_interrupt_handler( void )
* @param[in] cpu_index The target processor of the message. * @param[in] cpu_index The target processor of the message.
* @param[in] message The message. * @param[in] message The message.
*/ */
void _SMP_Send_message( uint32_t cpu_index, uint32_t message ); void _SMP_Send_message( uint32_t cpu_index, unsigned long message );
/** /**
* @brief Request of others CPUs. * @brief Request of others CPUs.

View File

@@ -140,14 +140,11 @@ void _SMP_Request_shutdown( void )
_Giant_Drop( self_cpu ); _Giant_Drop( self_cpu );
} }
void _SMP_Send_message( uint32_t cpu_index, uint32_t message ) void _SMP_Send_message( uint32_t cpu_index, unsigned long message )
{ {
Per_CPU_Control *cpu = _Per_CPU_Get_by_index( cpu_index ); Per_CPU_Control *cpu = _Per_CPU_Get_by_index( cpu_index );
ISR_Level level;
_Per_CPU_ISR_disable_and_acquire( cpu, level ); _Atomic_Fetch_or_ulong( &cpu->message, message, ATOMIC_ORDER_RELAXED );
cpu->message |= message;
_Per_CPU_Release_and_ISR_enable( cpu, level );
_CPU_SMP_Send_interrupt( cpu_index ); _CPU_SMP_Send_interrupt( cpu_index );
} }