taichi · December 15, 2015 10:49
diff --git a/index.html b/index.html
 <html><head>
    <title>WebSocket Chat</title>
    <script type='text/javascript'>

      if (!window.WebSocket && window.MozWebSocket)
        window.WebSocket=window.MozWebSocket;
      if (!window.WebSocket)
        alert("WebSocket not supported by this browser");
    
      function $() { return document.getElementById(arguments[0]); }
      function $F() { return document.getElementById(arguments[0]).value; }
      
      function getKeyCode(ev) { if (window.event) return window.event.keyCode; return ev.keyCode; } 
      
      var room = {
        join: function(name) {
          this._username=name;
          var location = document.location.toString().replace('http://','ws://').replace('https://','wss://');
          this._ws=new WebSocket(location,"echo-broadcast-ping");
          this._ws.onopen=this._onopen;
          this._ws.onmessage=this._onmessage;
          this._ws.onclose=this._onclose;
        },
        
        _onopen: function(){
          $('join').className='hidden';
          $('joined').className='';
          $('phrase').focus();
          room._send(room._username,'has joined!');
        },
        
        _send: function(user,message){
          user=user.replace(':','_');
          if (this._ws)
            this._ws.send(user+':'+message);
        },
      
        chat: function(text) {
          if (text != null && text.length>0 )
              room._send(room._username,text);
        },
        
        _onmessage: function(m) {
          if (m.data){
            var c=m.data.indexOf(':');
            var from=m.data.substring(0,c).replace('<','&lt;').replace('>','&gt;');
            var text=m.data.substring(c+1).replace('<','&lt;').replace('>','&gt;');
            
            var chat=$('chat');
            var spanFrom = document.createElement('span');
            spanFrom.className='from';
            spanFrom.innerHTML=from+':&nbsp;';
            var spanText = document.createElement('span');
            spanText.className='text';
            spanText.innerHTML=text;
            var lineBreak = document.createElement('br');
            chat.appendChild(spanFrom);
            chat.appendChild(spanText);
            chat.appendChild(lineBreak);
            chat.scrollTop = chat.scrollHeight - chat.clientHeight;   
          }
        },
        
        _onclose: function(m) {
          this._ws=null;
          $('join').className='';
          $('joined').className='hidden';
          $('username').focus();
          $('chat').innerHTML='';
        }
        
      };
      
    </script>
    <style type='text/css'>
    div { border: 0px solid black; }
    div#chat { clear: both; width: 40em; height: 20ex; overflow: auto; background-color: #f0f0f0; padding: 4px; border: 1px solid black; }
    div#input { clear: both; width: 40em; padding: 4px; background-color: #e0e0e0; border: 1px solid black; border-top: 0px }
    input#phrase { width:30em; background-color: #e0f0f0; }
    input#username { width:14em; background-color: #e0f0f0; }
    div.hidden { display: none; }
    span.from { font-weight: bold; }
    span.alert { font-style: italic; }
    </style>
 </head><body>
 <div id='chat'></div>
 <div id='input'>
  <div id='join' >
    Username:&nbsp;<input id='username' type='text'/><input id='joinB' class='button' type='submit' name='join' value='Join'/>
  </div>
  <div id='joined' class='hidden'>
    Chat:&nbsp;<input id='phrase' type='text'/>
    <input id='sendB' class='button' type='submit' name='join' value='Send'/>
  </div>
 </div>
 <script type='text/javascript'>
 $('username').setAttribute('autocomplete','OFF');
 $('username').onkeyup = function(ev) { var keyc=getKeyCode(ev); if (keyc==13 || keyc==10) { room.join($F('username')); return false; } return true; } ;        
 $('joinB').onclick = function(event) { room.join($F('username')); return false; };
 $('phrase').setAttribute('autocomplete','OFF');
 $('phrase').onkeyup = function(ev) {   var keyc=getKeyCode(ev); if (keyc==13 || keyc==10) { room.chat($F('phrase')); $('phrase').value=''; return false; } return true; };
 $('sendB').onclick = function(event) { room.chat($F('phrase')); $('phrase').value=''; return false; };
 </script>

 <p>
 This is a demonstration of the Jetty websocket server.
 </p>
 </body></html>
        
        
        
diff --git a/keygen.cmd b/keygen.cmd
 keytool -genkey -alias spdy -keystore spdy.jks -storepass password -keypass password -dname "CN=localhost, OU=spdy, O=example.org, L=Shinjuku-ku, ST=Tokyo, C=JP" -validity 730
diff --git a/SPDY_WS_ON_JETTY9.md b/SPDY_WS_ON_JETTY9.md
diff --git a/SynReplyBodyParser.java b/SynReplyBodyParser.java
 //
 //  ========================================================================
 //  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.spdy.parser;

 import java.nio.ByteBuffer;

 import org.eclipse.jetty.spdy.CompressionFactory;
 import org.eclipse.jetty.spdy.api.ReplyInfo;
 import org.eclipse.jetty.spdy.api.SPDY;
 import org.eclipse.jetty.spdy.frames.ControlFrameType;
 import org.eclipse.jetty.spdy.frames.SynReplyFrame;
 import org.eclipse.jetty.util.Fields;

 public class SynReplyBodyParser extends ControlFrameBodyParser
 {
    private final Fields headers = new Fields();
    private final ControlFrameParser controlFrameParser;
    private final HeadersBlockParser headersBlockParser;
    private State state = State.STREAM_ID;
    private int cursor;
    private int streamId;

    public SynReplyBodyParser(CompressionFactory.Decompressor decompressor, ControlFrameParser controlFrameParser)
    {
        this.controlFrameParser = controlFrameParser;
        this.headersBlockParser = new SynReplyHeadersBlockParser(decompressor);
    }

    @Override
    public boolean parse(ByteBuffer buffer)
    {
        while (buffer.hasRemaining())
        {
            switch (state)
            {
                case STREAM_ID:
                {
                    if (buffer.remaining() >= 4)
                    {
                        streamId = buffer.getInt() & 0x7F_FF_FF_FF;
                        state = State.ADDITIONAL;
                    }
                    else
                    {
                        state = State.STREAM_ID_BYTES;
                        cursor = 4;
                    }
                    break;
                }
                case STREAM_ID_BYTES:
                {
                    byte currByte = buffer.get();
                    --cursor;
                    streamId += (currByte & 0xFF) << 8 * cursor;
                    if (cursor == 0)
                    {
                        streamId &= 0x7F_FF_FF_FF;
                        state = State.ADDITIONAL;
                    }
                    break;
                }
                case ADDITIONAL:
                {
                    switch (controlFrameParser.getVersion())
                    {
                        case SPDY.V2:
                        {
                            if (buffer.remaining() >= 2)
                            {
                                buffer.getShort();
                                state = State.HEADERS;
                            }
                            else
                            {
                                state = State.ADDITIONAL_BYTES;
                                cursor = 2;
                            }
                            break;
                        }
                        case SPDY.V3:
                        {
                            state = State.HEADERS;
                            break;
                        }
                        default:
                        {
                            throw new IllegalStateException();
                        }
                    }
                    break;
                }
                case ADDITIONAL_BYTES:
                {
                    assert controlFrameParser.getVersion() == SPDY.V2;
                    buffer.get();
                    --cursor;
                    if (cursor == 0)
                        state = State.HEADERS;
                    break;
                }
                case HEADERS:
                {
                    short version = controlFrameParser.getVersion();
                    int length = controlFrameParser.getLength() - getSynReplyDataLength(version);
                    if (headersBlockParser.parse(streamId, version, length, buffer))
                    {
                        byte flags = controlFrameParser.getFlags();
                        if (flags != 0 && flags != ReplyInfo.FLAG_CLOSE)
                            throw new IllegalArgumentException("Invalid flag " + flags + " for frame " + ControlFrameType.SYN_REPLY);

                        SynReplyFrame frame = new SynReplyFrame(version, flags, streamId, new Fields(headers, true));
                        controlFrameParser.onControlFrame(frame);

                        reset();
                        return true;
                    }
                    break;
                }
                default:
                {
                    throw new IllegalStateException();
                }
            }
        }
        return false;
    }

    private int getSynReplyDataLength(short version)
    {
        switch (version)
        {
            case 2:
                return 6;
            case 3:
                return 4;
            default:
                throw new IllegalStateException();
        }
    }

    private void reset()
    {
        headers.clear();
        state = State.STREAM_ID;
        cursor = 0;
        streamId = 0;
    }

    private enum State
    {
        STREAM_ID, STREAM_ID_BYTES, ADDITIONAL, ADDITIONAL_BYTES, HEADERS
    }

    private class SynReplyHeadersBlockParser extends HeadersBlockParser
    {
        public SynReplyHeadersBlockParser(CompressionFactory.Decompressor decompressor)
        {
            super(decompressor);
        }

        @Override
        protected void onHeader(String name, String[] values)
        {
            for (String value : values)
                headers.add(name, value);
        }
    }
 }
	<html><head>
	<title>WebSocket Chat</title>
	<script type='text/javascript'>

	if (!window.WebSocket && window.MozWebSocket)
	window.WebSocket=window.MozWebSocket;
	if (!window.WebSocket)
	alert("WebSocket not supported by this browser");

	function $() { return document.getElementById(arguments[0]); }
	function $F() { return document.getElementById(arguments[0]).value; }

	function getKeyCode(ev) { if (window.event) return window.event.keyCode; return ev.keyCode; }

	var room = {
	join: function(name) {
	this._username=name;
	var location = document.location.toString().replace('http://','ws://').replace('https://','wss://');
	this._ws=new WebSocket(location,"echo-broadcast-ping");
	this._ws.onopen=this._onopen;
	this._ws.onmessage=this._onmessage;
	this._ws.onclose=this._onclose;
	},

	_onopen: function(){
	$('join').className='hidden';
	$('joined').className='';
	$('phrase').focus();
	room._send(room._username,'has joined!');
	},

	_send: function(user,message){
	user=user.replace(':','_');
	if (this._ws)
	this._ws.send(user+':'+message);
	},

	chat: function(text) {
	if (text != null && text.length>0 )
	room._send(room._username,text);
	},

	_onmessage: function(m) {
	if (m.data){
	var c=m.data.indexOf(':');
	var from=m.data.substring(0,c).replace('<','<').replace('>','>');
	var text=m.data.substring(c+1).replace('<','<').replace('>','>');

	var chat=$('chat');
	var spanFrom = document.createElement('span');
	spanFrom.className='from';
	spanFrom.innerHTML=from+': ';
	var spanText = document.createElement('span');
	spanText.className='text';
	spanText.innerHTML=text;
	var lineBreak = document.createElement('br');
	chat.appendChild(spanFrom);
	chat.appendChild(spanText);
	chat.appendChild(lineBreak);
	chat.scrollTop = chat.scrollHeight - chat.clientHeight;
	}
	},

	_onclose: function(m) {
	this._ws=null;
	$('join').className='';
	$('joined').className='hidden';
	$('username').focus();
	$('chat').innerHTML='';
	}

	};

	</script>
	<style type='text/css'>
	div { border: 0px solid black; }
	div#chat { clear: both; width: 40em; height: 20ex; overflow: auto; background-color: #f0f0f0; padding: 4px; border: 1px solid black; }
	div#input { clear: both; width: 40em; padding: 4px; background-color: #e0e0e0; border: 1px solid black; border-top: 0px }
	input#phrase { width:30em; background-color: #e0f0f0; }
	input#username { width:14em; background-color: #e0f0f0; }
	div.hidden { display: none; }
	span.from { font-weight: bold; }
	span.alert { font-style: italic; }
	</style>
	</head><body>
	<div id='chat'></div>
	<div id='input'>
	<div id='join' >
	Username: <input id='username' type='text'/><input id='joinB' class='button' type='submit' name='join' value='Join'/>
	</div>
	<div id='joined' class='hidden'>
	Chat: <input id='phrase' type='text'/>
	<input id='sendB' class='button' type='submit' name='join' value='Send'/>
	</div>
	</div>
	<script type='text/javascript'>
	$('username').setAttribute('autocomplete','OFF');
	$('username').onkeyup = function(ev) { var keyc=getKeyCode(ev); if (keyc==13 \|\| keyc==10) { room.join($F('username')); return false; } return true; } ;
	$('joinB').onclick = function(event) { room.join($F('username')); return false; };
	$('phrase').setAttribute('autocomplete','OFF');
	$('phrase').onkeyup = function(ev) { var keyc=getKeyCode(ev); if (keyc==13 \|\| keyc==10) { room.chat($F('phrase')); $('phrase').value=''; return false; } return true; };
	$('sendB').onclick = function(event) { room.chat($F('phrase')); $('phrase').value=''; return false; };
	</script>

	<p>
	This is a demonstration of the Jetty websocket server.
	</p>
	</body></html>
	//
	// ========================================================================
	// 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.spdy.parser;

	import java.nio.ByteBuffer;

	import org.eclipse.jetty.spdy.CompressionFactory;
	import org.eclipse.jetty.spdy.api.ReplyInfo;
	import org.eclipse.jetty.spdy.api.SPDY;
	import org.eclipse.jetty.spdy.frames.ControlFrameType;
	import org.eclipse.jetty.spdy.frames.SynReplyFrame;
	import org.eclipse.jetty.util.Fields;

	public class SynReplyBodyParser extends ControlFrameBodyParser
	{
	private final Fields headers = new Fields();
	private final ControlFrameParser controlFrameParser;
	private final HeadersBlockParser headersBlockParser;
	private State state = State.STREAM_ID;
	private int cursor;
	private int streamId;

	public SynReplyBodyParser(CompressionFactory.Decompressor decompressor, ControlFrameParser controlFrameParser)
	{
	this.controlFrameParser = controlFrameParser;
	this.headersBlockParser = new SynReplyHeadersBlockParser(decompressor);
	}

	@Override
	public boolean parse(ByteBuffer buffer)
	{
	while (buffer.hasRemaining())
	{
	switch (state)
	{
	case STREAM_ID:
	{
	if (buffer.remaining() >= 4)
	{
	streamId = buffer.getInt() & 0x7F_FF_FF_FF;
	state = State.ADDITIONAL;
	}
	else
	{
	state = State.STREAM_ID_BYTES;
	cursor = 4;
	}
	break;
	}
	case STREAM_ID_BYTES:
	{
	byte currByte = buffer.get();
	--cursor;
	streamId += (currByte & 0xFF) << 8 * cursor;
	if (cursor == 0)
	{
	streamId &= 0x7F_FF_FF_FF;
	state = State.ADDITIONAL;
	}
	break;
	}
	case ADDITIONAL:
	{
	switch (controlFrameParser.getVersion())
	{
	case SPDY.V2:
	{
	if (buffer.remaining() >= 2)
	{
	buffer.getShort();
	state = State.HEADERS;
	}
	else
	{
	state = State.ADDITIONAL_BYTES;
	cursor = 2;
	}
	break;
	}
	case SPDY.V3:
	{
	state = State.HEADERS;
	break;
	}
	default:
	{
	throw new IllegalStateException();
	}
	}
	break;
	}
	case ADDITIONAL_BYTES:
	{
	assert controlFrameParser.getVersion() == SPDY.V2;
	buffer.get();
	--cursor;
	if (cursor == 0)
	state = State.HEADERS;
	break;
	}
	case HEADERS:
	{
	short version = controlFrameParser.getVersion();
	int length = controlFrameParser.getLength() - getSynReplyDataLength(version);
	if (headersBlockParser.parse(streamId, version, length, buffer))
	{
	byte flags = controlFrameParser.getFlags();
	if (flags != 0 && flags != ReplyInfo.FLAG_CLOSE)
	throw new IllegalArgumentException("Invalid flag " + flags + " for frame " + ControlFrameType.SYN_REPLY);

	SynReplyFrame frame = new SynReplyFrame(version, flags, streamId, new Fields(headers, true));
	controlFrameParser.onControlFrame(frame);

	reset();
	return true;
	}
	break;
	}
	default:
	{
	throw new IllegalStateException();
	}
	}
	}
	return false;
	}

	private int getSynReplyDataLength(short version)
	{
	switch (version)
	{
	case 2:
	return 6;
	case 3:
	return 4;
	default:
	throw new IllegalStateException();
	}
	}

	private void reset()
	{
	headers.clear();
	state = State.STREAM_ID;
	cursor = 0;
	streamId = 0;
	}

	private enum State
	{
	STREAM_ID, STREAM_ID_BYTES, ADDITIONAL, ADDITIONAL_BYTES, HEADERS
	}

	private class SynReplyHeadersBlockParser extends HeadersBlockParser
	{
	public SynReplyHeadersBlockParser(CompressionFactory.Decompressor decompressor)
	{
	super(decompressor);
	}

	@Override
	protected void onHeader(String name, String[] values)
	{
	for (String value : values)
	headers.add(name, value);
	}
	}
	}