Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/CloseInfo.java')
-rw-r--r--jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/CloseInfo.java187
1 files changed, 0 insertions, 187 deletions
diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/CloseInfo.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/CloseInfo.java
deleted file mode 100644
index a56308e4ac..0000000000
--- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/CloseInfo.java
+++ /dev/null
@@ -1,187 +0,0 @@
-//
-// ========================================================================
-// Copyright (c) 1995-2013 Mort Bay Consulting Pty. Ltd.
-// ------------------------------------------------------------------------
-// All rights reserved. This program and the accompanying materials
-// are made available under the terms of the Eclipse Public License v1.0
-// and Apache License v2.0 which accompanies this distribution.
-//
-// The Eclipse Public License is available at
-// http://www.eclipse.org/legal/epl-v10.html
-//
-// The Apache License v2.0 is available at
-// http://www.opensource.org/licenses/apache2.0.php
-//
-// You may elect to redistribute this code under either of these licenses.
-// ========================================================================
-//
-
-package org.eclipse.jetty.websocket.common;
-
-import java.nio.ByteBuffer;
-
-import org.eclipse.jetty.util.StringUtil;
-import org.eclipse.jetty.util.Utf8Appendable.NotUtf8Exception;
-import org.eclipse.jetty.util.Utf8StringBuilder;
-import org.eclipse.jetty.util.log.Log;
-import org.eclipse.jetty.util.log.Logger;
-import org.eclipse.jetty.websocket.api.BadPayloadException;
-import org.eclipse.jetty.websocket.api.ProtocolException;
-import org.eclipse.jetty.websocket.api.StatusCode;
-import org.eclipse.jetty.websocket.api.extensions.Frame;
-
-public class CloseInfo
-{
- private static final Logger LOG = Log.getLogger(CloseInfo.class);
- private int statusCode;
- private String reason;
-
- public CloseInfo()
- {
- this(StatusCode.NO_CODE,null);
- }
-
- public CloseInfo(ByteBuffer payload, boolean validate)
- {
- this.statusCode = StatusCode.NO_CODE;
- this.reason = null;
-
- if ((payload == null) || (payload.remaining() == 0))
- {
- return; // nothing to do
- }
-
- ByteBuffer data = payload.slice();
- if ((data.remaining() == 1) && (validate))
- {
- throw new ProtocolException("Invalid 1 byte payload");
- }
-
- if (data.remaining() >= 2)
- {
- // Status Code
- statusCode = 0; // start with 0
- statusCode |= (data.get() & 0xFF) << 8;
- statusCode |= (data.get() & 0xFF);
-
- if(validate) {
- if ((statusCode < StatusCode.NORMAL) || (statusCode == StatusCode.UNDEFINED) || (statusCode == StatusCode.NO_CLOSE)
- || (statusCode == StatusCode.NO_CODE) || ((statusCode > 1011) && (statusCode <= 2999)) || (statusCode >= 5000))
- {
- throw new ProtocolException("Invalid close code: " + statusCode);
- }
- }
-
- if (data.remaining() > 0)
- {
- // Reason
- try
- {
- Utf8StringBuilder utf = new Utf8StringBuilder();
- utf.append(data);
- reason = utf.toString();
- }
- catch (NotUtf8Exception e)
- {
- if (validate)
- {
- throw new BadPayloadException("Invalid Close Reason",e);
- }
- else
- {
- LOG.warn(e);
- }
- }
- catch (RuntimeException e)
- {
- if (validate)
- {
- throw new ProtocolException("Invalid Close Reason",e);
- }
- else
- {
- LOG.warn(e);
- }
- }
- }
- }
- }
-
- public CloseInfo(Frame frame)
- {
- this(frame.getPayload(),false);
- }
-
- public CloseInfo(Frame frame, boolean validate)
- {
- this(frame.getPayload(),validate);
- }
-
- public CloseInfo(int statusCode)
- {
- this(statusCode, null);
- }
-
- public CloseInfo(int statusCode, String reason)
- {
- this.statusCode = statusCode;
- this.reason = reason;
- }
-
- private byte[] asByteBuffer()
- {
- if ((statusCode == StatusCode.NO_CLOSE) || (statusCode == StatusCode.NO_CODE) || (statusCode == (-1)))
- {
- // codes that are not allowed to be used in endpoint.
- return null;
- }
-
- int len = 2; // status code
- byte utf[] = null;
- if (StringUtil.isNotBlank(reason))
- {
- utf = StringUtil.getUtf8Bytes(reason);
- len += utf.length;
- }
-
- byte buf[] = new byte[len];
- buf[0] = (byte)((statusCode >>> 8) & 0xFF);
- buf[1] = (byte)((statusCode >>> 0) & 0xFF);
-
- if (utf != null)
- {
- System.arraycopy(utf,0,buf,2,utf.length);
- }
-
- return buf;
- }
-
- public WebSocketFrame asFrame()
- {
- WebSocketFrame frame = new WebSocketFrame(OpCode.CLOSE);
- frame.setFin(true);
- frame.setPayload(asByteBuffer());
- return frame;
- }
-
- public String getReason()
- {
- return reason;
- }
-
- public int getStatusCode()
- {
- return statusCode;
- }
-
- public boolean isHarsh()
- {
- return !((statusCode == StatusCode.NORMAL) || (statusCode == StatusCode.NO_CODE));
- }
-
- @Override
- public String toString()
- {
- return String.format("CloseInfo[code=%d,reason=%s]",statusCode,reason);
- }
-}

Back to the top