// Copyright (c) 1998-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 "SD_STD.H"

GLDEF_C void Panic(TDbsPanic aPanic)

//

// Panic the client

//

	{

	_LIT(KCategory,"DBMS-server");

	Dbms::Panic(KCategory,aPanic);

	}

// Class Dbms

EXPORT_C void Dbms::Panic(const TDesC& aCategory,TInt aCode)

//

// Panic the client

// Outside of the server this calls User::Panic, within it calls the server and LEAVES!

//

	{

	__TRACE(aCategory);

	__TRACE(aCode);

	CDbsServer* server=CDbsServer::Instance();

	if (server)

		{

		server->Panic(aCategory,aCode);

		__LEAVE(KDbsLeavePanic);

		}

	else

		User::Panic(aCategory,aCode);

	}

// streaming functions

GLDEF_C void ExternalizeL(const TDbCol& aCol,RWriteStream& aStream)

	{

	aStream<<aCol.iName<<TUint8(aCol.iType)<<TInt32(aCol.iMaxLength)<<TUint8(aCol.iAttributes);

	}

GLDEF_C void ExternalizeL(const CDbColSet& aColSet,RWriteStream& aStream)

	{

	TInt cc=aColSet.Count();

	aStream.WriteInt32L(cc);

	for (TInt ii=0;++ii<=cc;)

		aStream<<aColSet[ii];

	}

GLDEF_C void InternalizeL(CDbColSet& aColSet,RReadStream& aStream)

	{

	__ASSERT(aColSet.Count()==0);

	TDbCol col;

	TPtr name(col.iName.Des());

	TInt cc=aStream.ReadInt32L();

	while (--cc>=0)

		{

		aStream>>name;

		col.iType=TDbColType(aStream.ReadUint8L());

		col.iMaxLength=aStream.ReadInt32L();

		col.iAttributes=aStream.ReadUint8L();

		aColSet.AddL(col);

		}

	}

GLDEF_C void ExternalizeL(const CDbKey& aKey,RWriteStream& aStream)

	{

	TInt cc=aKey.Count();

	aStream.WriteInt32L(cc);

	for (TInt ii=0;ii<cc;++ii)

		{

		const TDbKeyCol& col=aKey[ii];

		aStream<<col.iName<<TUint8(col.iOrder)<<TInt32(col.iLength);

		}

	aStream<<TUint8(aKey.Comparison())<<TUint8(aKey.IsUnique());

	}

GLDEF_C void InternalizeL(CDbKey& aKey,RReadStream& aStream)

	{

	__ASSERT(aKey.Count()==0);

	TDbKeyCol col;

	TPtr name(col.iName.Des());

	TInt cc=aStream.ReadInt32L();

	while (--cc>=0)

		{

		aStream>>name;

		TUint8 uInt = aStream.ReadUint8L();

		col.iOrder=TDbKeyCol::TOrder(uInt);

		col.iLength=aStream.ReadInt32L();

		aKey.AddL(col);

		}

	aKey.SetComparison(TDbTextComparison(aStream.ReadUint8L()));

	if (aStream.ReadUint8L())

		aKey.MakeUnique();

	}

GLDEF_C void ExternalizeL(const CDbNames& aNames,RWriteStream& aStream)

	{

	TInt cc=aNames.Count();

	aStream.WriteInt32L(cc);

	for (TInt ii=0;ii<cc;++ii)

		aStream<<aNames[ii];

	}

GLDEF_C void InternalizeL(CDbNames& aNames,RReadStream& aStream)

	{

	__ASSERT(aNames.Count()==0);

	TDbName name;

	TInt cc=aStream.ReadInt32L();

	while (--cc>=0)

		{

		aStream>>name;

		aNames.AddL(name);

		}

	}

/**

A helper function, used in

"RWriteStream& operator<<(RWriteStream& aStream,const CDbStrings& aStrings)".

@internalComponent

*/

GLDEF_C void ExternalizeL(const CDbStrings& aStrings,RWriteStream& aStream)

	{

	TInt cc=aStrings.Count();

	aStream.WriteInt32L(cc);

	for (TInt ii=0;ii<cc;++ii)

		aStream<<aStrings[ii];

	}

/** 

Represents a generic read/write DBMS string. It maps to a modifiable buffer descriptor 

with maximum size KDbMaxStrLen.

@see TBuf 

@internalComponent

*/

typedef TBuf<KDbMaxStrLen> TDbString;

/**

A helper function, used in

"RReadStream& operator>>(RReadStream& aStream,CDbStrings& aStrings)".

@internalComponent

*/

GLDEF_C void InternalizeL(CDbStrings& aStrings,RReadStream& aStream)

	{

	__ASSERT(aStrings.Count()==0);

	TDbString str;

	TInt cc=aStream.ReadInt32L();

	while (--cc>=0)

		{

		aStream>>str;

		aStrings.AddL(str);

		}

	}