From 67d224af9e8d4cf07cf6c2bb3197b3dd7a90f2e7 Mon Sep 17 00:00:00 2001 From: Joel Sherrill Date: Fri, 8 Dec 1995 21:06:15 +0000 Subject: added correct use of _Thread_queue_Enter_critical_section --- cpukit/posix/src/cond.c | 1 + cpukit/rtems/src/region.c | 2 +- cpukit/score/src/coremsg.c | 2 +- cpukit/score/src/coremutex.c | 2 +- cpukit/score/src/coresem.c | 2 +- cpukit/score/src/mpci.c | 2 +- 6 files changed, 6 insertions(+), 5 deletions(-) (limited to 'cpukit') diff --git a/cpukit/posix/src/cond.c b/cpukit/posix/src/cond.c index ed151d8c1d..e20cfe5359 100644 --- a/cpukit/posix/src/cond.c +++ b/cpukit/posix/src/cond.c @@ -350,6 +350,7 @@ int _POSIX_Condition_variables_Wait_support( the_cond->Mutex = *mutex; +/* XXX .. enter critical section .. */ _Thread_queue_Enqueue( &the_cond->Wait_queue, 0 ); _Thread_Enable_dispatch(); diff --git a/cpukit/rtems/src/region.c b/cpukit/rtems/src/region.c index d0720f5040..5a8ad26797 100644 --- a/cpukit/rtems/src/region.c +++ b/cpukit/rtems/src/region.c @@ -355,7 +355,7 @@ rtems_status_code rtems_region_get_segment( executing->Wait.count = size; executing->Wait.return_argument = (unsigned32 *) segment; - the_region->Wait_queue.sync = TRUE; + _Thread_queue_Enter_critical_section( &the_region->Wait_queue ); _Thread_queue_Enqueue( &the_region->Wait_queue, timeout ); diff --git a/cpukit/score/src/coremsg.c b/cpukit/score/src/coremsg.c index 0b7a88b1b9..05e4fb799d 100644 --- a/cpukit/score/src/coremsg.c +++ b/cpukit/score/src/coremsg.c @@ -284,7 +284,7 @@ void _CORE_message_queue_Seize( return; } - the_message_queue->Wait_queue.sync = TRUE; + _Thread_queue_Enter_critical_section( &the_message_queue->Wait_queue ); executing->Wait.queue = &the_message_queue->Wait_queue; executing->Wait.id = id; executing->Wait.return_argument = (void *)buffer; diff --git a/cpukit/score/src/coremutex.c b/cpukit/score/src/coremutex.c index 321b4da5ed..08d1630b7f 100644 --- a/cpukit/score/src/coremutex.c +++ b/cpukit/score/src/coremutex.c @@ -139,7 +139,7 @@ void _CORE_mutex_Seize( return; } - the_mutex->Wait_queue.sync = TRUE; + _Thread_queue_Enter_critical_section( &the_mutex->Wait_queue ); executing->Wait.queue = &the_mutex->Wait_queue; executing->Wait.id = id; _ISR_Enable( level ); diff --git a/cpukit/score/src/coresem.c b/cpukit/score/src/coresem.c index e9d44369d5..5fc55b5359 100644 --- a/cpukit/score/src/coresem.c +++ b/cpukit/score/src/coresem.c @@ -146,7 +146,7 @@ void _CORE_semaphore_Seize( return; } - the_semaphore->Wait_queue.sync = TRUE; + _Thread_queue_Enter_critical_section( &the_semaphore->Wait_queue ); executing->Wait.queue = &the_semaphore->Wait_queue; executing->Wait.id = id; _ISR_Enable( level ); diff --git a/cpukit/score/src/mpci.c b/cpukit/score/src/mpci.c index 7887fe355e..08b8eff9ba 100644 --- a/cpukit/score/src/mpci.c +++ b/cpukit/score/src/mpci.c @@ -195,7 +195,7 @@ unsigned32 _MPCI_Send_request_packet ( (*_MPCI_table->send_packet)( destination, the_packet ); - _MPCI_Remote_blocked_threads.sync = TRUE; + _Thread_queue_Enter_critical_section( &_MPCI_Remote_blocked_threads ); /* * See if we need a default timeout -- cgit v1.2.3