diff -r 675a964f4eb5 -r 35751d3474b7 contentmgmt/referencedrmagent/RefTestAgent/streamingrefagent/inc/sraserver.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentmgmt/referencedrmagent/RefTestAgent/streamingrefagent/inc/sraserver.h	Thu Sep 10 14:01:51 2009 +0300
@@ -0,0 +1,164 @@
+/*
+* Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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: 
+* Server-side classes which are required to implement a streaming reference agent server.
+*
+*/
+
+
+/**
+ @file
+ @internalComponent
+ @released
+*/
+
+#ifndef SRASERVER_H
+#define SRASERVER_H
+
+
+#include <e32base.h>
+#include "sracommon.h"
+
+using namespace StreamAccess;
+
+// forward declarations
+class CSraServer;
+class CSraSession;
+class CSraRightsObject;
+class CSraProcessor;
+
+class CShutdownTimer : public CTimer
+/**
+	An instance of this class is constructed with a delay period.
+	If the object runs to completion, i.e. if it is not cancelled, then it stops
+	the active scheduler, which has the effect of terminating the server.
+ */
+	{
+public:
+	static CShutdownTimer* NewL(TInt aDelay);
+	void Restart();
+
+private:
+	CShutdownTimer(TInt aDelay);
+
+	// implement CTimer
+	virtual void RunL();
+
+private:
+	TInt iDelay;			///< Timer delay in microseconds.
+	};
+
+
+class CSraSession : public CSession2
+/**
+ 	Represents a session for a client thread on the server-side of the reference agent.
+ 	A client thread can have multiple concurrent sessions with the reference agent server.
+ */
+	{
+	friend class CSraProcessor;
+public:
+	static CSraSession* NewL();
+	~CSraSession();
+	void CreateL();
+	
+	// implement CSession2
+	virtual void ServiceL(const RMessage2& aMessage);
+	// override CSession2
+	virtual void ServiceError(const RMessage2& aMessage, TInt aError);
+	
+private:
+	CSraSession();
+	CSraServer* GetServerHandle();
+	
+	void GetAttributeL(const RMessage2& aMessage);
+	void GetStringAttributeSizeL(const RMessage2& aMessage);
+	void GetStringAttributeDataL(const RMessage2& aMessage);
+	void GetPostDeliveryRightsL(const RMessage2& aMessage);
+	void SetKeyStreamSinkL(const RMessage2& aMessage);
+	void SetSdpMediaFieldL(const RMessage2& aMessage);
+	void SetSdpDocumentL(const RMessage2& aMessage);
+	
+	void FindAndLoadRightsObjectL(const TDesC8& aCid);
+	void VerifyRoL();
+	void StartProcessorL();
+	
+private:
+	CSraProcessor* iProcessor;
+	CKeyStreamSink* iKeyStreamSink;
+	CSdpMediaField* iSdp;
+	CSraRightsObject* iRo;
+	CSdpDocument* iSdpDoc;
+	/**
+	 A handle to a mutex which is used to signal the client that the key has been implemented. 
+	 Not necessary in real-life agents and is present here only for testing.
+	 */
+	RMutex iMutex;
+	};
+	
+	
+class CSraServer : public CPolicyServer
+/**
+	The reference agent server object allocates sessions.	
+	It also uses a shutdown timer to stop the server when 
+	there have been no open sessions for a set period.
+ */
+	{
+	friend class CSraSession;
+public:
+	static CSraServer* NewLC();
+	~CSraServer();
+	
+private:
+	CSraServer();
+	void ConstructL();
+	void AddSession();
+	void RemoveSession();
+	// implement CServer2
+	virtual CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const;
+
+private:
+	CShutdownTimer* iShutdownTimer;
+	const TVersion iVersion;
+	/** Number of open sessions.  Used to start and cancel the shutdown timer. */
+	TInt iSessionCount;
+	/** File server handle. */
+	RFs iFs;
+	};
+
+
+/**
+	The server is panicked with this category when it detects an invalid state.
+ */
+_LIT(KSraServerPanicCat, "SRA-Server");
+
+/** The mime type of the post-acquisition rights object file. */
+_LIT8(KPostAcquisitionRoMimeType,"application/x-sra.drm.postacqrights");
+
+/** The mime type of the post-acquisition rights object file. */
+_LIT8(KPostAcquisitionContentMimeType,"application/x-sra.drm.postacqcontent");
+
+/** The content Id of the post-acquisition rights object file. */
+_LIT8(KPostAcquisitionCid,"SamplePostAcquisitionCid");
+
+/** The private folder of the Streaming Reference Agent. */
+_LIT(KSraPrivateFolder,"!:\\private\\10285a1c\\");
+
+/** 
+ 	Mutex name used to synchronize the reference agent with the test harness.
+ 	@see CSraSession::iMutex
+ */
+_LIT(KSraMutexName, "MutexBtwTestHarnessAndRefAgent");
+
+#endif
+