Fixed unnecessary database transactions when consumer is empty (fixes #…

…511)
PlayPro · May 11, 2024 · e61b8a4 · e61b8a4
1 parent 3b9d872
commit e61b8a4
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/main/java/net/coreprotect/consumer/process/Process.java b/src/main/java/net/coreprotect/consumer/process/Process.java
@@ -83,6 +83,14 @@ protected static void processConsumer(int processId, boolean lastRun) {
             int consumerDataSize = consumerData.size();
             currentConsumerSize = consumerDataSize;
 
+            if (currentConsumerSize == 0) { // No data, skip processing
+                updateLockTable(statement, (lastRun ? 0 : 1));
+                statement.close();
+                Consumer.consumer_id.put(processId, new Integer[] { 0, 0 });
+                Consumer.isPaused = false;
+                return;
+            }
+
             Database.beginTransaction(statement);
             // Scan through usernames, ensure everything is loaded in memory.
             for (Entry<Integer, String[]> entry : users.entrySet()) {
@@ -225,6 +233,7 @@ protected static void processConsumer(int processId, boolean lastRun) {
                                     consumerData.remove(index);
                                 }
                                 currentConsumerSize = 0;
+                                Consumer.consumer_id.put(processId, new Integer[] { 0, 0 });
                                 Consumer.isPaused = false;
                                 return;
                             }