sl@0: // Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: inline TSourceOutput::TSourceOutput(MStreamBuf* aSource)
sl@0: 	: iSrc(aSource)
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(aSource!=NULL,Panic(EStreamNotOpen));
sl@0: 	}
sl@0: 
sl@0: inline TFilterInput::TFilterInput(TStreamFilter& aFilter,TAny* aPtr,TInt aMaxLength)
sl@0: 	: iFltr(&aFilter),iPtr((TUint8*)aPtr),iLeft(aMaxLength)
sl@0: 	{}
sl@0: inline TBool TFilterInput::Done() const
sl@0: 	{return iLeft==0;}
sl@0: inline TBool TFilterInput::Eof() const
sl@0: 	{return iPtr==NULL;}
sl@0: inline TInt TFilterInput::Left() const
sl@0: 	{return iLeft;}
sl@0: 
sl@0: inline TFilterOutput::TFilterOutput(TStreamFilter& aFilter,const TAny* aPtr,TInt aLength)
sl@0: 	: iFltr(&aFilter),iFrom((TUint8*)aPtr),iEnd((TUint8*)aPtr+aLength)
sl@0: 	{}
sl@0: inline TBool TFilterOutput::Done() const
sl@0: 	{return iFrom==iEnd;}
sl@0: 
sl@0: inline TUint8* TDelimitedInput8::Ptr() const
sl@0: 	{return iPtr;}
sl@0: inline TInt TDelimitedInput8::Done() const
sl@0: 	{return iLeft==0;}
sl@0: 
sl@0: inline TUint16* TDelimitedInput16::Ptr() const
sl@0: 	{return iPtr;}
sl@0: inline TInt TDelimitedInput16::Done() const
sl@0: 	{return iLeft==0;}
sl@0: 
sl@0: inline TBool TStreamMark::IsTracking(TStreamMark*const& __DEBUG(aRef)) const
sl@0: 	{
sl@0: #if defined (_DEBUG)
sl@0: 	return iPos==KStreamBeginning-1-(TUint(&aRef)>>2);
sl@0: #else
sl@0: 	return IsEmpty();
sl@0: #endif
sl@0: 	}
sl@0: inline void TStreamMark::Track(TStreamMark*const& __DEBUG(aRef))
sl@0: 	{
sl@0: #if defined (_DEBUG)
sl@0: 	iPos=KStreamBeginning-1-(TUint(&aRef)>>2);
sl@0: 	__ASSERT_DEBUG(iPos<KStreamBeginning-1,User::Invariant());
sl@0: #else
sl@0: 	Clear();
sl@0: #endif
sl@0: 	}
sl@0: 
sl@0: inline MStreamBuf& TStreamExchange::BufL() const
sl@0: 	{
sl@0: 	if (iHost==NULL)
sl@0: 		User::Leave(KErrNotReady);
sl@0: 	return *iHost;
sl@0: 	}
sl@0: inline MStreamBuf& TStreamExchange::Buf() const
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(iHost!=NULL,User::Invariant());
sl@0: 	return *iHost;
sl@0: 	}
sl@0: 
sl@0: inline TStreamExchange& RShareBuf::Host() const
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(iHost!=NULL,User::Invariant());
sl@0: 	return *iHost;
sl@0: 	}
sl@0: