Eclipse/jetty.project
1
0
Fork 0
mirror of https://github.com/jetty/jetty.project.git synced 2025-03-06 05:49:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

switched method to add reason

Browse Source
This commit is contained in:
Jesse McConnell 2012-07-06 17:29:58 -05:00
parent b4cf61bc7d
commit 3797508f8e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
jetty-websocket/websocket-server/src/test/java/org/eclipse/jetty/websocket/server/ab/TestABCase7_9.java
View File

@ -12,6 +12,7 @@ import java.util.concurrent.TimeUnit;
import org.eclipse.jetty.util.BufferUtil; import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.FutureCallback; import org.eclipse.jetty.util.FutureCallback;
import org.eclipse.jetty.util.StringUtil;
import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger; import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.api.WebSocketAdapter; import org.eclipse.jetty.websocket.api.WebSocketAdapter;
@ -174,8 +175,10 @@ public class TestABCase7_9
* Test the requirement of issuing * Test the requirement of issuing
*/ */
@Test @Test
public void testCase7_9_XInvalidCloseStatusCodesWithBuilder() throws Exception public void testCase7_9_XInvalidCloseStatusCodesWithReason() throws Exception
{ {
String reason = "closing time";
BlockheadClient client = new BlockheadClient(server.getServerUri()); BlockheadClient client = new BlockheadClient(server.getServerUri());
try try
{ {
@ -191,12 +194,13 @@ public class TestABCase7_9
// Create Close Frame manually, as we are testing the server's behavior of a bad client. // Create Close Frame manually, as we are testing the server's behavior of a bad client.
buf.put((byte)(0x80 | OpCode.CLOSE.getCode())); buf.put((byte)(0x80 | OpCode.CLOSE.getCode()));
buf.put((byte)(0x80 | 2)); buf.put((byte)(0x80 | 2 + reason.length()));
byte mask[] = new byte[] byte mask[] = new byte[]
{ 0x44, 0x44, 0x44, 0x44 }; { 0x44, 0x44, 0x44, 0x44 };
buf.put(mask); buf.put(mask);
int position = buf.position(); int position = buf.position();
buf.putChar((char)this.invalidStatusCode); buf.putChar((char)this.invalidStatusCode);
buf.put(reason.getBytes(StringUtil.__UTF8_CHARSET));
remask(buf,position,mask); remask(buf,position,mask);
BufferUtil.flipToFlush(buf,0); BufferUtil.flipToFlush(buf,0);
client.writeRaw(buf); client.writeRaw(buf);