os/kernelhwsrv/kerneltest/f32test/plugins/version_2/src/observer_plugin.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 the License "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 "observer_plugin.h"
sl@0
    17
#include "plugincommon.h"
sl@0
    18
#include <f32pluginutils.h>
sl@0
    19
sl@0
    20
/**
sl@0
    21
Leaving New function for the plugin
sl@0
    22
@internalComponent
sl@0
    23
*/
sl@0
    24
CObserverPlugin* CObserverPlugin::NewL()
sl@0
    25
	{
sl@0
    26
	CObserverPlugin* self = new(ELeave) CObserverPlugin;
sl@0
    27
    CleanupStack::PushL(self);
sl@0
    28
    self->ConstructL();
sl@0
    29
    CleanupStack::Pop();
sl@0
    30
	return self;
sl@0
    31
	}
sl@0
    32
sl@0
    33
sl@0
    34
/**
sl@0
    35
Constructor for the plugin
sl@0
    36
@internalComponent
sl@0
    37
*/
sl@0
    38
CObserverPlugin::CObserverPlugin() : iInterceptsEnabled(EFalse),
sl@0
    39
									 iLogging(ETrue)
sl@0
    40
	{
sl@0
    41
	}
sl@0
    42
sl@0
    43
sl@0
    44
void CObserverPlugin::ConstructL()
sl@0
    45
	{
sl@0
    46
	}
sl@0
    47
sl@0
    48
/**
sl@0
    49
The destructor for the plugin
sl@0
    50
@internalComponent
sl@0
    51
*/
sl@0
    52
CObserverPlugin::~CObserverPlugin()
sl@0
    53
	{
sl@0
    54
	iFs.Close();
sl@0
    55
	}
sl@0
    56
sl@0
    57
/**
sl@0
    58
Initialise the plugin.
sl@0
    59
@internalComponent
sl@0
    60
*/
sl@0
    61
void CObserverPlugin::InitialiseL()
sl@0
    62
	{
sl@0
    63
	User::LeaveIfError(iFs.Connect());
sl@0
    64
	CleanupClosePushL(iFs);
sl@0
    65
sl@0
    66
	_LOG(_L("CObserverPlugin InitialiseL"));
sl@0
    67
	EnableInterceptsL();
sl@0
    68
	
sl@0
    69
	CleanupStack::Pop(); // iFs
sl@0
    70
	}
sl@0
    71
sl@0
    72
/**
sl@0
    73
Enable the plugin's intercepts.
sl@0
    74
@internalComponent
sl@0
    75
*/
sl@0
    76
void CObserverPlugin::EnableInterceptsL()
sl@0
    77
	{
sl@0
    78
	if (iInterceptsEnabled) return;
sl@0
    79
	
sl@0
    80
	User::LeaveIfError(RegisterIntercept(EFsFileRead,		EPrePostIntercept));
sl@0
    81
	User::LeaveIfError(RegisterIntercept(EFsFileWrite,		EPrePostIntercept));
sl@0
    82
	User::LeaveIfError(RegisterIntercept(EFsDirOpen,		EPrePostIntercept));
sl@0
    83
	User::LeaveIfError(RegisterIntercept(EFsFileLock,		EPrePostIntercept));
sl@0
    84
	User::LeaveIfError(RegisterIntercept(EFsFileUnLock,		EPrePostIntercept));
sl@0
    85
	User::LeaveIfError(RegisterIntercept(EFsFileSeek,		EPrePostIntercept));
sl@0
    86
	User::LeaveIfError(RegisterIntercept(EFsFileSize,		EPrePostIntercept));
sl@0
    87
	User::LeaveIfError(RegisterIntercept(EFsFileSetSize,	EPrePostIntercept));
sl@0
    88
	User::LeaveIfError(RegisterIntercept(EFsDirReadOne,		EPrePostIntercept));
sl@0
    89
	User::LeaveIfError(RegisterIntercept(EFsDirReadPacked,	EPrePostIntercept));
sl@0
    90
	User::LeaveIfError(RegisterIntercept(EFsFileOpen,		EPrePostIntercept));
sl@0
    91
	User::LeaveIfError(RegisterIntercept(EFsFileCreate,		EPrePostIntercept));
sl@0
    92
	User::LeaveIfError(RegisterIntercept(EFsFileReplace,	EPrePostIntercept));
sl@0
    93
	User::LeaveIfError(RegisterIntercept(EFsFileRename,		EPrePostIntercept));
sl@0
    94
   	User::LeaveIfError(RegisterIntercept(EFsReadFileSection,EPrePostIntercept));
sl@0
    95
	User::LeaveIfError(RegisterIntercept(EFsFileSubClose,	EPrePostIntercept));
sl@0
    96
	User::LeaveIfError(RegisterIntercept(EFsDriveList,		EPrePostIntercept)); 
sl@0
    97
	User::LeaveIfError(RegisterIntercept(EFsSubst,			EPrePostIntercept));
sl@0
    98
	User::LeaveIfError(RegisterIntercept(EFsSetSubst,		EPrePostIntercept));
sl@0
    99
	
sl@0
   100
	_LOG(_L("Observer Plugin: Enabled intercepts."));
sl@0
   101
    
sl@0
   102
	iInterceptsEnabled = ETrue;
sl@0
   103
	}
sl@0
   104
sl@0
   105
/**
sl@0
   106
Disable the plugin's intercepts.
sl@0
   107
@internalComponent
sl@0
   108
*/
sl@0
   109
void CObserverPlugin::DisableInterceptsL()
sl@0
   110
	{
sl@0
   111
	if (!iInterceptsEnabled) return;
sl@0
   112
	
sl@0
   113
	User::LeaveIfError(UnregisterIntercept(EFsFileRead,		EPrePostIntercept));
sl@0
   114
	User::LeaveIfError(UnregisterIntercept(EFsFileRename,	EPrePostIntercept));
sl@0
   115
	User::LeaveIfError(UnregisterIntercept(EFsFileWrite,	EPrePostIntercept));
sl@0
   116
	User::LeaveIfError(UnregisterIntercept(EFsDirOpen,		EPrePostIntercept));
sl@0
   117
	User::LeaveIfError(UnregisterIntercept(EFsFileLock,		EPrePostIntercept));
sl@0
   118
	User::LeaveIfError(UnregisterIntercept(EFsFileUnLock,	EPrePostIntercept));
sl@0
   119
	User::LeaveIfError(UnregisterIntercept(EFsFileSeek,		EPrePostIntercept));
sl@0
   120
	User::LeaveIfError(UnregisterIntercept(EFsFileSize,		EPrePostIntercept));
sl@0
   121
	User::LeaveIfError(UnregisterIntercept(EFsFileSetSize,	EPrePostIntercept));
sl@0
   122
	User::LeaveIfError(UnregisterIntercept(EFsFileCreate,	EPrePostIntercept));
sl@0
   123
	User::LeaveIfError(UnregisterIntercept(EFsFileOpen, 	EPrePostIntercept));
sl@0
   124
	User::LeaveIfError(UnregisterIntercept(EFsFileReplace, 	EPrePostIntercept));
sl@0
   125
	User::LeaveIfError(UnregisterIntercept(EFsFileSubClose,        EPrePostIntercept));
sl@0
   126
	User::LeaveIfError(UnregisterIntercept(EFsReadFileSection,EPrePostIntercept));
sl@0
   127
	User::LeaveIfError(UnregisterIntercept(EFsDirReadOne,	EPrePostIntercept));
sl@0
   128
	User::LeaveIfError(UnregisterIntercept(EFsDirReadPacked,EPrePostIntercept));
sl@0
   129
	User::LeaveIfError(UnregisterIntercept(EFsDriveList,	EPrePostIntercept));
sl@0
   130
	User::LeaveIfError(UnregisterIntercept(EFsSubst,	EPrePostIntercept));
sl@0
   131
	User::LeaveIfError(UnregisterIntercept(EFsSetSubst,	EPrePostIntercept));
sl@0
   132
sl@0
   133
sl@0
   134
	_LOG(_L("Observer Plugin: Disabled intercepts."));
sl@0
   135
    
sl@0
   136
	iInterceptsEnabled = EFalse;
sl@0
   137
	}
sl@0
   138
sl@0
   139
/**
sl@0
   140
Handle requests
sl@0
   141
@internalComponent
sl@0
   142
*/
sl@0
   143
TInt CObserverPlugin::DoRequestL(TFsPluginRequest& aRequest)
sl@0
   144
	{
sl@0
   145
	TInt err = KErrNone;
sl@0
   146
sl@0
   147
	TInt function = aRequest.Function();
sl@0
   148
sl@0
   149
	if (aRequest.IsPostOperation())
sl@0
   150
		{
sl@0
   151
		_LOG2(_L("CObserverPlugin post intercept for function %d"), function);
sl@0
   152
		}
sl@0
   153
	else
sl@0
   154
		{
sl@0
   155
		_LOG2(_L("CObserverPlugin pre intercept for function %d"), function);
sl@0
   156
		_LOG2(_L("CObserverPlugin pre intercept on drive %d"), aRequest.DriveNumber());
sl@0
   157
		}
sl@0
   158
sl@0
   159
	if(function == EFsFileOpen)
sl@0
   160
		{
sl@0
   161
		// Check that FileName can't be used in pre-operation (as the handle doesn't exist yet!)
sl@0
   162
		TFileName shareName;
sl@0
   163
		TInt nErr = aRequest.FileName(shareName);
sl@0
   164
		if (aRequest.IsPostOperation())
sl@0
   165
			{
sl@0
   166
			TFileName fileName = aRequest.Src().FullName();
sl@0
   167
			nErr = shareName.Compare(fileName);
sl@0
   168
			User::LeaveIfError(nErr);
sl@0
   169
			}
sl@0
   170
		else if(nErr != KErrNotSupported)
sl@0
   171
			{
sl@0
   172
			User::Leave(KErrArgument);
sl@0
   173
			}
sl@0
   174
		}
sl@0
   175
sl@0
   176
	return err;
sl@0
   177
	}
sl@0
   178
sl@0
   179
sl@0
   180
CFsPluginConn* CObserverPlugin::NewPluginConnL()
sl@0
   181
	{
sl@0
   182
	return new(ELeave) CObserverPluginConn();
sl@0
   183
	}
sl@0
   184
sl@0
   185
sl@0
   186
//Synchronous RPlugin::DoControl
sl@0
   187
TInt CObserverPlugin::FsPluginDoControlL(CFsPluginConnRequest& aRequest)
sl@0
   188
	{
sl@0
   189
	TInt err = KErrNone;
sl@0
   190
	TPckg<TBool> interceptStatusDes(iInterceptsEnabled);
sl@0
   191
	
sl@0
   192
	//We can use this to set the drive
sl@0
   193
	//We can store this as a member of this class.
sl@0
   194
	TInt function = aRequest.Function();
sl@0
   195
	switch(function)
sl@0
   196
		{
sl@0
   197
		//case KPluginSetDrive:
sl@0
   198
		//	//{
sl@0
   199
		//	TPckg<TChar> drive(iDriveToTest);
sl@0
   200
		//	TRAP(err,aRequest.ReadParam1L(drive));
sl@0
   201
		//	break;
sl@0
   202
		//	}
sl@0
   203
		//case KPluginGetError:
sl@0
   204
		//	{
sl@0
   205
		//	TPckg<TInt> errCodeDes(iLastError);
sl@0
   206
		//	TPckg<TInt> errMsgDes(iMessage);
sl@0
   207
		//	TRAP(err,aRequest.WriteParam1L(errCodeDes));
sl@0
   208
		//	TRAP(err,aRequest.WriteParam2L(errMsgDes));
sl@0
   209
		//	break;
sl@0
   210
		//	}
sl@0
   211
		case KPluginToggleIntercepts:
sl@0
   212
			{
sl@0
   213
			iInterceptsEnabled ^= (TBool)1; //toggle intercepts;
sl@0
   214
			TRAP(err,aRequest.WriteParam1L(interceptStatusDes));
sl@0
   215
			break;
sl@0
   216
			}
sl@0
   217
		default:
sl@0
   218
			break;
sl@0
   219
		}
sl@0
   220
sl@0
   221
	return err;
sl@0
   222
	}
sl@0
   223
sl@0
   224
TInt CObserverPluginConn::DoControl(CFsPluginConnRequest& aRequest)
sl@0
   225
	{
sl@0
   226
	return ((CObserverPlugin*)Plugin())->FsPluginDoControlL(aRequest);
sl@0
   227
	}
sl@0
   228
sl@0
   229
void CObserverPluginConn::DoRequest(CFsPluginConnRequest& aRequest)
sl@0
   230
	{
sl@0
   231
	DoControl(aRequest);
sl@0
   232
	}
sl@0
   233
sl@0
   234
void CObserverPluginConn::DoCancel(TInt /*aReqMask*/)
sl@0
   235
	{
sl@0
   236
	}
sl@0
   237
sl@0
   238
sl@0
   239
//factory functions
sl@0
   240
sl@0
   241
class CObserverPluginFactory : public CFsPluginFactory
sl@0
   242
	{
sl@0
   243
public:
sl@0
   244
	CObserverPluginFactory();
sl@0
   245
	virtual TInt Install();			
sl@0
   246
	virtual CFsPlugin* NewPluginL();
sl@0
   247
	virtual CFsPlugin* NewPluginConnL();
sl@0
   248
	virtual TInt UniquePosition();
sl@0
   249
	};
sl@0
   250
sl@0
   251
/**
sl@0
   252
Constructor for the plugin factory
sl@0
   253
@internalComponent
sl@0
   254
*/
sl@0
   255
CObserverPluginFactory::CObserverPluginFactory()
sl@0
   256
	{
sl@0
   257
	}
sl@0
   258
sl@0
   259
/**
sl@0
   260
Install function for the plugin factory
sl@0
   261
@internalComponent
sl@0
   262
*/
sl@0
   263
TInt CObserverPluginFactory::Install()
sl@0
   264
	{
sl@0
   265
	//SetSupportedDrives(1<<23);
sl@0
   266
	iSupportedDrives = KPluginSupportAllDrives; 
sl@0
   267
	return(SetName(&KObserverPluginName));
sl@0
   268
	}
sl@0
   269
sl@0
   270
/**
sl@0
   271
@internalComponent
sl@0
   272
*/
sl@0
   273
TInt CObserverPluginFactory::UniquePosition()
sl@0
   274
	{
sl@0
   275
	return(KObserverPos);
sl@0
   276
	}
sl@0
   277
sl@0
   278
/**
sl@0
   279
Plugin factory function
sl@0
   280
@internalComponent
sl@0
   281
*/
sl@0
   282
CFsPlugin* CObserverPluginFactory::NewPluginL()
sl@0
   283
sl@0
   284
	{
sl@0
   285
	return CObserverPlugin::NewL();
sl@0
   286
	}
sl@0
   287
sl@0
   288
/**
sl@0
   289
Plugin factory function
sl@0
   290
@internalComponent
sl@0
   291
*/
sl@0
   292
CFsPlugin* CObserverPluginFactory::NewPluginConnL()
sl@0
   293
sl@0
   294
	{
sl@0
   295
	return CObserverPlugin::NewL();
sl@0
   296
	}
sl@0
   297
sl@0
   298
/**
sl@0
   299
Create a new Plugin
sl@0
   300
@internalComponent
sl@0
   301
*/
sl@0
   302
extern "C" {
sl@0
   303
sl@0
   304
EXPORT_C CFsPluginFactory* CreateFileSystem()
sl@0
   305
	{
sl@0
   306
	return(new CObserverPluginFactory());
sl@0
   307
	}
sl@0
   308
}
sl@0
   309