diff -r 14460bf2a402 -r f50f4094acd7 wapstack/wapmessageapi/sws/WapBoundCLPush.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/wapstack/wapmessageapi/sws/WapBoundCLPush.cpp Tue Jul 06 15:36:38 2010 +0300 @@ -0,0 +1,198 @@ +// Copyright (c) 2003-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 "WapBoundCLPush.h" +#include "WapMsgUtils.h" +#include + +CSWSWapBoundCLPushService* CSWSWapBoundCLPushService::NewL() +/** +Static new function +@internalComponent +@released +@since v8.0 +*/ + { + CSWSWapBoundCLPushService* me = new(ELeave)CSWSWapBoundCLPushService(); + CleanupStack::PushL(me); + me->ConstructL(); + CleanupStack::Pop(me); + return me; + } + +CSWSWapBoundCLPushService::~CSWSWapBoundCLPushService() +/** +Destructor +@internalComponent +@released +@since v8.0 +*/ + { + delete iAgent; + } + +CSWSWapBoundCLPushService::CSWSWapBoundCLPushService() +/** +Constructor +@internalComponent +@released +@since v8.0 +*/ + { + } + +void CSWSWapBoundCLPushService::ConstructL() +/** +Second Phase Constructor +@internalComponent +@released +@since v8.0 +*/ + { + // Parent class construction + CWapBoundCLPushService::ConstructL(); + iAgent=CWspMessageApiAgent::NewL(); + } + +TInt CSWSWapBoundCLPushService::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool aSecure, TInetAddr /*aInetAddr*/) +/** +Opens a Wsp EndPoint which is to be used to listen for subsequent incoming Push messages from any sender; +@internalComponent +@released +@since v8.0 +@param aBearer (in) the bearer to listen on (use EAll for all bearers) +@param aPort (in) the port to listen on. If set to 0, a local port will be chosen for the client's first SendTo +@param aSecure (in) security flag indicates whether WTLS will be used or not +@param aInetAddr (in) the address of the adapter to use +@returns TInt KErrNone on successful completion, or one of the system error codes on failure. +*/ + { + if(aSecure) + { + return KErrNotSupported; + } + return iAgent->Connect(aBearer, aPort, aSecure); + } + +TInt CSWSWapBoundCLPushService::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool aSecure) +/** +Opens a socket which is to be used to listen for subsequent incoming Push messages from any sender; +@internalComponent +@released +@since v8.0 +@param aBearer (in) the bearer to listen on (use EAll for all bearers) +@param aPort (in) the port to listen on. If set to 0, a local port will be chosen for the client's first SendTo +@param aSecure (in) security flag indicates whether WTLS will be used or not +@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 CSWSWapBoundCLPushService::AwaitPush(TDes8& aPushHeaders, TDes8& aPushBody, TPckgBuf& aPushIdPckg, TRequestStatus& aReqStatus) +/** +Request an asynchronous notification upon arrival of the next push messages on the listening connection. +The request completes upon receipt of the message, filling the buffers with as much received data as possible. +A return code will indicate whether further data remains. The call must be re-issued for subsequent messages +or to receive remaining data from a previous push message. +@internalComponent +@released +@since v8.0 +@param aPushHeaders (out) (client-allocated) - when a push message arrives the header data is written here +@param aPushBody (out) (client-allocated) - when a push message arrives the body data is written here +@param aPushIdPckg (out) when a push message arrives an integer ID that uniquely specifies the message is written here +@param aReqStatus (inout) used by the service provider to notify the client when a push has arrived. +EMoreData is returned if more pushed data is available +@retval KErrNone on successful completion, or one of the system error codes on failure. +*/ + { + TInt err = iAgent->ReceiveWspMessage(aPushHeaders, aPushBody, aPushIdPckg, iWspStatus, aReqStatus, 0); + if(err == Wap::EMoreData) + { + return KErrNone; + } + return err; + } + +void CSWSWapBoundCLPushService::CancelAwaitPush() +/** +Cancel a previously-requested push message notification. If a push message arrives the client will not be notified. +@internalComponent +@released +@since v8.0 +*/ + { + iAgent->CancelRequest(); + } + +TInt CSWSWapBoundCLPushService::GetLocalPort(Wap::TPort& aPort) +/** +Get the local address of this endpoint. +@internalComponent +@released +@since v8.0 +@param aPort (out) the port of the local host +@returns KErrNone on successful completion, or one of the system error codes on failure. +*/ + { + return iAgent->GetLocalPort(aPort); + } + +TInt CSWSWapBoundCLPushService::GetLocalAddress(HBufC8*& aLocalHost) +/** +Get the local address of this endpoint. +@internalComponent +@released +@since v8.0 +@param aLocalHost (inout) the address of the local host. A reference to a HBufC8 pointer should +be passed in. This pointer MUST be null! A HBufC8 will be allocated to hold the address, ownership +of this buffer will be passed over to the client. +@returns KErrNone on successful completion, or one of the system error codes on failure. +*/ + { + return iAgent->GetLocalAddress(aLocalHost); + } + +TInt CSWSWapBoundCLPushService::GetBearer(Wap::TBearer& aBearer) +/** +Get the bearer on which the push message arrived. +Useful when EAll was specified in Connect() +@internalComponent +@released +@since v8.0 +@param aBearer (out) the bearer +@returns KErrNone on successful completion, or one of the system error codes on failure. +*/ + { + return iAgent->GetBearer(aBearer); + } + +TInt CSWSWapBoundCLPushService::GetServerAddress(HBufC8*& aRemoteHost) +/** +Get the address of the remote server +@internalComponent +@released +@since v8.0 +Cannot be called when there is an outstanding AwaitPush(). +@param aRemoteHost the address of the remote server. +A reference to a HBufC8 pointer should be passed in. An HBufC8 will be allocated +to hold the address ,ownership of this buffer will be passed over to the client. +@returns KErrNone on successful completion, KErrNotSupported if not implemented or one of the system error codes on failure. +*/ + { + return iAgent->GetServerAddress(aRemoteHost); + } +