os/mm/devsound/devsoundrefplugin/src/platsec/client/MmfAudioServerProxy.cpp
author sl@SLION-WIN7.fritz.box
Fri, 15 Jun 2012 03:10:57 +0200
changeset 0 bde4ae8d615e
permissions -rw-r--r--
First public contribution.
sl@0
     1
// Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0
     2
// All rights reserved.
sl@0
     3
// This component and the accompanying materials are made available
sl@0
     4
// under the terms of "Eclipse Public License v1.0"
sl@0
     5
// which accompanies this distribution, and is available
sl@0
     6
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0
     7
//
sl@0
     8
// Initial Contributors:
sl@0
     9
// Nokia Corporation - initial contribution.
sl@0
    10
//
sl@0
    11
// Contributors:
sl@0
    12
//
sl@0
    13
// Description:
sl@0
    14
//
sl@0
    15
sl@0
    16
#include <f32file.h>
sl@0
    17
#include <e32math.h>
sl@0
    18
#include <s32mem.h>
sl@0
    19
sl@0
    20
#include "MmfAudioServerProxy.h"
sl@0
    21
#include "MmfAudioServerStart.h"
sl@0
    22
#include "MmfBase.hrh"
sl@0
    23
#include "MmfAudioClientServer.h"
sl@0
    24
sl@0
    25
#define KMaxServerNameLength 256
sl@0
    26
sl@0
    27
static const TUid KUidAudioServer = {KUidMmfAudioServerDllUnicodeDefine};
sl@0
    28
const TInt KRetries = 5; 
sl@0
    29
const TInt KInitialTime = 100000;  //100ms
sl@0
    30
const TInt KTimeIncrement = 50000; // 50ms 
sl@0
    31
sl@0
    32
sl@0
    33
EXPORT_C TInt RMMFAudioServerProxy::Open()
sl@0
    34
	{
sl@0
    35
sl@0
    36
	const TUidType serverUid(KNullUid,KNullUid,KUidAudioServer);
sl@0
    37
		
sl@0
    38
	// Assume the server is already running and attempt to create a session
sl@0
    39
	// 4 message slots
sl@0
    40
	TInt err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
sl@0
    41
														KMMFAudioServerMinorVersionNumber,
sl@0
    42
														KMMFAudioServerBuildVersionNumber));
sl@0
    43
	if(err == KErrNotFound)
sl@0
    44
		{
sl@0
    45
		// Server not running
sl@0
    46
		// Construct the server binary name
sl@0
    47
		TBuf<KMaxServerNameLength> serverFile;
sl@0
    48
		RProcess server;
sl@0
    49
sl@0
    50
		_LIT(KEmpty,"");
sl@0
    51
sl@0
    52
		err = server.Create(KAudioServerFileName, KEmpty, serverUid);
sl@0
    53
		if(err != KErrNone)
sl@0
    54
			return err;
sl@0
    55
		// Synchronise with the server
sl@0
    56
		TRequestStatus reqStatus;
sl@0
    57
		server.Rendezvous(reqStatus);
sl@0
    58
		
sl@0
    59
		if (reqStatus!=KRequestPending)
sl@0
    60
			{
sl@0
    61
			server.Kill(0);
sl@0
    62
			}
sl@0
    63
		else
sl@0
    64
			{
sl@0
    65
			// Start the test harness
sl@0
    66
			server.Resume();
sl@0
    67
			// Server will call the reciprocal static synchronise call
sl@0
    68
			}
sl@0
    69
		User::WaitForRequest(reqStatus); // wait for rendezvous or death
sl@0
    70
		server.Close();
sl@0
    71
		TInt reqStatusValue = reqStatus.Int();
sl@0
    72
		if(reqStatusValue != KErrNone)
sl@0
    73
			{
sl@0
    74
			if(reqStatusValue == KErrNoMemory || reqStatusValue == KErrNotFound)
sl@0
    75
				{
sl@0
    76
				// All error codes except KErrNoMemory and KErrNotFound are assumed
sl@0
    77
				// to be a duplicate server instance dying, then keep trying connection
sl@0
    78
				// to the server. This can happen when two servers attempt to start
sl@0
    79
				// at the same time.
sl@0
    80
				return reqStatusValue;
sl@0
    81
				}
sl@0
    82
			//Wait for sometime, then retry and creation session
sl@0
    83
			TInt waitTime = KInitialTime;
sl@0
    84
			for(TInt retries=0;retries<KRetries;retries++)
sl@0
    85
				{
sl@0
    86
				User::After(waitTime);
sl@0
    87
				waitTime+=KTimeIncrement;
sl@0
    88
				err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
sl@0
    89
														KMMFAudioServerMinorVersionNumber,
sl@0
    90
														KMMFAudioServerBuildVersionNumber));
sl@0
    91
				if(err==KErrNone)
sl@0
    92
					{
sl@0
    93
					//Session created successfully
sl@0
    94
					break;
sl@0
    95
					}	
sl@0
    96
				}			
sl@0
    97
			}
sl@0
    98
		else
sl@0
    99
			{
sl@0
   100
			//Create the root server session
sl@0
   101
			err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
sl@0
   102
														KMMFAudioServerMinorVersionNumber,
sl@0
   103
														KMMFAudioServerBuildVersionNumber));	
sl@0
   104
			}
sl@0
   105
		}
sl@0
   106
	return err;		
sl@0
   107
		
sl@0
   108
	}
sl@0
   109
sl@0
   110
EXPORT_C TInt RMMFAudioServerProxy::SetDevSoundInfo()
sl@0
   111
	{
sl@0
   112
	return SendReceive(EMMFAudioLaunchRequests);
sl@0
   113
	}
sl@0
   114
sl@0
   115
EXPORT_C TInt RMMFAudioServerProxy::GetDevSoundSessionHandle()
sl@0
   116
	{
sl@0
   117
	return SendReceive(EMMFDevSoundSessionHandle);
sl@0
   118
	}
sl@0
   119