// Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

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

// e32\drivers\dmapil.cpp

// DMA Platform Independent Layer (PIL)

// 

//

#include <drivers/dma.h>

#include <kernel/kern_priv.h>

static const char KDmaPanicCat[] = "DMA";

NFastMutex DmaChannelMgr::Lock;

class TDmaCancelInfo : public SDblQueLink

	{

public:

	TDmaCancelInfo();

	void Signal();

public:

	NFastSemaphore iSem;

	};

TDmaCancelInfo::TDmaCancelInfo()

	:	iSem(0)

	{

	iNext = this;

	iPrev = this;

	}

void TDmaCancelInfo::Signal()

	{

	TDmaCancelInfo* p = this;

	FOREVER

		{

		TDmaCancelInfo* next = (TDmaCancelInfo*)p->iNext;

		if (p!=next)

			p->Deque();

		NKern::FSSignal(&p->iSem);	// Don't dereference p after this

		if (p==next)

			break;

		p = next;

		}

	}

//////////////////////////////////////////////////////////////////////////////

#ifdef __DMASIM__

#ifdef __WINS__

typedef TLinAddr TPhysAddr;

#endif

static inline TPhysAddr LinToPhys(TLinAddr aLin) {return aLin;}

#else

static inline TPhysAddr LinToPhys(TLinAddr aLin) {return Epoc::LinearToPhysical(aLin);}

#endif

//

// Return minimum of aMaxSize and size of largest physically contiguous block

// starting at aLinAddr.

//

static TInt MaxPhysSize(TLinAddr aLinAddr, const TInt aMaxSize)

	{

	const TPhysAddr physBase = LinToPhys(aLinAddr);

	TLinAddr lin = aLinAddr;

	TInt size = 0;

	for (;;)

		{

		// Round up the linear address to the next MMU page boundary

		const TLinAddr linBoundary = Kern::RoundToPageSize(lin + 1);

		size += linBoundary - lin;

		if (size >= aMaxSize)

			return aMaxSize;

		if ((physBase + size) != LinToPhys(linBoundary))

			return size;

		lin = linBoundary;

		}

	}

//////////////////////////////////////////////////////////////////////////////

// TDmac

TDmac::TDmac(const SCreateInfo& aInfo)

	: iMaxDesCount(aInfo.iDesCount),

	  iAvailDesCount(aInfo.iDesCount),

	  iDesSize(aInfo.iDesSize),

	  iCaps(aInfo.iCaps)

	{

	__DMA_ASSERTD(iMaxDesCount > 0);

	__DMA_ASSERTD((iCaps & ~KCapsBitHwDes) == 0); // undefined bits set?

	__DMA_ASSERTD(iDesSize > 0);

	}

//

// Second-phase c'tor

//

TInt TDmac::Create(const SCreateInfo& aInfo)

	{

	iHdrPool = new SDmaDesHdr[iMaxDesCount];

	if (iHdrPool == NULL)

		return KErrNoMemory;

	TInt r = AllocDesPool(aInfo.iDesChunkAttribs);

	if (r != KErrNone)

		return KErrNoMemory;

	// Link all descriptor headers together on the free list

	iFreeHdr = iHdrPool;

	TInt i;

	for (i = 0; i < iMaxDesCount - 1; i++)

		iHdrPool[i].iNext = iHdrPool + i + 1;

	iHdrPool[iMaxDesCount-1].iNext = NULL;

	__DMA_INVARIANT();

	return KErrNone;

	}

TDmac::~TDmac()

	{

	__DMA_INVARIANT();

	FreeDesPool();

	delete[] iHdrPool;

	}

// Calling thread must be in CS

TInt TDmac::AllocDesPool(TUint aAttribs)

	{

	TInt r;

	if (iCaps & KCapsBitHwDes)

		{

		TInt size = iMaxDesCount*iDesSize;

#ifdef __WINS__

		(void)aAttribs;

		iDesPool = new TUint8[size];

		r = iDesPool ? KErrNone : KErrNoMemory;

#else

		// Chunk not mapped as supervisor r/w user none? incorrect mask passed by PSL

		__DMA_ASSERTD((aAttribs & EMapAttrAccessMask) == EMapAttrSupRw);

		TPhysAddr phys;

		r = Epoc::AllocPhysicalRam(size, phys);

		if (r == KErrNone)

			{

			r = DPlatChunkHw::New(iHwDesChunk, phys, size, aAttribs);

			if (r == KErrNone)

				{

				iDesPool = (TAny*)iHwDesChunk->LinearAddress();

				__KTRACE_OPT(KDMA, Kern::Printf("descriptor hw chunk created lin=0x%08X phys=0x%08X, size=0x%X",

												iHwDesChunk->iLinAddr, iHwDesChunk->iPhysAddr, size));

				}

			else

				Epoc::FreePhysicalRam(phys, size);

			}

#endif

		}

	else

		{

		iDesPool = new SDmaPseudoDes[iMaxDesCount];

		r = iDesPool ? KErrNone : KErrNoMemory;

		}

	return r;

	}

// Calling thread must be in CS

void TDmac::FreeDesPool()

	{

	if (iCaps & KCapsBitHwDes)

		{

#ifdef __WINS__

		delete[] iDesPool;

#else

		if (iHwDesChunk)

			{

			TPhysAddr phys = iHwDesChunk->PhysicalAddress();

			TInt size = iHwDesChunk->iSize;

			iHwDesChunk->Close(NULL);

			Epoc::FreePhysicalRam(phys, size);

			}

#endif

		}

	else

		Kern::Free(iDesPool); 

	}

/**

 Prealloc the given number of descriptors.

 */

TInt TDmac::ReserveSetOfDes(TInt aCount)

	{

	__KTRACE_OPT(KDMA, Kern::Printf(">TDmac::ReserveSetOfDes count=%d", aCount));

	__DMA_ASSERTD(aCount > 0);

	TInt r = KErrTooBig;

	Wait();

	if (iAvailDesCount - aCount >= 0)

		{

		iAvailDesCount -= aCount;

		r = KErrNone;

		}

	Signal();

	__DMA_INVARIANT();

	__KTRACE_OPT(KDMA, Kern::Printf("<TDmac::ReserveSetOfDes r=%d", r));

	return r;

	}

/**

 Return the given number of preallocated descriptors to the free pool.

 */

void TDmac::ReleaseSetOfDes(TInt aCount)

	{

	__DMA_ASSERTD(aCount >= 0);

	Wait();

	iAvailDesCount += aCount;

	Signal();

	__DMA_INVARIANT();

	}

/**

 Queue DFC and update word used to communicate with DFC.

 Called in interrupt context by PSL.

 */

void TDmac::HandleIsr(TDmaChannel& aChannel, TBool aIsComplete)

	{

	//__KTRACE_OPT(KDMA, Kern::Printf("TDmac::HandleIsr channel=%d complete=%d", aChannelIdx, aIsComplete));

	// Queue DFC if necessary.  The possible scenarios are:

	// * no DFC queued --> need to queue DFC

	// * DFC queued (not running yet) --> just need to update iIsrDfc

	// * DFC running / iIsrDfc already reset --> need to requeue DFC

	// * DFC running /  iIsrDfc not reset yet --> just need to update iIsrDfc

	// Set error flag if necessary.

	TUint32 inc = aIsComplete ? 1u : TUint32(TDmaChannel::KErrorFlagMask)|1u;

	TUint32 orig = __e32_atomic_tau_ord32(&aChannel.iIsrDfc, TUint32(TDmaChannel::KCancelFlagMask), 0, inc);

	// As transfer should be suspended when an error occurs, we

	// should never get there with the error flag already set.

	__DMA_ASSERTD((orig & inc & (TUint32)TDmaChannel::KErrorFlagMask) == 0);

	if (orig == 0)

		aChannel.iDfc.Add();

	}

void TDmac::InitDes(const SDmaDesHdr& aHdr, TUint32 aSrc, TUint32 aDest, TInt aCount,

					TUint aFlags, TUint32 aPslInfo, TUint32 aCookie)

	{

 	if (iCaps & KCapsBitHwDes)

		InitHwDes(aHdr, aSrc, aDest, aCount, aFlags, aPslInfo, aCookie);

	else

		{

		SDmaPseudoDes& des = HdrToDes(aHdr);

		des.iSrc = aSrc;

		des.iDest = aDest;

		des.iCount = aCount;

		des.iFlags = aFlags;

		des.iPslInfo = aPslInfo;

		des.iCookie = aCookie;

		}

	}

void TDmac::InitHwDes(const SDmaDesHdr& /*aHdr*/, TUint32 /*aSrc*/, TUint32 /*aDest*/, TInt /*aCount*/,

					  TUint /*aFlags*/, TUint32 /*aPslInfo*/, TUint32 /*aCookie*/)

	{

	// concrete controller must override if KCapsBitHwDes set

	__DMA_CANT_HAPPEN();

	}

void TDmac::ChainHwDes(const SDmaDesHdr& /*aHdr*/, const SDmaDesHdr& /*aNextHdr*/)

	{

	// concrete controller must override if KCapsBitHwDes set

	__DMA_CANT_HAPPEN();

	}

void TDmac::AppendHwDes(const TDmaChannel& /*aChannel*/, const SDmaDesHdr& /*aLastHdr*/,

						const SDmaDesHdr& /*aNewHdr*/)

	{

 	// concrete controller must override if KCapsBitHwDes set

	__DMA_CANT_HAPPEN();

	}

void TDmac::UnlinkHwDes(const TDmaChannel& /*aChannel*/, SDmaDesHdr& /*aHdr*/)

	{

 	// concrete controller must override if KCapsBitHwDes set

	__DMA_CANT_HAPPEN();

	}

TInt TDmac::FailNext(const TDmaChannel& /*aChannel*/)

	{

	return KErrNotSupported;

	}

TInt TDmac::MissNextInterrupts(const TDmaChannel& /*aChannel*/, TInt /*aInterruptCount*/)

	{

	return KErrNotSupported;

	}

TInt TDmac::Extension(TDmaChannel& /*aChannel*/, TInt /*aCmd*/, TAny* /*aArg*/)

	{

	// default implementation - NOP

	return KErrNotSupported;

	}

#ifdef _DEBUG

void TDmac::Invariant()

	{

	Wait();

	__DMA_ASSERTD(0 <= iAvailDesCount && iAvailDesCount <= iMaxDesCount);

	__DMA_ASSERTD(! iFreeHdr || IsValidHdr(iFreeHdr));

	for (TInt i = 0; i < iMaxDesCount; i++)

		__DMA_ASSERTD(iHdrPool[i].iNext == NULL || IsValidHdr(iHdrPool[i].iNext));

	Signal();

	}

TBool TDmac::IsValidHdr(const SDmaDesHdr* aHdr)

	{

	return (iHdrPool <= aHdr) && (aHdr < iHdrPool + iMaxDesCount);

	}

#endif

//////////////////////////////////////////////////////////////////////////////

// DDmaRequest

EXPORT_C DDmaRequest::DDmaRequest(TDmaChannel& aChannel, TCallback aCb, TAny* aCbArg, TInt aMaxTransferSize)

	: iChannel(aChannel),

	  iCb(aCb),

	  iCbArg(aCbArg),

	  iMaxTransferSize(aMaxTransferSize)

	{

	// iDesCount = 0;

	// iFirstHdr = iLastHdr = NULL;

	// iQueued = EFalse;

	iChannel.iReqCount++;

	__DMA_INVARIANT();

	}

EXPORT_C DDmaRequest::~DDmaRequest()

	{

	__DMA_ASSERTD(!iQueued);

	__DMA_INVARIANT();

	FreeDesList();

	iChannel.iReqCount--;

	}

EXPORT_C TInt DDmaRequest::Fragment(TUint32 aSrc, TUint32 aDest, TInt aCount, TUint aFlags, TUint32 aPslInfo)

	{

	__KTRACE_OPT(KDMA, Kern::Printf("DDmaRequest::Fragment thread %O "

									"src=0x%08X dest=0x%08X count=%d flags=0x%X psl=0x%08X",

									&Kern::CurrentThread(), aSrc, aDest, aCount, aFlags, aPslInfo));

	__DMA_ASSERTD(aCount > 0);

	__DMA_ASSERTD(!iQueued);

	const TUint alignMask = iChannel.MemAlignMask(aFlags, aPslInfo);

	const TBool memSrc  = aFlags & KDmaMemSrc;

	const TBool memDest = aFlags & KDmaMemDest;

	// Memory buffers must satisfy alignment constraint

	__DMA_ASSERTD(!memSrc || ((aSrc & alignMask) == 0));

	__DMA_ASSERTD(!memDest || ((aDest & alignMask) == 0));

	// Ask the PSL what the maximum size possible for this transfer is

	TInt maxTransferSize = iChannel.MaxTransferSize(aFlags, aPslInfo);

	if (!maxTransferSize)

		{

		__KTRACE_OPT(KPANIC, Kern::Printf("Error: maxTransferSize == 0"));

		return KErrArgument;

		}

	if (iMaxTransferSize)

		{

		// User has set a size cap

		__DMA_ASSERTA((iMaxTransferSize <= maxTransferSize) || (maxTransferSize == -1));

		maxTransferSize = iMaxTransferSize;

		}

	else

		{

		// User doesn't care about max size

		if (maxTransferSize == -1)

			{

			// No maximum imposed by controller

			maxTransferSize = aCount;

			}

		}

	const TInt maxAlignedSize = (maxTransferSize & ~alignMask);

	__DMA_ASSERTD(maxAlignedSize > 0);						// bug in PSL if not true

	FreeDesList();

	TInt r = KErrNone;

	do

		{

		// Allocate fragment

		r = ExpandDesList();

		if (r != KErrNone)

			{

			FreeDesList();

			break;

			}

		// Compute fragment size

		TInt c = Min(maxTransferSize, aCount);

		if (memSrc && ((aFlags & KDmaPhysAddrSrc) == 0))

			c = MaxPhysSize(aSrc, c);

		if (memDest && ((aFlags & KDmaPhysAddrDest) == 0))

			c = MaxPhysSize(aDest, c);

		if ((memSrc || memDest) && (c < aCount) && (c > maxAlignedSize))

			{

			// This is not last fragment of transfer to/from memory. We must

			// round down fragment size so next one is correctly aligned.

			c = maxAlignedSize;

			}

		// Initialise fragment

		__KTRACE_OPT(KDMA, Kern::Printf("fragment: src=0x%08X dest=0x%08X count=%d", aSrc, aDest, c));

		iChannel.iController->InitDes(*iLastHdr, aSrc, aDest, c, aFlags, aPslInfo, iChannel.PslId());

		// Update for next iteration

		aCount -= c;

		if (memSrc)

			aSrc += c;

		if (memDest)

			aDest += c;

		}

	while (aCount > 0);

	__DMA_INVARIANT();

	return r;

	}

EXPORT_C void DDmaRequest::Queue()

	{

	__KTRACE_OPT(KDMA, Kern::Printf("DDmaRequest::Queue thread %O", &Kern::CurrentThread()));

	__DMA_ASSERTD(iDesCount > 0);	// Not configured? call Fragment() first !

	__DMA_ASSERTD(!iQueued);

	// append request to queue and link new descriptor list to existing one.

	iChannel.Wait();

	TUint32 req_count = iChannel.iQueuedRequests++;

	if (req_count == 0)

		{

		iChannel.Signal();

		iChannel.QueuedRequestCountChanged();

		iChannel.Wait();

		}

	if (!(iChannel.iIsrDfc & (TUint32)TDmaChannel::KCancelFlagMask))

		{

		iQueued = ETrue;

		iChannel.iReqQ.Add(&iLink);

		*iChannel.iNullPtr = iFirstHdr;

		iChannel.iNullPtr = &(iLastHdr->iNext);

		iChannel.DoQueue(*this);

		iChannel.Signal();

		}

	else

		{

		// Someone is cancelling all requests...

		req_count = --iChannel.iQueuedRequests;

		iChannel.Signal();

		if (req_count == 0)

			{

			iChannel.QueuedRequestCountChanged();

			}

		}

	__DMA_INVARIANT();

	}

EXPORT_C TInt DDmaRequest::ExpandDesList(TInt aCount)

	{

	__DMA_ASSERTD(!iQueued);

	__DMA_ASSERTD(aCount > 0);

	if (aCount > iChannel.iAvailDesCount)

		return KErrTooBig;

	iChannel.iAvailDesCount -= aCount;

	iDesCount += aCount;

	TDmac& c = *(iChannel.iController);

	c.Wait();

	if (iFirstHdr == NULL)

		{

		// handle empty list specially to simplify following loop