// 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:

// domain\src\domaincli.cpp

// 

//

#include <e32base.h>

#include <e32base_private.h>

#include <e32property.h>

#include <domainmember.h>

#include <domainmanager.h>

#include "domainobserver.h"

#include "domainsrv.h"

#define __DM_PANIC(aError) User::Panic(_L("domainCli.cpp"), (-(aError)) | (__LINE__ << 16))

#define __DM_ASSERT(aCond) __ASSERT_DEBUG(aCond,User::Panic(_L("domainCli.cpp; assertion failed"), __LINE__))

TInt RDmDomainSession::Connect(TDmHierarchyId aHierarchyId, TDmDomainId aDomainId, TUint* aKey)

	{

	TInt r = RSessionBase::CreateSession(KDmDomainServerNameLit, KDmDomainServerVersion, 1);

	if (r != KErrNone)

		return r;

	TIpcArgs a( (TInt)aHierarchyId, (TInt)aDomainId );

	r = RSessionBase::SendReceive(EDmDomainJoin, a);

	if (r != KErrNone)

		{

		RSessionBase::Close();

		return r;

		}

	*aKey = DmStatePropertyKey(

		aHierarchyId, 

		aDomainId);

	return KErrNone;

	}

void RDmDomainSession::Acknowledge(TInt aValue, TInt aError)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	TIpcArgs a(aValue, aError);

	TInt r = RSessionBase::SendReceive(EDmStateAcknowledge, a);

	if (r != KErrNone)

		__DM_PANIC(r);

	}

void RDmDomainSession::RequestTransitionNotification()

	{

	__DM_ASSERT(Handle() != KNullHandle);

	TInt r = RSessionBase::SendReceive(EDmStateRequestTransitionNotification);

	if (r != KErrNone)

		__DM_PANIC(r);

	}

void RDmDomainSession::CancelTransitionNotification()

	{

	if (Handle() != KNullHandle)

		{

		TInt r = RSessionBase::SendReceive(EDmStateCancelTransitionNotification);

		if (r != KErrNone)

			__DM_PANIC(r);

		}

	}

/**

Connects to the domain identified by the specified domain Id.

To connect to the root domain, which has the Id KDmIdRoot,

the capability WriteDeviceData is required.

Once connected, an  application can use this RDmDomain object to read

the domain's power state and to request notification

when the power state changes.

@param aDomainId The identifier of the domain to be connected to.

@return KErrNone, if successful; otherwise one of the other system-wide

        or domain manager specific error codes.

@capability WriteDeviceData If aDomainId==KDmIdRoot

*/

EXPORT_C TInt RDmDomain::Connect(TDmDomainId aDomainId)

	{

	TUint key;

	TInt r = iSession.Connect(KDmHierarchyIdPower, aDomainId, &key);

	if (r != KErrNone)

		return r;

	r = iStateProperty.Attach(KUidDmPropertyCategory, key);

	if (r != KErrNone)

		{

		iSession.Close();

		return r;

		}

	return KErrNone;

	}

/**

Connects to the domain identified by the specified domain Id.

To connect to the root domain, which has the Id KDmIdRoot,

the capability WriteDeviceData is required.

Once connected, an  application can use this RDmDomain object to read

the domain's state and to request notification

when the state changes.

@param aHierarchyId	The Id of the domain hierarchy to connect to.

@param aDomainId    The identifier of the domain to be connected to.

@return KErrNone, if successful; otherwise one of the other system-wide

        or domain manager specific error codes.

@capability WriteDeviceData If aDomainId==KDmIdRoot

*/

EXPORT_C TInt RDmDomain::Connect(TDmHierarchyId aHierarchyId, TDmDomainId aDomainId)

	{

	TUint key;

	TInt r = iSession.Connect(aHierarchyId, aDomainId, &key);

	if (r != KErrNone)

		return r;

	r = iStateProperty.Attach(KUidDmPropertyCategory, key);

	if (r != KErrNone)

		{

		iSession.Close();

		return r;

		}

	return KErrNone;

	}

/**

Disconnects from the associated domain.

If this object is not connected to any domain, then it returns silently.

*/

EXPORT_C void RDmDomain::Close()

	{

	iSession.Close();

	iStateProperty.Close();

	}

/**

Requests notification when the domain's state changes.

This is an asynchronous request that completes when

the domain's state changes.

@param aStatus The request status object for this asynchronous request.

@see RDmDomain::CancelTransitionNotification()

*/

EXPORT_C void RDmDomain::RequestTransitionNotification(TRequestStatus& aStatus)

	{

	iStateProperty.Subscribe(aStatus);

	iSession.RequestTransitionNotification();

	}

/**

Cancels an outstanding notification request.

Any outstanding notification request completes with KErrCancel.

*/

EXPORT_C void RDmDomain::CancelTransitionNotification()

	{

	iSession.CancelTransitionNotification();

	iStateProperty.Cancel();

	}

/**

Gets the domain's power state.

An application normally calls this function after a notification request

has completed. It then performs any application-dependent action demanded by

the power state, and then acknowledges the state transition.

Note that the domain manager requires any domain power state change to be

acknowledged by all applications connected to the domain.

@return The connected domain's power state.

@see RDmDomain::AcknowledgeLastState()

*/

EXPORT_C TPowerState RDmDomain::GetPowerState()

	{

	TInt value;

	TInt r = iStateProperty.Get(value);

	if (r != KErrNone)

		__DM_PANIC(r);

	iLastStatePropertyValue = value;

	return (TPowerState) DmStateFromPropertyValue(value);

	}

/**

Acknowledges the state change.

An application must acknowledge that it has performed all actions required

by the last known state of the domain.

*/

EXPORT_C void RDmDomain::AcknowledgeLastState()

	{

	iSession.Acknowledge(iLastStatePropertyValue, KErrNone);

	}

/**

Acknowledges the state change with the specified error

An application must acknowledge that it has performed all actions required

by the last known state of the domain.

@param aError KDmErrNotJoin if domain is not part of the hierarhcy or a 

	system wide error value associated with the state change.

*/

EXPORT_C void RDmDomain::AcknowledgeLastState(TInt aError)

	{

	iSession.Acknowledge(iLastStatePropertyValue, aError);

	}

/**

Gets the domain's state.

An application normally calls this function after a notification request

has completed. It then performs any application-dependent action demanded by

the state, and then acknowledges the state transition.

Note, that the domain manager requires any domain state change to be

acknowledged by all applications connected to the domain.

@return The connected domain's state.

*/

EXPORT_C TDmDomainState RDmDomain::GetState()

	{

	TInt value;

	TInt r = iStateProperty.Get(value);

	if (r != KErrNone)

		__DM_PANIC(r);

	iLastStatePropertyValue = value;

	return DmStateFromPropertyValue(value);

	}

TInt RDmManagerSession::Connect()

	{

	__DM_ASSERT(Handle() == KNullHandle);

	return RSessionBase::CreateSession(

				KDmManagerServerNameLit, 

				KDmManagerServerVersion, 

				2);

	}

TInt RDmManagerSession::ConnectObserver(TDmHierarchyId aHierarchyId)

	{

	TInt r = Connect();

	if (r != KErrNone)

		return r;

	TIpcArgs a( (TInt)aHierarchyId);

	r = RSessionBase::SendReceive(EDmObserverJoin, a);

	if (r != KErrNone)

		{

		RSessionBase::Close();

		return r;

		}

	return KErrNone;

	}

TInt RDmManagerSession::Connect(TDmHierarchyId aHierarchyId)

	{

	TInt r = Connect();

	if (r != KErrNone)

		return r;

	TIpcArgs a( (TInt)aHierarchyId);

	r = RSessionBase::SendReceive(EDmHierarchyJoin, a);

	if (r != KErrNone)

		{

		RSessionBase::Close();

		return r;

		}

	return KErrNone;

	}

void RDmManagerSession::RequestDomainTransition(

	TDmDomainId aDomainId, 

	TDmDomainState aState,

	TDmTraverseDirection aDirection,

	TRequestStatus& aStatus)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	if(aDirection < 0 || aDirection > ETraverseMax)

		__DM_PANIC(KErrArgument);

	TIpcArgs a(aDomainId, aState, aDirection);

	RSessionBase::SendReceive(EDmRequestDomainTransition, a, aStatus);

	}

void RDmManagerSession::CancelTransition()

	{

	if (Handle() != KNullHandle)

		{

		TInt r = RSessionBase::SendReceive(EDmCancelTransition);

		if (r != KErrNone)

			__DM_PANIC(r);

		}

	}

void RDmManagerSession::CancelObserver()

	{

	if (Handle() != KNullHandle)

		{

		TInt r = RSessionBase::SendReceive(EDmObserverCancel);

		if (r != KErrNone)

			__DM_PANIC(r);

		}

	}

void RDmManagerSession::RequestSystemTransition(

	TDmDomainState aState,

	TDmTraverseDirection aDirection,

	TRequestStatus& aStatus)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	TIpcArgs a(aState, aDirection);

	RSessionBase::SendReceive(EDmRequestSystemTransition, a, aStatus);

	}

TInt RDmManagerSession::AddDomainHierarchy(TDmHierarchyId aHierarchyId)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	TIpcArgs a( (TInt)aHierarchyId);

	TInt r = RSessionBase::SendReceive(EDmHierarchyAdd, a);

	return r;

	}

TInt RDmManagerSession::GetTransitionFailureCount()

	{

	__DM_ASSERT(Handle() != KNullHandle);

	return RSessionBase::SendReceive(EDmGetTransitionFailureCount);

	}

TInt RDmManagerSession::GetTransitionFailures(RArray<const TTransitionFailure>& aTransitionFailures)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	aTransitionFailures.Reset();

	TInt err = KErrNone;

	TInt failureCount = GetTransitionFailureCount();

	if (failureCount <= 0)

		return failureCount;

	TTransitionFailure* failures = new TTransitionFailure[failureCount];

	if(failures == NULL)

		return(KErrNoMemory);

	TPtr8 dataPtr(reinterpret_cast<TUint8*>(failures), failureCount * sizeof(TTransitionFailure));

	TIpcArgs a(&dataPtr);

	err = RSessionBase::SendReceive(EDmGetTransitionFailures, a);

	if (err == KErrNone)

		{

		}

	delete [] failures;

	return err;

	}

TInt RDmManagerSession::StartObserver(TDmDomainId aDomainId, TDmNotifyType aNotifyType)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	TIpcArgs a(aDomainId,aNotifyType);

	return(RSessionBase::SendReceive(EDmObserverStart,a));

	}

void RDmManagerSession::GetNotification(TRequestStatus& aStatus)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	RSessionBase::SendReceive(EDmObserverNotify,aStatus);

	}

TInt RDmManagerSession::GetEventCount()

	{

	__DM_ASSERT(Handle() != KNullHandle);

	return(RSessionBase::SendReceive(EDmObserverEventCount));

	}

TInt RDmManagerSession::GetEvents(RArray<const TTransInfo>& aTransitions)

	{

	__DM_ASSERT(Handle() != KNullHandle);

	aTransitions.Reset();

	TInt count = GetEventCount();

	// This shouldn't happen unless something gone terribly wrong

	if (count <= 0)

		return KErrGeneral;

	TTransInfo* trans = new TTransInfo[count];

	if(trans == NULL)

		return(KErrNoMemory);

	TPtr8 dataPtr(reinterpret_cast<TUint8*>(trans), count * sizeof(TTransInfo));

	TIpcArgs a(&dataPtr);

	if(ret==KErrNone)

		{

		for (TInt i=0; i<count; i++)

		}

	delete [] trans;

	return ret;

	}

TInt RDmManagerSession::ObserverDomainCount()

	{

	__DM_ASSERT(Handle() != KNullHandle);

	return(RSessionBase::SendReceive(EDmObserveredCount));

	}

/**

@internalAll

@released

*/

EXPORT_C TInt RDmDomainManager::WaitForInitialization()

	{

	RProperty prop;

	TInt r = prop.Attach(KUidDmPropertyCategory, KDmPropertyKeyInit);

	if (r != KErrNone)

		return r;

#ifdef _DEBUG

	TInt count = RThread().RequestCount();

#endif

	TRequestStatus status;

	for (;;)

		{

		prop.Subscribe(status);

		TInt value;

		r = prop.Get(value);

		if (r == KErrNone)

			{

			if (value) break; // initialized