// 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 <es_mbuf.h>

#include "dummynif.h"

#include "dummynifvar.h"

/*

 * Factory functions...

 * Build this file with its factory when you want a normal dummy nif which will

 * echo back udp packets and respond to commands

 */

EXPORT_C CNifFactory* NewInterfaceFactoryL()

	{

	return new(ELeave) CDummyIfFactory;

	}

void CDummyIfFactory::InstallL()

	{

	iDelayPipe.SetLengthL(KDelayQueueSize);

	for(TInt prime = 0; prime < KDelaySlots; ++prime)

		{

		RMBuf* stopper = NULL;

		User::LeaveIfError(iDelayPipe.Add(&stopper));

		}

	if(KDelaySlots > 0)

		{

		iNetDelayTimer = CPeriodic::NewL(50000);	// arbitrary stupid high priority, but we really need to run on our ticks & not get delayed until flow-offs & retransmits

		iNetDelayTimer->Start(KDelayQuantum, KDelayQuantum, TCallBack(CDummyIfFactory::DripCallback, this));

		TCallBack callBack(DripCallback, this);

		}

	}

void CDummyIfFactory::SetDripReceiver(TCallBack aReceiver)

	{

	iDripReceiver = aReceiver;

	}

TInt CDummyIfFactory::DripCallback(TAny* aSelf)

	{

	CDummyIfFactory* self = (CDummyIfFactory*) aSelf;

	if(self->iDripReceiver.iPtr)

		{

		RMBuf* stopper = NULL;

		self->iDelayPipe.Add(&stopper);	// keep the supply of backstops constant

		self->iDripReceiver.CallBack();

		}

	return 0;

	}

RMBuf* CDummyIfFactory::GetDrip()

	{

	RMBuf* next = NULL;

	iDelayPipe.Remove(&next);

	return next;

	}

void CDummyIfFactory::AddDrip(RMBuf* aDrip)

	{

	TInt err = iDelayPipe.Add(&aDrip);

	__ASSERT_ALWAYS(err == 1, User::Panic(_L("DummyIfOver"), 0));

	}

CDummyIfFactory::~CDummyIfFactory()

	{

	delete iNetDelayTimer;

	}

CNifIfBase* CDummyIfFactory::NewInterfaceL(const TDesC& /*aName*/)

	{	

	CDummyIfLink* s = new(ELeave) CDummyIfLink(*this);

	CleanupStack::PushL(s);

	s->TimerConstructL(ESocketTimerPriority);

	CleanupStack::Pop();

	return s;

	}

TInt CDummyIfFactory::Info(TNifIfInfo& aInfo, TInt /*aIndex*/) const

	{

	CDummyIfLink::FillInInfo(aInfo, (TAny*)this);

	return 1;

	}