diff -r 1a2a00e78665 -r f62f87b200ec contentstorage/srvsrc/casrv.cpp
--- /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