zervo/seb-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improved event log batch processing

Browse source
This commit is contained in:
anhefti 2021-03-04 13:48:16 +01:00
parent 2f8913f129
commit 53a9710ec8
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/AsyncBatchEventSaveStrategy.java
View file

@ -59,6 +59,9 @@ public class AsyncBatchEventSaveStrategy implements EventHandlingStrategy {
private static final int NUMBER_OF_WORKER_THREADS = 4; private static final int NUMBER_OF_WORKER_THREADS = 4;
private static final int BATCH_SIZE = 100; private static final int BATCH_SIZE = 100;
private static final int MIN_SLEEP_TIME = 100;
private static final int SLEEP_TIME_EXPAND = 100;
private static final int MAX_SLEEP_TIME = 5000;
private final SqlSessionFactory sqlSessionFactory; private final SqlSessionFactory sqlSessionFactory;
private final Executor executor; private final Executor executor;
@ -150,7 +153,7 @@ public class AsyncBatchEventSaveStrategy implements EventHandlingStrategy {
try { try {
if (!events.isEmpty()) { if (!events.isEmpty()) {
sleepTime = 100; sleepTime = MIN_SLEEP_TIME;
this.transactionTemplate this.transactionTemplate
.execute(status -> { .execute(status -> {
events.forEach(clientEventMapper::insert); events.forEach(clientEventMapper::insert);
@ -158,8 +161,8 @@ public class AsyncBatchEventSaveStrategy implements EventHandlingStrategy {
}); });
sqlSessionTemplate.flushStatements(); sqlSessionTemplate.flushStatements();
} else { } else if (sleepTime < MAX_SLEEP_TIME) {
sleepTime += 100; sleepTime += SLEEP_TIME_EXPAND;
} }
} catch (final Exception e) { } catch (final Exception e) {
log.error("unexpected Error while trying to batch store client-events: ", e); log.error("unexpected Error while trying to batch store client-events: ", e);