Ros-diffs August 2005

ros-diffs@reactos.org

23 participants
669 discussions

[mbosma] 17238: Add second call to DdQueryDirectDrawObject.
by mbosma＠svn.reactos.com 09 Aug '05

09 Aug '05

Add second call to DdQueryDirectDrawObject. Modified: trunk/reactos/lib/ddraw/hal/ddraw.c Modified: trunk/reactos/lib/ddraw/rosdraw.h _____ Modified: trunk/reactos/lib/ddraw/hal/ddraw.c --- trunk/reactos/lib/ddraw/hal/ddraw.c 2005-08-09 11:18:48 UTC (rev 17237) +++ trunk/reactos/lib/ddraw/hal/ddraw.c 2005-08-09 13:57:03 UTC (rev 17238) @@ -19,11 +19,11 @@ return DDERR_INVALIDPARAMS; This->HalInfo.dwSize = sizeof(DDHALINFO); + This->D3dDriverData.dwSize = sizeof(D3DHAL_GLOBALDRIVERDATA); This->DriverCallbacks.DdMain.dwSize = sizeof(DDHAL_DDCALLBACKS); This->DriverCallbacks.DdSurface.dwSize = sizeof(DDHAL_DDSURFACECALLBACKS); This->DriverCallbacks.DdPalette.dwSize = sizeof(DDHAL_DDPALETTECALLBACKS); This->DriverCallbacks.D3dMain.dwSize = sizeof(D3DHAL_CALLBACKS); - This->DriverCallbacks.D3dDriverData.dwSize = sizeof(D3DHAL_GLOBALDRIVERDATA); This->DriverCallbacks.D3dBufferCallbacks.dwSize = sizeof(DDHAL_DDEXEBUFCALLBACKS); if(!DdQueryDirectDrawObject ( @@ -33,15 +33,31 @@ &This->DriverCallbacks.DdSurface, &This->DriverCallbacks.DdPalette, &This->DriverCallbacks.D3dMain, - &This->DriverCallbacks.D3dDriverData, + &This->D3dDriverData, &This->DriverCallbacks.D3dBufferCallbacks, NULL, NULL, NULL )) return DDERR_INVALIDPARAMS; - // ToDo: Second DdQueryDirectDrawObject without the three NULLs + This->pD3dTextureFormats = HeapAlloc(GetProcessHeap(), 0, sizeof(DDSURFACEDESC) * This->D3dDriverData.dwNumTextureFormats); + This->pdwFourCC = HeapAlloc(GetProcessHeap(), 0, sizeof(DWORD) * This->HalInfo.ddCaps.dwNumFourCCCodes); + This->pvmList = HeapAlloc(GetProcessHeap(), 0, sizeof(VIDMEM) * This->HalInfo.vmiData.dwNumHeaps); + if(!DdQueryDirectDrawObject ( + &This->DirectDrawGlobal, + &This->HalInfo, + &This->DriverCallbacks.DdMain, + &This->DriverCallbacks.DdSurface, + &This->DriverCallbacks.DdPalette, + &This->DriverCallbacks.D3dMain, + &This->D3dDriverData, + &This->DriverCallbacks.D3dBufferCallbacks, + This->pD3dTextureFormats, + This->pdwFourCC, + This->pvmList )) + return DDERR_INVALIDPARAMS; + return DD_OK; } @@ -55,8 +71,11 @@ IDirectDrawImpl* This = (IDirectDrawImpl*)iface; DdDeleteDirectDrawObject (&This->DirectDrawGlobal); + + if(This->pD3dTextureFormats) + HeapFree(GetProcessHeap(), 0, This->pD3dTextureFormats); + if(This->pdwFourCC) + HeapFree(GetProcessHeap(), 0, This->pdwFourCC); + if(This->pvmList) + HeapFree(GetProcessHeap(), 0, This->pvmList); } - - - - _____ Modified: trunk/reactos/lib/ddraw/rosdraw.h --- trunk/reactos/lib/ddraw/rosdraw.h 2005-08-09 11:18:48 UTC (rev 17237) +++ trunk/reactos/lib/ddraw/rosdraw.h 2005-08-09 13:57:03 UTC (rev 17238) @@ -22,7 +22,6 @@ DDHAL_DDSURFACECALLBACKS DdSurface; DDHAL_DDPALETTECALLBACKS DdPalette; D3DHAL_CALLBACKS D3dMain; - D3DHAL_GLOBALDRIVERDATA D3dDriverData; DDHAL_DDEXEBUFCALLBACKS D3dBufferCallbacks; } DRIVERCALLBACKS; @@ -33,8 +32,13 @@ DRIVERCALLBACKS DriverCallbacks; DWORD ref; - DDHALINFO HalInfo; + DDHALINFO HalInfo; + D3DHAL_GLOBALDRIVERDATA D3dDriverData; + LPDDSURFACEDESC pD3dTextureFormats; + LPDWORD pdwFourCC; + LPVIDMEM pvmList; + HWND window; DWORD cooperative_level; HDC hdc;

1 0

[greatlrd] 17237: fix a minor bug, for bad writen driver. some drv checking for two DDRAWI_DDRAWSURFACE_LCL array instead for one. But it is not the bug
by greatlrd＠svn.reactos.com 09 Aug '05

09 Aug '05

fix a minor bug, for bad writen driver. some drv checking for two DDRAWI_DDRAWSURFACE_LCL array instead for one. But it is not the bug Modified: trunk/reactos/lib/ddraw/main/surface.c _____ Modified: trunk/reactos/lib/ddraw/main/surface.c --- trunk/reactos/lib/ddraw/main/surface.c 2005-08-09 08:54:56 UTC (rev 17236) +++ trunk/reactos/lib/ddraw/main/surface.c 2005-08-09 11:18:48 UTC (rev 17237) @@ -49,19 +49,27 @@ Local.lpGbl = &Global; Local.lpSurfMore = &More; Local.ddsCaps = *(DDSCAPS*)&pDDSD->ddsCaps; + + // BitDepth = DDSurf_BitDepth(psurf); ? + if(pDDSD->ddsCaps.dwCaps == DDSCAPS_PRIMARYSURFACE) Local.dwFlags |= DDRAWISURF_FRONTBUFFER; - DDRAWI_DDRAWSURFACE_LCL* pLocal = &Local; // for stupid double pointer below + DDRAWI_DDRAWSURFACE_LCL *pLocal[2]; // for stupid double pointer below + pLocal[0] = &Local; + pLocal[1] = NULL; + // The Parameter Struct DDHAL_CREATESURFACEDATA CreateData; memset(&CreateData, 0, sizeof(DDHAL_CREATESURFACEDATA)); CreateData.lpDD = &This->owner->DirectDrawGlobal; CreateData.lpDDSurfaceDesc = (DDSURFACEDESC*)pDDSD; CreateData.dwSCnt = 1; - CreateData.lplpSList = &pLocal; + CreateData.lplpSList = pLocal; + + DDHAL_CANCREATESURFACEDATA CanCreateData; memset(&CanCreateData, 0, sizeof(DD_CANCREATESURFACEDATA));

1 0

[ion] 17236: Return failure if native function failed. one more test passes
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

Return failure if native function failed. one more test passes Modified: trunk/reactos/lib/kernel32/thread/thread.c _____ Modified: trunk/reactos/lib/kernel32/thread/thread.c --- trunk/reactos/lib/kernel32/thread/thread.c 2005-08-09 08:50:57 UTC (rev 17235) +++ trunk/reactos/lib/kernel32/thread/thread.c 2005-08-09 08:54:56 UTC (rev 17236) @@ -530,7 +530,10 @@ &AffinityMask, sizeof(KAFFINITY)); if (!NT_SUCCESS(Status)) + { SetLastErrorByStatus(Status); + ThreadBasic.AffinityMask = 0; + } return(ThreadBasic.AffinityMask); }

1 0

[ion] 17235: - Last patch was incomplete, apologies. SVN @ 5AM = bad idea.
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

- Last patch was incomplete, apologies. SVN @ 5AM = bad idea. - Do not report that ROS is running on 0 active processors, that's a bad idea. - Actually check the affinity mask set by NtSetInformationThread - Fix the check in KeSetAffinityThread - Give a valid affinity to the system thread (corresponding to the active cpu affinity set). This removes all bugchecks from the kernel32 thread winetest. Modified: trunk/reactos/ntoskrnl/include/internal/ke.h Modified: trunk/reactos/ntoskrnl/ke/kthread.c Modified: trunk/reactos/ntoskrnl/ke/main.c Modified: trunk/reactos/ntoskrnl/ps/psmgr.c Modified: trunk/reactos/ntoskrnl/ps/query.c _____ Modified: trunk/reactos/ntoskrnl/include/internal/ke.h --- trunk/reactos/ntoskrnl/include/internal/ke.h 2005-08-09 08:02:05 UTC (rev 17234) +++ trunk/reactos/ntoskrnl/include/internal/ke.h 2005-08-09 08:50:57 UTC (rev 17235) @@ -228,6 +228,12 @@ VOID STDCALL +KiSetPriorityThread(PKTHREAD Thread, + KPRIORITY Priority, + PBOOLEAN Released); + +VOID +STDCALL KeStackAttachProcess ( IN struct _KPROCESS* Process, OUT PKAPC_STATE ApcState _____ Modified: trunk/reactos/ntoskrnl/ke/kthread.c --- trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 08:02:05 UTC (rev 17234) +++ trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 08:50:57 UTC (rev 17235) @@ -1299,7 +1299,12 @@ DPRINT("KeSetAffinityThread(Thread %x, Affinity %x)\n", Thread, Affinity); - ASSERT(Affinity & ((1 << KeNumberProcessors) - 1)); + /* Verify correct affinity */ + if ((Affinity & Thread->ApcStatePointer[0]->Process->Affinity) != + Affinity || !Affinity) + { + KEBUGCHECK(INVALID_AFFINITY_SET); + } OldIrql = KeAcquireDispatcherDatabaseLock(); _____ Modified: trunk/reactos/ntoskrnl/ke/main.c --- trunk/reactos/ntoskrnl/ke/main.c 2005-08-09 08:02:05 UTC (rev 17234) +++ trunk/reactos/ntoskrnl/ke/main.c 2005-08-09 08:50:57 UTC (rev 17235) @@ -25,7 +25,7 @@ EXPORTED ULONG NtBuildNumber = KERNEL_VERSION_BUILD; EXPORTED ULONG NtGlobalFlag = 0; EXPORTED CHAR KeNumberProcessors; -EXPORTED KAFFINITY KeActiveProcessors; +EXPORTED KAFFINITY KeActiveProcessors = 1; EXPORTED LOADER_PARAMETER_BLOCK KeLoaderBlock; EXPORTED ULONG KeDcacheFlushCount = 0; EXPORTED ULONG KeIcacheFlushCount = 0; _____ Modified: trunk/reactos/ntoskrnl/ps/psmgr.c --- trunk/reactos/ntoskrnl/ps/psmgr.c 2005-08-09 08:02:05 UTC (rev 17234) +++ trunk/reactos/ntoskrnl/ps/psmgr.c 2005-08-09 08:50:57 UTC (rev 17235) @@ -213,7 +213,7 @@ /* System threads may run on any processor. */ RtlZeroMemory(PsInitialSystemProcess, sizeof(EPROCESS)); - PsInitialSystemProcess->Pcb.Affinity = 0xFFFFFFFF; + PsInitialSystemProcess->Pcb.Affinity = KeActiveProcessors; PsInitialSystemProcess->Pcb.IopmOffset = 0xffff; PsInitialSystemProcess->Pcb.BasePriority = PROCESS_PRIO_NORMAL; PsInitialSystemProcess->Pcb.QuantumReset = 6; _____ Modified: trunk/reactos/ntoskrnl/ps/query.c --- trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 08:02:05 UTC (rev 17234) +++ trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 08:50:57 UTC (rev 17235) @@ -1194,6 +1194,8 @@ SetInformationData[ThreadInformationClass].Size); } + /* FIXME: This is REALLY wrong. Some types don't need THREAD_SET_INFORMATION */ + /* FIXME: We should also check for certain things before doing the reference */ Status = ObReferenceObjectByHandle (ThreadHandle, THREAD_SET_INFORMATION, PsThreadType, @@ -1218,7 +1220,19 @@ break; case ThreadAffinityMask: - Status = KeSetAffinityThread(&Thread->Tcb, u.Affinity); + + /* Check if this is valid */ + DPRINT1("%lx, %lx\n", Thread->ThreadsProcess->Pcb.Affinity, u.Affinity); + if ((Thread->ThreadsProcess->Pcb.Affinity & u.Affinity) != + u.Affinity) + { + DPRINT1("Wrong affinity given\n"); + Status = STATUS_INVALID_PARAMETER; + } + else + { + Status = KeSetAffinityThread(&Thread->Tcb, u.Affinity); + } break; case ThreadImpersonationToken:

1 0

[ion] 17234: Fix priority formulas, account for saturation, do proper km_um conversions for out of bounds or saturation priorirites, create an internal priority change function to be called if the lock is already held (however it's not efficient yet since ros dispatches instead of schedules, and so the lock is sometimes released, but i did write a small hack to account for that)... this fixes more wine tests
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

Fix priority formulas, account for saturation, do proper km_um conversions for out of bounds or saturation priorirites, create an internal priority change function to be called if the lock is already held (however it's not efficient yet since ros dispatches instead of schedules, and so the lock is sometimes released, but i did write a small hack to account for that)... this fixes more wine tests Modified: trunk/reactos/lib/kernel32/thread/thread.c Modified: trunk/reactos/ntoskrnl/ke/dpc.c Modified: trunk/reactos/ntoskrnl/ke/kthread.c _____ Modified: trunk/reactos/lib/kernel32/thread/thread.c --- trunk/reactos/lib/kernel32/thread/thread.c 2005-08-09 07:42:00 UTC (rev 17233) +++ trunk/reactos/lib/kernel32/thread/thread.c 2005-08-09 08:02:05 UTC (rev 17234) @@ -15,6 +15,9 @@ #define NDEBUG #include "../include/debug.h" +/* FIXME: NDK */ +#define HIGH_PRIORITY 31 + /* FUNCTIONS *****************************************************************/ _SEH_FILTER(BaseThreadExceptionFilter) { @@ -536,52 +539,77 @@ /* * @implemented */ -BOOL STDCALL +BOOL +STDCALL SetThreadPriority(HANDLE hThread, - int nPriority) + int nPriority) { - ULONG Prio = nPriority; - NTSTATUS Status; + ULONG Prio = nPriority; + NTSTATUS Status; - Status = NtSetInformationThread(hThread, - ThreadBasePriority, - &Prio, - sizeof(ULONG)); + /* Check if values forcing saturation should be used */ + if (Prio == THREAD_PRIORITY_TIME_CRITICAL) + { + Prio = (HIGH_PRIORITY + 1) / 2; + } + else if (Prio == THREAD_PRIORITY_IDLE) + { + Prio = -((HIGH_PRIORITY + 1) / 2); + } - if (!NT_SUCCESS(Status)) + /* Set the Base Priority */ + Status = NtSetInformationThread(hThread, + ThreadBasePriority, + &Prio, + sizeof(ULONG)); + if (!NT_SUCCESS(Status)) { - SetLastErrorByStatus(Status); - return(FALSE); + /* Failure */ + SetLastErrorByStatus(Status); + return FALSE; } - return(TRUE); + /* Return */ + return TRUE; } - /* * @implemented */ -int STDCALL +int +STDCALL GetThreadPriority(HANDLE hThread) { - THREAD_BASIC_INFORMATION ThreadBasic; - NTSTATUS Status; + THREAD_BASIC_INFORMATION ThreadBasic; + NTSTATUS Status; - Status = NtQueryInformationThread(hThread, - ThreadBasicInformation, - &ThreadBasic, - sizeof(THREAD_BASIC_INFORMATION), - NULL); - if (!NT_SUCCESS(Status)) + /* Query the Base Priority Increment */ + Status = NtQueryInformationThread(hThread, + ThreadBasicInformation, + &ThreadBasic, + sizeof(THREAD_BASIC_INFORMATION), + NULL); + if (!NT_SUCCESS(Status)) { - SetLastErrorByStatus(Status); - return(THREAD_PRIORITY_ERROR_RETURN); + /* Failure */ + SetLastErrorByStatus(Status); + return THREAD_PRIORITY_ERROR_RETURN; } - return(ThreadBasic.BasePriority); + /* Do some conversions for out of boundary values */ + if (ThreadBasic.BasePriority > THREAD_BASE_PRIORITY_MAX) + { + ThreadBasic.BasePriority = THREAD_PRIORITY_TIME_CRITICAL; + } + else if (ThreadBasic.BasePriority < THREAD_BASE_PRIORITY_MIN) + { + ThreadBasic.BasePriority = THREAD_PRIORITY_IDLE; + } + + /* Return the final result */ + return ThreadBasic.BasePriority; } - /* * @implemented */ _____ Modified: trunk/reactos/ntoskrnl/ke/dpc.c --- trunk/reactos/ntoskrnl/ke/dpc.c 2005-08-09 07:42:00 UTC (rev 17233) +++ trunk/reactos/ntoskrnl/ke/dpc.c 2005-08-09 08:02:05 UTC (rev 17234) @@ -465,7 +465,8 @@ if (OldPriority != NewPriority) { /* Set new Priority */ - CurrentThread->Priority = NewPriority; + BOOLEAN Dummy; /* <- This is a hack anyways... */ + KiSetPriorityThread(CurrentThread, NewPriority, &Dummy); } else { _____ Modified: trunk/reactos/ntoskrnl/ke/kthread.c --- trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 07:42:00 UTC (rev 17233) +++ trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 08:02:05 UTC (rev 17234) @@ -348,8 +348,9 @@ if (Priority != Thread->Priority) { /* - * HACK HACK This isn't nice, but it's the only way with our - * current codebase + * FIXME: This should be a call to KiSetPriorityThread but + * due to the current ""scheduler"" in ROS, it can't be done + * cleanly since it actualyl dispatches threads instead. */ Thread->Priority = Priority; } @@ -1054,121 +1055,231 @@ return BasePriorityIncrement; } -/* - * @implemented - */ -LONG STDCALL -KeSetBasePriorityThread (PKTHREAD Thread, - LONG Increment) -/* - * Sets thread's base priority relative to the process' base priority - * Should only be passed in THREAD_PRIORITY_ constants in pstypes.h - */ +VOID +STDCALL +KiSetPriorityThread(PKTHREAD Thread, + KPRIORITY Priority, + PBOOLEAN Released) { - KPRIORITY Priority; - if (Increment < -2) - { - Increment = -2; - } - else if (Increment > 2) - { - Increment = 2; - } - Priority = ((PETHREAD)Thread)->ThreadsProcess->Pcb.BasePriority + Increment; - if (Priority < LOW_PRIORITY) - { - Priority = LOW_PRIORITY; - } - else if (Priority >= MAXIMUM_PRIORITY) - { - Thread->BasePriority = HIGH_PRIORITY; - } - KeSetPriorityThread(Thread, Priority); - return 1; + KPRIORITY OldPriority = Thread->Priority; + ULONG Mask; + int i; + PKPCR Pcr; + DPRINT("Changing prio to : %lx\n", Priority); + + /* Check if priority changed */ + if (OldPriority != Priority) + { + /* Set it */ + Thread->Priority = Priority; + + /* Choose action based on thread's state */ + if (Thread->State == Ready) + { + /* Remove it from the current queue */ + KiRemoveFromThreadList(Thread); + + /* Re-insert it at its current priority */ + KiInsertIntoThreadList(Priority, Thread); + + /* Check if the old priority was lower */ + if (KeGetCurrentThread()->Priority < Priority) + { + /* Dispatch it immediately */ + KiDispatchThreadNoLock(Ready); + *Released = TRUE; + return; + } + } + else if (Thread->State == Running) + { + /* Check if the new priority is lower */ + if (Priority < OldPriority) + { + /* Check for threads with a higher priority */ + Mask = ~((1 << (Priority + 1)) - 1); + if (PriorityListMask & Mask) + { + /* Found a thread, is it us? */ + if (Thread == KeGetCurrentThread()) + { + /* Dispatch us */ + KiDispatchThreadNoLock(Ready); + *Released = TRUE; + return; + } + else + { + /* Loop every CPU */ + for (i = 0; i < KeNumberProcessors; i++) + { + /* Get the PCR for this CPU */ + Pcr = (PKPCR)(KPCR_BASE + i * PAGE_SIZE); + + /* Reschedule if the new one is already on a CPU */ + if (Pcr->Prcb->CurrentThread == Thread) + { + KeReleaseDispatcherDatabaseLockFromDpcLevel(); + KiRequestReschedule(i); + *Released = TRUE; + return; + } + } + } + } + } + } + } + + /* Return to caller */ + return; } /* + * Sets thread's base priority relative to the process' base priority + * Should only be passed in THREAD_PRIORITY_ constants in pstypes.h + * * @implemented */ -KPRIORITY +LONG STDCALL -KeSetPriorityThread(PKTHREAD Thread, - KPRIORITY Priority) +KeSetBasePriorityThread (PKTHREAD Thread, + LONG Increment) { - KPRIORITY OldPriority; KIRQL OldIrql; - PKTHREAD CurrentThread; - ULONG Mask; - int i; - PKPCR Pcr; + PKPROCESS Process; + KPRIORITY Priority; + KPRIORITY CurrentBasePriority; + KPRIORITY BasePriority; + BOOLEAN Released = FALSE; + LONG CurrentIncrement; + + /* Lock the Dispatcher Database */ + OldIrql = KeAcquireDispatcherDatabaseLock(); - if (Priority < LOW_PRIORITY || Priority >= MAXIMUM_PRIORITY) { + /* Get the process and calculate current BP and BPI */ + Process = Thread->ApcStatePointer[0]->Process; + CurrentBasePriority = Thread->BasePriority; + CurrentIncrement = CurrentBasePriority - Process->BasePriority; - KEBUGCHECK(0); + /* Change to use the SI if Saturation was used */ + if (Thread->Saturation) CurrentIncrement = (HIGH_PRIORITY + 1) / 2 * + Thread->Saturation; + + /* Now check if saturation is being used for the new value */ + if (abs(Increment) >= ((HIGH_PRIORITY + 1) / 2)) + { + /* Check if we need positive or negative saturation */ + Thread->Saturation = (Increment > 0) ? 1 : -1; } - OldIrql = KeAcquireDispatcherDatabaseLock(); + /* Normalize the Base Priority */ + BasePriority = Process->BasePriority + Increment; + if (Process->BasePriority >= LOW_REALTIME_PRIORITY) + { + /* Check if it's too low */ + if (BasePriority < LOW_REALTIME_PRIORITY) + BasePriority = LOW_REALTIME_PRIORITY; - OldPriority = Thread->Priority; + /* Check if it's too high */ + if (BasePriority > HIGH_PRIORITY) BasePriority = HIGH_PRIORITY; - if (OldPriority != Priority) { + /* We are at RTP, so use the raw BP */ + Priority = BasePriority; + } + else + { + /* Check if it's entering RTP */ + if (BasePriority >= LOW_REALTIME_PRIORITY) + BasePriority = LOW_REALTIME_PRIORITY - 1; - CurrentThread = KeGetCurrentThread(); + /* Check if it's too low */ + if (BasePriority <= LOW_PRIORITY) + BasePriority = 1; - if (Thread->State == Ready) { + /* If Saturation is used, then use the raw BP */ + if (Thread->Saturation) + { + Priority = BasePriority; + } + else + { + /* Calculate the new priority */ + Priority = Thread->Priority + (BasePriority - CurrentBasePriority)- + Thread->PriorityDecrement; - KiRemoveFromThreadList(Thread); - Thread->BasePriority = Thread->Priority = (CHAR)Priority; - KiInsertIntoThreadList(Priority, Thread); + /* Make sure it won't enter RTP ranges */ + if (Priority >= LOW_REALTIME_PRIORITY) + Priority = LOW_REALTIME_PRIORITY - 1; + } + } - if (CurrentThread->Priority < Priority) { + /* Finally set the new base priority */ + Thread->BasePriority = BasePriority; - KiDispatchThreadNoLock(Ready); - KeLowerIrql(OldIrql); - return (OldPriority); - } + /* Reset the decrements */ + Thread->DecrementCount = 0; + Thread->PriorityDecrement = 0; - } else if (Thread->State == Running) { + /* If the priority will change, reset quantum and change it for real */ + if (Priority != Thread->Priority) + { + Thread->Quantum = Thread->QuantumReset; + KiSetPriorityThread(Thread, Priority, &Released); + } - Thread->BasePriority = Thread->Priority = (CHAR)Priority; + /* Release Lock if needed */ + if (!Released) + { + KeReleaseDispatcherDatabaseLock(OldIrql); + } + else + { + KeLowerIrql(OldIrql); + } - if (Priority < OldPriority) { + /* Return the Old Increment */ + return CurrentIncrement; +} - /* Check for threads with a higher priority */ - Mask = ~((1 << (Priority + 1)) - 1); - if (PriorityListMask & Mask) { +/* + * @implemented + */ +KPRIORITY +STDCALL +KeSetPriorityThread(PKTHREAD Thread, + KPRIORITY Priority) +{ + KPRIORITY OldPriority; + BOOLEAN Released = FALSE; + KIRQL OldIrql; - if (Thread == CurrentThread) { + /* Lock the Dispatcher Database */ + OldIrql = KeAcquireDispatcherDatabaseLock(); - KiDispatchThreadNoLock(Ready); - KeLowerIrql(OldIrql); - return (OldPriority); + /* Save the old Priority */ + OldPriority = Thread->Priority; - } else { + /* Reset the Quantum and Decrements */ + Thread->Quantum = Thread->QuantumReset; + Thread->DecrementCount = 0; + Thread->PriorityDecrement = 0; - for (i = 0; i < KeNumberProcessors; i++) { + /* Set the new Priority */ + KiSetPriorityThread(Thread, Priority, &Released); - Pcr = (PKPCR)(KPCR_BASE + i * PAGE_SIZE); - - if (Pcr->Prcb->CurrentThread == Thread) { - - KeReleaseDispatcherDatabaseLockFromDpcLevel(); - KiRequestReschedule(i); - KeLowerIrql(OldIrql); - return (OldPriority); - } - } - } - } - } - } else { - - Thread->BasePriority = Thread->Priority = (CHAR)Priority; - } + /* Release Lock if needed */ + if (!Released) + { + KeReleaseDispatcherDatabaseLock(OldIrql); } + else + { + KeLowerIrql(OldIrql); + } - KeReleaseDispatcherDatabaseLock(OldIrql); - return(OldPriority); + /* Return Old Priority */ + return OldPriority; } /*

1 0

[greatlrd] 17233: Thx Royce3 for notice's a typo error CreateData to CanCreateData in a if statement. But it is not the bug we are looking for.
by greatlrd＠svn.reactos.com 09 Aug '05

09 Aug '05

Thx Royce3 for notice's a typo error CreateData to CanCreateData in a if statement. But it is not the bug we are looking for. Modified: trunk/reactos/lib/ddraw/main/surface.c _____ Modified: trunk/reactos/lib/ddraw/main/surface.c --- trunk/reactos/lib/ddraw/main/surface.c 2005-08-09 06:28:23 UTC (rev 17232) +++ trunk/reactos/lib/ddraw/main/surface.c 2005-08-09 07:42:00 UTC (rev 17233) @@ -72,7 +72,7 @@ if (This->owner->DriverCallbacks.DdMain.CanCreateSurface (&CanCreateData) == DDHAL_DRIVER_NOTHANDLED) return DDERR_INVALIDPARAMS; - if(CreateData.ddRVal != DD_OK) + if(CanCreateData.ddRVal != DD_OK) return CanCreateData.ddRVal;

1 0

[ion] 17232: It is generally considered a bad idea to dereference an object after the reference failed..... this fixes another wine test and avoids a bugcheck
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

It is generally considered a bad idea to dereference an object after the reference failed..... this fixes another wine test and avoids a bugcheck Modified: trunk/reactos/ntoskrnl/ps/query.c _____ Modified: trunk/reactos/ntoskrnl/ps/query.c --- trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 06:23:16 UTC (rev 17231) +++ trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 06:28:23 UTC (rev 17232) @@ -1233,9 +1233,9 @@ /* Shoult never occure if the data table is correct */ KEBUGCHECK(0); } + ObDereferenceObject (Thread); } - ObDereferenceObject (Thread); - + return Status; }

1 0

[ion] 17231: - Implement KeQueryBasePriorityThread to return the actual Base Priority Increment (or Saturation Increment) to NtQueryInformationThread. The value win32 works with is actually (usually) the difference between process and thread Base Priorities.
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

- Implement KeQueryBasePriorityThread to return the actual Base Priority Increment (or Saturation Increment) to NtQueryInformationThread. The value win32 works with is actually (usually) the difference between process and thread Base Priorities. This fixes another WINE test. Modified: trunk/reactos/ntoskrnl/include/internal/ke.h Modified: trunk/reactos/ntoskrnl/ke/kthread.c Modified: trunk/reactos/ntoskrnl/ps/query.c _____ Modified: trunk/reactos/ntoskrnl/include/internal/ke.h --- trunk/reactos/ntoskrnl/include/internal/ke.h 2005-08-09 05:54:57 UTC (rev 17230) +++ trunk/reactos/ntoskrnl/include/internal/ke.h 2005-08-09 06:23:16 UTC (rev 17231) @@ -222,6 +222,10 @@ NTSTATUS KeReleaseThread(PKTHREAD Thread); +LONG +STDCALL +KeQueryBasePriorityThread(IN PKTHREAD Thread); + VOID STDCALL KeStackAttachProcess ( _____ Modified: trunk/reactos/ntoskrnl/ke/kthread.c --- trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 05:54:57 UTC (rev 17230) +++ trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 06:23:16 UTC (rev 17231) @@ -1026,6 +1026,34 @@ } } +LONG +STDCALL +KeQueryBasePriorityThread(IN PKTHREAD Thread) +{ + LONG BasePriorityIncrement; + KIRQL OldIrql; + PKPROCESS Process; + + /* Lock the Dispatcher Database */ + OldIrql = KeAcquireDispatcherDatabaseLock(); + + /* Get the Process */ + Process = Thread->ApcStatePointer[0]->Process; + + /* Calculate the BPI */ + BasePriorityIncrement = Thread->BasePriority - Process->BasePriority; + + /* If saturation occured, return the SI instead */ + if (Thread->Saturation) BasePriorityIncrement = (HIGH_PRIORITY + 1) / 2 * + Thread->Saturation; + + /* Release Lock */ + KeReleaseDispatcherDatabaseLock(OldIrql); + + /* Return Increment */ + return BasePriorityIncrement; +} + /* * @implemented */ _____ Modified: trunk/reactos/ntoskrnl/ps/query.c --- trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 05:54:57 UTC (rev 17230) +++ trunk/reactos/ntoskrnl/ps/query.c 2005-08-09 06:23:16 UTC (rev 17231) @@ -1329,7 +1329,7 @@ u.TBI.ClientId = Thread->Cid; u.TBI.AffinityMask = Thread->Tcb.Affinity; u.TBI.Priority = Thread->Tcb.Priority; - u.TBI.BasePriority = Thread->Tcb.BasePriority; + u.TBI.BasePriority = KeQueryBasePriorityThread(&Thread->Tcb); break; case ThreadTimes:

1 0

[ion] 17230: - Fix NtSuspendThread: correct PreviousMode check, return error if thread is terminating, handle KeSuspendThread's possible exception, only attempt to return previous suspend count if asked to.
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

- Fix NtSuspendThread: correct PreviousMode check, return error if thread is terminating, handle KeSuspendThread's possible exception, only attempt to return previous suspend count if asked to. - Make KeSuspendThread return an exception if the thread has been suspended beyond the limit. This fixes another wine test. Modified: trunk/reactos/ntoskrnl/ke/kthread.c Modified: trunk/reactos/ntoskrnl/ps/suspend.c _____ Modified: trunk/reactos/ntoskrnl/ke/kthread.c --- trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 04:59:19 UTC (rev 17229) +++ trunk/reactos/ntoskrnl/ke/kthread.c 2005-08-09 05:54:57 UTC (rev 17230) @@ -14,10 +14,8 @@ #define NDEBUG #include <internal/debug.h> -#ifndef MUTANT_INCREMENT -#define MUTANT_INCREMENT 1 -#endif - +/* FIXME: NDK */ +#define MAXIMUM_SUSPEND_COUNT 0x7F #define THREAD_ALERT_INCREMENT 2 extern EX_WORK_QUEUE ExWorkerQueue[MaximumWorkQueue]; @@ -599,6 +597,14 @@ /* Save the Old Count */ PreviousCount = Thread->SuspendCount; + /* Handle the maximum */ + if (PreviousCount == MAXIMUM_SUSPEND_COUNT) + { + /* Raise an exception */ + KeReleaseDispatcherDatabaseLock(OldIrql); + ExRaiseStatus(STATUS_SUSPEND_COUNT_EXCEEDED); + } + /* Increment it */ Thread->SuspendCount++; _____ Modified: trunk/reactos/ntoskrnl/ps/suspend.c --- trunk/reactos/ntoskrnl/ps/suspend.c 2005-08-09 04:59:19 UTC (rev 17229) +++ trunk/reactos/ntoskrnl/ps/suspend.c 2005-08-09 05:54:57 UTC (rev 17230) @@ -115,25 +115,22 @@ { PETHREAD Thread; ULONG Prev; - KPROCESSOR_MODE PreviousMode; + KPROCESSOR_MODE PreviousMode = ExGetPreviousMode(); NTSTATUS Status = STATUS_SUCCESS; - PAGED_CODE(); - PreviousMode = ExGetPreviousMode(); - /* Check buffer validity */ - if(PreviousSuspendCount && PreviousMode == UserMode) { - - _SEH_TRY { - + if(PreviousSuspendCount && PreviousMode != KernelMode) + { + _SEH_TRY + { ProbeForWrite(PreviousSuspendCount, sizeof(ULONG), sizeof(ULONG)); - } _SEH_HANDLE { - + } + _SEH_HANDLE + { Status = _SEH_GetExceptionCode(); - } _SEH_END; if(!NT_SUCCESS(Status)) return Status; @@ -146,30 +143,34 @@ PreviousMode, (PVOID*)&Thread, NULL); - if (!NT_SUCCESS(Status)) { + if (!NT_SUCCESS(Status)) return Status; - return Status; - } + /* Guard with SEH because KeSuspendThread can raise an exception */ + _SEH_TRY + { + /* Make sure the thread isn't terminating */ + if ((Thread != PsGetCurrentThread()) && (Thread->Terminated)) + { + ObDereferenceObject(Thread); + return STATUS_THREAD_IS_TERMINATING; + } - /* Call the Kernel Function */ - Prev = KeSuspendThread(&Thread->Tcb); + /* Call the Kernel function */ + Prev = KeSuspendThread(&Thread->Tcb); - /* Return it */ - if(PreviousSuspendCount) { + /* Return the Previous Count */ + if (PreviousSuspendCount) *PreviousSuspendCount = Prev; + } + _SEH_HANDLE + { + Status = _SEH_GetExceptionCode(); - _SEH_TRY { + /* Don't fail if we merely couldn't write the handle back */ + if (Status != STATUS_SUSPEND_COUNT_EXCEEDED) Status = STATUS_SUCCESS; + } _SEH_END; - *PreviousSuspendCount = Prev; - - } _SEH_HANDLE { - - Status = _SEH_GetExceptionCode(); - - } _SEH_END; - } - - /* Dereference and Return */ - ObDereferenceObject((PVOID)Thread); + /* Return */ + ObDereferenceObject(Thread); return Status; }

1 0

[ion] 17229: Sigh... yet another misuse of Object Attributes. Developer Note: Object Attributes are used to pass OBJ_ flags. Not Access Flags.
by ion＠svn.reactos.com 09 Aug '05

09 Aug '05

Sigh... yet another misuse of Object Attributes. Developer Note: Object Attributes are used to pass OBJ_ flags. Not Access Flags. Modified: trunk/reactos/subsys/smss/init.c _____ Modified: trunk/reactos/subsys/smss/init.c --- trunk/reactos/subsys/smss/init.c 2005-08-09 04:56:29 UTC (rev 17228) +++ trunk/reactos/subsys/smss/init.c 2005-08-09 04:59:19 UTC (rev 17229) @@ -42,8 +42,8 @@ RtlInitUnicodeString (& EventName, L"\\ReactOSInitDone"); InitializeObjectAttributes(&ObjectAttributes, & EventName, - EVENT_ALL_ACCESS, 0, + 0, NULL); Status = NtOpenEvent(&ReactOSInitEvent, EVENT_ALL_ACCESS,

1 0

← Newer
1
...
34
35
36
37
38
39
40
...
67
Older →

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

2004

Ros-diffs August 2005