/*

* Copyright (c) 2007,2008 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:  Channel class of Orientation SSY

*

*/

#include <ssycallback.h>

#include <sensrvorientationsensor.h>

#include "SsyChannel.h"

#include "SsyOrientation.h"

#include "SsyProperty.h"

#include "SsyConfiguration.h"

#include "SsyTrace.h"

#ifdef _DEBUG

// ----------------------------------------------------------------------------------

// ConvertChannelStateIntoString()

// Helper function for printing this channel into a "string"

// ----------------------------------------------------------------------------------

// 

const TDesC* ConvertChannelStateIntoString( TChannelState aChannelState )

    {

    _LIT(KChannelIdle,              "EChannelIdle");

    _LIT(KChannelOpening,           "EChannelOpening");

    _LIT(KChannelOpen,              "EChannelOpen");

    _LIT(KChannelClosing,           "EChannelClosing");

    _LIT(KChannelListening,         "EChannelListening");

    _LIT(KChannelDataReceived,      "EChannelDataReceived");

    _LIT(KChannelStopListening,     "EChannelStopListening");

    _LIT(KChannelForceBufferFilled, "EChannelForceBufferFilled");

    _LIT(KChannelBufferFilled,      "EChannelBufferFilled");

    _LIT(KDefault,                  "EDefault");

    switch ( aChannelState )

        {

        case EChannelIdle:

            return &KChannelIdle;

        case EChannelOpening:

            return &KChannelOpening;

        case EChannelOpen:

            return &KChannelOpen;

        case EChannelClosing:

            return &KChannelClosing;

        case EChannelListening:

            return &KChannelListening;

        case EChannelDataReceived:

            return &KChannelDataReceived;

        case EChannelStopListening:

            return &KChannelStopListening;

        case EChannelForceBufferFilled:

            return &KChannelForceBufferFilled;

        case EChannelBufferFilled:

            return &KChannelBufferFilled;

        default:

            return &KDefault;

        }

    }

#endif

// ----------------------------------------------------------------------------------

// CSSYChannel::CSSYChannel()

// ----------------------------------------------------------------------------------

// 

CSSYChannel::CSSYChannel( CSSYProperty* aProperty,

                          MSsyCallback* const aCallBack,                                  

                          const TSensrvChannelInfo& aChannelInfo ) :

    CActive( EPriorityStandard ),

    iOrientationHandler( NULL ),

    iChannelProperties( NULL ),

    iSensorProperties( aProperty ),

    iCallback( aCallBack ),

    iChannelState( EChannelIdle ),

    iChannelInfo( aChannelInfo ),

    iBuffer( NULL ),

    iCount( 0 ),

    iCountReceived( 0 ),

    iWritePointer( NULL )

    {

    SSY_TRACE_IN();

    //ASSERT_DEBUG_SSY( aCallBack );

    // Add our active object to the process active scheduler

    CActiveScheduler::Add( this );

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::NewL()

// ----------------------------------------------------------------------------------

// 

CSSYChannel* CSSYChannel::NewL( CSSYProperty* aProperty,

                                MSsyCallback* const aCallBack,                                  

                                const TSensrvChannelInfo& aChannelInfo )

    {

    SSY_TRACE_IN();

    ASSERT_DEBUG_SSY( aCallBack );

    if ( !aCallBack )

        {

        User::Leave( KErrArgument );

        }

    CSSYChannel* self = new( ELeave ) CSSYChannel( aProperty, aCallBack, aChannelInfo );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    SSY_TRACE_OUT();

    return self;

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::ConstructL()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::ConstructL()

    {

    SSY_TRACE_IN();

    _LIT( KThreadName, "OrientationThread" );

    RThread thread;

    thread.RenameMe( KThreadName );

    // Create channel properties

    if ( iChannelInfo.iChannelType == KSensrvChannelTypeIdOrientationData )

        {        

        iChannelProperties = new (ELeave) CSSYProperty( 

                                            0, 

                                            KSSyChannelOrientationProperties, 

                                            ARRAY_LENGTH( 

                                                KSSyChannelOrientationProperties) );

        }

    else if ( iChannelInfo.iChannelType == KSensrvChannelTypeIdRotationData )

        {        

        iChannelProperties = new (ELeave) CSSYProperty( 

                                            0, 

                                            KSSyChannelRotationProperties, 

                                            ARRAY_LENGTH( 

                                                KSSyChannelRotationProperties) );

        }    

    // Create orientation handler

    iOrientationHandler = new (ELeave) CSSYOrientation( iChannelInfo.iChannelType );

    iOrientationHandler->ConstructL();

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::~CSSYChannel()

// ----------------------------------------------------------------------------------

// 

CSSYChannel::~CSSYChannel()

    {

    SSY_TRACE_IN();

    Cancel();

    delete iChannelProperties;

    iChannelProperties = NULL;

    delete iOrientationHandler;

    iOrientationHandler = NULL;

    // These pointers are not owned

    iSensorProperties = NULL; // Pointer assigned in cosntructor

    iCallback = NULL;         // Pointer assigned in cosntructor

    iBuffer = NULL;           // Assigned in StartChannelData

    iWritePointer = NULL;     // Assigned in AppendData

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::DoCancel()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::DoCancel()

    {

    SSY_TRACE_IN();

    // Try to stop the channel, ignore errors

    TRAP_IGNORE( StopChannelDataL( iChannelInfo.iChannelId ) );

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::RunError()

// ----------------------------------------------------------------------------------

// 

TInt CSSYChannel::RunError( TInt aError )

    {

    SSY_TRACE( EMust, "ORIENTATIONSSY:RunError %d", aError );

    return KErrNone;

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::SetChannelState()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::SetChannelState( const TChannelState aChannelState )

    {

#ifdef _DEBUG

    SSY_TRACE( EMust, "ORIENTATIONSSY:State change from %S to %S with channelId %d",

               ConvertChannelStateIntoString(iChannelState), 

               ConvertChannelStateIntoString(aChannelState), 

               iChannelInfo.iChannelId );

#endif

    iChannelState = aChannelState;

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::AppendData()

// ----------------------------------------------------------------------------------

// 

TBool CSSYChannel::AppendData( 

    const TSensrvOrientationData& aOrientationData, 

    const TSensrvRotationData& aRotationData )

    {

    TBool ret( ETrue );

    if ( iChannelState == EChannelDataReceived )

        {

        if( iCountReceived == 0 )

            {

            SSY_TRACE( EExtended, "ORIENTATIONSSY:First data append to buffer" );

            iWritePointer = iBuffer;

            }

        ASSERT_DEBUG_SSY( iWritePointer );

        if ( !iWritePointer )

            {

            return EFalse;

            }

        if ( iChannelInfo.iChannelType == KSensrvChannelTypeIdOrientationData )

            {

            TSensrvOrientationData* p = reinterpret_cast<TSensrvOrientationData*>(iWritePointer);

            p->iTimeStamp = aOrientationData.iTimeStamp;

            p->iDeviceOrientation = aOrientationData.iDeviceOrientation;

            iWritePointer += sizeof( TSensrvOrientationData );

            }

        else if ( iChannelInfo.iChannelType == KSensrvChannelTypeIdRotationData )

            {

            TSensrvRotationData* p = reinterpret_cast<TSensrvRotationData*>(iWritePointer);

            p->iDeviceRotationAboutZAxis = aRotationData.iDeviceRotationAboutZAxis;

            p->iDeviceRotationAboutXAxis = aRotationData.iDeviceRotationAboutXAxis;

            p->iDeviceRotationAboutYAxis = aRotationData.iDeviceRotationAboutYAxis;

            p->iTimeStamp = aRotationData.iTimeStamp;

            iWritePointer += sizeof( TSensrvRotationData );

            }

        else

            {

            ret = EFalse;

            }

        }

    else

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: Trying to append while not listening ", ChannelId() );

        ret = EFalse;

        }

    return ret;

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::RunL()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::RunL()

    {

    SSY_TRACE_IN();

    SSY_TRACE( EMust, "ORIENTATIONSSY:RunL in state %S", ConvertChannelStateIntoString(iChannelState) );

    switch ( iChannelState )

        {

        case EChannelIdle:

            break;

        case EChannelOpening:

            {

            // Before completing channel opening, get max data rate from actual SSY

            if ( !iSensorProperties->DataRateUpdated() )

                {

                TSensrvProperty maxdatarate;

                RSensrvChannelList affectedChannels;

                // Get max data rate

                iOrientationHandler->GetMaxDataRateL( maxdatarate );

                // Set property

                iSensorProperties->SetProperty( maxdatarate, affectedChannels );

                }

            SetChannelState( EChannelOpen );

            iCallback->ChannelOpened( iChannelInfo.iChannelId, iStatus.Int(), this, this );

            break;

            }

        case EChannelOpen:

            break;

        case EChannelClosing:

            SetChannelState( EChannelIdle );

            iCallback->ChannelClosed( iChannelInfo.iChannelId );

            break;

        case EChannelListening:

            SetChannelState( EChannelDataReceived );

            iOrientationHandler->GetDataFromHardware( this );

            break;

        case EChannelDataReceived:

            // Channel excepted data, increase the receive counter

            iCountReceived++;

            if( iCountReceived == iCount )

                {

                SetChannelState( EChannelBufferFilled );

                }

            else

                {

                SetChannelState( EChannelListening );

                }

            IssueRequest();

            break;

        case EChannelStopListening:

            SetChannelState( EChannelOpen );

            iBuffer        = NULL;

            iCount         = 0;

            iCountReceived = 0;

            break;

        case EChannelForceBufferFilled:

            // Intentional flowthrough

        case EChannelBufferFilled:

            iBuffer = NULL;

            iCount  = 0;

            iCallback->BufferFilled( iChannelInfo.iChannelId, iCountReceived, iBuffer, iCount );

            // Check that client did not change the state in the callback function

            if ( iChannelState == EChannelForceBufferFilled ||

                 iChannelState == EChannelBufferFilled )

                {

                iCountReceived = 0;

                if ( iBuffer && iCount )

                    {

                    SetChannelState( EChannelListening );

                    }

                else

                    {

                    SSY_TRACE( EError, "ORIENTATIONSSY:ERROR:New buffer and/or count values are wrong!" );

                    iOrientationHandler->StopListeningL();

                    SetChannelState( EChannelStopListening );

                    }

                IssueRequest();

                }

            break;

        default:

            ASSERT_DEBUG_SSY( 0 );

            break;

        }

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::IssueRequest()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::IssueRequest( TInt aError )

	{

    SSY_TRACE_IN();

	if ( !IsActive() )

        {

        iStatus = KRequestPending;

	    TRequestStatus *status = &iStatus;

	    User::RequestComplete( status, aError );

        SSY_TRACE( EExtended, "ORIENTATIONSSY:Setactive for channelId %d", iChannelInfo.iChannelId );

	    SetActive();

        }

    SSY_TRACE_OUT();

	}

// ----------------------------------------------------------------------------------

// CSSYChannel::StartChannelDataL()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::StartChannelDataL( const TSensrvChannelId aChannelId, 

                                     TUint8* aBuffer, 

                                     TInt aCount )

    {

    SSY_TRACE_IN();

    SSY_TRACE( EExtended, "ORIENTATIONSSY:ChannelId %d", iChannelInfo.iChannelId ); 

    if ( ChannelId() != aChannelId )

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: StartChannelDataL wrong channelId!" );

        User::Leave( KErrArgument );

        }

    ASSERT_DEBUG_SSY( aBuffer );

    ASSERT_DEBUG_SSY( aCount );

    if ( !aBuffer || !aCount )

        {

        User::Leave( KErrArgument );

        }

    iBuffer = aBuffer;

    iCount  = aCount;

    SSY_TRACE( EExtended, "ORIENTATIONSSY:New data buffer: 0x%x", iBuffer );

    SSY_TRACE( EExtended, "ORIENTATIONSSY:New data count : %d", iCount );

    if ( iChannelState & KChannelCanBeListened )

        {

        iOrientationHandler->StartListeningL();

        SetChannelState( EChannelListening );

        IssueRequest();

        }

    else

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: Trying to listen a channel that is not open! channelId: %d, state: %S", 

                   aChannelId,

                   ConvertChannelStateIntoString( iChannelState ) );

        User::Leave( KErrGeneral );

        }

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::StopChannelDataL()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::StopChannelDataL( const TSensrvChannelId aChannelId )

    {

    SSY_TRACE_IN();

    SSY_TRACE( EExtended, "ORIENTATIONSSY::ChannelId %d", iChannelInfo.iChannelId ); 

    if ( ChannelId() != aChannelId )

        {

        SSY_TRACE( EError, "ORIENTATIONSSY::ERROR: StartChannelDataL wrong channelId!" );

        User::Leave( KErrArgument );

        }

    if ( iChannelState & KChannelCanBeStopped )

        {

        iOrientationHandler->StopListeningL();

        SetChannelState( EChannelStopListening );

        IssueRequest();

        }

    else

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: Trying to stop listening a channel that is not listened! channelId: %d, state: %S",

                   aChannelId,

                   ConvertChannelStateIntoString( iChannelState ) );

        User::Leave( KErrGeneral );

        }

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::ForceBufferFilledL()

// ----------------------------------------------------------------------------------

// 

void CSSYChannel::ForceBufferFilledL( const TSensrvChannelId aChannelId )

    {

    SSY_TRACE_IN();

    SSY_TRACE( EExtended, "ORIENTATIONSSY:ChannelId %d", iChannelInfo.iChannelId ); 

    if ( ChannelId() != aChannelId )

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: StartChannelDataL wrong channelId!" );

        User::Leave( KErrArgument );

        }

    if( iChannelState & KChannelCanBeFilled )

        {

        SetChannelState( EChannelForceBufferFilled );

        IssueRequest();

        }

    else

        {

        SSY_TRACE( EError, "ORIENTATIONSSY:ERROR: ForceBufferFilledL called in incorrected state! channelId: %d, state: %S",

                   aChannelId,

                   ConvertChannelStateIntoString( iChannelState ) );

        User::Leave( KErrGeneral );

        }

    SSY_TRACE_OUT();

    }

// ----------------------------------------------------------------------------------

// CSSYChannel::ChannelId()

// ----------------------------------------------------------------------------------

// 

TSensrvChannelId CSSYChannel::ChannelId()