os/mm/mmlibs/mmfw/SecureDRM/src/Server/MmfDrmPluginServerSession.cpp
author sl
Tue, 10 Jun 2014 14:32:02 +0200
changeset 1 260cb5ec6c19
permissions -rw-r--r--
Update contrib.
sl@0
     1
// Copyright (c) 2007-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 <mmf/common/mmfcontrollerframework.h>
sl@0
    17
#include "MmfDrmPluginServerSession.h"
sl@0
    18
#include "MmfDrmPluginClientServer.h"
sl@0
    19
#include "MmfDrmPluginServer.h"
sl@0
    20
sl@0
    21
/*
sl@0
    22
 Create a DRM Plugin Server Session
sl@0
    23
 */
sl@0
    24
CMMFDRMPluginServerSession* CMMFDRMPluginServerSession::NewL()
sl@0
    25
	{
sl@0
    26
	CMMFDRMPluginServerSession* self = new(ELeave) CMMFDRMPluginServerSession();
sl@0
    27
	return self;
sl@0
    28
	}
sl@0
    29
sl@0
    30
CMMFDRMPluginServerSession::~CMMFDRMPluginServerSession()
sl@0
    31
	{
sl@0
    32
	CMMFDRMPluginServer* server = 
sl@0
    33
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
    34
	if (server)
sl@0
    35
		{
sl@0
    36
		server->DecrementSessionId();		
sl@0
    37
		}
sl@0
    38
	if (iData)
sl@0
    39
		{
sl@0
    40
		delete iData;
sl@0
    41
		}
sl@0
    42
	iControllerSessionHandle.Close();
sl@0
    43
	}
sl@0
    44
sl@0
    45
void CMMFDRMPluginServerSession::CreateL(const CMmfIpcServer& aServer)
sl@0
    46
	{
sl@0
    47
	CMmfIpcSession::CreateL(aServer);
sl@0
    48
	CMMFDRMPluginServer* server = 
sl@0
    49
			static_cast<CMMFDRMPluginServer*>(CONST_CAST(CMmfIpcServer*, &aServer));
sl@0
    50
	server->IncrementSessionId();
sl@0
    51
	}
sl@0
    52
sl@0
    53
void CMMFDRMPluginServerSession::ServiceL(const RMmfIpcMessage& aMessage)
sl@0
    54
	{
sl@0
    55
	switch (aMessage.Function())
sl@0
    56
		{
sl@0
    57
	case EMMFControllerLaunchRequest:
sl@0
    58
		DoLaunchControllerL(aMessage);
sl@0
    59
		aMessage.Complete(KErrNone);
sl@0
    60
		break;
sl@0
    61
	case EMMFControllerSessionHandle:
sl@0
    62
		if (!iControllerSessionHandle.Handle())
sl@0
    63
			{
sl@0
    64
			User::Leave(KErrNotReady);
sl@0
    65
			}
sl@0
    66
		aMessage.Complete(iControllerSessionHandle);
sl@0
    67
		break;
sl@0
    68
	case EMMFControllerThreadPanic:
sl@0
    69
		DoPanicControllerThreadL(aMessage);
sl@0
    70
		aMessage.Complete(KErrNone);
sl@0
    71
		break;
sl@0
    72
	case EMMFControllerThreadKill:
sl@0
    73
		DoKillControllerThreadL(aMessage);
sl@0
    74
		aMessage.Complete(KErrNone);
sl@0
    75
		break;
sl@0
    76
	case EMMFControllerSetThreadPriority:
sl@0
    77
		DoSetThreadPriorityL(aMessage);
sl@0
    78
		aMessage.Complete(KErrNone);
sl@0
    79
		break;
sl@0
    80
	case EMMFDRMContentOpenByFilePath:
sl@0
    81
		DoOpenContentByFilePathL(aMessage);
sl@0
    82
		aMessage.Complete(KErrNone);
sl@0
    83
		break;
sl@0
    84
	case EMMFDRMContentOpenByFileHandle:
sl@0
    85
		DoOpenContentByFileHandleL(aMessage);
sl@0
    86
		aMessage.Complete(KErrNone);
sl@0
    87
		break;
sl@0
    88
	case EMMFDRMContentEvaluateIntent:
sl@0
    89
		{
sl@0
    90
		TInt err = DoEvaluateContentIntent(aMessage);
sl@0
    91
		aMessage.Complete(err);
sl@0
    92
		}
sl@0
    93
		break;
sl@0
    94
	case EMMFDRMContentGetMimeType:
sl@0
    95
		DoGetContentMimeTypeL(aMessage);
sl@0
    96
		aMessage.Complete(KErrNone);
sl@0
    97
		break;
sl@0
    98
	case EMMFDRMContentGetFileHeader:
sl@0
    99
		DoGetContentFileHeaderL(aMessage);
sl@0
   100
		aMessage.Complete(KErrNone);
sl@0
   101
		break;
sl@0
   102
	case EMMFSetDrmPluginServerTimeout:
sl@0
   103
		DoSetDrmPluginServerTimeout(aMessage);
sl@0
   104
		aMessage.Complete(KErrNone);
sl@0
   105
		break;
sl@0
   106
	default:
sl@0
   107
		User::Leave(KErrNotSupported);
sl@0
   108
		break;
sl@0
   109
		}
sl@0
   110
	}
sl@0
   111
sl@0
   112
CMMFDRMPluginServerSession::CMMFDRMPluginServerSession()
sl@0
   113
	{
sl@0
   114
	}
sl@0
   115
sl@0
   116
void CMMFDRMPluginServerSession::DoLaunchControllerL(const RMmfIpcMessage& aMessage)
sl@0
   117
	{
sl@0
   118
	if (iControllerSessionHandle.Handle())
sl@0
   119
		{
sl@0
   120
		User::Leave(KErrAlreadyExists);
sl@0
   121
		}
sl@0
   122
	TThreadId controllerTID;
sl@0
   123
	RMMFControllerServerProxy controllerSessionHandle;
sl@0
   124
	CMMFDRMPluginServer* server = 
sl@0
   125
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
   126
	
sl@0
   127
	RThread clientThread;
sl@0
   128
	CleanupClosePushL(clientThread);
sl@0
   129
	User::LeaveIfError(aMessage.Client(clientThread));
sl@0
   130
	
sl@0
   131
	TPckg<TUint> maxHeapSize(0);
sl@0
   132
	TPckg<TBool> useShareHeap(ETrue);
sl@0
   133
	TPckg<TBool> stackSize(0);
sl@0
   134
	
sl@0
   135
	aMessage.ReadL(0, maxHeapSize);
sl@0
   136
	aMessage.ReadL(1, useShareHeap);
sl@0
   137
	aMessage.ReadL(3, stackSize);
sl@0
   138
	
sl@0
   139
	User::LeaveIfError(server->StartControllerServer(clientThread, maxHeapSize(), useShareHeap(), 
sl@0
   140
													controllerSessionHandle, controllerTID, stackSize()));
sl@0
   141
	SetControllerServerInfo(controllerSessionHandle, controllerTID);
sl@0
   142
	
sl@0
   143
	TPckgBuf<TThreadId> threadId(iControllerThreadID);
sl@0
   144
	aMessage.WriteL(2, threadId);
sl@0
   145
	CleanupStack::PopAndDestroy(&clientThread);
sl@0
   146
	}
sl@0
   147
sl@0
   148
void CMMFDRMPluginServerSession::DoPanicControllerThreadL(const RMmfIpcMessage& aMessage)
sl@0
   149
	{
sl@0
   150
	TPckgBuf<TThreadId> controllerTid(0);
sl@0
   151
	aMessage.ReadL(0, controllerTid);
sl@0
   152
	
sl@0
   153
	TInt desLen = aMessage.GetDesLengthL(1);
sl@0
   154
	HBufC* category = HBufC::NewLC(desLen);
sl@0
   155
	TPtr categoryPtr(category->Des());
sl@0
   156
	aMessage.ReadL(1, categoryPtr);
sl@0
   157
	
sl@0
   158
	TPckg<TInt>	panicReason(0);
sl@0
   159
	aMessage.ReadL(2, panicReason);
sl@0
   160
	
sl@0
   161
	CMMFDRMPluginServer* server = 
sl@0
   162
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
   163
	server->PanicControllerThread(controllerTid(), categoryPtr, panicReason());
sl@0
   164
	
sl@0
   165
	CleanupStack::PopAndDestroy(category);
sl@0
   166
	}
sl@0
   167
	
sl@0
   168
void CMMFDRMPluginServerSession::DoKillControllerThreadL(const RMmfIpcMessage& aMessage)
sl@0
   169
	{
sl@0
   170
	TPckgBuf<TThreadId> controllerTid(0);
sl@0
   171
	aMessage.ReadL(0, controllerTid);
sl@0
   172
	
sl@0
   173
	TPckg<TInt>	killReason(0);
sl@0
   174
	aMessage.ReadL(1, killReason);
sl@0
   175
	
sl@0
   176
	CMMFDRMPluginServer* server = 
sl@0
   177
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
   178
	server->KillControllerThread(controllerTid(), killReason());	
sl@0
   179
	}
sl@0
   180
	
sl@0
   181
void CMMFDRMPluginServerSession::SetControllerServerInfo(RHandleBase& aControllerSessionHandle,
sl@0
   182
													TThreadId& aControllerThreadId)
sl@0
   183
	{
sl@0
   184
	iControllerSessionHandle = aControllerSessionHandle;
sl@0
   185
	iControllerThreadID = aControllerThreadId;
sl@0
   186
	}
sl@0
   187
sl@0
   188
void CMMFDRMPluginServerSession::DoSetThreadPriorityL(const RMmfIpcMessage& aMessage)
sl@0
   189
	{
sl@0
   190
	TPckgBuf<TThreadId> threadId;
sl@0
   191
	TPckgBuf<TThreadPriority> priority;
sl@0
   192
	
sl@0
   193
	aMessage.ReadL(0, threadId);
sl@0
   194
	aMessage.ReadL(1, priority);
sl@0
   195
	
sl@0
   196
	CMMFDRMPluginServer* server = 
sl@0
   197
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
   198
	User::LeaveIfError(server->SetThreadPriority(threadId(), priority()));
sl@0
   199
	}
sl@0
   200
sl@0
   201
void CMMFDRMPluginServerSession::DoOpenContentByFilePathL(const RMmfIpcMessage& aMessage)
sl@0
   202
	{
sl@0
   203
	if (iData == NULL)
sl@0
   204
		{
sl@0
   205
		TInt length = aMessage.GetDesLengthL(0);
sl@0
   206
		HBufC* filePath = HBufC::NewLC(length);
sl@0
   207
		TPtr filePathPtr(filePath->Des());
sl@0
   208
		aMessage.ReadL(0, filePathPtr);
sl@0
   209
		
sl@0
   210
		length = aMessage.GetDesLengthL(1);
sl@0
   211
		HBufC8* initData = HBufC8::NewLC(length);
sl@0
   212
		TPtr8 initDataPtr(initData->Des());
sl@0
   213
		aMessage.ReadL(1, initDataPtr);
sl@0
   214
		
sl@0
   215
		HBufC* uniqueId = NULL;
sl@0
   216
		TBool UIEnabled;
sl@0
   217
		ContentAccess::TIntent intent;
sl@0
   218
		GetContentInitDataL(initDataPtr, uniqueId, UIEnabled, intent);
sl@0
   219
		CleanupStack::PopAndDestroy(initData);
sl@0
   220
		CleanupStack::PushL(uniqueId);
sl@0
   221
		
sl@0
   222
		iData = CData::NewL(TVirtualPathPtr(filePathPtr, *uniqueId), EContentShareReadWrite);
sl@0
   223
		TInt err = iData->SetProperty(EAgentPropertyAgentUI, UIEnabled);
sl@0
   224
		if (err != KErrNone && err != KErrCANotSupported)
sl@0
   225
			{
sl@0
   226
			// KErrCANotSupported isn't a problem for us so eat the error code.
sl@0
   227
			User::Leave(err);
sl@0
   228
			}
sl@0
   229
		User::LeaveIfError(iData->EvaluateIntent(intent));
sl@0
   230
		
sl@0
   231
		CleanupStack::PopAndDestroy(2, filePath);	// uniqueId, filePath
sl@0
   232
		}
sl@0
   233
	else
sl@0
   234
		{
sl@0
   235
		User::Leave(KErrAlreadyExists);
sl@0
   236
		}
sl@0
   237
	}
sl@0
   238
	
sl@0
   239
void CMMFDRMPluginServerSession::DoOpenContentByFileHandleL(const RMmfIpcMessage& aMessage)
sl@0
   240
	{
sl@0
   241
	if (iData == NULL)
sl@0
   242
		{
sl@0
   243
		RFile file;
sl@0
   244
		User::LeaveIfError(file.AdoptFromClient(aMessage, 0, 1));
sl@0
   245
		CleanupClosePushL(file);
sl@0
   246
		
sl@0
   247
		TInt length = aMessage.GetDesLengthL(2);
sl@0
   248
		HBufC8* initData = HBufC8::NewLC(length);
sl@0
   249
		TPtr8 initDataPtr(initData->Des());
sl@0
   250
		aMessage.ReadL(2, initDataPtr);
sl@0
   251
		
sl@0
   252
		HBufC* uniqueId = NULL;
sl@0
   253
		TBool UIEnabled;
sl@0
   254
		ContentAccess::TIntent intent;
sl@0
   255
		GetContentInitDataL(initDataPtr, uniqueId, UIEnabled, intent);
sl@0
   256
		CleanupStack::PopAndDestroy(initData);
sl@0
   257
		CleanupStack::PushL(uniqueId);
sl@0
   258
		
sl@0
   259
		iData = CData::NewL(file, *uniqueId);
sl@0
   260
		TInt err = iData->SetProperty(EAgentPropertyAgentUI, UIEnabled);
sl@0
   261
		if (err != KErrNone && err != KErrCANotSupported)
sl@0
   262
			{
sl@0
   263
			// KErrCANotSupported isn't a problem for us so eat the error code.
sl@0
   264
			User::Leave(err);
sl@0
   265
			}
sl@0
   266
		User::LeaveIfError(iData->EvaluateIntent(intent));
sl@0
   267
		
sl@0
   268
		CleanupStack::PopAndDestroy(2, &file);	// uniqueId, file
sl@0
   269
		}
sl@0
   270
	else
sl@0
   271
		{
sl@0
   272
		User::Leave(KErrAlreadyExists);
sl@0
   273
		}	
sl@0
   274
	}
sl@0
   275
sl@0
   276
void CMMFDRMPluginServerSession::GetContentInitDataL(const TDesC8& aInitData, HBufC*& aUniqueId,
sl@0
   277
							 						 TBool& aUIEnabled, ContentAccess::TIntent& aIntent)
sl@0
   278
	{
sl@0
   279
	if (aUniqueId)
sl@0
   280
		{
sl@0
   281
		delete aUniqueId;
sl@0
   282
		aUniqueId = NULL;
sl@0
   283
		}
sl@0
   284
	
sl@0
   285
	RDesReadStream stream(aInitData);
sl@0
   286
	CleanupClosePushL(stream);
sl@0
   287
	
sl@0
   288
	TInt length = stream.ReadInt32L();
sl@0
   289
	aUniqueId = HBufC::NewLC(length);
sl@0
   290
	TPtr ptr = aUniqueId->Des();
sl@0
   291
	stream.ReadL(ptr, length);
sl@0
   292
	
sl@0
   293
	aUIEnabled = stream.ReadInt32L();
sl@0
   294
	TPckgBuf<ContentAccess::TIntent> intentPckg;
sl@0
   295
	stream.ReadL(intentPckg);
sl@0
   296
	aIntent = intentPckg();
sl@0
   297
	
sl@0
   298
	CleanupStack::Pop(aUniqueId);
sl@0
   299
	CleanupStack::PopAndDestroy(&stream);
sl@0
   300
	}
sl@0
   301
sl@0
   302
TInt CMMFDRMPluginServerSession::DoEvaluateContentIntent(const RMmfIpcMessage& aMessage)
sl@0
   303
	{
sl@0
   304
	TInt err;
sl@0
   305
	if (iData)
sl@0
   306
		{
sl@0
   307
		TPckgBuf<TIntent> intentPckg;
sl@0
   308
		err = aMessage.Read(0, intentPckg);
sl@0
   309
		if (err == KErrNone)
sl@0
   310
			{
sl@0
   311
			err = iData->EvaluateIntent(intentPckg());
sl@0
   312
			}
sl@0
   313
		}
sl@0
   314
	else
sl@0
   315
		{
sl@0
   316
		err = KErrGeneral;
sl@0
   317
		}
sl@0
   318
	return err;
sl@0
   319
	}
sl@0
   320
sl@0
   321
void CMMFDRMPluginServerSession::DoGetContentMimeTypeL(const RMmfIpcMessage& aMessage)
sl@0
   322
	{
sl@0
   323
	if (iData)
sl@0
   324
		{
sl@0
   325
		TBool success = ETrue;
sl@0
   326
		TInt length = aMessage.GetDesMaxLengthL(0);
sl@0
   327
		
sl@0
   328
		HBufC* mimeType = HBufC::NewLC(length);
sl@0
   329
		TPtr mimeTypePtr = mimeType->Des();
sl@0
   330
		TInt err = iData->GetStringAttribute(EMimeType, mimeTypePtr);
sl@0
   331
		
sl@0
   332
		if (err == KErrNone)
sl@0
   333
			{
sl@0
   334
			HBufC8* mimeType8 = HBufC8::NewLC(length);
sl@0
   335
			TPtr8 mimeTypePtr8 = mimeType8->Des();
sl@0
   336
			mimeTypePtr8.Copy(mimeTypePtr);
sl@0
   337
			
sl@0
   338
			aMessage.WriteL(0, mimeTypePtr8);
sl@0
   339
			CleanupStack::PopAndDestroy(mimeType8);
sl@0
   340
			}
sl@0
   341
		else
sl@0
   342
			{
sl@0
   343
			success = EFalse;
sl@0
   344
			}
sl@0
   345
		CleanupStack::PopAndDestroy(mimeType);
sl@0
   346
		
sl@0
   347
		TPckg<TBool> successPckg(success);
sl@0
   348
		aMessage.WriteL(1, successPckg);
sl@0
   349
		}
sl@0
   350
	else
sl@0
   351
		{
sl@0
   352
		User::Leave(KErrGeneral);
sl@0
   353
		}
sl@0
   354
	}
sl@0
   355
sl@0
   356
void CMMFDRMPluginServerSession::DoGetContentFileHeaderL(const RMmfIpcMessage& aMessage)
sl@0
   357
	{
sl@0
   358
	if (iData)
sl@0
   359
		{
sl@0
   360
		TInt size = 0;
sl@0
   361
		iData->DataSizeL(size);
sl@0
   362
		
sl@0
   363
		TInt maxLength = aMessage.Int0();
sl@0
   364
		
sl@0
   365
		TInt desLength = aMessage.GetDesMaxLengthL(1);
sl@0
   366
		HBufC8* header = HBufC8::NewLC(desLength);
sl@0
   367
		TPtr8 headerPtr = header->Des();
sl@0
   368
		
sl@0
   369
		if (size > 0)
sl@0
   370
			{
sl@0
   371
			if (size > maxLength)
sl@0
   372
				{
sl@0
   373
				size = maxLength;
sl@0
   374
				}
sl@0
   375
			TInt pos = 0;
sl@0
   376
			User::LeaveIfError(iData->Seek(ESeekStart, pos));
sl@0
   377
			User::LeaveIfError(iData->Read(headerPtr, size));
sl@0
   378
			aMessage.WriteL(1, headerPtr);
sl@0
   379
			}
sl@0
   380
		CleanupStack::PopAndDestroy(header);
sl@0
   381
		}
sl@0
   382
	else
sl@0
   383
		{
sl@0
   384
		User::Leave(KErrGeneral);
sl@0
   385
		}
sl@0
   386
	}
sl@0
   387
sl@0
   388
void CMMFDRMPluginServerSession::DoSetDrmPluginServerTimeout(const RMmfIpcMessage& aMessage)
sl@0
   389
	{
sl@0
   390
	CMMFDRMPluginServer* server = 
sl@0
   391
		const_cast<CMMFDRMPluginServer*>(static_cast<const CMMFDRMPluginServer*>(Server()));
sl@0
   392
	server->SetTimeout(aMessage.Int0());	
sl@0
   393
	}
sl@0
   394