// Copyright (c) 2000-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 "WapSocketWatcher.h"
#include <watcher.h>

#include <wapmessage.h>
#include <wapmsgerr.h>

//
//CWdpPortWatcher
//

CWdpPortWatcher::CWdpPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, TUint16 aWapPort)
	: CWapPortWatcher(aWatcherLog, aPriority, aBioID, aFs, aWapPort), iRecvPtr(0,0), iDataSize(0), iDataSizePckg(iDataSize)
	{
	}

CWdpPortWatcher::~CWdpPortWatcher()
	{
	Cancel();
	CloseConn();
	}

void CWdpPortWatcher::CloseConn()
	{
	//Close the RWDPConn connection
	delete iWdpConn;
	iWdpConn=NULL;
	iRecvNext = ERecvSize;

	CWapPortWatcher::CloseConn(); //deletes iRecvBuf
	}

void CWdpPortWatcher::DoCancel()
	{
	//Cancel outstanding requests
	if (iWdpConn!=NULL)
		iWdpConn->CancelRecv();

	Complete(KErrCancel);
	}

void CWdpPortWatcher::DoSetupL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWdp: DoSetupL: %S, port %d"), &iBioMsgText, iWapPort));

	//Open the RWDPConn connection on port iWapPort
	iWdpConn = CWapBoundDatagramService::NewL();
	User::LeaveIfError(iWdpConn->Connect(Wap::ESMS,iWapPort));
	iRecvNext = ERecvSize;
	}

void CWdpPortWatcher::WaitForMessageL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWdp: WaitForMessageL: %S, port %d"), &iBioMsgText, iWapPort));

	User::LeaveIfError(iStatus.Int());

	//Wait to receive a WDP message on port iWapPort
	if (iRecvNext == ERecvSize)
		{
		User::LeaveIfError(iWdpConn->AwaitRecvDataSize(iDataSizePckg, iStatus));
		}
	else //iRecvNext == ERecv
		{
		iRecvPtr.Set(iRecvBuf->Des());
		iRecvPtr.Zero();
		iRemoteAddress.Zero();
		// 0 is an infinate time out, as we just got the recieved size we know a message is waiting
		User::LeaveIfError(iWdpConn->RecvFrom(iRemoteAddress,iRemotePort,iRecvPtr,iTruncated,iStatus,0));
		}

	//SetActive() is called by CBaseSmsActiveSocketWatcher::DoRunL()
	}

void CWdpPortWatcher::ReceiveL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWdp: ReceiveL: %S, port %d"), &iBioMsgText, iWapPort));

	//Receive the WAP Message.
	User::LeaveIfError(iStatus.Int());
	if(iTruncated) // should never happen as we ask for the size and allocate the required buffer
		User::Leave(KErrOverflow);

	if (iRecvNext == ERecvSize)
		{
		// iRecvBuf should not currently exist because it is deleted after a message is received (below)
		// or if there is an error (it is deleted by CloseConn())
		__ASSERT_DEBUG(iRecvBuf == NULL, PanicWatcher(EBufferNotNull));
		iRecvBuf = HBufC8::NewL(iDataSizePckg());
		iRecvNext = ERecv;

		TRequestStatus* status = &iStatus;
		User::RequestComplete(status, KErrNone);
		}
	else //iRecvNext == ERecv
		{
		DoReceiveL(iRemoteAddress);
		delete iRecvBuf; // buffer is no longer required.
		iRecvBuf = NULL;
		iRecvNext = ERecvSize;
		}
	}