ntdll/kernel32: #27 take III

Eric Pouech pouech-eric at wanadoo.fr
Fri Jun 20 14:46:26 CDT 2003


This is a third take at console handles in ntdll. It includes 
corrections for latest Alexandre's remarks and for latest latest 
Alexandre's remarks.

ChangeLog
   + Adapted kernel32 so that it no longer (directly) manages console
     handles as wineserver handles
   + console input handle object is no longer waitable (input record
     synchronisation is now implemented as a simple semaphore), and
     remove FD_TYPE_CONSOLE from fd types in wineserver
   + console handles now always have their two lower bit set so one can
     distinguish a console handle from a kernel object handle
   + implemented some undocumented kernel32 console related APIs
     (CloseConsoleHandle, GetConsoleInputWaitHandle, OpenConsoleW,
     VerifyConsoleIoHandle, DuplicateConsoleHandle)
   + allowed a few kernel32 APIs to take console pseudo-handles
     (FlushFileBuffer, GetFileType, WaitFor*Object*,
   + simplified the console inheritance at process creation
   + in console tests, no longer create a console if one already exists


Notes:
- some ugly include directives (../kernel/kernel_private.h) were needed 
because some functions are not yet in dlls/kernel. We'll be able to get 
rid of those ugly directives as soon as files/functions are moved

A+

-- 
Eric Pouech
-------------- next part --------------
diff -u -N -r -x '*~' -x '.#*' -x CVS dlls/kernel26/console.c dlls/kernel/console.c
--- dlls/kernel26/console.c	2003-05-13 19:29:57.000000000 +0200
+++ dlls/kernel/console.c	2003-06-20 21:33:20.000000000 +0200
@@ -48,12 +48,14 @@
 #include "wine/debug.h"
 #include "excpt.h"
 #include "console_private.h"
+#include "kernel_private.h"
 
 WINE_DEFAULT_DEBUG_CHANNEL(console);
 
 static UINT console_input_codepage;
 static UINT console_output_codepage;
 
+
 /* map input records to ASCII */
 static void input_records_WtoA( INPUT_RECORD *buffer, int count )
 {
@@ -189,20 +191,22 @@
                                 DWORD count, LPDWORD written )
 {
     BOOL ret;
-
+    DWORD w;
     TRACE("(%p,%p,%ld,%p)\n", handle, buffer, count, written);
 
     if (written) *written = 0;
     SERVER_START_REQ( write_console_input )
     {
-        req->handle = handle;
+        req->handle = console_handle_unmap(handle);
         wine_server_add_data( req, buffer, count * sizeof(INPUT_RECORD) );
-        if ((ret = !wine_server_call_err( req )))
-        {
-            if (written) *written = reply->written;
-        }
+        if ((ret = !wine_server_call_err( req ))) w = reply->written;
     }
     SERVER_END_REQ;
+    if (ret)
+    {
+        ReleaseSemaphore( GetConsoleInputWaitHandle(), w, NULL );
+        if (written) *written = w;
+    }
     return ret;
 }
 
@@ -266,7 +270,7 @@
         {
             SERVER_START_REQ( write_console_output )
             {
-                req->handle = hConsoleOutput;
+                req->handle = console_handle_unmap(hConsoleOutput);
                 req->x      = region->Left;
                 req->y      = region->Top + y;
                 req->mode   = CHAR_INFO_MODE_TEXTATTR;
@@ -348,7 +352,7 @@
 
     SERVER_START_REQ( write_console_output )
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->x      = coord.X;
         req->y      = coord.Y;
         req->mode   = CHAR_INFO_MODE_ATTR;
@@ -412,7 +416,7 @@
 
     SERVER_START_REQ( fill_console_output )
     {
-        req->handle  = hConsoleOutput;
+        req->handle  = console_handle_unmap(hConsoleOutput);
         req->x       = coord.X;
         req->y       = coord.Y;
         req->mode    = CHAR_INFO_MODE_TEXT;
@@ -453,7 +457,7 @@
 
     SERVER_START_REQ( fill_console_output )
     {
-        req->handle    = hConsoleOutput;
+        req->handle    = console_handle_unmap(hConsoleOutput);
         req->x         = coord.X;
         req->y         = coord.Y;
         req->mode      = CHAR_INFO_MODE_ATTR;
@@ -507,7 +511,7 @@
 
     SERVER_START_REQ( read_console_output )
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->x      = coord.X;
         req->y      = coord.Y;
         req->mode   = CHAR_INFO_MODE_TEXT;
@@ -536,7 +540,7 @@
 
     SERVER_START_REQ( read_console_output )
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->x      = coord.X;
         req->y      = coord.Y;
         req->mode   = CHAR_INFO_MODE_ATTR;
@@ -596,7 +600,7 @@
         {
             SERVER_START_REQ( read_console_output )
             {
-                req->handle = hConsoleOutput;
+                req->handle = console_handle_unmap(hConsoleOutput);
                 req->x      = region->Left;
                 req->y      = region->Top + y;
                 req->mode   = CHAR_INFO_MODE_TEXTATTR;
@@ -667,7 +671,7 @@
     BOOL ret;
     SERVER_START_REQ( read_console_input )
     {
-        req->handle = handle;
+        req->handle = console_handle_unmap(handle);
         req->flush  = FALSE;
         wine_server_set_reply( req, buffer, count * sizeof(INPUT_RECORD) );
         if ((ret = !wine_server_call_err( req )))
@@ -688,7 +692,7 @@
     BOOL ret;
     SERVER_START_REQ( read_console_input )
     {
-        req->handle = handle;
+        req->handle = console_handle_unmap(handle);
         req->flush  = FALSE;
         if ((ret = !wine_server_call_err( req )))
         {
@@ -700,24 +704,50 @@
 }
 
 
-/***********************************************************************
- *            FlushConsoleInputBuffer   (KERNEL32.@)
+/******************************************************************************
+ * read_console_input
+ *
+ * Helper function for ReadConsole, ReadConsoleInput and FlushConsoleInputBuffer
+ *
+ * Returns 
+ *      0 for error, 1 for no INPUT_RECORD ready, 2 with INPUT_RECORD ready
  */
-BOOL WINAPI FlushConsoleInputBuffer( HANDLE handle )
+enum read_console_input_return {rci_error = 0, rci_timeout = 1, rci_gotone = 2};
+static enum read_console_input_return read_console_input(HANDLE handle, LPINPUT_RECORD ir, DWORD timeout)
 {
-    BOOL ret;
+    enum read_console_input_return      ret;
+
+    if (WaitForSingleObject(GetConsoleInputWaitHandle(), timeout) != WAIT_OBJECT_0)
+        return rci_timeout;
     SERVER_START_REQ( read_console_input )
     {
-        req->handle = handle;
-        req->flush  = TRUE;
-        ret = !wine_server_call_err( req );
+        req->handle = console_handle_unmap(handle);
+        req->flush = TRUE;
+        wine_server_set_reply( req, ir, sizeof(INPUT_RECORD) );
+        if (wine_server_call_err( req ) || !reply->read) ret = rci_error;
+        else ret = rci_gotone;
     }
     SERVER_END_REQ;
+
     return ret;
 }
 
 
 /***********************************************************************
+ *            FlushConsoleInputBuffer   (KERNEL32.@)
+ */
+BOOL WINAPI FlushConsoleInputBuffer( HANDLE handle )
+{
+    enum read_console_input_return      last;
+    INPUT_RECORD                        ir;
+
+    while ((last = read_console_input(handle, &ir, 0)) == rci_gotone);
+
+    return last == rci_timeout;
+}
+
+
+/***********************************************************************
  *            SetConsoleTitleA   (KERNEL32.@)
  */
 BOOL WINAPI SetConsoleTitleA( LPCSTR title )
@@ -996,30 +1026,6 @@
 }
 
 
-/******************************************************************************
- * read_console_input
- *
- * Helper function for ReadConsole, ReadConsoleInput and PeekConsoleInput
- */
-static BOOL read_console_input(HANDLE handle, LPINPUT_RECORD buffer, DWORD count,
-			       LPDWORD pRead, BOOL flush)
-{
-    BOOL	ret;
-    unsigned	read = 0;
-
-    SERVER_START_REQ( read_console_input )
-    {
-        req->handle = handle;
-        req->flush = flush;
-        wine_server_set_reply( req, buffer, count * sizeof(INPUT_RECORD) );
-        if ((ret = !wine_server_call_err( req ))) read = reply->read;
-    }
-    SERVER_END_REQ;
-    if (pRead) *pRead = read;
-    return ret;
-}
-
-
 /***********************************************************************
  *            ReadConsoleA   (KERNEL32.@)
  */
@@ -1072,23 +1078,26 @@
     else
     {
 	INPUT_RECORD 	ir;
-	DWORD 		count;
+        DWORD           timeout = INFINITE;
 
 	/* FIXME: should we read at least 1 char? The SDK does not say */
 	/* wait for at least one available input record (it doesn't mean we'll have
-	 * chars stored in xbuf...
+	 * chars stored in xbuf...)
 	 */
-	WaitForSingleObject(hConsoleInput, INFINITE);
-	for (charsread = 0; charsread < nNumberOfCharsToRead;)
+	charsread = 0;
+        do 
 	{
-	    if (!read_console_input(hConsoleInput, &ir, 1, &count, TRUE)) return FALSE;
-	    if (count && ir.EventType == KEY_EVENT && ir.Event.KeyEvent.bKeyDown &&
+	    if (read_console_input(hConsoleInput, &ir, timeout) != rci_gotone) break;
+            timeout = 0;
+	    if (ir.EventType == KEY_EVENT && ir.Event.KeyEvent.bKeyDown &&
 		ir.Event.KeyEvent.uChar.UnicodeChar &&
 		!(ir.Event.KeyEvent.dwControlKeyState & ENHANCED_KEY))
 	    {
 		xbuf[charsread++] = ir.Event.KeyEvent.uChar.UnicodeChar;
 	    }
-	}
+        } while (charsread < nNumberOfCharsToRead);
+        /* nothing has been read */
+        if (timeout == INFINITE) return FALSE;
     }
 
     if (lpNumberOfCharsRead) *lpNumberOfCharsRead = charsread;
@@ -1103,7 +1112,8 @@
 BOOL WINAPI ReadConsoleInputW(HANDLE hConsoleInput, LPINPUT_RECORD lpBuffer,
                               DWORD nLength, LPDWORD lpNumberOfEventsRead)
 {
-    DWORD count;
+    DWORD idx = 0;
+    DWORD timeout = INFINITE;
 
     if (!nLength)
     {
@@ -1112,17 +1122,12 @@
     }
 
     /* loop until we get at least one event */
-    for (;;)
-    {
-        WaitForSingleObject(hConsoleInput, INFINITE);
-	if (!read_console_input(hConsoleInput, lpBuffer, nLength, &count, TRUE))
-	    return FALSE;
-        if (count)
-        {
-            if (lpNumberOfEventsRead) *lpNumberOfEventsRead = count;
-            return TRUE;
-        }
-    }
+    while (read_console_input(hConsoleInput, &lpBuffer[idx], timeout) == rci_gotone &&
+           ++idx < nLength)
+        timeout = 0;
+
+    if (lpNumberOfEventsRead) *lpNumberOfEventsRead = idx;
+    return idx != 0;
 }
 
 
@@ -1152,7 +1157,7 @@
 
     SERVER_START_REQ( write_console_output )
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->x      = coord.X;
         req->y      = coord.Y;
         req->mode   = CHAR_INFO_MODE_TEXT;
@@ -1480,7 +1485,7 @@
 
     SERVER_START_REQ(get_console_output_info)
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         if ((ret = !wine_server_call_err( req )))
         {
             csbi->dwSize.X              = reply->width;
@@ -1536,7 +1541,7 @@
 
     SERVER_START_REQ(get_console_mode)
     {
-	req->handle = hcon;
+	req->handle = console_handle_unmap(hcon);
 	ret = !wine_server_call_err( req );
 	if (ret && mode) *mode = reply->mode;
     }
@@ -1569,7 +1574,7 @@
 
     SERVER_START_REQ(set_console_mode)
     {
-	req->handle = hcon;
+	req->handle = console_handle_unmap(hcon);
 	req->mode = mode;
 	ret = !wine_server_call_err( req );
     }
@@ -1598,7 +1603,7 @@
 
     SERVER_START_REQ( write_console_output )
     {
-        req->handle = hCon;
+        req->handle = console_handle_unmap(hCon);
         req->x      = pos->X;
         req->y      = pos->Y;
         req->mode   = CHAR_INFO_MODE_TEXTSTDATTR;
@@ -1828,7 +1833,7 @@
 
     SERVER_START_REQ(set_console_output_info)
     {
-        req->handle         = hcon;
+        req->handle         = console_handle_unmap(hcon);
         req->cursor_x       = pos.X;
         req->cursor_y       = pos.Y;
         req->mask           = SET_CONSOLE_OUTPUT_INFO_CURSOR_POS;
@@ -1888,7 +1893,7 @@
 
     SERVER_START_REQ(get_console_output_info)
     {
-        req->handle = hcon;
+        req->handle = console_handle_unmap(hcon);
         ret = !wine_server_call_err( req );
         if (ret && cinfo)
         {
@@ -1917,7 +1922,7 @@
 
     SERVER_START_REQ(set_console_output_info)
     {
-        req->handle         = hCon;
+        req->handle         = console_handle_unmap(hCon);
         req->cursor_size    = cinfo->dwSize;
         req->cursor_visible = cinfo->bVisible;
         req->mask           = SET_CONSOLE_OUTPUT_INFO_CURSOR_GEOM;
@@ -1956,7 +1961,7 @@
     }
     SERVER_START_REQ(set_console_output_info)
     {
-        req->handle         = hCon;
+        req->handle         = console_handle_unmap(hCon);
 	req->win_left       = p.Left;
 	req->win_top        = p.Top;
 	req->win_right      = p.Right;
@@ -1986,7 +1991,7 @@
 
     SERVER_START_REQ(set_console_output_info)
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->attr   = wAttr;
         req->mask   = SET_CONSOLE_OUTPUT_INFO_ATTR;
         ret = !wine_server_call_err( req );
@@ -2013,7 +2018,7 @@
 
     SERVER_START_REQ(set_console_output_info)
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
         req->width  = dwSize.X;
         req->height = dwSize.Y;
         req->mask   = SET_CONSOLE_OUTPUT_INFO_SIZE;
@@ -2051,7 +2056,7 @@
 {
     SERVER_START_REQ( fill_console_output )
     {
-        req->handle    = hConsoleOutput;
+        req->handle    = console_handle_unmap(hConsoleOutput);
         req->mode      = CHAR_INFO_MODE_TEXTATTR;
         req->x         = i;
         req->y         = j;
@@ -2129,7 +2134,7 @@
     /* step 3: transfer the bits */
     SERVER_START_REQ(move_console_output)
     {
-        req->handle = hConsoleOutput;
+        req->handle = console_handle_unmap(hConsoleOutput);
 	req->x_src = lpScrollRect->Left;
 	req->y_src = lpScrollRect->Top;
 	req->x_dst = dst.Left;
@@ -2260,7 +2265,7 @@
     unsigned ret = FALSE;
     SERVER_START_REQ(get_console_input_info)
     {
-        req->handle = hConIn;
+        req->handle = console_handle_unmap(hConIn);
         if ((ret = !wine_server_call_err( req )))
             *mode = reply->edition_mode;
     }
diff -u -N -r -x '*~' -x '.#*' -x CVS dlls/kernel26/editline.c dlls/kernel/editline.c
--- dlls/kernel26/editline.c	2003-02-19 21:10:45.000000000 +0100
+++ dlls/kernel/editline.c	2003-05-23 22:46:44.000000000 +0200
@@ -88,29 +88,10 @@
 
 static BOOL WCEL_Get(WCEL_Context* ctx, INPUT_RECORD* ir)
 {
-    DWORD		retv;
-
-    for (;;)
-    {
-	/* data available ? */
-	if (ReadConsoleInputW(ctx->hConIn, ir, 1, &retv) && retv == 1)
-	    return TRUE;
-	/* then wait... */
-	switch (WaitForSingleObject(ctx->hConIn, INFINITE))
-	{
-	case WAIT_OBJECT_0:
-	    break;
-	default:
-	    /* we have checked that hConIn was a console handle (could be sb) */
-	    ERR("Shouldn't happen\n");
-	    /* fall thru */
-	case WAIT_ABANDONED:
-	case WAIT_TIMEOUT:
-	    ctx->error = 1;
-	    ERR("hmm bad situation\n");
-	    return FALSE;
-	}
-    }
+    if (ReadConsoleInputW(ctx->hConIn, ir, 1, NULL)) return TRUE;
+    ERR("hmm bad situation\n");
+    ctx->error = 1;
+    return FALSE;
 }
 
 static inline void WCEL_Beep(WCEL_Context* ctx)
@@ -633,7 +614,7 @@
 static void WCEL_RepeatCount(WCEL_Context* ctx)
 {
 #if 0
-/* FIXME: wait untill all console code is in kernel32 */
+/* FIXME: wait until all console code is in kernel32 */
     INPUT_RECORD        ir;
     unsigned            repeat = 0;
 
@@ -822,11 +803,12 @@
 
     while (!ctx.done && !ctx.error && WCEL_Get(&ctx, &ir))
     {
-	if (ir.EventType != KEY_EVENT || !ir.Event.KeyEvent.bKeyDown) continue;
+	if (ir.EventType != KEY_EVENT) continue;
 	TRACE("key%s repeatCount=%u, keyCode=%02x scanCode=%02x char=%02x keyState=%08lx\n",
 	      ir.Event.KeyEvent.bKeyDown ? "Down" : "Up  ", ir.Event.KeyEvent.wRepeatCount,
 	      ir.Event.KeyEvent.wVirtualKeyCode, ir.Event.KeyEvent.wVirtualScanCode,
 	      ir.Event.KeyEvent.uChar.UnicodeChar, ir.Event.KeyEvent.dwControlKeyState);
+	if (!ir.Event.KeyEvent.bKeyDown) continue;
 
 /* EPP  	WCEL_Dump(&ctx, "before func"); */
 	ofs = ctx.ofs;
diff -u -N -r -x '*~' -x '.#*' -x CVS dlls/kernel26/kernel32.spec dlls/kernel/kernel32.spec
--- dlls/kernel26/kernel32.spec	2003-06-14 09:30:10.000000000 +0200
+++ dlls/kernel/kernel32.spec	2003-06-18 20:28:01.000000000 +0200
@@ -913,7 +913,7 @@
 @ stub AddConsoleAliasW
 @ stub BaseAttachCompleteThunk
 @ stub BasepDebugDump
-@ stub CloseConsoleHandle
+@ stdcall CloseConsoleHandle(long)
 @ stub CmdBatNotification
 @ stub ConsoleMenuControl
 @ stub ConsoleSubst
@@ -941,7 +941,7 @@
 @ stub GetConsoleFontInfo
 @ stub GetConsoleFontSize
 @ stub GetConsoleHardwareState
-@ stub GetConsoleInputWaitHandle
+@ stdcall GetConsoleInputWaitHandle()
 @ stub GetCurrentConsoleFont
 @ stub GetNextVDMCommand
 @ stub GetNumberOfConsoleFonts
@@ -953,7 +953,7 @@
 @ stub HeapUsage
 @ stub InvalidateConsoleDIBits
 @ stdcall IsDebuggerPresent()
-@ stub OpenConsoleW
+@ stdcall OpenConsoleW(wstr long ptr long)
 @ stub QueryWin31IniFilesMappedToRegistry
 @ stub RegisterConsoleVDM
 @ stub RegisterWaitForInputIdle
@@ -976,7 +976,7 @@
 @ stub TrimVirtualBuffer
 @ stub VDMConsoleOperation
 @ stub VDMOperationStarted
-@ stub VerifyConsoleIoHandle
+@ stdcall VerifyConsoleIoHandle(long)
 @ stub VirtualBufferExceptionHandler
 @ stub WriteConsoleInputVDMA
 @ stub WriteConsoleInputVDMW
@@ -991,7 +991,7 @@
 @ stdcall CreateWaitableTimerA(ptr long str)
 @ stdcall CreateWaitableTimerW(ptr long wstr)
 @ stdcall DeleteFiber(ptr)
-@ stub DuplicateConsoleHandle
+@ stdcall DuplicateConsoleHandle(long long long long)
 @ stdcall FindFirstFileExA(str long ptr long ptr long)
 @ stdcall FindFirstFileExW(wstr long ptr long ptr long)
 @ stub GetConsoleInputExeNameA
diff -u -N -r -x '*~' -x '.#*' -x CVS dlls/kernel26/kernel_private.h dlls/kernel/kernel_private.h
--- dlls/kernel26/kernel_private.h	1970-01-01 01:00:00.000000000 +0100
+++ dlls/kernel/kernel_private.h	2003-06-18 21:33:39.000000000 +0200
@@ -0,0 +1,47 @@
+/*
+ * Kernel32 undocumented and private functions definition
+ *
+ * Copyright 2003 Eric Pouech
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+#ifndef __WINE_KERNEL_PRIVATE_H
+#define __WINE_KERNEL_PRIVATE_H
+
+HANDLE  WINAPI OpenConsoleW(LPCWSTR, DWORD, LPSECURITY_ATTRIBUTES, DWORD);
+BOOL    WINAPI VerifyConsoleIoHandle(HANDLE);
+HANDLE  WINAPI DuplicateConsoleHandle(HANDLE, DWORD, BOOL, DWORD);
+BOOL    WINAPI CloseConsoleHandle(HANDLE handle);
+HANDLE  WINAPI GetConsoleInputWaitHandle(void);
+
+static inline BOOL is_console_handle(HANDLE h)
+{
+    return h != INVALID_HANDLE_VALUE && ((DWORD)h & 3) == 3;
+}
+
+/* map a real wineserver handle onto a kernel32 console handle */
+static inline HANDLE console_handle_map(HANDLE h)
+{
+    return h != INVALID_HANDLE_VALUE ? (HANDLE)((DWORD)h ^ 3) : INVALID_HANDLE_VALUE;
+}
+
+/* map a kernel32 console handle onto a real wineserver handle */
+static inline HANDLE console_handle_unmap(HANDLE h)
+{
+    return h != INVALID_HANDLE_VALUE ? (HANDLE)((DWORD)h ^ 3) : INVALID_HANDLE_VALUE;
+}
+
+#endif
diff -u -N -r -x '*~' -x '.#*' -x CVS dlls/kernel26/tests/console.c dlls/kernel/tests/console.c
--- dlls/kernel26/tests/console.c	2003-05-13 06:46:54.000000000 +0200
+++ dlls/kernel/tests/console.c	2003-06-18 21:12:55.000000000 +0200
@@ -538,7 +538,7 @@
 
 START_TEST(console)
 {
-    HANDLE hCon;
+    HANDLE hConIn, hConOut;
     BOOL ret;
     CONSOLE_SCREEN_BUFFER_INFO	sbi;
 
@@ -548,16 +548,29 @@
      * Another solution would be to rerun the test under wineconsole with
      * the curses backend
      */
-    FreeConsole();
-    AllocConsole();
-    hCon = GetStdHandle(STD_OUTPUT_HANDLE);
-    ok(ret = GetConsoleScreenBufferInfo(hCon, &sbi), "Getting sb info");
+
+    hConIn = CreateFileA("CONIN$", GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0);
+    hConOut = CreateFileA("CONOUT$", GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0);
+
+    /* first, we need to be sure we're attached to a console */
+    if (hConIn == INVALID_HANDLE_VALUE || hConOut == INVALID_HANDLE_VALUE)
+    {
+        /* we're not attached to a console, let's do it */
+        AllocConsole();
+        hConIn = CreateFileA("CONIN$", GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0);
+        hConOut = CreateFileA("CONOUT$", GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0);
+    }
+    /* now verify everything's ok */
+    ok(hConIn != INVALID_HANDLE_VALUE, "Opening ConIn");
+    ok(hConOut != INVALID_HANDLE_VALUE, "Opening ConOut");
+
+    ok(ret = GetConsoleScreenBufferInfo(hConOut, &sbi), "Getting sb info");
     if (!ret) return;
 
     /* Non interactive tests */
-    testCursor(hCon, sbi.dwSize);
+    testCursor(hConOut, sbi.dwSize);
     /* will test wrapped (on/off) & processed (on/off) strings output */
-    testWrite(hCon, sbi.dwSize);
+    testWrite(hConOut, sbi.dwSize);
     /* will test line scrolling at the bottom of the screen */
     /* testBottomScroll(); */
     /* will test all the scrolling operations */
diff -u -N -r -x '*~' -x '.#*' -x CVS files26/file.c files/file.c
--- files26/file.c	2003-06-14 09:30:11.000000000 +0200
+++ files/file.c	2003-06-18 21:11:05.000000000 +0200
@@ -70,6 +70,7 @@
 #include "heap.h"
 #include "msdos.h"
 #include "wincon.h"
+#include "../kernel/kernel_private.h"
 
 #include "smb.h"
 #include "wine/unicode.h"
@@ -351,30 +352,124 @@
     return FILE_GetUnixHandleType( handle, access, NULL, NULL );
 }
 
-/*************************************************************************
- * 		FILE_OpenConsole
+/******************************************************************
+ *		OpenConsoleW            (KERNEL32.@)
  *
- * Open a handle to the current process console.
- * Returns 0 on failure.
+ * Undocumented
+ *      Open a handle to the current process console.
+ *      Returns INVALID_HANDLE_VALUE on failure.
  */
-static HANDLE FILE_OpenConsole( BOOL output, DWORD access, DWORD sharing, LPSECURITY_ATTRIBUTES sa )
+HANDLE WINAPI OpenConsoleW(LPCWSTR name, DWORD access, LPSECURITY_ATTRIBUTES sa,
+                           DWORD creation)
 {
+    static const WCHAR coninW[] = {'C','O','N','I','N','$',0};
+    static const WCHAR conoutW[] = {'C','O','N','O','U','T','$',0};
+    BOOL        output;
     HANDLE ret;
 
+    if (strcmpW(coninW, name) == 0) 
+        output = FALSE;
+    else if (strcmpW(conoutW, name) == 0) 
+        output = TRUE;
+    else
+    {
+        SetLastError(ERROR_INVALID_NAME);
+        return INVALID_HANDLE_VALUE;
+    }
+    if (creation != OPEN_EXISTING)
+    {
+        SetLastError(ERROR_INVALID_PARAMETER);
+        return INVALID_HANDLE_VALUE;
+    }
+
     SERVER_START_REQ( open_console )
     {
         req->from    = output;
         req->access  = access;
-	req->share   = sharing;
+	req->share   = FILE_SHARE_READ | FILE_SHARE_WRITE;
         req->inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
         SetLastError(0);
         wine_server_call_err( req );
         ret = reply->handle;
     }
     SERVER_END_REQ;
+    return ret ? console_handle_map(ret) : INVALID_HANDLE_VALUE;
+}
+
+/******************************************************************
+ *		VerifyConsoleIoHandle            (KERNEL32.@)
+ *
+ * Undocumented
+ */
+BOOL WINAPI VerifyConsoleIoHandle(HANDLE handle)
+{
+    BOOL ret;
+
+    if (!is_console_handle(handle)) return FALSE;
+    SERVER_START_REQ(get_console_mode)
+    {
+	req->handle = console_handle_unmap(handle);
+	ret = !wine_server_call_err( req );
+    }
+    SERVER_END_REQ;
     return ret;
 }
 
+/******************************************************************
+ *		DuplicateConsoleHandle            (KERNEL32.@)
+ *
+ * Undocumented
+ */
+HANDLE WINAPI DuplicateConsoleHandle(HANDLE handle, DWORD access, BOOL inherit,
+                                     DWORD options)
+{
+    HANDLE      ret;
+
+    if (!is_console_handle(handle) ||
+        !DuplicateHandle(GetCurrentProcess(), console_handle_unmap(handle), 
+                         GetCurrentProcess(), &ret, access, inherit, options))
+        return INVALID_HANDLE_VALUE;
+    return console_handle_map(ret);
+}
+
+/******************************************************************
+ *		CloseConsoleHandle            (KERNEL32.@)
+ *
+ * Undocumented
+ */
+BOOL WINAPI CloseConsoleHandle(HANDLE handle)
+{
+    if (!is_console_handle(handle)) 
+    {
+        SetLastError(ERROR_INVALID_PARAMETER);
+        return FALSE;
+    }
+    return CloseHandle(console_handle_unmap(handle));
+}
+
+/******************************************************************
+ *		GetConsoleInputWaitHandle            (KERNEL32.@)
+ *
+ * Undocumented
+ */
+HANDLE WINAPI GetConsoleInputWaitHandle(void)
+{
+    static HANDLE console_wait_event;
+ 
+    /* FIXME: this is not thread safe */
+    if (!console_wait_event)
+    {
+        SERVER_START_REQ(get_console_wait_event)
+        {
+            if (!wine_server_call_err( req )) console_wait_event = reply->handle;
+        }
+        SERVER_END_REQ;
+    }
+    return console_wait_event;
+}
+/* end of FIXME */
+
+
 /* FIXME: those routines defined as pointers are needed, because this file is
  * currently compiled into NTDLL whereas it belongs to kernel32.
  * this shall go away once all the DLL separation process is done
@@ -630,14 +725,9 @@
     }
 
     /* Open a console for CONIN$ or CONOUT$ */
-    if (!strcmpiW(filename, coninW))
+    if (!strcmpiW(filename, coninW) || !strcmpiW(filename, conoutW))
     {
-        ret = FILE_OpenConsole( FALSE, access, sharing, sa );
-        goto done;
-    }
-    if (!strcmpiW(filename, conoutW))
-    {
-        ret = FILE_OpenConsole( TRUE, access, sharing, sa );
+        ret = OpenConsoleW(filename, access, sa, creation);
         goto done;
     }
 
@@ -1807,6 +1897,9 @@
     if (bytesRead) *bytesRead = 0;  /* Do this before anything else */
     if (!bytesToRead) return TRUE;
 
+    if (is_console_handle(hFile))
+	return FILE_ReadConsole(hFile, buffer, bytesToRead, bytesRead, NULL);
+
     unix_handle = FILE_GetUnixHandleType( hFile, GENERIC_READ, &type, &flags );
 
     if (flags & FD_FLAG_OVERLAPPED)
@@ -1845,9 +1938,6 @@
     case FD_TYPE_SMB:
         return SMB_ReadFile(hFile, buffer, bytesToRead, bytesRead, NULL);
 
-    case FD_TYPE_CONSOLE:
-	return FILE_ReadConsole(hFile, buffer, bytesToRead, bytesRead, NULL);
-
     case FD_TYPE_DEFAULT:
         /* normal unix files */
         if (unix_handle == -1) return FALSE;
@@ -2031,6 +2121,9 @@
     if (bytesWritten) *bytesWritten = 0;  /* Do this before anything else */
     if (!bytesToWrite) return TRUE;
 
+    if (is_console_handle(hFile))
+	return FILE_WriteConsole(hFile, buffer, bytesToWrite, bytesWritten, NULL);
+
     unix_handle = FILE_GetUnixHandleType( hFile, GENERIC_WRITE, &type, &flags );
 
     if (flags & FD_FLAG_OVERLAPPED)
@@ -2062,11 +2155,6 @@
 
     switch(type)
     {
-    case FD_TYPE_CONSOLE:
-	TRACE("%p %s %ld %p %p\n", hFile, debugstr_an(buffer, bytesToWrite), bytesToWrite,
-	      bytesWritten, overlapped );
-	return FILE_WriteConsole(hFile, buffer, bytesToWrite, bytesWritten, NULL);
-
     case FD_TYPE_DEFAULT:
         if (unix_handle == -1) return FALSE;
 
@@ -2366,6 +2454,13 @@
     NTSTATUS            nts;
     IO_STATUS_BLOCK     ioblk;
 
+    if (is_console_handle( hFile ))
+    {
+        /* this will fail (as expected) for an output handle */
+        /* FIXME: wait until FlushFileBuffers is moved to dll/kernel */
+        /* return FlushConsoleInputBuffer( hFile ); */
+        return TRUE;
+    }
     nts = NtFlushBuffersFile( hFile, &ioblk );
     if (nts != STATUS_SUCCESS)
     {
@@ -2473,6 +2568,10 @@
 DWORD WINAPI GetFileType( HANDLE hFile )
 {
     DWORD ret = FILE_TYPE_UNKNOWN;
+
+    if (is_console_handle( hFile ))
+        return FILE_TYPE_CHAR;
+
     SERVER_START_REQ( get_file_info )
     {
         req->handle = hFile;
diff -u -N -r -x '*~' -x '.#*' -x CVS programs/wineconsole26/wineconsole.c programs/wineconsole/wineconsole.c
--- programs/wineconsole26/wineconsole.c	2003-06-18 08:01:57.000000000 +0200
+++ programs/wineconsole/wineconsole.c	2003-06-18 20:28:27.000000000 +0200
@@ -535,6 +535,7 @@
     DWORD		ret;
     struct config_data  cfg;
     STARTUPINFOW        si;
+    HANDLE              sem;
 
     data = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*data));
     if (!data) return 0;
@@ -563,6 +564,7 @@
         /* should always be defined */
     }
 
+    sem = CreateSemaphore(NULL, 0, 65536, NULL);
     /* the handles here are created without the whistles and bells required by console
      * (mainly because wineconsole doesn't need it)
      * - they are not inheritable
@@ -570,9 +572,11 @@
      */
     SERVER_START_REQ(alloc_console)
     {
-        req->access  = GENERIC_READ | GENERIC_WRITE;
-        req->inherit = FALSE;
-	req->pid     = pid;
+        req->access     = GENERIC_READ | GENERIC_WRITE;
+        req->inherit    = FALSE;
+	req->pid        = pid;
+        req->wait_event = sem;
+
         ret = !wine_server_call_err( req );
         data->hConIn = (HANDLE)reply->handle_in;
 	data->hSynchro = (HANDLE)reply->event;
diff -u -N -r -x '*~' -x '.#*' -x CVS scheduler26/handle.c scheduler/handle.c
--- scheduler26/handle.c	2003-05-13 22:49:11.000000000 +0200
+++ scheduler/handle.c	2003-05-23 22:03:16.000000000 +0200
@@ -32,6 +32,7 @@
 #include "wine/server.h"
 #include "winerror.h"
 #include "wine/debug.h"
+#include "../kernel/kernel_private.h"  /* FIXME: to be changed when moving file to dlls/kernel */
 
 WINE_DEFAULT_DEBUG_CHANNEL(win32);
 
@@ -49,6 +50,9 @@
         (handle == (HANDLE)STD_ERROR_HANDLE))
         handle = GetStdHandle( (DWORD)handle );
 
+    if (is_console_handle(handle))
+        return CloseConsoleHandle(handle);
+
     status = NtClose( handle );
     if (status) SetLastError( RtlNtStatusToDosError(status) );
     return !status;
@@ -118,8 +122,22 @@
                              HANDLE dest_process, HANDLE *dest,
                              DWORD access, BOOL inherit, DWORD options )
 {
-    NTSTATUS status = NtDuplicateObject( source_process, source, dest_process, dest,
-                                         access, inherit ? OBJ_INHERIT : 0, options );
+    NTSTATUS status;
+
+    if (is_console_handle(source))
+    {
+        /* FIXME: this test is not sufficient, we need to test process ids, not handles */
+        if (source_process != dest_process ||
+            source_process != GetCurrentProcess())
+        {
+            SetLastError(ERROR_INVALID_PARAMETER);
+            return FALSE;
+        }
+        *dest = DuplicateConsoleHandle( source, access, inherit, options );
+        return (*dest != INVALID_HANDLE_VALUE);
+    }
+    status = NtDuplicateObject( source_process, source, dest_process, dest,
+                                access, inherit ? OBJ_INHERIT : 0, options );
     if (status) SetLastError( RtlNtStatusToDosError(status) );
     return !status;
 }
diff -u -N -r -x '*~' -x '.#*' -x CVS scheduler26/process.c scheduler/process.c
--- scheduler26/process.c	2003-06-18 21:51:18.000000000 +0200
+++ scheduler/process.c	2003-06-20 21:27:30.000000000 +0200
@@ -47,6 +47,7 @@
 #include "wine/server.h"
 #include "options.h"
 #include "wine/debug.h"
+#include "../kernel/kernel_private.h"
 
 WINE_DEFAULT_DEBUG_CHANNEL(process);
 WINE_DECLARE_DEBUG_CHANNEL(server);
@@ -330,19 +329,31 @@
     /* Create the process heap */
     current_process.heap = HeapCreate( HEAP_GROWABLE, 0, 0 );
 
-    if (main_create_flags == 0 &&
-	process_pmts.hStdInput  == 0 &&
-	process_pmts.hStdOutput == 0 &&
-	process_pmts.hStdError  == 0)
-    {
-	/* This is wine specific:
-         * no parent, and no new console requested, create a simple console with bare handles to
-	 * unix stdio input & output streams (aka simple console)
+    if (info_size == 0)
+    {
+	/* This is wine specific: we have no parent (we're started from unix)
+         * so, create a simple console with bare handles to unix stdio 
+         * input & output streams (aka simple console)
 	 */
         wine_server_fd_to_handle( 0, GENERIC_READ|SYNCHRONIZE,  TRUE, &process_pmts.hStdInput );
         wine_server_fd_to_handle( 1, GENERIC_WRITE|SYNCHRONIZE, TRUE, &process_pmts.hStdOutput );
         wine_server_fd_to_handle( 1, GENERIC_WRITE|SYNCHRONIZE, TRUE, &process_pmts.hStdError );
     }
+    else
+    {
+        if (!process_pmts.hStdInput)
+            process_pmts.hStdInput = INVALID_HANDLE_VALUE;
+        else if (VerifyConsoleIoHandle(console_handle_map(process_pmts.hStdInput)))
+            process_pmts.hStdInput = console_handle_map(process_pmts.hStdInput);
+        if (!process_pmts.hStdOutput)
+            process_pmts.hStdOutput = INVALID_HANDLE_VALUE;
+        else if (VerifyConsoleIoHandle(console_handle_map(process_pmts.hStdOutput)))
+            process_pmts.hStdOutput = console_handle_map(process_pmts.hStdOutput);
+        if (!process_pmts.hStdError)
+            process_pmts.hStdError = INVALID_HANDLE_VALUE;
+        else if (VerifyConsoleIoHandle(console_handle_map(process_pmts.hStdError)))
+            process_pmts.hStdError = console_handle_map(process_pmts.hStdError);
+    }
 
     /* Now we can use the pthreads routines */
     PTHREAD_init_done();
@@ -955,6 +964,20 @@
             req->hstderr = GetStdHandle( STD_ERROR_HANDLE );
         }
 
+        if ((flags & (CREATE_NEW_CONSOLE | DETACHED_PROCESS)) != 0)
+        {
+            /* this is temporary (for console handles). We have no way to control that the handle is invalid in child process otherwise */
+            if (is_console_handle(req->hstdin))  req->hstdin  = INVALID_HANDLE_VALUE;
+            if (is_console_handle(req->hstdout)) req->hstdout = INVALID_HANDLE_VALUE;
+            if (is_console_handle(req->hstderr)) req->hstderr = INVALID_HANDLE_VALUE;
+        }
+        else
+        {
+            if (is_console_handle(req->hstdin))  req->hstdin  = console_handle_unmap(req->hstdin);
+            if (is_console_handle(req->hstdout)) req->hstdout = console_handle_unmap(req->hstdout);
+            if (is_console_handle(req->hstderr)) req->hstderr = console_handle_unmap(req->hstderr);
+        }
+
         if (GetLongPathNameA( filename, buf, MAX_PATH ))
             nameptr = buf;
         else
diff -u -N -r -x '*~' -x '.#*' -x CVS scheduler26/synchro.c scheduler/synchro.c
--- scheduler26/synchro.c	2003-03-31 21:34:14.000000000 +0200
+++ scheduler/synchro.c	2003-05-23 22:11:09.000000000 +0200
@@ -22,6 +22,7 @@
 
 #include "winbase.h"
 #include "winternl.h"
+#include "../kernel/kernel_private.h" /* FIXME: to be changed when moving file to dlls/kernel */
 
 
 /***********************************************************************
@@ -80,10 +81,39 @@
                                        BOOL alertable )
 {
     NTSTATUS status;
+    HANDLE hloc[MAXIMUM_WAIT_OBJECTS];
+    int i;
+
+    if (count >= MAXIMUM_WAIT_OBJECTS)
+    {
+        SetLastError(ERROR_INVALID_PARAMETER);
+        return WAIT_FAILED;
+    }
+    for (i = 0; i < count; i++)
+    {
+        if ((handles[i] == (HANDLE)STD_INPUT_HANDLE) ||
+            (handles[i] == (HANDLE)STD_OUTPUT_HANDLE) ||
+            (handles[i] == (HANDLE)STD_ERROR_HANDLE))
+            hloc[i] = GetStdHandle( (DWORD)handles[i] );
+        else
+            hloc[i] = handles[i];
+
+        /* yes, even screen buffer console handles are waitable, and are
+         * handled as a handle to the console itself !!
+         */
+        if (is_console_handle(hloc[i]))
+        {
+            if (!VerifyConsoleIoHandle(hloc[i]))
+            {
+                return FALSE;
+            }
+            hloc[i] = GetConsoleInputWaitHandle();
+        }
+    }
 
     if (timeout == INFINITE)
     {
-        status = NtWaitForMultipleObjects( count, handles, wait_all, alertable, NULL );
+        status = NtWaitForMultipleObjects( count, hloc, wait_all, alertable, NULL );
     }
     else
     {
@@ -91,7 +121,7 @@
 
         time.QuadPart = timeout * (ULONGLONG)10000;
         time.QuadPart = -time.QuadPart;
-        status = NtWaitForMultipleObjects( count, handles, wait_all, alertable, &time );
+        status = NtWaitForMultipleObjects( count, hloc, wait_all, alertable, &time );
     }
 
     if (HIWORD(status))  /* is it an error code? */
diff -u -N -r -x '*~' -x '.#*' -x CVS server26/console.c server/console.c
--- server26/console.c	2003-05-10 22:40:04.000000000 +0200
+++ server/console.c	2003-06-18 20:47:15.000000000 +0200
@@ -35,18 +35,16 @@
 #include "unicode.h"
 #include "console.h"
 
-
 static void console_input_dump( struct object *obj, int verbose );
 static void console_input_destroy( struct object *obj );
-static int console_input_signaled( struct object *obj, struct thread *thread );
 
 static const struct object_ops console_input_ops =
 {
     sizeof(struct console_input),     /* size */
     console_input_dump,               /* dump */
-    add_queue,                        /* add_queue */
-    remove_queue,                     /* remove_queue */
-    console_input_signaled,           /* signaled */
+    no_add_queue,                     /* add_queue */
+    NULL,                             /* remove_queue */
+    NULL,                             /* signaled */
     no_satisfied,                     /* satisfied */
     no_get_fd,                        /* get_fd */
     console_input_destroy             /* destroy */
@@ -205,7 +203,7 @@
     return evt;
 }
 
-static struct object *create_console_input( struct thread* renderer )
+static struct object *create_console_input( struct thread* renderer, struct object* wait_obj )
 {
     struct console_input *console_input;
 
@@ -224,6 +222,7 @@
     console_input->history_index = 0;
     console_input->history_mode  = 0;
     console_input->edition_mode  = 0;
+    console_input->wait_obj      = wait_obj;
 
     if (!console_input->history || !console_input->evt)
     {
@@ -368,11 +367,6 @@
     }
 }
 
-int is_console_object( struct object *obj )
-{
-    return (obj->ops == &console_input_ops || obj->ops == &screen_buffer_ops);
-}
-
 static struct console_input* console_input_get( obj_handle_t handle, unsigned access )
 {
     struct console_input*	console = 0;
@@ -390,14 +384,6 @@
     return console;
 }
 
-/* check if a console input is signaled: yes if non read input records */
-static int console_input_signaled( struct object *obj, struct thread *thread )
-{
-    struct console_input *console = (struct console_input *)obj;
-    assert( obj->ops == &console_input_ops );
-    return console->recnum ? 1 : 0;
-}
-
 struct console_signal_info {
     struct console_input        *console;
     process_id_t                 group;
@@ -957,6 +943,7 @@
 
     release_object( console_in->evt );
     console_in->evt = NULL;
+    release_object( console_in->wait_obj );
 
     for (i = 0; i < console_in->history_size; i++)
 	if (console_in->history[i]) free( console_in->history[i] );
@@ -1222,6 +1209,7 @@
     struct process *process;
     struct process *renderer = current->process;
     struct console_input *console;
+    struct object *wait_event;
 
     process = (req->pid) ? get_process_from_id( req->pid ) :
               (struct process *)grab_object( renderer->parent );
@@ -1234,8 +1222,13 @@
         set_error( STATUS_ACCESS_DENIED );
         goto the_end;
     }
-
-    if ((console = (struct console_input*)create_console_input( current )))
+    wait_event = get_handle_obj( renderer, req->wait_event, 0, NULL);
+    if (!wait_event)
+    {
+        set_error( STATUS_INVALID_PARAMETER );
+        goto the_end;
+    }
+    if ((console = (struct console_input*)create_console_input( current, wait_event )))
     {
         if ((in = alloc_handle( renderer, console, req->access, req->inherit )))
         {
@@ -1512,7 +1505,36 @@
     group = req->group_id ? req->group_id : current->process->group_id;
 
     if (!group)
-        set_error( STATUS_INVALID_PARAMETER);
+        set_error( STATUS_INVALID_PARAMETER );
     else
         propagate_console_signal( current->process->console, req->signal, group );
 }
+
+/* get console which renderer is 'current' */
+static int cgwe_enum( struct process* process, void* user)
+{
+    if (process->console && process->console->renderer == current)
+    {
+        *(struct console_input**)user = process->console;
+        return 1;
+    }
+    return 0;
+}
+
+DECL_HANDLER(get_console_wait_event)
+{
+    struct console_input* console = NULL;
+
+    if (current->process->console && current->process->console->renderer)
+        console = (struct console_input*)grab_object( (struct object*)current->process->console );
+    else enum_processes(cgwe_enum, &console);
+
+    if (console)
+    {
+        reply->handle = alloc_handle( current->process, console->wait_obj, 
+                                      SEMAPHORE_ALL_ACCESS, FALSE);
+        release_object( console );
+    }
+    else set_error( STATUS_INVALID_PARAMETER );
+}
+
diff -u -N -r -x '*~' -x '.#*' -x CVS server26/console.h server/console.h
--- server26/console.h	2003-05-10 22:40:04.000000000 +0200
+++ server/console.h	2003-05-23 15:43:03.000000000 +0200
@@ -42,12 +42,12 @@
     int                          history_index; /* number of used entries in history array */
     int                          history_mode;  /* mode of history (non zero means remove doubled strings */
     int                          edition_mode;  /* index to edition mode flavors */
+    struct object               *wait_obj;      /* object to wait on for input queue */
 };
 
 /* console functions */
 
 extern void inherit_console(struct thread *parent_thread, struct process *process, obj_handle_t hconin);
 extern int free_console( struct process *process );
-extern int is_console_object( struct object *obj );
 
 #endif  /* __WINE_SERVER_CONSOLE_H */
diff -u -N -r -x '*~' -x '.#*' -x CVS server26/fd.c server/fd.c
--- server26/fd.c	2003-05-15 20:34:06.000000000 +0200
+++ server/fd.c	2003-05-23 15:43:26.000000000 +0200
@@ -42,7 +42,6 @@
 #include "handle.h"
 #include "process.h"
 #include "request.h"
-#include "console.h"
 
 /* Because of the stupid Posix locking semantics, we need to keep
  * track of all file descriptors referencing a given file, and not
@@ -1035,16 +1034,6 @@
         reply->type = fd->fd_ops->get_file_info( fd, NULL, &reply->flags );
         release_object( fd );
     }
-    else  /* check for console handle (FIXME: should be done in the client) */
-    {
-        struct object *obj;
-
-        if ((obj = get_handle_obj( current->process, req->handle, req->access, NULL )))
-        {
-            if (is_console_object( obj )) reply->type = FD_TYPE_CONSOLE;
-            release_object( obj );
-        }
-    }
 }
 
 /* get a file information */
diff -u -N -r -x '*~' -x '.#*' -x CVS server26/process.c server/process.c
--- server26/process.c	2003-03-18 21:42:00.000000000 +0100
+++ server/process.c	2003-06-20 21:03:53.000000000 +0200
@@ -221,40 +221,11 @@
     }
     if (info)
     {
-        if (!info->inherit_all && !info->use_handles)
-        {
-            /* duplicate the handle from the parent into this process */
-            reply->hstdin  = duplicate_handle( parent_thread->process, info->hstdin, process,
-                                               0, TRUE, DUPLICATE_SAME_ACCESS );
-            reply->hstdout = duplicate_handle( parent_thread->process, info->hstdout, process,
-                                               0, TRUE, DUPLICATE_SAME_ACCESS );
-            reply->hstderr = duplicate_handle( parent_thread->process, info->hstderr, process,
-                                               0, TRUE, DUPLICATE_SAME_ACCESS );
-        }
-        else
-        {
-            reply->hstdin  = info->hstdin;
-            reply->hstdout = info->hstdout;
-            reply->hstderr = info->hstderr;
-        }
-    }
-    else
-    {
-        if (process->console)
-        {
-            reply->hstdin  = alloc_handle( process, process->console,
-                                           GENERIC_READ | GENERIC_WRITE | SYNCHRONIZE, 1 );
-            reply->hstdout = alloc_handle( process, process->console->active,
-                                           GENERIC_READ | GENERIC_WRITE, 1 );
-            reply->hstderr = alloc_handle( process, process->console->active,
-                                           GENERIC_READ | GENERIC_WRITE, 1 );
-        }
-        else
-        {
-            /* no parent, let the caller decide what to do */
-            reply->hstdin = reply->hstdout = reply->hstderr = 0;
-        }
+        reply->hstdin  = info->hstdin;
+        reply->hstdout = info->hstdout;
+        reply->hstderr = info->hstderr;
     }
+    else reply->hstdin = reply->hstdout = reply->hstderr = 0;
     /* some handles above may have been invalid; this is not an error */
     if (get_error() == STATUS_INVALID_HANDLE) clear_error();
     return 1;
diff -u -N -r -x '*~' -x '.#*' -x CVS server26/protocol.def server/protocol.def
--- server26/protocol.def	2003-06-18 21:46:42.000000000 +0200
+++ server/protocol.def	2003-06-18 20:28:29.000000000 +0200
@@ -627,7 +627,6 @@
 {
     FD_TYPE_INVALID,
     FD_TYPE_DEFAULT,
-    FD_TYPE_CONSOLE,
     FD_TYPE_SOCKET,
     FD_TYPE_SMB
 };
@@ -776,6 +775,7 @@
     unsigned int access;        /* wanted access rights */
     int          inherit;       /* inherit flag */
     process_id_t pid;           /* pid of process which shall be attached to the console */
+    obj_handle_t wait_event;    /* semaphore for number of active input events */
 @REPLY
     obj_handle_t handle_in;     /* handle to console input */
     obj_handle_t event;         /* handle to renderer events change notification */
@@ -851,6 +851,12 @@
 @END
 
 
+/* Get the input queue wait event */
+ at REQ(get_console_wait_event)
+ at REPLY
+    obj_handle_t handle;
+ at END
+
 /* Get a console mode (input or output) */
 @REQ(get_console_mode)
     obj_handle_t handle;        /* handle to the console */


More information about the wine-patches mailing list