X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=Kernel%2Farch%2Farmv7%2Fproc.c;h=146899c14293998a7d7bd4ba1d524dce17a388bb;hb=6a6f4fdb0cce6558bac6b30ce312555bb48a2c0a;hp=7dfbb456e55774c1012cb4abf8e05206e100178b;hpb=f9c581641afeb556188e84428febd4011e61edc2;p=tpg%2Facess2.git diff --git a/Kernel/arch/armv7/proc.c b/Kernel/arch/armv7/proc.c index 7dfbb456..146899c1 100644 --- a/Kernel/arch/armv7/proc.c +++ b/Kernel/arch/armv7/proc.c @@ -13,6 +13,7 @@ extern tThread gThreadZero; extern void SwitchTask(Uint32 NewSP, Uint32 *OldSP, Uint32 NewIP, Uint32 *OldIP, Uint32 MemPtr); extern void KernelThreadHeader(void); // Actually takes args on stack +extern void Proc_CloneInt(Uint32 *SP, Uint32 *MemPtr); extern tVAddr MM_NewKStack(int bGlobal); // TODO: Move out into a header // === PROTOTYPES === @@ -30,9 +31,11 @@ void ArchThreads_Init(void) void Proc_IdleThread(void *unused) { + Threads_SetPriority(gpIdleThread, -1); + Threads_SetName("Idle Thread"); for(;;) { - __asm__ __volatile__ ("wfi"); Proc_Reschedule(); + __asm__ __volatile__ ("wfi"); } } @@ -54,18 +57,52 @@ tThread *Proc_GetCurThread(void) return gpCurrentThread; } -tTID Proc_Clone(Uint Flags) +void Proc_StartUser(Uint Entrypoint, Uint *Bases, int ArgC, char **ArgV, char **EnvP, int DataSize) { - return -1; + Log_Debug("Proc", "Proc_StartUser: (Entrypoint=%p, Bases=%p, ArgC=%i, ...)", + Entrypoint, Bases, ArgC); } -void Proc_StartUser(Uint Entrypoint, Uint *Bases, int ArgC, char **ArgV, char **EnvP, int DataSize) +tTID Proc_Clone(Uint Flags) { + tThread *new; + + new = Threads_CloneTCB(Flags); + if(!new) return -1; + + Log_Error("Proc", "TODO: Implement Proc_Clone"); + + return -1; } tTID Proc_SpawnWorker( void (*Fnc)(void*), void *Ptr ) { - return -1; + tThread *new; + Uint32 sp; + + new = Threads_CloneThreadZero(); + if(!new) return -1; + + new->KernelStack = MM_NewKStack(1); + if(!new->KernelStack) { + // TODO: Delete thread + Log_Error("Proc", "Unable to allocate kernel stack"); + return -1; + } + + sp = new->KernelStack; + + *(Uint32*)(sp -= 4) = (Uint)Ptr; + *(Uint32*)(sp -= 4) = 1; + *(Uint32*)(sp -= 4) = (Uint)Fnc; + *(Uint32*)(sp -= 4) = (Uint)new; + + new->SavedState.SP = sp; + new->SavedState.IP = (Uint)KernelThreadHeader; + + Threads_AddActive(new); + + return new->TID; } tTID Proc_NewKThread( void (*Fnc)(void*), void *Ptr ) @@ -73,9 +110,10 @@ tTID Proc_NewKThread( void (*Fnc)(void*), void *Ptr ) tThread *new; Uint32 sp; - new = Threads_CloneTCB(NULL, 0); + new = Threads_CloneTCB(0); if(!new) return -1; + // TODO: Non-shared stack new->KernelStack = MM_NewKStack(1); if(!new->KernelStack) { // TODO: Delete thread @@ -85,10 +123,10 @@ tTID Proc_NewKThread( void (*Fnc)(void*), void *Ptr ) sp = new->KernelStack; - *(Uint32*)(sp -= 4) = (Uint)new; - *(Uint32*)(sp -= 4) = (Uint)Fnc; - *(Uint32*)(sp -= 4) = 1; *(Uint32*)(sp -= 4) = (Uint)Ptr; + *(Uint32*)(sp -= 4) = 1; + *(Uint32*)(sp -= 4) = (Uint)Fnc; + *(Uint32*)(sp -= 4) = (Uint)new; new->SavedState.SP = sp; new->SavedState.IP = (Uint)KernelThreadHeader; @@ -113,7 +151,8 @@ void Proc_Reschedule(void) if(!next) next = gpIdleThread; if(!next || next == cur) return; - Log("Switching to %p (%i) IP=%p SP=%p", next, next->TID, next->SavedState.IP, next->SavedState.SP); + Log("Switching to %p (%i %s) IP=%p SP=%p", next, next->TID, next->ThreadName, next->SavedState.IP, next->SavedState.SP); + Log("Requested by %p", __builtin_return_address(0)); gpCurrentThread = next; // TODO: Change kernel stack?