--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/javauis/mmapi_qt/baseline/src/cmmavideourlplayer.cpp Fri May 14 15:47:24 2010 +0300
@@ -0,0 +1,317 @@
+/*
+* Copyright (c) 2002-2007 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: This class is used for playing video.
+*
+*/
+
+
+// INCLUDE FILES
+#include <mmf/server/mmfurl.h>
+#include <es_enum.h>
+#include <logger.h>
+
+#include "cmmavideourlplayer.h"
+#include "mmmadisplay.h"
+#include "cmmasourcestream.h"
+
+const TUid KUrlSourceUid = { KMmfUidUrlSource };
+_LIT(KMMALiveStreamMetaDataKeyword, "LiveStream");
+_LIT(KMMALiveStreamMetaDataValue, "1");
+
+CMMAVideoUrlPlayer* CMMAVideoUrlPlayer::NewLC(
+ CMMAMMFResolver* aResolver,
+ const TDesC& aUrl)
+{
+ CMMAVideoUrlPlayer* self = new(ELeave) CMMAVideoUrlPlayer(
+ aResolver);
+ CleanupStack::PushL(self);
+ self->ConstructL(aUrl);
+ return self;
+}
+
+EXPORT_C CMMAVideoUrlPlayer::~CMMAVideoUrlPlayer()
+{
+ iConnection.Close();
+ iSocketServ.Close();
+ delete iUrl;
+ delete iPlayerDelegate;
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::ConstructL(const TDesC& aUrl)
+{
+ CMMAVideoPlayer::ConstructL();
+ iUrl = aUrl.AllocL();
+
+ User::LeaveIfError(iSocketServ.Connect());
+ User::LeaveIfError(iConnection.Open(iSocketServ));
+}
+
+EXPORT_C CMMAVideoUrlPlayer::CMMAVideoUrlPlayer(
+ CMMAMMFResolver* aResolver):
+ CMMAVideoPlayer(aResolver)
+{
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::DeallocateL()
+{
+ __ASSERT_DEBUG(iPlayerDelegate != NULL, User::Invariant());
+ delete iPlayerDelegate;
+ iPlayerDelegate = NULL;
+ CMMAMMFPlayerBase::DeallocateL();
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::CloseL()
+{
+ // Do not call the CMMAVideoPlayer CloseL because it deletes
+ // file source stream.
+ CMMAAudioPlayer::CloseL();
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::StartL()
+{
+ __ASSERT_DEBUG(iPlayerDelegate != NULL, User::Invariant());
+ LOG( EJavaMMAPI, EInfo, "CMMAVideoUrlPlayer::StartL() +");
+ iPlayerDelegate->StartL();
+ LOG( EJavaMMAPI, EInfo, "CMMAVideoUrlPlayer::StartL() -");
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::StopL(TBool aPostEvent)
+{
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::StopL ");
+ __ASSERT_DEBUG(iPlayerDelegate != NULL, User::Invariant());
+ iPlayerDelegate->StopL(aPostEvent);
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::GetMediaTime(TInt64* aMediaTime)
+{
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::GetMediaTime +");
+ if (iPlayerDelegate)
+ {
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::GetMediaTime .iPlayerDelegate->GetMediaTime ");
+ iPlayerDelegate->GetMediaTime(aMediaTime);
+ }
+ else
+ {
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::GetMediaTime Not found ");
+ *aMediaTime = KErrNotFound;
+ }
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::GetMediaTime -");
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::RealizeL()
+{
+ CMMAPlayer::RealizeL(); // Changes state to ERealized
+}
+
+
+EXPORT_C void CMMAVideoUrlPlayer::PrefetchL()
+{
+ const TUint KConnectionTreshold(1);
+ TUint connectIap((TUint)KUseDefaultIap);
+ TUint connectionCount(0);
+ User::LeaveIfError(iConnection.EnumerateConnections(connectionCount));
+ LOG1( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::PrefetchL: connectionCount = %d", connectionCount);
+ if (connectionCount == KConnectionTreshold)
+ {
+ // One active connection - find it and try using it
+ FindActiveIap(connectionCount, connectIap);
+ }
+ // else No active connections try using the default one
+ LOG1( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::PrefetchL: connectIap = %d", connectIap);
+
+ CMMFUrlParams* urlCfg = CMMFUrlParams::NewLC(*iUrl, (TInt)connectIap);
+ CBufFlat* urlCfgBuffer = urlCfg->ExternalizeToCBufFlatLC();
+
+ // Store current thread priority to give
+ // more CPU time to Java threads i.e. this
+ // is work around for not locking the Java
+ // thread while RTSP connection is being
+ // opened
+ iOrigPriority = RThread().Priority();
+
+ // player priority settings
+ TMMFPrioritySettings prioritySettings;
+ prioritySettings.iPriority = EMdaPriorityMax;
+ prioritySettings.iPref = EMdaPriorityPreferenceTimeAndQuality;
+ prioritySettings.iState = EMMFStatePlaying;
+
+ User::LeaveIfError(DoOpen(KUrlSourceUid,
+ urlCfgBuffer->Ptr(0),
+ KUidMmfAudioOutput,
+ KNullDesC8,
+ prioritySettings));
+
+ User::LeaveIfError(iController.Prime());
+
+ CleanupStack::PopAndDestroy(urlCfgBuffer);
+ CleanupStack::PopAndDestroy(urlCfg);
+
+ // Prefetch will be completed in HandleEvent method.
+ // Next event KMMFEventCategoryVideoOpenComplete will be handled in
+ // CMMAVideoPlayer.
+}
+
+void CMMAVideoUrlPlayer::FindActiveIap(const TUint aConnectionCount, TUint& aActiveIap)
+{
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::FindActiveIap: aConnectionCount = %d +", aConnectionCount);
+
+ TPckgBuf<TConnectionInfo> connectionInfo;
+ for (TUint i = 1; i <= aConnectionCount; ++i)
+ {
+ if (iConnection.GetConnectionInfo(i, connectionInfo) == KErrNone)
+ {
+ aActiveIap = connectionInfo().iIapId;
+ break;
+ }
+ }
+
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::FindActiveIap: aActiveIap = %d -", aActiveIap);
+}
+
+TBool CMMAVideoUrlPlayer::IsLiveStreamL()
+{
+ LOG( EJavaMMAPI, EInfo, "CMMAVideoUrlPlayer::IsLiveStream: Checking if this is a live stream..");
+
+ CMMFMetaDataEntry* currEntry = NULL;
+
+ TInt nEntries = 0;
+ User::LeaveIfError(iController.GetNumberOfMetaDataEntries(nEntries));
+
+ for (TInt i = 0; i < nEntries; ++i)
+ {
+ currEntry = iController.GetMetaDataEntryL(i);
+
+ if ((0 == currEntry->Name().Compare(KMMALiveStreamMetaDataKeyword)) &&
+ (0 == currEntry->Value().Compare(KMMALiveStreamMetaDataValue)))
+ {
+ LOG( EJavaMMAPI, EInfo, "CMMAVideoUrlPlayer::IsLiveStream: Stream is a live stream");
+ delete currEntry;
+ return ETrue;
+ }
+
+ delete currEntry;
+ }
+
+ LOG( EJavaMMAPI, EInfo, "CMMAVideoUrlPlayer::IsLiveStream: Not a live stream");
+ return EFalse;
+}
+
+EXPORT_C void CMMAVideoUrlPlayer::HandleEvent(const TMMFEvent& aEvent)
+{
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::HandleEvent 0x%X", aEvent.iEventType.iUid);
+ ELOG1( EJavaMMAPI, "MMA:CMMAVideoUrlPlayer::HandleEvent error code: %d", aEvent.iErrorCode);
+ RThread currentThread;
+
+ if (iPlayerDelegate != NULL)
+ {
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::HandleEvent: iPlayerDelegate != NULL");
+ iPlayerDelegate->HandleEvent(aEvent);
+ }
+ else
+ {
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::HandleEvent: else");
+
+ __ASSERT_DEBUG(iPlayerDelegate == NULL, User::Invariant());
+ TInt err = aEvent.iErrorCode;
+
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::HandleEvent: currentThread.Priority() I = %d", currentThread.Priority());
+
+ // Lower thread priority to give more CPU time to Java-threads
+ // i.e. current thread has one increment higher priority than
+ // EPriorityNormal
+ if (aEvent.iEventType == KMMFEventCategoryVideoOpenComplete &&
+ err == KErrNone)
+ {
+ currentThread.SetPriority(EPriorityNormal);
+ }
+
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::HandleEvent: currentThread.Priority() II = %d", currentThread.Priority());
+
+ if (aEvent.iEventType == KMMFEventCategoryVideoPrepareComplete)
+ {
+ // Restore original thread priority
+ currentThread.SetPriority(iOrigPriority);
+ LOG1( EJavaMMAPI, EInfo, "MMA:CMMAVideoUrlPlayer::HandleEvent: currentThread.Priority() III = %d", currentThread.Priority());
+
+ // NotCompleteVideoError is not considered as an error condition, instead it indicates
+ // that some elements of the media cannot be played (e.g. video OR audio)
+ if (err != KErrNone && err != KNotCompleteVideoError)
+ {
+ CompletePrefetch(err);
+ return;
+ }
+
+ // Find out of this is a live stream
+ TBool liveStream = EFalse;
+ TRAP(err, liveStream = IsLiveStreamL());
+
+ if (err != KErrNone)
+ {
+ CompletePrefetch(err);
+ return;
+ }
+
+ if (liveStream)
+ {
+ TRAP(err, iPlayerDelegate =
+ CMMAVideoUrlPlayerLiveStreamDelegate::NewL(*this));
+ }
+ else
+ {
+ iPlayerDelegate = new CMMAVideoUrlPlayerClipStreamDelegate(*this);
+ err = iPlayerDelegate ? KErrNone : KErrNoMemory;
+ }
+
+ if (err != KErrNone)
+ {
+ // could not create delegate
+ CompletePrefetch(err);
+ return;
+ }
+
+ iPlayerDelegate->HandleEvent(aEvent);
+ }
+ else
+ {
+ // All other events.
+ LOG( EJavaMMAPI, EInfo, "MMA::CMMAVideoUrlPlayer::HandleEvent: Calling CMMAVideoPlayer::HandleEvent()");
+ CMMAVideoPlayer::HandleEvent(aEvent);
+ }
+ }
+}
+
+void CMMAVideoUrlPlayer::HandleEventToParent(const TMMFEvent& aEvent)
+{
+ CMMAVideoPlayer::HandleEvent(aEvent);
+}
+
+// ----------------------------------------------------------------------------
+//
+// CMMAVideoUrlPlayerClipStreamDelegate
+//
+// ----------------------------------------------------------------------------
+
+CMMAVideoUrlPlayer::CMMAVideoUrlPlayerDelegate::
+CMMAVideoUrlPlayerDelegate(CMMAVideoUrlPlayer& aPlayer) :
+ iPlayer(aPlayer)
+{
+ // Nothing to be done.
+}
+
+CMMAVideoUrlPlayer::CMMAVideoUrlPlayerDelegate::~CMMAVideoUrlPlayerDelegate()
+{
+ // Nothing to be done.
+}
+
+// END OF FILE