X-Git-Url: http://git.jankratochvil.net/?a=blobdiff_plain;f=ntoskrnl%2Fnt%2Fnttimer.c;h=89d1edcfbe1f29344af5bacd0013211ae40dec72;hb=refs%2Ftags%2FHEAD-2003050101;hp=b2b30103318baaa311985f63264f6813a4def4e2;hpb=e3ed2d773259cc445c7ff8181ebd934931365328;p=reactos.git

diff --git a/ntoskrnl/nt/nttimer.c b/ntoskrnl/nt/nttimer.c
index b2b3010..89d1edc 100644
--- a/ntoskrnl/nt/nttimer.c
+++ b/ntoskrnl/nt/nttimer.c
@@ -63,6 +63,25 @@ NtpCreateTimer(PVOID ObjectBody,
 }
 
 
+VOID STDCALL
+NtpDeleteTimer(PVOID ObjectBody)
+{
+   KIRQL OldIrql;
+   PNTTIMER Timer = ObjectBody;
+
+   DPRINT("NtpDeleteTimer()\n");
+
+   OldIrql = KeRaiseIrqlToDpcLevel();
+
+   KeCancelTimer(&Timer->Timer);
+   KeRemoveQueueDpc(&Timer->Dpc);
+   KeRemoveQueueApc(&Timer->Apc);
+   Timer->Running = FALSE;
+
+   KeLowerIrql(OldIrql);
+}
+
+
 VOID
 NtpTimerDpcRoutine(PKDPC Dpc,
 		   PVOID DeferredContext,
@@ -70,11 +89,11 @@ NtpTimerDpcRoutine(PKDPC Dpc,
 		   PVOID SystemArgument2)
 {
    PNTTIMER Timer;
-   
+
    DPRINT("NtpTimerDpcRoutine()\n");
-   
+
    Timer = (PNTTIMER)DeferredContext;
-   
+
    if ( Timer->Running )
      {
 	KeInsertQueueApc(&Timer->Apc,
@@ -100,9 +119,9 @@ NtpTimerApcKernelRoutine(PKAPC Apc,
 VOID NtInitializeTimerImplementation(VOID)
 {
    ExTimerType = ExAllocatePool(NonPagedPool, sizeof(OBJECT_TYPE));
-   
+
    RtlCreateUnicodeString(&ExTimerType->TypeName, L"Timer");
-   
+
    ExTimerType->Tag = TAG('T', 'I', 'M', 'T');
    ExTimerType->MaxObjects = ULONG_MAX;
    ExTimerType->MaxHandles = ULONG_MAX;
@@ -114,7 +133,7 @@ VOID NtInitializeTimerImplementation(VOID)
    ExTimerType->Dump = NULL;
    ExTimerType->Open = NULL;
    ExTimerType->Close = NULL;
-   ExTimerType->Delete = NULL;
+   ExTimerType->Delete = NtpDeleteTimer;
    ExTimerType->Parse = NULL;
    ExTimerType->Security = NULL;
    ExTimerType->QueryName = NULL;
@@ -142,22 +161,22 @@ NtCancelTimer(IN HANDLE TimerHandle,
 				      NULL);
    if (!NT_SUCCESS(Status))
      return Status;
-   
+
    OldIrql = KeRaiseIrqlToDpcLevel();
-   
+
    State = KeCancelTimer(&Timer->Timer);
    KeRemoveQueueDpc(&Timer->Dpc);
    KeRemoveQueueApc(&Timer->Apc);
    Timer->Running = FALSE;
-  
+
    KeLowerIrql(OldIrql);
    ObDereferenceObject(Timer);
-   
+
    if (CurrentState != NULL)
      {
 	*CurrentState = State;
      }
-   
+
    return STATUS_SUCCESS;
 }
 
@@ -170,7 +189,7 @@ NtCreateTimer(OUT PHANDLE TimerHandle,
 {
    PNTTIMER Timer;
    NTSTATUS Status;
-   
+
    DPRINT("NtCreateTimer()\n");
    Status = ObCreateObject(TimerHandle,
 			   DesiredAccess,
@@ -179,18 +198,18 @@ NtCreateTimer(OUT PHANDLE TimerHandle,
 			   (PVOID*)&Timer);
    if (!NT_SUCCESS(Status))
      return Status;
-   
+
    KeInitializeTimerEx(&Timer->Timer,
 		       TimerType);
-   
+
    KeInitializeDpc (&Timer->Dpc,
 		    (PKDEFERRED_ROUTINE)NtpTimerDpcRoutine,
 		    (PVOID)Timer);
-   
+
    Timer->Running = FALSE;
-   
+
    ObDereferenceObject(Timer);
-   
+
    return(STATUS_SUCCESS);
 }
 
@@ -201,7 +220,7 @@ NtOpenTimer(OUT PHANDLE TimerHandle,
 	    IN POBJECT_ATTRIBUTES ObjectAttributes)
 {
    NTSTATUS Status;
-   
+
    Status = ObOpenObjectByName(ObjectAttributes,
 			       ExTimerType,
 			       NULL,
@@ -233,7 +252,7 @@ NtQueryTimer(IN HANDLE TimerHandle,
 				     NULL);
   if (!NT_SUCCESS(Status))
     {
-      return(Status); 
+      return(Status);
     }
 
   if (TimerInformationClass != TimerBasicInformation)
@@ -246,12 +265,12 @@ NtQueryTimer(IN HANDLE TimerHandle,
       ObDereferenceObject(Timer);
       return(STATUS_INFO_LENGTH_MISMATCH);
     }
-  
+
   memcpy(&TimerInformation.TimeRemaining, &Timer->Timer.DueTime,
 	 sizeof(LARGE_INTEGER));
   TimerInformation.SignalState = Timer->Timer.Header.SignalState;
   ResultLength = sizeof(TIMER_BASIC_INFORMATION);
-  
+
   Status = MmCopyToCaller(UnsafeTimerInformation, &TimerInformation,
 			  sizeof(TIMER_BASIC_INFORMATION));
   if (!NT_SUCCESS(Status))
@@ -259,7 +278,7 @@ NtQueryTimer(IN HANDLE TimerHandle,
       ObDereferenceObject(Timer);
       return(Status);
     }
-  
+
   if (UnsafeResultLength != NULL)
     {
       Status = MmCopyToCaller(UnsafeResultLength, &ResultLength,