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

// SHIMSCPR.CPP

// This is part of an ECOM plug-in

// 

//

#include <ss_std.h>

#include <comms-infras/ss_log.h>

#include "shimnifmansconn.h"

START_ATTRIBUTE_TABLE(TShimConnectionInfo, KShimCommsUid, Meta::KNetMetaTypeAny)

END_ATTRIBUTE_TABLE()

TInt CNifManSubConnectionShim::AsyncDestructorCb(TAny* aInstance)

	{

	CNifManSubConnectionShim* nifManSubConnection= reinterpret_cast<CNifManSubConnectionShim*>(aInstance);

	delete nifManSubConnection;

	return KErrNone;

	}

/**

Create a new CNifManSubConnectionShim to act as a mux/demux for subconnections

*/

CNifManSubConnectionShim::CNifManSubConnectionShim (CConnectionProviderShim& aProviderShim)

   :iSubConnectionsUniqueId(0), iConnectionProvider(&aProviderShim),

   iAsyncDestructor(CActive::EPriorityStandard + 1)

	{

	__CFLOG_VAR((KShimScprTag, KShimScprSubTag, _L8("CNifManSubConnectionShim [this=%08x]:\tCNifManSubConnectionShim() [MConnectionDataClient=%08x]"),

	   this, (MConnectionDataClient*)this));

	iAsyncDestructor.Set(TCallBack(AsyncDestructorCb, this));

	}

/**

D'tor

*/

CNifManSubConnectionShim::~CNifManSubConnectionShim()

	{

	__CFLOG_VAR((KShimScprTag, KShimScprSubTag, _L8("CNifManSubConnectionShim::~CNifManSubConnectionShim() %08x"), this));

	iShimClients.ResetAndDestroy();

	delete iConnDataTransferShim;

	}

void CNifManSubConnectionShim::DeleteAsync()

	{

	if ( !iAsyncDestructor.IsActive() )

		{

		iAsyncDestructor.CallBack();

		}

    }

TInt CNifManSubConnectionShim::FindClient(const CConnection& aConnection)

	{

	TInt max = iShimClients.Count();

	for (TInt i = max - 1 ; i >= 0 ; i--)

		{

		CSubConnectionLinkShimClient* client = iShimClients[i];

		if ( client->Match(aConnection) )

			{

			return i;

			}

		}

	return KErrNotFound;

	}

void CNifManSubConnectionShim::ConnectionJoiningL(const CConnection& aConnection)

	{//create a new CSubConnectionLinkShimClient for the joining conection

	TInt i = FindClient(aConnection);

	if ( i == KErrNotFound )

		{

		CSubConnectionLinkShimClient* client = new (ELeave)CSubConnectionLinkShimClient(aConnection,*this);

		CleanupStack::PushL(client);

		//create data transfer object if not created yet

		CreateDataTransferL();

		iConnDataTransferShim->RegisterClientL(*client);

		TInt ret = iShimClients.Append(client);

		if (ret != KErrNone)

			{

			iConnDataTransferShim->DeRegisterClient(*client);

			User::Leave(ret);

			}

		CleanupStack::Pop(client);

		}

	}

void CNifManSubConnectionShim::ConnectionLeaving(const CConnection& aConnection)

	{//destroy a CSubConnectionLinkShimClient belonging to leaving conection

	TInt i = FindClient(aConnection);

	if ( i >= 0 )

		{

		CSubConnectionLinkShimClient* client = iShimClients[i];

		iShimClients.Remove(i);

		delete client;

		}

	}

void CNifManSubConnectionShim::ConnectionGoingDown(CConnectionProviderBase& /*aConnProvider*/)

	{

	__CFLOG_VAR((KShimScprTag, KShimScprSubTag, _L8("CNifManSubConnectionShim %08x:\tConnectionGoingDown() Id %d"), 

						 this, iSubConnectionsUniqueId));

   // The ConnectionProvider has told us its going down so we delete ourselves, clearing

   // the pointer to it so our d'tor doesn't make any calls on it.

	iConnectionProvider = NULL;

	delete this;

	}

void CNifManSubConnectionShim::ConnectionError(TInt /*aStage*/, TInt /*aError*/)

	{

	}

void CNifManSubConnectionShim::Notify(TNotify /*aNotifyType*/,  CConnectionProviderBase* /*aConnProvider*/, TInt /*aError*/, const CConNotificationEvent* /*aConNotificationEvent*/)

	{

	}

void CNifManSubConnectionShim::AttachToNext(CSubConnectionProviderBase* /*aSubConnProvider*/)

	{

	}

TInt CNifManSubConnectionShim::ProgressNotification(TInt aStage, TInt aError, const TDesC8& aInfo)

/**

Upcall from connection provider via CInterface with notification of new progress stage reached

@param aStage The progress stage that the subconnection has reached

@param aError Any errors that were encountered at this stage

@param aInfo No idea what this is, it's inserted by CInterface and is currently null

@return KErrNone, or one of the system-wide error codes

*/

	{

	__CFLOG_VAR((KShimScprTag, KShimScprSubTag, _L8("CNifManSubConnectionShim %08x:\tProgressNotification(%d, %d) SubConnId: %d"), 

				this, aStage, aError, iSubConnectionsUniqueId));

	TInt max = iShimClients.Count();

	for (TInt i = max - 1 ; i >= 0 ; i--)

		{

		iShimClients[i]->ProgressNotification(aStage, aError, aInfo);

		}

	return KErrNone;

	}

TInt CNifManSubConnectionShim::NotifyDataTransferred(TUint aUplinkVolume, TUint aDownlinkVolume)

	{

	return  iConnDataTransferShim ? iConnDataTransferShim->NotifyDataTransferred(aUplinkVolume, aDownlinkVolume) : KErrNone;

	}

TInt CNifManSubConnectionShim::NotifyDataSent(TUint aUplinkVolume, TUint /*aCurrentGranularity*/)

	{

	return  iConnDataTransferShim ? iConnDataTransferShim->NotifyDataSent(aUplinkVolume) : KErrNone;

	}

TInt CNifManSubConnectionShim::NotifyDataReceived(TUint aDownlinkVolume, TUint /*aCurrentGranularity*/)

	{

	return  iConnDataTransferShim ? iConnDataTransferShim->NotifyDataReceived(aDownlinkVolume) : KErrNone;

	}

TSubConnectionUniqueId CNifManSubConnectionShim::Id()

	/**

	Access this subconnections unique id for search purposes

	*/

	{

	return iSubConnectionsUniqueId;

	}

void CNifManSubConnectionShim::SetSubConnectionUniqueId( TSubConnectionUniqueId aSubConnectionUniqueId )

	{

	iSubConnectionsUniqueId = aSubConnectionUniqueId;

	}

//void CNifManSubConnectionShim::DataClientJoiningL(MSubConnectionDataClient& aDataClient)

//	{

//	aDataClient.JoinComplete(*this);

//	}

//void CNifManSubConnectionShim::DataClientLeaving(MSubConnectionDataClient& aDataClient)

//	{

//	aDataClient.LeaveComplete(*this);

//	}

//void CNifManSubConnectionShim::DoSourceAddressUpdate(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aSource*/)

//	{//do nothing

//	}

//void CNifManSubConnectionShim::DoDestinationAddressUpdate(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aDestination*/)

//	{//do nothing

//	}

//void CNifManSubConnectionShim::DoDataClientRouted(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aSource*/, const TSockAddr& /*aDestination*/, const TDesC8& /*aConnectionInfo*/)

//	{//do nothing

//	}

//void CNifManSubConnectionShim::DoParametersAboutToBeSetL(CSubConParameterBundle& /*aParameterBundle*/)

//	{//do nothing

//	}

//TInt CNifManSubConnectionShim::DoControl(TUint /*aOptionLevel*/, TUint /*aOptionName*/, TDes8& /*aOption*/)

//	{//do nothing

//	return KErrNotSupported;	

//	}

//void CNifManSubConnectionShim::DoStartL()

//	{

//	User::Leave(KErrNotSupported);

//	}

//void CNifManSubConnectionShim::DoStop()

//	{

//	}

//CSubConnectionProviderBase* CNifManSubConnectionShim::DoNextLayer()

//	{

//	return NULL;

//	}

CConnDataTransfer& CNifManSubConnectionShim::CreateDataTransferL()

	{

	if (!iConnDataTransferShim)

		{

		iConnDataTransferShim = new (ELeave)CConnDataTransferShim(*this);

		}

	return *iConnDataTransferShim;

	}

//MConnectionDataClient* CNifManSubConnectionShim::DoSelfConnectionDataClient()

//	{

//	return this;

//	}