Function runTestQueries

be/src/service/internal-server-test.cc:475–491

Helper function for the SimultaneousMultipleQueriesOneSession test. Intended to be run as part of a separate thread.

// Helper function for the SimultaneousMultipleQueriesOneSession test. Intended to be run
// as part of a separate thread.
void runTestQueries(const int thread_num, InternalServer* server,
    const DatabaseTest* const db_test, const TUniqueId* session_id) {
  const int queries_to_run = 100;

  TUniqueId query_id;

  for (int i=0; i<queries_to_run; i++) {
    int cat = i % db_test->GetCategoryCount();
    ASSERT_OK(server->SubmitQuery(StrCat("select * from ", db_test->GetTableName(),
        " where category=", cat, " --thread '", thread_num, "' query '", i, "'"),
        *session_id, query_id));
    ASSERT_OK(server->WaitForResults(query_id));
    server->CloseQuery(query_id);

    assertQueryState(query_id, QUERY_STATE_SUCCESS);
  }
} // runTestQueries

TEST(InternalServerTest, SimultaneousMultipleQueriesOneSession) {
  const int test_threads = 10;