--- a/userlibandfileserver/fileserver/sfile/sf_request.cpp Tue Aug 31 16:34:26 2010 +0300
+++ b/userlibandfileserver/fileserver/sfile/sf_request.cpp Wed Sep 01 12:34:56 2010 +0100
@@ -974,7 +974,7 @@
//
{
TInt err = KErrNone;
- if(!iCurrentPlugin->OriginatedFromPlugin(*this))
+ if(!iCurrentPlugin->IsPluginThread(*this))
{
// The request hasn't come from this plugin so it's safe to dispatch
TFsPluginRequest request(this);
@@ -997,17 +997,14 @@
// Find the previous plugin in the chain and dispatch
// - If no more plugins are interested in this message, then complete
- FsPluginManager::ReadLockChain();
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this, ETrue);
if(iCurrentPlugin == NULL)
{
- FsPluginManager::UnlockChain();
Complete(GetError());
return;
}
Dispatch();
- FsPluginManager::UnlockChain();
return;
}
@@ -1018,7 +1015,7 @@
//
{
TInt err = KErrNone;
- if(!iCurrentPlugin->OriginatedFromPlugin(*this))
+ if(!iCurrentPlugin->IsPluginThread(*this))
{
// The request hasn't come from this plugin so it's safe to dispatch
TFsPluginRequest request(this);
@@ -1027,7 +1024,7 @@
if((iOperation->Function() == EFsDismountPlugin) && (err != KErrPermissionDenied))
{
- err = KErrNone;
+ TRAP(leaveValue, err = iOperation->DoRequestL(this));
}
if(leaveValue != KErrNone)
@@ -1045,12 +1042,10 @@
// Find the next plugin in the chain and dispatch
// - If no more plugins are interested in this message,
// then Dispatch() will process the request in drive/main thread context.
- FsPluginManager::ReadLockChain();
- FsPluginManager::NextPlugin(iCurrentPlugin, this);
+ FsPluginManager::NextPlugin(iCurrentPlugin, this,(TBool)ETrue);
if(iCurrentPlugin && IsPostOperation())
SetPostOperation(EFalse);
Dispatch();
- FsPluginManager::UnlockChain();
return;
}
// KErrCompletion may be returned by the plugin to
@@ -1059,21 +1054,18 @@
{
// Find the previous plugin in the chain and dispatch
// - If no more plugins are interested in this message, then complete
- FsPluginManager::ReadLockChain();
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this,(TBool)ETrue);
if(iCurrentPlugin != NULL)
{
SetPostOperation(ETrue);
err = KErrNone;
Dispatch();
- FsPluginManager::UnlockChain();
return;
}
else
{
err = KErrNone;
}
- FsPluginManager::UnlockChain();
}
Complete(err);
@@ -1132,18 +1124,13 @@
iCurrentPlugin = NULL;
if (PostInterceptEnabled())
{
- FsPluginManager::ReadLockChain();
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
- if(iCurrentPlugin && !iCurrentPlugin->OriginatedFromPlugin(*this))
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this,(TBool)ETrue);
+ if(iCurrentPlugin && !iCurrentPlugin->IsPluginThread(*this))
{
SetPostOperation(ETrue);
if (DispatchToPlugin())
- {
- FsPluginManager::UnlockChain();
return;
- }
}
- FsPluginManager::UnlockChain();
}
Complete(GetError());
@@ -1422,16 +1409,13 @@
iCurrentPlugin = NULL;
if (PostInterceptEnabled())
{
- FsPluginManager::ReadLockChain();
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
- if(iCurrentPlugin && !iCurrentPlugin->OriginatedFromPlugin(*this))
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this,(TBool)ETrue);
+ if(iCurrentPlugin && !iCurrentPlugin->IsPluginThread(*this))
{
SetPostOperation(ETrue);
Dispatch();
- FsPluginManager::UnlockChain();
return r; // EReqActionComplete
}
- FsPluginManager::UnlockChain();
}
Complete(KErrNone);
@@ -1459,7 +1443,6 @@
__THRD_PRINT1(_L("CFsMessageRequest::Dispatch() req %08x"), this);
TInt r = KErrNone;
- TBool pluginChainLocked = EFalse;
if (iReqState == EReqStateInitialise && aInitialise)
{
@@ -1479,18 +1462,16 @@
}
if(!IsPluginSpecific() && (iOwnerPlugin == NULL))
{
- FsPluginManager::ReadLockChain(); // Unlocked in DispatchToPlugin
- pluginChainLocked = ETrue;
iCurrentPlugin = NULL;
iClientThreadId = 0;
- FsPluginManager::NextPlugin(iCurrentPlugin, this);
+ FsPluginManager::NextPlugin(iCurrentPlugin, this, (TBool)ETrue);
// find out whether there is a plugin registered to post intercept this message
CFsPlugin* postInterceptPlugin = NULL;
if (iCurrentPlugin == NULL)
- FsPluginManager::PrevPlugin(postInterceptPlugin, this);
+ FsPluginManager::PrevPlugin(postInterceptPlugin, this, (TBool)ETrue);
- // Save the client's thread Id for subsequent testing by CFsPlugin::OriginatedFromPlugin() - doing so on the fly
+ // Save the client's thread Id for subsequent testing by CFsPlugin::IsPluginThread() - doing so on the fly
// is risky because some messages are completed early in which case Message().Client() will result in a panic
if ((iCurrentPlugin || postInterceptPlugin) && Message().Handle() != NULL && Message().Handle() != KLocalMessageHandle)
{
@@ -1509,23 +1490,16 @@
__PLUGIN_PRINT1(_L("PLUGIN: CFsMessageRequest %x dispatched to plugin (async)"), this);
// The request has been delivered to the plugin thread
// - leave the main thread now and await asynchronous completion
- if(pluginChainLocked)
- FsPluginManager::UnlockChain();
return;
}
- //DispatchToPlugin didn't (deliver then unlock) so make sure we unlock here.
- if(pluginChainLocked)
- FsPluginManager::UnlockChain();
// Is there a PostInitialise function ?
if (iReqState == EReqStatePostInitialise && aInitialise && r == KErrNone)
{
TInt r = PostInitialise();
if (r == EReqActionComplete)
- {
return;
- }
else if (r == EReqActionBusy) // request postponed ?
SetState(EReqStatePostInitialise); // reinitialize when request is next processed
}
@@ -1585,7 +1559,6 @@
//
// Common route: Receive -> Process -> Dispatch -> DispatchToPlugin
//
-// (Is called with FsPluginManager ReadLocked)
{
TInt drivenumber = DriveNumber();
if(iCurrentPlugin)
@@ -1599,16 +1572,16 @@
iCurrentPlugin = NULL;
}
- while(iCurrentPlugin && iCurrentPlugin->OriginatedFromPlugin(*this))
+ while(iCurrentPlugin && iCurrentPlugin->IsPluginThread(*this))
{
// Skip the current plugin if the request originated from the plugin
if(IsPostOperation())
{
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this,(TBool)ETrue);
}
else
{
- FsPluginManager::NextPlugin(iCurrentPlugin, this);
+ FsPluginManager::NextPlugin(iCurrentPlugin, this,(TBool)ETrue);
}
}
@@ -1638,7 +1611,7 @@
// - Pass the message on to the next plugin
if(FsFunction() != EFsPluginOpen)
{
- FsPluginManager::NextPlugin(iCurrentPlugin, this);
+ FsPluginManager::NextPlugin(iCurrentPlugin, this,(TBool)ETrue);
continue;
}
else // FsFunction == EFsPluginOpen
@@ -1646,6 +1619,7 @@
/*
* PluginOpen requests should not be passed down the plugin stack.
*
+
*/
iCurrentPlugin = NULL;
continue;
@@ -1656,7 +1630,7 @@
// The plugin has processed synchronously (case 2)
// - Pass the message back up the stack
SetPostOperation(ETrue);
- FsPluginManager::PrevPlugin(iCurrentPlugin, this);
+ FsPluginManager::PrevPlugin(iCurrentPlugin, this,(TBool)ETrue);
continue;
}
_LIT(KPanic,"Panic: F32-BAD-PLUGIN-ERROR");
@@ -1678,17 +1652,13 @@
}
}
- /*
- * Special case- DismountPlugin runs in the context of the plugin thread
- */
if(iOperation->Function() == EFsDismountPlugin)
{
// Don't pass plugin dismounts to the drive thread
- FsPluginManager::UnlockChain();
Process();
- FsPluginManager::ReadLockChain(); //inverted unlock/lock to get around dismount plugin being a special case
return(ETrue);
}
+
return EFalse;
}