--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/realtimenetprots/sipfw/SampleApp/socketengine/Inc/SIPExSocketEngine.h Tue Feb 02 01:03:15 2010 +0200
@@ -0,0 +1,220 @@
+
+/*
+* Copyright (c) 2004-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 __CSIPEXSOCKETENGINE_H__
+#define __CSIPEXSOCKETENGINE_H__
+
+// INCLUDES
+#include "SIPExTimeOutTimer.h"
+#include "SIPExSocketEngineObserver.h"
+#include "SIPEXReaderNotifier.h"
+#include "SIPExWriterNotifier.h"
+#include "SIPExTimeOutNotify.h"
+#include <in_sock.h> // SInetAddr
+
+
+// FORWARD DECLARATIONS
+class MSIPExSocketEngineObserver;
+class CSIPExSocketReader;
+class CSIPExSocketWriter;
+class CSIPExTimeOutTimer;
+
+// CLASS DECLARATIONS
+/**
+* Implements socket connections.
+*/
+class CSIPExSocketEngine
+: public CActive,
+ public MSIPExTimeOutNotify,
+ public MSIPExReaderNotifier,
+ public MSIPExWriterNotifier
+ {
+ public:
+
+ /**
+ * Static constructor
+ * @param aObserver A reference to the socket engine observer.
+ */
+ IMPORT_C static CSIPExSocketEngine* NewL( MSIPExSocketEngineObserver& aObserver );
+
+ /**
+ * Static constructor. On return the instance is left to the CleanupStack
+ * @param aObserver A reference to the socket engine observer.
+ */
+ IMPORT_C static CSIPExSocketEngine* NewLC( MSIPExSocketEngineObserver& aObserver );
+
+ /**
+ * Destructor
+ */
+ IMPORT_C ~CSIPExSocketEngine();
+
+ public: // From base classes
+
+ /**
+ * Connecting the socket to the aIPAddress.
+ * @param aIapId An iap id used for connection
+ * @param aIPAddress An ip address where to connect.
+ */
+ IMPORT_C void ConnectL( const TUint32 aIapId, const TInetAddr& aIPAddress );
+
+ /**
+ * Writes to the socket.
+ * @param aTxt A text to write to the socket.
+ */
+ IMPORT_C void Write( const TDesC8& aTxt );
+
+ /**
+ * Reads from the socket.
+ */
+ IMPORT_C void Read();
+
+ /**
+ * Closing the socket.
+ */
+ IMPORT_C void Stop();
+
+ /**
+ * Starts listening local game port
+ * @param aIapId The IAP id of the active accesspoint.
+ * @return A local address
+ */
+ IMPORT_C TInetAddr& StartListeningL( const TUint32 aIapId );
+
+ public:
+
+ /**
+ * Socket engine state enumerations.
+ */
+ enum TSocketEngineState
+ {
+ ENotConnected,
+ EConnecting,
+ EConnected,
+ EListening,
+ ETimedOut
+ };
+
+ protected: // From base classes
+
+ // From MSIPExTimeOutNotify
+ /**
+ * From MSIPExTimeOutNotify
+ * Destructor
+ */
+ void TimerExpired();
+
+ // From MSIPExReaderNotifier
+
+ /**
+ * From MSIPExReaderNotifier
+ */
+ void MessageReceived( TDesC8& aBuffer );
+
+ /**
+ * From MSIPExReaderNotifier
+ */
+ void ErrorInReading( TInt aError );
+
+ // From MSIPExWriterNotifier
+
+ /**
+ * From MSIPExWriterNotifier
+ */
+ void WriteDone();
+
+ /**
+ * From MSIPExWriterNotifier
+ */
+ void ErrorInWriting( TInt aError );
+
+ protected: // From base classes
+
+ /**
+ * From CActive
+ * Cancels any outstanding request.
+ */
+ void DoCancel();
+
+ /**
+ * From CActive
+ * Handles the completion of the active request.
+ */
+ void RunL();
+
+ private: // New functions
+
+ /**
+ * Changes the new state to iState and notifies observer.
+ * @param aNewState A new state of socket engine
+ */
+ void ChangeStateAndNotify( TSocketEngineState aNewState );
+
+ /**
+ * Activates PDP ctx of passed iap
+ * @param aIapId The IAP id of the activated accesspoint.
+ */
+ void StartInterfaceL( const TUint32 aIapId );
+
+ /**
+ * Gets the local IP address with host resolver.
+ * The address is set to the iAddress variable.
+ */
+ void ResolveLocalIPAddressL();
+
+ private:
+
+ /**
+ * Destructor
+ */
+ CSIPExSocketEngine( MSIPExSocketEngineObserver& aObserver );
+
+ /**
+ * Destructor
+ */
+ void ConstructL();
+
+ private:
+ // Member variables
+
+ // The reference to the socket engine observer
+ MSIPExSocketEngineObserver& iObserver;
+
+ // Sockets
+ RSocketServ iSocketServer;
+ RConnection iConnection;
+ RSocket iDataSocket;
+ RSocket iListenSocket;
+
+
+ //
+ CSIPExSocketReader* iReader;
+ CSIPExSocketWriter* iWriter;
+ CSIPExTimeOutTimer* iTimer;
+
+ // Socket engine's state
+ TSocketEngineState iState;
+
+ // The remote address
+ TInetAddr iAddress;
+ };
+
+#endif // __CSIPEXSOCKETENGINE_H__
+
+// End of file