diff -r 000000000000 -r bde4ae8d615e os/mm/mmplugins/cameraplugins/source/mmcameraclientplugin/mmcameraclientsession/src/mmcameraclientinterface.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/os/mm/mmplugins/cameraplugins/source/mmcameraclientplugin/mmcameraclientsession/src/mmcameraclientinterface.cpp	Fri Jun 15 03:10:57 2012 +0200
@@ -0,0 +1,178 @@
+// 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 "mmcameraclientinterface.h"
+#include <e32uid.h>
+
+
+/**
+ * Starts the server process. 
+ * 
+ * Simultaneous launching of two such processes should be detected when the second
+ * one attempts to create the server object, failing with KErrAlreadyExists.
+ */
+static TInt StartServer()
+    {
+    const TUidType serverUid(KNullUid, KExecutableImageUid, KECamServerUid3);
+    RProcess server;
+    TInt err = server.Create(KMMCameraServerExe, KNullDesC, serverUid);
+    if (err != KErrNone)
+		{
+        return err;
+		}
+    TRequestStatus stat;
+    server.Rendezvous(stat);
+    if (stat != KRequestPending)
+		{
+        server.Kill(0);     // abort startup
+		}
+    else
+		{
+        server.Resume();    // logon OK - start the server
+		}
+
+    User::WaitForRequest(stat);     // wait for start or death
+    // we can't use the 'exit reason' if the server panicked as this
+    // is the panic 'reason' and may be '0' which cannot be distinguished
+    // from KErrNone
+    err = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();
+    server.Close();
+
+    return err;
+    }
+
+
+/**
+ * Connect to the server.
+ * 
+ * Will attempt to start the server if it has not yet been started or has been shut down.
+ */
+TInt RMMCameraSession::Connect()
+    {
+    TInt serverStartRetries = 2;
+    for (;;)
+        {
+        // Attempt to create a session to the server
+        TInt err = CreateSession(KMMCameraServerName, TVersion(0, 0, 0), KECamNumAsynchMsg);
+        if (err != KErrNotFound && err != KErrServerTerminated)
+			{
+            return err;
+			}
+
+		if (--serverStartRetries == 0)
+			{
+            return err;
+			}
+
+		// Server not found or shut down so (re)start the server
+        err = StartServer();
+        if (err != KErrNone && err != KErrAlreadyExists)
+            {
+			return err;
+			}
+        }
+    }
+
+
+//
+// Synchronous interface APIs
+//
+
+TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TDes8& aMessage)
+	{
+	if (aMessage.Length() > KECamMaxMessage)
+    	{
+    	return KErrArgument;
+    	}
+
+	return SendReceive(aMsgId, TIpcArgs(aParameterId, &aMessage));
+	}
+
+TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TInt aMessage)
+	{
+	return SendReceive(aMsgId, TIpcArgs(aParameterId, aMessage));
+	}
+
+TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TDes8& aMessage)
+    {
+    if (aMessage.Length() > KECamMaxMessage)
+    	{
+    	return KErrArgument;
+    	}
+
+    return SendReceive(aMsgId, TIpcArgs(&aMessage));
+    }
+
+TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TInt aMessage)
+	{
+	return SendReceive(aMsgId, TIpcArgs(aMessage));
+	}
+
+TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId)
+	{
+	return SendReceive(aMsgId);
+	}
+
+TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TDes8& aMessage) const
+	{
+	if (aMessage.Length() > KECamMaxMessage)
+    	{
+    	return KErrArgument;
+    	}
+
+	return SendReceive(aMsgId, TIpcArgs(aParameterId, &aMessage));
+	}
+
+TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TInt aMessage) const
+	{
+	return SendReceive(aMsgId, TIpcArgs(aParameterId, aMessage));
+	}
+
+TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TDes8& aMessage) const
+	{
+	if (aMessage.Length() > KECamMaxMessage)
+    	{
+    	return KErrArgument;
+    	}
+
+    return SendReceive(aMsgId, TIpcArgs(&aMessage));
+	}
+
+
+//
+// Asynchronous interface APIs
+//
+
+TInt RMMCameraSession::ReceiveMessage(TECamMsgId aMsgId, TDes8& aMessage, TRequestStatus& aStatus)
+    {
+    if (aMessage.Length() > KECamMaxMessage)
+    	{
+    	return KErrArgument;
+    	}
+
+    SendReceive(aMsgId, TIpcArgs(&aMessage), aStatus);
+
+	return KErrNone;
+    }
+
+void RMMCameraSession::ReceiveMessage(TECamMsgId aMsgId, TInt aMessage, TRequestStatus& aStatus)
+    {
+    SendReceive(aMsgId, TIpcArgs(aMessage), aStatus);
+    }