// 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:
//



// INCLUDE FILES
#include <e32std.h>
#include <es_sock.h>
#include "BTGPSMessageSender.h"
#include "BTGPSDeviceManager.h"
#include "BTGPSConstantsManager.h"
#include "BTGPSRequestHandler.h"
#include "BTGPSLogging.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

// Granularity
const TInt KBTGPSArrayGranularity = 3;

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

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


// -----------------------------------------------------------------------------
// CBTGPSMessageSender::NewL
// -----------------------------------------------------------------------------
CBTGPSMessageSender* CBTGPSMessageSender::NewL(
    RSocket& aSocket,
    CBTGPSDeviceManager& aDeviceManager)
    {
    CBTGPSMessageSender* self = new (ELeave) CBTGPSMessageSender(
        aSocket,
        aDeviceManager);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop();
    return self;
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::~CBTGPSMessageSender
// -----------------------------------------------------------------------------
CBTGPSMessageSender::~CBTGPSMessageSender()
    {
    Cancel();
    if(iTimer!=NULL)
        {
        iTimer->Cancel();
        delete iTimer;
        }
    delete iBuffer;
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::ConstructL
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::ConstructL()
    {
    iBuffer = new (ELeave) CDesC8ArrayFlat(KBTGPSArrayGranularity);
    iTimer = CPeriodic::NewL(CActive::EPriorityStandard);
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::CBTGPSMessageSender
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
CBTGPSMessageSender::CBTGPSMessageSender(
        RSocket& aSocket,
        CBTGPSDeviceManager& aDeviceManager)
    : CActive(EPriorityNormal),
      iSocket(aSocket),
      iDeviceManager(aDeviceManager)
    {
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::SendL
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::SendL(const TDesC8& aMsg)
    {
    //if device is not connected then fail the sending
    if(iDeviceManager.DeviceConnectStatus() != EBTDeviceConnected)
        {
        User::Leave(KErrDisconnected);
        }
    
    if(IsActive() || iTimer->IsActive())
        {
        //Add this message to buffer
        iBuffer->AppendL(aMsg);
        }
    else
        {
        //Send this message
        TRACESTRING("CBTGPSMessageSender::SendL sending")
        TRACESTRING8(aMsg)
        iSocket.Write(aMsg, iStatus);
        SetActive();
        StartTimer();
        }
    }
    
// -----------------------------------------------------------------------------
// CBTGPSMessageSender::StartTimer
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::StartTimer()
    {
    iTimer->Cancel();
    iTimer->Start(
        CBTGPSRequestHandler::ConstantsManager().iSendDelay,
        CBTGPSRequestHandler::ConstantsManager().iSendDelay,
        TCallBack(TimerCallback, this));
    }
    
// -----------------------------------------------------------------------------
// CBTGPSMessageSender::TimerTick
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::TimerTick()
    {
    if(iBuffer->MdcaCount()!=0)
        {
        //check device connectivity
        if(iDeviceManager.DeviceConnectStatus() != EBTDeviceConnected)
            {
            Cancel();
            }
        else
            {
            //Buffer is not empty
            if(!IsActive())
                {
                TRACESTRING("CBTGPSMessageSender::TimerTick sending")
                TRACESTRING8(iBuffer->MdcaPoint(0))
                iSocket.Write(iBuffer->MdcaPoint(0), iStatus); //Send the first one
                SetActive();
                iBuffer->Delete(0); //Delete it from buffer
                }
            }
        }
    else
        {
        //Stop timer
        iTimer->Cancel();
        }
    }
        
// -----------------------------------------------------------------------------
// CBTGPSMessageSender::TimerCallback
// -----------------------------------------------------------------------------
TInt CBTGPSMessageSender::TimerCallback(TAny* aAny)
    {
    reinterpret_cast<CBTGPSMessageSender*>(aAny)->TimerTick();
    return 1; //continue periodic timer
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::RunL
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::RunL()
    {
    //error is ignored. do nothing
    }
        
// -----------------------------------------------------------------------------
// CBTGPSMessageSender::DoCancel
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::DoCancel()
    {
    iSocket.CancelWrite();
    if(iBuffer!=NULL)
        {
        iBuffer->Reset();
        }
    }
        
// -----------------------------------------------------------------------------
// CBTGPSMessageSender::RunError
// -----------------------------------------------------------------------------
TInt CBTGPSMessageSender::RunError(TInt /*aError*/)
    {
    //should never be called
    return KErrNone;
    }

// -----------------------------------------------------------------------------
// CBTGPSMessageSender::BTDeviceStatusChanged
// -----------------------------------------------------------------------------
void CBTGPSMessageSender::BTDeviceStatusChanged(
            TInt aConnectStatus, 
            TInt /*aDeviceType*/,
            TInt /*aErr*/)
    {
    if(aConnectStatus!=EBTDeviceConnected)
        {
        //reset buffer is device is not connected
        Cancel();
        }
    }

//  End of File