//
// * 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:  The CChannelMgrCmdData class defines a single 3GPP 27.010 based logical channel
// *               called DLC. Derived control and data channel add specific behavior.
//

// ChannelMgrCmdData.cpp

/** @file ChannelMgrCmdData.cpp
 *
 */

#include "ChannelMgrCmdData.h"
#include "PortC32InterfaceBase.h"
#include "PortC32Interface.h"
#include "CsyMsgBufBPFrame.h"
#include "CsyDebugLogger.h"

CChannelMgrCmdData* CChannelMgrCmdData::NewL(const TUint8 aDlcNum,
											 CPortFactory& aPortFactory,
											 CMux0710Protocol& aMux0710Protocol)
/**
 * This methods uses two phase construction and the cleanup stack to create
 * an instance of class CChannelMgrCmd.
 * @param aDlcNum - DLC number of this channel
 * @param aPortFactory - Reference to the port factory
 * @param aMux0710Protocol - Pointer to the 27.010 mux protocol
 * @return Pointer to the created instance
 */
    {
	_LOG_L4C2("CChannelMgrCmdData::NewL [aDlcNum=%d]", aDlcNum);

    CChannelMgrCmdData* p = new(ELeave) CChannelMgrCmdData(aDlcNum, aPortFactory,
														   aMux0710Protocol);
 	CleanupStack::PushL(p);
 	p->ConstructL();
	CleanupStack::Pop(p);
 	return p;
	}

CChannelMgrCmdData::~CChannelMgrCmdData()
/**
 * Destructor. Delete all resources and memory allocated by this object.
 * Disconnect the channel from the multiplexer.
 */
	{
    _LOG_L4C1("CChannelMgrData::~CChannelMgrCmdData");
	}


CChannelMgrCmdData::CChannelMgrCmdData(const TUint8 aDlcNum,
									   CPortFactory& aPortFactory,
									   CMux0710Protocol& aMux0710Protocol)
: CChannelMgrBase(aDlcNum, aPortFactory, aMux0710Protocol),
  iCount(0)
/**
 * Constructor.
 * @param aDlcNum - DLC number of this channel
 * @param aPortFactory - Reference to the port factory
 * @param aMux0710Protocol - Reference to the 27.010 mux protocol
 */
 	{
	iCsyAllowedToSendFrames = EFlowControlOn;
	}

void CChannelMgrCmdData::ConstructL()
/**
 * Create any instances and allocate any memory used by this object.
 */
 	{
	CChannelMgrBase::ConstructL();
	}

void CChannelMgrCmdData::Open(CPortC32InterfaceBase* aPort)
/**
 * Open the port
 *
 * @param aPort - Pointer to CPortC32Interface
 */
	{
	_LOG_L4C2(">>CChannelMgrCmdData::Open [aPort=0x%x]",aPort);
	
	iCount++;
	if (iCount == 1)
		{
		_LOG_L4C1("First client of port");
		
		if (aPort->GetClientType() == CPortFactory::EC32ClientIpNif)
			{
			ParameterNegotiate();
			}
		else
			{
			TInt err = Connect();
			if (err != KErrNone)
				_LOG_L4C2("Open Connect error =%d",err);				
			}
	}
	iPortArray.Insert(aPort,0);
	SetOwner(aPort);

	_LOG_L4C2("<<CChannelMgrCmdData::Open [iCount=%d]",iCount);
	}

void CChannelMgrCmdData::Close(CPortC32InterfaceBase* aPort)
/**
 * Close the port
 *
 * @param aPort - Pointer to CPortC32Interface
 */
	{
	_LOG_L4C2(">>CChannelMgrCmdData::Close [aPort=%d]",aPort->GetPortNumber());

	iCount--;
	if (iCount < 1)
		{
		_LOG_L4C1("Last client of port");
		Disconnect();
		iCount = 0; // reset counter
		iChannelReady = EFalse;
		}

	// remove port from the port list, set next port in the queue to be the port owner
	TInt index;
	index = iPortArray.Find(aPort);
	if (index == KErrNotFound)
		{
		_LOG_L1C2("** Close() - Port %d not found **", aPort);
		}
	else
		{
		iPortArray.Remove(index);
		if (iPortC32Interface == aPort)
			{
			// close the current owner of the channel, set owership to the first one in the port list
			// if there are one
			if (iPortArray.Count() > 0)
				SetOwner(iPortArray[0]);
			else
				SetOwner(NULL);
			}
		}

	_LOG_L4C2("<<CChannelMgrCmdData::Close [iCount=%d]",iCount);
	}

void CChannelMgrCmdData::SetOwner(CPortC32InterfaceBase* aPort)
/**
 * Set owner to the pointer
 * @param aPort - Pointer to new owner, which is a CPortC32Interface instance
 */
	{
	_LOG_L4C1(">>CChannelMgrCmdData::SetOwner");
	
	if (iPortC32Interface == aPort)
		return;

	if (iPortC32Interface != NULL)
		iPortC32Interface->CompleteOutstandingRequest();

	if (aPort == NULL)
		{
		iPortC32Interface = aPort;
		_LOG_L4C1("<<CChannelMgrCmdData::SetOwner aPort was Null");
		return;
		}

	TInt index;
	index = iPortArray.Find(aPort);
	if (index == KErrNotFound)
		{
		_LOG_L1C2("** Port %d not found **", aPort);
		}
	else
		{
		iPortC32Interface = aPort;
		}

	_LOG_L4C1("<<CChannelMgrCmdData::SetOwner");
	}

void CChannelMgrCmdData::SetupCmdChannelsForATCmdsL()
/**
 * Set up and prepare the ports for AT commands
 */
	{
	_LOG_L4C1("CChannelMgrCmdData::SetupCmdChannelsForATCmdsL");
#if defined DSAMPLE || defined H2
	_LOG_L4C1("Setting up for DSample/H2 (or P2Sample on Wins)");
#endif
#ifdef P2SAMPLE
	_LOG_L4C1("Setting up for P2Sample on TARGET");
#endif

	TBuf8<20> temp;
	temp.Copy(KATCmdSetup);
	iMux0710Protocol.Create0710DataFrames(temp, (TInt8)GetDlcNumber());
	}

void CChannelMgrCmdData::ProcessRecvUihFrame(CCsyMsgBufBpFrame* aBpFrame)
/**
 * Process a received UIH frame. Set flow control off if an "ok" is received
 * and we are still initializing.
 *
 * @param aBpFrame - Pointer to the frame received from the baseband
 */
	{
#ifdef _DEBUG
	// The dlcNum is only needed for logging when _DEBUG is set.
	// Otherwise we get a warning for ARM v5
	TInt dlcNum;
	dlcNum = aBpFrame->GetDlcNum();
#endif

	if(!iInitFinished)
		{
		if (iChannelState != ECsyChannelStateConnected)
			{
			_LOG_L4C1("Waiting for AT interpreter");
			if (aBpFrame->iMsg.Find(KATInitialised) != KErrNotFound)
				{
				_LOG_L3C2E("AT interpreter ready [dlcNum=%d]", dlcNum);
				iChannelState = ECsyChannelStateConnected;
				// Send initial AT command
				TRAP_IGNORE(SetupCmdChannelsForATCmdsL());
				}
			else
				{
				_LOG_L3C2E("Throw away unexpected response dlcNum=%d", dlcNum);
				}
			}
		else
			{
			_LOG_L4C1("Waiting for response to initial AT command");
			if (aBpFrame->iMsg.Find(_L8("OK")) != KErrNotFound)
				{
				_LOG_L1C2E("**** Init completed [dlcNum=%d] ****", dlcNum);
				NotifyChannelReady();
				ModemAndCsyToClientFlowCtrl(EFlowControlOff);
				}
			/*else if (aBpFrame->iMsg.Find(_L8("ERROR")) != KErrNotFound)
				{
				_LOG_L1C2E("**** Init completed [dlcNum=%d] ****ERROR****", dlcNum);
				NotifyChannelReady();
				ModemAndCsyToClientFlowCtrl(EFlowControlOff);
				}
			*/
			else
				{
				_LOG_L3C2E("Throw away unexpected response dlcNum=%d", dlcNum);
				}
			}
		iMux0710Protocol.AddFrameFreeQ(aBpFrame);
		}
	else if (iPortC32Interface)
		{
		// don't need to add to the mux's queue if we are not defragging messages
		// simply add to the port object's queue
		// send frame to client
		iPortC32Interface->SendFrameToClient(aBpFrame);
		}
	else
		{
		_LOG_L1C2E("** NULL C32 PORT ** dlcNum=%d", dlcNum);
		iMux0710Protocol.AddFrameFreeQ(aBpFrame);
		// MAF __ASSERT_DEBUG(EFalse, PANIC(KPanicIllegalState));
		}
	}