// ssyreferencechanneldataprovider.cpp

// Copyright (c) 2006-2009 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:

//

#include "ssyreferencechanneldataprovider.h"

#include "ssyreferencetrace.h"

#include "ssyreferencechannel.h"

#include "ssyreferencecontrol.h"

#include "ssyreferencecmdhandler.h"

#include <sensors/spi/ssycallback.h>

// ======== MEMBER FUNCTIONS ========

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

// CSsyReferenceChannelDataProvider C++ constructor

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

//

CSsyReferenceChannelDataProvider::CSsyReferenceChannelDataProvider( CSsyReferenceChannel& aChannel ) :

    iChannel( aChannel )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::CSsyReferenceChannelDataProvider()" ) ) );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::CSsyReferenceChannelDataProvider() - return" ) ) );

    }

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

// Symbian 2nd phase constructor

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

//

void CSsyReferenceChannelDataProvider::ConstructL()

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ConstructL()" ) ) );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ConstructL() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::NewL

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

//

CSsyReferenceChannelDataProvider* CSsyReferenceChannelDataProvider::NewL( CSsyReferenceChannel& aChannel )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::NewL()" ) ) );

    CSsyReferenceChannelDataProvider* self = new ( ELeave ) CSsyReferenceChannelDataProvider( aChannel );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::NewL() - return" ) ) );

    return self;

    }

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

// Destructor

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

//

CSsyReferenceChannelDataProvider::~CSsyReferenceChannelDataProvider()

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::~CSsyReferenceChannelDataProvider()" ) ) );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::~CSsyReferenceChannelDataProvider() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::StartChannelDataL

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

//

void CSsyReferenceChannelDataProvider::StartChannelDataL( 

    const TSensrvChannelId aChannelId, 

    TUint8* aBuffer, 

    TInt aCount )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::StartChannelDataL()" ) ) );

    if ( iChannel.ChannelId() != aChannelId )

        {

        User::Leave( KErrNotFound );

        }

    // Store buffer pointer

    iDataBuffer = aBuffer;

    iMaxCount = aCount;

    iDataCount = 0;

    // Udpate channel state

    iChannel.UpdateState( CSsyReferenceChannel::ESsyReferenceChannelReceiving );

    // Start receiving

    iChannel.CommandHandler().ProcessCommand( TSsyReferenceMsg( aChannelId, ESsyReferenceStartChannelData ) );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::StartChannelDataL() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::StopChannelDataL

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

//

void CSsyReferenceChannelDataProvider::StopChannelDataL( const TSensrvChannelId aChannelId )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::StopChannelDataL()" ) ) );

    // Leave if wrong channel

    if ( iChannel.ChannelId() != aChannelId )

        {

        User::Leave( KErrNotFound );

        }

    // Udpate channel state

    iChannel.UpdateState( CSsyReferenceChannel::ESsyReferenceChannelOpen );

    // Stop receiving

    iChannel.CommandHandler().ProcessCommand( TSsyReferenceMsg( aChannelId, ESsyReferenceStopChannelData ) );

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::StopChannelDataL() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::ForceBufferFilledL

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

//

void CSsyReferenceChannelDataProvider::ForceBufferFilledL( const TSensrvChannelId aChannelId )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ForceBufferFilledL()" ) ) );

    // Leave if wrong channel

    if ( iChannel.ChannelId() != aChannelId )

        {

        User::Leave( KErrNotFound );

        }

    // Send current buffer. Channel keeps receiveing

    SendBufferFilled();

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ForceBufferFilledL() - return" ) ) );

    }

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

// CSensrvTestCases::GetChannelDataProviderInterfaceL

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

//

void CSsyReferenceChannelDataProvider::GetChannelDataProviderInterfaceL( TUid /*aInterfaceUid*/, 

	                                        TAny*& aInterface )

    {

    aInterface = NULL;

    }

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

// CSsyReferenceChannelDataProvider::ChannelDataReceived

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

//

void CSsyReferenceChannelDataProvider::ChannelDataReceivedL( TSsyReferenceMsg* aMessage )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ChannelDataReceived()" ) ) );

    // Get base class from message

    TSsyRefChannelDataBase* dataItemBase = aMessage->DataItem();

    if ( !dataItemBase )

        {

        User::Leave( KErrArgument );

        }

    // get size of the object

    TInt size( dataItemBase->Size() );

    // First, resolve data item type

    switch ( dataItemBase->ChannelDataType() )

        {

        case TSsyRefChannelDataBase::ESsyRefChannelTypeTapping:

            {

            // Cast data item base to tapping data item

            TSsyRefChannelDataTapping* tappingData = static_cast<TSsyRefChannelDataTapping*>( dataItemBase );

            TSensrvTappingData senSrvTapping;

            senSrvTapping.iTimeStamp = tappingData->Timestamp();

            senSrvTapping.iDirection = tappingData->Direction();

            // Add mapped data item into buffer

            AddDataToBuffer( reinterpret_cast<TUint8*>( &senSrvTapping ), size );

            break;

            }

        case TSsyRefChannelDataBase::ESsyRefChannelTypeAxis:

            {

            // Cast data item base to Axis data item

            TSsyRefChannelDataAxis* axisData = static_cast<TSsyRefChannelDataAxis*>( dataItemBase );

            TSensrvAccelerometerAxisData senSrvAxis;

            senSrvAxis.iTimeStamp = axisData->Timestamp();

            senSrvAxis.iAxisX = axisData->XAxis();

            senSrvAxis.iAxisY = axisData->YAxis();

            senSrvAxis.iAxisZ = axisData->ZAxis();

            // Add data to buffer

            AddDataToBuffer( reinterpret_cast<TUint8*>( &senSrvAxis ), size );

            break;

            }

        case TSsyRefChannelDataBase::ESsyRefChannelTypeProximity:

            {

            // Cast data item base to tapping data item

            TSsyRefChannelDataProximity* proximityData = static_cast<TSsyRefChannelDataProximity*>( dataItemBase );

            TSensrvProximityData senSrvProximity;

            senSrvProximity.iProximityState = ( TSensrvProximityData::TProximityState ) proximityData->ProximityState();

            // Add mapped data item into buffer

            AddDataToBuffer( reinterpret_cast<TUint8*>( &senSrvProximity ), size );

            break;

            }

        default:

            {

            // Unknown data item -> Leave

            User::Leave( KErrUnknown );

            }

        }

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::ChannelDataReceived() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::AddDataToBuffer

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

//

void CSsyReferenceChannelDataProvider::AddDataToBuffer( TUint8* aData, const TInt aSize )

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::AddDataToBuffer()" ) ) );

    // Write data to buffer. If buffer is full, send notification to SensorServer

    // Write data bytes one by one to buffer pointer. The actual buffer is in Sensor Server    

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

        {

        *iDataBuffer++ = *aData++;

        }

    // Increase number of items count

    iDataCount++;

    // Check is maximum data count received

    if ( iDataCount == iMaxCount )

        {

        // Send BufferFilled notification to Sensor server

        SendBufferFilled();

        }

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::AddDataToBuffer() - return" ) ) );

    }

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

// CSsyReferenceChannelDataProvider::SendBufferFilled

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

//

void CSsyReferenceChannelDataProvider::SendBufferFilled()

    {

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::SendBufferFilled()" ) ) );

    // Send BufferFilled notification to Sensor server

    iChannel.SsyControl().SsyCallback().BufferFilled( iChannel.ChannelId(), iDataCount, iDataBuffer, iMaxCount );

    iDataCount = 0;

    COMPONENT_TRACE( ( _L( "SSY Reference Plugin - CSsyReferenceChannelDataProvider::SendBufferFilled() - return" ) ) );

    }