--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/centralrepository/cenrepsrv/srvsubsess.h Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,111 @@
+// Copyright (c) 2006-2009 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:
+//
+
+#ifndef SRVSUBSESS_H
+#define SRVSUBSESS_H
+
+#include <e32base.h>
+#include "shrepos.h"
+#include "srvrepos_noc.h"
+#include "clientrequest.h"
+#include "sessnotf.h"
+
+class CServerSession;
+class CSessionManager;
+
+class CServerSubSession : public CObject
+ {
+friend class CServerSession;
+public:
+ CServerSubSession(CServerSession* aSession);
+ ~CServerSubSession();
+ void ServiceError(TInt aError);
+ TInt ServiceL(const RMessage2& aMessage);
+public:
+ enum { KDontCompleteMessage = 1 };
+
+private:
+ typedef TInt (CServerSubSession::*TServerFunc)(const TClientRequest&);
+
+ TInt GeneralOperationsL(const TClientRequest& aMessage, TServerFunc aFunc);
+ TInt ReadOperationsL(const TClientRequest& aMessage, TServerFunc aFunc);
+ TInt WriteOperationsL(const TClientRequest& aMessage, TServerFunc aFunc);
+ TInt ResetOperationsL(const TClientRequest& aMessage, TServerFunc aFunc);
+
+ TInt InitialiseL(const TClientRequest& aMessage);
+ TInt CreateIntL(const TClientRequest& aMessage);
+ TInt CreateRealL(const TClientRequest& aMessage);
+ TInt CreateStringL(const TClientRequest& aMessage);
+ TInt DeleteL(const TClientRequest& aMessage);
+ TInt DeleteRangeL(const TClientRequest& aMessage);
+ TInt GetIntL(const TClientRequest& aMessage);
+ TInt SetIntL(const TClientRequest& aMessage);
+ TInt GetRealL(const TClientRequest& aMessage);
+ TInt SetRealL(const TClientRequest& aMessage);
+ TInt GetStringL(const TClientRequest& aMessage);
+ TInt SetStringL(const TClientRequest& aMessage);
+ TInt FindL(const TClientRequest& aMessage);
+ TInt FindEqIntL(const TClientRequest& aMessage);
+ TInt FindEqRealL(const TClientRequest& aMessage);
+ TInt FindEqStringL(const TClientRequest& aMessage);
+ TInt FindNeqIntL(const TClientRequest& aMessage);
+ TInt FindNeqRealL(const TClientRequest& aMessage);
+ TInt FindNeqStringL(const TClientRequest& aMessage);
+ TInt GetFindResultL(const TClientRequest& aMessage);
+ TInt NotifyRequestCheck(const TClientRequest& aMessage);
+ TInt NotifyRequest(const TClientRequest& aMessage);
+ TInt NotifyCancel(const TClientRequest& aMessage);
+ TInt NotifyCancelAll(const TClientRequest& aMessage);
+ TInt GroupNotifyRequest(const TClientRequest& aMessage);
+ TInt GroupNotifyCancel(const TClientRequest& aMessage);
+ TInt ResetL(const TClientRequest& aMessage);
+ TInt ResetAllL(const TClientRequest& aMessage);
+ TInt TransactionStart(const TClientRequest& aMessage);
+ TInt TransactionCancel(const TClientRequest& aMessage);
+ TInt TransactionCommitL(const TClientRequest& aMessage);
+ TInt MoveL(const TClientRequest& aMessage) ;
+ TInt TransactionStateL(const TClientRequest& aMessage);
+ TInt TransactionFail(const TClientRequest& aMessage);
+ TInt GetMeta(const TClientRequest& aMessage);
+
+ template <class T> TInt FindValueL(const TClientRequest& aMessage, const T& aVal, TComparison aComparison=EEqual);
+ inline CSessionManager* Server();
+ TInt CheckPolicy(const TClientRequest& msg,const TSecurityPolicy& aPolicy,
+ const char *aDiagnostic);
+
+private:
+ CServerSession* iSession;
+ CServerRepository iRepository;
+ CSessionNotifier iNotifier;
+ RArray<TUint32> iFindResult;
+ TBool iInitialised;
+#if defined (__CENTREP_SERVER_PERFTEST__) || defined(SRVSUBSESS_TRACE) || defined(CENTREP_TRACE)
+
+ TUid iRepositoryUid;
+ #endif
+
+
+#if defined (__CENTREP_SERVER_PERFTEST__) || defined(SRVSUBSESS_TRACE) || defined(CENTREP_TRACE)
+// For testing purposes only
+public:
+ inline TUid RepositoryUid()
+ {
+ return iRepositoryUid;
+ }
+#endif
+ };
+
+
+#endif // SRVSUBSESS_H