diff -r 6a20128ce557 -r ebfee66fde93 email/pop3andsmtpmtm/servermtmutils/src/imutcon.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/email/pop3andsmtpmtm/servermtmutils/src/imutcon.cpp	Fri Jun 04 10:25:39 2010 +0100
@@ -0,0 +1,309 @@
+// Copyright (c) 2000-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 <cdbpreftable.h>
+
+#include <commsdat.h>
+#include <commsdattypesv1_1.h>
+#include <commdbconnpref.h>
+#include <miut_err.h>
+#include <es_enum.h>		// For TConnectionInfo
+#include <imutcon.h>
+#include "IMSK.H"
+
+
+#ifdef _DEBUG
+#define __IMSK_SIMULATION
+#include <etel.h>
+#endif
+
+#define __IMSK_LOGGING
+
+
+CImConnect* CImConnect::NewL(const CImIAPPreferences& aIAPPreferences, CImTextServerSession &aTextSession)
+	{
+	CImConnect* self = new (ELeave) CImConnect(aIAPPreferences, &aTextSession, NULL);
+	CActiveScheduler::Add(self);
+	return self;
+	}
+
+EXPORT_C CImConnect* CImConnect::NewL(const CImIAPPreferences& aIAPPreferences, RSocketServ& aSocketServerHandle)
+	{
+	CImConnect* self = new (ELeave) CImConnect(aIAPPreferences, NULL, &aSocketServerHandle);
+	CActiveScheduler::Add(self);
+	return self;
+	}
+
+void CImConnect::RunL()
+	{
+	User::RequestComplete(iReportStatus, iStatus.Int());
+	}
+
+void CImConnect::DoCancel()
+	{
+	iConn.Close();
+	User::RequestComplete(iReportStatus, KErrCancel);
+	}
+
+EXPORT_C void CImConnect::StartL(TRequestStatus& aStatus)
+	{
+	// Attempt the first connection using the appropriate IAP.
+	iReportStatus = &aStatus;
+	if (iTextSession != NULL)
+		{
+		User::LeaveIfError(iConn.Open(iTextSession->GetSocketServ()));
+		}
+	else
+		{
+		User::LeaveIfError(iConn.Open(*iSocketServerHandle));
+		}
+	ConnectL();
+	SetActive();
+	aStatus=KRequestPending;
+	}
+
+#ifdef __IMSK_SIMULATION
+void CImConnect::SetIAPsToFail(TInt aIAPsToFail)
+	{
+	iIAPsToFail=aIAPsToFail;
+	}
+#endif
+
+void CImConnect::ConnectL()
+	{
+	if (iIAPPreferences.SNAPDefined())
+		{
+		ConnectWithSNAP();
+		}
+	else
+		{
+		ConnectWithIAPListL();
+		}
+	}
+
+void CImConnect::ConnectWithSNAP()
+	{
+	TConnSnapPref snapPref(iIAPPreferences.SNAPPreference());
+	iConn.Start(snapPref, iStatus);
+	}
+
+void CImConnect::ConnectWithIAPListL()
+	{
+	TInt iapCount=iIAPPreferences.NumberOfIAPs();
+
+	if(iapCount==0)
+		{
+#ifdef __IMSK_LOGGING
+		_LIT8(KImConDefault,"CImConnect connecting with defaults");
+		if (iTextSession != NULL)
+			{
+			iTextSession->LogText(KImConDefault);
+			}
+#endif
+		iConn.Start(iStatus);
+		}
+	else
+		{
+#ifdef __IMSK_SIMULATION
+		if(iapCount<=iIAPsToFail)
+			{
+#ifdef __IMSK_LOGGING
+			_LIT8(KImConSimFail,"CImConnect simulated failure of all IAPs");
+			if (iTextSession != NULL)
+				{
+				iTextSession->LogText(KImConSimFail);
+				}
+#endif
+			TRequestStatus* status = &iStatus;
+			// Just pick an etel error and pretend we failed
+   			User::RequestComplete(status, KErrEtelModemNotDetected);  
+			return;
+			}
+#endif
+		// Set up the appropriate override
+#ifdef __IMSK_LOGGING
+		_LIT8(KImConOverride,"CImConnect trying overrides");
+		if (iTextSession != NULL)
+			{
+			iTextSession->LogText(KImConOverride);
+			}
+#endif
+
+		TInt rank=1;
+#ifdef __IMSK_SIMULATION
+		for(TInt i=iIAPsToFail;i<iapCount;i++)
+#else
+		for(TInt i=0;i<iapCount;i++)
+#endif
+			{
+			TCommDbConnPref pref;
+			pref.SetDirection(ECommDbConnectionDirectionOutgoing);
+			
+			// legacy code which restricted the type of bearer
+			pref.SetBearerSet(KCommDbBearerCSD | KCommDbBearerWcdma | KCommDbBearerLAN |
+			                  KCommDbBearerVirtual | KCommDbBearerPAN | KCommDbBearerWLAN);
+
+			TImIAPChoice iapChoice = iIAPPreferences.IAPPreference(i);
+
+			pref.SetIapId(iapChoice.iIAP);
+			pref.SetDialogPreference(iapChoice.iDialogPref);
+
+			User::LeaveIfError(iPrefs.SetPreference(rank, pref));
+
+			rank++;
+			}
+
+		iPrefs.SetConnectionAttempts(rank-1);
+		iConn.Start(iPrefs, iStatus);
+		}
+	}
+
+CImConnect::~CImConnect()
+	{
+	Cancel();
+	// Fix for DEF40210:
+	// Although it is not necessary because the RSocketServ will delete all RConnection handles when it is closed, 
+	// we call this for completeness as this class should tidy up all resources it creates
+	iConn.Close();
+	}
+
+CImConnect::CImConnect(const CImIAPPreferences& aIAPPreferences, CImTextServerSession* aTextSession, RSocketServ* aSocketServerHandle) : 
+		CActive(EPriorityStandard), iIAPPreferences(aIAPPreferences), iTextSession(aTextSession), iSocketServerHandle(aSocketServerHandle)
+	{
+	}
+
+TInt CImConnect::RunError(TInt aError)
+	{
+	if (iReportStatus)
+		User::RequestComplete(iReportStatus, aError);
+
+	return KErrNone;
+	}
+
+EXPORT_C TInt CImConnect::GetIAPValue(TUint32& aIap)
+	{
+	// INC040630 - AV20 Panic while disconnecting a service.
+	// Cancel closes the RConnection. Check we still have a valid subsession
+	// handle.
+	TInt iapValue = KErrBadHandle;
+	if (iConn.SubSessionHandle() != KNullHandle)
+		{		
+		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
+		settingName.Copy(KCDTypeNameIAP);
+		settingName.Append('\\');
+		settingName.Append(TPtrC(KCDTypeNameRecordTag));
+		iapValue = iConn.GetIntSetting(settingName, aIap);
+		}
+	return iapValue;
+	}
+
+EXPORT_C TInt CImConnect::GetIAPBearer(TUint32& aBearer)
+	{
+	TInt err = KErrBadHandle;
+	if (iConn.SubSessionHandle() != KNullHandle)
+		{
+		TBuf<KCommsDbSvrMaxColumnNameLength> iapservicename;	
+		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
+		settingName.Copy(KCDTypeNameIAP);
+		settingName.Append('\\');
+		settingName.Append(TPtrC(KCDTypeNameServiceType));
+		
+		// Get the current active IAP's service name
+		err = iConn.GetDesSetting(settingName, iapservicename);
+		if(err==KErrNone)
+			{
+			// Set the bearer corresponding to the service name
+			if( iapservicename.Compare(TPtrC(KCDTypeNameDialOutISP))==0 ||
+				iapservicename.Compare(TPtrC(KCDTypeNameDialInISP))==0)
+				aBearer=KCommDbBearerCSD;
+			else if( iapservicename.Compare(TPtrC(KCDTypeNameOutgoingWCDMA))==0 ||
+					 iapservicename.Compare(TPtrC(KCDTypeNameIncomingWCDMA))==0)
+				aBearer=KCommDbBearerWcdma;
+			else if(iapservicename.Compare(TPtrC(KCDTypeNameLANService))==0)
+				aBearer=KCommDbBearerLAN;	
+			else 
+				err = KErrNotFound;
+			}	
+		}
+	return err;
+	}
+
+EXPORT_C RConnection& CImConnect::GetConnection()
+	{
+	return iConn;
+	}
+
+EXPORT_C TInt CImConnect::Progress(TNifProgress& aProgress)
+	{
+	if (iConn.SubSessionHandle() != KNullHandle)
+		return iConn.Progress(aProgress);
+	return KErrBadHandle;
+	}
+
+EXPORT_C TInt CImConnect::GetRConnectionName(TName &aName)
+	{
+	return iConn.Name(aName);
+	}
+
+EXPORT_C TInt CImConnect::GetLastSocketActivityTimeout(TUint32& aTimeout)
+	{
+	TInt err = KErrBadHandle;
+
+	if (iConn.SubSessionHandle() != KNullHandle)
+		{
+		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
+		TBuf<KCommsDbSvrMaxColumnNameLength> iapBearer;
+
+		settingName.Copy(KCDTypeNameIAP);
+		settingName.Append('\\');
+		settingName.Append(TPtrC(KCDTypeNameBearerType));
+
+		// Get the current active IAP's bearer table name
+		err = iConn.GetDesSetting(settingName, iapBearer);
+
+		if (err == KErrNone)
+			{
+			// Get the last socket activity timeout from the bearer table
+			iapBearer.Append('\\');
+			iapBearer.Append(TPtrC(KCDTypeNameLastSocketActivityTimeout));
+			err = iConn.GetIntSetting(iapBearer, aTimeout);
+			}
+		}
+
+	return err;
+	}
+
+// Continuing the Existing RConnection	
+void CImConnect::SecondaryStartL(CImTextServerSession* aPrimaryTextServerSession)
+	{
+	// openign the connection from socketserver.
+	User::LeaveIfError(iConn.Open(iTextSession->GetSocketServ()));
+
+#ifdef __IMSK_LOGGING
+	_LIT8(KImConDefault,"SecondarySession connecting with existing RConnection");
+	iTextSession->LogText(KImConDefault);
+#endif
+
+	TConnectionInfo connInfo;
+	TPckg<TConnectionInfo> connInfoPckg(connInfo);
+	TUint count;
+	// Enumerates the number of currently active interfaces
+	User::LeaveIfError(aPrimaryTextServerSession->GetCImConnect()->GetConnection().EnumerateConnections(count));
+	// Get the information about currently active connection	
+	User::LeaveIfError(aPrimaryTextServerSession->GetCImConnect()->GetConnection().GetConnectionInfo(count, connInfoPckg) );
+	// Attaches the RConnection object to an existing interface
+	User::LeaveIfError(iConn.Attach(connInfoPckg, RConnection::EAttachTypeNormal));
+	}
+