X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=liblttng-ust-java-agent%2Fjava%2Flttng-ust-agent-common%2Forg%2Flttng%2Fust%2Fagent%2Fclient%2FSessiondDisableEventCommand.java;h=43ff4026346fa62a8a18ef5d402eda6272d17c8f;hb=5c588ccfbdb647157a678ce4211e6563edb035e3;hp=39d14b0db6e157c6c936c83f5744e51e84bacbbb;hpb=301a3ddb302c9c2767f41f3b47d2f3e8ca8b9067;p=lttng-ust.git diff --git a/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/client/SessiondDisableEventCommand.java b/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/client/SessiondDisableEventCommand.java index 39d14b0d..43ff4026 100644 --- a/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/client/SessiondDisableEventCommand.java +++ b/liblttng-ust-java-agent/java/lttng-ust-agent-common/org/lttng/ust/agent/client/SessiondDisableEventCommand.java @@ -21,8 +21,6 @@ package org.lttng.ust.agent.client; import java.nio.ByteBuffer; import java.nio.ByteOrder; -import org.lttng.ust.agent.AbstractLttngAgent; - /** * Session daemon command indicating to the Java agent that some events were * disabled in the tracing session. @@ -30,7 +28,7 @@ import org.lttng.ust.agent.AbstractLttngAgent; * @author Alexandre Montplaisir * @author David Goulet */ -class SessiondDisableEventCommand implements ISessiondCommand { +class SessiondDisableEventCommand extends SessiondCommand { /** Event name to disable from the tracing session */ private final String eventName; @@ -40,13 +38,24 @@ class SessiondDisableEventCommand implements ISessiondCommand { throw new IllegalArgumentException(); } ByteBuffer buf = ByteBuffer.wrap(data); - buf.order(ByteOrder.LITTLE_ENDIAN); - eventName = new String(data).trim(); + buf.order(ByteOrder.BIG_ENDIAN); + eventName = new String(data, SESSIOND_PROTOCOL_CHARSET).trim(); } @Override - public ILttngAgentResponse execute(AbstractLttngAgent agent) { + public LttngAgentResponse execute(ILttngTcpClientListener agent) { boolean success = agent.eventDisabled(this.eventName); - return (success ? ILttngAgentResponse.SUCESS_RESPONSE : ILttngAgentResponse.FAILURE_RESPONSE); + return (success ? LttngAgentResponse.SUCESS_RESPONSE : DISABLE_EVENT_FAILURE_RESPONSE); } + + /** + * Response sent when the disable-event command asks to disable an + * unknown event. + */ + private static final LttngAgentResponse DISABLE_EVENT_FAILURE_RESPONSE = new LttngAgentResponse() { + @Override + public ReturnCode getReturnCode() { + return ReturnCode.CODE_UNKNOWN_LOGGER_NAME; + } + }; }