--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Server/AppProtIntf/inc/app_protintf_base.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,135 @@
+// 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:
+//
+
+#ifndef __APP_PROTINF_BASE_H__
+#define __APP_PROTINF_BASE_H__
+
+#include <comms-infras/ss_subconnflow.h>
+#include <rsockethandler.h>
+#include <csocketopener.h>
+#include <appprotintf/genericcontainer.h>
+
+_LIT ( KAppProtIntfInvalidRealmId, " RealmId is invalid " );
+
+enum TAppProtIntfPanic
+	{
+	KInvalidReamId
+	};
+	
+// Forward declarations
+class CApplicationProtocolIntfFactory;
+
+class CApplicationProtocolIntfBase : public CFactoryObject,
+									public MSocketHandlerObserver
+	{
+public:
+
+	inline TUint Port () const;
+	virtual TUint Protocol () const =0;
+	virtual ~CApplicationProtocolIntfBase ();
+
+protected:
+
+	enum
+		{
+		ERecvFrom = 1
+		};
+
+	typedef Messages::TMessageSigVoid < ERecvFrom, ESock::TCFMessage::ERealmId > TRecvFrom;
+
+	CApplicationProtocolIntfBase ( TUint aPort, TInt aProtocolType );
+
+	void JoinCompleted ();
+	void PostToLink ( const Messages::TNodeCtxId& aRecipient, const Messages::TSignatureBase& aMessage );
+	void PostToLink ( const Messages::RNodeInterface& aRecipient, const Messages::TSignatureBase& aMessage );
+	void PostToAllLinks ( const Messages::TSignatureBase& aMessage );
+
+	void InitiateLinkL ( const Messages::TNodeCtxId& aSender, TUint aSockType, TUint aProtocol );
+	void HandleClientLeavingRequest ( const Messages::TNodeCtxId&  aSender );
+	void CloseLink ( const Messages::TNodeId& aSender );
+
+	TInt OpenSocket ( TUint aAddrFamily, TUint aSockType, TUint aProtocol );
+
+	virtual TInt Startup () =0;
+	virtual void Shutdown ();
+
+	// From ANodeIdBase
+	virtual void ReceivedL ( const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage );
+	
+	// From MSocketHandlerObserver
+	virtual void OpenComplete ( RInternalSocket& aSocket );
+	inline virtual void ConnectComplete ();
+	inline virtual void AcceptComplete ( RInternalSocket& aSocket );
+	inline virtual void SendComplete ( TInt aLength );
+	inline virtual void SendToComplete ( TInt aLength );
+	inline virtual void RecvComplete ( RMBufChain& aData );
+	inline virtual void RecvFromComplete ( RMBufChain& aData, const TSockAddr& aAddr );
+//	virtual void IoctlComplete ();
+	virtual void Error ( TOperation aOperation, TInt aError  );
+
+protected:
+	TInt AddLink ( const Messages::TNodeId& aSender );
+	TInt RemoveLink ( const Messages::TNodeId& aSender );
+	TInt FindLink ( const Messages::TNodeId& aSender );
+
+protected:
+	RArray<Messages::RNodeInterface>	iLinks;
+	RSocketHandler		iSocketHandler;
+	RInternalSocket 	iSocket;
+private:
+	TUint 				iPort;
+	CSocketOpener*		iSocketOpener;
+	};
+
+
+TUint CApplicationProtocolIntfBase::Port () const
+	{
+	return iPort;
+	}
+
+void CApplicationProtocolIntfBase::ConnectComplete ()
+	{
+
+	}
+
+void CApplicationProtocolIntfBase::AcceptComplete ( RInternalSocket& /* aSocket */ )
+	{
+	}
+
+/*void CApplicationProtocolIntfBase::IoctlComplete ()
+	{
+	}
+*/
+void CApplicationProtocolIntfBase::RecvComplete ( RMBufChain& /* aData */ )
+	{
+
+	}
+
+void CApplicationProtocolIntfBase::RecvFromComplete ( RMBufChain& /* aData */, const TSockAddr& /* aAddr */ )
+	{
+
+	}
+
+void CApplicationProtocolIntfBase::SendComplete ( TInt /* aLength */ )
+	{
+
+	}
+
+void CApplicationProtocolIntfBase::SendToComplete ( TInt /* aLength */ )
+	{
+
+	}
+
+#endif // __APP_PROTINF_BASE_H__