// Copyright (c) 1997-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:

//

/**

 @file

*/

#include "IF_DEF.H"

#include "NI_STD.H"

#include "Ni_Log.h"

#include <in_sock.h>

#include <es_prot.h>

#include <in_iface.h>

#include "NIFConfigurationControl.h"

#ifndef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <comms-infras/nifvar_internal.h>

#include <nifman_internal.h>

#endif

const TInt KAsyncUnBindPriority = 10000;

const TInt KTimerTick = 1000000;

const TInt KTimerCorrectionPeriod = 4;

/**

Don't ever want to set a timer for much less than 1/5 of a second

*/

const TInt KMinTimerTick = KTimerTick / 5;

CBinderRef::CBinderRef(MNifIfUser* aNetwork, CNifAgentRef& aAgentRef, TAny* aId)

/**

Constructor

*/

	: CActive(KAsyncUnBindPriority)

	{

	aAgentRef.iBinders.AddLast(*this);

	iAgentRef = &aAgentRef;

	iNetworkLayer = aNetwork;

	iNetworkLayer->IfUserOpenNetworkLayer();

	iId=aId;

	CActiveScheduler::Add(this);

	}

CBinderRef::~CBinderRef()

/**

Destructor - deque from link

*/

	{

	Cancel();

	iLink.Deque();

	iAgentRef->iTimerDisableCount++;

	iNetworkLayer->IfUserCloseNetworkLayer();

	iAgentRef->iTimerDisableCount--;

	if(iLinkLayer)

		iLinkLayer->Close();

	}

void CBinderRef::BindL(CNifIfLink* aInterface)

/**

Bind this interface to object returned by interface

*/

	{

	__ASSERT_DEBUG(!iLinkLayer, Panic(ENifManPanic_LinkLayerAlreadyExists));

	LOG( NifmanLog::Printf(_L("BinderRef %x:\tBinding interface(%x) to network layer(%x)"), this, aInterface, iNetworkLayer); )

	TServerProtocolDesc inf;

	iNetworkLayer->IfUserProtocol()->Identify(&inf);

	CNifIfBase* linklayer = aInterface->GetBinderL(inf.iName);

	TAny* id=iId;

	if (linklayer!=NULL)

		{

		LOG( NifmanLog::Printf(_L("BinderRef %x:\tLink layer for binding interface(%x) to network layer(%x) is '%S' (%x)"), this, aInterface, iNetworkLayer, &inf.iName, linklayer); )

		linklayer->Open();

		CleanupStack::PushL(TCleanupItem(CNifIfBase::Cleanup, linklayer));

		iId=0; // If new interface fails protocol does not get an IfUserBindFailure

		LOG( NifmanLog::Printf(_L("BinderRef %x:\tInforming network layer(%x) of new link layer(%x)"), this, iNetworkLayer, linklayer); )

		iNetworkLayer->IfUserNewInterfaceL(linklayer, id);

		CleanupStack::Pop();

		iLinkLayer = linklayer;

		}

	else

		{

		iId=0; // If new interface fails protocol does not get an IfUserBindFailure

		LOG( NifmanLog::Printf(_L("BinderRef %x:\tInforming network layer(%x) of new link layer(%x)"), this, iNetworkLayer, aInterface); )

		iNetworkLayer->IfUserNewInterfaceL(aInterface, id);

		iLinkLayer = aInterface;

		iLinkLayer->Open();

		}

	LOG( NifmanLog::Printf(_L("BinderRef %x:\tSuccessfully bound network layer(%x) to link layer(%x)"), this, iNetworkLayer, iLinkLayer); )

	}

void CBinderRef::LinkDown(TInt aError, TBool)

/**

Lower layer link down error

*/

	{

	__ASSERT_DEBUG(iLinkLayer, Panic(ENifManPanic_LinkLayerNotEstablished));

	if(!IsActive())

		{

		TRequestStatus* p = &iStatus;

		User::RequestComplete(p, aError);

		SetActive();

		}

	}

void CBinderRef::UnBind(TInt aError,TBool)

/**

Notify fact that link layer has dissappear even before it started

*/

	{

	if(iLinkLayer) // means binding happened successfully

	    iNetworkLayer->IfUserInterfaceDown(aError, iLinkLayer);

	else if(iId)

		iNetworkLayer->IfUserBindFailure(aError, iId);

	delete this;

	}

void CBinderRef::DoCancel()

	{

	}

void CBinderRef::RunL()

	{

	UnBind(iStatus.Int());

	}

CNifAgentRef::CNifAgentRef(CObject& aFactory)

/**

Constructor

*/

:

	iIsSubClassed(EFalse)

	{

	iBinders.SetOffset(_FOFF(CBinderRef, iLink));

	SetOwner(&aFactory);

	Owner()->Open();

	SocketServExt::OpenSession();

	}

CNifAgentRef::CNifAgentRef(TInt)

//

// C'tor

//

:

	iIsSubClassed(EFalse)

	{

	}

CNifAgentRef::~CNifAgentRef()

/**

Destructor

*/

	{

	if(iIsSubClassed)

		{

		TInt ac = CObject::AccessCount();

		if(ac==1)

			CObject::Dec();

		return;

		}

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tDestructor called"), this); )

	BindFailAll(KErrDied);

	ServiceClosed();

	SocketServExt::CloseSession();

	iSessions.Reset();

	// Inform interface state change observers that the interface is going down.

	CNifMan::Global()->AgentGoingDown(*this);

	// tell the network controller that this agent is no-longer available

	if(iNetCon)

		{

		iNetCon->AgentConnectionFailure(iAgent, KErrNone);

		iNetCon = NULL;

		}

	// If we're using the extended management compatibility layer, delete it

	if(iNifExtndMngmntCompatibilityLayer)

		delete iNifExtndMngmntCompatibilityLayer;

	delete iAgent;

	Owner()->Close();

	TimerDelete(); // will also cancel timer

	}

CNifAgentRef* CNifAgentRef::NewL(const TDesC& aName, CNifAgentFactory& aFactory)

/**

create new agent reference

*/

	{

	CNifAgentRef* ref = new (ELeave) CNifAgentRef(aFactory);

	CleanupStack::PushL(TCleanupItem(CNifFactory::Cleanup, ref));

	ref->ConstructL(aName, aFactory);

	CleanupStack::Pop();

	return ref;

	}

void CNifAgentRef::ConstructL(const TDesC& aName, CNifAgentFactory& aFactory)

/**

Dynamic construction

*/

	{

	LOG_DETAILED( NifmanLog::Printf(_L("AgentRef %x:\tConstructL('%S', aFactory 0x%x)"), this, &aName); )

	// find the network controller if there is one

	iNetCon = CNifMan::Global()->NetworkController();

	TimerConstructL(ESocketTimerPriority);

	iAgent = aFactory.NewAgentL(aName);

	iAgent->iNotify = this;

	CNifMan::Global()->AddAgentL(this);

	Progress(KConnectionUninitialised, KErrNone);

	(void)RefreshConnectionInfo();

	}

void CNifAgentRef::RefreshConnectionInfo()

/**

Update the IAP id and Network ID of this agent

*/

	{

	_LIT(KIAPId, "IAP\\Id");

	_LIT(KIAPNetwork, "IAP\\IAPNetwork");

	TSoIfConnectionInfo info;

	TInt err = ReadInt(KIAPId(), info.iIAPId);

	if(err!=KErrNone)

		return;

	err = ReadInt(KIAPNetwork(), info.iNetworkId);

	if(err!=KErrNone)

		return;

	SetConnectionInfo(info);

	}

TName CNifAgentRef::Name() const

/**

Override with name of agent

*/

	{

	if(iAgent)

		{

		TNifAgentInfo info;

		iAgent->Info(info);

		return info.iName;

		}

	else

		return CObject::Name();

	}

TInt CNifAgentRef::Open()

	{

	TInt ret = CObject::Open();

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tOpen() - new reference count is %d"), this, AccessCount()); )

	return ret;

	}

void CNifAgentRef::Close()

/**

Close - only destroy if in an idle state

*/

	{

	ASSERT(AccessCount()>0);

	Dec();

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tClose() - new reference count is %d"), this, AccessCount()); )

	if (AccessCount()==0 && iState==EIdle)

		{

		delete this;

		}

	}

TInt CNifAgentRef::AddNetworkLayer(MNifIfUser* aNetwork, TAny* aId)

/**

First search to see if it already exists

Create the binding reference

If the interface exists go straight to binding

*/

	{

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tAdding a new binder for network layer(%x)"), this, aNetwork); )

	TDblQueIter<CBinderRef> iter(iBinders);

	CBinderRef* b;

	while((b=iter++)!=0)

		{

		if(b->iNetworkLayer==aNetwork)

			{

			LOG( NifmanLog::Printf(_L("AgentRef %x:\tFound existing binder(%x) between network layer(%x) and link layer(%x)"), this, b, aNetwork, b->iLinkLayer); )

			return KErrAlreadyExists;

			}

		}

	// Network layer trying to bind but interface in progress

	if(!aId || (iState==EConnecting && !iInterface) || iState==EIdle || iState==EDisconnecting)

		{

		b= new CBinderRef(aNetwork, *this, aId);

		if(!b)

			return KErrNoMemory;

		if(iInterface && !aId)

			{

			TRAPD(res, b->BindL(iInterface));

			if(res!=KErrNone)

				{

				LOG( NifmanLog::Printf(_L("AgentRef %x:\tError(%d) binding interface(%x) to network layer(%x)"), this, res, iInterface, aNetwork); )

				b->UnBind(res);

				}

			return res;

			}

		return KErrNone;

		}

	return KErrLocked;

	}

void CNifAgentRef::LinkDownAll(TInt aError,TBool)

/**

Link has gone down

*/

	{

	LOG_DETAILED( NifmanLog::Printf(_L("AgentRef %x:\tLinkDownAll(%d)"), this, aError); )

	TDblQueIter<CBinderRef> iter(iBinders);

	CBinderRef* p;

	while((p=iter++)!=0)

		p->LinkDown(aError);

	}

void CNifAgentRef::BindFailAll(TInt aError)

/**

Unbind all those which are bound

*/

	{

	LOG_DETAILED( NifmanLog::Printf(_L("AgentRef %x:\tBindFailAll(%d)"), this, aError); )

	Progress(KConnectionFailure, aError);

	while(!iBinders.IsEmpty())

		iBinders.First()->UnBind(aError);

	}

void CNifAgentRef::SetUsageProfile(TUint aProfile)

	{

	LOG_DETAILED( NifmanLog::Printf(_L("AgentRef %x:\tSetUsageProfile(%d)"), this, aProfile); )

	switch (aProfile)

		{

	case KConnProfileMedium:

		if (iUserCount++ == 0)

			{

			// Move from short to medium timer

			if (iTimerMode == ETimerShort)

				{

				LOG( NifmanLog::Printf(_L("AgentRef %x:\tUsage profile %d - timer mode set to Medium"), this, aProfile); )

				SetTimerMode(ETimerMedium);

				}

			}

		break;

	case KConnProfileNone:

		__ASSERT_DEBUG(iUserCount >= 1, Panic(ENifManPanic_NegativeCloseCount));

		if (--iUserCount == 0)

			{

			// Moving from medium to short timer

			if (iTimerMode == ETimerMedium && iRouteCount == 0)

				{

				// Moving from medium to short timer

				LOG( NifmanLog::Printf(_L("AgentRef %x:\tUsage profile %d - timer mode set to Short"), this, aProfile); )

				SetTimerMode(ETimerShort);

				}

			}

		break;

	default:

		Panic(ENifManPanic_UsageProfileOutOfRange);

		}

	}

TInt CNifAgentRef::IsNetworkLayerActive()

/**

Return state to client side

*/

	{

	if(iBinders.IsEmpty())

		return KErrNotReady;

	return IsAnyNetworkLayerOpen();

	}

TBool CNifAgentRef::IsAnyNetworkLayerOpen()

/**

Is any network layer open

*/

	{

	TDblQueIter<CBinderRef> iter(iBinders);

	CBinderRef* b;

	while((b=iter++)!=0)

		{

		if(b->iNetworkLayer->IfUserIsNetworkLayerActive())

			{

		    return ETrue;

			}

		}

	return EFalse;

	}

TBool CNifAgentRef::AreAllNetworkLayersOpen()

/**

Are all link layers open

*/

	{

	TDblQueIter<CBinderRef> iter(iBinders);

	CBinderRef* b;

	while((b=iter++)!=0)

		{

		TIfStatus linkStatus=TIfStatus(b->iLinkLayer->State());

		if(linkStatus==EIfPending || linkStatus==EIfDown)

			{

			return EFalse;

			}

		}

	return ETrue;

	}

void CNifAgentRef::NetworkLayerClosed(MNifIfUser* aNetworkLayer)

/**

Network layer no longer has any clients

*/

	{

	LOG_DETAILED( NifmanLog::Printf(_L("AgentRef %x:\tNetworkLayerClosed(MNifIfUser %x)"), this, aNetworkLayer); )

	// is aNetworkLayer one of our bindees?

	TDblQueIter<CBinderRef> iter(iBinders);

	CBinderRef* b;

	TBool found(EFalse);

	while((b=iter++)!=0 && !found)

		{

		if(b->iNetworkLayer == aNetworkLayer)

			found = ETrue;

		}

	if(!found)

		return;

	if(iTimer->IsActive() || iTimerDisableCount>0)

		return;

	if(iState==ELinkUp || iState==EIdle)

		{

		ResetTimer();

		}

	}

TInt CNifAgentRef::GetTimerThresholds()

	{

	TUint32 value;

	TInt ret = ReadInt(TPtrC(LAST_SESSION_CLOSED_TIMEOUT), value);

	if (ret!= KErrNone)

		{

		LOG( NifmanLog::Printf(_L("AgentRef %x:\tCould not read short timeout value - disabling this timer"), this); )

		value = KMaxTUint32;

		}

	iTickThreshold[ETimerShort] = (TInt) value;

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tShort timeout value set to %d ticks"), this, iTickThreshold[ETimerShort]); )

	ret = ReadInt(TPtrC(LAST_SOCKET_CLOSED_TIMEOUT), value);

	if (ret!= KErrNone)

		{

		LOG( NifmanLog::Printf(_L("AgentRef %x:\tCould not read medium timeout value - disabling this timer"), this); )

		value = KMaxTUint32;

		}

	iTickThreshold[ETimerMedium] = (TInt) value;

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tMedium timeout value set to %d ticks"), this, iTickThreshold[ETimerMedium]); )

	ret = ReadInt(TPtrC(LAST_SOCKET_ACTIVITY_TIMEOUT), value);

	if (ret!= KErrNone)

		{

		LOG( NifmanLog::Printf(_L("AgentRef %x:\tCould not read long timeout value - disabling this timer"), this); )

		value = KMaxTUint32;

		}

	iTickThreshold[ETimerLong] = (TInt) value;

	LOG( NifmanLog::Printf(_L("AgentRef %x:\tLong timeout value set to %d ticks"), this, iTickThreshold[ETimerLong]); )

	iTickThreshold[ETimerImmediate] = 0;

	return KErrNone;

	}