--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/devsound/devsoundrefplugin/src/platsec/client/MmfAudioServerProxy.cpp Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,119 @@
+// Copyright (c) 2004-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:
+//
+
+#include <f32file.h>
+#include <e32math.h>
+#include <s32mem.h>
+
+#include "MmfAudioServerProxy.h"
+#include "MmfAudioServerStart.h"
+#include "MmfBase.hrh"
+#include "MmfAudioClientServer.h"
+
+#define KMaxServerNameLength 256
+
+static const TUid KUidAudioServer = {KUidMmfAudioServerDllUnicodeDefine};
+const TInt KRetries = 5;
+const TInt KInitialTime = 100000; //100ms
+const TInt KTimeIncrement = 50000; // 50ms
+
+
+EXPORT_C TInt RMMFAudioServerProxy::Open()
+ {
+
+ const TUidType serverUid(KNullUid,KNullUid,KUidAudioServer);
+
+ // Assume the server is already running and attempt to create a session
+ // 4 message slots
+ TInt err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
+ KMMFAudioServerMinorVersionNumber,
+ KMMFAudioServerBuildVersionNumber));
+ if(err == KErrNotFound)
+ {
+ // Server not running
+ // Construct the server binary name
+ TBuf<KMaxServerNameLength> serverFile;
+ RProcess server;
+
+ _LIT(KEmpty,"");
+
+ err = server.Create(KAudioServerFileName, KEmpty, serverUid);
+ if(err != KErrNone)
+ return err;
+ // Synchronise with the server
+ TRequestStatus reqStatus;
+ server.Rendezvous(reqStatus);
+
+ if (reqStatus!=KRequestPending)
+ {
+ server.Kill(0);
+ }
+ else
+ {
+ // Start the test harness
+ server.Resume();
+ // Server will call the reciprocal static synchronise call
+ }
+ User::WaitForRequest(reqStatus); // wait for rendezvous or death
+ server.Close();
+ TInt reqStatusValue = reqStatus.Int();
+ if(reqStatusValue != KErrNone)
+ {
+ if(reqStatusValue == KErrNoMemory || reqStatusValue == KErrNotFound)
+ {
+ // All error codes except KErrNoMemory and KErrNotFound are assumed
+ // to be a duplicate server instance dying, then keep trying connection
+ // to the server. This can happen when two servers attempt to start
+ // at the same time.
+ return reqStatusValue;
+ }
+ //Wait for sometime, then retry and creation session
+ TInt waitTime = KInitialTime;
+ for(TInt retries=0;retries<KRetries;retries++)
+ {
+ User::After(waitTime);
+ waitTime+=KTimeIncrement;
+ err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
+ KMMFAudioServerMinorVersionNumber,
+ KMMFAudioServerBuildVersionNumber));
+ if(err==KErrNone)
+ {
+ //Session created successfully
+ break;
+ }
+ }
+ }
+ else
+ {
+ //Create the root server session
+ err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
+ KMMFAudioServerMinorVersionNumber,
+ KMMFAudioServerBuildVersionNumber));
+ }
+ }
+ return err;
+
+ }
+
+EXPORT_C TInt RMMFAudioServerProxy::SetDevSoundInfo()
+ {
+ return SendReceive(EMMFAudioLaunchRequests);
+ }
+
+EXPORT_C TInt RMMFAudioServerProxy::GetDevSoundSessionHandle()
+ {
+ return SendReceive(EMMFDevSoundSessionHandle);
+ }
+