--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/tsrc/testdriver/testclient/net/src/CTcBaseConnection.h	Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,184 @@
+/*
+* Copyright (c) 2004 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:  See class definition below.
+*
+*/
+
+#ifndef __CTCBASECONNECTION_H__
+#define __CTCBASECONNECTION_H__
+
+// INCLUDES
+#include <e32base.h>
+#include <es_sock.h>
+#include "MTcBearerObserver.h"
+#include <in_sock.h>
+
+// CLASS DEFINITION
+/**
+ * CTcBaseConnection implements a base class for socket connections.
+ * Basically provides core send and receive operations. Send and receive
+ * cannot be used at the same time (this is a design choice; those are
+ * not actually ever needed simultaneously with the TestClient).
+ */
+class CTcBaseConnection
+	: public CActive
+	{
+	protected: // Enumerations
+
+		/// Internal connection state
+		enum TState
+			{
+			/// Not connected
+			EIdle,
+			/// Waiting for incoming connections or connecting to remote address
+			EConnecting,
+			/// Waiting after unsuccesfull connection attempt
+			EWaitingRetry,
+			/// Connected with a remote party
+			EConnected,
+			/// Sending or waiting to send data
+			ESending,
+			/// Receiving or waiting to receive data
+			EReceiving
+			};
+
+	public:	// Constructors and destructor
+
+		/// Destructor
+		~CTcBaseConnection();
+
+	protected:	// Constructors and destructor
+
+		/// Default constructor
+		CTcBaseConnection();
+
+	public: // From CActive
+
+		void RunL();
+		void DoCancel();
+
+	public: // New methods
+
+		/// Initialize port and start waiting for incoming connections
+		void ConnectL();
+		
+		/// Connect to remote address
+		void ConnectL( TInetAddr& aRemoteAddr );
+
+		/// Shut down port and stop waiting for incoming connections
+		void Close();
+
+		/**
+		 * Send a block of data contained in aDes
+		 *
+		 * @param aDes Data to be sent
+		 * @exceptions Panics with KErrNotReady if not connected, and with
+		 *			   KErrInUse if we were already sending or receiving.
+		 */
+		void Send( const TDesC8& aDes );
+
+		/**
+		 * Receive a block of data to aDes. Completes when aDes is full.
+		 *
+		 * @param aDes Buffer for incoming data
+		 * @exceptions Panics with KErrNotReady if not connected, and with
+		 *			   KErrInUse if we were already sending or receiving.
+		 */
+		void Receive( TDes8& aDes );
+
+		/**
+		 * Receive a block of data to aDes. Completes when at least one
+		 * character (byte) has been received. Length of aDes is changed
+		 * to reflect the amount of bytes received.
+		 *
+		 * @param aDes Buffer for incoming data
+		 * @exceptions Panics with KErrNotReady if not connected, and with
+		 *			   KErrInUse if we were already sending or receiving.
+		 */
+		void ReceiveOneOrMore( TDes8& aDes );
+
+		/**
+		 * Set connection event observer. Use NULL to deregister.
+		 *
+		 * @param aObserver Pointer to observer object or NULL.
+		 */
+		void SetObserver( MTcBearerObserver* aObserver );
+		
+		/**
+		 * Set connection.
+		 *
+		 * @param aSocketServ
+		 * @param aConnection
+		 */
+		void SetConnection( RSocketServ* aSocketServ, RConnection* aConnection );
+
+		/// @return Local port number for the connection
+		TInt LocalPort() const;
+
+	protected: // Abstract methods
+
+		/// Called to perform bearer specific port setup. Implemented
+		/// by derived classes.
+		virtual void SetupPortL() = 0;
+		
+		virtual void SetupPort2L();
+
+	protected: // New metods
+
+		/**
+		 * Notifies a registered observer about state transitions.
+		 *
+		 * @param aState Connection state
+		 * @param aStatus System-wide error code or KErrNone
+		 */
+		void Notify( TState aState, TInt aStatus );
+
+	protected: // Data
+
+		/// Connection state.
+		TState iState;
+
+		/// Pointer to connection observer. Not owned.
+		MTcBearerObserver* iObserver;
+
+		/// Socket server session.  Not owned.
+		RSocketServ* iSocketServ;
+
+		/// Data transfer socket. Owned.
+		RSocket iSocket;
+
+		/// Listening socket. Owned.
+		RSocket iListeningSocket;
+
+		/// Socket address (generic). Owned.
+		TSockAddr iSockAddr;
+
+		/// Local port where we're listening
+		TInt iLocalPort;
+
+		/// Transfer length for RecvOneOrMore(), value not used but
+		/// must still be present.
+		TSockXfrLength iIgnoredLength;
+		
+		RConnection* iConnection;
+		
+		// Remote address for connection retry
+		TInetAddr iRemoteAddr;
+		
+		// Timer for waiting for retry
+		RTimer iTimer;
+
+	};
+
+#endif // __CTCBASECONNECTION_H__