--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cbsref/csyrefplugins/csy27010/src/CommReadWriteBaseAo.cpp	Tue Aug 31 16:23:08 2010 +0300
@@ -0,0 +1,135 @@
+//
+// * Copyright 2004 Neusoft America Inc.
+// * All rights reserved.
+// * This component and the accompanying materials are made available
+// * under the terms of the Eclipse Public License v1.0
+// * which accompanies this distribution, and is available
+// * at the URL "http://www.eclipse.org/legal/epl-v10.html".
+// *
+// * Contributors:
+// * Keith Collins (Neusoft America Inc.)  original software development and additional code and modifications.
+// * Thomas Gahagen (Neusoft America Inc.)  additional code and modifications.
+// * Zhen Yuan (Neusoft America Inc.)  additional code and modifications.
+// *
+// * Description:  This file has the implementation for the class MsgToBPCmdQueue
+// *               for adding and removing the BasePort Command messages from the queue.
+//
+
+// CommReadWriteBaseAo.cpp
+
+/** @file CommReadWriteBaseAo.cpp
+ *
+ * 
+ */
+
+#include "CommReadWriteBaseAo.h"
+#include "Portfactory.h"
+#include "CsyDebugLogger.h"
+#include "CsyGlobals.h"
+
+CCommReadWriteBaseAo::CCommReadWriteBaseAo(CPortFactory* aParent,
+										   CMux0710Protocol* aMux0710Protocol,
+										   TInt aPriority)
+/**
+ * Constructor.
+ * @param aParent - Pointer to the parent
+ * @param aMux0710Protocol - Pointer to the mux protocol
+ * @param aPriority - Priority to set for active object
+ */
+ : CActive(aPriority),
+   iBufSize(KDefaultTxRxBufSize),
+   iRole(ECommRoleDTE),
+   iParent(aParent),
+   iMux0710Protocol(aMux0710Protocol)
+	{
+	iCommPort = aParent->DTEPort();
+	CActiveScheduler::Add(this);
+	}
+
+
+CCommReadWriteBaseAo::~CCommReadWriteBaseAo()
+/**
+ * Destructor. Delete the memory allocated by this object.
+ */
+    {
+    delete iBuffer;
+    delete iBuf;
+    }
+
+TInt CCommReadWriteBaseAo::SetServerConfig(TCommServerConfig& aConfig)
+/**
+ * Set the port to use partial reads/writes or the bungee buffer.
+ *
+ * @param aConfig Reference to the new Comm server configuration
+ * @return TInt error code. KErrNone for sucess
+ */
+    {
+    _LOG_L4C1(">>CCommReadWriteBaseAo::SetServerConfig");
+
+    TCommServerConfigV01& c = aConfig();
+    TInt res = KErrNone;
+
+    if (c.iBufFlags & KCommBufferPartial)
+        {
+        TInt bufSave = iBufSize;
+        iBufSize = c.iBufSize;
+        TRAP(res, SetBuffersL();)
+        if (res==KErrNone)
+            iBufFlags = c.iBufFlags;
+        else
+            iBufSize = bufSave;
+        }
+
+	_LOG_L4C2("<<CCommReadWriteBaseAo::SetServerConfig [res=%d]",res);
+	return res;
+    }
+
+void CCommReadWriteBaseAo::GetServerConfig(TCommServerConfig& aConfig) const
+/**
+ * This method reads the comm server buffer configuration.
+ *
+ * @param aConfig Reference to location to write the Comm server configuration
+ */
+    {
+    _LOG_L4C1("CCommReadWriteBaseAo::GetServerConfig");
+
+    aConfig().iBufFlags = iBufFlags;
+    aConfig().iBufSize  = iBufSize;
+    }
+
+void CCommReadWriteBaseAo::FreeMemory()
+/**
+ * Reduce memory allocation levels by order of the comm server.
+ */
+    {
+    _LOG_L4C1("CCommReadWriteBaseAo::FreeMemory");
+
+    TRAP_IGNORE(SetBuffersL();)
+	// MAF the result is ignored?
+    }
+
+void CCommReadWriteBaseAo::SetBuffersL()
+/**
+ * This method frees the buffer memory and then tries to allocate
+ * a smaller piece of memory. Note that this function will leave if
+ * the memory allocation fails.
+ */
+    {
+    _LOG_L4C1(">>CCommReadWriteBaseAo::SetBuffersL");
+
+    if (!IsActive())
+        {
+		_LOG_L3C1("Not active - allow alloc to happen");
+        TInt allocLen = Align4(iBufSize);
+   
+        delete iBuffer;
+        delete iBuf;
+        iBuf = NULL;   // set to NULL, in case new leaves
+        iBuffer = NULL;
+
+        iBuffer = HBufC8::NewMaxL(allocLen);
+        iBuf = new (ELeave) TPtr8((TText8*)iBuffer->Des().Ptr(), allocLen, allocLen);
+        }
+
+	_LOG_L4C1("<<CCommReadWriteBaseAo::SetBuffersL");
+	}
\ No newline at end of file