1 /*
2 * FreeRTOS Kernel V10.6.2
3 * Copyright (C) 2021 Amazon.com, Inc. or its affiliates. All Rights Reserved.
4 *
5 * SPDX-License-Identifier: MIT
6 *
7 * Permission is hereby granted, free of charge, to any person obtaining a copy of
8 * this software and associated documentation files (the "Software"), to deal in
9 * the Software without restriction, including without limitation the rights to
10 * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
11 * the Software, and to permit persons to whom the Software is furnished to do so,
12 * subject to the following conditions:
13 *
14 * The above copyright notice and this permission notice shall be included in all
15 * copies or substantial portions of the Software.
16 *
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
19 * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
20 * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
21 * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
22 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
23 *
24 * https://www.FreeRTOS.org
25 * https://github.com/FreeRTOS
26 *
27 */
28
29 /* Standard includes. */
30 #include <stdio.h>
31
32 /* Scheduler includes. */
33 #include "FreeRTOS.h"
34 #include "task.h"
35
36 #ifdef __GNUC__
37 #include "mmsystem.h"
38 #else
39 #pragma comment(lib, "winmm.lib")
40 #endif
41
42 #define portMAX_INTERRUPTS ( ( uint32_t ) sizeof( uint32_t ) * 8UL ) /* The number of bits in an uint32_t. */
43 #define portNO_CRITICAL_NESTING ( ( uint32_t ) 0 )
44
45 /* The priorities at which the various components of the simulation execute. */
46 #define portDELETE_SELF_THREAD_PRIORITY THREAD_PRIORITY_TIME_CRITICAL /* Must be highest. */
47 #define portSIMULATED_INTERRUPTS_THREAD_PRIORITY THREAD_PRIORITY_TIME_CRITICAL
48 #define portSIMULATED_TIMER_THREAD_PRIORITY THREAD_PRIORITY_HIGHEST
49 #define portTASK_THREAD_PRIORITY THREAD_PRIORITY_ABOVE_NORMAL
50
51 /*
52 * Created as a high priority thread, this function uses a timer to simulate
53 * a tick interrupt being generated on an embedded target. In this Windows
54 * environment the timer does not achieve anything approaching real time
55 * performance though.
56 */
57 static DWORD WINAPI prvSimulatedPeripheralTimer( LPVOID lpParameter );
58
59 /*
60 * Process all the simulated interrupts - each represented by a bit in
61 * ulPendingInterrupts variable.
62 */
63 static void prvProcessSimulatedInterrupts( void );
64
65 /*
66 * Interrupt handlers used by the kernel itself. These are executed from the
67 * simulated interrupt handler thread.
68 */
69 static uint32_t prvProcessYieldInterrupt( void );
70 static uint32_t prvProcessTickInterrupt( void );
71
72 /*
73 * Exiting a critical section will cause the calling task to block on yield
74 * event to wait for an interrupt to process if an interrupt was pended while
75 * inside the critical section. This variable protects against a recursive
76 * attempt to obtain pvInterruptEventMutex if a critical section is used inside
77 * an interrupt handler itself.
78 */
79 volatile BaseType_t xInsideInterrupt = pdFALSE;
80
81 /*
82 * Called when the process exits to let Windows know the high timer resolution
83 * is no longer required.
84 */
85 static BOOL WINAPI prvEndProcess( DWORD dwCtrlType );
86
87 /*-----------------------------------------------------------*/
88
89 /* The WIN32 simulator runs each task in a thread. The context switching is
90 managed by the threads, so the task stack does not have to be managed directly,
91 although the task stack is still used to hold an xThreadState structure this is
92 the only thing it will ever hold. The structure indirectly maps the task handle
93 to a thread handle. */
94 typedef struct
95 {
96 /* Handle of the thread that executes the task. */
97 void *pvThread;
98
99 /* Event used to make sure the thread does not execute past a yield point
100 between the call to SuspendThread() to suspend the thread and the
101 asynchronous SuspendThread() operation actually being performed. */
102 void *pvYieldEvent;
103 } ThreadState_t;
104
105 /* Simulated interrupts waiting to be processed. This is a bit mask where each
106 bit represents one interrupt, so a maximum of 32 interrupts can be simulated. */
107 static volatile uint32_t ulPendingInterrupts = 0UL;
108
109 /* An event used to inform the simulated interrupt processing thread (a high
110 priority thread that simulated interrupt processing) that an interrupt is
111 pending. */
112 static void *pvInterruptEvent = NULL;
113
114 /* Mutex used to protect all the simulated interrupt variables that are accessed
115 by multiple threads. */
116 static void *pvInterruptEventMutex = NULL;
117
118 /* The critical nesting count for the currently executing task. This is
119 initialised to a non-zero value so interrupts do not become enabled during
120 the initialisation phase. As each task has its own critical nesting value
121 ulCriticalNesting will get set to zero when the first task runs. This
122 initialisation is probably not critical in this simulated environment as the
123 simulated interrupt handlers do not get created until the FreeRTOS scheduler is
124 started anyway. */
125 static volatile uint32_t ulCriticalNesting = 9999UL;
126
127 /* Handlers for all the simulated software interrupts. The first two positions
128 are used for the Yield and Tick interrupts so are handled slightly differently,
129 all the other interrupts can be user defined. */
130 static uint32_t (*ulIsrHandler[ portMAX_INTERRUPTS ])( void ) = { 0 };
131
132 /* Pointer to the TCB of the currently executing task. */
133 extern void * volatile pxCurrentTCB;
134
135 /* Used to ensure nothing is processed during the startup sequence. */
136 static BaseType_t xPortRunning = pdFALSE;
137
138 /*-----------------------------------------------------------*/
139
prvSimulatedPeripheralTimer(LPVOID lpParameter)140 static DWORD WINAPI prvSimulatedPeripheralTimer( LPVOID lpParameter )
141 {
142 TickType_t xMinimumWindowsBlockTime;
143 TIMECAPS xTimeCaps;
144
145 /* Set the timer resolution to the maximum possible. */
146 if( timeGetDevCaps( &xTimeCaps, sizeof( xTimeCaps ) ) == MMSYSERR_NOERROR )
147 {
148 xMinimumWindowsBlockTime = ( TickType_t ) xTimeCaps.wPeriodMin;
149 timeBeginPeriod( xTimeCaps.wPeriodMin );
150
151 /* Register an exit handler so the timeBeginPeriod() function can be
152 matched with a timeEndPeriod() when the application exits. */
153 SetConsoleCtrlHandler( prvEndProcess, TRUE );
154 }
155 else
156 {
157 xMinimumWindowsBlockTime = ( TickType_t ) 20;
158 }
159
160 /* Just to prevent compiler warnings. */
161 ( void ) lpParameter;
162
163 while( xPortRunning == pdTRUE )
164 {
165 /* Wait until the timer expires and we can access the simulated interrupt
166 variables. *NOTE* this is not a 'real time' way of generating tick
167 events as the next wake time should be relative to the previous wake
168 time, not the time that Sleep() is called. It is done this way to
169 prevent overruns in this very non real time simulated/emulated
170 environment. */
171 if( portTICK_PERIOD_MS < xMinimumWindowsBlockTime )
172 {
173 Sleep( xMinimumWindowsBlockTime );
174 }
175 else
176 {
177 Sleep( portTICK_PERIOD_MS );
178 }
179
180 if( xPortRunning == pdTRUE )
181 {
182 configASSERT( xPortRunning );
183
184 /* Can't proceed if in a critical section as pvInterruptEventMutex won't
185 be available. */
186 WaitForSingleObject( pvInterruptEventMutex, INFINITE );
187
188 /* The timer has expired, generate the simulated tick event. */
189 ulPendingInterrupts |= ( 1 << portINTERRUPT_TICK );
190
191 /* The interrupt is now pending - notify the simulated interrupt
192 handler thread. Must be outside of a critical section to get here so
193 the handler thread can execute immediately pvInterruptEventMutex is
194 released. */
195 configASSERT( ulCriticalNesting == 0UL );
196 SetEvent( pvInterruptEvent );
197
198 /* Give back the mutex so the simulated interrupt handler unblocks
199 and can access the interrupt handler variables. */
200 ReleaseMutex( pvInterruptEventMutex );
201 }
202 }
203
204
205 return 0;
206 }
207 /*-----------------------------------------------------------*/
208
prvEndProcess(DWORD dwCtrlType)209 static BOOL WINAPI prvEndProcess( DWORD dwCtrlType )
210 {
211 TIMECAPS xTimeCaps;
212
213 ( void ) dwCtrlType;
214
215 if( timeGetDevCaps( &xTimeCaps, sizeof( xTimeCaps ) ) == MMSYSERR_NOERROR )
216 {
217 /* Match the call to timeBeginPeriod( xTimeCaps.wPeriodMin ) made when
218 the process started with a timeEndPeriod() as the process exits. */
219 timeEndPeriod( xTimeCaps.wPeriodMin );
220 }
221
222 return pdFALSE;
223 }
224 /*-----------------------------------------------------------*/
225
pxPortInitialiseStack(StackType_t * pxTopOfStack,TaskFunction_t pxCode,void * pvParameters)226 StackType_t *pxPortInitialiseStack( StackType_t *pxTopOfStack, TaskFunction_t pxCode, void *pvParameters )
227 {
228 ThreadState_t *pxThreadState = NULL;
229 int8_t *pcTopOfStack = ( int8_t * ) pxTopOfStack;
230 const SIZE_T xStackSize = 1024; /* Set the size to a small number which will get rounded up to the minimum possible. */
231
232 /* In this simulated case a stack is not initialised, but instead a thread
233 is created that will execute the task being created. The thread handles
234 the context switching itself. The ThreadState_t object is placed onto
235 the stack that was created for the task - so the stack buffer is still
236 used, just not in the conventional way. It will not be used for anything
237 other than holding this structure. */
238 pxThreadState = ( ThreadState_t * ) ( pcTopOfStack - sizeof( ThreadState_t ) );
239
240 /* Create the event used to prevent the thread from executing past its yield
241 point if the SuspendThread() call that suspends the thread does not take
242 effect immediately (it is an asynchronous call). */
243 pxThreadState->pvYieldEvent = CreateEvent( NULL, /* Default security attributes. */
244 FALSE, /* Auto reset. */
245 FALSE, /* Start not signalled. */
246 NULL );/* No name. */
247
248 /* Create the thread itself. */
249 pxThreadState->pvThread = CreateThread( NULL, xStackSize, ( LPTHREAD_START_ROUTINE ) pxCode, pvParameters, CREATE_SUSPENDED | STACK_SIZE_PARAM_IS_A_RESERVATION, NULL );
250 configASSERT( pxThreadState->pvThread ); /* See comment where TerminateThread() is called. */
251 SetThreadAffinityMask( pxThreadState->pvThread, 0x01 );
252 SetThreadPriorityBoost( pxThreadState->pvThread, TRUE );
253 SetThreadPriority( pxThreadState->pvThread, portTASK_THREAD_PRIORITY );
254
255 return ( StackType_t * ) pxThreadState;
256 }
257 /*-----------------------------------------------------------*/
258
xPortStartScheduler(void)259 BaseType_t xPortStartScheduler( void )
260 {
261 void *pvHandle = NULL;
262 int32_t lSuccess;
263 ThreadState_t *pxThreadState = NULL;
264 SYSTEM_INFO xSystemInfo;
265
266 /* This port runs windows threads with extremely high priority. All the
267 threads execute on the same core - to prevent locking up the host only start
268 if the host has multiple cores. */
269 GetSystemInfo( &xSystemInfo );
270 if( xSystemInfo.dwNumberOfProcessors <= 1 )
271 {
272 printf( "This version of the FreeRTOS Windows port can only be used on multi-core hosts.\r\n" );
273 lSuccess = pdFAIL;
274 }
275 else
276 {
277 lSuccess = pdPASS;
278
279 /* The highest priority class is used to [try to] prevent other Windows
280 activity interfering with FreeRTOS timing too much. */
281 if( SetPriorityClass( GetCurrentProcess(), REALTIME_PRIORITY_CLASS ) == 0 )
282 {
283 printf( "SetPriorityClass() failed\r\n" );
284 }
285
286 /* Install the interrupt handlers used by the scheduler itself. */
287 vPortSetInterruptHandler( portINTERRUPT_YIELD, prvProcessYieldInterrupt );
288 vPortSetInterruptHandler( portINTERRUPT_TICK, prvProcessTickInterrupt );
289
290 /* Create the events and mutexes that are used to synchronise all the
291 threads. */
292 pvInterruptEventMutex = CreateMutex( NULL, FALSE, NULL );
293 pvInterruptEvent = CreateEvent( NULL, FALSE, FALSE, NULL );
294
295 if( ( pvInterruptEventMutex == NULL ) || ( pvInterruptEvent == NULL ) )
296 {
297 lSuccess = pdFAIL;
298 }
299
300 /* Set the priority of this thread such that it is above the priority of
301 the threads that run tasks. This higher priority is required to ensure
302 simulated interrupts take priority over tasks. */
303 pvHandle = GetCurrentThread();
304 if( pvHandle == NULL )
305 {
306 lSuccess = pdFAIL;
307 }
308 }
309
310 if( lSuccess == pdPASS )
311 {
312 if( SetThreadPriority( pvHandle, portSIMULATED_INTERRUPTS_THREAD_PRIORITY ) == 0 )
313 {
314 lSuccess = pdFAIL;
315 }
316 SetThreadPriorityBoost( pvHandle, TRUE );
317 SetThreadAffinityMask( pvHandle, 0x01 );
318 }
319
320 if( lSuccess == pdPASS )
321 {
322 /* Start the thread that simulates the timer peripheral to generate
323 tick interrupts. The priority is set below that of the simulated
324 interrupt handler so the interrupt event mutex is used for the
325 handshake / overrun protection. */
326 pvHandle = CreateThread( NULL, 0, prvSimulatedPeripheralTimer, NULL, CREATE_SUSPENDED, NULL );
327 if( pvHandle != NULL )
328 {
329 SetThreadPriority( pvHandle, portSIMULATED_TIMER_THREAD_PRIORITY );
330 SetThreadPriorityBoost( pvHandle, TRUE );
331 SetThreadAffinityMask( pvHandle, 0x01 );
332 ResumeThread( pvHandle );
333 }
334
335 /* Start the highest priority task by obtaining its associated thread
336 state structure, in which is stored the thread handle. */
337 pxThreadState = ( ThreadState_t * ) *( ( size_t * ) pxCurrentTCB );
338 ulCriticalNesting = portNO_CRITICAL_NESTING;
339
340 /* Start the first task. */
341 ResumeThread( pxThreadState->pvThread );
342
343 /* Handle all simulated interrupts - including yield requests and
344 simulated ticks. */
345 prvProcessSimulatedInterrupts();
346 }
347
348 /* Would not expect to return from prvProcessSimulatedInterrupts(), so should
349 not get here. */
350 return 0;
351 }
352 /*-----------------------------------------------------------*/
353
prvProcessYieldInterrupt(void)354 static uint32_t prvProcessYieldInterrupt( void )
355 {
356 /* Always return true as this is a yield. */
357 return pdTRUE;
358 }
359 /*-----------------------------------------------------------*/
360
prvProcessTickInterrupt(void)361 static uint32_t prvProcessTickInterrupt( void )
362 {
363 uint32_t ulSwitchRequired;
364
365 /* Process the tick itself. */
366 configASSERT( xPortRunning );
367 ulSwitchRequired = ( uint32_t ) xTaskIncrementTick();
368
369 return ulSwitchRequired;
370 }
371 /*-----------------------------------------------------------*/
372
prvProcessSimulatedInterrupts(void)373 static void prvProcessSimulatedInterrupts( void )
374 {
375 uint32_t ulSwitchRequired, i;
376 ThreadState_t *pxThreadState;
377 void *pvObjectList[ 2 ];
378 CONTEXT xContext;
379
380 /* Going to block on the mutex that ensured exclusive access to the simulated
381 interrupt objects, and the event that signals that a simulated interrupt
382 should be processed. */
383 pvObjectList[ 0 ] = pvInterruptEventMutex;
384 pvObjectList[ 1 ] = pvInterruptEvent;
385
386 /* Create a pending tick to ensure the first task is started as soon as
387 this thread pends. */
388 ulPendingInterrupts |= ( 1 << portINTERRUPT_TICK );
389 SetEvent( pvInterruptEvent );
390
391 xPortRunning = pdTRUE;
392
393 for(;;)
394 {
395 xInsideInterrupt = pdFALSE;
396 WaitForMultipleObjects( sizeof( pvObjectList ) / sizeof( void * ), pvObjectList, TRUE, INFINITE );
397
398 /* Cannot be in a critical section to get here. Tasks that exit a
399 critical section will block on a yield mutex to wait for an interrupt to
400 process if an interrupt was set pending while the task was inside the
401 critical section. xInsideInterrupt prevents interrupts that contain
402 critical sections from doing the same. */
403 xInsideInterrupt = pdTRUE;
404
405 /* Used to indicate whether the simulated interrupt processing has
406 necessitated a context switch to another task/thread. */
407 ulSwitchRequired = pdFALSE;
408
409 /* For each interrupt we are interested in processing, each of which is
410 represented by a bit in the 32bit ulPendingInterrupts variable. */
411 for( i = 0; i < portMAX_INTERRUPTS; i++ )
412 {
413 /* Is the simulated interrupt pending? */
414 if( ( ulPendingInterrupts & ( 1UL << i ) ) != 0 )
415 {
416 /* Is a handler installed? */
417 if( ulIsrHandler[ i ] != NULL )
418 {
419 /* Run the actual handler. Handlers return pdTRUE if they
420 necessitate a context switch. */
421 if( ulIsrHandler[ i ]() != pdFALSE )
422 {
423 /* A bit mask is used purely to help debugging. */
424 ulSwitchRequired |= ( 1 << i );
425 }
426 }
427
428 /* Clear the interrupt pending bit. */
429 ulPendingInterrupts &= ~( 1UL << i );
430 }
431 }
432
433 if( ulSwitchRequired != pdFALSE )
434 {
435 void *pvOldCurrentTCB;
436
437 pvOldCurrentTCB = pxCurrentTCB;
438
439 /* Select the next task to run. */
440 vTaskSwitchContext();
441
442 /* If the task selected to enter the running state is not the task
443 that is already in the running state. */
444 if( pvOldCurrentTCB != pxCurrentTCB )
445 {
446 /* Suspend the old thread. In the cases where the (simulated)
447 interrupt is asynchronous (tick event swapping a task out rather
448 than a task blocking or yielding) it doesn't matter if the
449 'suspend' operation doesn't take effect immediately - if it
450 doesn't it would just be like the interrupt occurring slightly
451 later. In cases where the yield was caused by a task blocking
452 or yielding then the task will block on a yield event after the
453 yield operation in case the 'suspend' operation doesn't take
454 effect immediately. */
455 pxThreadState = ( ThreadState_t *) *( ( size_t * ) pvOldCurrentTCB );
456 SuspendThread( pxThreadState->pvThread );
457
458 /* Ensure the thread is actually suspended by performing a
459 synchronous operation that can only complete when the thread is
460 actually suspended. The below code asks for dummy register
461 data. Experimentation shows that these two lines don't appear
462 to do anything now, but according to
463 https://devblogs.microsoft.com/oldnewthing/20150205-00/?p=44743
464 they do - so as they do not harm (slight run-time hit). */
465 xContext.ContextFlags = CONTEXT_INTEGER;
466 ( void ) GetThreadContext( pxThreadState->pvThread, &xContext );
467
468 /* Obtain the state of the task now selected to enter the
469 Running state. */
470 pxThreadState = ( ThreadState_t * ) ( *( size_t *) pxCurrentTCB );
471
472 /* pxThreadState->pvThread can be NULL if the task deleted
473 itself - but a deleted task should never be resumed here. */
474 configASSERT( pxThreadState->pvThread != NULL );
475 ResumeThread( pxThreadState->pvThread );
476 }
477 }
478
479 /* If the thread that is about to be resumed stopped running
480 because it yielded then it will wait on an event when it resumed
481 (to ensure it does not continue running after the call to
482 SuspendThread() above as SuspendThread() is asynchronous).
483 Signal the event to ensure the thread can proceed now it is
484 valid for it to do so. Signaling the event is benign in the case that
485 the task was switched out asynchronously by an interrupt as the event
486 is reset before the task blocks on it. */
487 pxThreadState = ( ThreadState_t * ) ( *( size_t *) pxCurrentTCB );
488 SetEvent( pxThreadState->pvYieldEvent );
489 ReleaseMutex( pvInterruptEventMutex );
490 }
491 }
492 /*-----------------------------------------------------------*/
493
vPortDeleteThread(void * pvTaskToDelete)494 void vPortDeleteThread( void *pvTaskToDelete )
495 {
496 ThreadState_t *pxThreadState;
497 uint32_t ulErrorCode;
498
499 /* Remove compiler warnings if configASSERT() is not defined. */
500 ( void ) ulErrorCode;
501
502 /* Find the handle of the thread being deleted. */
503 pxThreadState = ( ThreadState_t * ) ( *( size_t *) pvTaskToDelete );
504
505 /* Check that the thread is still valid, it might have been closed by
506 vPortCloseRunningThread() - which will be the case if the task associated
507 with the thread originally deleted itself rather than being deleted by a
508 different task. */
509 if( pxThreadState->pvThread != NULL )
510 {
511 WaitForSingleObject( pvInterruptEventMutex, INFINITE );
512
513 /* !!! This is not a nice way to terminate a thread, and will eventually
514 result in resources being depleted if tasks frequently delete other
515 tasks (rather than deleting themselves) as the task stacks will not be
516 freed. */
517 ulErrorCode = TerminateThread( pxThreadState->pvThread, 0 );
518 configASSERT( ulErrorCode );
519
520 ulErrorCode = CloseHandle( pxThreadState->pvThread );
521 configASSERT( ulErrorCode );
522
523 ReleaseMutex( pvInterruptEventMutex );
524 }
525 }
526 /*-----------------------------------------------------------*/
527
vPortCloseRunningThread(void * pvTaskToDelete,volatile BaseType_t * pxPendYield)528 void vPortCloseRunningThread( void *pvTaskToDelete, volatile BaseType_t *pxPendYield )
529 {
530 ThreadState_t *pxThreadState;
531 void *pvThread;
532 uint32_t ulErrorCode;
533
534 /* Remove compiler warnings if configASSERT() is not defined. */
535 ( void ) ulErrorCode;
536
537 /* Find the handle of the thread being deleted. */
538 pxThreadState = ( ThreadState_t * ) ( *( size_t *) pvTaskToDelete );
539 pvThread = pxThreadState->pvThread;
540
541 /* Raise the Windows priority of the thread to ensure the FreeRTOS scheduler
542 does not run and swap it out before it is closed. If that were to happen
543 the thread would never run again and effectively be a thread handle and
544 memory leak. */
545 SetThreadPriority( pvThread, portDELETE_SELF_THREAD_PRIORITY );
546
547 /* This function will not return, therefore a yield is set as pending to
548 ensure a context switch occurs away from this thread on the next tick. */
549 *pxPendYield = pdTRUE;
550
551 /* Mark the thread associated with this task as invalid so
552 vPortDeleteThread() does not try to terminate it. */
553 pxThreadState->pvThread = NULL;
554
555 /* Close the thread. */
556 ulErrorCode = CloseHandle( pvThread );
557 configASSERT( ulErrorCode );
558
559 /* This is called from a critical section, which must be exited before the
560 thread stops. */
561 taskEXIT_CRITICAL();
562 CloseHandle( pxThreadState->pvYieldEvent );
563 ExitThread( 0 );
564 }
565 /*-----------------------------------------------------------*/
566
vPortEndScheduler(void)567 void vPortEndScheduler( void )
568 {
569 xPortRunning = pdFALSE;
570 }
571 /*-----------------------------------------------------------*/
572
vPortGenerateSimulatedInterrupt(uint32_t ulInterruptNumber)573 void vPortGenerateSimulatedInterrupt( uint32_t ulInterruptNumber )
574 {
575 ThreadState_t *pxThreadState = ( ThreadState_t *) *( ( size_t * ) pxCurrentTCB );
576
577 configASSERT( xPortRunning );
578
579 if( ( ulInterruptNumber < portMAX_INTERRUPTS ) && ( pvInterruptEventMutex != NULL ) )
580 {
581 WaitForSingleObject( pvInterruptEventMutex, INFINITE );
582 ulPendingInterrupts |= ( 1 << ulInterruptNumber );
583
584 /* The simulated interrupt is now held pending, but don't actually
585 process it yet if this call is within a critical section. It is
586 possible for this to be in a critical section as calls to wait for
587 mutexes are accumulative. If in a critical section then the event
588 will get set when the critical section nesting count is wound back
589 down to zero. */
590 if( ulCriticalNesting == portNO_CRITICAL_NESTING )
591 {
592 SetEvent( pvInterruptEvent );
593
594 /* Going to wait for an event - make sure the event is not already
595 signaled. */
596 ResetEvent( pxThreadState->pvYieldEvent );
597 }
598
599 ReleaseMutex( pvInterruptEventMutex );
600 if( ulCriticalNesting == portNO_CRITICAL_NESTING )
601 {
602 /* An interrupt was pended so ensure to block to allow it to
603 execute. In most cases the (simulated) interrupt will have
604 executed before the next line is reached - so this is just to make
605 sure. */
606 WaitForSingleObject( pxThreadState->pvYieldEvent, INFINITE );
607 }
608 }
609 }
610 /*-----------------------------------------------------------*/
611
vPortSetInterruptHandler(uint32_t ulInterruptNumber,uint32_t (* pvHandler)(void))612 void vPortSetInterruptHandler( uint32_t ulInterruptNumber, uint32_t (*pvHandler)( void ) )
613 {
614 if( ulInterruptNumber < portMAX_INTERRUPTS )
615 {
616 if( pvInterruptEventMutex != NULL )
617 {
618 WaitForSingleObject( pvInterruptEventMutex, INFINITE );
619 ulIsrHandler[ ulInterruptNumber ] = pvHandler;
620 ReleaseMutex( pvInterruptEventMutex );
621 }
622 else
623 {
624 ulIsrHandler[ ulInterruptNumber ] = pvHandler;
625 }
626 }
627 }
628 /*-----------------------------------------------------------*/
629
vPortEnterCritical(void)630 void vPortEnterCritical( void )
631 {
632 if( xPortRunning == pdTRUE )
633 {
634 /* The interrupt event mutex is held for the entire critical section,
635 effectively disabling (simulated) interrupts. */
636 WaitForSingleObject( pvInterruptEventMutex, INFINITE );
637 }
638
639 ulCriticalNesting++;
640 }
641 /*-----------------------------------------------------------*/
642
vPortExitCritical(void)643 void vPortExitCritical( void )
644 {
645 int32_t lMutexNeedsReleasing;
646
647 /* The interrupt event mutex should already be held by this thread as it was
648 obtained on entry to the critical section. */
649 lMutexNeedsReleasing = pdTRUE;
650
651 if( ulCriticalNesting > portNO_CRITICAL_NESTING )
652 {
653 ulCriticalNesting--;
654
655 /* Don't need to wait for any pending interrupts to execute if the
656 critical section was exited from inside an interrupt. */
657 if( ( ulCriticalNesting == portNO_CRITICAL_NESTING ) && ( xInsideInterrupt == pdFALSE ) )
658 {
659 /* Were any interrupts set to pending while interrupts were
660 (simulated) disabled? */
661 if( ulPendingInterrupts != 0UL )
662 {
663 ThreadState_t *pxThreadState = ( ThreadState_t *) *( ( size_t * ) pxCurrentTCB );
664
665 configASSERT( xPortRunning );
666
667 /* The interrupt won't actually executed until
668 pvInterruptEventMutex is released as it waits on both
669 pvInterruptEventMutex and pvInterruptEvent.
670 pvInterruptEvent is only set when the simulated
671 interrupt is pended if the interrupt is pended
672 from outside a critical section - hence it is set
673 here. */
674 SetEvent( pvInterruptEvent );
675 /* The calling task is going to wait for an event to ensure the
676 interrupt that is pending executes immediately after the
677 critical section is exited - so make sure the event is not
678 already signaled. */
679 ResetEvent( pxThreadState->pvYieldEvent );
680
681 /* Mutex will be released now so the (simulated) interrupt can
682 execute, so does not require releasing on function exit. */
683 lMutexNeedsReleasing = pdFALSE;
684 ReleaseMutex( pvInterruptEventMutex );
685 WaitForSingleObject( pxThreadState->pvYieldEvent, INFINITE );
686 }
687 }
688 }
689
690 if( pvInterruptEventMutex != NULL )
691 {
692 if( lMutexNeedsReleasing == pdTRUE )
693 {
694 configASSERT( xPortRunning );
695 ReleaseMutex( pvInterruptEventMutex );
696 }
697 }
698 }
699 /*-----------------------------------------------------------*/
700