hti/HtiServicePlugins/HtiIpProxyServicePlugin/IPProxyEngine/Src/Clocaltcpconnection.cpp
branchRCL_3
changeset 19 07b41fa8d1dd
parent 18 3406c99bc375
child 20 ca8a1b6995f6
--- a/hti/HtiServicePlugins/HtiIpProxyServicePlugin/IPProxyEngine/Src/Clocaltcpconnection.cpp	Thu Jul 15 20:25:38 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,219 +0,0 @@
-/*
-* Copyright (c) 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:  Local TCP connection for emulator testing
-*
-*/
-
-
-
-// INCLUDE FILES
-#include "CLocalTCPConnection.h"
-#include "MLocalTCPConnectionObserver.h"
-
-#define DEBUG_FILENAME "IPProxyEngine.log"
-#include "DebugPrint.h"
-
-// ============================ MEMBER FUNCTIONS ===============================
-
-// -----------------------------------------------------------------------------
-// CLocalTCPConnection::CLocalTCPConnection
-// -----------------------------------------------------------------------------
-//
-CLocalTCPConnection::CLocalTCPConnection(
-    MLocalTCPConnectionObserver* aObserver, TInt aPort ) :
-    CActive( EPriorityStandard )
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::CLocalTCPConnection() aPort=%d" ), aPort );
-
-    iOwnsSocket = ETrue;
-    iObserver = aObserver;
-    iAddr.SetPort( aPort );
-    iAddr.SetAddress( KInetAddrLoop );
-    }
-
-// -----------------------------------------------------------------------------
-// CLocalTCPConnection::ConstructL
-// Symbian 2nd phase constructor can leave.
-// -----------------------------------------------------------------------------
-//
-void CLocalTCPConnection::ConstructL()
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::ConstructL, opening socket..." ) );
-
-    iSocket = new (ELeave) RSocket;
-    User::LeaveIfError( iSocketServer.Connect() );
-    User::LeaveIfError( iSocket->Open(
-        iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::ConstructL, socket opened." ) );
-    CActiveScheduler::Add( this );
-    }
-
-// -----------------------------------------------------------------------------
-// CLocalTCPConnection::NewL
-// Two-phased constructor.
-// -----------------------------------------------------------------------------
-//
-CLocalTCPConnection* CLocalTCPConnection::NewL(
-    MLocalTCPConnectionObserver* aObserver,
-    TInt aPort  )
-    {
-    CLocalTCPConnection* self =
-        CLocalTCPConnection::NewLC( aObserver, aPort );
-    CleanupStack::Pop();
-
-    return self;
-    }
-
-CLocalTCPConnection* CLocalTCPConnection::NewLC(
-    MLocalTCPConnectionObserver* aObserver,
-    TInt aPort  )
-    {
-    CLocalTCPConnection* self =
-        new( ELeave ) CLocalTCPConnection( aObserver, aPort );
-    CleanupStack::PushL( self );
-
-    self->ConstructL();
-    return self;
-    }
-
-// Destructor
-CLocalTCPConnection::~CLocalTCPConnection()
-    {
-    Cancel();
-
-    if ( iOwnsSocket )
-        {
-        if ( iSocket )
-            {
-            iSocket->Close();
-            delete iSocket;
-            }
-        }
-
-    iSocketServer.Close();
-    }
-
-// -----------------------------------------------------------------------------
-// CLocalTCPConnection::RunL
-// -----------------------------------------------------------------------------
-//
-void CLocalTCPConnection::RunL()
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::RunL(), iStatus=%d" ),
-        iStatus.Int() );
-
-    if ( iStatus.Int() == KErrNone )
-        {
-        switch ( iState )
-            {
-            case ELTCStateConnecting:
-                {
-                DEBUG_PRINT( DEBUG_STRING(
-                    "CLocalTCPConnection::RunL(), ELCStateConnecting" ) );
-                iState = ELTCStateConnected;
-                iObserver->LocalTCPConnectionEstablishedL( Port() );
-                break;
-                }
-            case ELTCStateDisconnecting:
-                {
-                DEBUG_PRINT( DEBUG_STRING(
-                    "CLocalTCPConnection::RunL(), ELCStateDisconnecting" ) );
-                iState = ELTCStateDisconnected;
-
-                iSocket->Close();
-                User::LeaveIfError( iSocket->Open(
-                    iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );
-                break;
-                }
-            }
-        }
-    else
-        {
-        iObserver->LocalTCPConnectionErrorL( Port(), iStatus.Int() );
-        iSocket->Close();
-        User::LeaveIfError( iSocket->Open(
-            iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );
-        }
-    }
-
-// -----------------------------------------------------------------------------
-// CLocalTCPConnection::DoCancel
-// -----------------------------------------------------------------------------
-//
-void CLocalTCPConnection::DoCancel()
-    {
-    iSocket->CancelConnect();
-    }
-
-TInt CLocalTCPConnection::RunError( TInt aError )
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::RunError( %d )" ), aError );
-
-    iObserver->LocalTCPConnectionObserverLeaved( Port(), aError );
-    return KErrNone;
-    }
-
-TInt CLocalTCPConnection::Port()
-    {
-    return iAddr.Port();
-    }
-
-void CLocalTCPConnection::IssueConnectL()
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::IssueConnectL()" ) );
-
-    iSocket->Connect( iAddr, iStatus );
-    SetActive();
-    iState = ELTCStateConnecting;
-    }
-
-void CLocalTCPConnection::IssueDisconnect()
-    {
-    DEBUG_PRINT( DEBUG_STRING(
-        "CLocalTCPConnection::IssueDisconnect()" ) );
-    iSocket->CancelAll();
-    Cancel();
-    iSocket->Shutdown( RSocket::ENormal, iStatus );
-    SetActive();
-    iState = ELTCStateDisconnecting;
-    }
-
-void CLocalTCPConnection::SetObserver( MLocalTCPConnectionObserver* aObserver )
-    {
-    iObserver = aObserver;
-    }
-
-RSocket* CLocalTCPConnection::Socket()
-    {
-    return iSocket;
-    }
-
-void CLocalTCPConnection::SetSocketOwnership( TBool aOwns )
-    {
-    iOwnsSocket = aOwns;
-    }
-
-
-TBool CLocalTCPConnection::IsConnected()
-    {
-    return ( iState == ELTCStateConnected || iState == ELTCStateDisconnecting );
-    }
-
-//  End of File