// Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "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:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

// Support for pipes between processes

// CPipeDesc is in the parent process, CPipeChildDesc is in the child

// 

//

#include "FDESC.H"

#include <sys/ioctl.h>

NONSHARABLE_CLASS(CPipeDesc) : public CFileDescBase

/**

@internalComponent

*/

	{

public:

	CPipeDesc(TInt anIndex);

	void SetClientSide(CPipeDesc*& aClientPointer);

	TInt LSeek(int& offset, int whence);

	void Read(TDes8& aDesc, TRequestStatus& aStatus);

	TInt ReadCompletion(TDes8& aDesc, TInt aStatus);

	void ReadCancel();

	void Write(TDes8& aDesc, TRequestStatus& aStatus);

	TInt WriteCompletion(TDes8& aDesc, TInt aStatus);

	void WriteCancel();

	TInt FStat(struct stat *st);

	void Ioctl(int aCmd, void* aParam, TRequestStatus& aStatus);

	TInt IoctlCompletion(int aCmd, void* aParam, TInt aStatus);

	void IoctlCancel();

	void ClientRead(const RMessage2& aMessage);

	void ClientWrite(const RMessage2& aMessage);

	void ClientIoctl(const RMessage2& aMessage);

	void ClientCancel(const RMessage2& aMessage);

	void ClientClose();

protected:

	TInt FinalClose();

private:

	void Cancel();

	TInt IsWriteable() { return !iIndex; }	// 0 => child STDIN

	TInt IsReadable() { return iIndex; }

	TInt SelectMask()       { return (iIndex)? E32SELECT_READ :E32SELECT_WRITE; }

	TInt ClientSelectMask() { return (iIndex)? E32SELECT_WRITE:E32SELECT_READ;  }

	TInt ClientIoctlPending() { return iClientIoctlPending; }

	void TransferFromClient();

	void TransferToClient();

	void CompleteClientIoctl(TInt ret);

	void CompleteClientIoctl();

	void Panic(TInt aReason);

	void Panic(RMessage2& aMessage, TInt aReason);

private:

	TInt iIndex;	// index into per-process table of pipes, also implies direction.

	CPipeDesc** iClientSide;

	TInt iClientClosed;

	// Pending info for parent operation

	TRequestStatus* iStatus;	// null implies "no pending operation"

	TRequestStatus* iIoctlStatus;

	TPtrC8 iWriteBuf;

	TDes8* iReadBuf;

	// Pending info for child operation

	TInt iClientLength;		// 0 implies "no pending operation"

	TInt iClientOffset;

	RMessage2 iMessage;

	TInt iClientIoctlPending;

	RMessage2 iIoctlMessage;

	};

class RPosixSession;

NONSHARABLE_CLASS(CPipeChildDesc) : public CFileDescBase

/**

CPipeChildDesc

Basically just forwards requests to the parent CPosixServer, where the related CPipeDesc

does the actual work.

@internalComponent

*/

	{

public:

	CPipeChildDesc(TInt anIndex, RPosixSession& aSession); 

	TInt LSeek(int& offset, int whence);

	void Read(TDes8& aDesc, TRequestStatus& aStatus);

	TInt ReadCompletion(TDes8& aDesc, TInt aStatus);

	void ReadCancel();

	void Write(TDes8& aDesc, TRequestStatus& aStatus);

	TInt WriteCompletion(TDes8& aDesc, TInt aStatus);

	void WriteCancel();

	TInt FStat(struct stat *st);

	void Ioctl(int aCmd, void* aParam, TRequestStatus& aStatus);

	void IoctlCancel();

	void ClientClose() { iClientClosed=1; }

protected:

	TInt FinalClose();

private:

	void Cancel(TInt aType);

	TInt IsWriteable() { return iIndex; }	// 0 => child STDIN

	TInt IsReadable() { return !iIndex; }

	TInt SelectMask() { return (!iIndex)? E32SELECT_READ:E32SELECT_WRITE; }

	TInt iIndex;	// index into per-process table of pipes, also implies direction.

	RPosixSession& iSession;

	TInt iClientClosed;

	TPtr8 iParamDes;

	};