Skip to content

Commit

Permalink
Followup to #3113, remove unused first BatchControl queue
Browse files Browse the repository at this point in the history
  • Loading branch information
rbygrave committed Jun 16, 2023
1 parent ac1b307 commit 870d90d
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,10 +81,10 @@ public final class BatchControl {
*/
private int bufferMax;

private final Queue[] queues = new Queue[3];
private final Queue[] queues = new Queue[2];

static final int DELETE_QUEUE = 1;
static final int INSERT_QUEUE = 2;
static final int DELETE_QUEUE = 0;
static final int INSERT_QUEUE = 1;

/**
* Create for a given transaction, PersistExecute, default size and getGeneratedKeys.
Expand Down Expand Up @@ -268,7 +268,6 @@ public void clear() {
}

private void flushBuffer(boolean reset) throws BatchedSqlException {
flushQueue(queues[0]);
flushInternal(reset);
flushQueue(queues[DELETE_QUEUE]);
flushQueue(queues[INSERT_QUEUE]);
Expand Down

0 comments on commit 870d90d

Please sign in to comment.