// 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 "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 <ss_std.h>

#include <es_mbufif.h>

#include <comms-infras/ss_flowbinders.h>

using namespace ESock;

// the CWaitForMBufs active object class is used to handle an out of mbufs 

// condition during CServProviderBaseMBuf::Write. If a normal allocation fails 

// then one of these AOs is created to wait on mbufs becomign available.

//

// when they are, this AO calls CanSend on the socket, which results

// in Write being called, which should now be able to complete successfully.

// 

CWaitForMBufs* CWaitForMBufs::NewL(MSessionDataNotify* aSocket)

	{

	CWaitForMBufs* self = new(ELeave) CWaitForMBufs(aSocket);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CWaitForMBufs::CWaitForMBufs(MSessionDataNotify* aSocket) 

: CActive(0),

  iSocket(aSocket)

	{

	}

void CWaitForMBufs::ConstructL()

	{

	CActiveScheduler::Add(this);

	}

CWaitForMBufs::~CWaitForMBufs()  

	{

	Cancel();

	iMBufChain.Free();

	}

// from CActive

void CWaitForMBufs::RunL()     

	{

	iMBufChain.Free();

	if(iSignalCanSend)

		{

		iSignalCanSend = EFalse;  //Has to be before because CanSend can re-request

		iSocket->CanSend();

		}

	if(iSignalNewData)

		{

		iSignalNewData = EFalse;  //Has to be before because CanSend can re-request

		iSocket->NewData(0);

		}

	}

void CWaitForMBufs::DoCancel() 

	{

		iSignalNewData = EFalse;  

		iSignalCanSend = EFalse;

		iRequest.Cancel();

	}

// requests

void CWaitForMBufs::CancelNewData() 

	{

	iSignalNewData = EFalse;  

	if (!iSignalNewData && !iSignalCanSend)

		{

		iRequest.Cancel();

		}

	}

void CWaitForMBufs::CancelCanSend() 

	{

	iSignalCanSend = EFalse;

	if (!iSignalNewData && !iSignalCanSend)

		{

		iRequest.Cancel();

		}

	}

void CWaitForMBufs::AllocWaitAndSignalNewData(TUint aSize)

	{

	if(!IsActive())

		{

		iRequest.Alloc(iMBufChain, aSize, iStatus);

		SetActive();

		}

	iSignalNewData = ETrue;

	}

void CWaitForMBufs::AllocWaitAndSignalCanSend(TUint aSize)

	{

	if(!IsActive())

		{

		iRequest.Alloc(iMBufChain, aSize, iStatus);

		SetActive();

		}

	iSignalCanSend = ETrue;

	}