X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=liblttng-ust-jul%2Forg%2Flttng%2Fust%2Fjul%2FLTTngTCPSessiondClient.java;h=5fdb04986c6c6f8ab2b6147ad83c43f1adddd12d;hb=b49957330f2fe80e872a5a3ceed0d0d07364cf08;hp=f3ac80dc6e78860ae8ae4fb72cfb182da65a445d;hpb=025907937f0f5aa689385a575e8cebb7e9381a1e;p=lttng-ust.git

diff --git a/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java b/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java
index f3ac80dc..5fdb0498 100644
--- a/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java
+++ b/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java
@@ -186,6 +186,17 @@ public class LTTngTCPSessiondClient {
 		}
 	}
 
+	/*
+	 * Cleanup Agent state.
+	 */
+	private void cleanupState() {
+		enabledEventSet.clear();
+		enabledLoggers.clear();
+		if (this.handler != null) {
+			this.handler.clear();
+		}
+	}
+
 	public void init(LTTngLogHandler handler) throws InterruptedException {
 		this.handler = handler;
 
@@ -194,6 +205,9 @@ public class LTTngTCPSessiondClient {
 				break;
 			}
 
+			/* Cleanup Agent state before trying to connect or reconnect. */
+			cleanupState();
+
 			try {
 
 				/*