diff -r a2efdd544abf -r b47902b73a93 datasourcemodules/bluetoothgpspositioningmodule/btgpspsy/src/Utils/BTGPSMessageSender.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datasourcemodules/bluetoothgpspositioningmodule/btgpspsy/src/Utils/BTGPSMessageSender.cpp	Fri Jun 04 10:34:15 2010 +0100
@@ -0,0 +1,232 @@
+// 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
+
+
+