/*
* Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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: 
* Library to add s32strm support for IPC (ie. stream via multiple IPC read/writes instead of
* copying to a buffer and streaming to/from there.
*
*/


/**
 @file
*/
#include "ipcbuf.h"


EXPORT_C void RIpcBuf::Open(const RMessagePtr2& aMessage, TInt aMessageSlot)
	{
	iMessage = aMessage;
	iMessageSlot = aMessageSlot;
	iReadPos = 0;
	iWritePos = 0;
	}

EXPORT_C TStreamPos RIpcBuf::DoSeekL(TMark aMark, TStreamLocation aLocation, TInt anOffset)
	{

	TInt size = iMessage.GetDesLengthL(iMessageSlot);

	switch (aLocation)
		{
	case EStreamBeginning:
		// do nothing
		break;
		
	case EStreamMark:
		if (aMark&ERead)
			{
			anOffset += iReadPos;
			}
		else if (aMark&EWrite)
			{
			anOffset += iWritePos;
			}
		break;
		
	case EStreamEnd:
		anOffset += size;
		break;
		
	default:
		User::Panic(KIpcBufPanic, EIpcBufSeekUnknownLocation);
		break;
		}
		
	// offset can't be negative or greater than size
	if (anOffset > size || anOffset < 0)
		{
		User::Panic(KIpcBufPanic, EIpcBufSeekBadOffset);
		}
		
	if (aMark&ERead)
		{
		iReadPos = anOffset;
		}
	else if (aMark&EWrite)
		{
		iWritePos = anOffset;
		}
		
	return TStreamPos(anOffset);
	}
	
EXPORT_C TInt RIpcBuf::DoReadL(TAny *aPtr, TInt aMaxLength)
	{
	TPtr8 ptr((TUint8*)aPtr, aMaxLength);
	iMessage.ReadL(iMessageSlot, ptr, iReadPos);
	TInt len = ptr.Length();
	iReadPos += len;
	return len;
	}
	
EXPORT_C void RIpcBuf::DoWriteL(const TAny* aPtr,TInt aLength)
	{
	TPtr8 ptr((TUint8*)aPtr, aLength, aLength);
	iMessage.WriteL(iMessageSlot, ptr, iWritePos);
	iWritePos += aLength;
	}