X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=liblttng-ust-jul%2Forg%2Flttng%2Fust%2Fjul%2FLTTngTCPSessiondClient.java;h=0c2cb48f1b92e3eb8c590b6debf67648cee7ad71;hb=529e6def5152664150912edbb3a01630f83b1ef2;hp=b89deb818c4702514d86842570abf9a9aac16dcd;hpb=7d73d7ced8c978e2a3bc94e71c322ac2548b2db3;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 b89deb81..0c2cb48f 100644 --- a/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java +++ b/liblttng-ust-jul/org/lttng/ust/jul/LTTngTCPSessiondClient.java @@ -29,9 +29,11 @@ import java.io.DataInputStream; import java.net.*; import java.lang.management.ManagementFactory; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; import java.util.Timer; import java.util.TimerTask; +import java.util.logging.Logger; class USTRegisterMsg { public static int pid; @@ -56,6 +58,10 @@ public class LTTngTCPSessiondClient { private Timer eventTimer; private List enabledEventList = new ArrayList(); + /* + * Map of Logger objects that have been enabled. They are indexed by name. + */ + private HashMap enabledLoggers = new HashMap(); /* Timer delay at each 5 seconds. */ private final static long timerDelay = 5 * 1000; private static boolean timerInitialized; @@ -85,8 +91,22 @@ public class LTTngTCPSessiondClient { LTTngSessiondCmd2_4.sessiond_enable_handler enableCmd = new LTTngSessiondCmd2_4.sessiond_enable_handler(); for (String strEventName: tmpList) { + /* + * Check if this Logger name has been enabled already. Note + * that in the case of "*", it's never added in that hash + * table thus the enable command does a lookup for each + * logger name in that hash table for the * case in order + * to make sure we don't enable twice the same logger + * because JUL apparently accepts that the *same* + * LogHandler can be added twice on a Logger object... + * don't ask... + */ + if (enabledLoggers.get(strEventName) != null) { + continue; + } + enableCmd.name = strEventName; - if (enableCmd.execute(handler) == null) { + if (enableCmd.execute(handler, enabledLoggers) == null) { enabledEventList.remove(strEventName); } } @@ -220,13 +240,15 @@ public class LTTngTCPSessiondClient { break; } enableCmd.populate(data); - event_name = enableCmd.execute(this.handler); + event_name = enableCmd.execute(this.handler, this.enabledLoggers); if (event_name != null) { /* * Add the event to the list so it can be enabled if * the logger appears at some point in time. */ - enabledEventList.add(event_name); + if (enabledEventList.contains(event_name) == false) { + enabledEventList.add(event_name); + } } data = enableCmd.getBytes(); break;