diff -r 000000000000 -r 5d29cba61097 omxilvideocomps/omxilvideoscheduler/src/comxilvideoscheduler.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/omxilvideocomps/omxilvideoscheduler/src/comxilvideoscheduler.cpp	Fri Oct 08 22:09:17 2010 +0100
@@ -0,0 +1,237 @@
+/*
+* Copyright (c) 2008-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:
+*
+*/
+
+
+/**
+@file
+@internalComponent
+*/
+
+#include <openmax/il/common/omxilspecversion.h>
+#include <openmax/il/common/omxilconfigmanager.h>
+#include <openmax/il/loader/omxilcomponentif.h>
+#include <openmax/il/loader/omxilsymbiancomponentif.h>
+#include <openmax/il/common/omxilclientclockport.h>
+
+#include "comxilvideoscheduler.h"
+#include "comxilvideoschedulerinputport.h"
+#include "comxilvideoscheduleroutputport.h"
+#include "comxilvideoschedulerpf.h"
+#include "omxilvideoscheduler.hrh"
+
+const OMX_U32 KInputPortIndex = 0;
+const OMX_U32 KOutputPortIndex = 1;
+const OMX_U32 KClockPortIndex = 2;
+
+_LIT8(KSymbianOmxILVideoSchedulerName, "OMX.SYMBIAN.VIDEO.VIDEOSCHEDULER");
+_LIT8(KSymbianOmxILVideoSchedulerRole, "video_scheduler.binary");	
+
+OMXIL_COMPONENT_ECOM_ENTRYPOINT(KUidSymbianOmxILVideoScheduler);
+
+OMX_ERRORTYPE SymbianErrorToOmx(TInt aError);
+
+// Component Entry Point
+OMX_ERRORTYPE OMX_ComponentInit(OMX_HANDLETYPE aComponent)
+	{
+	TInt err = COmxILVideoScheduler::CreateComponent(aComponent);
+	return SymbianErrorToOmx(err);
+	}
+
+TInt COmxILVideoScheduler::CreateComponent(OMX_HANDLETYPE aComponent)
+	{
+	COmxILVideoScheduler* self = new COmxILVideoScheduler();
+
+	if (!self)
+		{
+		return KErrNoMemory;
+		}
+
+	TRAPD(err, self->ConstructL(aComponent));
+	if(err)
+		{
+		delete self;
+		}
+	return err;
+	}
+
+COmxILVideoScheduler::COmxILVideoScheduler()
+	{
+	// nothing to do
+	}
+
+void COmxILVideoScheduler::ConstructL(OMX_HANDLETYPE hComponent)
+	{
+	// STEP 1: Initialize the data received from the IL Core
+    COmxILComponent::ConstructL(hComponent);
+    
+	// STEP 2: Create the callback manager
+	// In context callback manager is used since we need output buffers to be received at the sink
+	// component immediately after we decide to send them.
+	// Also, returning clock buffers imediately avoids clock buffer starvation 
+    MOmxILCallbackNotificationIf* callbackNotificationIf = CreateCallbackManagerL(COmxILComponent::EOutofContext);
+ 
+    
+	// STEP 3: Create the Processing Function...
+    COmxILVideoSchedulerPF* pProcessingFunction = COmxILVideoSchedulerPF::NewL(*callbackNotificationIf, *this, GetHandle());
+	RegisterProcessingFunction(pProcessingFunction);
+	
+	// STEP 4: Create Port manager...
+	CreatePortManagerL(COmxILComponent::ENonBufferSharingPortManager,
+		TOmxILSpecVersion(),	        // OMX Version
+		0,						// The number of audio ports in this component
+		0,						// The starting audio port index
+		0,						// The number of image ports in this component
+		0,						// The starting image port index
+		2,						// The number of video ports in this component
+		0,						// The starting video port index
+		1,						// The number of other ports in this component
+		2						// The starting other port index
+		);
+
+	// create the input port
+	AddInputVideoPortL();
+	AddOutputVideoPortL();
+	AddClockPortL();
+	
+	// STEP 5: Create the non-port related configuration manager...
+	RPointerArray<TDesC8> roleList;
+	CleanupClosePushL(roleList);
+	roleList.AppendL(&KSymbianOmxILVideoSchedulerRole);
+	COmxILConfigManager* pConfigManager = COmxILConfigManager::NewL(
+			KSymbianOmxILVideoSchedulerName,
+			TOmxILSpecVersion(),
+			roleList);
+	CleanupStack::PopAndDestroy();
+	RegisterConfigurationManager(pConfigManager);
+	
+	// And finally, let's get everything started
+	InitComponentL();
+	}
+
+COmxILVideoScheduler::~COmxILVideoScheduler()
+	{
+	}
+
+void COmxILVideoScheduler::AddInputVideoPortL()
+	{
+	TOmxILSpecVersion specVersion;
+
+	TOmxILCommonPortData portData(
+			specVersion,
+			KInputPortIndex, 
+			OMX_DirInput, 
+			1,											// minimum number of buffers
+			1,											// minimum buffer size, in bytes
+			OMX_PortDomainVideo,
+			OMX_FALSE,					// do not need contigious buffers
+			1,							// 1-byte alignment
+			OMX_BufferSupplyInput,
+			KOutputPortIndex);
+
+	iVideoInputPort = COmxILVideoSchedulerInputPort::NewL(portData);
+	CleanupStack::PushL(iVideoInputPort);
+	User::LeaveIfError(AddPort(iVideoInputPort, OMX_DirInput));
+	CleanupStack::Pop();
+	}
+	
+void COmxILVideoScheduler::AddOutputVideoPortL()
+	{
+	TOmxILSpecVersion specVersion;
+
+	TOmxILCommonPortData portData(
+			specVersion,
+			KOutputPortIndex, 
+			OMX_DirOutput, 
+			1,											// minimum number of buffers
+			1,											// minimum buffer size, in bytes
+			OMX_PortDomainVideo,
+			OMX_FALSE,					// do not need contigious buffers
+			1,							// 1-byte alignment
+			OMX_BufferSupplyInput,
+			COmxILPort::KBufferMarkPropagationPortNotNeeded);
+			
+	iVideoOutputPort = COmxILVideoSchedulerOutputPort::NewL(portData);
+	CleanupStack::PushL(iVideoOutputPort);
+	User::LeaveIfError(AddPort(iVideoOutputPort, OMX_DirOutput));
+	CleanupStack::Pop();
+	}	
+	
+void COmxILVideoScheduler::AddClockPortL()
+	{
+	TOmxILSpecVersion specVersion;
+
+	TOmxILCommonPortData portData(
+			specVersion,
+			KClockPortIndex, 
+			OMX_DirInput, 
+			4,											// minimum number of buffers
+			sizeof(OMX_TIME_MEDIATIMETYPE),				// minimum buffer size, in bytes
+			OMX_PortDomainOther,
+			OMX_TRUE,									// contigious buffers
+			4,											// 4-byte alignment
+			OMX_BufferSupplyOutput,
+			COmxILPort::KBufferMarkPropagationPortNotNeeded);
+
+	RArray<OMX_OTHER_FORMATTYPE> array;
+	CleanupClosePushL(array);
+	array.AppendL(OMX_OTHER_FormatTime);
+	iClockPort = COmxILClientClockPort::NewL(portData, array);
+	CleanupStack::PopAndDestroy(&array);
+	CleanupStack::PushL(iClockPort);
+	User::LeaveIfError(AddPort(iClockPort, OMX_DirInput));
+	CleanupStack::Pop();
+	}
+
+/** Returns the maximum number of buffers configured on a port. */
+TUint32 COmxILVideoScheduler::BufferCount() const
+	{
+	// due to buffer copying we do not need the same number of buffers on each port,
+	// so to be safe the maximum count is used when allocating queues.
+	// when buffer sharing is added, the buffer counts must be checked to be the same on
+	// the Loaded->Idle phase.
+	TUint32 in = iVideoInputPort->BufferCount();
+	TUint32 out = iVideoOutputPort->BufferCount();
+	return in > out ? in : out;
+	}
+
+OMX_ERRORTYPE COmxILVideoScheduler::MediaTimeRequest(TAny* apPrivate, OMX_TICKS aMediaTime, OMX_TICKS aOffset)
+	{
+	return iClockPort->MediaTimeRequest(apPrivate, aMediaTime, aOffset);
+	}		
+
+OMX_ERRORTYPE COmxILVideoScheduler::GetWallTime(OMX_TICKS& aWallTime)
+	{
+	return iClockPort->GetWallTime(aWallTime);
+	}			
+
+OMX_ERRORTYPE COmxILVideoScheduler::SetVideoStartTime(OMX_TICKS aStartTime)
+	{
+	return iClockPort->SetStartTime(aStartTime);
+	}
+
+OMX_ERRORTYPE SymbianErrorToOmx(TInt aError)
+	{
+	switch(aError)
+		{
+	case KErrNone:
+		return OMX_ErrorNone;
+	case KErrNoMemory:
+		return OMX_ErrorInsufficientResources;
+	default:
+		return OMX_ErrorUndefined;
+		}
+	}