Inheritance diagram for com.mapd.tests.ConcurrencyTest.SqlCommandThread:

Collaboration diagram for com.mapd.tests.ConcurrencyTest.SqlCommandThread:

Public Member Functions
void	run ()

Package Functions
	SqlCommandThread (final String threadName, final List< String > queries, int threadId, int port, int iterations, final List< String > exceptions, final List< String > cleanUpQueries)

	SqlCommandThread (final String threadName, final List< String > queries, int threadId, final List< String > exceptions, final List< String > cleanUpQueries)

Package Attributes
final List< String >	queries

final List< String >	expectedExceptionTexts

final List< String >	cleanUpQueries

final String	threadName

final int	port

final int	iterations

final int	threadId

Detailed Description

Definition at line 230 of file ConcurrencyTest.java.

Constructor & Destructor Documentation

com.mapd.tests.ConcurrencyTest.SqlCommandThread.SqlCommandThread	(	final String	threadName,
		final List< String >	queries,
		int	threadId,
		int	port,
		int	iterations,
		final List< String >	exceptions,
		final List< String >	cleanUpQueries
	)

inlinepackage

Definition at line 235 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.SqlCommandThread.cleanUpQueries, com.mapd.tests.ConcurrencyTest.SqlCommandThread.iterations, com.mapd.tests.ConcurrencyTest.SqlCommandThread.port, com.mapd.tests.ConcurrencyTest.SqlCommandThread.queries, and com.mapd.tests.ConcurrencyTest.SqlCommandThread.threadId.

                                                {
       this.queries = queries;
       this.port = port;
       this.iterations = iterations;
       this.threadId = threadId;
       this.threadName = threadName + "[" + port + "][" + threadId + "]";
       this.expectedExceptionTexts = exceptions;
       this.cleanUpQueries = cleanUpQueries;
     }

com.mapd.tests.ConcurrencyTest.SqlCommandThread.SqlCommandThread	(	final String	threadName,
		final List< String >	queries,
		int	threadId,
		final List< String >	exceptions,
		final List< String >	cleanUpQueries
	)

inlinepackage

Definition at line 251 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.SqlCommandThread.cleanUpQueries, com.mapd.tests.ConcurrencyTest.getRandomPort(), com.mapd.tests.ConcurrencyTest.numIterations, com.mapd.tests.ConcurrencyTest.SqlCommandThread.queries, com.mapd.tests.ConcurrencyTest.SqlCommandThread.threadId, and com.mapd.tests.ConcurrencyTest.SqlCommandThread.threadName.

                                                {
       this(threadName,
               queries,
               threadId,
               getRandomPort(),
               numIterations,
               exceptions,
               cleanUpQueries);
     }

Here is the call graph for this function:

Member Function Documentation

void com.mapd.tests.ConcurrencyTest.SqlCommandThread.run ( )

inline

Definition at line 266 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.db, com.mapd.tests.ConcurrencyTest.SqlCommandThread.expectedExceptionTexts, com.mapd.tests.ConcurrencyTest.SqlCommandThread.iterations, com.mapd.tests.ConcurrencyTest.localhost, com.mapd.tests.ConcurrencyTest.password, com.mapd.tests.ConcurrencyTest.SqlCommandThread.port, com.mapd.tests.ConcurrencyTest.SqlCommandThread.queries, com.mapd.tests.ConcurrencyTest.SqlCommandThread.threadName, and com.mapd.tests.ConcurrencyTest.userName.

                       {
       logger.info("  Starting: " + threadName);
       try {
         HeavyDBTestClient user =
                 HeavyDBTestClient.getClient(localhost, port, db, userName, password);
         barrier.await(); // Synch point.
         for (int iteration = 0; iteration < iterations; ++iteration) {
           for (String query : queries) {
             logger.info("  " + threadName + "[" + iteration + "]: " + query);
             try {
               user.runSql(query);
             } catch (TDBException e) {
               boolean foundExpected = false;
               for (String exceptionText : expectedExceptionTexts) {
                 if (e.error_msg.contains(exceptionText)) {
                   foundExpected = true;
                 }
               }
               if (!foundExpected) {
                 throw e;
               }
             }
           }
         }
       } catch (TDBException e) {
         logger.error("  " + threadName + ": caught exception - " + e.error_msg);
         exceptionTexts.add(threadName + ": " + e.error_msg);
       } catch (Exception e) {
         logger.error("  " + threadName + ": caught exception - " + e.getMessage());
         exceptionTexts.add(threadName + ": " + e.getMessage());
       }
       logger.info("  Finished: " + threadName);
     }