// Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the License "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 "t_prop_ldd.h"
#include <kernel/kernel.h>
#include "nk_priv.h"

class DPropLDevice : public DLogicalDevice
	{
public:
	DPropLDevice();
	virtual TInt Install();
	virtual void GetCaps(TDes8& aDes) const;
	virtual TInt Create(DLogicalChannelBase*& aChannel);
	};

class DPropLChannel : public DLogicalChannelBase
	{
public:
	DPropLChannel();
	~DPropLChannel();

	virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);
	virtual TInt Request(TInt aFunction, TAny* a1, TAny* a2);

private:
	TInt Basic(RPropChannel::TBasicInfo* aInfo);

	static void CompleteFn(TAny* aPtr, TInt aReason);
	TInt iReason;
	NFastSemaphore iSem;

	};

DECLARE_STANDARD_LDD()
//
// Create a new device
//
	{
	return new DPropLDevice;
	}

DPropLDevice::DPropLDevice()
//
// Constructor
//
	{
	//iUnitsMask=0;
	iVersion = TVersion(1,0,1);
	// iParseMask = 0;
	}

TInt DPropLDevice::Install()
//
// Install the device driver.
//
	{
	TInt r = SetName(&KPropLdName);
	return r;
	}

void DPropLDevice::GetCaps(TDes8&) const
//
// Return the Comm capabilities.
//
	{
	}

TInt DPropLDevice::Create(DLogicalChannelBase*& aChannel)
//
// Create a channel on the device.
//
	{
	aChannel = new DPropLChannel;
	return aChannel ? KErrNone : KErrNoMemory;
	}

DPropLChannel::DPropLChannel() 
	{
	NKern::FSSetOwner(&iSem, NKern::CurrentThread());
	}

TInt DPropLChannel::DoCreate(TInt /*aUnit*/, const TDesC8* /* aInfo*/ , const TVersion& aVer)
//
// Create the channel from the passed info.
//
	{
	if (!Kern::QueryVersionSupported(TVersion(1,0,1),aVer))
		return KErrNotSupported;
	return KErrNone;
	}

DPropLChannel::~DPropLChannel()
	{
	}


#define BASIC_ERROR(aRes, aCond) \
	{\
	if (!(aCond)) \
		{ \
		Kern::Printf("Test '" #aCond "' fails; r = %d;\n\tfile '" __FILE__ "'; line %d;\n", aRes, __LINE__); \
		prop.Close(); \
		return EFalse; \
		} \
	}

void DPropLChannel::CompleteFn(TAny* aPtr, TInt aReason)
	{ // static
	DPropLChannel* self = (DPropLChannel*) aPtr;
	self->iReason = aReason;
	NKern::FSSignal(&self->iSem);
	}

TBool DPropLChannel::Basic(RPropChannel::TBasicInfo* aInfo)
	{

	TUid category = aInfo->iCategory;
	TUint key = aInfo->iKey;
	TUint count = aInfo->iCount;
	RProperty::TType type = aInfo->iType;

	for (TUint i = 0; i < count; ++i)
		{
		RPropertyRef prop;
		TInt r = prop.Open(category, key);
		BASIC_ERROR(r, r == KErrNotFound);
		r = prop.Attach(category, key);
		BASIC_ERROR(r, r == KErrNone);

		//	Defines the attributes and access control for a property. This can only be done 
		//	once for each property. Subsequent attempts to define the same property will return
		//	KErrAlreadyExists.

		TSecurityPolicy policy;

		r = prop.Define(type, policy, policy);
		BASIC_ERROR(r, r == KErrNone);
		r = prop.Define(type, policy, policy);
		BASIC_ERROR(r, r == KErrAlreadyExists);
		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);

		// Define fails with KErrArgument if wrong type or attribute was specified.
		r = prop.Define(RProperty::ETypeLimit, policy, policy);
		BASIC_ERROR(r, r == KErrArgument);

		static _LIT_SECURITY_POLICY_PASS(KPassPolicy);
		TSecurityPolicy badPolicy;
		*(TInt*)&badPolicy = -1;

		r = prop.Define(type, badPolicy, policy);
		BASIC_ERROR(r, r == KErrArgument);
		r = prop.Define(type, KPassPolicy, badPolicy);
		BASIC_ERROR(r, r == KErrArgument);
	
		if (type == RProperty::EInt)
			{
			// Define fails with KErrArgument if aType is TInt and aPreallocate is not 0
			r = prop.Define(type, KPassPolicy, KPassPolicy, 16);
			BASIC_ERROR(r, r == KErrArgument);

			// Following defintion the property has a default value, 0 for integer properties
			r = prop.Define(RProperty::EInt, KPassPolicy, KPassPolicy);
			BASIC_ERROR(r, r == KErrNone);
			TInt value;
			r = prop.Get(value);
			BASIC_ERROR(r, r == KErrNone);
			BASIC_ERROR(value, value == 0);
			r = prop.Delete();
			BASIC_ERROR(r, r == KErrNone);
			}
		else 
			{
			// Defne fails with KErrTooBig if aPeallocate is grater than KMaxPropertySize.
			r = prop.Define(RProperty::EByteArray, KPassPolicy, KPassPolicy, RProperty::KMaxPropertySize);
			BASIC_ERROR(r, r == KErrNone);
			r = prop.Delete();
			BASIC_ERROR(r, r == KErrNone);
			r = prop.Define(RProperty::EByteArray, KPassPolicy, KPassPolicy, RProperty::KMaxPropertySize+1);
			BASIC_ERROR(r, r == KErrTooBig);

			// Following defintion the property has a default value, zero-length data for byte-array and text 
			// properties. 
			r = prop.Define(RProperty::EByteArray, KPassPolicy, KPassPolicy);
			BASIC_ERROR(r, r == KErrNone);
			TBuf8<16> buf;
			r = prop.Get(buf);
			BASIC_ERROR(r, r == KErrNone);
			BASIC_ERROR(buf.Size(), buf.Size() == 0);
			r = prop.Delete();
			BASIC_ERROR(r, r == KErrNone);
			}

		// Pending subscriptions for this property will not be completed until a new value is published.
		TPropertySubsRequest subs(CompleteFn, this);
		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		r = prop.Define(type, KPassPolicy, KPassPolicy);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrNotFound);

		// If the property has not been defined Delete() fails with KErrNotFound.
		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNotFound);

		// When deleted any pending subscriptions for the property will be completed with KErrNotFound.
		r = prop.Define(type, KPassPolicy, KPassPolicy);
		BASIC_ERROR(r, r == KErrNone);
		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrNotFound);

		// Any new request will not complete until the property is defined and published again.
		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		r = prop.Define(type, KPassPolicy, KPassPolicy);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		if (type == RProperty::EInt)
			{
			r = prop.Set(1);
			BASIC_ERROR(r, r == KErrNone);
			}
		else
			{
			TBuf8<16> buf((TUint8*) "Foo");
			r = prop.Set(buf);
			BASIC_ERROR(r, r == KErrNone);
			}
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrNone);
		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);

		// If the property has not been defined Set()/Get() fail with KErrNotFound.
			{
			TInt value;
			TBuf8<16> buf;
			if (type == RProperty::EInt)
				{
				r = prop.Get(value);
				BASIC_ERROR(r, r == KErrNotFound);
				r = prop.Set(value);
				BASIC_ERROR(r, r == KErrNotFound);
				}
			else
				{
				r = prop.Get(buf);
				BASIC_ERROR(r, r == KErrNotFound);
				r = prop.Set(buf);
				BASIC_ERROR(r, r == KErrNotFound);
				}
			}

		r = prop.Define(type, KPassPolicy, KPassPolicy);
		BASIC_ERROR(r, r == KErrNone);

		// If the property is larger than KMaxPropertySize Set() fails with KErrTooBig
			{
			if (type ==  RProperty::EByteArray)
				{
				TBuf8<RProperty::KMaxPropertySize + 1> buf(RProperty::KMaxPropertySize + 1);
				r = prop.Set(buf);
				BASIC_ERROR(r, r == KErrTooBig);
				}
			}

		// When type of operation mismatch with the property type Set()/Get() fails with KErrArgument.
			{
			if (type !=  RProperty::EInt)
				{
				TInt value;
				r = prop.Get(value);
				BASIC_ERROR(r, r == KErrArgument);
				r = prop.Set(value);
				BASIC_ERROR(r, r == KErrArgument);
				}
			else
				{
				TBuf8<16> buf;
				r = prop.Get(buf);
				BASIC_ERROR(r, r == KErrArgument);
				r = prop.Set(buf);
				BASIC_ERROR(r, r == KErrArgument);
				}
			}

		// Get/Set
		if (type == RProperty::EInt)
			{
			r = prop.Set(1);
			BASIC_ERROR(r, r == KErrNone);
			TInt value = 0;
			r = prop.Get(value);
			BASIC_ERROR(r, r == KErrNone);
			BASIC_ERROR(value, value == 1);
			}
		else 
			{
			TBuf8<16> ibuf((TUint8*)"Foo");
			TBuf8<16> obuf;
			r = prop.Set(ibuf);
			BASIC_ERROR(r, r == KErrNone);
			r = prop.Get(obuf);
			BASIC_ERROR(r, r == KErrNone);
			r = obuf.Compare(ibuf);
			BASIC_ERROR(r, r == 0);
			}

		// If the supplied buffer is too small Get() fails with KErrOverflow and the truncated value is reported.
		if (type == RProperty::EByteArray)
			{
			TBuf8<16> ibuf((TUint8*) "0123456789012345");
			TBuf8<16> obuf((TUint8*) "abcdefghigklmnop");
			TPtr8 optr((TUint8*) obuf.Ptr(), 0, 15);
			r = prop.Set(ibuf);
			BASIC_ERROR(r, r == KErrNone);
			r = prop.Get(optr);
			BASIC_ERROR(r, r == KErrOverflow);
			BASIC_ERROR(optr.Length(), optr.Length() == 15); 
			BASIC_ERROR(obuf[14], obuf[14] == '4'); 
			BASIC_ERROR(obuf[15], obuf[15] == 'p');
			}

		// The calling thread will have the specified request status signalled when the property is next updated.
		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		if (type == RProperty::EInt)
			{
			r = prop.Set(1);
			BASIC_ERROR(r, r == KErrNone);
			}
		else
			{
			TBuf8<16> buf((TUint8*) "Foo");
			r = prop.Set(buf);
			BASIC_ERROR(r, r == KErrNone);
			}
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrNone);

		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);

		// Cancel an outstanding subscription request.
		// If it has not already completed, the request is completed with KErrCancelled.
		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		prop.Cancel(subs);		
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrCancel);

		r = prop.Define(type, KPassPolicy, KPassPolicy);
		BASIC_ERROR(r, r == KErrNone);

		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		if (type == RProperty::EInt)
			{
			r = prop.Set(1);
			BASIC_ERROR(r, r == KErrNone);
			}
		else
			{
			TBuf8<16> buf((TUint8*) "Foo");
			r = prop.Set(buf);
			BASIC_ERROR(r, r == KErrNone);
			}
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrNone);
		prop.Cancel(subs);		
		BASIC_ERROR(iReason, iReason == KErrNone);

		iReason = KRequestPending;
		r = prop.Subscribe(subs);
		BASIC_ERROR(r, r == KErrNone);
		BASIC_ERROR(iReason, iReason == KRequestPending);
		prop.Cancel(subs);		
		NKern::FSWait(&iSem);
		BASIC_ERROR(iReason, iReason == KErrCancel);

		r = prop.Delete();
		BASIC_ERROR(r, r == KErrNone);

		prop.Close();
		}
	return ETrue;
	}

//
// Client requests.
//
TBool DPropLChannel::Request(TInt aFunction, TAny* a1, TAny*)
	{
	TBool r;
	switch (aFunction)
		{
		case RPropChannel::EBasicTests:
			RPropChannel::TBasicInfo info;
			kumemget32(&info, a1, sizeof(info));
			NKern::ThreadEnterCS();
			r = Basic(&info);
			NKern::ThreadLeaveCS();
			break;	
		default:
			r = EFalse;
			break;
		}
	return r;
	}