1 /*

     2 * Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 *

     9 * Initial Contributors:

    10 * Nokia Corporation - initial contribution.

    11 *

    12 * Contributors:

    13 *

    14 * Description:

    15 *

    16 */

    17 

    18 #include <ss_glob.h>

    19 #include <comms-infras/ss_thread.h>

    20 

    21 #include "testtcpserver.h"

    22 #include "ctestserversockethandler.h"

    23 #include "ptcpclienttests.h"

    24 #include "upnp_cf_msgs.h"

    25 

    26 const TUint KListenQSize = 5;

    27 const TUint KListenPort = 80;

    28 

    29 CTestTcpServer* CTestTcpServer::NewL ( MTestServerObserver& aObserver )

    30 	{

    31 	CTestTcpServer* self = new ( ELeave ) CTestTcpServer ( aObserver );

    32 	CleanupStack::PushL ( self );

    33 	self->ConstructL ();

    34 	CleanupStack::Pop ();

    35 	return self;		

    36 	}

    37 

    38 CTestTcpServer::CTestTcpServer ( MTestServerObserver& aObserver ) 

    39 	: iObserver ( aObserver ), iSocketHandler ( *this )

    40 	{	

    41 	}

    42 	

    43 void CTestTcpServer::ConstructL ()

    44 	{

    45 	User::LeaveIfError ( OpenSocket () );	

    46 	TUpnpMessage::RegisterL ( SockManGlobals::Get ()->SelfWorker ());

    47 	}

    48 

    49 CTestTcpServer::~CTestTcpServer ()

    50 	{

    51 	iIncomingHandlers.ResetAndDestroy ();

    52 	iSocketHandler.CancelAll ();

    53 	iSocket.Close ();

    54 	delete iSocketOpener;

    55 		

    56 	TUpnpMessage::DeRegister ();

    57 	}

    58 	

    59 TInt CTestTcpServer::OpenSocket ()

    60 	{

    61 	TInt err = KErrNone;

    62 	if ( NULL == iSocketOpener )

    63 		{

    64 		TRAP ( err, iSocketOpener = CSocketOpener::NewL ( *this ) );

    65 		}

    66 	

    67 	if ( err == KErrNone )

    68 		iSocketOpener->MakeSocket ( KAfInet, KSockStream, KProtocolInetTcp );

    69 	

    70 	return err;

    71 	}

    72 	

    73 void CTestTcpServer::DoAccept ()

    74 	{

    75 	iSocketHandler.Accept();		

    76 	}

    77 

    78 TInt CTestTcpServer::Startup ()

    79 	{

    80 	// Start listening and accepting for new connections

    81 	TInt err = iSocket.Listen ( KListenQSize ); 

    82 	if ( err == KErrNone )

    83 		DoAccept ();

    84 	return err;		

    85 	}

    86 

    87 void CTestTcpServer::OpenComplete ( RInternalSocket& aSocket )

    88 	{

    89 	iSocket = aSocket;

    90 	iSocketHandler.Attach ( iSocket );

    91 	

    92 	TInetAddr addr ( KListenPort );

    93 	addr.SetAddress ( KInetAddrAny );

    94 	TInt err = iSocket.Bind ( addr );

    95 

    96 	if ( err == KErrNone )

    97 		{

    98 		err = Startup ();

    99 		}

   100 		

   101 	TRAP_IGNORE(iObserver.OnTestServerEventL ( err ));

   102 	}	

   103 	

   104 void CTestTcpServer::AcceptComplete ( RInternalSocket& aSocket )

   105 	{

   106 

   107 

   108 	//iTestCase = reinterpret_cast<MTcpClientTestCase*> ( &iObserver );

   109 	iTestCase = iObserver.GetTestCase();

   110 	CTestServerSocketHandler* newSrvSockHandler = NULL;

   111 	TRAP_IGNORE(newSrvSockHandler = CTestServerSocketHandler::NewL ( iTestCase, aSocket, iObserver.GetLogger()));

   112     iIncomingHandlers.Append ( newSrvSockHandler );

   113 

   114     DoAccept ();

   115 	}

   116 	

   117