Skip to content

Commit

Permalink
test2
Browse files Browse the repository at this point in the history
  • Loading branch information
tommystendahl committed Oct 10, 2023
1 parent 13664ac commit c91a7fd
Showing 1 changed file with 15 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public class ITVerifyThreadedAudit
{
private final static String UUID_REGEX = "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}";

private static final int USER_COUNT = 1;
private static final int USER_COUNT = 5;

private static CassandraDaemonForAuditTest cdt;

Expand Down Expand Up @@ -132,20 +132,20 @@ public void testValidPreparedStatementsAreLogged() throws Exception
jobResults.add(executorService.submit(new PreparedStatementClient("user" + i)));
}

// for (int i = 0; i < USER_COUNT; i++)
// {
// jobResults.add(executorService.submit(new BatchStatementClient("user" + i)));
// }
//
// for (int i = 0; i < USER_COUNT; i++)
// {
// jobResults.add(executorService.submit(new NonPreparedBatchStatementClient("user" + i)));
// }
//
// for (int i = 0; i < USER_COUNT; i++)
// {
// jobResults.add(executorService.submit(new PreparedBatchStatementClient("user" + i)));
// }
for (int i = 0; i < USER_COUNT; i++)
{
jobResults.add(executorService.submit(new BatchStatementClient("user" + i)));
}

for (int i = 0; i < USER_COUNT; i++)
{
jobResults.add(executorService.submit(new NonPreparedBatchStatementClient("user" + i)));
}

for (int i = 0; i < USER_COUNT; i++)
{
jobResults.add(executorService.submit(new PreparedBatchStatementClient("user" + i)));
}

List<String> expectedAttempts = new ArrayList<>();
for (Future<List<String>> jobResult : jobResults)
Expand Down

0 comments on commit c91a7fd

Please sign in to comment.