0005823: Capture timings when running Sync Triggers

JumpMind · May 9, 2023 · 3e80a4d · 3e80a4d
1 parent ae05f77
commit 3e80a4d
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
@@ -1566,11 +1566,16 @@ protected void inactivateTriggers(final List<Trigger> triggersThatShouldBeActive
                 public void run() {
                     MDC.put("engineName", parameterService.getEngineName());
                     boolean removeTrigger = false;
-                    Set<Table> tables = tablesByTriggerId.get(history.getTriggerId());
+                    Set<Table> tables;
+                    synchronized(tablesByTriggerId) {
+                        tables = tablesByTriggerId.get(history.getTriggerId());
+                    }
                     Trigger trigger = getTriggerFromList(history.getTriggerId(), triggersThatShouldBeActive);
                     if (tables == null && trigger != null) {
-                        tables = getTablesForTrigger(trigger, triggersThatShouldBeActive, false, triggerRouterContext);
-                        tablesByTriggerId.put(trigger.getTriggerId(), tables);
+                        tables = getTablesForTrigger(trigger, triggersThatShouldBeActive, true, triggerRouterContext);
+                        synchronized(tablesByTriggerId) {
+                            tablesByTriggerId.put(trigger.getTriggerId(), tables);
+                        }
                     }
                     if (tables == null || tables.size() == 0 || trigger == null) {
                         removeTrigger = true;