1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/os/persistentdata/persistentstorage/sql/SRC/Server/IPC/IPCStream.cpp	Fri Jun 15 03:10:57 2012 +0200
     1.3 @@ -0,0 +1,103 @@
     1.4 +// Copyright (c) 2005-2010 Nokia Corporation and/or its subsidiary(-ies).
     1.5 +// All rights reserved.
     1.6 +// This component and the accompanying materials are made available
     1.7 +// under the terms of "Eclipse Public License v1.0"
     1.8 +// which accompanies this distribution, and is available
     1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
    1.10 +//
    1.11 +// Initial Contributors:
    1.12 +// Nokia Corporation - initial contribution.
    1.13 +//
    1.14 +// Contributors:
    1.15 +//
    1.16 +// Description:
    1.17 +//
    1.18 +
    1.19 +#include <s32buf.h>
    1.20 +#include "SqlAssert.h"
    1.21 +#include "IPCStream.h"
    1.22 +#include "SqlSrvResourceProfiler.h"
    1.23 +
    1.24 +/**
    1.25 +Reads data from the stream buffer and sends them to the client.
    1.26 +
    1.27 +@param aMessage The client message.
    1.28 +
    1.29 +@return The number of bytes sent.
    1.30 +
    1.31 +Usage of the IPC call arguments:
    1.32 +Arg 0:            not used
    1.33 +Arg 1: [in]       from which position to read
    1.34 +Arg 2: [in/out]   IPC buffer
    1.35 +Arg 3: [in]       max length of the requested data
    1.36 +*/
    1.37 +TInt HIpcStream::ReadL(const RMessage2& aMessage)
    1.38 +	{
    1.39 +	TInt pos=aMessage.Int1();
    1.40 +	if (pos!=iRPos)
    1.41 +		iHost.SeekL(iHost.ERead,EStreamBeginning,pos);
    1.42 +	iRPos=-1;
    1.43 +	TInt len=aMessage.Int3();
    1.44 +	pos+=len;
    1.45 +	TInt tfr=len;
    1.46 +	for (;;)
    1.47 +		{
    1.48 +		TUint8 buf[KIpcStreamSize];
    1.49 +		TInt read=iHost.ReadL(buf,Min(tfr,KIpcStreamSize));
    1.50 +		if (read==0)
    1.51 +			break;
    1.52 +		aMessage.WriteL(2,TPtrC8(buf,read),len-tfr);
    1.53 +		SQLPROFILER_REPORT_IPC(ESqlIpcWrite, read);
    1.54 +		tfr-=read;
    1.55 +		if (tfr==0)
    1.56 +			break;
    1.57 +		if (read<KIpcStreamSize)
    1.58 +			break;
    1.59 +		}
    1.60 +	iRPos=pos-tfr;
    1.61 +	return len-tfr;
    1.62 +	}
    1.63 +
    1.64 +/**
    1.65 +Reads data from the client message and stores the data in the stream buffer.
    1.66 +
    1.67 +@param aMessage The client message.
    1.68 +
    1.69 +@return The number of bytes read and stored in the stream buffer.
    1.70 +
    1.71 +
    1.72 +Usage of the IPC call arguments:
    1.73 +Arg 0:            not used
    1.74 +Arg 1: [in]       from which position to write
    1.75 +Arg 2: [in/out]   IPC buffer
    1.76 +*/
    1.77 +void HIpcStream::WriteL(const RMessage2& aMessage)
    1.78 +	{
    1.79 +	TInt pos=aMessage.Int1();
    1.80 +	if (pos!=iWPos)
    1.81 +		iHost.SeekL(iHost.EWrite,EStreamBeginning,pos);
    1.82 +	iWPos=-1;
    1.83 +	TInt offset=0;
    1.84 +	TBuf8<KIpcStreamSize> buf;
    1.85 +	for (;;)
    1.86 +		{
    1.87 +		aMessage.ReadL(2,buf,offset);
    1.88 +		TInt len=buf.Length();
    1.89 +		SQLPROFILER_REPORT_IPC(ESqlIpcRead, len);
    1.90 +		if (len==0)
    1.91 +			break;
    1.92 +		iHost.WriteL(buf.Ptr(),len);
    1.93 +		offset+=len;
    1.94 +		if (len<KIpcStreamSize)
    1.95 +			break;
    1.96 +		}
    1.97 +	iWPos=pos+offset;
    1.98 +	}
    1.99 +
   1.100 +/**
   1.101 +Destroys HIpcReadBuf object.
   1.102 +*/
   1.103 +void HIpcReadBuf::DoRelease()
   1.104 +	{
   1.105 +	delete this;
   1.106 +	}