some generator debug logging
This commit is contained in:
parent
e47c47f071
commit
1899a938d0
|
@ -2,6 +2,8 @@ package org.eclipse.jetty.websocket.generator;
|
||||||
|
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
|
|
||||||
|
import org.eclipse.jetty.util.log.Log;
|
||||||
|
import org.eclipse.jetty.util.log.Logger;
|
||||||
import org.eclipse.jetty.websocket.api.OpCode;
|
import org.eclipse.jetty.websocket.api.OpCode;
|
||||||
import org.eclipse.jetty.websocket.api.PolicyViolationException;
|
import org.eclipse.jetty.websocket.api.PolicyViolationException;
|
||||||
import org.eclipse.jetty.websocket.api.WebSocketPolicy;
|
import org.eclipse.jetty.websocket.api.WebSocketPolicy;
|
||||||
|
@ -33,6 +35,8 @@ import org.eclipse.jetty.websocket.frames.BaseFrame;
|
||||||
*/
|
*/
|
||||||
public abstract class FrameGenerator<T extends BaseFrame>
|
public abstract class FrameGenerator<T extends BaseFrame>
|
||||||
{
|
{
|
||||||
|
private static final Logger LOG = Log.getLogger(FrameGenerator.class);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* The overhead (maximum) for a framing header. Assuming a maximum sized payload with masking key.
|
* The overhead (maximum) for a framing header. Assuming a maximum sized payload with masking key.
|
||||||
*/
|
*/
|
||||||
|
@ -48,6 +52,9 @@ public abstract class FrameGenerator<T extends BaseFrame>
|
||||||
|
|
||||||
public ByteBuffer generate(ByteBuffer buffer, T frame)
|
public ByteBuffer generate(ByteBuffer buffer, T frame)
|
||||||
{
|
{
|
||||||
|
LOG.debug(String.format("Generate.Frame[opcode=%s,fin=%b,cont=%b,rsv1=%b,rsv2=%b,rsv3=%b,mask=%b,plength=%d]",frame.getOpCode().toString(),
|
||||||
|
frame.isFin(),frame.isContinuation(),frame.isRsv1(),frame.isRsv2(),frame.isRsv3(),frame.isMasked(),frame.getPayloadLength()));
|
||||||
|
|
||||||
byte b;
|
byte b;
|
||||||
|
|
||||||
// Setup fin thru opcode
|
// Setup fin thru opcode
|
||||||
|
|
|
@ -3,6 +3,8 @@ package org.eclipse.jetty.websocket.generator;
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
import java.util.EnumMap;
|
import java.util.EnumMap;
|
||||||
|
|
||||||
|
import org.eclipse.jetty.util.log.Log;
|
||||||
|
import org.eclipse.jetty.util.log.Logger;
|
||||||
import org.eclipse.jetty.websocket.api.OpCode;
|
import org.eclipse.jetty.websocket.api.OpCode;
|
||||||
import org.eclipse.jetty.websocket.api.WebSocketPolicy;
|
import org.eclipse.jetty.websocket.api.WebSocketPolicy;
|
||||||
import org.eclipse.jetty.websocket.frames.BaseFrame;
|
import org.eclipse.jetty.websocket.frames.BaseFrame;
|
||||||
|
@ -31,7 +33,10 @@ import org.eclipse.jetty.websocket.frames.BaseFrame;
|
||||||
* +---------------------------------------------------------------+
|
* +---------------------------------------------------------------+
|
||||||
* </pre>
|
* </pre>
|
||||||
*/
|
*/
|
||||||
public class Generator {
|
public class Generator
|
||||||
|
{
|
||||||
|
private static final Logger LOG = Log.getLogger(Generator.class);
|
||||||
|
|
||||||
private final EnumMap<OpCode, FrameGenerator<?>> generators = new EnumMap<>(OpCode.class);
|
private final EnumMap<OpCode, FrameGenerator<?>> generators = new EnumMap<>(OpCode.class);
|
||||||
|
|
||||||
public Generator(WebSocketPolicy policy)
|
public Generator(WebSocketPolicy policy)
|
||||||
|
@ -48,6 +53,7 @@ public class Generator {
|
||||||
public ByteBuffer generate(ByteBuffer buffer, BaseFrame frame)
|
public ByteBuffer generate(ByteBuffer buffer, BaseFrame frame)
|
||||||
{
|
{
|
||||||
FrameGenerator generator = generators.get(frame.getOpCode());
|
FrameGenerator generator = generators.get(frame.getOpCode());
|
||||||
|
LOG.debug(generator.getClass().getSimpleName() + " active");
|
||||||
return generator.generate(buffer,frame);
|
return generator.generate(buffer,frame);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue