--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bluetoothcommsprofiles/btpan/bnep/CSocketWriter.cpp	Fri Jan 15 08:13:17 2010 +0200
@@ -0,0 +1,156 @@
+// 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:
+//
+
+/**
+ @file
+ @internalComponent
+*/
+
+#include <bluetooth/logger.h>
+#include "CBnepLink.h"
+#include "CSocketWriter.h"
+#include "bneputils.h"
+
+#ifdef __FLOG_ACTIVE
+_LIT8(KLogComponent, LOG_COMPONENT_PAN_BNEP);
+#endif
+
+CSocketWriter::CSocketWriter (RInternalSocket& aSocket, CBnepLink& aOwner)
+        : CActive(EPriorityHigh), iSocket(aSocket), iBnepLink(aOwner)
+    {
+    LOG_FUNC
+    CActiveScheduler::Add(this); 
+    }
+
+/**
+   Cancels any pending writes.
+   @internalComponent
+*/
+CSocketWriter::~CSocketWriter()
+    {
+    LOG_FUNC
+    Cancel();
+    
+    iPendingWriteData.Free();
+    }
+
+/**
+   Create the socket writer
+   @internalComponent
+*/ 
+CSocketWriter* CSocketWriter::NewL (RInternalSocket& aSocket, CBnepLink& aOwner)
+    {
+    LOG_STATIC_FUNC
+    CSocketWriter* self = new(ELeave) CSocketWriter(aSocket, aOwner);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self; 
+    }
+
+/**
+   Attempt to write a buffer.
+   @return KErrNone if successful or a system-wide error code
+   @internalComponent
+*/
+TInt CSocketWriter::Write (RMBufChain& aChain)
+    {
+    LOG_FUNC
+    if (aChain.Length() > KBnepMTU)
+        {
+        LOG(_L8("Length greater than expected MTU!"));
+        aChain.Free();
+        return KErrTooBig;
+        }
+    if (IsActive())
+        {
+        if(iQueueSize < KMaxSocketWriterQueueSize)
+            {
+            iQueue.Append(aChain);
+            iQueueSize++;
+            return KErrNone;
+            }
+        else
+            {
+            LOG(_L8("Bnep::ESocketWriterQueueOverflow"));
+            aChain.Free();
+            return KErrOverflow;
+            }
+        }
+    LOG1(_L8("Length %d"), aChain.Length());
+    
+    __ASSERT_DEBUG(iPendingWriteData.IsEmpty(), BnepUtils::Panic(Bnep::ESocketWriterQueueOverflow));
+    iPendingWriteData.Assign(aChain);
+    iSocket.Write(iPendingWriteData, iStatus);
+
+    SetActive();
+    return KErrNone; 
+    }
+
+/**
+   Does nothing
+   @internalComponent
+*/ 
+void CSocketWriter::ConstructL ()
+    {
+    LOG_FUNC
+    }
+
+/**
+   Checks iQueue for outstanding buffers and writes the first
+   if it exists.
+   @internalComponent
+*/ 
+void CSocketWriter::RunL ()
+    {
+    LOG_FUNC
+	// Check if the completed write was a success.
+	if(iStatus.Int() != KErrNone)
+		{
+		// The write failed - clear the pending write data.
+	    LOG1(_L8("CSocketWriter::RunL completed with error: %d"), iStatus.Int());
+		iPendingWriteData.Free();
+		}
+
+    __ASSERT_DEBUG(iPendingWriteData.IsEmpty(), BnepUtils::Panic(Bnep::ESocketWriterQueueOverflow));
+
+    if(!iQueue.IsEmpty())
+        {
+        RMBufChain item;
+        //Check on return value of iQueue.Remove() is unnecessary, since we've checked iQueue.IsEmpty()
+        static_cast<void>(iQueue.Remove(item));
+        iQueueSize--;
+        Write(item);
+        }
+    else
+        {
+        iQueueSize = 0; // To make sure that we are always in sync
+        }
+    }
+
+/**
+   Cancel write.
+   @internalComponent
+*/
+void CSocketWriter::DoCancel ()
+    {
+    LOG_FUNC
+    iSocket.CancelWrite();
+    
+    // Free the pending data buffer to aviod asserting when the next Write operation
+    // is performed.
+    
+    iPendingWriteData.Free();
+    }