// Copyright (c) 2008-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 <bluetooth/logger.h>

#include "pancoexistenceconnectioncontroller.h"
#include "panagtutils.h"

#ifdef __FLOG_ACTIVE
_LIT8(KLogComponent, LOG_COMPONENT_PAN_AGENT);
#endif

// This is the identifer of the shared mutex used to allow safe read / write of the coexistence P&S key.
// This can only be changed if all other existing definitions of the mutex name are also changed.
_LIT(KIPBearerCoexistenceMutex, "IPBearerCoexistenceMutex");

using namespace PanAgent;

CPanCoexistenceConnectionController* CPanCoexistenceConnectionController::NewL(MPanCoexistenceConnectionObserver& aObserver)
	{
	CPanCoexistenceConnectionController* self = new(ELeave) CPanCoexistenceConnectionController(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CPanCoexistenceConnectionController::CPanCoexistenceConnectionController(MPanCoexistenceConnectionObserver& aObserver)
	: CActive(EPriorityStandard),iPanCoexistenceConnectionObserver(aObserver) 
	{
	CActiveScheduler::Add(this);
	}

CPanCoexistenceConnectionController::~CPanCoexistenceConnectionController()
	{
	Cancel();
	iProperty.Close();
	iMutex.Close();
	}

void CPanCoexistenceConnectionController::ConstructL()
	{
	LOG_FUNC
	
	// Creates a global mutex and open a handle to the mutex.
	// (Note if CreateGlobal returns wirh KErrNone then the mutex is also opened).  
	TInt err = iMutex.CreateGlobal(KIPBearerCoexistenceMutex);
	if (err==KErrAlreadyExists)
		{
		err=iMutex.OpenGlobal(KIPBearerCoexistenceMutex);
		}
    
    User::LeaveIfError(err);

	// Define property
    err = DefineProperty();

	if(err != KErrNone && err != KErrAlreadyExists)
		{
		User::Leave(err);
		}
	
	// Attach to the property
	TSecureId thisSID = RProcess().SecureId();
	User::LeaveIfError(iProperty.Attach(thisSID, KIPBearerCoexistenceProperty));
	
	SubscribeToProperty();
	}

//Define the P&S key
TInt CPanCoexistenceConnectionController::DefineProperty()
	{
	TInt err;
	_LIT_SECURITY_POLICY_PASS(KPassPolicy);
	_LIT_SECURITY_POLICY_C1(KNetworkControl, ECapabilityNetworkControl); 

	err=iProperty.Define(KIPBearerCoexistenceProperty,
						 RProperty::EInt,
						 KPassPolicy,	    //	Read policy
						 KNetworkControl);	//	Write policy
	return err;
	}

// If another IP bearer has not set the key then this method will set the P&S key to indicate 
// that a PAN connection is active.
TInt CPanCoexistenceConnectionController::TryToCreateNewPanConnection()
	{	
	LOG_FUNC
	
	TInt err = KErrNone;
	
	// Wait for the Mutex to become free and then acquire it.
	iMutex.Wait();
	
	//Get the property	
	TIPBearerCoexistenceStatus value = ReadStatus();
	
	switch (value)
		{
		case ENoneIsActive:
			iActivePanConnectionExists = ETrue;
			iLocallyInitiatedTransition = ETrue;

			WriteStatus(EBTPanIsActive);
			break;

		case EBTPanIsActive:
			//P&S key is allready set to EBTPanIsActive 
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EBTPanIsAlreadyActive));
			break;

		case ERndisIsActive:
			//BT PAN cannot be active at the point, since Rndis holds the key
			__ASSERT_DEBUG(!iActivePanConnectionExists, PanAgentPanic(ERndisIsActiveWhenBTPanTriesToBeActive));
			err = KErrAccessDenied;
			break;

		default:
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EInvalidIPBearerCoexistanceProperty));
			break;
		}
		
	//Release the mutex
	iMutex.Signal();
	return err; 
	}

// If the co-existence P&S key has been set by the PAN service then
// clear the P&S key
void CPanCoexistenceConnectionController::HandleAllPanConnectionsClosed()
	{
	LOG_FUNC
	
	// Get the property	
	TIPBearerCoexistenceStatus value = ReadStatus();
	
	switch(value)
		{
		case ENoneIsActive:
			// The P&S key is ENoneIsActive, when BT PAN tries to clear it.
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EClearKeyWhenNoneIsActive));
			break;
		
		case ERndisIsActive:
			// This is the race condition where RNDIS sets the key when BT PAN incoming connection request
			// goes through the stack, we didn't own the key, do nothing
			LOG(_L("CPanCoexistenceConnectionController::HandleAllPanConnectionsClosed, enter the race condition"));
			break;
			
		case EBTPanIsActive:
			__ASSERT_DEBUG(iActivePanConnectionExists, PanAgentPanic(ENoPanConnectionExistsWhileInPanIsActiveCoexistencePandSState));
			iActivePanConnectionExists = EFalse;
			iLocallyInitiatedTransition = ETrue;

			WriteStatus(ENoneIsActive);
			break;

		default:
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EInvalidIPBearerCoexistanceProperty));
			break;
		}
	}

// Read property and handle error conditions
TIPBearerCoexistenceStatus CPanCoexistenceConnectionController::ReadStatus()
	{
	LOG_FUNC

	//Get the property
	TInt value = ENoneIsActive;
	TInt err = iProperty.Get(value);
	
	if(err)
		{
		if (err == KErrNotFound)
			{
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertyIsNotDefined));
					
			//Redefine property if property has been deleted	
			err = DefineProperty();
			 			
			if (err == KErrNone)
				{
				value = iActivePanConnectionExists ? EBTPanIsActive : ENoneIsActive;
				err = iProperty.Set(value);
				if (err)
					{
					//reset failed, log the error and assert the debug
					LOG1(_L("CPanCoexistenceConnectionController::ReadProperty reset Property with error: %d"), err);
					__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertySetFailed));
					}
				}
			else
				{
				//Define P&S failed, log the error and assert the debug
				LOG1(_L("CPanCoexistenceConnectionController::ReadProperty Define Property with error: %d"), err);
				__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertyCanNotBeDefined));
				}			
			}
		else
			{
			//Getter returns error rather than KErrNotFound, log the error and assert the debug
			LOG1(_L("CPanCoexistenceConnectionController::ReadProperty Get Property with error: %d"), err);
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertyGetFailed));
			}
		}
	
	return static_cast<TIPBearerCoexistenceStatus>(value);
	}

//Write the property and handle setter errors
void CPanCoexistenceConnectionController::WriteStatus(TIPBearerCoexistenceStatus aStatus)
	{
	LOG_FUNC
	
	//Set the property
	TInt err = iProperty.Set(aStatus);
	if (err)
		{
		if (err == KErrNotFound)
			{
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertyIsNotDefined));
					
			//Redefine property if property has been deleted				
			err = DefineProperty();
			 	
			if (err == KErrNone)
				{
				//Reset the property
				err = iProperty.Set(aStatus);
				if (err)
					{
					LOG1(_L("CPanCoexistenceConnectionController::WriteStatus Set Property with error: %d"), err);
					__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertySetFailed));
					}
				}
			else
				{
				//Define P&S failed, log the error and assert the debug
				LOG1(_L("CPanCoexistenceConnectionController::ReadProperty Define Property with error: %d"), err);
				__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertyCanNotBeDefined));
				//Nothing else we can do at this stage
				}

			}
		else
			{
			//Setter returns error rather than KErrNotFound
			LOG1(_L("CPanCoexistenceConnectionController::WriteStatus Set Property with error: %d"), err);
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EIPBearerCoexistancePropertySetFailed));
			}
		}
	}

void CPanCoexistenceConnectionController::SubscribeToProperty()
	{
	LOG_FUNC
	iProperty.Subscribe(iStatus);
	SetActive();
	}

void CPanCoexistenceConnectionController::DoCancel()
	{
	LOG_FUNC
	iProperty.Cancel();
	}

void CPanCoexistenceConnectionController::RunL()
	{	
	LOG_FUNC
	
	// Do not check the iStatus, since the ReadStatus() will redefine the P&S key if the key 
	// has been deleted by mistakes

	//Read the property
	TIPBearerCoexistenceStatus value = ReadStatus();
	
	switch(value)
		{
		case ENoneIsActive:
			if (!iLocallyInitiatedTransition)
				{
				// BT PAN cannot be active at this point, since the P&S key is ENoneIsActive
				__ASSERT_DEBUG(!iActivePanConnectionExists, PanAgentPanic(EPropertyIsNoneIsActiveWhenBTPanIsActive));
						
				// Notify Agent P&S Key has been updated
				iPanCoexistenceConnectionObserver.MpccoPanCoexistenceConnectionUpdated(ENoneIsActive);
				}
			break;

		case ERndisIsActive:
			// BT PAN cannot be active at this point
			__ASSERT_DEBUG(!iActivePanConnectionExists, PanAgentPanic(ERndisIsActiveWhenBTPanTriesToBeActive));
			__ASSERT_DEBUG(!iLocallyInitiatedTransition, PanAgentPanic(EBTPanInitiateDirectTransitionToRndis));
			
			//from non service to Rndis
			//Notify Agent P&S Key has been updated
			iPanCoexistenceConnectionObserver.MpccoPanCoexistenceConnectionUpdated(ERndisIsActive);
			break;

		case EBTPanIsActive:
			//Setting the P&S key to EBTPanIsActive when BT PAN is not active or BT PAN is already active
			__ASSERT_DEBUG(iActivePanConnectionExists && iLocallyInitiatedTransition, PanAgentPanic(EImproperSituationToSetPropertyToBTPanIsActive));
			break;

		default:
			__ASSERT_DEBUG(EFalse, PanAgentPanic(EInvalidIPBearerCoexistanceProperty));
			break;
		}
	
	iLocallyInitiatedTransition = EFalse;

	//Resubscribe to the property
	SubscribeToProperty();
	}