--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/wapstack/wapmessageapi/sws/WapMessageApiAgent.cpp Tue Apr 20 17:00:49 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"));)
+ ;
+ }
+ }