--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/memspy/Driver/Kernel/Source/MemSpyDriverXferBuffer.cpp	Tue Feb 02 01:57:15 2010 +0200
@@ -0,0 +1,189 @@
+/*
+* Copyright (c) 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 "MemSpyDriverXferBuffer.h"
+
+// System includes
+#include <u32hal.h>
+
+// Shared includes
+#include <memspy/driver/memspydriverobjectsshared.h>
+#include "MemSpyDriverObjectsInternal.h"
+
+// User includes
+#include "MemSpyDriverUtils.h"
+#include "MemSpyDriverDevice.h"
+
+
+
+DMemSpyDriverXferBuffer::DMemSpyDriverXferBuffer( DMemSpyDriverDevice& aDevice, DThread& aThread )
+:   iDevice( aDevice ), iClientThread( aThread )
+    {
+	TRACE( Kern::Printf("DMemSpyDriverXferBuffer::DMemSpyDriverXferBuffer() - this: 0x%08x", this ));
+    }
+
+
+DMemSpyDriverXferBuffer::~DMemSpyDriverXferBuffer()
+	{
+	TRACE( Kern::Printf("DMemSpyDriverXferBuffer::~DMemSpyDriverXferBuffer() - START - this: 0x%08x", this ));
+
+    NKern::ThreadEnterCS();
+    delete iBuffer;
+    NKern::ThreadLeaveCS();
+
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::~DMemSpyDriverXferBuffer() - END - this: 0x%08x", this ));
+	}
+
+
+TInt DMemSpyDriverXferBuffer::Construct( TInt aSize )
+    {
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::Construct() - START - this: 0x%08x, newSize: %d, iSize: %d", this, aSize, iSize ));
+    TInt ret = KErrNone;
+    //
+    iBuffer = Kern::AllocZ( aSize );
+    if  ( iBuffer == NULL )
+        {
+        ret = KErrNoMemory;
+        }
+    else
+        {
+        iSize = aSize;
+        }
+    //
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::Construct() - END - this: 0x%08x, newSize: %d, iSize: %d", this, aSize, iSize ));
+    return ret;
+    }
+
+
+
+TInt DMemSpyDriverXferBuffer::Size() const
+    {
+    return iSize;
+    }
+
+
+TInt DMemSpyDriverXferBuffer::GrowBy( TInt aSize )
+    {
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::GrowBy() - START - this: 0x%08x, newSize: %d, iSize: %d", this, iSize + aSize, iSize ));
+    //
+    TInt ret = KErrNone;
+    const TInt newSize = iSize + aSize;
+    if  ( newSize > iSize )
+        {
+        NKern::ThreadEnterCS();
+        ret = Kern::SafeReAlloc( iBuffer, iSize, newSize );
+        if  ( ret == KErrNone )
+            {
+            iSize = newSize;
+            }
+	    NKern::ThreadLeaveCS();
+        }
+    else
+        {
+        TRACE( Kern::Printf("DMemSpyDriverXferBuffer::GrowBy() - WARNING - new size would shrink buffer (or have no effect)!" ));
+        }
+    //
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::GrowBy() - END - this: 0x%08x, err: %d, iSize: %d", this, ret, iSize ));
+    return ret;
+    }
+
+
+TInt DMemSpyDriverXferBuffer::EnsureCapacity( TInt aSize )
+    {
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::EnsureCapacity() - START - this: 0x%08x, aSize: %d, iSize: %d", this, aSize, iSize ));
+    //
+    TInt ret = KErrNone;
+    if  ( aSize > iSize )
+        {
+        const TInt newSize = aSize;
+        //
+        NKern::ThreadEnterCS();
+        ret = Kern::SafeReAlloc( iBuffer, iSize, newSize );
+        if  ( ret == KErrNone )
+            {
+            iSize = newSize;
+            }
+	    NKern::ThreadLeaveCS();
+        }
+    else
+        {
+        TRACE( Kern::Printf("DMemSpyDriverXferBuffer::EnsureCapacity() - WARNING - new size would shrink buffer (or have no effect)!" ));
+        }
+    //
+    TRACE( Kern::Printf("DMemSpyDriverXferBuffer::EnsureCapacity() - END - this: 0x%08x, err: %d, iSize: %d", this, ret, iSize ));
+    return ret;
+    }
+
+
+void DMemSpyDriverXferBuffer::Reset()
+    {
+    memclr( iBuffer, iSize );
+    }
+
+
+
+
+
+
+
+
+
+
+TInt DMemSpyDriverXferBuffer::WriteToClient( TDes8* aDestinationPointer, TInt aLength )
+    {
+    // Check the client has enough space
+    TInt err = Kern::ThreadGetDesMaxLength( &iClientThread, aDestinationPointer );
+    if  ( err >= 0 )
+        {
+        if  ( aLength > err )
+            {
+            Kern::Printf("DMemSpyDriverXferBuffer::WriteToClient() - client descriptor max len: %d, amount to write: %d => KErrOverflow", err, aLength );
+            err = KErrOverflow;
+            }
+        else
+            {
+            const TPtrC8 pData( (const TUint8*) iBuffer, aLength );
+            err = Kern::ThreadDesWrite( &iClientThread, aDestinationPointer, pData, 0, KChunkShiftBy0 | KTruncateToMaxLength, &iClientThread );
+            }
+        }
+
+    // Check for bad descriptor and panic the client
+    if  ( err == KErrBadDescriptor )
+        {
+        MemSpyDriverUtils::PanicThread( iClientThread, EPanicBadDescriptor );
+        }
+    //
+    return err;
+    }
+
+
+DThread& DMemSpyDriverXferBuffer::ClientThread()
+    {
+    return iClientThread;
+    }
+
+
+TUint8* DMemSpyDriverXferBuffer::Ptr()
+    {
+    return (TUint8*) iBuffer;
+    }
+
+
+
+
+
+