#include <debug.h>
#include <lwip/sys.h>
#include "lwip_glue.h"

Include dependency graph for sys_arch.c:

Classes
struct	_thread_t

Typedefs
typedef struct _thread_t *	thread_t

Functions
u32_t	sys_now (void)

void	sys_arch_protect (sys_prot_t *lev)

void	sys_arch_unprotect (sys_prot_t lev)

err_t	sys_sem_new (sys_sem_t *sem, u8_t count)

int	sys_sem_valid (sys_sem_t *sem)

void	sys_sem_set_invalid (sys_sem_t *sem)

void	sys_sem_free (sys_sem_t *sem)

void	sys_sem_signal (sys_sem_t *sem)

u32_t	sys_arch_sem_wait (sys_sem_t *sem, u32_t timeout)

err_t	sys_mbox_new (sys_mbox_t *mbox, int size)

int	sys_mbox_valid (sys_mbox_t *mbox)

void	sys_mbox_set_invalid (sys_mbox_t *mbox)

void	sys_mbox_free (sys_mbox_t *mbox)

void	sys_mbox_post (sys_mbox_t mbox, void msg)

u32_t	sys_arch_mbox_fetch (sys_mbox_t mbox, void *msg, u32_t timeout)

u32_t	sys_arch_mbox_tryfetch (sys_mbox_t mbox, void *msg)

err_t	sys_mbox_trypost (sys_mbox_t mbox, void msg)

VOID NTAPI	LwipThreadMain (PVOID Context)

sys_thread_t	sys_thread_new (const char name, lwip_thread_fn thread, void arg, int stacksize, int prio)

void	sys_init (void)

void	sys_shutdown (void)

Variables
static LIST_ENTRY	ThreadListHead

static KSPIN_LOCK	ThreadListLock

static ERESOURCE	GlobalLock

static ULONG	GlobalLockLevel = 0

KEVENT	TerminationEvent

NPAGED_LOOKASIDE_LIST	MessageLookasideList

NPAGED_LOOKASIDE_LIST	QueueEntryLookasideList

static LARGE_INTEGER	StartTime

Typedef Documentation

◆ thread_t

typedef struct _thread_t * thread_t

Function Documentation

◆ LwipThreadMain()

VOID NTAPI LwipThreadMain ( PVOID Context )

Definition at line 260 of file sys_arch.c.

{
    thread_t Container = (thread_t)Context;
    KIRQL OldIrql;
 
    ExInterlockedInsertHeadList(&ThreadListHead, &Container->ListEntry, &ThreadListLock);
 
    Container->ThreadFunction(Container->ThreadContext);
 
    KeAcquireSpinLock(&ThreadListLock, &OldIrql);
    RemoveEntryList(&Container->ListEntry);
    KeReleaseSpinLock(&ThreadListLock, OldIrql);
 
    ExFreePool(Container);
 
    PsTerminateSystemThread(STATUS_SUCCESS);
}

Referenced by sys_thread_new().

◆ sys_arch_protect()

void sys_arch_protect ( sys_prot_t * lev )

Definition at line 35 of file sys_arch.c.

{
    /* Acquire the global resource to prevent other CPUs from running */
    ExEnterCriticalRegionAndAcquireResourceExclusive(&GlobalLock);
    *lev = ++GlobalLockLevel;
}

◆ sys_arch_unprotect()

void sys_arch_unprotect ( sys_prot_t lev )

Definition at line 43 of file sys_arch.c.

{
    /* Release the global resource */
    ASSERT((GlobalLockLevel > 0) && (lev == GlobalLockLevel));
    GlobalLockLevel--;
    ExReleaseResourceAndLeaveCriticalRegion(&GlobalLock);
}

◆ sys_shutdown()

void sys_shutdown ( void )

Definition at line 336 of file sys_arch.c.

{
    PLIST_ENTRY CurrentEntry;
    thread_t Container;
 
    /* Set the termination event */
    KeSetEvent(&TerminationEvent, IO_NO_INCREMENT, FALSE);
 
    /* Loop through the thread list and wait for each to die */
    while ((CurrentEntry = ExInterlockedRemoveHeadList(&ThreadListHead, &ThreadListLock)))
    {
        Container = CONTAINING_RECORD(CurrentEntry, struct _thread_t, ListEntry);
 
        if (Container->ThreadFunction)
        {
            KeWaitForSingleObject(Container->Handle,
                                  Executive,
                                  KernelMode,
                                  FALSE,
                                  NULL);
 
            ZwClose(Container->Handle);
        }
    }
 
    ExDeleteNPagedLookasideList(&MessageLookasideList);
    ExDeleteNPagedLookasideList(&QueueEntryLookasideList);
}