Inheritance diagram for com.mapd.tests.ConcurrencyTest:

Collaboration diagram for com.mapd.tests.ConcurrencyTest:

Classes
class	MonitoringThread

class	SqlCommandThread

Public Member Functions
abstract List< SqlCommandThread[]>	createTestThreads ()

abstract void	runTests (final List< SqlCommandThread[]> tests) throws Exception

abstract void	setUpTests () throws Exception

abstract void	cleanUpTests (final List< SqlCommandThread[]> tests) throws Exception

void	testConcurrency () throws Exception

HeavyDBTestClient	getAdminClient (String db) throws Exception

void	runAndLog (HeavyDBTestClient client, String sql) throws Exception

Static Public Member Functions
static boolean	deleteDirectory (File dir)

static int[]	getPorts ()

static int	getNumThreads ()

static int	getNumIterations ()

static boolean	getEnableHeavyConnect ()

static boolean	getEnableMonitorThread ()

static String	getConfig ()

static CyclicBarrier	createBarrier (int numThreadsToWait)

static void	printErrors (ArrayList< String > exceptionTexts)

static int	getRandomPort ()

Public Attributes
CyclicBarrier	barrier

ArrayList< String >	exceptionTexts = new ArrayList<String>()

Static Public Attributes
static final String	db = "TestDB"

static final int	defaultPort = 6274

static final boolean	defaultEnableHeavyConnect = true

static int	numThreads = defaultNumThreads

static boolean	enableHeavyConnect = defaultEnableHeavyConnect

static Logger	logger = null

static String	testName = ""

static int[]	ports = null

Static Package Attributes
static final String	userName = "admin"

static final String	password = "HyperInteractive"

static final String	localhost = "localhost"

static final String	defaultDb = "heavyai"

static final int	defaultNumThreads = 5

static final int	defaultNumIterations = 5

static final boolean	defaultEnableMonitorThread = false

static int	numIterations = defaultNumIterations

static boolean	enableMonitorThread = defaultEnableMonitorThread

static Random	rand = new Random()

Detailed Description

Definition at line 33 of file ConcurrencyTest.java.

Member Function Documentation

abstract void com.mapd.tests.ConcurrencyTest.cleanUpTests ( final List< SqlCommandThread[]> tests ) throws Exception

pure virtual

Implemented in com.mapd.tests.DdlConcurrencyTest.

Referenced by com.mapd.tests.ConcurrencyTest.testConcurrency().

Here is the caller graph for this function:

static CyclicBarrier com.mapd.tests.ConcurrencyTest.createBarrier ( int numThreadsToWait )

inlinestatic

Definition at line 141 of file ConcurrencyTest.java.

References run.

Referenced by com.mapd.tests.DdlConcurrencyTest.runTests().

                                                                   {
     return new CyclicBarrier(numThreadsToWait, new Runnable() {
       @Override
       public void run() {
         logger.info("Threads Synched");
       }
     });
   }

Here is the caller graph for this function:

abstract List<SqlCommandThread[]> com.mapd.tests.ConcurrencyTest.createTestThreads ( )

pure virtual

Implemented in com.mapd.tests.DdlConcurrencyTest.

Referenced by com.mapd.tests.ConcurrencyTest.testConcurrency().

Here is the caller graph for this function:

static boolean com.mapd.tests.ConcurrencyTest.deleteDirectory ( File dir )

inlinestatic

Definition at line 56 of file ConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.cleanUpTests().

                                                   {
     File[] files = dir.listFiles();
     if (files != null) {
       for (File file : files) {
         deleteDirectory(file);
       }
     }
     return dir.delete();
   }

Here is the caller graph for this function:

HeavyDBTestClient com.mapd.tests.ConcurrencyTest.getAdminClient ( String db ) throws Exception

inline

Definition at line 187 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.db, com.mapd.tests.ConcurrencyTest.localhost, com.mapd.tests.ConcurrencyTest.password, com.mapd.tests.ConcurrencyTest.ports, and com.mapd.tests.ConcurrencyTest.userName.

Referenced by com.mapd.tests.DdlConcurrencyTest.cleanUpTests(), and com.mapd.tests.DdlConcurrencyTest.setUpTests().

                                                                       {
     return HeavyDBTestClient.getClient(localhost, ports[0], db, userName, password);
   }

Here is the caller graph for this function:

static String com.mapd.tests.ConcurrencyTest.getConfig ( )

inlinestatic

Definition at line 129 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.enableHeavyConnect, com.mapd.tests.ConcurrencyTest.enableMonitorThread, com.mapd.tests.ConcurrencyTest.numIterations, com.mapd.tests.ConcurrencyTest.numThreads, com.mapd.tests.ConcurrencyTest.ports, and com.mapd.tests.ConcurrencyTest.testName.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                    {
     String log = "Config for " + testName + ":\n{\n  ports = {\n";
     for (int port : ports) {
       log += "    " + port + "\n";
     }
     log += "  }\n  num_threads = " + numThreads + "\n  num_iterations = " + numIterations
             + "\n  enable_heavy_connect = " + enableHeavyConnect
             + "\n  enable_monitor_thread = " + enableMonitorThread + "\n}";
     return log;
   }

Here is the caller graph for this function:

static boolean com.mapd.tests.ConcurrencyTest.getEnableHeavyConnect ( )

inlinestatic

Definition at line 108 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.defaultEnableHeavyConnect.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                                 {
     String propertyString = System.getProperty("ENABLE_HEAVY_CONNECT");
     if (propertyString == null) {
       return defaultEnableHeavyConnect;
     } else {
       return Boolean.parseBoolean(propertyString);
     }
   }

Here is the caller graph for this function:

static boolean com.mapd.tests.ConcurrencyTest.getEnableMonitorThread ( )

inlinestatic

Definition at line 119 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.defaultEnableMonitorThread.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                                  {
     String propertyString = System.getProperty("ENABLE_MONITOR_THREAD");
     if (propertyString == null) {
       return defaultEnableMonitorThread;
     } else {
       return Boolean.parseBoolean(propertyString);
     }
   }

Here is the caller graph for this function:

static int com.mapd.tests.ConcurrencyTest.getNumIterations ( )

inlinestatic

Definition at line 98 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.defaultNumIterations.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                        {
     String propertyString = System.getProperty("NUM_ITERATIONS");
     if (propertyString == null) {
       return defaultNumIterations;
     } else {
       return Integer.parseInt(propertyString);
     }
   }

Here is the caller graph for this function:

static int com.mapd.tests.ConcurrencyTest.getNumThreads ( )

inlinestatic

Definition at line 88 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.defaultNumThreads.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                     {
     String propertyString = System.getProperty("NUM_THREADS");
     if (propertyString == null) {
       return defaultNumThreads;
     } else {
       return Integer.parseInt(propertyString);
     }
   }

Here is the caller graph for this function:

static int [] com.mapd.tests.ConcurrencyTest.getPorts ( )

inlinestatic

Definition at line 69 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.defaultPort.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

                                  {
     String portString = System.getProperty("PORT_LIST");
     int[] retPorts;
     if (portString != null) {
       List<String> portList = Arrays.asList(portString.split(","));
       if (portList.size() > 0) {
         retPorts = new int[portList.size()];
         for (int i = 0; i < portList.size(); ++i) {
           retPorts[i] = Integer.parseInt(portList.get(i));
         }
         return retPorts;
       }
     }
     retPorts = new int[1];
     retPorts[0] = defaultPort;
     return retPorts;
   }

Here is the caller graph for this function:

static int com.mapd.tests.ConcurrencyTest.getRandomPort ( )

inlinestatic

Definition at line 161 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.ports.

Referenced by com.mapd.tests.ConcurrencyTest.SqlCommandThread.SqlCommandThread().

                                     {
     return ports[rand.nextInt(ports.length)];
   }

Here is the caller graph for this function:

static void com.mapd.tests.ConcurrencyTest.printErrors ( ArrayList< String > exceptionTexts )

inlinestatic

Definition at line 151 of file ConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.runTests().

                                                                    {
     if (exceptionTexts.size() > 0) {
       String errors = "\n";
       for (String s : exceptionTexts) {
         errors += s + "\n";
       }
       logger.error("Found exceptions:" + errors);
     }
   }

Here is the caller graph for this function:

void com.mapd.tests.ConcurrencyTest.runAndLog	(	HeavyDBTestClient	client,
		String	sql
	)		throws Exception

inline

Definition at line 191 of file ConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.cleanUpTests(), and com.mapd.tests.DdlConcurrencyTest.setUpTests().

                                                                                {
     client.runSql(sql);
     logger.info("  " + sql);
   }

Here is the caller graph for this function:

abstract void com.mapd.tests.ConcurrencyTest.runTests ( final List< SqlCommandThread[]> tests ) throws Exception

pure virtual

Implemented in com.mapd.tests.DdlConcurrencyTest.

Referenced by com.mapd.tests.ConcurrencyTest.testConcurrency().

Here is the caller graph for this function:

abstract void com.mapd.tests.ConcurrencyTest.setUpTests ( ) throws Exception

pure virtual

Implemented in com.mapd.tests.DdlConcurrencyTest.

Referenced by com.mapd.tests.ConcurrencyTest.testConcurrency().

Here is the caller graph for this function:

void com.mapd.tests.ConcurrencyTest.testConcurrency ( ) throws Exception

inline

Definition at line 172 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.cleanUpTests(), com.mapd.tests.ConcurrencyTest.createTestThreads(), com.mapd.tests.ConcurrencyTest.logger, com.mapd.tests.ConcurrencyTest.runTests(), com.mapd.tests.ConcurrencyTest.setUpTests(), and com.mapd.tests.ConcurrencyTest.testName.

                                                  {
     if (testName.equals("")) {
       throw new RuntimeException("Derived test has not set a test name");
     }
     if (logger == null) {
       throw new RuntimeException("Derived test has not initialized logger");
     }
     logger.info(testName + "()");
     final List<SqlCommandThread[]> tests = createTestThreads();
     setUpTests();
     runTests(tests);
     cleanUpTests(tests);
     logger.info(testName + "() done");
   }