Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

upgraded persistence service

Browse Source
This commit is contained in:
Timo Bejan 2021-10-07 11:22:17 +03:00
parent 733007ccb3
commit dc047675f1
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/scheduler/AutomaticAnalysisScheduler.java
View File

@ -41,12 +41,13 @@ public class AutomaticAnalysisScheduler {
// only 1 file in queue // only 1 file in queue
if (redactionQueueInfo.getMessageCount() <= 1) { if (redactionQueueInfo.getMessageCount() <= 1) {
// queue up 5 files // queue up 5 files
var allStatuses = getAllStatuses().iterator(); var allStatuses= getAllStatuses();
var allStatusesIterator = allStatuses.iterator();
int queuedCount = 0; int queuedCount = 0;
log.info("Files that require reanalysis: {}", allStatuses); log.info("Files that require reanalysis: {}", allStatuses.size());
while (queuedCount < 5 && allStatuses.hasNext()) { while (queuedCount < 5 && allStatusesIterator.hasNext()) {
var next = allStatuses.next(); var next = allStatusesIterator.next();
if (next.isAnalysisRequired()) { if (next.isAnalysisRequired()) {
queuedCount += 1; queuedCount += 1;
log.info("Queued file: {} for automatic analysis!", next.getFilename()); log.info("Queued file: {} for automatic analysis!", next.getFilename());