Adding TooFastClientTest for websocket server

+ test performs a client upgrade + 2 websocket frames all at once.
  not waiting for the upgrade response before sending those frames.
+ currently set to @ignore until we can address how to copy this extra
  buffer information from the Http side to the WebSocket side.

jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/Generator.java

@@ -344,10 +344,12 @@ else if (payloadLength >= 0x7E)
     /**
      * Generate the whole frame (header + payload copy) into a single ByteBuffer.
      * <p>
-     * Note: THIS IS SLOW. Only use this if you must.
+     * Note: This is slow, moves lots of memory around. Only use this if you must (such as in unit testing).
      * 
      * @param frame
      *            the frame to generate
+     * @param buf
+     *            the buffer to output the generated frame to
      */
     public void generateWholeFrame(Frame frame, ByteBuffer buf)
     {

jetty-websocket/websocket-common/src/test/java/org/eclipse/jetty/websocket/common/test/BlockheadClient.java

@@ -627,6 +627,12 @@ else if (len > 0)
     }
 
     public void sendStandardRequest() throws IOException
+    {
+        StringBuilder req = generateUpgradeRequest();
+        writeRaw(req.toString());
+    }
+
+    public StringBuilder generateUpgradeRequest()
     {
         StringBuilder req = new StringBuilder();
         req.append("GET ").append(getRequestPath()).append(" HTTP/1.1\r\n");
@@ -651,7 +657,7 @@ public void sendStandardRequest() throws IOException
         }
         req.append("Sec-WebSocket-Version: ").append(version).append("\r\n");
         req.append("\r\n");
-        writeRaw(req.toString());
+        return req;
     }
 
     public void setConnectionValue(String connectionValue)

jetty-websocket/websocket-server/src/test/java/org/eclipse/jetty/websocket/server/TooFastClientTest.java

@@ -0,0 +1,112 @@
+//
+//  ========================================================================
+//  Copyright (c) 1995-2015 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.server;
+
+import static org.hamcrest.Matchers.*;
+
+import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
+import java.util.concurrent.TimeUnit;
+
+import org.eclipse.jetty.io.MappedByteBufferPool;
+import org.eclipse.jetty.toolchain.test.EventQueue;
+import org.eclipse.jetty.util.BufferUtil;
+import org.eclipse.jetty.websocket.api.WebSocketPolicy;
+import org.eclipse.jetty.websocket.common.Generator;
+import org.eclipse.jetty.websocket.common.WebSocketFrame;
+import org.eclipse.jetty.websocket.common.frames.TextFrame;
+import org.eclipse.jetty.websocket.common.test.BlockheadClient;
+import org.eclipse.jetty.websocket.common.test.LeakTrackingBufferPool;
+import org.eclipse.jetty.websocket.server.examples.MyEchoServlet;
+import org.junit.AfterClass;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Ignore;
+import org.junit.Test;
+
+/**
+ * Test simulating a client that talks too quickly.
+ * <p>
+ * There is a class of client that will send the GET+Upgrade Request along with a few websocket frames in a single
+ * network packet. This test attempts to perform this behavior as close as possible.
+ */
+@Ignore
+public class TooFastClientTest
+{
+    private static SimpleServletServer server;
+
+    @BeforeClass
+    public static void startServer() throws Exception
+    {
+        server = new SimpleServletServer(new MyEchoServlet());
+        server.start();
+    }
+
+    @AfterClass
+    public static void stopServer()
+    {
+        server.stop();
+    }
+
+    @Test
+    public void testUpgradeWithWebkitDeflateExtension() throws Exception
+    {
+        BlockheadClient client = new BlockheadClient(server.getServerUri());
+        try
+        {
+            client.connect();
+
+            // Create ByteBuffer representing the initial opening network packet from the client
+            ByteBuffer initialPacket = ByteBuffer.allocate(4096);
+            BufferUtil.clearToFill(initialPacket);
+
+            // Add upgrade request to packet
+            StringBuilder upgradeRequest = client.generateUpgradeRequest();
+            ByteBuffer upgradeBuffer = BufferUtil.toBuffer(upgradeRequest.toString(),StandardCharsets.UTF_8);
+            initialPacket.put(upgradeBuffer);
+
+            // Add text frames
+            Generator generator = new Generator(WebSocketPolicy.newClientPolicy(),
+                    new LeakTrackingBufferPool("Generator",new MappedByteBufferPool()));
+            String msg1 = "Echo 1";
+            String msg2 = "This is also an echo ... cho ... ho ... o";
+
+            generator.generateWholeFrame(new TextFrame().setPayload(msg1),initialPacket);
+            generator.generateWholeFrame(new TextFrame().setPayload(msg2),initialPacket);
+
+            // Write packet to network
+            BufferUtil.flipToFlush(initialPacket,0);
+            client.writeRaw(initialPacket);
+
+            // Expect upgrade
+            client.expectUpgradeResponse();
+
+            // Read frames (hopefully text frames)
+            EventQueue<WebSocketFrame> frames = client.readFrames(2,1,TimeUnit.SECONDS);
+            WebSocketFrame tf = frames.poll();
+            Assert.assertThat("Text Frame/msg1",tf.getPayloadAsUTF8(),is(msg1));
+            tf = frames.poll();
+            Assert.assertThat("Text Frame/msg2",tf.getPayloadAsUTF8(),is(msg2));
+        }
+        finally
+        {
+            client.close();
+        }
+    }
+}