com.mapd.parser.server.test.TestMapDServer Class Reference

Collaboration diagram for com.mapd.parser.server.test.TestMapDServer:

Classes
class	ConnInfo

Public Member Functions
void	testThreadedCall ()

Private Member Functions
void	randomMapDCall (ConnInfo conn)
ConnInfo	createMapDConnection ()
void	executeQuery (ConnInfo conn, String query, int resultCount)
void	closeMapDConnection (ConnInfo conn)

Private Attributes
volatile int	threadsRun = 0
volatile boolean	threadHadFailure = false
volatile AssertionError	ae

Static Private Attributes
static final Logger	MAPDLOGGER = LoggerFactory.getLogger(TestMapDServer.class)
static final int	TEST_THREAD_COUNT = 2
static CalciteServerWrapper	csw = null

Detailed Description

Definition at line 40 of file TestMapDServer.java.

Member Function Documentation

void com.mapd.parser.server.test.TestMapDServer.closeMapDConnection ( ConnInfo  conn )

inlineprivate

Definition at line 140 of file TestMapDServer.java.

References Testing.fail.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

                                                  {
    try {
      conn.client.disconnect(conn.session);
      conn.transport.close();
    } catch (TException x) {
      fail("Exception on close occurred " + x.toString());
    }
  }

Here is the caller graph for this function:

ConnInfo com.mapd.parser.server.test.TestMapDServer.createMapDConnection ( )

inlineprivate

Definition at line 110 of file TestMapDServer.java.

References Testing.fail, and Experimental.String.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

                                          {
    String session = null;
    TTransport transport = null;
    MapD.Client client = null;
    try {
      transport = new TSocket("localhost", 6274);
      transport.open();
      TProtocol protocol = new TBinaryProtocol(transport);
      client = new MapD.Client(protocol);
      session = client.connect("admin", "HyperInteractive", "omnisci");
    } catch (TException x) {
      fail("Exception on create occurred " + x.toString());
    }
    return new ConnInfo(session, transport, client);
  }

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestMapDServer.executeQuery ( ConnInfo  conn, String  query, int  resultCount  )

inlineprivate

Definition at line 126 of file TestMapDServer.java.

References Testing.fail, and run_benchmark_import.res.

Referenced by com.mapd.parser.server.test.TestMapDServer.randomMapDCall().

                                                                          {
    try {
      TQueryResult res = conn.client.sql_execute(conn.session, query, true, null, -1, -1);
      if (resultCount != res.row_set.columns.get(0).nulls.size()) {
        fail("result doesn't match " + resultCount
                + " != " + res.row_set.columns.get(0).nulls.size());
      }
    } catch (TMapDException x) {
      fail("Exception on EXECUTE " + x.toString());
    } catch (TException x) {
      fail("Exception on EXECUTE " + x.toString());
    }
  }

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestMapDServer.randomMapDCall ( ConnInfo  conn )

inlineprivate

Definition at line 97 of file TestMapDServer.java.

References com.mapd.parser.server.test.TestMapDServer.executeQuery().

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

                                             {
    Random r = new Random();
    int aliasID = r.nextInt(100000) + 1000000;
    int limit = r.nextInt(20) + 1;
    // executeQuery(conn, String.format("Select TABALIAS%d.dest_lon AS COLALIAS%d
    // from
    // flights TABALIAS%d LIMIT %d",
    // aliasID, aliasID, aliasID, limit), limit);
    executeQuery(conn,
            "SELECT date_trunc(day, arr_timestamp) as key0,CASE when carrier_name IN ('Southwest Airlines','American Airlines','Skywest Airlines','American Eagle Airlines','US Airways') then carrier_name ELSE 'other' END as key1,COUNT(*) AS val FROM flights_2008_7m WHERE (arr_timestamp >= TIMESTAMP(0) '2008-01-01 00:57:00' AND arr_timestamp < TIMESTAMP(0) '2009-01-01 18:27:00') GROUP BY key0, key1 ORDER BY key0,key1",
            2202);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestMapDServer.testThreadedCall ( )

inline

Definition at line 49 of file TestMapDServer.java.

References com.mapd.parser.server.test.TestMapDServer.ae, com.mapd.parser.server.test.TestMapDServer.closeMapDConnection(), com.mapd.parser.server.test.TestMapDServer.createMapDConnection(), com.mapd.parser.server.test.TestMapDServer.randomMapDCall(), run, com.mapd.parser.server.test.TestMapDServer.TEST_THREAD_COUNT, com.mapd.parser.server.test.TestMapDServer.threadHadFailure, and com.mapd.parser.server.test.TestMapDServer.threadsRun.

                                 {
    final ExecutorService pool = Executors.newFixedThreadPool(TEST_THREAD_COUNT);

    Runnable r = new Runnable() {
      @Override
      public void run() {
        try {
          ConnInfo conn = createMapDConnection();
          Random r = new Random();
          int calCount = r.nextInt(9) + 1;
          int calls = 0;
          for (int i = 1; i <= 100; i++) {
            // if (i%100 == 0){
            System.out.println("i is " + i);
            // }
            if (calls > calCount) {
              closeMapDConnection(conn);
              conn = createMapDConnection();
              calCount = r.nextInt(9) + 1;
              calls = 0;
            }
            randomMapDCall(conn);
            calls++;
          }
          closeMapDConnection(conn);
        } catch (AssertionError x) {
          MAPDLOGGER.error("error during Runnable");
          threadHadFailure = true;
          ae = x;
        }
        threadsRun++;
        if (threadsRun >= TEST_THREAD_COUNT) {
          pool.shutdown();
        }
      }
    };

    for (int i = 0; i < TEST_THREAD_COUNT; i++) {
      pool.submit(r);
    }
    while (!pool.isShutdown()) {
      // stay alive
    }
    if (threadHadFailure) {
      throw ae;
    }
  }

Here is the call graph for this function:

Member Data Documentation

volatile AssertionError com.mapd.parser.server.test.TestMapDServer.ae

private

Definition at line 45 of file TestMapDServer.java.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

CalciteServerWrapper com.mapd.parser.server.test.TestMapDServer.csw = null

staticprivate

Definition at line 46 of file TestMapDServer.java.

final Logger com.mapd.parser.server.test.TestMapDServer.MAPDLOGGER = LoggerFactory.getLogger(TestMapDServer.class)

staticprivate

Definition at line 41 of file TestMapDServer.java.

final int com.mapd.parser.server.test.TestMapDServer.TEST_THREAD_COUNT = 2

staticprivate

Definition at line 42 of file TestMapDServer.java.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

volatile boolean com.mapd.parser.server.test.TestMapDServer.threadHadFailure = false

private

Definition at line 44 of file TestMapDServer.java.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

volatile int com.mapd.parser.server.test.TestMapDServer.threadsRun = 0

private

Definition at line 43 of file TestMapDServer.java.

Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/test/java/com/mapd/parser/server/test/TestMapDServer.java