--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/wapstack/wapmessageapi/sws/WapMessageApiAgent.cpp	Tue Jul 13 14:53:59 2010 +0100
@@ -0,0 +1,1184 @@
+// 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:
+//
+
+#include "WapMessageApiAgent.h"
+#include "WapMsgUtils.h"
+#include "CLWSPPduHandler.h"
+#include <es_wsms.h>
+#include <wapmsgerr.h>
+#include "WapSwsLog.h"
+
+CWapAsyncCallBack::CWapAsyncCallBack( const TCallBack& aCallBack, TInt aPriority )
+:   CActive( aPriority ), iCallBack( aCallBack )
+	{
+	CActiveScheduler::Add( this );
+	}
+
+CWapAsyncCallBack::~CWapAsyncCallBack()
+	{
+	Cancel();
+	}
+
+void CWapAsyncCallBack::CallBack()
+	{
+	if  ( !IsActive() )
+		{
+		TRequestStatus* status = &iStatus;
+		User::RequestComplete( status, KErrNone );
+		SetActive();
+		}
+	}
+
+void CWapAsyncCallBack::RunL()
+	{
+	iCallBack.CallBack();
+	}
+
+void CWapAsyncCallBack::DoCancel()
+	{
+	// Empty - request already completed in CallBack()
+	}
+
+//
+//CWapMessageApiAgent class Method
+//
+CWapMessageApiAgent::CWapMessageApiAgent(TWapMessageType aMessageType):iMessageType(aMessageType)
+/**
+Constuctor.
+@internalComponent
+@released since v8.0
+@param aMessageType the message type that handled by this agent
+*/
+	{
+	}
+
+CWapMessageApiAgent::~CWapMessageApiAgent()
+/**
+Destrutor
+@internalComponent.
+@released since v8.0
+*/
+	{
+	TInt count=iBearers.Count();
+	for (TInt i=0; i<count; i++)
+		{
+		iBearers[i]->Cancel();
+		iBearers[i]->CleanUpData();
+		}
+	iBearers.ResetAndDestroy();
+	iSocketServ.Close();
+	if (iTimeoutTimer)
+		{
+		iTimeoutTimer->Cancel();		
+		delete iTimeoutTimer;
+		}
+	if (iAsyncReadCompletion)
+		{
+		delete iAsyncReadCompletion;
+		}
+	}
+
+TInt CWapMessageApiAgent::CompleteReading(TAny* aAgent)
+	{
+	CWapMessageApiAgent* agent = reinterpret_cast<CWapMessageApiAgent*>(aAgent);
+	return agent->DoCompleteReading();
+	}
+
+TInt CWapMessageApiAgent::DoCompleteReading()
+	{
+	iRequestActive=EFalse;
+	User::RequestComplete(iRequestStatus, iLastReadingError);
+	return KErrNone;
+	}
+void CWapMessageApiAgent::ConstructL()
+/**
+Second Phase Constructor
+@internalComponent.
+@released since v8.0
+*/
+	{
+	iTimeoutTimer = CTimeOutTimer::NewL(*this);
+	TCallBack callback = TCallBack(CompleteReading, this);
+	iAsyncReadCompletion = new (ELeave) CWapAsyncCallBack(callback, CActive::EPriorityHigh);
+	User::LeaveIfError(iSocketServ.Connect());
+ 	}
+
+CActiveSocket* CWapMessageApiAgent::GetActiveSocketByBearer(Wap::TBearer aBearer)
+/**
+To Get the CActiveSocket from the Array by Bearer type. 
+@internalComponent.
+@released since v8.0
+@param aBearer (in)the bearer type of the CActiveSocket
+@returns the pointer of CAtiveSocket
+*/
+	{
+	TInt count=iBearers.Count();
+	for (TInt i=0; i<count; i++)
+		{
+		Wap::TBearer bearer=iBearers[i]->GetBearerType();
+		if (bearer==aBearer)
+			{
+			return iBearers[i];
+			}
+		else
+			{
+			if ((aBearer>=Wap::ESMS7 && aBearer<=Wap::EWAPSMS) && (bearer>=Wap::ESMS7 && bearer<=Wap::EWAPSMS))
+				{
+				return iBearers[i];
+				}
+			}
+		}
+	return NULL;
+	}
+
+CActiveSocket* CWapMessageApiAgent::GetActiveSocketByStatus(TWapMessageState aState)
+/**
+To Get the CActiveSocket from the Array by Data State. 
+@internalComponent.
+@released since v8.0
+@param aState (in)the Data state of the CActiveSocket
+@returns the pointer of CAtiveSocket
+*/
+	{
+	TInt count=iBearers.Count();
+	for (TInt i=0; i<count; i++)
+		{
+		if (iBearers[i]->GetDataState()==aState)
+			{
+			return iBearers[i];
+			}
+		}
+	return NULL;
+	}
+
+void CWapMessageApiAgent::TimerExpired()
+/**
+To handle the receive time out.
+@internalComponent.
+@released since v8.0
+*/
+	{
+	TInt count=iBearers.Count();
+	for (TInt i=0; i<count; i++)
+		{
+		iBearers[i]->Cancel();
+		iBearers[i]->CleanUpData();
+		}
+	iRequestActive=EFalse;
+	User::RequestComplete(iRequestStatus, KErrTimedOut);
+	}
+
+TInt CWapMessageApiAgent::GetLocalPort(Wap::TPort& aLocalPort)
+/**
+To Get local port of the last received packet
+@internalComponent.
+@released since v8.0
+@param aLocalPort (out)the reference of the localPort.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalPort: Trying to GetLocalPort on unconnected API."));)
+		return KErrNotReady;
+		}
+	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);
+	if (!sock)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalPort: Can not find Last Bearer."));)
+		return Wap::EBearerError;
+		}
+	sock->GetLocalPort(aLocalPort);
+	return KErrNone;
+	}
+
+TInt CWapMessageApiAgent::GetLocalAddress(HBufC8*& aLocalHost)
+/**
+To Get local Address of the last received Packet
+@internalComponent.
+@released since v8.0
+@param aLocalHost (out)the reference of the localHost.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Trying to GetLocalAddress on unconnected API."));)
+		return KErrNotReady;
+		}
+	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);
+	if (!sock)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Can not find Last Bearer"));)
+		return Wap::EBearerError;
+		}
+	TSockAddr& localHost=sock->GetLocalAddress();
+	TInt err=KErrNone;
+	TRAP(err, aLocalHost=localHost.AllocL())
+	if (err)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Alloc Memory Err=%d"), err);)
+		}
+	return err;
+	}
+
+TInt CWapMessageApiAgent::GetBearer(Wap::TBearer& aBearer)
+/**
+To Get Bearer of the last received packet
+@internalComponent.
+@released since v8.0
+@param aBearer (out)the reference of the Bearer.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetBearer: Trying to GetBearer on unconnected API."));)
+		return KErrNotReady;
+		}
+	aBearer=iLastPduBearer;
+	return KErrNone;
+	}
+
+TInt CWapMessageApiAgent::GetServerAddress(HBufC8*& aServerHost)
+/**
+To Get Server Host of the last received packet
+@internalComponent.
+@released since v8.0
+@param aServerHost (out)the reference of the Server Host.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetServerAddress: Trying to GetServerAddress on unconnected API."));)
+		return KErrNotReady;
+		}
+	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);
+	if (!sock)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetServerAddress: Can not find last error."));)
+		return Wap::EBearerError;
+		}
+	return sock->GetRemoteAddress(aServerHost);
+	}
+
+void CWapMessageApiAgent::CancelRequest()
+/**
+To Cancel the client's request
+@internalComponent.
+@released since v8.0
+*/
+	{
+	if (iIsOpen)
+		{
+		TInt count=iBearers.Count();
+		for (TInt i=0; i<count; i++)
+			{
+			iBearers[i]->Cancel();
+			iBearers[i]->CleanUpData();
+			}
+		iTimeoutTimer->Cancel();
+		if (iRequestActive)
+			{
+			iRequestActive=EFalse;
+			iAsyncReadCompletion->Cancel();
+			User::RequestComplete(iRequestStatus, KErrCancel);
+			}
+		}
+	}
+
+TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool aSecure)
+/**
+Opening an endpoint that can be used to listen for subsequent incoming datagrams.
+@internalComponent.
+@released since v8.0
+@param aBearer (In) the bearer to listen on
+@param aPort (In) the port to listen on.
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TInetAddr inetAddr( KInetAddrAny, 0);
+	return (Connect(aBearer, aPort, aSecure, inetAddr));
+	}
+
+TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool /*aSecure*/, TInetAddr /*aInetAddr*/)
+/**
+Opening an endpoint that can be used to listen for subsequent incoming datagrams.
+@internalComponent.
+@released since v8.0
+@param aBearer (In) the bearer to listen on
+@param aPort (In) the port to listen on.
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@param aInetAddr (In) Not In Use.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TInt ret=KErrNone;
+	if (!iIsOpen)
+		{
+		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, aPort))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."),ret);)
+			return ret;
+			}
+		iIsOpen=ETrue;
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying Connect twice to the API."));)
+		ret=KErrInUse;
+		}
+	return ret;
+	}
+
+TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool /*aSecure*/, TInt aSocketServHandle, RConnection* aConnection)
+/**
+Opening an endpoint that can be used to listen for subsequent incoming datagrams.
+@internalComponent.
+@released since v8.0
+@param aBearer (In) the bearer to listen on
+@param aPort (In) the port to listen on.
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@param aSocketServHandle (In) The Socket Server ID.
+@param aConnection (In) The RConnection that shared with the client.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (aSocketServHandle==0 || !aConnection)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Parameter Error"));)
+		return KErrArgument;
+		}
+	TInt ret=KErrNone;
+	if (!iIsOpen)
+		{
+		iSocketServ.SetHandle(aSocketServHandle);
+		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, aPort, aConnection))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."), ret);)
+			return ret;
+			}
+		iIsOpen=ETrue;
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying to Connect twice to the API."));)
+		ret=KErrInUse;
+		}
+	return ret;
+	}
+
+TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool /*aSecure*/, TInetAddr /*aInetAddr*/)
+/**
+Opens a socket which is to be used only with a single, named remote host.
+@internalComponent.
+@released since v8.0
+@param aRemoteHost (In) the name of the remote host to connect.
+@param aRemotePort (In) the port of the remote host to connect.
+@param aBearer (In) the bearer to be used
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@param aInetAddr (In) Not In Use
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (aBearer==Wap::EAll)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Connect to EAll Error"));)
+		return Wap::EBearerError;
+		}
+	TInt ret=KErrNone;
+	if (!iIsOpen)
+		{
+		TSockAddr remoteAddr;
+		TRAP(ret, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: BuildAddress err=%d."), ret);)
+			return ret;
+			}
+		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, remoteAddr))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."), ret);)
+			return ret;
+			}
+		iIsOpen=ETrue;
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying to Connect twice to the API."));)
+		ret=KErrInUse;
+		}
+	return ret;
+	}
+
+TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool aSecure)
+/**
+Opens a socket which is to be used only with a single, named remote host.
+@internalComponent.
+@released since v8.0
+@param aRemoteHost (In) the name of the remote host to connect.
+@param aRemotePort (In) the port of the remote host to connect.
+@param aBearer (In) the bearer to be used
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TInetAddr inetAddr( KInetAddrAny, 0);
+	return (Connect(aRemoteHost, aRemotePort, aBearer, aSecure, inetAddr));
+	}
+
+TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool /*aSecure*/, TInt aSocketServHandle, RConnection* aConnection)
+/**
+Opens a socket which is to be used only with a single, named remote host.
+@internalComponent.
+@released since v8.0
+@param aRemoteHost (In) the name of the remote host to connect.
+@param aRemotePort (In) the port of the remote host to connect.
+@param aBearer (In) the bearer to be used
+@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)
+@param aSocketServHandle (In) The Socket Server ID.
+@param aConnection (In) The RConnection that shared with the client.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (aBearer==Wap::EAll)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Connect to EAll Error"));)
+		return Wap::EBearerError;
+		}
+	if (aSocketServHandle==0 || !aConnection)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Parameter Error"));)
+		return KErrArgument;
+		}
+	TInt ret=KErrNone;
+	if (!iIsOpen)
+		{
+		iSocketServ.SetHandle(aSocketServHandle);
+		TSockAddr remoteAddr;
+		TRAP(ret, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: BuildAddress err=%d."),ret);)
+			return ret;
+			}
+		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, remoteAddr, aConnection))
+		if (ret!=KErrNone)
+			{
+			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."),ret);)
+			return ret;
+			}
+		iIsOpen=ETrue;
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Connect to a connected API."));)
+		ret=KErrInUse;
+		}
+	return ret;
+	}
+//
+//CWspMessageApiAgent class Methods
+//
+CWspMessageApiAgent* CWspMessageApiAgent::NewL()
+/**
+Static NEWL()
+@internalComponent
+@released since v8.0
+@returns CWspMessageApiAgent instance.
+*/
+	{
+	CWspMessageApiAgent* me = new(ELeave) CWspMessageApiAgent();
+	CleanupStack::PushL(me);
+	me->ConstructL();
+	CleanupStack::Pop(me);
+	return me;
+	}
+
+CWspMessageApiAgent::CWspMessageApiAgent():CWapMessageApiAgent(EWapWsp)
+/**
+Constructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	}
+
+CWspMessageApiAgent::~CWspMessageApiAgent()
+/**
+Destructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	}
+
+void CWspMessageApiAgent::ConstructL()
+/**
+Second Phase Constructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	CWapMessageApiAgent::ConstructL();
+	}
+
+TInt CWspMessageApiAgent::SendWspMessage(Wap::TBearer aBearer, const TDesC8& aRemoteHost, Wap::TPort aRemotePort, TUint aMethod, const TDesC& aURI, const TDesC8& aReqHeaders, const TDesC8& aReqBody, TUint8 aTransactionId)
+/**
+Send Wsp Message to a remote host
+@internalComponent
+@released since v8.0
+@param aBearer (in) the bearer to be used
+@param aRemoteHost (in) The remote host to be sent.
+@param aRemotePort (in) The remote port to be sent.
+@param aMethod (in) The method to be invoked.
+@param aURI (in) The destination URI.
+@param aReqHeaders (in) The Wsp header of WSP message.
+@param aReqBody (in) The Wsp body of WSP message.
+@param aTransactionId (in) The transaction ID of WSP message.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Tryig to send to unconnected API"));)
+		return KErrNotReady;
+		}
+	if (aBearer==Wap::EAll)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Send to EAll Error"));)
+		return Wap::EBearerError;
+		}
+	HBufC8* sendBuf=NULL;
+	TInt err=KErrNone;
+	TSockAddr remoteAddr;
+	TRAP(err, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))
+	if (err!=KErrNone)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage: BuildAddress err=%d."),err);)
+		return err;
+		}
+	TRAP(err, CCLWSPPduHandler::PackWSPPduL(sendBuf, TWSPPduType(aMethod), aURI, aReqHeaders, aReqBody, aTransactionId))
+	if (err!=KErrNone)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Pack Wsp Packet Error=%d"),err);)
+		return err;
+		}
+	CActiveSocket* sendSock=GetActiveSocketByBearer(aBearer);
+	if (sendSock)
+		{
+		if (aBearer==Wap::ESMS||aBearer==Wap::EWAPSMS)
+			{
+			TWapSmsDataCodingScheme codingScheme = EWapSms8BitDCS;
+			sendSock->Socket().SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,codingScheme);
+			}
+		TRequestStatus status;
+		sendSock->Socket().SendTo(*sendBuf, remoteAddr, 0, status);
+		User::WaitForRequest(status);
+		err=status.Int();
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage: Can not find Bearer"));)
+		err=Wap::EBearerError;
+		}
+	delete sendBuf;
+	return err;
+	}
+
+TInt CWspMessageApiAgent::SendWspMessage(TUint aMethod, const TDesC& aURI, const TDesC8& aReqHeaders, const TDesC8& aReqBody, TUint8 aTransactionId)
+/**
+Send Wsp Message to a remote host for fulluSpecified Interface
+@internalComponent
+@released since v8.0
+@param aMethod (in) The method to be invoked.
+@param aURI (in) The destination URI.
+@param aReqHeaders (in) The Wsp header of WSP message.
+@param aReqBody (in) The Wsp body of WSP message.
+@param aTransactionId (in) The transaction ID of WSP message.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Trying to send to unconnected API"));)
+		return KErrNotReady;
+		}
+	if (!iBearers[0])
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:No Bearer"));)
+		return Wap::EBearerError;
+		}
+	HBufC8* sendBuf=NULL;
+	TInt err=KErrNone;
+	TRAP(err, CCLWSPPduHandler::PackWSPPduL(sendBuf, TWSPPduType(aMethod), aURI, aReqHeaders, aReqBody, aTransactionId))
+	if (err!=KErrNone)
+		{
+		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Pack Wsp Packet Error=%d"),err);)
+		return err;
+		}
+	Wap::TBearer bearer=iBearers[0]->GetBearerType();
+	if (bearer==Wap::ESMS||bearer==Wap::EWAPSMS)
+		{
+		TWapSmsDataCodingScheme codingScheme = EWapSms8BitDCS;
+		iBearers[0]->Socket().SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,codingScheme);
+		}
+	TSockAddr& remoteAddr=iBearers[0]->GetRemoteAddress();
+	TRequestStatus status;
+	iBearers[0]->Socket().SendTo(*sendBuf, remoteAddr, 0, status);
+	User::WaitForRequest(status);
+	delete sendBuf;
+	return status.Int();
+	}
+
+TInt CWspMessageApiAgent::ReceiveWspMessage(TDes8& aWspHeaders, TDes8& aWspBody, TPckgBuf<TUint8>& aTransactionIdPckg, TWSPStatus& aWspStatus, TRequestStatus& aReqStatus, TUint32 aTimeout)
+/**
+Receive the Wsp Message to a remote host for fulluSpecified Interface
+@internalComponent
+@released since v8.0
+@param aWspHeaders (out) The Wsp header to be received
+@param aWspBody (out) The Wsp body to be received.
+@param aTransactionIdPckg (out) The received transaction ID buffer
+@param aWspStatus (out) The Wsp status for Method Result.
+@param aReqStatus (out) The request status of the WAP message API
+@param aTimeout (in) The timer out value.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TRequestStatus* reqStatus=NULL;
+	if (!iIsOpen)
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrNotReady);
+		LOG(SwsLog::Printf(_L("CWspMessageApiAgent::ReceiveWspMessage: Trying to recvive from unconnected API"));)
+		return KErrNotReady;
+		}
+	if (iRequestActive)
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrInUse);
+		LOG(SwsLog::Printf(_L("CWspMessageApiAgent::ReceiveWspMessage:Outstanding Receive exist"));)
+		return KErrInUse;
+		}
+	//Record the client buffer
+	iClientReqHeaders=&aWspHeaders;
+	iClientReqBody=&aWspBody;
+	iClientTransactionId=(TUint8*)aTransactionIdPckg.Ptr();
+	iClientWspStatus=&aWspStatus;
+	//if there are data are being reading
+	CActiveSocket* readingSock=GetActiveSocketByStatus(EReading);
+	if (readingSock)
+		{
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		iRequestActive=ETrue;
+		iLastReadingError=readingSock->GetWspData(*iClientReqHeaders, *iClientReqBody, *iClientTransactionId, *iClientWspStatus);
+		if (iLastReadingError==KErrNone)
+			{
+			iLastPduBearer=readingSock->GetBearerType();
+			}
+		iAsyncReadCompletion->CallBack();
+		return iLastReadingError;
+		}
+	//if there are pending data.
+	CActiveSocket* pendingSock=GetActiveSocketByStatus(EPendingData);
+	if (pendingSock)
+		{
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		iRequestActive=ETrue;
+		iLastReadingError=pendingSock->GetWspData(*iClientReqHeaders, *iClientReqBody, *iClientTransactionId, *iClientWspStatus);
+		if (iLastReadingError==KErrNone)
+			{
+			iLastPduBearer=pendingSock->GetBearerType();
+			}
+		iAsyncReadCompletion->CallBack();
+		return iLastReadingError;
+		}
+	// Issue request in Idle socket
+	CActiveSocket* sock=GetActiveSocketByStatus(EIdle);
+	if (sock)
+		{
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		iRequestActive=ETrue;
+		for (TInt i=0; i<iBearers.Count(); i++)
+			{
+			if (iBearers[i]->GetDataState()==EIdle)
+				{
+				iBearers[i]->AwaitRecvDataSize();
+				}
+			}
+		if (aTimeout>0)
+			{
+			iTimeoutTimer->After(aTimeout);
+			}
+		}
+	return KErrNone;
+	}
+
+void CWspMessageApiAgent::Notification(TInt aMessage, const TDesC8& aData)
+/**
+Notification of PDU size or PDU data
+@internalComponent
+@released since v8.0
+@param aMessage (in) The Event Type received by the ActiveSocket
+@param aData (in)The Event received by the ActiveSocket.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification is called"));)
+	TWapNotificationInfo& info=*(reinterpret_cast<TWapNotificationInfo*>(const_cast<TUint8*>(aData.Ptr())));
+	Wap::TBearer bearer=info.iBearer;
+	CActiveSocket* currentSocket=GetActiveSocketByBearer(bearer);
+	ASSERT(currentSocket!=NULL);
+	if (!currentSocket)
+		{
+		return;
+		}
+	TInt err=info.iError;		
+	switch (TWapNotificationEvent(aMessage))
+		{
+	case EPduLengthReceived:
+			{
+			if (err!=KErrNone)
+				{
+				LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification PDU length err status:%d"), err);)
+				currentSocket->CleanUpData();
+				if (iRequestActive)
+					{
+					iTimeoutTimer->Cancel();
+					User::RequestComplete(iRequestStatus, err);
+					iRequestActive=EFalse;
+					}
+				}
+			else
+				{
+				LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification PDU length is received"));)
+				if ((err=currentSocket->Receive())!=KErrNone)
+					{
+					currentSocket->CleanUpData();
+					if (iRequestActive)
+						{
+						iTimeoutTimer->Cancel();
+						User::RequestComplete(iRequestStatus, err);
+						iRequestActive=EFalse;
+						}
+					}
+				}
+			break;
+			}
+	case EPduReceived:
+			{
+			CActiveSocket* sock=GetActiveSocketByStatus(EReading);
+			if (err!=KErrNone)
+				{
+				LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification PDU data is received with Err status:%d"), err);)
+				currentSocket->CleanUpData();
+				if (iRequestActive && !sock)
+					{
+					iTimeoutTimer->Cancel();
+					User::RequestComplete(iRequestStatus, err);
+					iRequestActive=EFalse;
+					}
+				}
+			else
+				{
+				LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification PDU data is received"));)
+				if (!sock && iRequestActive)
+					{
+					iTimeoutTimer->Cancel();
+					iRequestActive=EFalse;
+					TRAP(err, currentSocket->UnpackPduToWspDataL())
+					if (err)
+						{
+						currentSocket->CleanUpData();
+						User::RequestComplete(iRequestStatus, err);
+						return;
+						}
+					err=currentSocket->GetWspData(*iClientReqHeaders, *iClientReqBody, *iClientTransactionId, *iClientWspStatus);
+					if (err==KErrNone)
+						iLastPduBearer=bearer;
+					User::RequestComplete(iRequestStatus, err);
+					}
+				}
+			break;
+			}
+	default:
+		LOG(SwsLog::Printf(_L("CWspMessageApiAgent::Notification() Unknown Event From Bearer"));)
+		;	
+		}
+	}
+
+//
+//CWdpMessageApiAgent class Method
+//
+CWdpMessageApiAgent* CWdpMessageApiAgent::NewL()
+/**
+The static funtion to new a wdp message API agent
+@internalComponent
+@released since v8.0
+@returns the CWdpMessageApiAgent instance
+*/
+	{
+	CWdpMessageApiAgent* me = new(ELeave) CWdpMessageApiAgent();
+	CleanupStack::PushL(me);
+	me->ConstructL();
+	CleanupStack::Pop(me);
+	return me;
+	}
+
+CWdpMessageApiAgent::CWdpMessageApiAgent():CWapMessageApiAgent(EWapWdp)
+/**
+Constructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	}
+
+CWdpMessageApiAgent::~CWdpMessageApiAgent()
+/**
+Destructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	}
+
+void CWdpMessageApiAgent::ConstructL()
+/**
+Second Phase Constructor
+@internalComponent
+@released since v8.0
+*/
+	{
+	CWapMessageApiAgent::ConstructL();
+	}
+
+TInt CWdpMessageApiAgent::ReceiveWdpMessage(TDes8& aRemoteHost, Wap::TPort& aRemotePort, TDes8& aBuffer, TBool& aTruncated, TRequestStatus& aReqStatus, TUint32 aTimeout)
+/**
+Receive WDP message from a remote host
+@internalComponent
+@released since v8.0
+@param aRemoteHost (out) the remote host from which the WDP is sent
+@param aRemotePort (out) the remote port from which the WDP is sent
+@param aBuffer (out) the buffer to contain the received the WDP pdu
+@param aTruncated (out) the flag to show if the WDP PDU is trucated ot not
+@param aReqStatus (out) the client request status.
+@param aTimeOut (in) the time out value
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TRequestStatus* reqStatus=NULL;
+	TInt err=KErrNone;
+	if (!iIsOpen)
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrNotReady);
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::ReceiveWdpMessage:Recv From unconnected API"));)
+		return KErrNotReady;
+		}
+	//if the length has been read
+	CActiveSocket* sock=GetActiveSocketByStatus(EGotLength);
+	CActiveSocket* sock1=GetActiveSocketByStatus(EReading);
+	if (iRequestActive || (!sock && !sock1))
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrInUse);
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::ReceiveWdpMessage:in wrong state"));)
+		return KErrInUse;
+		}
+	if (sock1)
+		{
+		Wap::TBearer bearer=sock1->GetBearerType();
+		TSockAddr& remoteAddr=sock1->GetRemoteAddress();
+		TRAP(err, CSWSWapMsgUtils::AnalyseAddrL(remoteAddr, bearer, *iClientRemoteHost, *iClientRemotePort))
+		if (err)
+			{
+			reqStatus=&aReqStatus;
+			User::RequestComplete(reqStatus, err);
+			return err;
+			}
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		iRequestActive=ETrue;
+		iLastReadingError=sock1->GetPduData(*iClientPduBuffer, *iClientTruncated);
+		if (!iLastReadingError)
+			{
+			iLastPduBearer=bearer;
+			}
+		iAsyncReadCompletion->CallBack();
+		return iLastReadingError;
+		}
+	if (sock)
+		{
+		if ((err=sock->Receive())==KErrNone)
+			{
+			iClientPduBuffer=&aBuffer;
+			iClientRemoteHost=&aRemoteHost;
+			iClientRemotePort=&aRemotePort;
+			iClientTruncated=&aTruncated;
+			iRequestStatus=&aReqStatus;
+			*iRequestStatus = KRequestPending;
+			iRequestActive=ETrue;		
+			if (aTimeout)
+				{
+				iTimeoutTimer->After(aTimeout);
+				}
+			}
+		else
+			{
+			reqStatus=&aReqStatus;
+			User::RequestComplete(reqStatus, err);
+			LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::ReceiveWdpMessage:err=%d"), err);)
+			return err;
+			}
+		}
+	return KErrNone;
+	}
+
+TInt CWdpMessageApiAgent::AwaitRecvDataSize(TPckg<TUint16>& aDataSizePckg, TRequestStatus& aReqStatus)
+/**
+Receive WDP message PDU length from a remote host
+@internalComponent
+@released since v8.0
+@param aDataSizePckg (out) the length of the PDU
+@param aReqStatus (out) the client request status.
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TRequestStatus* reqStatus=NULL;
+	if (!iIsOpen)
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrNotReady);
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::AwaitRecvDataSize:Wait For Data length From unconnected API"));)
+		return KErrNotReady;
+		}
+	//if the length has been read or there is some data pending, then error completion
+	CActiveSocket* sock=GetActiveSocketByStatus(EGotLength);
+	CActiveSocket* sock1=GetActiveSocketByStatus(ERequestingData);
+	CActiveSocket* sock2=GetActiveSocketByStatus(EReading);
+	if (iRequestActive||sock||sock1||sock2)
+		{
+		reqStatus=&aReqStatus;
+		User::RequestComplete(reqStatus, KErrInUse);
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::AwaitRecvDataSize:in wrong state"));)
+		return KErrInUse;
+		}
+	//if there is a pending length, then get it
+	sock=GetActiveSocketByStatus(EPendingLength);
+	if (sock)
+		{
+		iClientDataSize=&aDataSizePckg;
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		iRequestActive=ETrue;
+		TUint16 length=(TUint16)sock->GetPduSize();
+		TPckg<TUint16> des(length);
+		iClientDataSize->Copy(des);
+		iLastReadingError=KErrNone;
+		iAsyncReadCompletion->CallBack();
+		return KErrNone;
+		}
+	//if there is some idle socket, then wait for length
+	sock=GetActiveSocketByStatus(EIdle);
+	if (sock)
+		{
+		iRequestActive=ETrue;
+		iClientDataSize=&aDataSizePckg;
+		iRequestStatus=&aReqStatus;
+		*iRequestStatus = KRequestPending;
+		//Wait for length on the idle socket
+		for (TInt i=0; i<iBearers.Count(); i++)
+			{
+			if (iBearers[i]->GetDataState()==EIdle)
+				{
+				iBearers[i]->AwaitRecvDataSize();
+				}
+			}
+		}
+	return KErrNone;
+	}
+
+TInt CWdpMessageApiAgent::SendWdpMessage(const TDesC8& aBuffer, const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer)
+/**
+Send WDP message to a remote host
+@internalComponent
+@released since v8.0
+@param aBuffer (in) the data to be sent
+@param aRemoteHost (in) the remote host to be sent
+@param aRemotePort (in) the remote port to be sent
+@param aBearer (in) the Bearer to be used
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:Send WDP to unconnected API"));)
+		return KErrNotReady;
+		}
+	if (aBearer==Wap::EAll)
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:Wrong Bearer"));)
+		return Wap::EBearerError;
+		}
+	TSockAddr remoteAddr;
+	TInt err=KErrNone;
+	TRAP(err, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))
+	if (err)
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:BuildAddrL Err=%d"), err);)
+		return err;
+		}
+	CActiveSocket* sendSock=GetActiveSocketByBearer(aBearer);
+	if (sendSock)
+		{
+		if (aBearer==Wap::ESMS||aBearer==Wap::EWAPSMS)
+			{
+			TWapSmsDataCodingScheme codingScheme = EWapSms8BitDCS;
+			sendSock->Socket().SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,codingScheme);
+			}
+		TRequestStatus status;
+		sendSock->Socket().SendTo(aBuffer, remoteAddr, 0, status);
+		User::WaitForRequest(status);
+		err=status.Int();
+		}
+	else
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:No Bearer"));)
+		err=Wap::EBearerError;
+		}
+	return err;
+	}
+
+TInt CWdpMessageApiAgent::SendWdpMessage(const TDesC8& aBuffer)
+/**
+Send WDP message to a remote host
+@internalComponent
+@released since v8.0
+@param aBuffer (in) the data to be sent
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	if (!iIsOpen)
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:Send WDP to unconnected API"));)
+		return KErrNotReady;
+		}
+	if (!iBearers[0])
+		{
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::SendWdpMessage:No Bearer"));)
+		return Wap::EBearerError;
+		}
+	Wap::TBearer bearer=iBearers[0]->GetBearerType();
+	if (bearer==Wap::ESMS||bearer==Wap::EWAPSMS)
+		{
+		TWapSmsDataCodingScheme codingScheme = EWapSms8BitDCS;
+		iBearers[0]->Socket().SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,codingScheme);
+		}
+	TSockAddr& remoteAddr=iBearers[0]->GetRemoteAddress();
+	TRequestStatus status;
+	iBearers[0]->Socket().SendTo(aBuffer, remoteAddr, 0, status);
+	User::WaitForRequest(status);
+	return status.Int();
+	}
+
+void CWdpMessageApiAgent::Notification(TInt aMessage, const TDesC8& aData)
+/**
+Notification from the ActiveSocket
+@internalComponent
+@released since v8.0
+@param aMessage (in) the Event Type
+@param aData (in) the Event
+@returns KErrNone on successful completion, or one of the system error codes on failure.
+*/
+	{
+	TWapNotificationInfo& info=*(reinterpret_cast<TWapNotificationInfo*>(const_cast<TUint8*>(aData.Ptr())));
+	Wap::TBearer bearer=info.iBearer;
+	CActiveSocket* currentSocket=GetActiveSocketByBearer(bearer);
+	ASSERT(currentSocket!=NULL);
+	if (!currentSocket)
+		{
+		return;
+		}
+	TInt err=info.iError;		
+	switch (TWapNotificationEvent(aMessage))
+		{
+	case EPduLengthReceived:
+			{
+			CActiveSocket* sock1=GetActiveSocketByStatus(ERequestingData);
+			CActiveSocket* sock2=GetActiveSocketByStatus(EGotLength);
+			CActiveSocket* sock3=GetActiveSocketByStatus(EReading);
+			if (!sock1 && !sock2 && !sock3 && iRequestActive)
+				// Read pdu length from this socket
+				{
+				iRequestActive=EFalse;
+				if (err==KErrNone)
+					{
+					TUint16 length=(TUint16)currentSocket->GetPduSize();
+					TPckg<TUint16> des(length);
+					iClientDataSize->Copy(des);	
+					}
+				else
+					{
+					currentSocket->CleanUpData();
+					}
+				User::RequestComplete(iRequestStatus, err);
+				}
+			break;
+			}
+	case EPduReceived:
+			{
+			ASSERT(iRequestActive);
+			if (iRequestActive)
+				{
+				// Read pdu from this socket
+				iRequestActive=EFalse;
+				iTimeoutTimer->Cancel();
+				if (err==KErrNone)
+					{
+					TSockAddr& remoteAddr=currentSocket->GetRemoteAddress();
+					TRAP(err, CSWSWapMsgUtils::AnalyseAddrL(remoteAddr, bearer, *iClientRemoteHost, *iClientRemotePort))
+					if (!err)
+						{
+						err=currentSocket->GetPduData(*iClientPduBuffer, *iClientTruncated);
+						if (!err)
+							iLastPduBearer=bearer;
+						}
+					else
+						{
+						currentSocket->SetDataState(EReading);
+						}
+					}
+				else
+					{
+					currentSocket->CleanUpData();
+					}
+				User::RequestComplete(iRequestStatus, err);
+				}
+			}
+		break;
+	default:
+		LOG(SwsLog::Printf(_L("CWdpMessageApiAgent::Notification() Unknown Event From Bearer"));)
+		;
+		}
+	}