diff -r a2efdd544abf -r b47902b73a93 datasourcemodules/bluetoothgpspositioningmodule/btgpspsy/src/Utils/BTGPSMessageReceiver.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datasourcemodules/bluetoothgpspositioningmodule/btgpspsy/src/Utils/BTGPSMessageReceiver.cpp	Fri Jun 04 10:34:15 2010 +0100
@@ -0,0 +1,258 @@
+// 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 "BTGPSMessageReceiver.h"
+#include "BTGPSMessageListener.h"
+#include "BTGPSDeviceManager.h"
+#include "BTGPSMessageDef.h"
+#include "BTGPSLogging.h"
+#include "BTGPSNmeaParser.h"
+
+// EXTERNAL DATA STRUCTURES
+
+// EXTERNAL FUNCTION PROTOTYPES  
+
+// CONSTANTS
+
+// MACROS
+
+// LOCAL CONSTANTS AND MACROS
+
+// MODULE DATA STRUCTURES
+
+// LOCAL FUNCTION PROTOTYPES
+
+// FORWARD DECLARATIONS
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::NewL
+// -----------------------------------------------------------------------------
+CBTGPSMessageReceiver* CBTGPSMessageReceiver::NewL(
+    RSocket& aSocket,
+    CBTGPSDeviceManager& aDeviceManager)
+    {
+    CBTGPSMessageReceiver* self = new (ELeave) CBTGPSMessageReceiver(
+        aSocket,
+        aDeviceManager);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop();
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::~CBTGPSMessageReceiver
+// -----------------------------------------------------------------------------
+CBTGPSMessageReceiver::~CBTGPSMessageReceiver()
+    {
+    Cancel();    
+    iDeviceManager.RemoveListener(*this);
+    iListenerArray.Close();
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::ConstructL
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::ConstructL()
+    {
+    iDeviceManager.AddListenerL(*this);
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::CBTGPSMessageReceiver
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+CBTGPSMessageReceiver::CBTGPSMessageReceiver(
+        RSocket& aSocket,
+        CBTGPSDeviceManager& aDeviceManager)
+    : CActive(EPriorityNormal),
+      iSocket(aSocket),
+      iDeviceManager(aDeviceManager)
+    {
+    CActiveScheduler::Add(this);
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::AddMessageListenerL
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::AddMessageListenerL(MBTGPSMessageListener& aListener)
+    {
+    //Add listener to array
+    User::LeaveIfError(iListenerArray.Append(&aListener));
+
+    //Start listening if device is connected
+    if(!IsActive() && iDeviceManager.DeviceConnectStatus() == EBTDeviceConnected)
+        {
+        Receive();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::AddMessageListenerL
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::RemoveMessageListener(MBTGPSMessageListener& aListener)
+    {
+    //remove listener from array
+    TInt index = iListenerArray.Find(&aListener);
+    if(index!=KErrNotFound)
+        {
+        iListenerArray.Remove(index);
+        }
+        
+    //If no listener anymore, then remove receiving
+    if(iListenerArray.Count()==0)
+        {
+        Cancel();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::RunL
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::RunL()
+    {
+    TRACESTRING2("CBTGPSMessageReceiver::RunL start...%d", iStatus.Int())
+    if(iStatus == KErrNone)
+        {
+        HandleReceivedMessage();
+        Receive();
+        }
+    else
+        {
+        //If connecting error then we report connecting status
+        iDeviceManager.SetBTDeviceConnectStatus(
+            EBTDeviceDisconnected,
+            iStatus.Int());
+        }
+    TRACESTRING("CBTGPSMessageReceiver::RunL end")
+    }
+        
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::DoCancel
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::DoCancel()
+    {
+    iSocket.CancelRecv();
+    }
+        
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::RunError
+// -----------------------------------------------------------------------------
+TInt CBTGPSMessageReceiver::RunError(TInt /*aError*/)
+    {
+    //should never be called
+    return KErrNone;
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::BTDeviceStatusChanged
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::BTDeviceStatusChanged(
+            TInt aConnectStatus, 
+            TInt /*aDeviceType*/,
+            TInt /*aErr*/)
+    {
+    //Start listening if device is connected
+    if( aConnectStatus == EBTDeviceConnected 
+        && iListenerArray.Count()!=0)
+        {
+        Receive();
+        }
+    else
+        {
+        Cancel();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::Receive
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::Receive()
+    {
+    if(!IsActive())
+        {
+        iSocket.RecvOneOrMore(iBuffer, 0, iStatus, iRecLen);
+        SetActive();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::HandleReceivedMessage
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::HandleReceivedMessage()
+    {
+    for(TInt i=0; i<iBuffer.Length(); i++)
+        {
+        TUint8 next = iBuffer[i];
+        TInt nmeaBufLen = iNmeaBuf.Length();
+        if((next==KNmeaSentenceTerminator1 || 
+            next == KNmeaSentenceTerminator2))
+            {
+            if(nmeaBufLen>0)
+                {
+                //We have a valid nmea message. Inform listeners
+                InformListeners();
+                iNmeaBuf.Zero();
+                }
+            }
+        else
+            {
+            if(nmeaBufLen>=KMaxNmeaMessageSize)
+                {
+                //Empty nmea message buffer if it's overflow
+                iNmeaBuf.Zero();
+                }
+            iNmeaBuf.Append(next);
+            }
+        }
+    //Empty receiving buffer
+    iBuffer.Zero();
+    }
+
+// -----------------------------------------------------------------------------
+// CBTGPSMessageReceiver::InformListeners
+// -----------------------------------------------------------------------------
+void CBTGPSMessageReceiver::InformListeners()
+    {
+    TRACESTRING("CBTGPSMessageReceiver::InformListeners start...")
+    TRACESTRING8(iNmeaBuf)
+    TBTGPSNmeaParser parser;
+    parser.SetNmeaSentence(iNmeaBuf);
+    if(parser.IsValid())
+        {
+        TInt count = iListenerArray.Count();
+        for(TInt i=count-1; i>=0; i--)
+            {
+            iListenerArray[i]->HandleMessage(parser);
+            }
+        }
+    TRACESTRING("CBTGPSMessageReceiver::InformListeners end")
+    }
+
+//  End of File
+
+
+