/*

* Copyright (c) 2007 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:    

*

*/

#include "testserver.h"

#include <in_sock.h>

#include <e32debug.h>

CTestServer* CTestServer::NewL( MTestServerObserver* aObserver )

    {

    CTestServer* self = CTestServer::NewLC( aObserver );

    CleanupStack::Pop( self );

    return self;

    }

CTestServer* CTestServer::NewLC( MTestServerObserver* aObserver )

    {   

    CTestServer* self = new( ELeave ) CTestServer( aObserver );

    CleanupStack::PushL( self );

    self->ConstructL( );

    return self;

    }

CTestServer::CTestServer( MTestServerObserver* aObserver ) :

    CActive( EPriorityStandard ), iObserver( aObserver )

    {

    CActiveScheduler::Add( this );

    }

void CTestServer::ConstructL()

    {

    RDebug::Print( _L( "CTestServer::ConstructL" ) );

    User::LeaveIfError( iServer.Connect() );

    iState = EServerDisconnected;

    iTimer = CTimeOutTimer::NewL( EPriorityStandard, *this );

    }

CTestServer::~CTestServer()

    {

    RDebug::Print( _L( "CTestServer::~CTestServer" ) );

    Cancel();

    iSocket.Close();

    iListenSocket.Close();  

    iServer.Close();

    iTimer->Cancel();

    delete iTimer;

    RDebug::Print( _L( "CTestServer::~CTestServer - done" ) );

    }

// ---------------------------------------------------------------------------

// CTestServer::OpenL

// ---------------------------------------------------------------------------

//

void CTestServer::OpenL( TInetAddr& aAddr, TUint aTimeoutTime )

    {

    RDebug::Print( _L( "CTestServer::OpenL" ) );

    __ASSERT_ALWAYS( EServerDisconnected == iState, User::Leave( KErrAlreadyExists ) );

    User::LeaveIfError( iListenSocket.Open( iServer, KAfInet,

        KSockStream, KProtocolInetTcp ) );

    User::LeaveIfError( iSocket.Open( iServer ) );

    User::LeaveIfError( iListenSocket.SetOpt( KSoReuseAddr,

        KProtocolInetIp, 1 ) );

    User::LeaveIfError( iListenSocket.Bind( aAddr ) );

    User::LeaveIfError( iListenSocket.Listen( 1 ) );

    iListenSocket.Accept( iSocket, iStatus );

    iState = EServerWaitingConnection;

    if ( aTimeoutTime )

        {

        iTimer->After( aTimeoutTime );

        }

    SetActive();

    }

// ---------------------------------------------------------------------------

// CTestServer::RunL

// from CActive

// ---------------------------------------------------------------------------

//

void CTestServer::RunL()

    {

    RDebug::Print( _L( "CTestServer::RunL - iStatus: %d" ), iStatus.Int() );

    switch( iState )

        {

        case EServerWaitingConnection:

            if( iStatus.Int() == KErrNone )

                {

                iState = EServerConnected;

                iObserver->Notify( MTestServerObserver::EConnected, KErrNone );

                }

            else

                {

                iState = EServerDisconnected;

                iObserver->Notify( MTestServerObserver::EConnecting, iStatus.Int() );

                }

            break;

        case EServerConnected:

            iObserver->Notify( MTestServerObserver::EConnected, iStatus.Int() );

            break;

        case EServerDisconnected:

            iObserver->Notify( MTestServerObserver::EDisconnected, iStatus.Int() );

            break;

        }

    }

// ---------------------------------------------------------------------------

// CTestServer::DoCancel

// from CActive

// ---------------------------------------------------------------------------

//

void CTestServer::DoCancel()

    {

    iTimer->Cancel();

    }

// ---------------------------------------------------------------------------

// CTestServer::TimerExpired

// from MTimeoutNotifier

// ---------------------------------------------------------------------------

//

void CTestServer::TimerExpired()

    {

    iObserver->Notify( MTestServerObserver::EShutdownTimer, KErrNone );

    }