1 // Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

     2 // All rights reserved.

     3 // This component and the accompanying materials are made available

     4 // under the terms of "Eclipse Public License v1.0"

     5 // which accompanies this distribution, and is available

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

     7 //

     8 // Initial Contributors:

     9 // Nokia Corporation - initial contribution.

    10 //

    11 // Contributors:

    12 //

    13 // Description:

    14 // Contains the implementation of all the commands, which is used by the script file.

    15 //

    16 

    17 /**

    18  @file te_tundrivertestwrapper.h

    19  @internalTechnology

    20  */

    21 

    22 #include "te_tundrivertestwrapper.h"

    23 #include <e32base.h>

    24 #include <utf.h>

    25 #include <in_sock.h>

    26 #include <es_sock.h>

    27 

    28 #include <metadatabase.h> 

    29 #include <commsdattypesv1_1.h> 

    30 #include <commsdat.h>

    31 #include <commsdattypesv1_1_partner.h>

    32 #include <commsdattypeinfov1_1_internal.h>

    33 #include <commdb.h>

    34 #include <commdbconnpref.h>

    35 

    36 //Virtual Interface 

    37 

    38 // Commands

    39 

    40 _LIT(KRConnTest1_1,         "RConnTest1_1");

    41 _LIT(KRConnTest1_2,         "RConnTest1_2");

    42 _LIT(KRConnTest1_3,         "RConnTest1_3");

    43 _LIT(KRConnTest1_4,         "RConnTest1_4");

    44 _LIT(KRConnTest1_5,         "RConnTest1_5");

    45 _LIT(KRConnTest1_6,         "RConnTest1_6");

    46 _LIT(KRConnTest1_7,         "RConnTest1_7");

    47 _LIT(KRConnTest1_8,         "RConnTest1_8");

    48 _LIT(KRConnTest1_9,         "RConnTest1_9");

    49 _LIT(KRConnTest1_10,        "RConnTest1_10");

    50 _LIT(KRConnTest1_11,        "RConnTest1_11");

    51 _LIT(KRConnTest1_12,        "RConnTest1_12");

    52 _LIT(KRConnTest1_13,        "RConnTest1_13");

    53 _LIT(KRConnTest1_14,        "RConnTest1_14");

    54 _LIT(KRConnTest1_15,        "RConnTest1_15");

    55 _LIT(KRConnTest1_16,        "RConnTest1_16");

    56 _LIT(KRConnTest1_17,        "RConnTest1_17");

    57 _LIT(KRConnTest1_18,        "RConnTest1_18");

    58 _LIT(KRConnTest1_19,        "RConnTest1_19");

    59 _LIT(KRConnTest1_20,        "RConnTest1_20");

    60 _LIT(KRConnTest1_21,        "RConnTest1_21");

    61 _LIT(KRConnTest1_22,        "RConnTest1_22");

    62 _LIT(KRConnTest1_23,        "RConnTest1_23");

    63 _LIT(KRConnTest1_24,        "RConnTest1_24");

    64 _LIT(KRConnTest1_25,        "RConnTest1_25");

    65 _LIT(KRConnTest1_26,        "RConnTest1_26");

    66 _LIT(KRConnTest1_27,        "RConnTest1_27");

    67 _LIT(KRConnTest1_28,        "RConnTest1_28");

    68 _LIT(KRConnTest1_29,        "RConnTest1_29");

    69 _LIT(KRConnTest1_30,        "RConnTest1_30");

    70 _LIT(KRConnTest1_31,        "RConnTest1_31");

    71 _LIT(KRConnTest1_32,        "RConnTest1_32");

    72 _LIT(KRConnTest1_33,        "RConnTest1_33");

    73 

    74 // Config file

    75 _LIT(KNameDefault, 	    	"default");

    76 _LIT(KIpAddr,               "IpAddr");

    77 _LIT(KGatewayAddr,          "GatewayAddr");

    78 _LIT(KDestAddr, 		    "DestAddr");

    79 _LIT(KLocalAddr,            "LocalAddr");

    80 _LIT(KLocalPort,            "LocalPort");

    81 _LIT(KDestPort,             "DestPort");

    82 _LIT(KTcpDestPort,          "TcpDestPort");

    83 _LIT(KRealDestAddr,         "RealDestAddr");

    84 _LIT(KRealDestPort,         "RealDestPort");

    85 

    86 //Test code

    87 _LIT(KCommand, 			    "aCommand = %S");

    88 _LIT(KSection, 			    "aSection = %S");

    89 

    90 //Test code error

    91 _LIT(KInetInputFail,         "TInetAddr Input failed with error: %d");

    92 

    93 #define TUNDRIVER_IAP   14

    94 #define REAL_IAP    9

    95 #define LOCAL_PORT 7777

    96 

    97 // public

    98 //LOCAL_D CConsoleBase* console; 

    99 

   100 

   101 /**

   102 Constructor.

   103 

   104 @internalTechnology

   105  */

   106 CTunDriverTestWrapper::CTunDriverTestWrapper()

   107     {

   108     }

   109 

   110 /**

   111 Destructor.

   112 

   113 @internalTechnology

   114  */

   115 CTunDriverTestWrapper::~CTunDriverTestWrapper()

   116     {

   117     }

   118 

   119 /**

   120 Function to instantiate TestWrapper.

   121 @return Returns constructed TestWrapper instance pointer

   122 @internalTechnology

   123  */

   124 CTunDriverTestWrapper* CTunDriverTestWrapper::NewL()

   125     {

   126     CTunDriverTestWrapper*	ret = new (ELeave) CTunDriverTestWrapper();

   127     CleanupStack::PushL(ret);

   128     ret->ConstructL();

   129     CleanupStack::Pop(ret);

   130     return ret;	

   131     }

   132 

   133 /**

   134 Second level constructor, constructs TestWrapper instance.

   135 @internalTechnology

   136  */

   137 void CTunDriverTestWrapper::ConstructL()

   138     {

   139     iInitNumOfInterfaces    = 0;

   140     iCurNumOfInterfaces     = 0;

   141     iDestPort               = 0;

   142 

   143     }

   144 

   145 /**

   146 Function to map the input command to respective function.

   147 

   148 @return - True Upon successfull command to Function name mapping otherwise False

   149 @param aCommand Function name has to be called

   150 @param aSection INI file paramenter section name

   151 @param aAsyncErrorIndex Error index

   152 @see Refer the script file COMMAND section.

   153 

   154 @internalTechnology

   155  */

   156 TBool CTunDriverTestWrapper::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt /*aAsyncErrorIndex*/)

   157     {

   158     TBool ret = ETrue;

   159 

   160     // Print out the parameters for debugging

   161     INFO_PRINTF2( KCommand, &aCommand );

   162     INFO_PRINTF2( KSection, &aSection );

   163     //INFO_PRINTF2( KAsyncErrorIndex, aAsyncErrorIndex );

   164 

   165     //RConnection Testcases

   166     if(KRConnTest1_1() == aCommand)

   167         {

   168         DoRConnTest1_1();

   169         }

   170     else if(KRConnTest1_2() == aCommand)

   171         {

   172         DoRConnTest1_2();

   173         }

   174     else if(KRConnTest1_3() == aCommand)

   175         {

   176         DoRConnTest1_3(aSection);

   177         }

   178     else if(KRConnTest1_4() == aCommand)

   179         {

   180         DoRConnTest1_4(aSection);

   181         }

   182     else if(KRConnTest1_5() == aCommand)

   183         {

   184         DoRConnTest1_5(aSection);

   185         }

   186     else if(KRConnTest1_6() == aCommand)

   187         {

   188         DoRConnTest1_6(aSection);

   189         }

   190     else if(KRConnTest1_7() == aCommand)

   191         {

   192         DoRConnTest1_7(aSection);

   193         }

   194     else if(KRConnTest1_8() == aCommand)

   195         {

   196         DoRConnTest1_8(aSection);

   197         }

   198     else if(KRConnTest1_9() == aCommand)

   199         {

   200         DoRConnTest1_9(aSection);

   201         }

   202     else if(KRConnTest1_10() == aCommand)

   203         {

   204         DoRConnTest1_10(aSection);

   205         }

   206     else if(KRConnTest1_11() == aCommand)

   207         {

   208         DoRConnTest1_11();

   209         }

   210     else if(KRConnTest1_12() == aCommand)

   211         {

   212         DoRConnTest1_12();

   213         }

   214     else if(KRConnTest1_13() == aCommand)

   215         {

   216         DoRConnTest1_13(aSection);

   217         }

   218     else if(KRConnTest1_14() == aCommand)

   219         {

   220         DoRConnTest1_14(aSection);

   221         }

   222     else if(KRConnTest1_15() == aCommand)

   223         {

   224         DoRConnTest1_15();

   225         }

   226     else if(KRConnTest1_16() == aCommand)

   227         {

   228         DoRConnTest1_16(aSection);

   229         }

   230     else if(KRConnTest1_17() == aCommand)

   231         {

   232         DoRConnTest1_17(aSection);

   233         }

   234     else if(KRConnTest1_18() == aCommand)

   235         {

   236         

   237         }

   238     else if(KRConnTest1_19() == aCommand)

   239         {

   240     

   241         }

   242     else if(KRConnTest1_20() == aCommand)

   243         {

   244         DoRConnTest1_20();

   245         }

   246     else if(KRConnTest1_21() == aCommand)

   247         {

   248         DoRConnTest1_21();

   249         }

   250     else if(KRConnTest1_22() == aCommand)

   251         {

   252         DoRConnTest1_22();

   253         }

   254     else if(KRConnTest1_23() == aCommand)

   255         {

   256         DoRConnTest1_23();

   257         }

   258     else if(KRConnTest1_24() == aCommand)

   259         {

   260         DoRConnTest1_24();

   261         }

   262     else if(KRConnTest1_25() == aCommand)

   263         {

   264         DoRConnTest1_25();

   265         }

   266     else if(KRConnTest1_26() == aCommand)

   267         {

   268         DoRConnTest1_26();

   269         }

   270     else if(KRConnTest1_27() == aCommand)

   271         {

   272         DoRConnTest1_27();

   273         }

   274     else if(KRConnTest1_28() == aCommand)

   275         {

   276         DoRConnTest1_28();

   277         }

   278     else if(KRConnTest1_29() == aCommand)

   279         {

   280         DoRConnTest1_29();

   281         }

   282     else if(KRConnTest1_30() == aCommand)

   283         {

   284         DoRConnTest1_30();

   285         }

   286 	else if(KRConnTest1_31() == aCommand)

   287         {

   288         DoRConnTest1_31();

   289         }

   290 	else if(KRConnTest1_32() == aCommand)

   291         {

   292         DoRConnTest1_32();

   293         }

   294     else if(KRConnTest1_33() == aCommand)

   295         {

   296         DoRConnTest1_33();

   297         }	

   298     else

   299         {

   300         ret = EFalse;

   301         User::LeaveIfError(KErrNone); // just to suppress LeaveScan warning

   302         }

   303     return ret;

   304     }

   305 

   306 /**

   307 Function to open Virtual Socket.

   308 @internalTechnology

   309  */

   310 

   311 TBool CTunDriverTestWrapper::FindInterface(TPckgBuf<TSoInet6InterfaceInfo> &info)

   312     {

   313     TBool success = FALSE;

   314     if((iStatus = iSocketServ.Connect()) == KErrNone )

   315         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   316     else

   317         {

   318         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   319         SetError(iStatus.Int());

   320 

   321         return success;

   322         }

   323 

   324     if((iStatus = iConnection1.Open(iSocketServ)) == KErrNone )

   325         INFO_PRINTF1(_L("Connection1 opened. \n"));

   326     else

   327         {

   328         ERR_PRINTF2(_L("Error Opening Connection1: %d"), iStatus.Int());

   329         SetError(iStatus.Int());

   330 

   331         return success;

   332         }

   333 

   334     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   335     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   336     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   337 

   338     iConnection1.Start(iCommDbPref, iStatus);

   339 

   340 

   341     //open socket on interface. 

   342     if((iStatus = iSocket1.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection1)) == KErrNone )

   343         INFO_PRINTF1(_L("Socket Opened!\n "));

   344 

   345     User::LeaveIfError( iSocket1.SetOpt( KSoInetEnumInterfaces, KSolInetIfCtrl ) );

   346 

   347     TProtocolDesc in;

   348     User::LeaveIfError( iSocket1.Info( in ) );

   349     TInt res = iSocket1.GetOpt( KSoInetNextInterface, KSolInetIfCtrl, info );

   350     if (res != KErrNone)

   351         {

   352         User::Leave( res );

   353         }

   354     

   355     TPckgBuf<TSoInet6InterfaceInfo> next;

   356 

   357 

   358     while (res == KErrNone)

   359         {

   360         res = iSocket1.GetOpt( KSoInetNextInterface, KSolInetIfCtrl, next );

   361         if (res == KErrNone)

   362             info = next;

   363         //Compare the string with interface name

   364         if (info().iName.Mid(1,4).Compare(_L("TunDriver")))

   365             //if (info().iName == KIfName)

   366             {

   367             success = TRUE;

   368             break;

   369 

   370             }

   371         else

   372             {

   373             continue;

   374             }

   375         }

   376 

   377     return success;

   378 

   379 

   380     }

   381 

   382 TInt CTunDriverTestWrapper::StartD3PApp()

   383     {

   384     TInt err(0);

   385     if ((err = p.Create(KDummy3rdPartyApp,KArg)) == KErrNone)

   386         {

   387         p.Resume();

   388         }

   389     else

   390         {

   391         ERR_PRINTF2(_L("Error Opening Dummy3rdPartyApp: %d"), iVTunError);

   392         SetError(err);

   393         return(err);        

   394         }

   395     //Wait for Dummy3rdPartyApp to be up and running!

   396     User::After(10000000);   //10 Sec

   397     return(err);

   398     }

   399 

   400 void CTunDriverTestWrapper::StopD3PApp()

   401     {

   402     p.Kill(NULL);   //Kill Dummy3rdPartyApp.       

   403     }

   404 

   405 //Gurpreet: RConnection Testcases

   406 

   407 void CTunDriverTestWrapper::DoRConnTest1_1()

   408     {

   409     INFO_PRINTF1(_L("********************************************"));

   410     INFO_PRINTF1(_L("           Test: DoRConnTest1_1             "));

   411     INFO_PRINTF1(_L("********************************************"));

   412 

   413     if((iStatus = iSocketServ.Connect()) == KErrNone )

   414         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   415     else

   416         {

   417         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   418         SetError(iStatus.Int());

   419         return;

   420         }

   421 

   422     if((iStatus = iConnection.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

   423         INFO_PRINTF1(_L("Connection opened. \n"));

   424     else

   425         {

   426         ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

   427         SetError(iStatus.Int());

   428         return;

   429         }

   430 

   431     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   432     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   433     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   434 

   435     iVTunError = iConnection.Start(iCommDbPref);

   436     //User::WaitForRequest(iStatus);

   437     INFO_PRINTF2(_L("Starting Connection %d.\n"), iVTunError);

   438 

   439     if(iVTunError!= KErrNone)

   440         {

   441         SetError(iVTunError);

   442         }

   443     iConnection.Close();

   444     iSocketServ.Close();    

   445     }

   446 

   447 void CTunDriverTestWrapper::DoRConnTest1_2()

   448     {

   449     INFO_PRINTF1(_L("********************************************"));

   450     INFO_PRINTF1(_L("           Test: DoRConnTest1_2             "));

   451     INFO_PRINTF1(_L("********************************************"));

   452 

   453     if((iStatus = iSocketServ.Connect()) == KErrNone )

   454         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   455     else

   456         {

   457         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   458         SetError(iStatus.Int());

   459         return;

   460         }

   461 

   462     if((iStatus = iConnection.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

   463         INFO_PRINTF1(_L("Connection opened. \n"));

   464     else

   465         {

   466         ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

   467         SetError(iStatus.Int());

   468         return;

   469         }

   470 

   471     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   472     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   473     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   474 

   475     iConnection.Start(iCommDbPref, iStatus);

   476     User::WaitForRequest(iStatus);

   477     INFO_PRINTF2(_L("Starting Connection %d.\n"), iStatus.Int());

   478 

   479     iConnection.Close();

   480     iSocketServ.Close();    

   481     }

   482 

   483 void CTunDriverTestWrapper::DoRConnTest1_3(const TDesC& aSection)

   484     {

   485     INFO_PRINTF1(_L("*********************************************"));

   486     INFO_PRINTF1(_L("           Test: DoRConnTest1_3             "));

   487     INFO_PRINTF1(_L("********************************************"));

   488 

   489     //start the dummy3rdpartyapp

   490     if ((iVTunError = StartD3PApp()) != KErrNone)

   491         {

   492         return;

   493         }

   494 

   495     if((iStatus = iSocketServ.Connect()) == KErrNone )

   496         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   497     else

   498         {

   499         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   500         SetError(iStatus.Int());

   501         StopD3PApp();

   502         return;

   503         }

   504 

   505     if((iStatus = iConnection.Open(iSocketServ)) == KErrNone )

   506         INFO_PRINTF1(_L("Connection opened. \n"));

   507     else

   508         {

   509         ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

   510         SetError(iStatus.Int());

   511         StopD3PApp();

   512         return;

   513         }

   514 

   515     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   516     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   517     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   518 

   519     iConnection.Start(iCommDbPref, iStatus);

   520 		User::WaitForRequest(iStatus);

   521 		if (iStatus.Int() != KErrNone)

   522 			{

   523 			ERR_PRINTF2(_L("Error starting connection: %d"), iStatus.Int());	

   524 			SetError(iStatus.Int());

   525 			StopD3PApp();

   526 			return;

   527 			}

   528 	INFO_PRINTF1(_L("Connection started!\n "));

   529 

   530     //open socket on interface. 

   531     if((iStatus = iSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection)) == KErrNone )

   532         INFO_PRINTF1(_L("Socket Opened!\n "));

   533     else   // (iStatus!=KErrNone)

   534         {

   535         ERR_PRINTF2(_L("Error Opening Socket: %d"), iStatus.Int());    

   536         SetError(iStatus.Int());

   537         StopD3PApp();

   538         return;

   539         }

   540 

   541     iSendBuf.Zero();

   542     iSendBuf = (TText8*)"Nokia sues Apple!";

   543 

   544     // Get destination address from config file   

   545     TPtrC ptrToReadFromConfig(KNameDefault);

   546     TBool returnValue = GetStringFromConfig(aSection, KDestAddr, ptrToReadFromConfig);

   547     if (!returnValue)

   548         {

   549         ERR_PRINTF1(_L("Reading config file failed, while reading DestAddr"));   

   550         SetError(KErrUnknown);

   551         StopD3PApp();

   552         return;

   553         }

   554     //set destination IP ie. server

   555     TInt err = iDestAddr.Input(ptrToReadFromConfig);   

   556     if(err != KErrNone)

   557         {

   558         INFO_PRINTF2(KInetInputFail, err);

   559         SetError(err);

   560         StopD3PApp();

   561         return;

   562         }

   563 

   564     returnValue = GetIntFromConfig(aSection, KDestPort, iDestPort);

   565     iDestAddr.SetPort(iDestPort);

   566 

   567     //bind local port to socket

   568     err = iSocket.SetLocalPort(7776);

   569 

   570     //send data to server

   571     iSocket.SendTo(iSendBuf, iDestAddr, NULL, iStatus);

   572     User::WaitForRequest(iStatus);

   573     if( iStatus == KErrNone)

   574         INFO_PRINTF1(_L("\nData Sent"));

   575     else

   576 	   {

   577         ERR_PRINTF1(_L("\nData sending failed"));

   578         SetError(iStatus.Int());

   579         iSocket.Close();

   580         iConnection.Close();

   581         iSocketServ.Close();

   582         StopD3PApp();

   583         return;

   584   	    }

   585 

   586     iRecvBuf.Zero();

   587     iSocket.RecvFrom(iRecvBuf, iDestAddr, NULL, iStatus);

   588     User::WaitForRequest(iStatus);

   589     TBuf<128> temp;

   590     if( iStatus == KErrNone)

   591         {

   592         INFO_PRINTF1(_L("\nData Received : "));

   593         temp.Copy(iRecvBuf);

   594         INFO_PRINTF1(temp);

   595         INFO_PRINTF1(_L("\n"));

   596         }

   597     else

   598         {

   599         ERR_PRINTF1(_L("\nData receive failed"));  

   600         SetError(iStatus.Int());

   601         }

   602     iSocket.Close();

   603     iSocketServ.Close();

   604     

   605     StopD3PApp();

   606     

   607     }

   608 

   609 void CTunDriverTestWrapper::DoRConnTest1_4(const TDesC& aSection)

   610     {

   611     INFO_PRINTF1(_L("*********************************************"));

   612     INFO_PRINTF1(_L("           Test: DoRConnTest1_4             "));

   613     INFO_PRINTF1(_L("********************************************"));

   614 

   615 		//start the dummy3rdpartyapp

   616     if ((iVTunError = StartD3PApp()) != KErrNone)

   617         {

   618         return;

   619         }

   620 

   621     if((iStatus = iSocketServ.Connect()) == KErrNone )

   622         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   623     else

   624         {

   625         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   626         SetError(iStatus.Int());

   627         return;

   628         }

   629 

   630     if((iStatus = iConnection.Open(iSocketServ)) == KErrNone )

   631         INFO_PRINTF1(_L("Connection opened. \n"));

   632     else

   633         {

   634         ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

   635         SetError(iStatus.Int());

   636         return;

   637         }

   638 

   639     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   640     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   641     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   642 

   643     iConnection.Start(iCommDbPref, iStatus);

   644     User::WaitForRequest(iStatus);

   645     if (iStatus.Int() != KErrNone)

   646 		{

   647 		ERR_PRINTF2(_L("Error starting connection: %d"), iStatus.Int());	

   648 		SetError(iStatus.Int());

   649 		iSocketServ.Close();

   650 		StopD3PApp();

   651 		return;

   652 		}

   653     INFO_PRINTF2(_L("Starting Connection %d.\n"), iStatus.Int());

   654 

   655     //open socket on interface. 

   656 

   657     if((iStatus = iSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection)) == KErrNone )

   658         INFO_PRINTF1(_L("Socket Opened!\n "));

   659     else   // (iStatus!=KErrNone)

   660         {

   661         ERR_PRINTF2(_L("Error Opening Socket: %d"), iStatus.Int());    

   662         SetError(iStatus.Int());

   663         iConnection.Close();

   664         iSocketServ.Close();

   665         StopD3PApp();

   666         return;

   667         }

   668 

   669     iSendBuf.Zero();

   670     iSendBuf = (TText8*)"Nokia sues Apple!";

   671 

   672     // Get destination address from config file  

   673     TPtrC ptrToReadFromConfig(KNameDefault);

   674     TBool returnValue = GetStringFromConfig(aSection, KDestAddr, ptrToReadFromConfig);

   675     if (!returnValue)

   676         {

   677         ERR_PRINTF1(_L("Reading config file failed, while reading DestAddr"));   

   678         SetError(KErrUnknown);

   679         iSocket.Close();

   680         iConnection.Close();

   681         iSocketServ.Close();

   682         StopD3PApp();

   683         return;

   684         }

   685     //set destination IP ie. server

   686     TInt err = iDestAddr.Input(ptrToReadFromConfig);   

   687     if(err != KErrNone)

   688         {

   689         INFO_PRINTF2(KInetInputFail, err);

   690         SetError(err);

   691         iSocket.Close();

   692         iConnection.Close();

   693         iSocketServ.Close();

   694         StopD3PApp();

   695         return;

   696         }

   697 

   698     returnValue = GetIntFromConfig(aSection, KDestPort, iDestPort);

   699     iDestAddr.SetPort(iDestPort);

   700 

   701     //bind local port to socket

   702     err = iSocket.SetLocalPort(LOCAL_PORT);

   703 

   704     //send data to server

   705     iSocket.SendTo(iSendBuf, iDestAddr, NULL, iStatus);

   706     User::WaitForRequest(iStatus);

   707     if( iStatus == KErrNone)

   708         INFO_PRINTF1(_L("\nData Sent"));

   709     else

   710 	   {

   711         ERR_PRINTF1(_L("\nData sending failed"));

   712         SetError(iStatus.Int());

   713         iSocket.Close();

   714         iConnection.Close();

   715         iSocketServ.Close();

   716         StopD3PApp();

   717         return;

   718   	    }

   719 

   720     iRecvBuf.Zero();

   721     iSocket.RecvFrom(iRecvBuf, iDestAddr, NULL, iStatus);

   722     User::WaitForRequest(iStatus);

   723     TBuf<128> temp;

   724     if( iStatus == KErrNone)

   725         {

   726         INFO_PRINTF1(_L("\nData Received : "));

   727         temp.Copy(iRecvBuf);

   728         INFO_PRINTF1(temp);

   729         INFO_PRINTF1(_L("\n"));

   730         }

   731     else

   732         {

   733         ERR_PRINTF1(_L("\nData receive failed"));

   734         SetError(iStatus.Int());

   735         }

   736     iSocket.Close();

   737     iConnection.Close();

   738     iSocketServ.Close();    

   739 

   740     StopD3PApp();

   741     

   742     }

   743 

   744 void CTunDriverTestWrapper::DoRConnTest1_5(const TDesC& aSection)

   745     {

   746     INFO_PRINTF1(_L("*********************************************"));

   747     INFO_PRINTF1(_L("           Test: DoRConnTest1_5             "));

   748     INFO_PRINTF1(_L("********************************************"));

   749 

   750     //start the dummy3rdpartyapp

   751     if ((iVTunError = StartD3PApp()) != KErrNone)

   752         {

   753         return;

   754         }

   755 

   756     if((iStatus = iSocketServ.Connect()) == KErrNone )

   757         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   758     else

   759         {

   760         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   761         SetError(iStatus.Int());

   762         StopD3PApp();

   763         return;

   764         }

   765     if((iStatus = iConnection.Open(iSocketServ)) == KErrNone )

   766         INFO_PRINTF1(_L("Connection opened. \n"));

   767     else

   768         {

   769         ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

   770         SetError(iStatus.Int());

   771         StopD3PApp();

   772         return;

   773         }

   774 

   775     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

   776     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

   777     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

   778 

   779     iConnection.Start(iCommDbPref, iStatus);

   780     User::WaitForRequest(iStatus);

   781     if (iStatus.Int() != KErrNone)

   782 		{

   783 		ERR_PRINTF2(_L("Error starting connection: %d"), iStatus.Int());	

   784 		SetError(iStatus.Int());

   785 		iSocketServ.Close();

   786 		StopD3PApp();

   787 		return;

   788 		}

   789     INFO_PRINTF2(_L("Starting Connection %d.\n"), iStatus.Int());

   790 

   791     //open socket on interface. 

   792     if((iStatus = iSocket1.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection)) == KErrNone )

   793         INFO_PRINTF1(_L("Socket1 Opened!\n "));

   794     else   // (iStatus!=KErrNone)

   795         {

   796         ERR_PRINTF2(_L("Error Opening Socket1: %d"), iStatus.Int());    

   797         SetError(iStatus.Int());

   798         iConnection.Close();

   799         iSocketServ.Close();

   800         StopD3PApp();

   801         return;

   802         }

   803 

   804     if((iStatus = iSocket2.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection)) == KErrNone )

   805         INFO_PRINTF1(_L("Socket2 Opened!\n "));

   806     else   // (iStatus!=KErrNone)

   807         {

   808         ERR_PRINTF2(_L("Error Opening Socket2: %d"), iStatus.Int());    

   809         SetError(iStatus.Int());

   810         iConnection.Close();

   811         iSocketServ.Close();

   812         StopD3PApp();

   813         return;

   814         }

   815 

   816     // Get destination address from config file 

   817     TPtrC ptrToReadFromConfig(KNameDefault);

   818     TBool returnValue = GetStringFromConfig(aSection, KDestAddr, ptrToReadFromConfig);

   819     if (!returnValue)

   820         {

   821         ERR_PRINTF1(_L("Reading config file failed, while reading DestAddr"));   

   822         SetError(KErrUnknown);

   823         iSocket1.Close();

   824         iSocket2.Close();

   825         iConnection.Close();

   826         iSocketServ.Close();

   827         StopD3PApp();

   828         return;

   829         }

   830     //set destination IP ie. server

   831     TInt err = iDestAddr.Input(ptrToReadFromConfig);   

   832     if(err != KErrNone)

   833         {

   834         INFO_PRINTF2(KInetInputFail, err);

   835         SetError(err);

   836         iSocket1.Close();

   837         iSocket2.Close();

   838         iConnection.Close();

   839         iSocketServ.Close();

   840         StopD3PApp();

   841         return;

   842         }

   843 

   844     returnValue = GetIntFromConfig(aSection, KDestPort, iDestPort);

   845     iDestAddr.SetPort(iDestPort);

   846 

   847     //bind local port to socket

   848     err = iSocket1.SetLocalPort(LOCAL_PORT);

   849     if(err != KErrNone)

   850     	{

   851         ERR_PRINTF2(_L("Error Binding Socket1: %d"), err);    

   852         SetError(err);

   853         iSocket1.Close();

   854         iSocket2.Close();

   855         iConnection.Close();

   856         iSocketServ.Close();

   857         StopD3PApp();

   858       	}

   859     //bind local port to socket

   860     err = iSocket2.SetLocalPort(LOCAL_PORT + 1);

   861     if(err != KErrNone)

   862     	{

   863         ERR_PRINTF2(_L("Error Binding Socket2: %d"), err);

   864         SetError(err);

   865         iSocket1.Close();

   866         iSocket2.Close();

   867         iConnection.Close();

   868         iSocketServ.Close();

   869         StopD3PApp();

   870       	}

   871 

   872     iSendBuf.Zero();

   873     iSendBuf = (TText8*)"Nokia sues Apple!";//"Sending Data through Socket1!";

   874 

   875     //send data to server

   876     iSocket1.SendTo(iSendBuf, iDestAddr, NULL, iStatus);

   877     User::WaitForRequest(iStatus);

   878 

   879     if( iStatus == KErrNone)

   880         INFO_PRINTF1(_L("\nData Sent thru socket1"));

   881     else

   882     	{

   883         ERR_PRINTF1(_L("\nData sending failed"));

   884         SetError(iStatus.Int());

   885         iSocket1.Close();

   886         iSocket2.Close();

   887         iConnection.Close();

   888         iSocketServ.Close();

   889         StopD3PApp();

   890       	}

   891 

   892     iRecvBuf.Zero();

   893     iSocket1.RecvFrom(iRecvBuf, iDestAddr, NULL, iStatus);

   894     User::WaitForRequest(iStatus);

   895     TBuf<128> temp;

   896     if( iStatus == KErrNone)

   897         {

   898         INFO_PRINTF1(_L("\nData Received from Socket1 : "));

   899         temp.Copy(iRecvBuf);

   900         INFO_PRINTF1(temp);

   901         INFO_PRINTF1(_L("\n"));

   902         }

   903     else

   904     	{

   905         ERR_PRINTF1(_L("\nData receive failed on Socket1"));  

   906         SetError(iStatus.Int());

   907         iSocket1.Close();

   908         iSocket2.Close();

   909         iConnection.Close();

   910         iSocketServ.Close();

   911         StopD3PApp();

   912       	}

   913 

   914     iSendBuf.Zero();

   915     iSendBuf = (TText8*)" Socket2:Nokia sues Apple!";

   916     iSocket2.SendTo(iSendBuf, iDestAddr, NULL, iStatus);

   917     User::WaitForRequest(iStatus);

   918 

   919     if( iStatus == KErrNone)

   920         INFO_PRINTF1(_L("\nData Sent thru socket2"));

   921     else

   922 	    {

   923 		ERR_PRINTF1(_L("\nData sending failed"));

   924 	    SetError(iStatus.Int());

   925 	    iSocket1.Close();

   926 	    iSocket2.Close();

   927 	    iConnection.Close();

   928 	    iSocketServ.Close();

   929 	    StopD3PApp();

   930 	    }

   931 

   932     iRecvBuf.Zero();

   933     iSocket2.RecvFrom(iRecvBuf, iDestAddr, NULL, iStatus);

   934     User::WaitForRequest(iStatus);

   935     temp.Zero();

   936     if( iStatus == KErrNone)

   937         {

   938         INFO_PRINTF1(_L("\nData Received from Socket2: "));

   939         temp.Copy(iRecvBuf);

   940         INFO_PRINTF1(temp);

   941         INFO_PRINTF1(_L("\n"));

   942         }

   943     else

   944         {

   945         ERR_PRINTF1(_L("\nData receive failed on Socket2"));

   946         SetError(iStatus.Int());

   947         }

   948     iSocket1.Close();

   949     iSocket2.Close();

   950     iConnection.Close();

   951     iSocketServ.Close();

   952     

   953     StopD3PApp();

   954     

   955     }

   956 

   957 void CTunDriverTestWrapper::DoRConnTest1_6(const TDesC& aSection)

   958     {

   959 

   960     INFO_PRINTF1(_L("*********************************************"));

   961     INFO_PRINTF1(_L("           Test: DoRConnTest1_6              "));

   962     INFO_PRINTF1(_L("*********************************************"));

   963 

   964     //start the dummy3rdpartyapp

   965     if ((iVTunError = StartD3PApp()) != KErrNone)

   966         {

   967         return;

   968         }

   969 

   970     if((iStatus = iSocketServ.Connect()) == KErrNone )

   971         INFO_PRINTF1(_L("Socket Server Opened.\n"));

   972     else

   973         {

   974         ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

   975         SetError(iStatus.Int());

   976         StopD3PApp();

   977         return;

   978         }

   979     if((iStatus = iConnection1.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

   980         INFO_PRINTF1(_L("Connection1 opened. \n"));

   981     else

   982         {

   983         ERR_PRINTF2(_L("Error Opening Connection1: %d"), iStatus.Int());

   984         SetError(iStatus.Int());

   985         StopD3PApp();

   986         return;

   987         }

   988 

   989     if((iStatus = iConnection2.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

   990         INFO_PRINTF1(_L("Connection2 opened. \n"));

   991     else

   992         {

   993         ERR_PRINTF2(_L("Error Opening Connection2: %d"), iStatus.Int());

   994         SetError(iStatus.Int());

   995         StopD3PApp();

   996         return;

   997         }

   998 

   999     iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

  1000     iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

  1001     iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

  1002 

  1003     iConnection1.Start(iCommDbPref, iStatus);

  1004     User::WaitForRequest(iStatus);

  1005    	

  1006     if(iStatus.Int()!=KErrNone)

  1007 	   	{

  1008 	   	ERR_PRINTF2(_L("Error starting connection1: %d"), iStatus.Int());	

  1009 		SetError(iStatus.Int());

  1010 		iSocketServ.Close();

  1011 		StopD3PApp();

  1012 		return;

  1013 	    }

  1014 	    INFO_PRINTF2(_L("Starting Connection1 %d.\n"), iStatus.Int());

  1015         	

  1016 

  1017     iConnection2.Start(iCommDbPref, iStatus);

  1018     User::WaitForRequest(iStatus);

  1019     if(iStatus.Int()!=KErrNone)

  1020 	    {

  1021 	    ERR_PRINTF2(_L("Error starting connection2: %d"), iStatus.Int());	

  1022 		SetError(iStatus.Int());

  1023 		iConnection1.Close();

  1024 		iSocketServ.Close();

  1025 		StopD3PApp();

  1026 		return;

  1027 	    }

  1028 

  1029     INFO_PRINTF2(_L("Starting Connection2 %d.\n"), iStatus.Int());

  1030 

  1031     //open socket on interface. 

  1032     if((iStatus = iSocket1.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection1)) == KErrNone )

  1033         INFO_PRINTF1(_L("Socket1 Opened!\n "));

  1034     else   // (iStatus!=KErrNone)

  1035         {

  1036         ERR_PRINTF2(_L("Error Opening Socket1: %d"), iStatus.Int());    

  1037         SetError(iStatus.Int());

  1038         iConnection1.Close();

  1039         iConnection2.Close();

  1040         iSocketServ.Close();

  1041         StopD3PApp();

  1042         return;

  1043         }

  1044     if((iStatus = iSocket2.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection2)) == KErrNone )

  1045         INFO_PRINTF1(_L("Socket2 Opened!\n "));

  1046     else   // (iStatus!=KErrNone)

  1047         {

  1048         ERR_PRINTF2(_L("Error Opening Socket2: %d"), iStatus.Int());    

  1049         SetError(iStatus.Int());

  1050         iSocket1.Close();

  1051         iConnection1.Close();

  1052         iConnection2.Close();

  1053         iSocketServ.Close();

  1054         StopD3PApp();

  1055         return;

  1056         }

  1057 

  1058     iSendBuf.Zero();

  1059     iSendBuf = (TText8*)"Socket1: Nokia sues Apple!";

  1060 

  1061     // Get destination address from config file    

  1062     TPtrC ptrToReadFromConfig(KNameDefault);

  1063     TBool returnValue = GetStringFromConfig(aSection, KDestAddr, ptrToReadFromConfig);

  1064     if (!returnValue)

  1065         {

  1066         ERR_PRINTF1(_L("Reading config file failed, while reading DestAddr"));   

  1067         SetError(KErrUnknown);

  1068         iSocket1.Close();

  1069         iSocket2.Close();

  1070         iConnection1.Close();

  1071         iConnection2.Close();

  1072         iSocketServ.Close();

  1073         StopD3PApp();

  1074         return;

  1075         }

  1076     //set destination IP ie. server

  1077     TInt err = iDestAddr.Input(ptrToReadFromConfig);   

  1078     if(err != KErrNone)

  1079         {

  1080         INFO_PRINTF2(KInetInputFail, err);

  1081         SetError(err);

  1082         iSocket1.Close();

  1083         iSocket2.Close();

  1084         iConnection1.Close();

  1085         iConnection2.Close();

  1086         iSocketServ.Close();

  1087         StopD3PApp();

  1088         return;

  1089         }

  1090 

  1091     returnValue = GetIntFromConfig(aSection, KDestPort, iDestPort);

  1092     iDestAddr.SetPort(iDestPort);

  1093     //bind local port to socket

  1094     err = iSocket1.SetLocalPort(LOCAL_PORT);

  1095     if(err != KErrNone)

  1096 		{

  1097 	    ERR_PRINTF1(_L("Error in setting local port to socket1"));

  1098 	    SetError(err);

  1099 	    iSocket1.Close();

  1100 	    iSocket2.Close();

  1101 	    iConnection1.Close();

  1102 	    iConnection2.Close();

  1103 	    iSocketServ.Close();

  1104 	    StopD3PApp();

  1105 	    return;

  1106 	    }

  1107 

  1108     err = iSocket2.SetLocalPort(LOCAL_PORT+1);

  1109     if(err != KErrNone)

  1110 	    {

  1111 		ERR_PRINTF1(_L("Error in setting local port to socket1"));

  1112 	    SetError(err);

  1113 		iSocket1.Close();

  1114 	    iSocket2.Close();

  1115 	    iConnection1.Close();

  1116 	    iConnection2.Close();

  1117 	    iSocketServ.Close();

  1118 	    StopD3PApp();

  1119 	    return;

  1120 	    }

  1121 	    //send data to server

  1122     iSocket1.SendTo(iSendBuf, iDestAddr, NULL, iStatus);

  1123     User::WaitForRequest(iStatus);

  1124 	  if( iStatus == KErrNone)

  1125         INFO_PRINTF1(_L("\nData Sent for socket1"));

  1126     else

  1127 	    {

  1128 	    ERR_PRINTF1(_L("\nData sending failed for socket1"));

  1129 		SetError(iStatus.Int());

  1130 		iSocket1.Close();

  1131 	    iSocket2.Close();

  1132 	    iConnection1.Close();

  1133 	    iConnection2.Close();

  1134 	    iSocketServ.Close();