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: #include "SD_STD.H"
sl@0: 
sl@0: GLDEF_C void Panic(TDbsPanic aPanic)
sl@0: //
sl@0: // Panic the client
sl@0: //
sl@0: 	{
sl@0: 	_LIT(KCategory,"DBMS-server");
sl@0: 	Dbms::Panic(KCategory,aPanic);
sl@0: 	}
sl@0: 
sl@0: // Class Dbms
sl@0: 
sl@0: EXPORT_C void Dbms::Panic(const TDesC& aCategory,TInt aCode)
sl@0: //
sl@0: // Panic the client
sl@0: // Outside of the server this calls User::Panic, within it calls the server and LEAVES!
sl@0: //
sl@0: 	{
sl@0: 	__TRACE(aCategory);
sl@0: 	__TRACE(aCode);
sl@0: 	CDbsServer* server=CDbsServer::Instance();
sl@0: 	if (server)
sl@0: 		{
sl@0: 		server->Panic(aCategory,aCode);
sl@0: 		__LEAVE(KDbsLeavePanic);
sl@0: 		}
sl@0: 	else
sl@0: 		User::Panic(aCategory,aCode);
sl@0: 	}
sl@0: 
sl@0: // streaming functions
sl@0: 
sl@0: GLDEF_C void ExternalizeL(const TDbCol& aCol,RWriteStream& aStream)
sl@0: 	{
sl@0: 	aStream<<aCol.iName<<TUint8(aCol.iType)<<TInt32(aCol.iMaxLength)<<TUint8(aCol.iAttributes);
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void ExternalizeL(const CDbColSet& aColSet,RWriteStream& aStream)
sl@0: 	{
sl@0: 	TInt cc=aColSet.Count();
sl@0: 	aStream.WriteInt32L(cc);
sl@0: 	for (TInt ii=0;++ii<=cc;)
sl@0: 		aStream<<aColSet[ii];
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void InternalizeL(CDbColSet& aColSet,RReadStream& aStream)
sl@0: 	{
sl@0: 	__ASSERT(aColSet.Count()==0);
sl@0: 	TDbCol col;
sl@0: 	TPtr name(col.iName.Des());
sl@0: 	TInt cc=aStream.ReadInt32L();
sl@0: 	while (--cc>=0)
sl@0: 		{
sl@0: 		aStream>>name;
sl@0: 		col.iType=TDbColType(aStream.ReadUint8L());
sl@0: 		col.iMaxLength=aStream.ReadInt32L();
sl@0: 		col.iAttributes=aStream.ReadUint8L();
sl@0: 		aColSet.AddL(col);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void ExternalizeL(const CDbKey& aKey,RWriteStream& aStream)
sl@0: 	{
sl@0: 	TInt cc=aKey.Count();
sl@0: 	aStream.WriteInt32L(cc);
sl@0: 	for (TInt ii=0;ii<cc;++ii)
sl@0: 		{
sl@0: 		const TDbKeyCol& col=aKey[ii];
sl@0: 		aStream<<col.iName<<TUint8(col.iOrder)<<TInt32(col.iLength);
sl@0: 		}
sl@0: 	aStream<<TUint8(aKey.Comparison())<<TUint8(aKey.IsUnique());
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void InternalizeL(CDbKey& aKey,RReadStream& aStream)
sl@0: 	{
sl@0: 	__ASSERT(aKey.Count()==0);
sl@0: 	TDbKeyCol col;
sl@0: 	TPtr name(col.iName.Des());
sl@0: 	TInt cc=aStream.ReadInt32L();
sl@0: 	while (--cc>=0)
sl@0: 		{
sl@0: 		aStream>>name;
sl@0: 		TUint8 uInt = aStream.ReadUint8L();
sl@0: 		col.iOrder=TDbKeyCol::TOrder(uInt);
sl@0: 		col.iLength=aStream.ReadInt32L();
sl@0: 		aKey.AddL(col);
sl@0: 		}
sl@0: 	aKey.SetComparison(TDbTextComparison(aStream.ReadUint8L()));
sl@0: 	if (aStream.ReadUint8L())
sl@0: 		aKey.MakeUnique();
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void ExternalizeL(const CDbNames& aNames,RWriteStream& aStream)
sl@0: 	{
sl@0: 	TInt cc=aNames.Count();
sl@0: 	aStream.WriteInt32L(cc);
sl@0: 	for (TInt ii=0;ii<cc;++ii)
sl@0: 		aStream<<aNames[ii];
sl@0: 	}
sl@0: 
sl@0: GLDEF_C void InternalizeL(CDbNames& aNames,RReadStream& aStream)
sl@0: 	{
sl@0: 	__ASSERT(aNames.Count()==0);
sl@0: 	TDbName name;
sl@0: 	TInt cc=aStream.ReadInt32L();
sl@0: 	while (--cc>=0)
sl@0: 		{
sl@0: 		aStream>>name;
sl@0: 		aNames.AddL(name);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: A helper function, used in
sl@0: "RWriteStream& operator<<(RWriteStream& aStream,const CDbStrings& aStrings)".
sl@0: @internalComponent
sl@0: */
sl@0: GLDEF_C void ExternalizeL(const CDbStrings& aStrings,RWriteStream& aStream)
sl@0: 	{
sl@0: 	TInt cc=aStrings.Count();
sl@0: 	aStream.WriteInt32L(cc);
sl@0: 	for (TInt ii=0;ii<cc;++ii)
sl@0: 		aStream<<aStrings[ii];
sl@0: 	}
sl@0: 
sl@0: /** 
sl@0: Represents a generic read/write DBMS string. It maps to a modifiable buffer descriptor 
sl@0: with maximum size KDbMaxStrLen.
sl@0: 
sl@0: @see TBuf 
sl@0: @internalComponent
sl@0: */
sl@0: typedef TBuf<KDbMaxStrLen> TDbString;
sl@0: 
sl@0: /**
sl@0: A helper function, used in
sl@0: "RReadStream& operator>>(RReadStream& aStream,CDbStrings& aStrings)".
sl@0: @internalComponent
sl@0: */
sl@0: GLDEF_C void InternalizeL(CDbStrings& aStrings,RReadStream& aStream)
sl@0: 	{
sl@0: 	__ASSERT(aStrings.Count()==0);
sl@0: 	TDbString str;
sl@0: 	TInt cc=aStream.ReadInt32L();
sl@0: 	while (--cc>=0)
sl@0: 		{
sl@0: 		aStream>>str;
sl@0: 		aStrings.AddL(str);
sl@0: 		}
sl@0: 	}