diff -r 000000000000 -r 7f656887cf89 plugins/consoles/win32cons/src/console.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/consoles/win32cons/src/console.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,255 @@
+// console.cpp
+// 
+// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+// 
+// Initial Contributors:
+// Accenture - Initial contribution
+//
+
+#include <e32debug.h>
+#include "console.h"
+#include <fshell/consoleextensions.h>
+
+_LIT(KWin32ConsPanic, "Win32Console");
+#define PANIC() User::Panic(KWin32ConsPanic, 0);
+
+//_____________________________________________________________________________
+//					CWin32Console
+CWin32Console::CWin32Console()
+	{
+	}
+
+CWin32Console::~CWin32Console()
+	{
+	iWin32.FreeConsole();
+	// when call FreeConsole(), it should cause the reader thread to exit as the
+	// console read handle will become invalid, and windows will complete the
+	// ReadRequest with an error
+	if (iReaderThread.Handle())
+		{
+		TRequestStatus stat;
+		iReaderThread.Logon(stat);
+		User::WaitForRequest(stat);
+		}
+	iReaderThread.Close();
+	iKeyQueue.Close();
+	iThreadParams.iOwner.Close();
+	}
+
+TInt CWin32Console::Create(const TDesC& aTitle, TSize /*aSize*/)
+	{
+	int r = iWin32.AttachConsole();
+	if (r==0)
+		{
+		return KErrCouldNotConnect; // suitable error code??
+		}
+	SetTitle(aTitle);
+	
+	_LIT(KReadThreadName, "Win32ConsReader");
+	
+	TInt err = iKeyQueue.CreateLocal(4);
+	if (err!=KErrNone) return err;
+	
+	err = iThreadParams.iOwner.Open(RThread().Id());
+	if (err!=KErrNone) return err;
+	iThreadParams.iWin32 = &iWin32;
+	iThreadParams.iKeyQueue = iKeyQueue;
+	err = iReaderThread.Create(KReadThreadName, ReaderThread, 0x800, KMinHeapSize, KMinHeapSize*4, &iThreadParams);
+	if (err!=KErrNone) return err;
+	iReaderThread.Resume();	
+	
+	return KErrNone;
+	}
+
+void CWin32Console::Read(TRequestStatus& aStatus)
+	{
+	iReadKp = EFalse;
+	iKeyQueue.NotifyDataAvailable(aStatus);
+	}
+
+void CWin32Console::ReadCancel()
+	{
+	iKeyQueue.CancelDataAvailable();
+	}
+
+void CWin32Console::Write(const TDesC& aDes)
+	{
+	iWin32.Write(aDes.Ptr(), aDes.Length());
+	}
+	
+void CWin32Console::WriteStdErr(const TDesC& aDes)
+	{
+	iWin32.WriteStdErr(aDes.Ptr(), aDes.Length());
+	}
+
+TPoint CWin32Console::CursorPos() const
+	{
+	TPoint pos;
+	iWin32.GetCursorPos(pos.iX, pos.iY);
+	return pos;
+	}
+
+void CWin32Console::SetCursorPosAbs(const TPoint& aPoint)
+	{
+	iWin32.SetCursorPos(aPoint.iX, aPoint.iY);
+	}
+
+void CWin32Console::SetCursorPosRel(const TPoint& aPoint)
+	{
+	iWin32.SetCursorPosRel(aPoint.iX, aPoint.iY);
+	}
+
+void CWin32Console::SetCursorHeight(TInt aPercentage)
+	{
+	iWin32.SetCursorHeight(aPercentage);
+	}
+
+void CWin32Console::SetTitle(const TDesC& aTitle)
+	{
+	RBuf8 title;
+	TInt err = title.Create(aTitle.Length()+1);
+	if (err==KErrNone)
+		{
+		title.Copy(aTitle);
+		iWin32.SetTitle((const char*)title.PtrZ());
+		title.Close();
+		}
+	}
+
+void CWin32Console::ClearScreen()
+	{
+	iWin32.ClearScreen();
+	}
+
+void CWin32Console::ClearToEndOfLine()
+	{
+	iWin32.ClearToEndOfLine();
+	}
+
+TSize CWin32Console::ScreenSize() const
+	{
+	TSize size;
+	iWin32.GetScreenSize(size.iWidth, size.iHeight);
+	return size;
+	}
+
+TKeyCode CWin32Console::KeyCode() const
+	{
+	if (!iReadKp)
+		{
+		iKeyQueue.Receive(iKp);
+		iReadKp = ETrue;
+		}
+	return iKp.iCode;
+	}
+
+TUint CWin32Console::KeyModifiers() const
+	{
+	if (!iReadKp)
+		{
+		iKeyQueue.Receive(iKp);
+		iReadKp = ETrue;
+		}
+	return iKp.iModifiers;
+	}
+
+TInt CWin32Console::Extension_(TUint aExtensionId, TAny*& a0, TAny* a1)
+	{
+	if (aExtensionId == ConsoleStdErr::KWriteStdErrConsoleExtension)
+		{
+		TDesC* des = (TDesC*)a1;
+		WriteStdErr(*des);
+		return KErrNone;
+		}
+	else if (aExtensionId == ConsoleAttributes::KSetConsoleAttributesExtension)
+		{
+		ConsoleAttributes::TAttributes* attributes = (ConsoleAttributes::TAttributes*)a1;
+		int res = iWin32.SetAttributes(attributes->iAttributes, (TWin32Console::TColor)attributes->iForegroundColor, (TWin32Console::TColor)attributes->iBackgroundColor);
+		return res ? KErrNone : KErrGeneral; // Yay for KErrGeneral!
+		}
+	else
+		{
+		return CConsoleBase::Extension_(aExtensionId, a0, a1);
+		}
+	
+	}
+
+//_____________________________________________________________________________
+//					Reader thread
+
+static int ReaderThread(TAny* aParams)
+	{
+	TReaderThreadParams params = *(TReaderThreadParams*)aParams;
+	
+	RMsgQueue<TKeyPress> keyQueue = params.iKeyQueue;
+	TInt err = keyQueue.Duplicate(params.iOwner);
+	
+	while (err==KErrNone)
+		{
+		TKeyPress kp;
+		err = params.iWin32->ReadKey(kp.iCode, kp.iModifiers);
+		
+		if (err==KErrNone)
+			{
+			keyQueue.SendBlocking(kp);
+			}
+
+		};
+	
+	keyQueue.Close();
+	
+	return err;
+	}
+
+//_____________________________________________________________________________
+//					Debugging stuff
+EXPORT_C TAny* NewConsole()
+	{
+	return new CWin32Console;
+	}
+
+class TOverflowTruncate8 : public TDes8Overflow
+	{
+public:
+	virtual void Overflow(TDes8&) {}
+	};
+
+class TOverflowTruncate16 : public TDes16Overflow
+	{
+public:
+	virtual void Overflow(TDes16&) {}
+	};
+
+void DebugMsg(const char* aMsg, ...)
+	{
+	VA_LIST list;
+	VA_START(list, aMsg);
+	TBuf8<0x100> buf;
+	TOverflowTruncate8 overflow;
+	buf.AppendFormatList(_L8(aMsg), list, &overflow);
+
+	RDebug::Printf((const char*)buf.PtrZ());
+	}
+
+void DebugMsg(const TUint16* aMsg, ...)
+	{
+	VA_LIST list;
+	VA_START(list, aMsg);
+	TBuf16<0x100> buf;
+	TOverflowTruncate16 overflow;
+	buf.AppendFormatList(TPtrC((const TText16*)aMsg), list, &overflow);
+
+	RDebug::Print(buf);
+	}
+
+
+#ifndef EKA2
+GLDEF_C TInt E32Dll(TDllReason)
+	{
+	return(KErrNone);
+	}
+#endif