diff -r 9f5ae1728557 -r db3f5fa34ec7 messagingfw/biomsgfw/BioWatchers/Src/NbsWatcher.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingfw/biomsgfw/BioWatchers/Src/NbsWatcher.cpp	Wed Nov 03 22:41:46 2010 +0530
@@ -0,0 +1,177 @@
+// Copyright (c) 1999-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 "NbsWatcher.h"
+#include <biodb.h>
+
+#include "NBSSocketWatcher.h"
+
+#include <e32test.h>
+#include <watcher.h>
+
+//
+// DLL Global Methods
+//
+
+
+#include <ecom/implementationproxy.h>
+
+const TImplementationProxy ImplementationTable[] = 
+	{
+		IMPLEMENTATION_PROXY_ENTRY(0x10008C66, CNbsWatcher::NewL)
+	};
+
+EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
+	{
+	aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);
+
+	return ImplementationTable;
+	}
+
+
+//
+// NbsWatcher
+//
+
+//
+// Construction
+//
+CNbsWatcher::CNbsWatcher(RFs& aFs, CWatcherLog& aLog)
+: CSmsBaseWatcher(aFs, aLog, EPriorityStandard + 1)
+	{
+	}
+	
+CNbsWatcher::~CNbsWatcher()
+	{
+	}
+
+//
+CNbsWatcher* CNbsWatcher::NewL(TAny* aWatcherParams)
+	{
+	TWatcherParams* params = reinterpret_cast<TWatcherParams*>(aWatcherParams);
+	CNbsWatcher* self= new (ELeave) CNbsWatcher(params->iFs, params->iLog);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop(self);
+	return self;
+	}
+	
+void CNbsWatcher::ConstructL()
+	{
+	// CSmsBaseWatcher::ConstructL calls SetActive
+	CSmsBaseWatcher::ConstructL();
+	}
+
+//
+// Construction/destruction
+
+void CNbsWatcher::StartL()
+	{
+	CSmsBaseWatcher::StartL();
+
+	GetBioServiceId(*iSession, iBioServiceId, iSmsServiceId);
+
+	CreateSocketWatchersFromBioDbL(EBioMsgIdNbs);
+
+	// Set up a SMS Watcher for Special Messages
+	SetupSpecialWatcherL(ESmsAddrMessageIndication);
+
+	// Set up a SMS Watcher for Status Reports
+	SetupSpecialWatcherL(ESmsAddrStatusReport);
+
+	// Set up the default NULL SMS message
+	CBaseSmsActiveSocketWatcher* nbsWatcher = CNbsSmsSocketWatcher::NewLC(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), KNullUid, iFs, KNullDesC, ESmsAddrRecvAny);
+	TInt error = SetupAndAppendL(*nbsWatcher, *iSocketWatchers);
+	User::LeaveIfError(error); //need to make sure the ReceiveAny watcher is working
+	iReceiveAnySocket = nbsWatcher;
+	CleanupStack::Pop(); //nbsWatcher
+
+	StartSocketWatchersL();
+
+	ResetDb(); //these members are only required during construction
+
+	// delete the session with the message server
+	delete iSession;
+	iSession = NULL;	
+	}
+
+CBaseSmsActiveSocketWatcher* CNbsWatcher::CreateSocketWatcherLC(const TUid aBioUid, const TBioMsgId& aBioMsg)
+	{
+	if (!SupportBioMsgId(aBioMsg))
+		User::Leave(KErrNotSupported);
+
+	__ASSERT_DEBUG(iBioDb, PanicWatcher(EObjectNotConstructed));
+
+	return CNbsSmsSocketWatcher::NewLC(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), aBioUid, iFs, aBioMsg.iText);
+	}
+
+TBool CNbsWatcher::SupportBioMsgId(const TBioMsgId& aBioMsg) const
+	{
+	return aBioMsg.iType == EBioMsgIdNbs && aBioMsg.iPort <= 0 && aBioMsg.iText.Length();
+	}
+
+void CNbsWatcher::AddBifL(TUid aBioID)
+	{
+	BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: AddBifL(BioUid: %d)"), aBioID.iUid));
+
+	// Handle the case where the watchers are not working
+	if (!iReceiveAnySocket)
+		User::Leave(KErrNotSupported);
+
+	iReceiveAnySocket->Cancel();
+
+	TRAPD(err, AddBifWithTypeL(EBioMsgIdNbs, aBioID));
+
+	iReceiveAnySocket->SetupL();
+	iReceiveAnySocket->StartL();
+
+	ResetDb();
+
+	User::LeaveIfError(err);
+	}
+
+void CNbsWatcher::SetupSpecialWatcherL(TSmsAddrFamily aAddrFamily)
+	{
+	CBaseSmsActiveSocketWatcher* nbsWatcher = NULL;
+
+	//The following function will leave with KErrNotSupported
+	//if the CSmsSettings stored against the SMS Service indicates
+	//that this message type should not be watched
+
+	BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: SetupSpecialWatcher [aAddrFamily=%d]"), aAddrFamily));
+	__ASSERT_DEBUG(iBioDb, PanicWatcher(EObjectNotConstructed));
+
+	TRAPD(error, nbsWatcher = CSpecialNbsSmsSocketWatcher::NewL(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), KNullUid, iFs, KNullDesC, aAddrFamily));
+
+	if (error == KErrNone)
+		{
+		CleanupStack::PushL(nbsWatcher);
+		error = SetupAndAppendL(*nbsWatcher, *iSocketWatchers); //Returns either KErrNotFound or KErrAlreadyExists, otherwise leaves
+
+		if (error != KErrNone)
+			CleanupStack::PopAndDestroy(nbsWatcher);
+		else
+			CleanupStack::Pop(nbsWatcher);
+		}
+
+	if (error != KErrNone)
+		{
+		BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: SetupSpecialWatcher Failed [error=%d]"), error));
+
+		if (error == KErrNoMemory)
+			User::Leave(error);
+		//else ignore the error
+		}
+	}