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


#include "CFSClient.h"
#include "clientutils.h"
#include "clientsession.h"

CFSClient::CFSClient(TInt aUID,
					 MCTToken& aToken, 
					 RFileStoreClientSession& aClient)
	:	CActive(EPriorityNormal),
		iToken(aToken), 	
		iInterfaceUID(aUID),	
		iClient(aClient),
		iRequestPtr(NULL, 0, 0)
	{
	}

CFSClient::~CFSClient()
	{
    Cancel(); 
    delete iRequestDataBuf;
	}

CFSClient::TAsyncRequest::~TAsyncRequest()
	{
	__ASSERT_DEBUG(EIdle==iRequest, FSTokenPanic(ERequestOutstanding));
	}

void CFSClient::TAsyncRequest::operator()(TFSTokenMessages aRequest, TRequestStatus* aStatus)
	{
	__ASSERT_DEBUG(EIdle==iRequest, FSTokenPanic(ERequestOutstanding));

	iRequest = aRequest; 
	iClientStatus = aStatus;
	*aStatus = KRequestPending;
	}

void CFSClient::TAsyncRequest::Complete(TInt aCompletionResult)
	{
	__ASSERT_DEBUG(EIdle!=iRequest, FSTokenPanic(ENoRequestOutstanding));
	User::RequestComplete(iClientStatus, aCompletionResult);
	iRequest = EIdle;
	}

void CFSClient::TAsyncRequest::Cancel()
	{
	User::RequestComplete(iClientStatus, KErrCancel);
	iRequest = EIdle;
	}

void CFSClient::FreeRequestBuffer() const
	{
    delete iRequestDataBuf; 
	iRequestDataBuf = NULL;
	iRequestPtr.Set(NULL, 0, 0);
	}

TInt CFSClient::AllocRequestBuffer(TInt aReqdSize) const
	{
    ASSERT(aReqdSize > 0);
	TInt result = KErrNoMemory;
	
	FreeRequestBuffer();
	iRequestDataBuf = HBufC8::NewMax(aReqdSize);
	if (iRequestDataBuf)
		{
	    iRequestPtr.Set(iRequestDataBuf->Des());
		iRequestPtr.FillZ();
		result = KErrNone;
		}

	return result;
	}

/**
 * Execute a synchronous request that returns a buffer of indetermintate length.
 *
 * If the initial buffer is too short, the server leaves with KErrOverflow and
 * passes us the required length - the reuest is then re-sent.
 */
void CFSClient::SendSyncRequestAndHandleOverflowL(TFSTokenMessages aMessage,
												  TInt aInitialBufSize,
												  const TIpcArgs& aArgs) const
	{
	User::LeaveIfError(AllocRequestBuffer(aInitialBufSize));
	
	TInt err = iClient.SendRequest(aMessage, aArgs);
	if (err == KErrOverflow)
		{
		TInt sizeReqd = 0;
		TPckg<TInt> theSize(sizeReqd);
		theSize.Copy(iRequestPtr);
		User::LeaveIfError(AllocRequestBuffer(sizeReqd));			
		err = iClient.SendRequest(aMessage, aArgs);
		}

	User::LeaveIfError(err);
	}

//	*********************************************************************************
//	CActive implementation
//	*********************************************************************************

void CFSClient::DoCancel()
	{
	iCurrentRequest.Cancel();
	}

TInt CFSClient::RunError(TInt aError)
	{
	iCurrentRequest.Complete(aError);
	return KErrNone; // Handled
	}