jdk-sandbox: test/jdk/java/net/httpclient/websocket/AutomaticPong.java@3a79d4cccbcb (annotated)

49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	1	/*
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	2	* Copyright (c) 2018, 2019, Oracle and/or its affiliates. All rights reserved.
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	3	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	4	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	5	* This code is free software; you can redistribute it and/or modify it
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	6	* under the terms of the GNU General Public License version 2 only, as
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	7	* published by the Free Software Foundation.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	8	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	9	* This code is distributed in the hope that it will be useful, but WITHOUT
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	12	* version 2 for more details (a copy is included in the LICENSE file that
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	13	* accompanied this code).
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	14	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	15	* You should have received a copy of the GNU General Public License version
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	16	* 2 along with this work; if not, write to the Free Software Foundation,
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	17	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	18	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	19	* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	20	* or visit www.oracle.com if you need additional information or have any
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	21	* questions.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	22	*/
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	23
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	24	/*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	25	* @test
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	26	* @build DummyWebSocketServer
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	27	* @run testng/othervm
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	28	* -Djdk.internal.httpclient.websocket.debug=true
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	29	* AutomaticPong
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	30	*/
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	31	import org.testng.annotations.DataProvider;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	32	import org.testng.annotations.Test;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	33
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	34	import java.io.IOException;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	35	import java.net.http.WebSocket;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	36	import java.nio.ByteBuffer;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	37	import java.nio.charset.StandardCharsets;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	38	import java.util.List;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	39
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	40	import static java.net.http.HttpClient.newHttpClient;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	41	import static org.testng.Assert.assertEquals;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	42	import static org.testng.Assert.assertFalse;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	43	import static org.testng.Assert.assertTrue;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	44	import static org.testng.Assert.fail;
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	45
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	46	public class AutomaticPong {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	47	/*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	48	* The sendClose method has been invoked and a Ping comes from the server.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	49	* Naturally, the client cannot reply with a Pong (the output has been
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	50	* closed). However, this MUST not be treated as an error.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	51	* At this stage the server either has received or pretty soon will receive
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	52	* the Close message sent by the sendClose. Thus, the server will know the
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	53	* client cannot send further messages and it's up to the server to decide
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	54	* how to react on the corresponding Pong not being received.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	55	*/
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	56	@Test
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	57	public void sendCloseThenAutomaticPong() throws IOException {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	58	int[] bytes = {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	59	0x89, 0x00, // ping
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	60	0x89, 0x06, 0x68, 0x65, 0x6c, 0x6c, 0x6f, 0x3f, // ping hello?
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	61	0x88, 0x00, // close
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	62	};
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	63	try (var server = Support.serverWithCannedData(bytes)) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	64	server.open();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	65	MockListener listener = new MockListener() {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	66	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	67	protected void onOpen0(WebSocket webSocket) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	68	/* request nothing */
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	69	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	70	};
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	71	var webSocket = newHttpClient()
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	72	.newWebSocketBuilder()
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	73	.buildAsync(server.getURI(), listener)
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	74	.join();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	75	try {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	76	webSocket.sendClose(WebSocket.NORMAL_CLOSURE, "ok").join();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	77	// now request all messages available
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	78	webSocket.request(Long.MAX_VALUE);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	79	List<MockListener.Invocation> actual = listener.invocations();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	80	ByteBuffer hello = ByteBuffer.wrap("hello?".getBytes(StandardCharsets.UTF_8));
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	81	ByteBuffer empty = ByteBuffer.allocate(0);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	82	List<MockListener.Invocation> expected = List.of(
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	83	MockListener.Invocation.onOpen(webSocket),
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	84	MockListener.Invocation.onPing(webSocket, empty),
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	85	MockListener.Invocation.onPing(webSocket, hello),
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	86	MockListener.Invocation.onClose(webSocket, 1005, "")
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	87	);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	88	assertEquals(actual, expected);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	89	} finally {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	90	webSocket.abort();
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	91	}
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	92	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	93	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	94
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	95	/*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	96	* The server sends a number of contiguous Ping messages. The client replies
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	97	* to these messages automatically. According to RFC 6455 a WebSocket client
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	98	* is free to reply only to the most recent Pings.
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	99	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	100	* What is checked here is that:
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	101	*
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	102	* a) the order of Pong replies corresponds to the Pings received,
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	103	* b) the last Pong corresponds to the last Ping
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	104	* c) there are no unrelated Pongs
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	105	*/
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	106	@Test(dataProvider = "nPings")
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	107	public void automaticPongs(int nPings) throws Exception {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	108	// big enough to not bother with resize
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	109	ByteBuffer buffer = ByteBuffer.allocate(65536);
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	110	Frame.HeaderWriter w = new Frame.HeaderWriter();
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	111	for (int i = 0; i < nPings; i++) {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	112	w.fin(true)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	113	.opcode(Frame.Opcode.PING)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	114	.noMask()
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	115	.payloadLen(4) // the length of the number of the Ping (int)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	116	.write(buffer);
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	117	buffer.putInt(i); // the number of the Ping (int)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	118	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	119	w.fin(true)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	120	.opcode(Frame.Opcode.CLOSE)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	121	.noMask()
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	122	.payloadLen(2)
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	123	.write(buffer);
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	124	buffer.putChar((char) 1000);
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	125	buffer.flip();
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	126	try (var server = Support.serverWithCannedData(buffer.array())) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	127	server.open();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	128	MockListener listener = new MockListener();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	129	var webSocket = newHttpClient()
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	130	.newWebSocketBuilder()
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	131	.buildAsync(server.getURI(), listener)
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	132	.join();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	133	try {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	134	List<MockListener.Invocation> inv = listener.invocations();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	135	assertEquals(inv.size(), nPings + 2); // n * onPing + onOpen + onClose
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	136
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	137	ByteBuffer data = server.read();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	138	Frame.Reader reader = new Frame.Reader();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	139
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	140	Frame.Consumer consumer = new Frame.Consumer() {
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	141
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	142	ByteBuffer number = ByteBuffer.allocate(4);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	143	Frame.Masker masker = new Frame.Masker();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	144	int i = -1;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	145	boolean closed;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	146
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	147	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	148	public void fin(boolean value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	149	assertTrue(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	150	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	151
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	152	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	153	public void rsv1(boolean value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	154	assertFalse(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	155	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	156
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	157	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	158	public void rsv2(boolean value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	159	assertFalse(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	160	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	161
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	162	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	163	public void rsv3(boolean value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	164	assertFalse(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	165	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	166
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	167	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	168	public void opcode(Frame.Opcode value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	169	if (value == Frame.Opcode.CLOSE) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	170	closed = true;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	171	return;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	172	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	173	assertEquals(value, Frame.Opcode.PONG);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	174	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	175
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	176	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	177	public void mask(boolean value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	178	assertTrue(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	179	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	180
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	181	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	182	public void payloadLen(long value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	183	if (!closed)
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	184	assertEquals(value, 4);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	185	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	186
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	187	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	188	public void maskingKey(int value) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	189	masker.mask(value);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	190	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	191
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	192	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	193	public void payloadData(ByteBuffer src) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	194	masker.transferMasking(src, number);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	195	if (closed) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	196	return;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	197	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	198	number.flip();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	199	int n = number.getInt();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	200	System.out.printf("pong number=%s%n", n);
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	201	number.clear();
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	202	// a Pong with the number less than the maximum of Pongs already
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	203	// received MUST never be received
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	204	if (i >= n) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	205	fail(String.format("i=%s, n=%s", i, n));
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	206	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	207	i = n;
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	208	}
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	209
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	210	@Override
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	211	public void endFrame() {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	212	}
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	213	};
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	214	while (data.hasRemaining()) {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	215	reader.readFrame(data, consumer);
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	216	}
58289 3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	217	} finally {
3a79d4cccbcb 8217825: Verify @AfterTest is used correctly in WebSocket tests pconcannon parents: 49765 diff changeset	218	webSocket.abort();
49765 ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	219	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	220	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	221	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	222
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	223
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	224	@DataProvider(name = "nPings")
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	225	public Object[][] nPings() {
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	226	return new Object[][]{{1}, {2}, {4}, {8}, {9}, {256}};
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	227	}
ee6f7a61f3a5 8197564: HTTP Client implementation chegar parents: diff changeset	228	}

author	pconcannon
	Mon, 23 Sep 2019 16:53:16 +0100
changeset 58289	3a79d4cccbcb
parent 49765	ee6f7a61f3a5
permissions	-rw-r--r--