Lines Matching refs:peer
59 private final MockSpdyPeer peer = new MockSpdyPeer();
62 peer.close();
67 peer.acceptFrame(); // SYN_STREAM
68 peer.sendFrame()
70 peer.sendFrame().data(true, 1, new Buffer().writeUtf8("robot"), 5);
71 peer.acceptFrame(); // DATA
72 peer.play();
75 SpdyConnection connection = connection(peer, SPDY3);
84 // verify the peer received what was expected
85 MockSpdyPeer.InFrame synStream = peer.takeFrame();
93 MockSpdyPeer.InFrame requestData = peer.takeFrame();
98 peer.acceptFrame(); // SYN_STREAM
99 peer.sendFrame().synReply(false, 1, headerEntries("b", "banana"));
100 peer.acceptFrame(); // PING
101 peer.sendFrame().ping(true, 1, 0);
102 peer.play();
104 SpdyConnection connection = connection(peer, SPDY3);
114 peer.acceptFrame(); // SYN_STREAM
115 peer.acceptFrame(); // PING
116 peer.sendFrame().synReply(true, 1, headerEntries("a", "android"));
117 peer.sendFrame().ping(true, 1, 0);
118 peer.play();
121 SpdyConnection connection = connection(peer, SPDY3);
127 // verify the peer received what was expected
128 MockSpdyPeer.InFrame synStream = peer.takeFrame();
131 MockSpdyPeer.InFrame ping = peer.takeFrame();
145 peer.sendFrame().synStream(false, false, 2, 0, pushHeaders);
146 peer.acceptFrame(); // SYN_REPLY
147 peer.play();
159 new SpdyConnection.Builder(true, peer.openSocket()).handler(handler).build();
161 // verify the peer received what was expected
162 MockSpdyPeer.InFrame reply = peer.takeFrame();
173 peer.sendFrame().synStream(false, false, 2, 0, headerEntries("a", "android"));
174 peer.acceptFrame(); // SYN_REPLY
175 peer.play();
186 connectionBuilder(peer, SPDY3).handler(handler).build();
188 // verify the peer received what was expected
189 MockSpdyPeer.InFrame reply = peer.takeFrame();
199 peer.sendFrame().ping(false, 2, 0);
200 peer.acceptFrame(); // PING
201 peer.play();
204 connection(peer, SPDY3);
206 // verify the peer received what was expected
207 MockSpdyPeer.InFrame ping = peer.takeFrame();
216 peer.acceptFrame(); // PING
217 peer.sendFrame().ping(true, 1, 5); // payload2 ignored in spdy!
218 peer.play();
221 SpdyConnection connection = connection(peer, SPDY3);
226 // verify the peer received what was expected
227 MockSpdyPeer.InFrame pingFrame = peer.takeFrame();
236 peer.sendFrame().ping(false, 2, 0);
237 peer.acceptFrame(); // PING
238 peer.sendFrame().ping(true, 3, 0); // This ping will not be returned.
239 peer.sendFrame().ping(false, 4, 0);
240 peer.acceptFrame(); // PING
241 peer.play();
244 connection(peer, SPDY3);
246 // verify the peer received what was expected
247 MockSpdyPeer.InFrame ping2 = peer.takeFrame();
249 MockSpdyPeer.InFrame ping4 = peer.takeFrame();
257 peer.sendFrame().settings(settings);
258 peer.sendFrame().ping(false, 2, 0);
259 peer.acceptFrame(); // PING
260 peer.play();
263 SpdyConnection connection = connection(peer, SPDY3);
265 peer.takeFrame(); // Guarantees that the peer Settings frame has been processed.
277 peer.sendFrame().settings(settings1);
282 peer.sendFrame().settings(settings2);
283 peer.sendFrame().ping(false, 2, 0);
284 peer.acceptFrame();
285 peer.play();
288 SpdyConnection connection = connection(peer, SPDY3);
290 peer.takeFrame(); // Guarantees that the Settings frame has been processed.
309 peer.sendFrame().settings(settings1);
310 peer.sendFrame().ping(false, 2, 0);
311 peer.acceptFrame();
312 peer.play();
315 SpdyConnection connection = connection(peer, SPDY3);
317 peer.takeFrame(); // Guarantees that the Settings frame has been processed.
334 peer.sendFrame().data(true, 41, new Buffer().writeUtf8("bogus"), 5);
335 peer.acceptFrame(); // RST_STREAM
336 peer.sendFrame().ping(false, 2, 0);
337 peer.acceptFrame(); // PING
338 peer.play();
341 connection(peer, SPDY3);
343 // verify the peer received what was expected
344 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
348 MockSpdyPeer.InFrame ping = peer.takeFrame();
354 peer.sendFrame().synReply(false, 41, headerEntries("a", "android"));
355 peer.acceptFrame(); // RST_STREAM
356 peer.sendFrame().ping(false, 2, 0);
357 peer.acceptFrame(); // PING
358 peer.play();
361 connection(peer, SPDY3);
363 // verify the peer received what was expected
364 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
368 MockSpdyPeer.InFrame ping = peer.takeFrame();
374 peer.acceptFrame(); // SYN_STREAM
375 peer.sendFrame().synReply(false, 1, headerEntries("b", "banana"));
376 peer.acceptFrame(); // TYPE_DATA
377 peer.acceptFrame(); // TYPE_DATA with FLAG_FIN
378 peer.acceptFrame(); // PING
379 peer.sendFrame().ping(true, 1, 0);
380 peer.play();
383 SpdyConnection connection = connection(peer, SPDY3);
399 // verify the peer received what was expected
400 MockSpdyPeer.InFrame synStream = peer.takeFrame();
405 MockSpdyPeer.InFrame data = peer.takeFrame();
409 MockSpdyPeer.InFrame fin = peer.takeFrame();
412 MockSpdyPeer.InFrame ping = peer.takeFrame();
419 peer.acceptFrame(); // SYN_STREAM
420 peer.sendFrame().rstStream(1, CANCEL);
421 peer.acceptFrame(); // PING
422 peer.sendFrame().ping(true, 1, 0);
423 peer.play();
426 SpdyConnection connection = connection(peer, SPDY3);
445 // verify the peer received what was expected
446 MockSpdyPeer.InFrame synStream = peer.takeFrame();
451 MockSpdyPeer.InFrame ping = peer.takeFrame();
462 peer.acceptFrame(); // SYN_STREAM
463 peer.acceptFrame(); // RST_STREAM
464 peer.play();
467 SpdyConnection connection = connection(peer, SPDY3);
487 // verify the peer received what was expected
488 MockSpdyPeer.InFrame synStream = peer.takeFrame();
493 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
504 peer.acceptFrame(); // SYN_STREAM
505 peer.acceptFrame(); // DATA
506 peer.acceptFrame(); // DATA with FLAG_FIN
507 peer.acceptFrame(); // RST_STREAM
508 peer.play();
511 SpdyConnection connection = connection(peer, SPDY3);
527 // verify the peer received what was expected
528 MockSpdyPeer.InFrame synStream = peer.takeFrame();
533 MockSpdyPeer.InFrame data = peer.takeFrame();
536 MockSpdyPeer.InFrame fin = peer.takeFrame();
540 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
547 peer.acceptFrame(); // SYN_STREAM
548 peer.sendFrame().synReply(false, 1, headerEntries("b", "banana"));
549 peer.sendFrame().data(true, 1, new Buffer().writeUtf8("square"), 6);
550 peer.acceptFrame(); // PING
551 peer.sendFrame().ping(true, 1, 0);
552 peer.play();
555 SpdyConnection connection = connection(peer, SPDY3);
562 // verify the peer received what was expected
563 MockSpdyPeer.InFrame synStream = peer.takeFrame();
572 peer.acceptFrame(); // SYN_STREAM
573 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
574 peer.acceptFrame(); // PING
575 peer.sendFrame().synReply(false, 1, headerEntries("b", "banana"));
576 peer.sendFrame().ping(true, 1, 0);
577 peer.acceptFrame(); // RST_STREAM
578 peer.play();
581 SpdyConnection connection = connection(peer, SPDY3);
592 // verify the peer received what was expected
593 MockSpdyPeer.InFrame synStream = peer.takeFrame();
596 MockSpdyPeer.InFrame ping = peer.takeFrame();
598 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
606 peer.sendFrame().synStream(false, false, 2, 0, headerEntries("a", "android"));
607 peer.acceptFrame(); // SYN_REPLY
608 peer.sendFrame().synStream(false, false, 2, 0, headerEntries("b", "banana"));
609 peer.acceptFrame(); // RST_STREAM
610 peer.play();
622 new SpdyConnection.Builder(true, peer.openSocket()).handler(handler).build();
624 // verify the peer received what was expected
625 MockSpdyPeer.InFrame reply = peer.takeFrame();
628 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
637 peer.acceptFrame(); // SYN_STREAM
638 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
639 peer.sendFrame().data(true, 1, new Buffer().writeUtf8("robot"), 5);
640 peer.sendFrame().data(true, 1, new Buffer().writeUtf8("c3po"), 4); // Ignored.
641 peer.sendFrame().ping(false, 2, 0); // Ping just to make sure the stream was fastforwarded.
642 peer.acceptFrame(); // PING
643 peer.play();
646 SpdyConnection connection = connection(peer, SPDY3);
651 // verify the peer received what was expected
652 MockSpdyPeer.InFrame synStream = peer.takeFrame();
655 MockSpdyPeer.InFrame ping = peer.takeFrame();
663 peer.acceptFrame(); // SYN_STREAM
664 peer.sendFrame().synReply(false, 1, headerEntries("b", "banana"));
665 peer.sendFrame().data(false, 1, new Buffer().write(new byte[dataLength]), dataLength);
666 peer.sendFrame().ping(false, 2, 0); // Ping just to make sure the stream was fastforwarded.
667 peer.acceptFrame(); // PING
668 peer.play();
671 SpdyConnection connection = connection(peer, SPDY3);
675 // verify the peer received what was expected
676 MockSpdyPeer.InFrame synStream = peer.takeFrame();
679 MockSpdyPeer.InFrame ping = peer.takeFrame();
686 peer.acceptFrame(); // SYN_STREAM
687 peer.sendFrame().rstStream(1, REFUSED_STREAM);
688 peer.sendFrame().ping(false, 2, 0);
689 peer.acceptFrame(); // PING
690 peer.play();
693 SpdyConnection connection = connection(peer, SPDY3);
703 // verify the peer received what was expected
704 MockSpdyPeer.InFrame synStream = peer.takeFrame();
707 MockSpdyPeer.InFrame ping = peer.takeFrame();
713 peer.setVariantAndClient(SPDY3, false);
716 peer.acceptFrame(); // SYN_STREAM 1
717 peer.acceptFrame(); // SYN_STREAM 3
718 peer.acceptFrame(); // PING.
719 peer.sendFrame().goAway(1, PROTOCOL_ERROR, Util.EMPTY_BYTE_ARRAY);
720 peer.sendFrame().ping(true, 1, 0);
721 peer.acceptFrame(); // DATA STREAM 1
722 peer.play();
725 SpdyConnection connection = connection(peer, SPDY3);
751 // verify the peer received what was expected
752 MockSpdyPeer.InFrame synStream1 = peer.takeFrame();
754 MockSpdyPeer.InFrame synStream2 = peer.takeFrame();
756 MockSpdyPeer.InFrame ping = peer.takeFrame();
758 MockSpdyPeer.InFrame data1 = peer.takeFrame();
766 peer.acceptFrame(); // SYN_STREAM 1
767 peer.acceptFrame(); // GOAWAY
768 peer.acceptFrame(); // PING
769 peer.sendFrame().synStream(false, false, 2, 0, headerEntries("b", "b")); // Should be ignored!
770 peer.sendFrame().ping(true, 1, 0);
771 peer.play();
774 SpdyConnection connection = connection(peer, SPDY3);
779 ping.roundTripTime(); // Prevent the peer from exiting prematurely.
781 // verify the peer received what was expected
782 MockSpdyPeer.InFrame synStream1 = peer.takeFrame();
784 MockSpdyPeer.InFrame pingFrame = peer.takeFrame();
786 MockSpdyPeer.InFrame goaway = peer.takeFrame();
794 peer.acceptFrame(); // GOAWAY
795 peer.play();
798 SpdyConnection connection = connection(peer, SPDY3);
807 // verify the peer received what was expected
808 MockSpdyPeer.InFrame goaway = peer.takeFrame();
815 peer.acceptFrame(); // SYN_STREAM
816 peer.acceptFrame(); // GOAWAY
817 peer.acceptFrame(); // RST_STREAM
818 peer.play();
821 SpdyConnection connection = connection(peer, SPDY3);
847 // verify the peer received what was expected
848 MockSpdyPeer.InFrame synStream = peer.takeFrame();
851 MockSpdyPeer.InFrame goaway = peer.takeFrame();
853 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
860 peer.acceptFrame(); // PING
861 peer.acceptFrame(); // GOAWAY
862 peer.play();
865 SpdyConnection connection = connection(peer, SPDY3);
873 peer.acceptFrame(); // SYN_STREAM
874 peer.acceptFrame(); // RST_STREAM
875 peer.play();
878 SpdyConnection connection = connection(peer, SPDY3);
892 // verify the peer received what was expected
893 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
894 assertEquals(TYPE_RST_STREAM, peer.takeFrame().type);
899 peer.acceptFrame(); // SYN_STREAM
900 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
901 peer.acceptFrame(); // RST_STREAM
902 peer.play();
905 SpdyConnection connection = connection(peer, SPDY3);
920 // verify the peer received what was expected
921 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
922 assertEquals(TYPE_RST_STREAM, peer.takeFrame().type);
926 // Set the peer's receive window to 5 bytes!
930 peer.sendFrame().settings(peerSettings);
931 peer.acceptFrame(); // PING
932 peer.sendFrame().ping(true, 1, 0);
933 peer.acceptFrame(); // SYN_STREAM
934 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
935 peer.acceptFrame(); // DATA
936 peer.acceptFrame(); // RST_STREAM
937 peer.play();
940 SpdyConnection connection = connection(peer, SPDY3);
958 // verify the peer received what was expected
959 assertEquals(TYPE_PING, peer.takeFrame().type);
960 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
961 assertEquals(TYPE_DATA, peer.takeFrame().type);
962 assertEquals(TYPE_RST_STREAM, peer.takeFrame().type);
966 // Set the peer's receive window to 5 bytes. Give the stream 5 bytes back, so only the
971 peer.sendFrame().settings(peerSettings);
972 peer.acceptFrame(); // SYN_STREAM
973 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
974 peer.sendFrame().windowUpdate(1, 5);
975 peer.acceptFrame(); // PING
976 peer.sendFrame().ping(true, 1, 0);
977 peer.acceptFrame(); // DATA
978 peer.acceptFrame(); // RST_STREAM
979 peer.play();
982 SpdyConnection connection = connection(peer, SPDY3);
999 // verify the peer received what was expected
1000 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
1001 assertEquals(TYPE_PING, peer.takeFrame().type);
1002 assertEquals(TYPE_DATA, peer.takeFrame().type);
1003 assertEquals(TYPE_RST_STREAM, peer.takeFrame().type);
1008 peer.acceptFrame(); // SYN_STREAM
1009 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1010 peer.acceptFrame(); // DATA
1011 peer.play();
1014 SpdyConnection connection = connection(peer, SPDY3);
1023 // verify the peer received one incoming frame
1024 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
1025 MockSpdyPeer.InFrame data = peer.takeFrame();
1033 peer.acceptFrame(); // SYN_STREAM
1034 peer.acceptFrame(); // PING
1035 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1036 peer.sendFrame().headers(1, headerEntries("c", "c3po"));
1037 peer.sendFrame().ping(true, 1, 0);
1038 peer.play();
1041 SpdyConnection connection = connection(peer, SPDY3);
1046 // verify the peer received what was expected
1047 MockSpdyPeer.InFrame synStream = peer.takeFrame();
1050 MockSpdyPeer.InFrame ping = peer.takeFrame();
1056 peer.acceptFrame(); // SYN_STREAM
1057 peer.acceptFrame(); // PING
1058 peer.sendFrame().headers(1, headerEntries("c", "c3po"));
1059 peer.acceptFrame(); // RST_STREAM
1060 peer.sendFrame().ping(true, 1, 0);
1061 peer.play();
1064 SpdyConnection connection = connection(peer, SPDY3);
1074 // verify the peer received what was expected
1075 MockSpdyPeer.InFrame synStream = peer.takeFrame();
1078 MockSpdyPeer.InFrame ping = peer.takeFrame();
1080 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
1086 peer.setVariantAndClient(SPDY3, false);
1092 peer.acceptFrame(); // SYN_STREAM
1093 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1096 peer.sendFrame().data(false, 1, data(24), 24);
1097 peer.sendFrame().data(false, 1, data(25), 25);
1098 peer.sendFrame().data(false, 1, data(1), 1);
1099 peer.acceptFrame(); // connection WINDOW UPDATE
1100 peer.acceptFrame(); // stream WINDOW UPDATE
1102 peer.sendFrame().data(true, 1, data(0), 0);
1103 peer.play();
1106 SpdyConnection connection = connection(peer, SPDY3);
1117 MockSpdyPeer.InFrame synStream = peer.takeFrame();
1122 MockSpdyPeer.InFrame windowUpdate = peer.takeFrame();
1137 peer.setVariantAndClient(SPDY3, false);
1140 peer.acceptFrame(); // SYN_STREAM
1141 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1142 peer.sendFrame().data(true, 1, data(0), 0);
1143 peer.play();
1146 SpdyConnection connection = connection(peer, SPDY3);
1150 // Verify the peer received what was expected.
1151 MockSpdyPeer.InFrame synStream = peer.takeFrame();
1153 assertEquals(3, peer.frameCount());
1157 peer.setVariantAndClient(SPDY3, false);
1160 peer.acceptFrame(); // SYN_STREAM
1161 peer.acceptFrame(); // DATA
1162 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1163 peer.play();
1166 SpdyConnection connection = connection(peer, SPDY3);
1173 // Verify the peer received what was expected.
1174 assertEquals(TYPE_HEADERS, peer.takeFrame().type);
1175 assertEquals(TYPE_DATA, peer.takeFrame().type);
1176 assertEquals(3, peer.frameCount());
1181 peer.acceptFrame(); // SYN_STREAM
1182 peer.sendFrame().synReply(false, 1, headerEntries("a", "android"));
1183 peer.sendFrame().data(false, 1, data(1024), 1024);
1184 peer.truncateLastFrame(8 + 100);
1185 peer.play();
1188 SpdyConnection connection = connection(peer, SPDY3);
1201 int framesThatFillWindow = roundUp(DEFAULT_INITIAL_WINDOW_SIZE, peer.maxOutboundDataLength());
1204 peer.acceptFrame(); // SYN_STREAM on stream 1
1206 peer.acceptFrame(); // DATA on stream 1
1208 peer.acceptFrame(); // SYN_STREAM on stream 2
1209 peer.acceptFrame(); // DATA on stream 2
1210 peer.play();
1213 SpdyConnection connection = connection(peer, SPDY3);
1294 peer.acceptFrame(); // SYN_STREAM
1297 peer.sendFrame(trailingCompressedBytes);
1298 peer.sendFrame().data(true, 1, new Buffer().writeUtf8("robot"), 5);
1299 peer.acceptFrame(); // DATA
1300 peer.play();
1303 SpdyConnection connection = connection(peer, SPDY3);
1310 private SpdyConnection connection(MockSpdyPeer peer, Variant variant) throws IOException {
1311 return connectionBuilder(peer, variant).build();
1314 private SpdyConnection.Builder connectionBuilder(MockSpdyPeer peer, Variant variant)
1316 return new SpdyConnection.Builder(true, peer.openSocket())