--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/core/src/pipe_line.h	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,131 @@
+// pipe_line.h
+// 
+// Copyright (c) 2006 - 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
+//
+
+#ifndef __PIPE_LINE_H__
+#define __PIPE_LINE_H__
+
+#include <e32base.h>
+#include "command_wrappers.h"
+
+class TError;
+class CPipeLine;
+class MConsole;
+class CCommandFactory;
+namespace IoUtils
+	{
+	class CEnvironment;
+	}
+
+
+class MPipeLineObserver
+	{
+public:
+	virtual void HandlePipeLineComplete(CPipeLine& aPipeLine, const TError& aError) = 0;
+	};
+
+
+class RPipeSection
+	{
+public:
+	RPipeSection();
+	void Close();
+	HBufC* GetCommandArguments() const;
+public:
+	class TRedirection
+		{
+	public:
+		enum TType
+			{
+			ENotRedirected,
+			EFile,
+			EFileAppend,
+			EHandle,
+			ENull
+			};
+		enum THandle
+			{
+			EUnknown,
+			EStdin,
+			EStdout,
+			EStderr
+			};
+	public:
+		TRedirection();
+		void SetFileNameL(const TDesC& aCwd, const TDesC& aName);
+	public:
+		TType iType;
+		IoUtils::TFileName2* iFileName;
+		THandle iHandle;
+		};
+public:
+	TPtrC iFullName;
+	TPtrC iCommandName;
+	RArray<TPtrC> iCommandArguments;
+	TRedirection iStdinRedirection;
+	TRedirection iStdoutRedirection;
+	TRedirection iStderrRedirection;
+private:
+	mutable HBufC* iCommandArgumentsBuf;
+	};
+
+
+class CPipeLine : public CBase, public MCommandObserver
+	{
+public:
+	static CPipeLine* NewL(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, const RArray<RPipeSection>& aPipeSections, TBool aBackground, MPipeLineObserver* aObserver, TError& aErrorContext);
+	static CPipeLine* NewLC(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, const RArray<RPipeSection>& aPipeSections, TBool aBackground, MPipeLineObserver* aObserver, TError& aErrorContext);
+	~CPipeLine();
+	void Kill();
+	TInt Suspend();
+	TInt Resume();
+	TInt BringToForeground();
+	void SendToBackground();
+	const TDesC& Name() const;
+	TInt Reattach(RIoEndPoint& aStdinEndPoint, RIoEndPoint& aStdoutEndPoint, RIoEndPoint& aStderrEndPoint);
+	TBool IsDisownable() const;
+	void Disown();
+private:
+	CPipeLine(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, MPipeLineObserver* aObserver);
+	void ConstructL(const RArray<RPipeSection>& aPipeSections, TBool aBackground, TError& aErrorContext);
+	static TInt CompletionCallBack(TAny* aSelf);
+private:	// From MCommandObserver.
+	virtual void HandleCommandComplete(MCommand& aCommand, TInt aError);
+private:
+	class RPipedCommand
+		{
+	public:
+		RPipedCommand();
+		void Close();
+	public:
+		MCommand* iCommand;
+		TInt iCompletionError;
+		HBufC* iCommandName;
+		TBool iStdinRedirected;
+		TBool iStdoutRedirected;
+		TBool iStderrRedirected;
+		};
+private:
+	TPtrC iName;
+	RIoSession& iIoSession;
+	RIoReadHandle& iStdin;
+	RIoWriteHandle& iStdout;
+	RIoWriteHandle& iStderr;
+	IoUtils::CEnvironment& iEnv;
+	CCommandFactory& iFactory;
+	MPipeLineObserver* iObserver;
+	RArray<RPipedCommand> iCommands;
+	CAsyncCallBack* iCompletionCallBack;
+	TError iCompletionError;
+	};
+
+
+#endif // __PIPE_LINE_H__