Lines Matching refs:peer
50 private final MockSpdyPeer peer = new MockSpdyPeer();
53 peer.close();
57 peer.setVariantAndClient(HTTP_2, false);
60 peer.sendFrame().ping(false, 2, 3);
61 peer.acceptFrame(); // PING
62 peer.play();
65 connection(peer, HTTP_2);
67 // verify the peer received what was expected
68 MockSpdyPeer.InFrame ping = peer.takeFrame();
77 peer.setVariantAndClient(HTTP_2, false);
80 peer.acceptFrame(); // PING
81 peer.sendFrame().ping(true, 1, 5);
82 peer.play();
85 SpdyConnection connection = connection(peer, HTTP_2);
90 // verify the peer received what was expected
91 MockSpdyPeer.InFrame pingFrame = peer.takeFrame();
99 peer.setVariantAndClient(HTTP_2, false);
106 peer.sendFrame().settings(initial);
107 peer.acceptFrame(); // ACK
108 peer.sendFrame().settings(shouldntImpactConnection);
109 peer.acceptFrame(); // ACK 2
110 peer.acceptFrame(); // HEADERS
111 peer.play();
113 SpdyConnection connection = connection(peer, HTTP_2);
118 // Verify the peer received the ACK.
119 MockSpdyPeer.InFrame ackFrame = peer.takeFrame();
123 ackFrame = peer.takeFrame();
144 // verify the peer's settings were read and applied.
154 settings.set(Settings.ENABLE_PUSH, 0, 0); // The peer client disables push.
158 // verify the peer's settings were read and applied.
169 // verify the peer's settings were read and applied.
175 peer.setVariantAndClient(HTTP_2, false);
178 peer.acceptFrame(); // SYN_STREAM 3
179 peer.acceptFrame(); // SYN_STREAM 5
180 peer.sendFrame().goAway(3, PROTOCOL_ERROR, Util.EMPTY_BYTE_ARRAY);
181 peer.acceptFrame(); // PING
182 peer.sendFrame().ping(true, 1, 0);
183 peer.acceptFrame(); // DATA STREAM 3
184 peer.play();
187 SpdyConnection connection = connection(peer, HTTP_2);
213 // verify the peer received what was expected
214 MockSpdyPeer.InFrame synStream1 = peer.takeFrame();
216 MockSpdyPeer.InFrame synStream2 = peer.takeFrame();
218 MockSpdyPeer.InFrame ping = peer.takeFrame();
220 MockSpdyPeer.InFrame data1 = peer.takeFrame();
227 peer.setVariantAndClient(HTTP_2, false);
233 peer.acceptFrame(); // SYN_STREAM
234 peer.sendFrame().synReply(false, 3, headerEntries("a", "android"));
237 peer.sendFrame().data(false, 3, data(24), 24);
238 peer.sendFrame().data(false, 3, data(25), 25);
239 peer.sendFrame().data(false, 3, data(1), 1);
240 peer.acceptFrame(); // connection WINDOW UPDATE
241 peer.acceptFrame(); // stream WINDOW UPDATE
243 peer.sendFrame().data(true, 3, data(0), 0);
244 peer.play();
247 SpdyConnection connection = connection(peer, HTTP_2);
258 MockSpdyPeer.InFrame synStream = peer.takeFrame();
263 MockSpdyPeer.InFrame windowUpdate = peer.takeFrame();
278 peer.setVariantAndClient(HTTP_2, false);
281 peer.acceptFrame(); // SYN_STREAM
282 peer.sendFrame().synReply(false, 3, headerEntries("a", "android"));
283 peer.sendFrame().data(true, 3, data(0), 0);
284 peer.play();
287 SpdyConnection connection = connection(peer, HTTP_2);
291 // Verify the peer received what was expected.
292 MockSpdyPeer.InFrame synStream = peer.takeFrame();
294 assertEquals(3, peer.frameCount());
298 peer.setVariantAndClient(HTTP_2, false);
301 peer.acceptFrame(); // SYN_STREAM
302 peer.acceptFrame(); // DATA
303 peer.sendFrame().synReply(false, 3, headerEntries("a", "android"));
304 peer.play();
307 SpdyConnection connection = connection(peer, HTTP_2);
314 // Verify the peer received what was expected.
315 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
316 assertEquals(TYPE_DATA, peer.takeFrame().type);
317 assertEquals(3, peer.frameCount());
321 peer.setVariantAndClient(HTTP_2, false);
323 byte[] buff = new byte[peer.maxOutboundDataLength() + 1];
327 peer.acceptFrame(); // SYN_STREAM
328 peer.sendFrame().synReply(false, 3, headerEntries("a", "android"));
329 peer.acceptFrame(); // DATA
330 peer.acceptFrame(); // DATA
331 peer.play();
334 SpdyConnection connection = connection(peer, HTTP_2);
341 MockSpdyPeer.InFrame synStream = peer.takeFrame();
343 MockSpdyPeer.InFrame data = peer.takeFrame();
344 assertEquals(peer.maxOutboundDataLength(), data.data.length);
345 data = peer.takeFrame();
350 peer.setVariantAndClient(HTTP_2, false);
353 peer.acceptFrame(); // SYN_STREAM
354 peer.sendFrame().synReply(false, 3, headerEntries("a", "android"));
361 peer.sendFrame().pushPromise(3, 2, expectedRequestHeaders);
365 peer.sendFrame().synReply(true, 2, expectedResponseHeaders);
366 peer.sendFrame().data(true, 3, data(0), 0);
367 peer.play();
372 SpdyConnection connection = connectionBuilder(peer, HTTP_2)
377 // verify the peer received what was expected
378 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
385 peer.setVariantAndClient(HTTP_2, false);
388 peer.sendFrame().pushPromise(3, 2, headerEntries("a", "android"));
389 peer.acceptFrame(); // SYN_REPLY
390 peer.sendFrame().pushPromise(3, 2, headerEntries("b", "banana"));
391 peer.acceptFrame(); // RST_STREAM
392 peer.play();
395 SpdyConnection connection = connectionBuilder(peer, HTTP_2).build();
398 // verify the peer received what was expected
399 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
400 assertEquals(PROTOCOL_ERROR, peer.takeFrame().errorCode);
404 peer.setVariantAndClient(HTTP_2, false);
407 peer.sendFrame().pushPromise(3, 2, Arrays.asList(
413 peer.sendFrame().synReply(true, 2, Arrays.asList(
416 peer.acceptFrame(); // RST_STREAM
417 peer.play();
420 connectionBuilder(peer, HTTP_2)
423 // verify the peer received what was expected
424 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
432 peer.setVariantAndClient(HTTP_2, client);
433 peer.sendFrame().settings(settings);
434 peer.acceptFrame(); // ACK
435 peer.acceptFrame(); // PING
436 peer.sendFrame().ping(true, 1, 0);
437 peer.play();
440 SpdyConnection connection = connection(peer, HTTP_2);
442 // verify the peer received the ACK
443 MockSpdyPeer.InFrame ackFrame = peer.takeFrame();
452 private SpdyConnection connection(MockSpdyPeer peer, Variant variant) throws IOException {
453 return connectionBuilder(peer, variant).build();
456 private SpdyConnection.Builder connectionBuilder(MockSpdyPeer peer, Variant variant)
458 return new SpdyConnection.Builder(true, peer.openSocket())