//

// * 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 contains the implementation for the Mux0710Protocol class.

//

// Mux0710Protocol.cpp

/** @file Mux0710Protocol.cpp

 *

 */

#include "Mux0710Protocol.h"

#include "Portfactory.h"

#include "PortC32Interface.h"

#include "CsyMsgBufBPFrame.h"

#include "ChannelMgrCmdData.h"

#include "CommFrameWriterAo.h"

#include "CommFrameReaderAo.h"

#include "ChannelMgrCtrl.h"

#include "CsyDebugLogger.h"

// AT Commands

_LIT8(KATCmdAttention,     "ATE0\r");

_LIT8(KATCmdDisableEcho,   "ATE0Q0V1\r");

_LIT8(KATCmdReset,   "AT%b\r");

_LIT8(KATCmdSleep,   "AT%SLEEP=0\r");

const TInt KRetryCount = 2;

CMux0710Protocol* CMux0710Protocol::NewL(CPortFactory& aPortFactory)

/**

 * This static method uses 2-phase construction to create an instance of

 * this class.

 *

 * @return Pointer to the created object

 */

	{

	_LOG_L4C1("CMux0710Protocol::NewL");

	CMux0710Protocol* p = new(ELeave) CMux0710Protocol(aPortFactory);

	CleanupStack::PushL(p);

	p->ConstructL();

	CleanupStack::Pop(p);

	return p;

 	}

CMux0710Protocol::~CMux0710Protocol()

/**

 * Destructor.

 */

	{

	_LOG_L4C1("CMux0710Protocol::~CMux0710Protocol");

	// Release  Free Frame Memory 

	CCsyMsgBufBpFrame* aBpFrame;

    iFreeFrameBufIter.SetToFirst();

	while ((aBpFrame = iFreeFrameBufIter++) != NULL)

		{

		iFreeFrameBufList.Remove(*aBpFrame);

		delete  aBpFrame;

	 	}  

	delete iTimeouter;

	}

CMux0710Protocol::CMux0710Protocol(CPortFactory& aPortFactory)

/**

 * Constructor.

 *

 */

 : iPortFactory(aPortFactory),

   iMuxMgrState(ECsyWaitingForFlushResp),

   iFreeFrameBufList(_FOFF(CCsyMsgBufBpFrame, iMsgLink)),

   iFreeFrameBufIter(iFreeFrameBufList),

   iRetryCount(KRetryCount)

   	{}

void CMux0710Protocol::ConstructL()

/**

 * Allocate the memory for the free frames list.

 */

	{

	_LOG_L4C1("CMux0710Protocol::ConstructL");

	iTimeouter = CActiveTimeouter::NewL(*this);

	// allocate memory for the free frame buffer

	for (TUint i=0; i < KMaxFreeFrames; i++)

		{

		CCsyMsgBufBpFrame* aBpFrame = CCsyMsgBufBpFrame::NewL();

		iFreeFrameBufList.AddLast(*aBpFrame);

		}

	iFreeFrameCount = KMaxFreeFrames;

	}

CCsyMsgBufBpFrame* CMux0710Protocol::GetFreeFrameBuf(TBool aCheckFlowControlThresholds)

/**

 * Get a free frame buffer and then remove the buffer from

 * the free list.

 *

 * @return - Pointer to a frame buffer or NULL 

 */

	{

	_LOG_L4C2(">>CMux0710Protocol::GetFreeFrameBuf [aCheckFlowControlThresholds=%d]",

		aCheckFlowControlThresholds);

	CCsyMsgBufBpFrame* frame = NULL;

	if (!iFreeFrameBufList.IsEmpty())

		{

		frame = iFreeFrameBufList.First();

		if (frame)

			{

			iFreeFrameBufList.Remove(*frame);

			iFreeFrameCount--;

			_LOG_L4C2("iFreeFrameCount=%d",iFreeFrameCount);

			if ((aCheckFlowControlThresholds)&&(iFreeFrameCount < KStopDataDlcsThreshold))

				{

				// Need to enforce some flow control

				iEnforcingFlowControl = ETrue;

				if (iFreeFrameCount == 1)

					{

					// Only one frame free - that can be used to send the MSC command

					_LOG_L4C1("Drastic action! - 1 frame free");

					iPortFactory.StopAnyDlc();

					}

				else

					{

					_LOG_L4C2("Less than %d frames free",KStopDataDlcsThreshold);

					iPortFactory.FindActiveDataDlcToStop();

					}

				}

			frame->iMsg.Zero();

			frame->MsgDlc() = KCtrlChannelDlcNum;

			frame->CompleteWhenSent() = ETrue;

			}

		}

	_LOG_L4C2("<<CMux0710Protocol::GetFreeFrameBuf [frame=0x%x]",frame);

	return frame;

	}

void CMux0710Protocol::AddFrameFreeQ(CCsyMsgBufBpFrame* aBpFrame)

/**

 * This method is called to add the specified frame buffer to the

 * free frame queue.

 *

 * @param aBpFrame - Pointer to the frame buffer

 */

	{

	_LOG_L4C2(">>CMux0710Protocol::AddFrameFreeQ [aBpFrame=0x%x]",aBpFrame);

	iFreeFrameBufList.AddLast(*aBpFrame);

	if (iEnforcingFlowControl)

		{

		if (iFreeFrameCount >= KStartDataDlcsThreshold)

			{

			// Release flow control

			_LOG_L4C2("More than %d frames free",

				KStartDataDlcsThreshold);

			// re-enable a data dlc (note only re-enable one dlc at a time)

			iEnforcingFlowControl = iPortFactory.FindDlcToEnable();

			_LOG_L4C2("iEnforcingFlowControl=%d",iEnforcingFlowControl);

			}

		}

	iFreeFrameCount++;

	//MAF __ASSERT_DEBUG((iFreeFrameCount <= KMaxFreeFrames),PANIC(KPanicIllegalState));

	_LOG_L4C2("<<CMux0710Protocol::AddFrameFreeQ iFreeFrameCount=%d",

		iFreeFrameCount);

	}

TUint8 CMux0710Protocol::CalcFCS(TUint8* aBuffer, TInt aLen)

/**

 * This method calculates the checkSum for the specified buffer

 * with the specified length.

 *

 * @param aBuffer - Pointer to the data buffer

 * @param aLen    - Length of Number of bytes in the Buffer for which CheckSum to be calculated

 * @return checksum

 */

	{

    TUint8 frameCheckSum = 0xFF;

	aBuffer++;

	for (TInt i=0; i < aLen; i++ )

		{

		frameCheckSum = crctable[(frameCheckSum ^ (*aBuffer++))];

		}

	// One's Complement

	frameCheckSum = (TUint8) ((TUint8)(0xFF) - frameCheckSum);

	return frameCheckSum;

	}

TInt CMux0710Protocol::Create0710DataFrames(TDesC8& aMsgBuf, 

											   const TUint8 aDlcNum)

/**

 * This method is called by channel manager objects to fragment

 * a client message into frames for transmission to the BP.

 * The length of the client message is determined, the client message is

 * fragment into 27.010 format, and the formatted frames are added to the

 * write frame queue.

 *

 * @param aMsgBuf - Pointer to the client message

 * @param aDlcNum - DLC number

 * @return KErrNone, KErrArgument, or KErrNoMemory

 */

	{

	_LOG_L4C2(">>CMux0710Protocol::Create0710DataFrames [aDlcNum=%d]",

		aDlcNum);

	TInt ret = KErrNone;

	TInt msgLength   = aMsgBuf.Length();

	TInt offset      = 0;

	TInt frameLength = 0;

	TInt maxFrameLength = KMaxFrameSize;

	TBool beginFlag = ETrue;

	TBool endFlag = EFalse;

	_LOG_L4C2("msgLength = %d", msgLength);

	if (msgLength > 0)

		{

		while ((msgLength > 0)&&(ret == KErrNone))

			{

			CCsyMsgBufBpFrame* bpFrame = GetFreeFrameBuf();

			if (bpFrame)

				{

				// Set up the frame

				bpFrame->MsgDlc() = aDlcNum;

				if (msgLength > maxFrameLength)

					{

					_LOG_L4C3("Fragmenting (%d > %d)",msgLength,maxFrameLength);

					frameLength = maxFrameLength;

					bpFrame->CompleteWhenSent() = EFalse;

					}

				else

					{

					_LOG_L4C1("No Fragment");

					frameLength = msgLength;

					bpFrame->CompleteWhenSent() = ETrue;

					endFlag = ETrue;

					}

				// Test for convergence layer 4

				CPortC32InterfaceBase* port = 

					iPortFactory.FindPortC32Interface(aDlcNum);

				if (port)

					{

					if (port->GetClientType() == CPortFactory::EC32ClientIpNif)

						{

						_LOG_L4C1("Layer 4 frame");

						Create0710UIHLayer4FrameFromMsg(aMsgBuf, offset, 

							bpFrame, frameLength, aDlcNum, beginFlag, endFlag);

						// No longer the beginning

						beginFlag = EFalse;

						}

					else

						{

						_LOG_L4C1("Normal frame");

						Create0710UIHFrameFromMsg(

							aMsgBuf, offset, bpFrame, frameLength, aDlcNum);

						}

					_LOG_L4C1("Writing the frame");

					ret = iCommWriter->Write(bpFrame);

					}

				else

					{

					_LOG_L1C2("** No port defined for aDlcNum=%d",

						aDlcNum);

					}

				}

			else

				{

				// error no free frame available

				_LOG_L1C1("** No free frame buffer **");

				ret = KErrNoMemory;

				}

			msgLength -= frameLength;

			offset += maxFrameLength;

			}

		}

	else

		{

		ret = KErrArgument;

		}

	_LOG_L4C2("<<CMux0710Protocol::Create0710DataFrames [ret=%d]",ret);

	return ret;

	}

void CMux0710Protocol::Create0710UIHFrameFromMsg(TDesC8& aMsgBuf,

												 TInt aOffset,

												 CCsyMsgBufBpFrame* aFrameBuf,

												 TInt aLength,

												 TUint8 aDlcNum)

/**

 * This method creates an 27.010 UIH frame from a message.

 * NOTE: This method assumes that a free frame buffer has been allocated.

 *

 * @param aMsgBuf - Pointer to a CSY memory element pointing to a Msg

 * @param aOffset - Offset from the start of the message to be copied to the frame.

 *                  This is needed if the calling method needs to defragment a long message.

 * @param aFrameBuf - Pointer to a CSY memory elelemt pointing to a Frame

 * @param aLength   - Length of the payload to be copied.

 * @param aDlcNum   - DLC channel number.

 */

    {

	_LOG_L4C3(">>CMux0710Protocol::Create0710UIHFrameFromMsg [aOffset=%d,aLength=%d]",aOffset,aLength);

	aFrameBuf->iMsg.Zero();

	// set initial length for headers

#ifdef _27010ADVANCEOPTION

	aFrameBuf->iMsg.SetLength(3);

#else

	aFrameBuf->iMsg.SetLength(4);

#endif

	// Octet 0 = Start Flag

	aFrameBuf->iMsg[0] = KCsy0710StartEndFlag;

	// Octet 1 = Non-extended Address, Command/Response, DLCI number

	aFrameBuf->iMsg[1] = (TUint8) ((aDlcNum << 2) | 0x03);  // Set the DLCI, EA, C/R

	// Octet 2 = Control Field = Frame Type (UIH)

	aFrameBuf->iMsg[2] = (TUint8) KCsy0710CTLUIH;

#ifdef _27010ADVANCEOPTION

	TInt checksumLength = 2;

#else

	// Octet 3 = Length indicator

	// ASSUME only 1 byte needed for length size

	//    27.010 supports 7 bits in Octet 3 to indicate a length up to 128 bytes long

	aFrameBuf->iMsg[3] = (TUint8) ((aLength << 1) | KCsy0710EA);

	// CRC Frame check : Basic Option  -> for Addr, Control, Length Fields only

	// length = 3 bytes  [Addr(1) + Control(1) + Length (1)]

	TInt checksumLength = 3;

#endif

	TUint8 checksum;

	checksum = (TUint8) CalcFCS(&aFrameBuf->iMsg[0], checksumLength);

	// Octet 5-x

	//CCsyMsgBufClient* csyMsgBufClient = STATIC_CAST(CCsyMsgBufClient*, aMsgBuf);

	const TUint8* temp = &aMsgBuf[aOffset];

	aFrameBuf->iMsg.Append(temp, aLength);

	TInt tempLength = aFrameBuf->iMsg.Length();

	aFrameBuf->iMsg.SetLength(tempLength + 2);

	aFrameBuf->iMsg[tempLength] = checksum;

	aFrameBuf->iMsg[tempLength+1] = KCsy0710StartEndFlag;

 	_LOG_L4C1("<<CMux0710Protocol::Create0710UIHFrameFromMsg");

	}

void CMux0710Protocol::Create0710UIHLayer4FrameFromMsg(TDesC8& aMsgBuf, 

													   TInt aOffset, 

													   CCsyMsgBufBpFrame* aFrameBuf, 

													   TInt aLength, 

													   TUint8 aDlcNum, 

													   TBool aLayer4Begin, 

													   TBool aLayer4End)

/**

 * This method creates an 27.010 UIH frame from a message.

 * NOTE: This method assumes that a free frame buffer has been allocated.

 *

 * @param aMsgBuf - Pointer to a CSY memory element pointing to a Msg

 * @param aOffset - Offset from the start of the message to be copied to the frame.

 *                  This is needed if the calling method needs to defragment a long message.

 *                  This method builds the message as a Convergence Layer 4 type, so

 *                  only Advanced Option.

 * @param aFrameBuf - Pointer to a CSY memory elelemt pointing to a Frame

 * @param aLength   - Length of the payload to be copied.

 * @param aDlcNum   - DLC channel number.

 * @param aLayer4Begin - Beginning of Convergence Layer 4.

 * @param aLayer4End   - End of Convergence Layer 4.

 */

    {

	_LOG_L4C3(">>CMux0710Protocol::Create0710UIHLayer4FrameFromMsg [aOffset=%d,aLength=%d]",aOffset,aLength);

	_LOG_L4C3("[aLayer4Begin=%d,aLayer4End=%d]",aLayer4Begin,aLayer4End);

	//aFrameBuf->iMsg.Zero(); - this is done in GetFreeFrameBuf

	// set initial length for headers

	aFrameBuf->iMsg.SetLength(3);

	// Octet 0 = Start Flag

	aFrameBuf->iMsg[0] = KCsy0710StartEndFlag;