--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bluetoothengine/bthid/bthidserver/src/socketreader.cpp	Mon Jan 18 20:28:57 2010 +0200
@@ -0,0 +1,122 @@
+/*
+* Copyright (c) 2008 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:  This is the implementation of application class
+ *
+*/
+
+
+#include "sockets.pan"
+#include "socketreader.h"
+#include "socketobserver.h"
+#include "debug.h"
+
+CSocketReader* CSocketReader::NewL(TUint aSocketID,
+        MSocketObserver& aObserver, TInt aInitialBufSize)
+    {
+    CSocketReader* self = CSocketReader::NewLC(aSocketID, aObserver,
+            aInitialBufSize);
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+CSocketReader* CSocketReader::NewLC(TUint aSocketID,
+        MSocketObserver& aObserver, TInt aInitialBufSize)
+    {
+    CSocketReader* self = new (ELeave) CSocketReader(aSocketID, aObserver);
+    CleanupStack::PushL(self);
+    self->ConstructL(aInitialBufSize);
+    return self;
+    }
+
+CSocketReader::CSocketReader(TUint aSocketID, MSocketObserver& aObserver) :
+    CActive(EPriorityStandard), iSocketID(aSocketID), iObserver(aObserver),
+            iBufferPtr(0, 0)
+    {
+    }
+
+CSocketReader::~CSocketReader()
+    {
+    Cancel(); // Causes DoCancel
+
+    delete iBuffer;
+    }
+
+void CSocketReader::ConstructL(TInt aInitialBufSize)
+    {
+    iBuffer = HBufC8::NewL(aInitialBufSize);
+    iBufferPtr.Set(iBuffer->Des());
+
+    CActiveScheduler::Add(this);
+    }
+
+void CSocketReader::DoCancel()
+    {
+    // Cancel asynchronous read request
+    iSocket->CancelRead();
+    }
+
+void CSocketReader::RunL()
+    {
+        // Active object request complete handler
+        TRACE_INFO((_L("CSocketReader::RunL(), iStatus.Int()=%d, socketID=%d"),iStatus.Int(), iSocketID));
+
+    switch (iStatus.Int())
+        {
+        case KErrNone:
+            {
+            // Data has been read from socket
+            // Inform the observer and issue another read if we want
+            // to continue listening
+            if (iObserver.HandleDataReceived(iSocketID, iBufferPtr))
+                {
+                IssueRead();
+                }
+            break;
+            }
+
+        default:
+            {
+            // A read error has occurred. Inform the observer the connection is lost
+            iObserver.HandleSocketError(iSocketID, ETrue, iStatus.Int());
+            break;
+            }
+        }
+    }
+
+void CSocketReader::IssueRead()
+    {
+    // Initiate a new read from socket into iBuffer
+    iSocket->Read(iBufferPtr, iStatus);
+    SetActive();
+    }
+
+void CSocketReader::StartReadingL(RSocket* aSocket, TInt aMTU)
+    {
+    // Initiate a new read from socket into iBuffer
+    __ASSERT_DEBUG(!IsActive(),
+            User::Panic(KPanicSocketsEngineRead, ESocketsBadState));
+
+    if (aMTU > iBufferPtr.MaxLength())
+        {
+        // Realloc the buffer as it isn't large enough.
+        iBufferPtr.Set(0, 0, 0);
+        delete iBuffer;
+        iBuffer = 0;
+        iBuffer = HBufC8::NewL(aMTU);
+        iBufferPtr.Set(iBuffer->Des());
+        }
+
+    iSocket = aSocket;
+    IssueRead();
+    }