com.mobiledgex.matchingengine.performancemetrics.NetTest Class Reference

Classes
enum	TestType

Public Member Functions
	NetTest ()
Comparator< Site >	getSiteComparator ()
void	setSiteComparator (Comparator< Site > siteComparator)
ExecutorService	setExecutorService (ExecutorService executorService)
long	ConnectAndDisconnectHostAndPort (Site site)
long	ConnectAndDisconnect (Site site)
long	Ping (Site site)
boolean	doTest (boolean enable)
Site	getSite (String hostOrL7Path)
boolean	addSite (Site site)
List< Site >	sortedSiteList ()
Site	bestSite ()
double	testSite (Site site)
void	testSites (long TimeoutMS)
void	testSitesOnExecutor (long TimeoutMS)
void	RunNetTest ()

Public Attributes
int	testRounds = 3
boolean	runTest
int	TestIntervalMS = 100
int	TestTimeoutMS = 2000

Static Public Attributes
static final String	TAG = "NetTest"

Detailed Description

Utility class used for testing network latency

Example

        NetTest netTest = new NetTest();
        AppClient.RegisterClientRequest.Builder registerClientRequestBuilder = null;
        try {
            registerClientRequestBuilder = me.createDefaultRegisterClientRequest(context, "MobiledgeX-Samples")
                    .setAppName("EdgeMultiplay")
                    .setAppVers("1.2");
            AppClient.RegisterClientRequest req = registerClientRequestBuilder.build();
 
            AppClient.RegisterClientReply regReply = me.registerClient(req,10000);
            AppClient.FindCloudletRequest findCloudletRequest = me.createDefaultFindCloudletRequest(context, location)
                    .setCarrierName("")
                    .build();
 
            int internalPort = 7776; // This is the un-remapped port of the App definition. See the app's console definition.
            AppClient.FindCloudletReply findCloudletReply = me.findCloudlet(findCloudletRequest, 10000);
            String host = me.getAppConnectionManager().getHost(findCloudletReply, internalPort); // internal port to host lookup.
            int port = me.getAppConnectionManager().getPublicPort(findCloudletReply, internalPort); // internal port to port lookup.
            Site site = new Site(context, NetTest.TestType.CONNECT, 5, host, port);
            netTest.addSite(site);
        } catch (DmeDnsException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            Assert.assertFalse(String.valueOf(e.getStackTrace()), true);
        } catch (NameNotFoundException pmnf) {
            Assert.assertTrue("Missing package manager!", false);
        }
 
        List<Site> sites = netTest.sortedSiteList();
        netTest.testSites(TimeoutMS);
        List<Site> sortedSites = netTest.sortedSiteList();
        for (Site s : sortedSites) {
            Log.i(TAG, "Test average: " + s.average);
        }

Constructor & Destructor Documentation

NetTest()

com.mobiledgex.matchingengine.performancemetrics.NetTest.NetTest

(

)

Constructor for NetTest

Member Function Documentation

bestSite()

Site com.mobiledgex.matchingengine.performancemetrics.NetTest.bestSite

(

)

Best site, from collection. return Site

ConnectAndDisconnect()

long com.mobiledgex.matchingengine.performancemetrics.NetTest.ConnectAndDisconnect

(

Site

site

)

Test and gather stats on site using TCP connection to host.

Parameters

site

Site

Returns

long

ConnectAndDisconnectHostAndPort()

long com.mobiledgex.matchingengine.performancemetrics.NetTest.ConnectAndDisconnectHostAndPort

(

Site

site

)

Create a client and connect/disconnect on a raw TCP server port from a device network Interface.

Parameters

site

(Site)

Returns

long

Ping()

long com.mobiledgex.matchingengine.performancemetrics.NetTest.Ping

(

Site

site

)

Basic ICMP ping. Does not set source network interface, it just pings to see if it is reachable along current default route.

Parameters

site

(Site)

Returns

long

RunNetTest()

void com.mobiledgex.matchingengine.performancemetrics.NetTest.RunNetTest

(

)

Basic utility function to connect and disconnect from any TCP port.

setExecutorService()

ExecutorService com.mobiledgex.matchingengine.performancemetrics.NetTest.setExecutorService

(

ExecutorService

executorService

)

Set the executorService to use if using the async Future versions.

Parameters

executorService

(ExecutorService)

Returns

ExecutorService

sortedSiteList()

List< Site > com.mobiledgex.matchingengine.performancemetrics.NetTest.sortedSiteList

(

)

Copy of sites for gathered performance stats based on default Comparator.

Returns

List<Site>

testSites()

void com.mobiledgex.matchingengine.performancemetrics.NetTest.testSites

(

long

TimeoutMS

)

Gather metrics for sites

testSitesOnExecutor()

void com.mobiledgex.matchingengine.performancemetrics.NetTest.testSitesOnExecutor

(

long

TimeoutMS

)

Parallel gather of sites added to NetTest over on executorService configured in NetTest.