// Copyright (c) 2005-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:

// secpolreader.cpp - IPSec event message reader

//

#include <es_sock.h>

#include <in_sock.h>

#include "secpolreader.h"

#include "ipsecpolmanhandler.h"

//

// CSecpolReader::CSecpolReader

//

CSecpolReader::CSecpolReader(CIPSecPolicyManagerHandler *control)

: CActive(1), iControl(control)

    {

    CActiveScheduler::Add(this);

    }

//

// CSecpolReader::~CSecpolReader

//

CSecpolReader::~CSecpolReader()

    {

    if (IsActive())

        Cancel();

    iSocket.Close();

    }

//

// CSecpolReader::Construct()

//  Open and activate the socket input

//

TInt CSecpolReader::Construct(const TDesC &aSocket)

    {

    TInt err;

    TInetAddr addr;

    err = iSocket.Open(iControl->iSS,aSocket);

    if( err != KErrNone )

	return err;

    addr.SetAddress(KInetAddrNone);

    addr.SetPort(0);

    err = iSocket.Bind(addr);

    if( err != KErrNone )

	return err;

    iSocket.LocalName(addr);

    iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);

    SetActive();

    return err;

    }

//

// CSecpolReader::RunL

//  Called when request completed

//

void CSecpolReader::RunL()

    {

    //    DEB(TBuf<1000> str;)

    //    DEB(TBuf<40> buf;)

    //  TPayload packet(iMsg.Ptr());

    iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);  // start a new read

    SetActive();

    }

//

// CSecpolReader::DoCancel

//  Called when a pending request should be cancelled

//

void CSecpolReader::DoCancel()

    {

    iSocket.CancelRecv();

    }

//

// CSecpolReader::RunError

// Called when RunL() leaves 

//

TInt CSecpolReader::RunError(TInt /*aError*/)

    {

    iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);  // start a new read 

    SetActive();

    return KErrNone; // Active scheduler Error() method NOT called              

    }