/*

* Copyright (c) 2005 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:  array for storing dataproviders and datastores.

*

*/

// INCLUDE FILES

#include <s32std.h>

#include <nsmldebug.h>

#include "nsmldshostconstants.h"

#include "Nsmldsasyncrequesthandler.h"

#include "Nsmldsdataproviderarray.h"

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

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::~CNSmlDSAsyncRequestHandler

// ------------------------------------------------------------------------------------------------    

CNSmlDSAsyncRequestHandler::~CNSmlDSAsyncRequestHandler()

	{

	if ( iDSItem )

    	{

    	iDSItem->iDSAO = NULL;

    	}

	}

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::CallDSAsyncL

// ------------------------------------------------------------------------------------------------

CSmlDataStore& CNSmlDSAsyncRequestHandler::CallDSAsyncLC()

    {

    AddToSchedulerL();

    if ( !iDSItem )

	    {

	    User::Leave( KErrUnknown );

	    }

    if ( !iDSItem->iDataStore )

	    {

	    User::Leave( KErrUnknown );

	    }

	SetRequestStatusOnLeaveLC();

	SetActive();

    return *( iDSItem->iDataStore );

    }

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::SetRequestStatusOnLeaveLC

// ------------------------------------------------------------------------------------------------	

void CNSmlDSAsyncRequestHandler::SetRequestStatusOnLeaveLC()

    {

    CleanupStack::PushL(TCleanupItem ( SetRequestStatusOnLeaveCleanup, this ) );

    }    

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::SetRequestStatusOnLeaveCleanup

// ------------------------------------------------------------------------------------------------

void CNSmlDSAsyncRequestHandler::SetRequestStatusOnLeaveCleanup( TAny* aP )

	{

	CNSmlDSAsyncRequestHandler* self = reinterpret_cast<CNSmlDSAsyncCallBack*>( aP );

    TRequestStatus *status = &self->iStatus;

    User::RequestComplete( status, KErrNone );

	}

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::SetActive

// ------------------------------------------------------------------------------------------------

void CNSmlDSAsyncRequestHandler::SetActive()

	{

	CActive::SetActive();

	}    

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::CNSmlDSAsyncRequestHandler

// ------------------------------------------------------------------------------------------------

CNSmlDSAsyncRequestHandler::CNSmlDSAsyncRequestHandler( TInt aPriority, 

		CNSmlDSHostSession* aSession, 

        TNSmlDSDataStoreElement* aDSItem, 

        const RMessagePtr2& aMessage ) :

    CActive( aPriority ), iSession( aSession ), 

        iDSItem( aDSItem ), iMessage( aMessage )

    {

    ASSERT( aSession != NULL );

    }

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::AddToSchedulerL

// ------------------------------------------------------------------------------------------------

void CNSmlDSAsyncRequestHandler::AddToSchedulerL()

	{

	ASSERT( iDSItem != NULL );

	ASSERT( iDSItem->iDataStore != NULL );

	if ( iDSItem->iDSAO )

        {

        //error: asyncronous call already outstanding. Only one allowed at any one time.

        User::Leave( ENSmlDSHostServerErrAsynchCallOutstanding );

        }

	iDSItem->iDSAO = this;

    CActiveScheduler::Add( this );

	}

// ------------------------------------------------------------------------------------------------

// CNSmlDSAsyncRequestHandler::RunError

// ------------------------------------------------------------------------------------------------

TInt CNSmlDSAsyncRequestHandler::RunError( TInt aError )

	{

	iMessage.Complete( aError );

	delete this;

	return KErrNone;

	}

// End of File