/*

* Copyright (c) 2005 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:  Implementation

*

*/

#include "CTcSerialConnection.h"

#include "debuglog.h"

#include "ErrorHandling.h"

CTcSerialConnection::CTcSerialConnection( 

    RCommServ& aCommServ, 

    const TDesC& aPortName, 

    TUint aPortSpeed ) :

    iCommServ( aCommServ ),

    iPortName( aPortName ),

    iPortSpeed( aPortSpeed )

	{

	}

CTcSerialConnection::~CTcSerialConnection()

	{

	Cancel();

	iCommPort.Close();

	}

void CTcSerialConnection::DoCancel()

    {

    iCommPort.Cancel();

    }

void CTcSerialConnection::ConnectL()

    {

    LOG( _L("CTcSerialConnection::ConnectL() start") );

	if( iState != EIdle )

		{

		User::Leave( KErrNotReady );

		}

	iState = EConnecting;

	// Open serial port

	SetupPortL();

    // Serial port can be used immediately after port opening, do some nasty

    // RunL call to get in connected state

    iStatus = KErrNone;

	RunL();

	LOG( _L("CTcSerialConnection::ConnectL() end") );

    }

void CTcSerialConnection::Close()

    {

    Cancel();

    iCommPort.Close();

    }

void CTcSerialConnection::Send( const TDesC8& aDes )

    {

   	LOG( _L("CTcSerialConnection::Send() start") );

	// Make sure we're in correct state

	__ASSERT_ALWAYS( iState == EConnected, Panic( KErrNotReady ) );

	__ASSERT_ALWAYS( !IsActive(), Panic( KErrInUse ) );

	// Start writing

	iState = ESending;

	iCommPort.Write( iStatus, aDes );

	SetActive();

	LOG( _L("CTcSerialConnection::Send() end") );

    }

void CTcSerialConnection::Receive( TDes8& aDes )

    {

   	LOG( _L("CTcSerialConnection::Receive() start") );

	// Make sure we're in correct state

	__ASSERT_ALWAYS( iState == EConnected, Panic( KErrNotReady ) );

	__ASSERT_ALWAYS( !IsActive(), Panic( KErrInUse ) );

	// Start reading

	iState = EReceiving;

	iCommPort.Read( iStatus, aDes );

	SetActive();

	LOG( _L("CTcSerialConnection::Receive() end") );

    }

void CTcSerialConnection::ReceiveOneOrMore( TDes8& aDes )

    {

    LOG( _L("CTcSerialConnection::ReceiveOneOrMore() start") );

	// Make sure we're in correct state

	__ASSERT_ALWAYS( iState == EConnected, Panic( KErrNotReady ) );

	__ASSERT_ALWAYS( !IsActive(), Panic( KErrInUse ) );

	// Start reading

	iState = EReceiving;

	iCommPort.ReadOneOrMore( iStatus, aDes );

	SetActive();

	LOG( _L("CTcSerialConnection::ReceiveOneOrMore() end") );

    }

void CTcSerialConnection::SetupPortL()

	{

	LOG( _L("CTcSerialConnection::SetupPortL()") );

	SetupPortBaudrateValuesL();

	User::LeaveIfError( iCommPort.Open( iCommServ, iPortName, ECommShared ) );

    // Configure port, chack first whether ports supports settings we want

	TCommCaps ourCapabilities;

	iCommPort.Caps( ourCapabilities );

	if ( ( ( ourCapabilities().iRate & iBaudrateCap ) == 0 ) ||

		 ( ( ourCapabilities().iDataBits & KCapsData8 ) == 0 ) ||

		 ( ( ourCapabilities().iStopBits & KCapsStop1 ) == 0 ) ||

		 ( ( ourCapabilities().iParity & KCapsParityNone ) == 0 ) )

	    {

		User::Leave( KErrNotSupported );

	    }

	TCommConfig portSettings;

	iCommPort.Config( portSettings );

	portSettings().iRate = iBaudrate;

	portSettings().iParity = EParityNone;

	portSettings().iDataBits = EData8;

	portSettings().iStopBits = EStop1;

	// as well as the physical characteristics, we need to set various logical ones

	// to do with handshaking, behaviour of reads and writes and so so

	portSettings().iFifo = EFifoEnable;

	portSettings().iHandshake = ( KConfigObeyCTS | KConfigFreeRTS ); // for cts/rts

    portSettings ().iTerminator[ 0 ] = 10;

	portSettings ().iTerminatorCount = 1; // so that we terminate a read on each line feed arrives

	User::LeaveIfError( iCommPort.SetConfig( portSettings ) );

	// now turn on CTS and RTS 

	iCommPort.SetSignals( KSignalCTS, 0 );

	iCommPort.SetSignals( KSignalRTS, 0 );

	// (perhaps set our receive buffer size also)

	//TInt curlenth = commPort.ReceiveBufferLength();

	//commPort.SetReceiveBufferLength( KTcRequestMaxLength );

	LOG( _L("CTcSerialConnection::ConnectL() done") );

	}

void CTcSerialConnection::SetupPortBaudrateValuesL()

    {

    LOG( _L("CTcSerialConnection::SetupPortBaudrateValuesL()") );

    switch ( iPortSpeed )

        {

        case 1200:

            {

            iBaudrate = EBps1200;

            iBaudrateCap = KCapsBps1200;

            break;

            }

        case 1800:

            {

            iBaudrate = EBps1800;

            iBaudrateCap = KCapsBps1800;

            break;

            }

        case 2000:

            {

            iBaudrate = EBps2000;

            iBaudrateCap = KCapsBps2000;

            break;

            }

        case 2400:

            {

            iBaudrate = EBps2400;

            iBaudrateCap = KCapsBps2400;

            break;

            }

        case 3600:

            {

            iBaudrate = EBps3600;

            iBaudrateCap = KCapsBps3600;

            break;

            }

        case 4800:

            {

            iBaudrate = EBps4800;

            iBaudrateCap = KCapsBps4800;

            break;

            }

        case 7200:

            {

            iBaudrate = EBps7200;

            iBaudrateCap = KCapsBps7200;

            break;

            }

        case 9600:

            {

            iBaudrate = EBps9600;

            iBaudrateCap = KCapsBps9600;

            break;

            }

        case 19200:

            {

            iBaudrate = EBps19200;

            iBaudrateCap = KCapsBps19200;

            break;

            }

        case 38400:

            {

            iBaudrate = EBps38400;

            iBaudrateCap = KCapsBps38400;

            break;

            }

        case 57600:

            {

            iBaudrate = EBps57600;

            iBaudrateCap = KCapsBps57600;

            break;

            }        

         case 115200:

            {

            iBaudrate = EBps115200;

            iBaudrateCap = KCapsBps115200;

            break;

            }

        default:

            {

            User::Leave( KErrArgument );

            break;

            }

        }

    }