// DynamicDfcSupport.cpp

// 

// Copyright (c) 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the "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:

// Accenture - Initial contribution

//

#include "DynamicDfcSupport.h"

#ifdef FSHELL_DYNAMICDFC_SUPPORT

TInt TDynDfcQueWrapper::Create(TDynDfcQueWrapper*& aDfcQ, TInt aPriority, const TDesC& aBaseName)

	{

	TDynDfcQueWrapper* wrapper = new TDynDfcQueWrapper;

	if (!wrapper) return KErrNoMemory;

	TInt err = Kern::DynamicDfcQCreate(wrapper->iQueue, aPriority, aBaseName);

	if (err)

		{

		delete wrapper;

		}

	else

		{

		aDfcQ = wrapper;

		}

	return err;

	}

void TDynDfcQueWrapper::Destroy()

	{

	delete this;

	}

TDynDfcQueWrapper::TDynDfcQueWrapper()

	: iQueue(NULL)

	{}

TDynDfcQueWrapper::~TDynDfcQueWrapper()

	{

	iQueue->Destroy();

	}

#else

TDynDfcQueWrapper::TDynDfcQueWrapper()

	: iQueue(NULL), iKillDfc(ExitDfcThread, this, 7)

	{}

TInt TDynDfcQueWrapper::Create(TDynDfcQueWrapper*& aDfcQ, TInt aPriority, const TDesC& aBaseName)

	{

	TDynDfcQueWrapper* wrapper = new TDynDfcQueWrapper;

	TInt nonce = 0;

	TInt ret;

	do

		{

		TBuf<64> buf;

		buf.Copy(aBaseName);

		buf.Append('-');

		buf.AppendNum(nonce);

		nonce++;

		ret = Kern::DfcQCreate(wrapper->iQueue, aPriority, &buf);

		} while (ret == KErrAlreadyExists);

	if (ret == KErrNone)

		{

		wrapper->iKillDfc.SetDfcQ(wrapper->iQueue);

		aDfcQ = wrapper;

		}

	return ret;

	}

void TDynDfcQueWrapper::Destroy()

	{

	iKillDfc.Enque(); 

	}

TDynDfcQueWrapper::~TDynDfcQueWrapper()

	{

	delete iQueue;

	}

void TDynDfcQueWrapper::ExitDfcThread(TAny* aSelf)

	{

	delete (TDynDfcQueWrapper*)aSelf;

	Kern::Exit(KErrNone);

	}

#endif