// Copyright (c) 2008-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: Extra test interface to the NetProtocolProxy.  It allows the test+
−
//  to be asynchronous and continue to run other events whilst waiting for a message+
−
//  from the NG. The test is notified when a message arrives (or if it times out)+
−
// +
−
//+
−
+
−
#include "clbstestngmessagehandler.h"+
−
+
−
+
−
/** 2nd Phase constructor+
−
 */+
−
CLbsTestNgMessageHandler* CLbsTestNgMessageHandler::NewL(MLbsTestNgMessageHandler& aObserver, TInt aPmId)+
−
	{+
−
	CLbsTestNgMessageHandler* self = new (ELeave) CLbsTestNgMessageHandler(aObserver, aPmId);+
−
	CleanupStack::PushL(self);+
−
	self->ConstructL();+
−
	CleanupStack::Pop(self);+
−
	return self;+
−
	}+
−
+
−
CLbsTestNgMessageHandler::~CLbsTestNgMessageHandler()+
−
	{+
−
	Cancel();+
−
	iRequestTimeout.Close();+
−
	delete iProxy;+
−
	}+
−
+
−
void CLbsTestNgMessageHandler::ConstructL()+
−
	{+
−
	iProxy = CNetProtocolProxy::NewL(iPmId);+
−
	}+
−
+
−
CLbsTestNgMessageHandler::CLbsTestNgMessageHandler(MLbsTestNgMessageHandler& aObserver, TInt aPmId)+
−
:CActive(CActive::EPriorityStandard),+
−
iObserver(aObserver),+
−
iPmId(aPmId)+
−
	{+
−
	CActiveScheduler::Add(this);+
−
	}+
−
+
−
/* AO RunL method, called when either:+
−
 *  - Message received from the NG+
−
 *  - Timeout occurs (-1000)+
−
 * The message type is returned back to the test.  It then decides whether it should set itself+
−
 *  listening again for another message+
−
 */+
−
void CLbsTestNgMessageHandler::RunL()+
−
	{+
−
	//Callback the test, to let it know a message has been received. The iStatus contains the ID of the message received+
−
	iObserver.OnHandleNGMessage(iPmId, iStatus.Int());+
−
	+
−
	//Check to see whether any requests were made when we were busy completing this request+
−
	if((iRequestTimeout.Count() > 0) && (iStatus.Int() != -1000))+
−
		{+
−
		//Set us off listening again, with the stored timeout value+
−
		WaitForResponseL(iRequestTimeout[0]);+
−
		//This request has been satisfied, remove the timeout value from the array+
−
		iRequestTimeout.Remove(0);+
−
		}+
−
	}+
−
+
−
void CLbsTestNgMessageHandler::DoCancel()+
−
	{+
−
	//Cancel waiting for a message+
−
	iProxy->CancelWait();+
−
	}+
−
+
−
TInt CLbsTestNgMessageHandler::RunError(TInt /*aError*/)+
−
	{+
−
	return KErrNone;+
−
	}+
−
+
−
+
−
/* Sets the NetProtocolProxy off listening for a new message from the NG. This function+
−
 *  does not block, but asynchronously waits for a new message to arrive. It can be called+
−
 *  even when already active, it will remember that a request was made and will re-request+
−
 *  as soon as the first request finishes.+
−
 *  NOTE: If this is called when we are already active, the timeout is not started straightway,+
−
 *  but is stored.  As such, the timeout value will be larger than specified.+
−
 *  +
−
 * @param aTimeOut Specifies the time that should be spent waiting for the message to arrive+
−
 */+
−
void CLbsTestNgMessageHandler::WaitForResponseL(TInt aTimeOut)+
−
	{+
−
	if(!IsActive())+
−
		{+
−
		iProxy->WaitForResponseL(aTimeOut, iStatus);+
−
		SetActive();+
−
		}+
−
	else+
−
		{+
−
		//Remember that a sequence requested we listen for a message when we were busy+
−
		iRequestTimeout.Append(aTimeOut);+
−
		}+
−
	}+
−
+
−
/* Gives direct access to the NetProtocolProxy which allows the test to directly send messages +
−
 * and access elements of the message.  It should not be used for waiting for a message (use+
−
 * WaitForResponseL from this class) +
−
 */+
−
CNetProtocolProxy* CLbsTestNgMessageHandler::ProtocolProxy()+
−
	{+
−
	return iProxy;+
−
	}+
−
+
−
/** Returns the PM ID of the PM that this Network proxy is talking to.+
−
 */+
−
TInt CLbsTestNgMessageHandler::GetPmId()+
−
	{+
−
	return iPmId;+
−
	}+
−