// 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 "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
 @internalComponent
*/

#include <bluetooth/logger.h>
#include "CBnepLink.h"
#include "CSocketWriter.h"
#include "bneputils.h"

#ifdef __FLOG_ACTIVE
_LIT8(KLogComponent, LOG_COMPONENT_PAN_BNEP);
#endif

CSocketWriter::CSocketWriter (RInternalSocket& aSocket, CBnepLink& aOwner)
        : CActive(EPriorityHigh), iSocket(aSocket), iBnepLink(aOwner)
    {
    LOG_FUNC
    CActiveScheduler::Add(this); 
    }

/**
   Cancels any pending writes.
   @internalComponent
*/
CSocketWriter::~CSocketWriter()
    {
    LOG_FUNC
    Cancel();
    
    iPendingWriteData.Free();
    }

/**
   Create the socket writer
   @internalComponent
*/ 
CSocketWriter* CSocketWriter::NewL (RInternalSocket& aSocket, CBnepLink& aOwner)
    {
    LOG_STATIC_FUNC
    CSocketWriter* self = new(ELeave) CSocketWriter(aSocket, aOwner);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self; 
    }

/**
   Attempt to write a buffer.
   @return KErrNone if successful or a system-wide error code
   @internalComponent
*/
TInt CSocketWriter::Write (RMBufChain& aChain)
    {
    LOG_FUNC
    if (aChain.Length() > KBnepMTU)
        {
        LOG(_L8("Length greater than expected MTU!"));
        aChain.Free();
        return KErrTooBig;
        }
    if (IsActive())
        {
        if(iQueueSize < KMaxSocketWriterQueueSize)
            {
            iQueue.Append(aChain);
            iQueueSize++;
            return KErrNone;
            }
        else
            {
            LOG(_L8("Bnep::ESocketWriterQueueOverflow"));
            aChain.Free();
            return KErrOverflow;
            }
        }
    LOG1(_L8("Length %d"), aChain.Length());
    
    __ASSERT_DEBUG(iPendingWriteData.IsEmpty(), BnepUtils::Panic(Bnep::ESocketWriterQueueOverflow));
    iPendingWriteData.Assign(aChain);
    iSocket.Write(iPendingWriteData, iStatus);

    SetActive();
    return KErrNone; 
    }

/**
   Does nothing
   @internalComponent
*/ 
void CSocketWriter::ConstructL ()
    {
    LOG_FUNC
    }

/**
   Checks iQueue for outstanding buffers and writes the first
   if it exists.
   @internalComponent
*/ 
void CSocketWriter::RunL ()
    {
    LOG_FUNC
	// Check if the completed write was a success.
	if(iStatus.Int() != KErrNone)
		{
		// The write failed - clear the pending write data.
	    LOG1(_L8("CSocketWriter::RunL completed with error: %d"), iStatus.Int());
		iPendingWriteData.Free();
		}

    __ASSERT_DEBUG(iPendingWriteData.IsEmpty(), BnepUtils::Panic(Bnep::ESocketWriterQueueOverflow));

    if(!iQueue.IsEmpty())
        {
        RMBufChain item;
        //Check on return value of iQueue.Remove() is unnecessary, since we've checked iQueue.IsEmpty()
        static_cast<void>(iQueue.Remove(item));
        iQueueSize--;
        Write(item);
        }
    else
        {
        iQueueSize = 0; // To make sure that we are always in sync
        }
    }

/**
   Cancel write.
   @internalComponent
*/
void CSocketWriter::DoCancel ()
    {
    LOG_FUNC
    iSocket.CancelWrite();
    
    // Free the pending data buffer to aviod asserting when the next Write operation
    // is performed.
    
    iPendingWriteData.Free();
    }