/*

* Copyright (c) 2010 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:

* implementation for simple NTB build policy

*

*/

/**

@file

@internalComponent

*/

#include "ncmntbbuildsimplepolicy.h"

#include "ncmntbbuilder.h"

#include "ncmpktdrvcommon.h"

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "ncmntbbuildsimplepolicyTraces.h"

#endif

const TInt KMaxPacketsOfNtb = 10;

const TInt KMaxPacketDelay = 1000;

const TInt KMinFreeBuffers = 5;

_LIT(KSimPolicyPanic, "CNcmNtbBuildSimplePolicy");

const TInt KTimerError = 1;

// ======== MEMBER FUNCTIONS ========

//

CNcmNtbBuildPolicy* CNcmNtbBuildSimplePolicy::NewL(CNcmNtbBuilder& aNtbBuilder)

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_NEWL_ENTRY, ( TUint )&( aNtbBuilder ) );

    CNcmNtbBuildSimplePolicy *self=new (ELeave) CNcmNtbBuildSimplePolicy(aNtbBuilder);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    OstTraceFunctionExit0( CNCMNTBBUILDSIMPLEPOLICY_NEWL_EXIT );

    return self;    

    }

CNcmNtbBuildSimplePolicy::CNcmNtbBuildSimplePolicy(CNcmNtbBuilder& aNtbBuilder)

    : CNcmNtbBuildPolicy(aNtbBuilder)

    {

    CActiveScheduler::Add(this);

    }

CNcmNtbBuildSimplePolicy::~CNcmNtbBuildSimplePolicy()

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_CNCMNTBBUILDSIMPLEPOLICY_ENTRY, this );

    Cancel();

    iTimer.Close();

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_CNCMNTBBUILDSIMPLEPOLICY_EXIT, this );

    }

void CNcmNtbBuildSimplePolicy::DoCancel()

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_DOCANCEL_ENTRY, this );

    iTimer.Cancel();

    iPacketsCount = 0;    

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_DOCANCEL_EXIT, this );

    }

void CNcmNtbBuildSimplePolicy::ConstructL()

    {

    User::LeaveIfError(iTimer.CreateLocal());

    }

void CNcmNtbBuildSimplePolicy::RunL()

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_RUNL_ENTRY, this );

    OstTrace1( TRACE_NORMAL, CNCMNTBBUILDSIMPLEPOLICY_RUNL, "CNcmNtbBuildSimplePolicy::RunL Status=%d", iStatus.Int() );

    if(iStatus.Int() != KErrNone)

        {

        User::Panic(KSimPolicyPanic, KTimerError);

        OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_RUNL_EXIT, this );

        return;

        }

    if (iPacketsCount > 0)

        {

        iNtbBuilder.CompleteNtbBuild();

        }

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_RUNL_EXIT_DUP1, this );

    }

void CNcmNtbBuildSimplePolicy::CompleteNtbBuild()

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_COMPLETENTBBUILD_ENTRY, this );

    Cancel();

    iPacketsCount = 0;

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_COMPLETENTBBUILD_EXIT, this );

    }

void CNcmNtbBuildSimplePolicy::StartNewNtb()

    {

    OstTraceFunctionEntry1( CNCMNTBBUILDSIMPLEPOLICY_STARTNEWNTB_ENTRY, this );    

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_STARTNEWNTB_EXIT, this );

    }

void CNcmNtbBuildSimplePolicy::UpdateNtb(TInt aSize)

    {

    OstTraceFunctionEntryExt( CNCMNTBBUILDSIMPLEPOLICY_UPDATENTB_ENTRY, this );

    OstTrace1( TRACE_NORMAL, CNCMNTBBUILDSIMPLEPOLICY_UPDATENTB, "CNcmNtbBuildSimplePolicy::UpdateNtb aSize=%d", aSize );

    if (iPacketsCount == 0)

        {

        iStatus = KRequestPending;

        iTimer.After(iStatus, KMaxPacketDelay);

        SetActive();

        }

    if (KMaxPacketsOfNtb <= ++iPacketsCount && aSize >= iBufferSize/2)

        {

        iNtbBuilder.CompleteNtbBuild();

        }

   else if (iFreeBufferCount >= KMinFreeBuffers && aSize >= iBufferSize/8)

        {

        iNtbBuilder.CompleteNtbBuild();

        }

    OstTraceFunctionExit1( CNCMNTBBUILDSIMPLEPOLICY_UPDATENTB_EXIT, this );

    }

void CNcmNtbBuildSimplePolicy::UpdateBufferSize(TInt aSize)

    {

    iBufferSize = aSize;

    }

void CNcmNtbBuildSimplePolicy::UpdateFreeBufferCount(TInt aCount)

    {

    iFreeBufferCount = aCount;

	}

void CNcmNtbBuildSimplePolicy::UpdateTotalBufferCount(TInt aCount)

    {

    iTotalBufferCount = aCount;

    }