// Copyright (c) 2005-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:
//

#include <s32buf.h>
#include "SqlPanic.h"
#include "IPCStream.h"
#include "SqlSrvResourceProfiler.h"

/**
Reads data from the stream buffer and sends them to the client.

@param aMessage The client message.

@return The number of bytes sent.

Usage of the IPC call arguments:
Arg 0:            not used
Arg 1: [in]       from which position to read
Arg 2: [in/out]   IPC buffer
Arg 3: [in]       max length of the requested data
*/
TInt HIpcStream::ReadL(const RMessage2& aMessage)
	{
	TInt pos=aMessage.Int1();
	if (pos!=iRPos)
		iHost.SeekL(iHost.ERead,EStreamBeginning,pos);
	iRPos=-1;
	TInt len=aMessage.Int3();
	pos+=len;
	TInt tfr=len;
	for (;;)
		{
		TUint8 buf[KIpcStreamSize];
		TInt read=iHost.ReadL(buf,Min(tfr,KIpcStreamSize));
		if (read==0)
			break;
		aMessage.WriteL(2,TPtrC8(buf,read),len-tfr);
		SQLPROFILER_REPORT_IPC(ESqlIpcWrite, read);
		tfr-=read;
		if (tfr==0)
			break;
		if (read<KIpcStreamSize)
			break;
		}
	iRPos=pos-tfr;
	return len-tfr;
	}

/**
Reads data from the client message and stores the data in the stream buffer.

@param aMessage The client message.

@return The number of bytes read and stored in the stream buffer.


Usage of the IPC call arguments:
Arg 0:            not used
Arg 1: [in]       from which position to write
Arg 2: [in/out]   IPC buffer
*/
void HIpcStream::WriteL(const RMessage2& aMessage)
	{
	TInt pos=aMessage.Int1();
	if (pos!=iWPos)
		iHost.SeekL(iHost.EWrite,EStreamBeginning,pos);
	iWPos=-1;
	TInt offset=0;
	TBuf8<KIpcStreamSize> buf;
	for (;;)
		{
		aMessage.ReadL(2,buf,offset);
		TInt len=buf.Length();
		SQLPROFILER_REPORT_IPC(ESqlIpcRead, len);
		if (len==0)
			break;
		iHost.WriteL(buf.Ptr(),len);
		offset+=len;
		if (len<KIpcStreamSize)
			break;
		}
	iWPos=pos+offset;
	}

/**
Destroys HIpcReadBuf object.
*/
void HIpcReadBuf::DoRelease()
	{
	delete this;
	}