xref: /Kernel-v10.6.2/portable/MSVC-MingW/port.c (revision ef7b253b56c9788077f5ecd6c9deb4021923d646)
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