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

//

/**

 @file

 @internalTechnology

*/

#include "cagentdlgproc.h"

void CAgentDialogProcessor::Enque(CAgentBase* aItem)

    {

    iQueue.AddLast(aItem);

    iQueueLength++;

    }

TBool CAgentDialogProcessor::IsQueued(CAgentBase* aItem)

    {

   TSglQueIter<CAgentBase*> iter(iQueue);

    CAgentBase** item;

    while ( (item = iter++) != NULL )

        {

        if (*item == aItem)

            {

            return ETrue;

            }

        }

    return EFalse;

    }

CAgentBase* CAgentDialogProcessor::Deque()

	{

	CAgentBase* headOfQueue = NULL;

	if (!IsEmpty())

		{

		headOfQueue = *iQueue.First();

		iQueue.Remove(headOfQueue);

		iQueueLength--;

		}

    return headOfQueue;

	}

CAgentDialogProcessor::CAgentDialogProcessor()

    {

    }

void CAgentDialogProcessor::PromptForReconnect(CAgentBase& aAgent)

    {

    if (iCurrentRequest)

        {

        if (iCurrentRequest == &aAgent || IsQueued(&aAgent))

            {

            return;

            }

        Enque(&aAgent);

        }

    else

        {

        iCurrentRequest = &aAgent;

        aAgent.DialogProcessor()->Reconnect(*this);

        }

    }

void CAgentDialogProcessor::CancelPromptForReconnect(CAgentBase& aAgent)

    {

    if (iCurrentRequest == &aAgent)

        {

        iCurrentRequest = NULL;

        aAgent.DialogProcessor()->CancelEverything();

        }

    else

        {

        CAgentBase* a = &aAgent;

        if (IsQueued(a))

        	{

        	iQueue.Remove(a);

        	}        

        }

    }

void CAgentDialogProcessor::MDPOReconnectComplete(TInt aError)

    {

    CAgentBase* completedRequest = iCurrentRequest;

    iCurrentRequest = Deque();

    if (iCurrentRequest)

        {

        // Another prompt to display

        iCurrentRequest->DialogProcessor()->Reconnect(*this);

        }

    if (completedRequest)

        {

        completedRequest->ReconnectComplete(aError);

        }

    }