1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/sdbms/SD_SRV.CPP Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,237 @@
1.4 +// Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +// DBMS server implementation
1.18 +//
1.19 +//
1.20 +
1.21 +#include "SD_STD.H"
1.22 +#include "Sd_PlatDep.h"
1.23 +
1.24 +using namespace DBSC;
1.25 +
1.26 +//CDbmsActiveScheduler class just exposes the access to
1.27 +//CActiveScheduler::Level() method, which is needed to
1.28 +//make a decision when to call CDbmsActiveScheduler::Stop().
1.29 +class CDbmsActiveScheduler : public CActiveScheduler
1.30 + {
1.31 +public:
1.32 + inline TInt Level() const
1.33 + {
1.34 + return CActiveScheduler::Level();
1.35 + }
1.36 + };
1.37 +
1.38 +///////////////////////
1.39 +// Class CDbsServer
1.40 +inline CDbsServer::CDbsServer() :
1.41 + CServer2(0, ESharableSessions),
1.42 + iSources(iCache),
1.43 + iDbPropsFactory(iFs),
1.44 + iDriveSpaceCol(iFs)
1.45 + {
1.46 + DbgPrint1(_L("###CDbsServer::CDbsServer(), Server ProcID=%d\n"), RDbProcess().Id());
1.47 + }
1.48 +
1.49 +//"iCache.Hold(this,KDbsExitDelay)" statement will put CDbsServer instance in the cache,
1.50 +//which ensures that CDbsServer instance will be automatically destroyed if nobody
1.51 +//uses it next KDbsExitDelay microseconds.
1.52 +CDbsServer* CDbsServer::NewL()
1.53 + {
1.54 + DbgPrint1(_L("###CDbsServer::NewL(), Server ProcId=%d\n"), RDbProcess().Id());
1.55 + CDbsServer* self= new (ELeave) CDbsServer;
1.56 + CleanupStack::PushL(self);
1.57 + self->ConstructL();
1.58 + CleanupStack::Pop(self);
1.59 + self->iCache.Hold(self, KDbsExitDelay); // the last thing we do here
1.60 + //Intentional behaviour, resources freed after timeout only
1.61 + //coverity[use_after_free]
1.62 + return self;
1.63 + }
1.64 +
1.65 +//
1.66 +// 2nd phase construction - ensure the timer and server objects are running
1.67 +//
1.68 +void CDbsServer::ConstructL()
1.69 + {
1.70 + DbgPrint1(_L("###CDbsServer::ConstructL(), Server ProcId=%d\n"), RDbProcess().Id());
1.71 + __LEAVE_IF_ERROR(Dll::SetTls(this));
1.72 + StartL(KDbsServerName);
1.73 + __LEAVE_IF_ERROR(iFs.Connect());
1.74 + iDbPropsFactory.OpenL();
1.75 + //EDriveZ - Symbian OS ROM drive !?!?
1.76 + iDbPropsFactory.GetPrivatePathL(EDriveZ, iFileName);
1.77 + iPolicyProxy = CPolicyProxy::NewL(iFs,iFileName);
1.78 + User::LeaveIfError(iCache.Open(ECacheSize, ETrue)); // create a timed cache
1.79 + }
1.80 +
1.81 +//
1.82 +// Invoked via cache entry expiry (or cleanup)
1.83 +//
1.84 +CDbsServer::~CDbsServer()
1.85 + {
1.86 + DbgPrint1(_L("###CDbsServer::~CDbsServer(), Server ProcId=%d\n"), RDbProcess().Id());
1.87 + iDriveSpaceCol.Close();
1.88 + delete iPolicyProxy;
1.89 + iDbPropsFactory.Close();
1.90 + iCache.Close();
1.91 + iSources.Close();
1.92 + iFs.Close();
1.93 + //Stop the scheduler if the nesting level > 0.
1.94 + //Sometime it happens that more than one thread tries to run the server and you will have
1.95 + //CDbmsActiveScheduler::Install() called multiple times. But you have to stop the
1.96 + //scheduler only once!
1.97 + CDbmsActiveScheduler* scheduler = static_cast <CDbmsActiveScheduler*> (CActiveScheduler::Current());
1.98 + if(scheduler->Level() > 0)
1.99 + {
1.100 + DbgPrint2(_L("###CDbsServer::~CDbsServer(), stop the scheduler, Server ProcId=%d, scheduler=%x\n"), RDbProcess().Id(), (TInt)scheduler);
1.101 + CDbmsActiveScheduler::Stop();
1.102 + }
1.103 + }
1.104 +
1.105 +//
1.106 +// Creates a new client session. This should really check the version number.
1.107 +//
1.108 +CSession2* CDbsServer::NewSessionL(const TVersion& aVersion,const RMessage2&) const
1.109 + {
1.110 + if(!User::QueryVersionSupported(RDbs::Version(), aVersion))
1.111 + {
1.112 + __LEAVE(KErrNotSupported);
1.113 + }
1.114 + CSession2* session = new (ELeave) CDbsSession;
1.115 + iCache.Release(*this);
1.116 + return session;
1.117 + }
1.118 +
1.119 +//
1.120 +// Returns the instance of the server
1.121 +//
1.122 +CDbsServer* CDbsServer::Instance()
1.123 + {
1.124 + return (CDbsServer*)Dll::Tls();
1.125 + }
1.126 +
1.127 +//
1.128 +// initiates exit if the last client is closing
1.129 +//
1.130 +void CDbsServer::RemoveSession()
1.131 + {
1.132 + iSessionIter.SetToFirst();
1.133 + iSessionIter++;
1.134 + if(iSessionIter++ == 0)
1.135 + {
1.136 + iCache.Hold(this, KDbsExitDelay);
1.137 + }
1.138 + }
1.139 +
1.140 +//
1.141 +// Performs all server initialisation, in particular creation of the
1.142 +// scheduler and server.
1.143 +// Noting has to be leaved in the cleanup stack!
1.144 +// Both: DBMS server and the active scheduler will be destroyed
1.145 +// later. The active scheduler - in CDbsServer destructor.
1.146 +// CDbsServer instance - by iCache instance (RDbCache).
1.147 +static void CreateServerL()
1.148 + {
1.149 + DbgPrint1(_L("###DBMS-CreateServerL(), Server ProcId=%d\n"), RDbProcess().Id());
1.150 + // naming the server thread after the server helps to debug panics
1.151 + User::LeaveIfError(User::RenameThread(KDbsServerName));
1.152 + // ensure the server thread has a handle on EDBMS.DLL
1.153 + LoadDbmsLibraryL();
1.154 +
1.155 + // create and install the active scheduler we need
1.156 + CDbmsActiveScheduler* scheduler = new (ELeave) CDbmsActiveScheduler;
1.157 + CleanupStack::PushL(scheduler);
1.158 + CDbmsActiveScheduler::Install(scheduler);
1.159 +
1.160 + // create the server
1.161 + (void)CDbsServer::NewL();
1.162 +
1.163 + CleanupStack::Pop(scheduler);
1.164 +
1.165 + // Initialisation complete, now signal the client
1.166 + RDbProcess::Rendezvous(KErrNone);
1.167 + }
1.168 +
1.169 +//
1.170 +// Performs all server initialisation, in particular creation of the
1.171 +// scheduler and server and then run the scheduler
1.172 +//
1.173 +static void RunServerL()
1.174 + {
1.175 + DbgPrint1(_L("###DBMS-RunServerL(), Server ProcId=%d\n"), RDbProcess().Id());
1.176 + ::CreateServerL();
1.177 + //After successfull creation CreateServerL() call leaves the active scheduler instance
1.178 + //and the DBMS server instance in the heap - they will be destroyed later.
1.179 + __UHEAP_MARK;
1.180 + //Start the scheduler. The execution control is transferred to the curent
1.181 + //active scheduler. The statement after "CDbmsActiveScheduler::Start();" will
1.182 + //be reached after the stop of active scheduler.
1.183 + CDbmsActiveScheduler::Start();
1.184 + __UHEAP_MARKEND;
1.185 + }
1.186 +
1.187 +//
1.188 +// Server process entry-point
1.189 +//
1.190 +EXPORT_C TInt Dbs::Run()
1.191 + {
1.192 + CTrapCleanup* cleanup = CTrapCleanup::New();
1.193 + TInt err = KErrNoMemory;
1.194 + if(cleanup)
1.195 + {
1.196 + TRAP(err, ::RunServerL());
1.197 + delete cleanup;
1.198 + }
1.199 + DbgPrint2(_L("###Dbs::Run(), end, Server ProcId=%d, err=%d\n"), RDbProcess().Id(), err);
1.200 + return err;
1.201 + }
1.202 +
1.203 +///////////////////////
1.204 +// Client called code
1.205 +
1.206 +//
1.207 +// Starts the DBMS server
1.208 +//
1.209 +TInt Dbs::Start()
1.210 + {
1.211 + DbgPrint1(_L("#-#Dbs::Start(), Client ProcId=%d\n"), RDbProcess().Id());
1.212 + RDbProcess server;
1.213 + TInt err = ::CreateDbmsProcess(server);
1.214 + if(err != KErrNone)
1.215 + {
1.216 + DbgPrint2(_L("#-#Dbs::Start(), CreateDbmsProcess, Client ProcId=%d, err=%d\n"), RDbProcess().Id(), err);
1.217 + return err;
1.218 + }
1.219 +
1.220 + TRequestStatus stat;
1.221 + server.Rendezvous(stat);
1.222 + if(stat != KRequestPending)
1.223 + {
1.224 + server.Kill(0); // abort startup
1.225 + }
1.226 + else
1.227 + {
1.228 + server.Resume(); // logon OK - start the server
1.229 + }
1.230 + User::WaitForRequest(stat); // wait for start or death
1.231 +
1.232 + // we can't use the 'exit reason' if the server panicked as this
1.233 + // is the panic 'reason' and may be '0' which cannot be distinguished
1.234 + // from KErrNone
1.235 + err = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();
1.236 + server.Close();
1.237 + DbgPrint2(_L("#-#Dbs::Start(), end, Client ProcId=%d, err=%d\n"), RDbProcess().Id(), err);
1.238 + return err;
1.239 + }
1.240 +