diff -r 000000000000 -r ed9695c8bcbe vtprotocolplugins/VideoSource/src/CVSDataProvider.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/vtprotocolplugins/VideoSource/src/CVSDataProvider.cpp	Mon Nov 23 14:47:47 2009 +0200
@@ -0,0 +1,543 @@
+/*
+* Copyright (c) 2006 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:  Video Source subsystem.
+*
+*/
+
+
+// INCLUDE FILES
+#include <badesca.h>
+#include <e32svr.h>
+#include <featmgr.h>
+#include "CApiVideoSource.h"
+#include "CVSCameraDataProvider.h"
+#include "CVSStillImageDataProvider.h"
+#include "CVSOnboardCameraDataProvider.h"
+
+// EXTERNAL FUNCTION PROTOTYPES
+
+// MACROS
+
+#ifdef _DEBUG
+#    define __IF_DEBUG(t) {RDebug::t;}
+#else
+#    define __IF_DEBUG(t)
+#endif
+
+// LOCAL CONSTANTS AND MACROS
+
+class TSizeCount
+    {
+    public:
+        TInt    iCount;
+        TSize   iSize;
+    };
+
+class TRateCount
+    {
+    public:
+        TInt    iCount;
+        TReal32 iRate;
+    };
+
+// LOCAL FUNCTION PROTOTYPES
+
+static TInt TSizeCountTLinearOrderFunc( 
+    const TSizeCount& aSizeCount1, const TSizeCount& aSizeCount2 );
+static TBool TSizeCountTIdentityRelationFunc( 
+    const TSizeCount& aSizeCount1, const TSizeCount& aSizeCount2 );
+static TInt TRateCountTLinearOrderFunc( 
+    const TRateCount& aRateCount1, const TRateCount& aRateCount2 );
+static TBool TRateCountTIdentityRelationFunc( 
+    const TRateCount& aRateCount1, const TRateCount& aRateCount2 );
+
+// FORWARD DECLARATIONS
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// TSizeCountTLinearOrderFunc: Used in RArray<TSizeCount)::InsertInOrder
+// -----------------------------------------------------------------------------
+//
+static TInt TSizeCountTLinearOrderFunc( 
+    const TSizeCount& aSizeCount1,
+    const TSizeCount& aSizeCount2 )
+    {
+    if ( aSizeCount1.iSize == aSizeCount2.iSize )
+        {
+        return 0;
+        }
+    else
+        {
+        // It is assumed that width and height fit in 16-bit, if they don't,
+        // use TInt64
+        TInt32 s1 = 
+            ( aSizeCount1.iSize.iWidth & 0xffff ) << 16 | 
+            ( aSizeCount1.iSize.iHeight & 0xffff );
+        TInt32 s2 = 
+            ( aSizeCount2.iSize.iWidth & 0xffff ) << 16 | 
+            ( aSizeCount2.iSize.iHeight & 0xffff );
+        return s1 - s2;
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// TSizeCountTIdentityRelationFunc: Used in RArray<TSizeCount)::Find
+// -----------------------------------------------------------------------------
+//
+static TBool TSizeCountTIdentityRelationFunc( 
+    const TSizeCount& aSizeCount1, 
+    const TSizeCount& aSizeCount2 )
+    {
+    if ( aSizeCount1.iSize == aSizeCount2.iSize )
+        {
+        return ETrue;
+        }
+    else
+        {
+        return EFalse;
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// TRateCountTLinearOrderFunc: Used in RArray<TRateCount)::InsertInOrder
+// -----------------------------------------------------------------------------
+//
+static TInt TRateCountTLinearOrderFunc( 
+    const TRateCount& aRateCount1, 
+    const TRateCount& aRateCount2 )
+    {
+    if ( aRateCount1.iRate > aRateCount2.iRate ) 
+        {
+        return 1;
+        }
+        
+    if ( aRateCount1.iRate < aRateCount2.iRate )
+        {
+        return -1;
+        }
+        
+    return 0;
+    }
+
+// -----------------------------------------------------------------------------
+// TRateCountTIdentityRelationFunc: Used in RArray<TRateCount)::Find
+// -----------------------------------------------------------------------------
+//
+static TBool TRateCountTIdentityRelationFunc( 
+    const TRateCount& aRateCount1, 
+    const TRateCount& aRateCount2 )
+    {
+    if ( aRateCount1.iRate == aRateCount2.iRate )
+        {
+        return ETrue;
+        }
+    else
+        {
+        return EFalse;
+        }
+    }
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::NewL
+// -----------------------------------------------------------------------------
+//
+CVSDataProvider* CVSDataProvider::NewL( 
+    TInt aProviderIndex, 
+    MVSDataProviderObserver* aObserver, 
+    MVSBufferPool* aPool )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::NewL() [aProviderIndex = %d] >>"), RThread().Id().operator TUint(), aProviderIndex));
+    
+    CVSDataProvider* self = NULL;
+    
+    // Is it ecam
+    TInt count = CamerasAvailable();
+    
+    // < 0 == error
+    if( count < 0 )
+        {
+        User::Leave( count );
+        }
+
+    if ( aProviderIndex < count )
+        {
+        self = CVSCameraDataProvider::NewL( aObserver, aProviderIndex, aPool );
+        }
+    else
+        {
+        // Is it still image
+        count += 1;
+
+        if ( aProviderIndex == ( count - 1) )
+            {
+            self = CVSStillImageDataProvider::NewL( aObserver, aPool );
+            }
+        else
+            {
+            User::Leave( KErrNotSupported );
+            }
+        }
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::NewL() <<"), RThread().Id().operator TUint()));
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::~CVSDataProvider
+// -----------------------------------------------------------------------------
+//
+CVSDataProvider::~CVSDataProvider()
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::~CVSDataProvider() >>"), RThread().Id().operator TUint()));
+    delete iErrorNotifier;
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::~CVSDataProvider() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::ProvidersAvailable
+// -----------------------------------------------------------------------------
+//
+TInt CVSDataProvider::ProvidersAvailable()
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ProvidersAvailable() >>"), RThread().Id().operator TUint()));
+    
+    // Count ecams
+    TInt numProviders = CamerasAvailable();
+
+    // < 0 == error
+    if ( numProviders < 0 )
+        {
+        numProviders = 1; // only still image provider
+        }
+    else
+        {
+        numProviders += 1; // add still
+        }
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ProvidersAvailable() [numProviders = %d] <<"), RThread().Id().operator TUint(), numProviders));
+
+    return numProviders;
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::ProviderInfoL
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::ProviderInfoL( 
+    TInt aProviderIndex, 
+    TVSDataProviderInfo& aInfo )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ProviderInfoL() >>"), RThread().Id().operator TUint()));
+    CVSDataProvider* provider = NewL( aProviderIndex, NULL, NULL);
+    provider->ProviderInfo( aInfo );
+    delete provider;
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ProviderInfoL() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::SetFillBufferParams
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::SetFillBufferParams( 
+    MVTVideoSink* aConsumer, 
+    TMediaId aMediaId )
+    {
+    iConsumer = aConsumer;
+    iMediaId = aMediaId;
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::NotifyError
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::NotifyError( TInt aError )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::NotifyError() >>"), RThread().Id().operator TUint()));
+    iErrorNotifier->NotifyError( &Observer(), aError );
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::NotifyError() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::CVSDataProvider
+// -----------------------------------------------------------------------------
+//
+CVSDataProvider::CVSDataProvider( 
+    MVSDataProviderObserver* aObserver, 
+    MVSBufferPool* aPool ) : 
+        iObserver( aObserver ), 
+        iPool ( aPool )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::CVSDataProvider() >>"), RThread().Id().operator TUint()));
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::CVSDataProvider() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::ConstructL()
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ConstructL() >>"), RThread().Id().operator TUint()));
+    iErrorNotifier = CProviderErrorNotifierAO::NewL();
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ConstructL() <<"), RThread().Id().operator TUint()));
+    }
+
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::TimeToPlay
+// -----------------------------------------------------------------------------
+//
+const TTimeIntervalMicroSeconds& CVSDataProvider::TimeToPlay()
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::TimeToPlay() >>"), RThread().Id().operator TUint()));
+
+    TTime now;
+    now.HomeTime();
+
+    TTimeIntervalMicroSeconds timeToPlay( now.MicroSecondsFrom( iStartTime ) );
+
+    if( timeToPlay <= iPreviousTimeToPlay )
+        {
+        __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::TimeToPlay(): *WARNING* Time warp backwards! Correcting.."), RThread().Id().operator TUint()));
+        iPreviousTimeToPlay = 
+            TTimeIntervalMicroSeconds( iPreviousTimeToPlay.Int64() + 1 );
+        }
+    else
+        {
+        iPreviousTimeToPlay = timeToPlay;
+        }
+
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::TimeToPlay() <<"), RThread().Id().operator TUint()));
+    return iPreviousTimeToPlay;
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::ResetStartTime
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::ResetStartTime()
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ResetStartTime() >>"), RThread().Id().operator TUint()));
+    iStartTime.HomeTime();
+    iPreviousTimeToPlay = iStartTime.MicroSecondsFrom( iStartTime );
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::ResetStartTime() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::CamerasAvailable()
+// -----------------------------------------------------------------------------
+//
+TInt CVSDataProvider::CamerasAvailable()
+    {
+    TRAPD( result, FeatureManager::InitializeLibL() );
+    
+    if( result != KErrNone )
+        {
+        return result;
+        }
+    
+    TInt count( 0 );
+
+    if( FeatureManager::FeatureSupported( KFeatureIdCamera ) )
+        {
+        count = CCamera::CamerasAvailable();
+        }
+
+    FeatureManager::UnInitializeLib();
+
+    return count;
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::SwitchFrom
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::SwitchFrom( const CVSDataProvider& anOldProvider )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::SwitchFrom() >>"), RThread().Id().operator TUint()));
+    iStartTime = anOldProvider.iStartTime;
+    iPreviousTimeToPlay = anOldProvider.iPreviousTimeToPlay;
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::SwitchFrom() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::EnumerateVideoFrameFormatsL
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::EnumerateVideoFrameFormatsL( 
+    CDesC8Array* aSupportedFormats )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameFormats() >>"), RThread().Id().operator TUint()));
+    TInt providerCount = ProvidersAvailable();    
+    TInt countOfProvidersThatSupportYUV420Planar = 0;
+    for ( TInt i = 0; i < providerCount; i++ )
+        {
+        TVSDataProviderInfo info;
+        ProviderInfoL( i, info );
+        if ( info.iVideoFrameFormatsSupported & CCamera::EFormatYUV420Planar )
+            {
+            countOfProvidersThatSupportYUV420Planar++;
+            }
+        }
+    if( providerCount > 0 && 
+        providerCount <= countOfProvidersThatSupportYUV420Planar )
+        {
+        aSupportedFormats->AppendL( KVtVideoMIMETypeYUV420 );
+        }
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameFormats() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::EnumerateVideoFrameSizesL
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::EnumerateVideoFrameSizesL( 
+    RArray<TSize>& aSupportedSizes, 
+    const TDesC8& aFormat )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameSizes() >>"), RThread().Id().operator TUint()));
+    RArray<TSizeCount> sizeCountArray;
+    CleanupClosePushL( sizeCountArray );
+    TInt providerCount = ProvidersAvailable();
+    for ( TInt i = 0; i < providerCount; i++ )
+        {
+        CVSDataProvider* p = CVSDataProvider::NewL( i, NULL, NULL );
+        CleanupStack::PushL( p );
+        TVSDataProviderInfo info;
+        ProviderInfoL( i, info );
+        for ( TInt j = 0; j < info.iNumVideoFrameSizesSupported; j++ )
+            {
+            TSize size;
+            p->GetVideoFrameSize( size, j, aFormat );
+            if ( size != TSize(0,0) )
+                {
+                TSizeCount sizeCount;
+                sizeCount.iCount = 1;
+                sizeCount.iSize = size;
+                TInt err = sizeCountArray.InsertInOrder( 
+                    sizeCount, 
+                    TLinearOrder<TSizeCount>( TSizeCountTLinearOrderFunc ) );
+                if ( err == KErrAlreadyExists )
+                    {
+                    TInt idx = sizeCountArray.Find( 
+                        sizeCount, 
+                        TIdentityRelation<TSizeCount>( 
+                            TSizeCountTIdentityRelationFunc ) );
+                    if ( idx == KErrNotFound )
+                        {
+                        User::Leave( KErrUnknown );
+                        }
+                    else
+                        {
+                        // Increment count of providers that supports the size
+                        sizeCountArray[idx].iCount++;
+                        }
+                    }
+                else
+                    {
+                    User::LeaveIfError( err );
+                    }
+                }
+            }
+        CleanupStack::PopAndDestroy(); // p
+        }
+    aSupportedSizes.Reset();
+    for ( TInt k = 0; k < sizeCountArray.Count(); k++ )
+        {
+        // Do all providers support the size
+        if ( providerCount > 0 && providerCount <= sizeCountArray[k].iCount ) 
+            {
+            User::LeaveIfError( 
+                aSupportedSizes.Append( sizeCountArray[k].iSize ) );
+            }
+        }
+    CleanupStack::PopAndDestroy( ); // sizeCountArray
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameSizes() <<"), RThread().Id().operator TUint()));
+    }
+
+// -----------------------------------------------------------------------------
+// CVSDataProvider::EnumerateVideoFrameRatesL
+// -----------------------------------------------------------------------------
+//
+void CVSDataProvider::EnumerateVideoFrameRatesL( 
+    RArray<TReal32>& aSupportedRates, 
+    const TDesC8& aFormat, 
+    const TSize& aSize )
+    {
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameRates() >>"), RThread().Id().operator TUint()));
+    RArray<TRateCount> rateCountArray;
+    CleanupClosePushL( rateCountArray );
+    TInt providerCount = ProvidersAvailable();
+    __IF_DEBUG(Print(_L("   LOOKING FOR COMMON SUPPORTED RATES, PROVIDER COUNT: %d"), providerCount));
+    for ( TInt i = 0; i < providerCount; i++ )
+        {
+        __IF_DEBUG(Print(_L("      PROVIDER %d"), i));
+        CVSDataProvider* p = CVSDataProvider::NewL( i, NULL, NULL );
+        CleanupStack::PushL( p );
+        TVSDataProviderInfo info;
+        ProviderInfoL( i, info );
+        __IF_DEBUG(Print(_L("         info.iNumVideoFrameRatesSupported: %d"), info.iNumVideoFrameRatesSupported));
+        for ( TInt j = 0; j < info.iNumVideoFrameRatesSupported; j++ )
+            {
+            TReal32 rate = 0.0;
+            p->GetVideoFrameRate( rate, j, aFormat, aSize );
+            __IF_DEBUG(Print(_L("         RATE FOR RATE INDEX %d IS %f"), j, rate));
+            if ( rate != 0.0 )
+                {
+                TRateCount rateCount;
+                rateCount.iCount = 1;
+                rateCount.iRate = rate;
+                TInt err = rateCountArray.InsertInOrder( 
+                    rateCount, 
+                    TLinearOrder<TRateCount>( TRateCountTLinearOrderFunc ) );
+                if ( err == KErrAlreadyExists )
+                    {
+                    TInt idx = rateCountArray.Find( 
+                        rateCount, 
+                        TIdentityRelation<TRateCount>( 
+                            TRateCountTIdentityRelationFunc ) );
+                    if ( idx == KErrNotFound )
+                        {
+                        User::Leave( KErrUnknown );
+                        }
+                    else
+                        {
+                        // Increment count of providers that supports the rate
+                        rateCountArray[idx].iCount++;
+                        }
+                    }
+                else
+                    {
+                    User::LeaveIfError( err );
+                    }
+                }
+            }
+        CleanupStack::PopAndDestroy(); // p
+        }
+    aSupportedRates.Reset();
+    for ( TInt k = 0; k < rateCountArray.Count(); k++ )
+        {
+        // Do all providers support the rate
+        if ( providerCount > 0 && providerCount <= rateCountArray[k].iCount )
+            {
+            User::LeaveIfError( 
+                aSupportedRates.Append( rateCountArray[k].iRate ) );
+            }
+        }
+    CleanupStack::PopAndDestroy( ); // rateCountArray
+    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSDataProvider::EnumerateVideoFrameRates() <<"), RThread().Id().operator TUint()));
+    }
+
+//  End of File