[ros-diffs] [jimtabor] 34418: - Port wine WaitForInputIdle. Work in progress and untested. Need input idle event to support it.

[jimtabor at svn.reactos.org]

Author: jimtabor
Date: Thu Jul 10 20:02:28 2008
New Revision: 34418

URL: http://svn.reactos.org/svn/reactos?rev=34418&view=rev
Log:
- Port wine WaitForInputIdle. Work in progress and untested. Need input idle event to support it.

Modified:
    trunk/reactos/subsystems/win32/win32k/include/win32.h
    trunk/reactos/subsystems/win32/win32k/ntuser/message.c

Modified: trunk/reactos/subsystems/win32/win32k/include/win32.h
URL: http://svn.reactos.org/svn/reactos/trunk/reactos/subsystems/win32/win32k/include/win32.h?rev=34418&r1=34417&r2=34418&view=diff
==============================================================================
--- trunk/reactos/subsystems/win32/win32k/include/win32.h [iso-8859-1] (original)
+++ trunk/reactos/subsystems/win32/win32k/include/win32.h [iso-8859-1] Thu Jul 10 20:02:28 2008
@@ -43,6 +43,7 @@
   ULONG Flags;
   LONG GDIObjects;
   LONG UserObjects;
+  KEVENT InputIdleEvent;
 
   W32HEAP_USER_MAPPING HeapMappings;
   PW32PROCESSINFO ProcessInfo;

Modified: trunk/reactos/subsystems/win32/win32k/ntuser/message.c
URL: http://svn.reactos.org/svn/reactos/trunk/reactos/subsystems/win32/win32k/ntuser/message.c?rev=34418&r1=34417&r2=34418&view=diff
==============================================================================
--- trunk/reactos/subsystems/win32/win32k/ntuser/message.c [iso-8859-1] (original)
+++ trunk/reactos/subsystems/win32/win32k/ntuser/message.c [iso-8859-1] Thu Jul 10 20:02:28 2008
@@ -1854,10 +1854,74 @@
    IN DWORD dwMilliseconds,
    IN BOOL Unknown2)
 {
-   UNIMPLEMENTED
-
-   return 0;
-}
-
+  ULONGLONG start_time, elapsed, run;
+  DWORD ret;
+  LARGE_INTEGER Timeout; 
+  HANDLE handles[2];
+
+  UserEnterExclusive();
+
+  handles[0] = hProcess;
+  handles[1] = &PsGetCurrentProcessWin32Process()->InputIdleEvent; // Fixme!
+
+  if (!handles[1]) return 0;  /* no event to wait on */
+
+  start_time = ((ULONGLONG)SharedUserData->TickCountLowDeprecated *
+                           SharedUserData->TickCountMultiplier / 16777216);
+  elapsed = 0;
+  run = dwMilliseconds;
+
+  DPRINT("waiting for %p\n", handles[1] );
+  do
+  {
+     Timeout.QuadPart = run - elapsed;
+     UserLeave();
+     ret = KeWaitForMultipleObjects( 2,
+                               handles,
+                               WaitAny,
+                           UserRequest,
+                              UserMode,
+                                 FALSE,
+                              &Timeout,
+                                  NULL);
+     UserEnterExclusive();
+
+     switch (ret)
+     {
+       case STATUS_WAIT_0:
+         ret = (DWORD)-1;
+         goto WaitExit;
+       case STATUS_WAIT_2:
+       {
+         USER_MESSAGE msg;
+         co_IntPeekMessage( &msg, 0, 0, 0, PM_REMOVE | PM_QS_SENDMESSAGE );
+         break;
+       }
+       case STATUS_USER_APC:
+       case STATUS_ALERTED:
+       case STATUS_TIMEOUT:
+         DPRINT1("timeout\n");
+         ret = STATUS_TIMEOUT;
+         goto WaitExit;
+       default:
+         DPRINT1("finished\n");
+         ret = 0;
+         goto WaitExit;
+     }
+     if (dwMilliseconds != -1 ) //INFINITE)
+     {
+        elapsed = ((ULONGLONG)SharedUserData->TickCountLowDeprecated *
+                              SharedUserData->TickCountMultiplier / 16777216) - start_time;
+
+        if (elapsed > run)
+           ret = STATUS_TIMEOUT;
+           break;
+     }
+  }
+  while (1);
+WaitExit:
+  UserLeave();
+  return ret;
+}
 
 /* EOF */