diff -r d15a50675083 -r c0a997472b1c networkcontrol/ipcprshim/src/shimnifmansconn.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/networkcontrol/ipcprshim/src/shimnifmansconn.cpp	Fri Jun 11 15:15:43 2010 +0300
@@ -0,0 +1,244 @@
+// 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;
+//	}
+