--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/contentstorage/srvsrc/casrv.cpp Fri Mar 19 09:35:23 2010 +0200
@@ -0,0 +1,216 @@
+/*
+ * Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
+ * All rights reserved.
+ * This component and the accompanying materials are made available
+ * under the terms of "Eclipse Public License v1.0"
+ * which accompanies this distribution, and is available
+ * at the URL "http://www.eclipse.org/legal/epl-v10.html".
+ *
+ * Initial Contributors:
+ * Nokia Corporation - initial contribution.
+ *
+ * Contributors:
+ *
+ * Description: ?Description
+ *
+ */
+// INCLUDE FILES
+#include <sqldb.h>
+#include <eikenv.h>
+#include <eikappui.h>
+#include "casrv.h"
+#include "casrvdef.h"
+#include "casrvsession.h"
+#include "casrvengutils.h"
+#include "castorageproxy.h"
+#include "casrvmanager.h"
+
+// ==================== LOCAL FUNCTIONS ====================
+
+/**
+ * Stop the Active Scheduler.
+ * @param aPtr Not used.
+ * @return KErrNone.
+ */
+LOCAL_C TInt StopScheduler( TAny* /*aPtr*/)
+ {
+ // Called by the exit timer, after all clients disconnected (plus a small
+ // delay). Stop the scheduler, this will enable he thread exit.
+ CActiveScheduler::Stop();
+ return KErrNone;
+ }
+
+/**
+ * Create a server.
+ * @param Pointer to created server (if created) returned here.
+ * @return Error code.
+ */
+LOCAL_C TInt CreateServer( CCaSrv*& aServer )
+ {
+ // The TRAP is not working in the same stack frame where the
+ // CTrapCleanup was created. This is why we need this function.
+ TRAPD( err, aServer = CCaSrv::NewL() );
+ return err;
+ }
+
+// ==================== GLOBAL FUNCTIONS ====================
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+EXPORT_C TInt RunCaServer()
+ {
+ __UHEAP_MARK;
+ CTrapCleanup* trapCleanup = NULL;
+ CActiveScheduler* activeScheduler = NULL;
+ CCaSrv* server = NULL;
+
+ TInt err = User::RenameThread( KCaSrvName );
+ if( !err )
+ {
+ // Create a trap cleanup, make and install an active scheduler.
+ err = KErrNoMemory;
+ trapCleanup = CTrapCleanup::New();
+ if( trapCleanup )
+ {
+ activeScheduler = new CActiveScheduler();
+ if( activeScheduler )
+ {
+ CActiveScheduler::Install( activeScheduler );
+ err = CreateServer( server ); // Not pushed (no leaving).
+ if( !err )
+ {
+ err = server->Start( KCaSrvName );
+ }
+ }
+ else
+ {
+ err = KErrNoMemory;
+ }
+ }
+ }
+ // Let the caller know how it went.
+ RProcess::Rendezvous( err );
+ if( !err )
+ {
+ CActiveScheduler::Start(); // Start off. Exit timer will stop it.
+ }
+ CActiveScheduler::Install( NULL );
+ delete activeScheduler;
+ delete server;
+ delete trapCleanup;
+ __UHEAP_MARKEND;
+ return err;
+ }
+
+// ==================== MEMBER FUNCTIONS ====================
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+CCaSrv* CCaSrv::NewL()
+ {
+ CCaSrv* srv = new ( ELeave ) CCaSrv();
+ CleanupStack::PushL( srv );
+ srv->ConstructL();
+ CleanupStack::Pop( srv );
+ return srv;
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+CCaSrv::~CCaSrv()
+ {
+ // Cancel requests and delete all sessions first.
+ // Base class would do it for us but that's too late - our sessions
+ // call the server back (SessionClosed, RemoveContainer, etc.).
+ Cancel();
+ CSession2* session;
+ iSessionIter.SetToFirst();
+ while( ( session = iSessionIter++ ) != NULL )
+ {
+ delete session;
+ }
+ delete iSrvManager;
+ delete iSrvEngUtils;
+ delete iStorageProxy;
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+CCaStorageProxy* CCaSrv::GetStorageProxy()
+ {
+ return iStorageProxy;
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+CCaSrv::CCaSrv() :
+ CServer2( EPriorityNormal, CServer2::TServerType( EIpcSession_Sharable ) )
+ {
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+void CCaSrv::ConstructL()
+ {
+ iSessionCount = 0;
+ iStorageProxy = CCaStorageProxy::NewL();
+ iSrvEngUtils = CCaSrvEngUtils::NewL();
+ TRAPD( err, iSrvManager = CCaSrvManager::NewL(
+ *iStorageProxy, iSrvEngUtils ) );
+ if( KSqlErrNotDb <= err && err <= KSqlErrGeneral )
+ {
+ //problem in loading one of plugins, probably data base is corrupted
+ //lets load it from ROM and try again
+ iStorageProxy->LoadDataBaseFromRomL();
+ iSrvManager = CCaSrvManager::NewL( *iStorageProxy, iSrvEngUtils );
+ }
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+CSession2* CCaSrv::NewSessionL( const TVersion& aVersion,
+ const RMessage2& /*aMessage*/) const
+ {
+ TVersion version( KCaMajorVersion, KCaMinorVersion, KCaBuild );
+ if( !User::QueryVersionSupported( version, aVersion ) )
+ {
+ User::Leave( KErrNotSupported );
+ }
+ CSession2* session;
+ session = CCaSrvSession::NewL( const_cast<CCaSrv&> ( *this ) );
+ return session;
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+void CCaSrv::IncreaseSessionCount()
+ {
+ iSessionCount++;
+ }
+
+// ---------------------------------------------------------
+//
+// ---------------------------------------------------------
+//
+void CCaSrv::DecreaseSessionCount()
+ {
+ iSessionCount--;
+ }
+
+// End of File