1 //

     2 // * Copyright 2004 Neusoft America Inc.

     3 // * All rights reserved.

     4 // * This component and the accompanying materials are made available

     5 // * under the terms of the Eclipse Public License v1.0

     6 // * which accompanies this distribution, and is available

     7 // * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 // *

     9 // * Contributors:

    10 // * Keith Collins (Neusoft America Inc.)  original software development and additional code and modifications.

    11 // * Thomas Gahagen (Neusoft America Inc.)  additional code and modifications.

    12 // * Zhen Yuan (Neusoft America Inc.)  additional code and modifications.

    13 // *

    14 // * Description:  This file has the implementation for the class MsgToBPCmdQueue

    15 // *               for adding and removing the BasePort Command messages from the queue.

    16 //

    17 

    18 // CommReadWriteBaseAo.cpp

    19 

    20 /** @file CommReadWriteBaseAo.cpp

    21  *

    22  * 

    23  */

    24 

    25 #include "CommReadWriteBaseAo.h"

    26 #include "Portfactory.h"

    27 #include "CsyDebugLogger.h"

    28 #include "CsyGlobals.h"

    29 

    30 CCommReadWriteBaseAo::CCommReadWriteBaseAo(CPortFactory* aParent,

    31 										   CMux0710Protocol* aMux0710Protocol,

    32 										   TInt aPriority)

    33 /**

    34  * Constructor.

    35  * @param aParent - Pointer to the parent

    36  * @param aMux0710Protocol - Pointer to the mux protocol

    37  * @param aPriority - Priority to set for active object

    38  */

    39  : CActive(aPriority),

    40    iBufSize(KDefaultTxRxBufSize),

    41    iRole(ECommRoleDTE),

    42    iParent(aParent),

    43    iMux0710Protocol(aMux0710Protocol)

    44 	{

    45 	iCommPort = aParent->DTEPort();

    46 	CActiveScheduler::Add(this);

    47 	}

    48 

    49 

    50 CCommReadWriteBaseAo::~CCommReadWriteBaseAo()

    51 /**

    52  * Destructor. Delete the memory allocated by this object.

    53  */

    54     {

    55     delete iBuffer;

    56     delete iBuf;

    57     }

    58 

    59 TInt CCommReadWriteBaseAo::SetServerConfig(TCommServerConfig& aConfig)

    60 /**

    61  * Set the port to use partial reads/writes or the bungee buffer.

    62  *

    63  * @param aConfig Reference to the new Comm server configuration

    64  * @return TInt error code. KErrNone for sucess

    65  */

    66     {

    67     _LOG_L4C1(">>CCommReadWriteBaseAo::SetServerConfig");

    68 

    69     TCommServerConfigV01& c = aConfig();

    70     TInt res = KErrNone;

    71 

    72     if (c.iBufFlags & KCommBufferPartial)

    73         {

    74         TInt bufSave = iBufSize;

    75         iBufSize = c.iBufSize;

    76         TRAP(res, SetBuffersL();)

    77         if (res==KErrNone)

    78             iBufFlags = c.iBufFlags;

    79         else

    80             iBufSize = bufSave;

    81         }

    82 

    83 	_LOG_L4C2("<<CCommReadWriteBaseAo::SetServerConfig [res=%d]",res);

    84 	return res;

    85     }

    86 

    87 void CCommReadWriteBaseAo::GetServerConfig(TCommServerConfig& aConfig) const

    88 /**

    89  * This method reads the comm server buffer configuration.

    90  *

    91  * @param aConfig Reference to location to write the Comm server configuration

    92  */

    93     {

    94     _LOG_L4C1("CCommReadWriteBaseAo::GetServerConfig");

    95 

    96     aConfig().iBufFlags = iBufFlags;

    97     aConfig().iBufSize  = iBufSize;

    98     }

    99 

   100 void CCommReadWriteBaseAo::FreeMemory()

   101 /**

   102  * Reduce memory allocation levels by order of the comm server.

   103  */

   104     {

   105     _LOG_L4C1("CCommReadWriteBaseAo::FreeMemory");

   106 

   107     TRAP_IGNORE(SetBuffersL();)

   108 	// MAF the result is ignored?

   109     }

   110 

   111 void CCommReadWriteBaseAo::SetBuffersL()

   112 /**

   113  * This method frees the buffer memory and then tries to allocate

   114  * a smaller piece of memory. Note that this function will leave if

   115  * the memory allocation fails.

   116  */

   117     {

   118     _LOG_L4C1(">>CCommReadWriteBaseAo::SetBuffersL");

   119 

   120     if (!IsActive())

   121         {

   122 		_LOG_L3C1("Not active - allow alloc to happen");

   123         TInt allocLen = Align4(iBufSize);

   124    

   125         delete iBuffer;

   126         delete iBuf;

   127         iBuf = NULL;   // set to NULL, in case new leaves

   128         iBuffer = NULL;

   129 

   130         iBuffer = HBufC8::NewMaxL(allocLen);

   131         iBuf = new (ELeave) TPtr8((TText8*)iBuffer->Des().Ptr(), allocLen, allocLen);

   132         }

   133 

   134 	_LOG_L4C1("<<CCommReadWriteBaseAo::SetBuffersL");

   135 	}