diff -r 22de2e391156 -r 20ac952a623c remotecontrol/remotecontrolfw/server/inc/bulkserver.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/remotecontrol/remotecontrolfw/server/inc/bulkserver.h	Wed Oct 13 16:20:29 2010 +0300
@@ -0,0 +1,173 @@
+// Copyright (c) 2008-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:
+//
+
+
+
+/**
+ @file
+ @internalComponent
+*/
+
+#ifndef BULKSERVER_H
+#define BULKSERVER_H
+
+#include <e32base.h>
+#include <e32msgqueue.h>
+#include "bulkservermsgqueue.h"
+
+class CBulkBearerInterface;
+class CMessageQueue;
+class CRemConBulkSession;
+class CRemConMessage;
+class TRemConAddress;
+
+class CRemConServer;
+
+
+/**
+The bulk server class for Rem Con.
+*/
+NONSHARABLE_CLASS(CRemConBulkServer) : public CPolicyServer
+	{
+public:
+	/**
+	RemCon bulk server construction.
+	@return Ownership of a new RemCon bulk server object
+	*/
+	static CRemConBulkServer* NewLC(RMsgQueue<TBulkServerMsg>& aMsgQueue);
+
+	/** Destructor. */
+	~CRemConBulkServer();
+
+public: // called by session objects 
+	/** Called by a session when a client session is created. Cancels the 
+	shutdown timer in accordance with transient server design. */
+	TInt ClientOpened(CRemConBulkSession& aSession, TProcessId aProcessId);
+
+	/** Called by a session when a client session is destroyed. Starts the 
+	shutdown timer if necessary in accordance with transient server design. 
+	Does not assume that the session successfully registered itself with the 
+	server to begin with.
+	*/
+	void ClientClosed(CRemConBulkSession& aSession);
+	
+	/** Called by a session when a client session has issued a receive.
+	*/
+	void ReceiveRequest(CRemConBulkSession& aSession);
+	
+	/**
+	Starts the process of sending a response.
+	Always takes ownership of aMsg.
+	@return error
+	*/
+	TInt SendResponse(CRemConMessage& aMsg, CRemConBulkSession& aSess);
+	
+	/**
+	Sends a reject back to the bearer.
+	*/
+	void SendReject(TRemConAddress aAddr, TUid aInterfaceUid, TUint aOperationId, TUint aTransactionId);
+	
+	inline CBulkBearerInterface& BulkBearerInterface();
+
+public: // called by the bearer manager 
+	inline RPointerArray<CRemConBulkSession>& Sessions();
+	
+	/** 
+	Handles a new incoming command.
+	Always takes ownership of aMsg.
+	*/
+	void NewCommand(CRemConMessage& aMsg);
+	
+	void CommandExpired(TUint aTransactionId);
+
+private:
+	/** Constructor. */
+	CRemConBulkServer(RMsgQueue<TBulkServerMsg>& aMsgQueue);
+
+	/** 2nd-phase construction. */
+	void ConstructL();
+	
+private: // from CPolicyServer
+	/**
+	Called by the base class to create a new session.
+	@param aVersion Version of client
+	@param aMessage Client's IPC message
+	@return A new session to be used for the client. If this could not be made, 
+	this function should leave.
+	*/
+	CSession2* NewSessionL(const TVersion &aVersion, const RMessage2& aMessage) const;
+
+private: // utility	
+	CRemConBulkSession* Session(TUint aSessionId) const;
+	
+	void StartShutdownTimerIfNoSessions();
+	
+#ifdef __FLOG_ACTIVE
+	void LogSessions() const;
+	void LogIncomingPendingDelivery() const;
+	void LogIncomingDelivered() const;
+#endif // __FLOG_ACTIVE
+	
+	CMessageQueue& IncomingPendingDelivery();
+	CMessageQueue& IncomingDelivered();
+	
+	void DeliverCmdToClient(const CRemConMessage& aMsg, CRemConBulkSession& aSess);
+	void DeliverMessageToClient(CRemConMessage& aMsg, CRemConBulkSession& aSess);
+		
+private: // called by the shutdown timer
+	/** 
+	Called by the shutdown timer when it fires. Terminates the server thread. 
+	@param aThis This. 
+	@return KErrNone.
+	*/
+	static TInt TimerFired(TAny* aThis);
+
+	
+private: // owned
+
+	// NB This isn't really being used as a CPeriodic, but (a) it will do the 
+	// job, and (b) it saves us writing our own concrete timer (there aren't 
+	// any other more suitable concrete timer classes).
+	CPeriodic* iShutdownTimer;
+
+	// Shutdown delay (when there are no sessions) = 1 second- there's no 
+	// point hanging around.
+	static const TUint KShutdownDelay = 1 * 1000 * 1000;
+
+	RPointerArray<CRemConBulkSession> iSessions;
+	
+	CMessageQueue* iIncomingPendingDelivery;
+	CMessageQueue* iIncomingDelivered;
+	
+	CBulkBearerInterface* iBulkBearerInterface;
+	
+	RMsgQueue<TBulkServerMsg> iRemConMsgQueue;
+	
+	CRemConServer* iControlServer; //unowned.
+	};
+
+// Inlines
+
+RPointerArray<CRemConBulkSession>& CRemConBulkServer::Sessions()
+	{
+	return iSessions;
+	}
+
+CBulkBearerInterface& CRemConBulkServer::BulkBearerInterface()
+	{
+	return *iBulkBearerInterface;
+	}
+
+#endif // BULKSERVER_H