diff -r 000000000000 -r 79c6a41cd166 contentcontrolsrv/ccsrv/src/ccsrv.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentcontrolsrv/ccsrv/src/ccsrv.cpp	Thu Dec 17 08:54:17 2009 +0200
@@ -0,0 +1,321 @@
+/*
+ * 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:  
+ *
+ */
+
+// System include files
+
+// User include files
+#include "ccsrv.h"
+#include "ccsrvsession.h"
+#include "ccresource.h"
+#include "ccsrvapi.h"
+
+
+// Local constants
+
+// Home screen content control server name
+_LIT( KCcSrvName,"ccserver" );
+
+// Home screen content control server policy
+//Total number of ranges
+const TUint KCcRangeCount = 2;
+
+//Definition of the ranges of IPC numbers
+const TInt KCcRanges[KCcRangeCount] = 
+        {
+        ECcIPCFunctionBase,
+        ECcNotSupported 
+        }; 
+
+// Policy actions for each of the above ranges
+const TUint8 KCcPolicyAction[KCcRangeCount] = 
+        {
+        0,
+        CPolicyServer::ENotSupported
+        };
+
+// Requested capabilities
+const CPolicyServer::TPolicyElement KCcCapability[] = 
+        {
+        {_INIT_SECURITY_POLICY_C2( ECapabilityReadUserData, ECapabilityWriteUserData ), CPolicyServer::EFailClient}
+        };
+
+const CPolicyServer::TPolicy KCcPolicy =
+        {
+        0,
+        KCcRangeCount,                                 
+        KCcRanges,
+        KCcPolicyAction,
+        KCcCapability
+        };
+
+// -----------------------------------------------------------------------------
+// RunServerL()
+// -----------------------------------------------------------------------------
+//
+static void RunServerL()
+    {
+    User::LeaveIfError(User::RenameThread(KCcSrvName));
+    CActiveScheduler* s=new(ELeave) CActiveScheduler;
+    CleanupStack::PushL(s);
+    CActiveScheduler::Install(s);
+    CCcSrv::NewLC();
+    RProcess::Rendezvous(KErrNone);
+    CActiveScheduler::Start();
+    CleanupStack::PopAndDestroy( 2, s );
+    }
+
+// -----------------------------------------------------------------------------
+// E32Main
+// Server process entry-point
+// -----------------------------------------------------------------------------
+//
+TInt E32Main()
+    {
+    __UHEAP_MARK;
+    CTrapCleanup* cleanup=CTrapCleanup::New();
+    TInt r=KErrNoMemory;
+    if (cleanup)
+        {
+        TRAP(r,RunServerL());
+        delete cleanup;
+        }
+    __UHEAP_MARKEND;
+    return r;
+    }
+
+// ======== MEMBER FUNCTIONS ========
+
+// -----------------------------------------------------------------------------
+// CCcSrv::NewLC
+// -----------------------------------------------------------------------------
+//
+CServer2* CCcSrv::NewLC()
+    {
+    CCcSrv* self=new ( ELeave ) CCcSrv;
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    return self;
+    }
+
+// -----------------------------------------------------------------------
+// CCcSrv::ConstructL()
+// -----------------------------------------------------------------------
+//
+void CCcSrv::ConstructL()
+    {
+    StartL( KCcSrvName );
+    }
+
+// -----------------------------------------------------------------------
+// CCcSrv::CCcSrv()
+// -----------------------------------------------------------------------
+//
+CCcSrv::CCcSrv()
+    :CPolicyServer( 0,KCcPolicy,ESharableSessions )
+    ,iLastSessionId( 0 )
+    {
+    }
+
+// -----------------------------------------------------------------------
+// CCcSrv::~CCcSrv()
+// -----------------------------------------------------------------------
+//
+CCcSrv::~CCcSrv()
+    {
+    iSessions.Close();
+    iProviders.Close();
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::NewSessionL
+// -----------------------------------------------------------------------------
+//
+CSession2* CCcSrv::NewSessionL(
+    const TVersion&,
+    const RMessage2& /* aMessage */ ) const
+    {
+    return new ( ELeave ) CCcSrvSession();
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::AddSessionL
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::AddSessionL( CCcSrvSession* aSession )
+    {
+    // Find next available session id
+    while( ETrue )
+        {
+        iLastSessionId = iLastSessionId + 1;
+        TBool found( EFalse );
+        for ( TUint32 i = 0; i < iSessions.Count() && !found; i++ )
+            {
+            if ( iSessions[ i ]->Id() == iLastSessionId )
+                {
+                found = ETrue;
+                }
+            }
+        if ( !found )
+            {
+            break;
+            }
+        }
+    
+    aSession->SetId( iLastSessionId );
+    iSessions.AppendL( aSession );
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::DropSession
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::DropSession( CCcSrvSession* aSession )
+    {
+    for ( TUint32 i = 0; i < iSessions.Count(); i++ )
+        {
+        if ( iSessions[ i ]->Id() == aSession->Id() )
+            {
+            iSessions.Remove( i );
+            break;
+            }
+        }
+    // Unregister possible observations
+    for ( TUint32 i = 0; i < iProviders.Count(); i++ )
+        {
+        TRAP_IGNORE( iProviders[ i ].iSession->
+            UnregisterObserverSessionL( aSession->Id() ) );
+        }
+    
+    // Remove possible provider
+    for ( TUint32 i = 0; i < iProviders.Count(); i++ )
+        {
+        if ( iProviders[ i ].iId == aSession->Id() )
+            {
+            iProviders.Remove( i );
+            break;
+            }
+        }
+    if ( iSessions.Count() == 0 )
+        {
+        // Last session dropped -> stop server
+        CActiveScheduler::Stop();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::RegisterProviderSessionL
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::RegisterProviderL( 
+    TUint32 aProvider,
+    CCcSrvSession* aSession )
+    {
+    for ( TUint32 i = 0; i < iProviders.Count(); i++ )
+        {
+        if ( iProviders[ i ].iId == aProvider )
+            {
+            User::Leave( KErrAlreadyExists );
+            }
+        }
+    CCcSrv::TCcProvider provider;
+    provider.iId = aProvider;
+    provider.iSession = aSession;
+    iProviders.Append( provider );
+    
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::RegisterObserverL
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::RegisterObserverL( 
+    TUint32 aProvider,
+    CCcSrvSession* aSession )
+    {
+    TBool found( EFalse );
+    for ( TUint32 i = 0; i < iProviders.Count() && !found; i++ )
+        {
+        if ( iProviders[ i ].iId == aProvider )
+            {
+            iProviders[ i ].iSession->RegisterObserverSessionL( aSession->Id() );   
+            found = ETrue;
+            }
+        }
+    if ( !found )
+        {
+        User::Leave( KErrNotFound );
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::ResolveProviderAddressL
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::ResolveProviderAddressL( 
+    TUint32 aProvider,
+    TUint32& aAddress )
+    {
+    TBool found( EFalse );
+    for ( TUint32 i = 0; i < iProviders.Count() && !found; i++ )
+        {
+        if ( iProviders[ i ].iId == aProvider )
+            {
+            aAddress = iProviders[ i ].iSession->Id();
+            found = ETrue;
+            }
+        }
+    if ( !found )
+        {
+        User::Leave( KErrNotFound );
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::GetTrId
+// -----------------------------------------------------------------------------
+//
+TUint32 CCcSrv::GetTrId()
+    {
+    iLastTrId++;
+    return iLastTrId;
+    }
+
+// -----------------------------------------------------------------------------
+// CCcSrv::SendMsgL
+// -----------------------------------------------------------------------------
+//
+void CCcSrv::SendMsgL( 
+    TUint32 aSender,
+    TUint32 aReceiver,
+    CCcSrvMsg& aMessage )
+    {
+    TBool found( EFalse );
+    for ( TUint32 i = 0; i < iSessions.Count() && !found; i++ )
+        {
+        if ( iSessions[ i ]->Id() == aReceiver )
+            {
+            iSessions[ i ]->ReceiveMsgL( aSender, aReceiver, aMessage );
+            found = ETrue;
+            }
+        }
+    if ( !found )
+        {
+        User::Leave( KErrNotFound );
+        }
+    }
+
+// End of file