--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javauis/lcdui_akn/javalcdui/src/CMIDToLcduiObserver.cpp	Tue Apr 27 16:30:29 2010 +0300
@@ -0,0 +1,316 @@
+/*
+* Copyright (c) 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:  Provides a way of sending asynchronous
+*                requests from mmapi (JSR-135) to lcdui
+*
+*/
+
+
+// Using CCoeControl
+#include <coecntrl.h>
+// Using MUiEventConsumer
+#include <reflcdui.h>
+// Using debug macros.
+#include <j2me/jdebug.h>
+
+#include "CMIDToLcduiObserver.h"
+
+
+// Event queue size
+const TInt KMaxQueueSlots = 30;
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::CMIDToLcduiObserver
+// Constructor.
+// ---------------------------------------------------------------------------
+//
+CMIDToLcduiObserver::CMIDToLcduiObserver():
+        CActive(EPriorityStandard)
+{
+    // Create mutex
+    iEventQueue.CreateLocal(KMaxQueueSlots);
+
+    // Install self to Active scheduler
+    CActiveScheduler::Add(this);
+
+    iEventQueue.NotifyDataAvailable(iStatus);
+    SetActive();
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::~CMIDToLcduiObserver
+// Destructor.
+// ---------------------------------------------------------------------------
+//
+CMIDToLcduiObserver::~CMIDToLcduiObserver()
+{
+    // Unregister all controls
+    iRegisteredControls.Reset();
+
+    // Cancel the active object
+    Cancel();
+
+    // Close the mutex
+    iEventQueue.Close();
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::RegisterControl
+// Allows a control to be used during event processing.
+// ---------------------------------------------------------------------------
+//
+#ifdef RD_JAVA_NGA_ENABLED
+void CMIDToLcduiObserver::RegisterControl(
+    CCoeControl& aControl, MDirectContainer* aCallbackContainer /*= NULL*/)
+#else
+void CMIDToLcduiObserver::RegisterControl(CCoeControl& aControl)
+#endif
+{
+    TInt index = iRegisteredControls.Find(&aControl);
+
+    // Append the control only if it have not been added yet
+    if (index == KErrNotFound)
+    {
+        if (iRegisteredControls.Append(&aControl) != KErrNone)
+        {
+            // Appending of control failed
+            DEBUG("CMIDToLcduiObserver::RegisterControl - Append failed");
+        }
+
+#ifdef RD_JAVA_NGA_ENABLED
+        if (aCallbackContainer)
+        {
+            TToLcduiEventData data;
+            data.iType = ENotifyContentAdded;
+            data.iContainer = aCallbackContainer;
+            data.iControl = &aControl;
+            data.iConsumer = NULL;
+            iEventQueue.Send(data);
+        }
+#endif
+    }
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::UnregisterControl
+// Removes a control from the list of controls allowed
+// to be used in event processing.
+// Events which works with this control will be ignored.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::UnregisterControl(CCoeControl& aControl)
+{
+    TInt index = iRegisteredControls.Find(&aControl);
+
+    if (index != KErrNotFound)
+    {
+        iRegisteredControls.Remove(index);
+    }
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::FlushControl
+// Asynchronously flushes the control's graphics content on screen.
+// The call may origin in other than lcdui thread.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::FlushControl(
+    CCoeControl& aControl,
+    const TRect& aRect)
+{
+    // Can run in non lcdui thread
+
+    // Prepare event data
+    TToLcduiEventData data;
+    data.iType = EFlushEvent;
+    data.iRect = aRect;
+    data.iControl = &aControl;
+
+    // Add event to the queue
+    iEventQueue.Send(data);
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::InvokeDSAResourcesCallback
+// Asynchronously invokes aConsumer->MdcDSAResourcesCallback
+// from lcdui thread.
+// The call may origin in other than lcdui thread.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::InvokeDSAResourcesCallback(
+    CCoeControl& aControl,
+    MUiEventConsumer& aConsumer)
+{
+    // Can run in non lcdui thread
+
+    // Prepare event data
+    TToLcduiEventData data;
+    data.iType = EDSAResourcesCallbackEvent;
+    data.iControl = &aControl;
+    data.iConsumer = &aConsumer;
+
+    // Add event to the queue
+    iEventQueue.Send(data);
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::InvokeUICallback
+// Asynchronously invokes aConsumer->MdcUICallback
+// from lcdui thread.
+// The call may origin in other than lcdui thread.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::InvokeUICallback(
+    MUiEventConsumer& aConsumer,
+    TInt aCallbackId)
+{
+    // Can run in non lcdui thread
+
+    // Prepare event data
+    TToLcduiEventData data;
+    data.iType = EUICallbackEvent;
+    data.iConsumer = &aConsumer;
+    data.iId = aCallbackId;
+
+    // Add event to the queue
+    iEventQueue.Send(data);
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::RunL
+// Handles an active object’s request completion event.
+// Processes the first available event in queue.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::RunL()
+{
+    TToLcduiEventData data;
+
+    // Get the event
+    iEventQueue.Receive(data);
+
+    // Process the event
+    switch (data.iType)
+    {
+    case EFlushEvent:
+        DoFlushControl(data.iControl, data.iRect);
+        break;
+    case EDSAResourcesCallbackEvent:
+        DoInvokeDSAResourcesCallback(data.iControl, data.iConsumer);
+        break;
+    case EUICallbackEvent:
+        DoInvokeUICallback(data.iConsumer, data.iId);
+        break;
+#ifdef RD_JAVA_NGA_ENABLED
+    case ENotifyContentAdded:
+        DoInvokeNotifyContentAdded(data.iControl, data.iContainer);
+        break;
+#endif
+    }
+
+    iEventQueue.NotifyDataAvailable(iStatus);
+    SetActive();
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::DoCancel
+// Implements cancellation of an outstanding request.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::DoCancel()
+{
+    iEventQueue.CancelDataAvailable();
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::DoFlushControl
+// Processes the event invoked by FlushControl.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::DoFlushControl(
+    CCoeControl* aControl,
+    const TRect& aRect)
+{
+    TInt index = iRegisteredControls.Find(aControl);
+
+    if (index != KErrNotFound)
+    {
+        TPoint relativePos =
+            aControl->Position() - aControl->PositionRelativeToScreen();
+        TRect rectToDraw = aRect;
+        rectToDraw.Move(relativePos);
+        aControl->DrawNow(rectToDraw);
+    }
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::DoInvokeDSAResourcesCallback
+// Processes the event invoked by InvokeDSAResourcesCallback.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::DoInvokeDSAResourcesCallback(
+    CCoeControl* aControl,
+    MUiEventConsumer *aConsumer)
+{
+    TInt index = iRegisteredControls.Find(aControl);
+
+    if (index != KErrNotFound)
+    {
+        RWsSession&      session = aControl->ControlEnv()->WsSession();
+        CWsScreenDevice* device  = aControl->ControlEnv()->ScreenDevice();
+        RDrawableWindow* window  = aControl->DrawableWindow();
+
+        aConsumer->MdcDSAResourcesCallback(session, *device, *window);
+    }
+}
+
+
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::DoInvokeUICallback
+// Processes the event invoked by InvokeUICallback.
+// ---------------------------------------------------------------------------
+//
+void CMIDToLcduiObserver::DoInvokeUICallback(
+    MUiEventConsumer *aConsumer,
+    TInt aCallbackId)
+{
+    aConsumer->MdcUICallback(aCallbackId);
+}
+
+#ifdef RD_JAVA_NGA_ENABLED
+// ---------------------------------------------------------------------------
+// CMIDToLcduiObserver::DoInvokeNotifyContentAdded
+// ---------------------------------------------------------------------------
+void CMIDToLcduiObserver::DoInvokeNotifyContentAdded(
+    CCoeControl* aControl,
+    MDirectContainer *aContainer)
+{
+    TInt index = iRegisteredControls.Find(aControl);
+    if (index != KErrNotFound)
+    {
+        aContainer->MdcNotifyContentAdded();
+    }
+}
+#endif