X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=liblttng-ust-java-agent%2Fjava%2Flttng-ust-agent-common%2Forg%2Flttng%2Fust%2Fagent%2FAbstractLttngAgent.java;fp=liblttng-ust-java-agent%2Fjava%2Flttng-ust-agent-common%2Forg%2Flttng%2Fust%2Fagent%2FAbstractLttngAgent.java;h=8531eaec7c3b8ddab23f0b7aa1e668ffc3376124;hb=4fb826b158cbd2cea8f4a91457f49417c261777d;hp=ef3b1dbe9afddddd5922a0e91d9999254c40209e;hpb=3daf5cba66edbd7d8b608be1372a1665189b3c67;p=lttng-ust.git

diff --git a/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/AbstractLttngAgent.java b/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/AbstractLttngAgent.java
index ef3b1dbe..8531eaec 100644
--- a/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/AbstractLttngAgent.java
+++ b/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/AbstractLttngAgent.java
@@ -30,6 +30,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 import org.lttng.ust.agent.client.ILttngTcpClientListener;
 import org.lttng.ust.agent.client.LttngTcpSessiondClient;
+import org.lttng.ust.agent.filter.FilterChangeNotifier;
 import org.lttng.ust.agent.session.EventRule;
 
 /**
@@ -191,6 +192,9 @@ public abstract class AbstractLttngAgent<T extends ILttngHandler>
 
 	@Override
 	public boolean eventEnabled(EventRule eventRule) {
+		/* Notify the filter change manager of the command */
+		FilterChangeNotifier.getInstance().addEventRule(eventRule);
+
 		String eventName = eventRule.getEventName();
 
 		if (eventName.equals(WILDCARD)) {
@@ -208,6 +212,9 @@ public abstract class AbstractLttngAgent<T extends ILttngHandler>
 
 	@Override
 	public boolean eventDisabled(String eventName) {
+		/* Notify the filter change manager of the command */
+		FilterChangeNotifier.getInstance().removeEventRules(eventName);
+
 		if (eventName.equals(WILDCARD)) {
 			int newCount = enabledWildcards.decrementAndGet();
 			if (newCount < 0) {