diff -r 000000000000 -r f5a58ecadc66 servicediscoveryandcontrol/pnp/test/upnp/Client/pnp/inc/ccontrolchannel.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Client/pnp/inc/ccontrolchannel.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,96 @@
+// 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 __CCONTROLCHANNEL_H_
+#define __CCONTROLCHANNEL_H_
+
+#include <e32base.h>
+#include <es_sock.h>
+#include "rcontrolchannel.h"
+
+class CControlChannelHandler : public CActive
+	{	
+	protected:
+		CControlChannelHandler ( RSocket& aSocket, TBool aChannelType );		
+		TInt RunError(TInt aError);
+	protected:
+		RSocket& 			iSocket;  // Not owned
+		TBool				iChannelType; // EFalse for Client usage
+										  // ETrue for server usage	
+		TControlMessage* 	iMessage; // Not owned.
+		TRequestStatus*		iChannelStatus;  // Not owned	
+		TInt 				iDataLength;	// Actual buffer size. this is used for internal purpose to find the
+										// end of the message. This variable will get incremented whenever we
+										// receive/send data from/to the socket and will be reset to 0 once the end of
+										// message is reached.		
+	};
+
+class CControlChannelReader : public CControlChannelHandler 
+	{
+	public:
+		static CControlChannelReader* NewL ( RSocket& aSocket, TBool aChannelType );
+		~CControlChannelReader ();
+		
+		void Read ( TControlMessage& aMessage, TRequestStatus& aStatus );		
+	private:
+		CControlChannelReader ( RSocket& aSocket, TBool aChannelType );		
+		
+		// From CActive
+		void RunL ();
+		void DoCancel ();
+			
+	private:
+		TSockXfrLength  iBytesReceived; // Socket recv buffer size.
+ 	};
+
+// ---------------------------------------------------------------
+
+class CControlChannelWriter : public CControlChannelHandler
+	{
+	public:
+		static CControlChannelWriter* NewL ( RSocket& aSocket, TBool aChannelType );
+		~CControlChannelWriter ();
+		
+		void Write ( TControlMessage& aMessage, TRequestStatus& aStatus );
+	private:
+	  	CControlChannelWriter ( RSocket& aSocket, TBool aChannelType );
+	  		  	
+	  	// From CActive
+		void RunL ();
+		void DoCancel ();
+
+	private:
+		RBuf8	iBuf; 		  
+	};
+
+// ---------------------------------------------------------------
+
+class CControlChannel : public CBase
+{
+public:
+	static CControlChannel* NewL ( RSocketServ& aSocketServ, RSubConnection& aSubConnection, TUint aAddrFamily, TBool aChannelType, TUint aProtocol, const TConnectionDetails& aConnInfo );
+	virtual ~CControlChannel ();
+	
+	void Recv ( TControlMessage& aMessage, TRequestStatus& aStatus );
+	void Send ( TControlMessage& aMessage, TRequestStatus& aStatus );
+private:
+	CControlChannel ( );
+	void ConstructL ( RSocketServ& aSocketServ, RSubConnection& aSubConnection, TUint aAddrFamily, TBool aChannelType, TUint aProtocol, const TConnectionDetails& aConnInfo );
+private:
+	RSocket 				iSocket;
+	CControlChannelReader* 	iReader;
+	CControlChannelWriter* 	iWriter;	
+};
+#endif
\ No newline at end of file